新增：etcd的链路追踪入口

eumTraceType/enum.go

@@ -8,4 +8,5 @@ const (
 	QueueConsumer             // 本地消费
 	FSchedule                 // 调度中心
 	Task                      // 本地任务
+	WatchKey                  // ETCD
 )

traceManager.go

@@ -195,7 +195,7 @@ func (*traceManager) EntryFSchedule(taskGroupName string, taskGroupId int64, tas
 		ParentAppName: "",
 		TraceId:       traceId,
 		StartTs:       time.Now().UnixMicro(),
-		TraceType:     eumTraceType.Task,
+		TraceType:     eumTraceType.FSchedule,
 		Task: TaskContext{
 			TaskName:    taskGroupName,
 			TaskGroupId: taskGroupId,
@@ -207,6 +207,26 @@ func (*traceManager) EntryFSchedule(taskGroupName string, taskGroupId int64, tas
 	return context
 }
 
+// EntryWatchKey 创建etcd入口
+func (*traceManager) EntryWatchKey(key string) trace.ITraceContext {
+	traceId := snowflake.GenerateId()
+	context := &TraceContext{
+		AppId:         fs.AppId,
+		AppName:       fs.AppName,
+		AppIp:         fs.AppIp,
+		ParentAppName: "",
+		TraceId:       traceId,
+		StartTs:       time.Now().UnixMicro(),
+		TraceType:     eumTraceType.WatchKey,
+		WatchKey: WatchKeyContext{
+			Key: key,
+		},
+		List: collections.NewList[trace.ITraceDetail](),
+	}
+	curTraceContext.Set(context)
+	return context
+}
+
 // TraceMq open、create埋点
 func (*traceManager) TraceMq(method string, server string, exchange string) trace.ITraceDetail {
 	detail := &TraceDetailMq{

trackContext.go

@@ -28,6 +28,7 @@ type TraceContext struct {
 	Web              WebContext
 	Consumer         ConsumerContext
 	Task             TaskContext
+	WatchKey         WatchKeyContext
 }
 
 type WebContext struct {
@@ -52,6 +53,9 @@ type TaskContext struct {
 	TaskGroupId int64
 	TaskId      int64
 }
+type WatchKeyContext struct {
+	Key string
+}
 
 func (receiver *TraceContext) SetBody(requestBody string, statusCode int, responseBody string) {
 	receiver.Web.RequestBody = requestBody