Compare commits

...

1 Commits

Author SHA1 Message Date
杨赟 3b39763e2a 修复bug
2 years ago

@ -48,7 +48,11 @@ func BeforeHandel(ctx context.Context, baseName, serviceName, serviceMethod stri
span.AddEvent(fmt.Sprintf("调用rpc服务:%s,%s,%s", baseName, serviceName, serviceMethod)) span.AddEvent(fmt.Sprintf("调用rpc服务:%s,%s,%s", baseName, serviceName, serviceMethod))
spanCtx := ctx.Value(CtxSpanCtxName).(context.Context) spanCtx := ctx.Value(CtxSpanCtxName).(context.Context)
meta := ctx.Value(share.ReqMetaDataKey) meta := ctx.Value(share.ReqMetaDataKey)
if meta == nil {
spanCtx = context.WithValue(spanCtx, share.ReqMetaDataKey, map[string]string{})
} else {
spanCtx = context.WithValue(spanCtx, share.ReqMetaDataKey, meta) spanCtx = context.WithValue(spanCtx, share.ReqMetaDataKey, meta)
}
share2.Inject(spanCtx, otel.GetTextMapPropagator()) share2.Inject(spanCtx, otel.GetTextMapPropagator())
ctx = spanCtx ctx = spanCtx
} }

Loading…
Cancel
Save