调整：链路追踪增加高度中心的Data参数保存

farseer-go · Jan 10, 2024 · aca7a32 · aca7a32
1 parent 2f3fb17
commit aca7a32
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/traceManager.go b/traceManager.go
@@ -213,7 +213,7 @@ func (*traceManager) EntryFSchedule(taskGroupName string, taskId int64, data map
 			TaskName:      taskGroupName,
 			TaskGroupName: taskGroupName,
 			TaskId:        taskId,
-			Data:          data,
+			TaskData:      collections.NewDictionaryFromMap(data),
 		},
 	}
 	trace.CurTraceContext.Set(context)

diff --git a/trackContext.go b/trackContext.go
@@ -61,10 +61,10 @@ func (receiver ConsumerContext) IsNil() bool {
 }
 
 type TaskContext struct {
-	TaskName      string            // 任务名称
-	TaskGroupName string            // 任务组ID
-	TaskId        int64             // 任务ID
-	Data          map[string]string // 任务数据
+	TaskName      string                                 // 任务名称
+	TaskGroupName string                                 // 任务组ID
+	TaskId        int64                                  // 任务ID
+	TaskData      collections.Dictionary[string, string] // 任务数据
 }
 
 func (receiver TaskContext) IsNil() bool {