trace

type ConsumerContext struct {
	ConsumerServer     string `json:"cs"` // MQ服务器
	ConsumerQueueName  string `json:"cq"` // 队列名称
	ConsumerRoutingKey string `json:"cr"` // 路由KEY
}

type EmptyManager struct {
}

type ExceptionStack struct {
	ExceptionIsException bool                   // 是否执行异常
	ExceptionMessage     string                 // 异常信息
	ExceptionDetails     []ExceptionStackDetail // 异常详情
}

type ExceptionStackDetail struct {
	ExceptionCallFile     string // 调用者文件路径
	ExceptionCallLine     int    // 调用者行号
	ExceptionCallFuncName string // 调用者函数名称
}

type IManager interface {
	// EntryWebApi 创建webapi的链路追踪入口
	EntryWebApi(domain string, path string, method string, contentType string, headerDictionary map[string]string, requestIp string) *TraceContext
	// EntryWebSocket 创建WebSocket的链路追踪入口
	EntryWebSocket(domain string, path string, headerDictionary map[string]string, requestIp string) *TraceContext
	// EntryMqConsumer 创建MQ消费入口
	EntryMqConsumer(parentTraceId, parentAppName, server string, queueName string, routingKey string) *TraceContext
	// EntryQueueConsumer 创建Queue消费入口
	EntryQueueConsumer(queueName, subscribeName string) *TraceContext
	// EntryEventConsumer 创建Event消费入口
	EntryEventConsumer(server, eventName, subscribeName string) *TraceContext
	// EntryTask 创建本地任务入口
	EntryTask(taskName string) *TraceContext
	// EntryTaskGroup 创建本地任务入口（调度中心专用）
	EntryTaskGroup(taskName string, taskGroupName string, taskId int64) *TraceContext
	// EntryFSchedule 创建调度中心入口
	EntryFSchedule(taskGroupName string, taskId int64, data map[string]string) *TraceContext
	// EntryWatchKey 创建etcd入口
	EntryWatchKey(key string) *TraceContext

	// TraceDatabaseOpen 数据库埋点
	TraceDatabaseOpen(dbName string, connectString string) *TraceDetail
	// TraceDatabase 数据库埋点
	TraceDatabase() *TraceDetail
	// TraceElasticsearch Elasticsearch埋点
	TraceElasticsearch(method string, IndexName string, AliasesName string) *TraceDetail
	// TraceEtcd etcd埋点
	TraceEtcd(method string, key string, leaseID int64) *TraceDetail
	// TraceHand 手动埋点
	TraceHand(name string) *TraceDetail
	// TraceEventPublish 事件发布
	TraceEventPublish(eventName string) *TraceDetail
	// TraceMqSend send埋点
	TraceMqSend(method string, server string, exchange string, routingKey string) *TraceDetail
	// TraceMq open、create埋点
	TraceMq(method string, server string, exchange string) *TraceDetail
	// TraceRedis Redis埋点
	TraceRedis(method string, key string, field string) *TraceDetail
	// TraceHttp http埋点
	TraceHttp(method string, url string) *TraceDetail
	// 推送到队列
	Push(traceContext *TraceContext, err error)
}

type TaskContext struct {
	TaskName      string            `json:"tn"`  // 任务名称
	TaskGroupName string            `json:"tgn"` // 任务组ID
	TaskId        int64             `json:"tid"` // 任务ID
	TaskData      map[string]string `json:"td"`  // 任务数据
}

type TraceContext struct {
	TraceId       string            `json:"tid"` // 上下文ID
	AppId         string            `json:"aid"` // 应用ID
	AppName       string            `json:"an"`  // 应用名称
	AppIp         string            `json:"aip"` // 应用IP
	ParentAppName string            `json:"pn"`  // 上游应用
	TraceLevel    int               `json:"tl"`  // 逐层递增（显示上下游顺序）
	StartTs       int64             `json:"st"`  // 调用开始时间戳（微秒）
	EndTs         int64             `json:"et"`  // 调用结束时间戳（微秒）
	UseTs         time.Duration     `json:"ut"`  // 总共使用时间（微秒）
	UseDesc       string            `json:"ud"`  // 总共使用时间（描述）
	TraceType     eumTraceType.Enum `json:"tt"`  // 状态码
	List          []*TraceDetail    `json:"l"`   // 调用的上下文trace.TraceDetail
	TraceCount    int               `json:"tc"`  // 追踪明细数量

	Exception *ExceptionStack `json:"e"` // 异常信息
	WebContext
	ConsumerContext
	TaskContext
	WatchKeyContext
	CreateAt dateTime.DateTime `json:"ca"` // 请求时间
	// contains filtered or unexported fields
}

type TraceDetail struct {
	// TraceId    string // 上下文ID
	// AppId          string            // 应用ID
	// AppName        string            // 应用名称
	// AppIp          string            // 应用IP
	// ParentAppName  string            // 上游应用
	TraceLevel     int              // 逐层递增（显示上下游顺序）
	DetailId       string           // 明细ID
	ParentDetailId string           // 父级明细ID
	Level          int              // 当前层级（入口为0层）
	Comment        string           // 调用注释
	MethodName     string           // 调用方法
	CallType       eumCallType.Enum // 调用类型
	Timeline       time.Duration    // 从入口开始统计（微秒）
	UnTraceTs      time.Duration    // 上一次结束到现在开始之间未Trace的时间（微秒）
	StartTs        int64            // 调用开始时间戳（微秒）
	EndTs          int64            // 调用停止时间戳（微秒）

	Exception *ExceptionStack   // 异常信息
	CreateAt  dateTime.DateTime // 请求时间
	TraceDetailHand
	TraceDetailDatabase
	TraceDetailEs
	TraceDetailEtcd
	TraceDetailEvent
	TraceDetailGrpc
	TraceDetailHttp
	TraceDetailMq
	TraceDetailRedis
	// contains filtered or unexported fields
}

type TraceDetailDatabase struct {
	DbName             string // 数据库名
	DbTableName        string // 表名
	DbSql              string // SQL
	DbConnectionString string // 连接字符串
	DbRowsAffected     int64  // 影响行数
}

type TraceDetailEs struct {
	EsIndexName   string // 索引名称
	EsAliasesName string // 别名
}

type TraceDetailEtcd struct {
	EtcdKey     string // key
	EtcdLeaseID int64
}

type TraceDetailEvent struct {
	EventName string
}

type TraceDetailGrpc struct {
	GrpcMethod          string            // post/get/put/delete
	GrpcUrl             string            // url
	GrpcHeaders         map[string]string // 头部
	GrpcRequestBody     string            // 入参
	GrpcResponseBody    string            // 出参
	GrpcResponseHeaders map[string]string // 响应头部
	GrpcStatusCode      int               // 状态码
}

type TraceDetailHand struct {
	HandName string
}

type TraceDetailHttp struct {
	HttpMethod          string            // post/get/put/delete
	HttpUrl             string            // url
	HttpHeaders         map[string]string // 头部
	HttpRequestBody     string            // 入参
	HttpResponseBody    string            // 出参
	HttpResponseHeaders map[string]string // 响应头部
	HttpStatusCode      int               // 状态码
}

type TraceDetailMq struct {
	MqServer     string // MQ服务器地址
	MqExchange   string // 交换器名称
	MqRoutingKey string // 路由key
}

type TraceDetailRedis struct {
	RedisKey          string // redis key
	RedisField        string // hash field
	RedisRowsAffected int    // 影响行数
}

type WatchKeyContext struct {
	WatchKey string `json:"wk"` // KEY
}

type WebContext struct {
	WebDomain       string            `json:"wd"`  // 请求域名
	WebPath         string            `json:"wp"`  // 请求地址
	WebMethod       string            `json:"wm"`  // 请求方式
	WebContentType  string            `json:"wct"` // 请求内容类型
	WebStatusCode   int               `json:"wsc"` // 状态码
	WebHeaders      map[string]string `json:"wh"`  // 请求头部
	WebRequestBody  string            `json:"wrb"` // 请求参数
	WebResponseBody string            `json:"wpb"` // 输出参数
	WebRequestIp    string            `json:"wip"` // 客户端IP
}