新增：调度中心使用的链路入口

farseer-go · Dec 28, 2023 · bce9e75 · bce9e75
1 parent fc25b07
commit bce9e75
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/trace/emptyManager.go b/trace/emptyManager.go
@@ -22,6 +22,9 @@ func (m *EmptyManager) EntryTask(taskName string) ITraceContext {
 func (m *EmptyManager) EntryFSchedule(taskGroupName string, taskGroupId int64, taskId int64) ITraceContext {
 	return &emptyTraceContext{}
 }
+func (*EmptyManager) EntryTaskGroup(taskName string, taskGroupName string, taskGroupId int64, taskId int64) ITraceContext {
+	return &emptyTraceContext{}
+}
 
 func (m *EmptyManager) EntryWatchKey(key string) ITraceContext { return &emptyTraceContext{} }
 func (m *EmptyManager) TraceMq(method string, server string, exchange string) ITraceDetail {

diff --git a/trace/iManager.go b/trace/iManager.go
@@ -31,6 +31,8 @@ type IManager interface {
 	TraceHttp(method string, url string) ITraceDetail
 	// EntryTask 创建本地任务入口
 	EntryTask(taskName string) ITraceContext
+	// EntryTask 创建本地任务入口（调度中心专用）
+	EntryTaskGroup(taskName string, taskGroupName string, taskGroupId int64, taskId int64) ITraceContext
 	// EntryFSchedule 创建调度中心入口
 	EntryFSchedule(taskGroupName string, taskGroupId int64, taskId int64) ITraceContext
 	// EntryWatchKey 创建etcd入口