-
Notifications
You must be signed in to change notification settings - Fork 12
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
8 changed files
with
204 additions
and
81 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,34 @@ | ||
| package eumTraceType | ||
|
|
||
| type Enum int | ||
|
|
||
| const ( | ||
| WebApi Enum = iota // WebApi | ||
| MqConsumer // MQ消费 | ||
| QueueConsumer // 本地消费 | ||
| FSchedule // 调度中心 | ||
| Task // 本地任务 | ||
| WatchKey // ETCD | ||
| EventConsumer // 事件消费 | ||
| WebSocket // WebSocket | ||
| ) | ||
|
|
||
| func (e Enum) ToString() string { | ||
| switch e { | ||
| case WebApi: | ||
| return "WebApi" | ||
| case MqConsumer: | ||
| return "MqConsumer" | ||
| case QueueConsumer: | ||
| return "QueueConsumer" | ||
| case FSchedule: | ||
| return "FSchedule" | ||
| case Task: | ||
| return "Task" | ||
| case WatchKey: | ||
| return "WatchKey" | ||
| case EventConsumer: | ||
| return "EventConsumer" | ||
| } | ||
| return "" | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file was deleted.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,128 @@ | ||
| package trace | ||
|
|
||
| import ( | ||
| "time" | ||
|
|
||
| "github.com/farseer-go/collections" | ||
| "github.com/farseer-go/fs/dateTime" | ||
| "github.com/farseer-go/fs/trace/eumTraceType" | ||
| ) | ||
|
|
||
| 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 []any `json:"l"` // 调用的上下文trace.ITraceDetail | ||
| TraceCount int `json:"tc"` // 追踪明细数量 | ||
| ignore bool // 忽略这次的链路追踪 | ||
| ignoreDetail bool // 忽略链路明细 | ||
| Exception *ExceptionStack `json:"e"` // 异常信息 | ||
| WebContext | ||
| ConsumerContext | ||
| TaskContext | ||
| WatchKeyContext | ||
| CreateAt dateTime.DateTime `json:"ca"` // 请求时间 | ||
| } | ||
|
|
||
| type WebContext struct { | ||
| WebDomain string `json:"wd"` // 请求域名 | ||
| WebPath string `json:"wp"` // 请求地址 | ||
| WebMethod string `json:"wm"` // 请求方式 | ||
| WebContentType string `json:"wct"` // 请求内容类型 | ||
| WebStatusCode int `json:"wsc"` // 状态码 | ||
| WebHeaders collections.Dictionary[string, string] `json:"wh"` // 请求头部 | ||
| WebRequestBody string `json:"wrb"` // 请求参数 | ||
| WebResponseBody string `json:"wpb"` // 输出参数 | ||
| WebRequestIp string `json:"wip"` // 客户端IP | ||
| } | ||
|
|
||
| func (receiver WebContext) IsNil() bool { | ||
| return receiver.WebDomain == "" && receiver.WebPath == "" && receiver.WebMethod == "" && receiver.WebContentType == "" && receiver.WebStatusCode == 0 | ||
| } | ||
|
|
||
| type ConsumerContext struct { | ||
| ConsumerServer string `json:"cs"` // MQ服务器 | ||
| ConsumerQueueName string `json:"cq"` // 队列名称 | ||
| ConsumerRoutingKey string `json:"cr"` // 路由KEY | ||
| } | ||
|
|
||
| func (receiver ConsumerContext) IsNil() bool { | ||
| return receiver.ConsumerServer == "" && receiver.ConsumerQueueName == "" && receiver.ConsumerRoutingKey == "" | ||
| } | ||
|
|
||
| type TaskContext struct { | ||
| TaskName string `json:"tn"` // 任务名称 | ||
| TaskGroupName string `json:"tgn"` // 任务组ID | ||
| TaskId int64 `json:"tid"` // 任务ID | ||
| TaskData collections.Dictionary[string, string] `json:"td"` // 任务数据 | ||
| } | ||
|
|
||
| func (receiver TaskContext) IsNil() bool { | ||
| return receiver.TaskName == "" && receiver.TaskGroupName == "" && receiver.TaskId == 0 | ||
| } | ||
|
|
||
| type WatchKeyContext struct { | ||
| WatchKey string `json:"wk"` // KEY | ||
| } | ||
|
|
||
| func (receiver WatchKeyContext) IsNil() bool { | ||
| return receiver.WatchKey == "" | ||
| } | ||
|
|
||
| func (receiver *TraceContext) SetBody(requestBody string, statusCode int, responseBody string) { | ||
| receiver.WebContext.WebRequestBody = requestBody | ||
| receiver.WebContext.WebStatusCode = statusCode | ||
| receiver.WebContext.WebResponseBody = responseBody | ||
| } | ||
|
|
||
| func (receiver *TraceContext) SetResponseBody(responseBody string) { | ||
| receiver.WebContext.WebResponseBody = responseBody | ||
| } | ||
|
|
||
| func (receiver *TraceContext) Ignore() { | ||
| receiver.ignore = true | ||
| } | ||
|
|
||
| func (receiver *TraceContext) IsIgnore() bool { | ||
| return receiver.ignore | ||
| } | ||
|
|
||
| func (receiver *TraceContext) IgnoreDetail() { | ||
| //receiver.AddDetail() | ||
| receiver.ignoreDetail = true | ||
| } | ||
|
|
||
| // GetList 获取链路明细 | ||
| func (receiver *TraceContext) GetList() []any { | ||
| return receiver.List | ||
| } | ||
|
|
||
| // AddDetail 添加链路明细 | ||
| func (receiver *TraceContext) AddDetail(detail ITraceDetail) { | ||
| // 没有忽略明细，才要加入 | ||
| if !receiver.ignoreDetail { | ||
| receiver.List = append(receiver.List, detail) | ||
| } | ||
| } | ||
|
|
||
| func (receiver *TraceContext) Error(err error) { | ||
| if err != nil { | ||
| receiver.Exception = &ExceptionStack{ | ||
| ExceptionIsException: true, | ||
| ExceptionMessage: err.Error(), | ||
| } | ||
| receiver.Exception.ExceptionCallFile, receiver.Exception.ExceptionCallFuncName, receiver.Exception.ExceptionCallLine = GetCallerInfo() | ||
| } | ||
| } | ||
|
|
||
| func (receiver *TraceContext) GetAppInfo() (string, string, string, string, string) { | ||
| return receiver.TraceId, receiver.AppName, receiver.AppId, receiver.AppIp, receiver.ParentAppName | ||
| } |