Skip to content

Commit

Permalink
调整:事件驱动的Level自动+1
Browse files Browse the repository at this point in the history
  • Loading branch information
steden committed Jan 16, 2024
1 parent 192c059 commit 80e2a95
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions traceManager.go
Original file line number Diff line number Diff line change
Expand Up @@ -101,9 +101,12 @@ func (receiver *traceManager) EntryEventConsumer(server, eventName, subscribeNam
// 事件消费,一般是由其它入口的程序触发的,所以这里先看能不能取到之前的上下文
var traceId string
var parentAppName string
var traceLevel int

if cur := receiver.GetCurTrace(); cur != nil {
traceId = cur.GetTraceId()
parentAppName = core.AppName
traceLevel = cur.GetTraceLevel() + 1
} else {
traceId = parse.ToString(sonyflake.GenerateId())
}
Expand All @@ -115,6 +118,7 @@ func (receiver *traceManager) EntryEventConsumer(server, eventName, subscribeNam
TraceId: traceId,
StartTs: time.Now().UnixMicro(),
TraceType: eumTraceType.EventConsumer,
TraceLevel: traceLevel,
ConsumerContext: ConsumerContext{
ConsumerServer: server,
ConsumerQueueName: eventName + "/" + subscribeName,
Expand Down

0 comments on commit 80e2a95

Please sign in to comment.