|
|
@ -153,11 +153,8 @@ func (w *clientStream) sendStreamEvent(eventType streamEventType, err error) {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
func startSpan(ctx context.Context, method, target string) (context.Context, trace.Span) {
|
|
|
|
func startSpan(ctx context.Context, method, target string) (context.Context, trace.Span) {
|
|
|
|
var md metadata.MD
|
|
|
|
md, ok := metadata.FromOutgoingContext(ctx)
|
|
|
|
requestMetadata, ok := metadata.FromOutgoingContext(ctx)
|
|
|
|
if !ok {
|
|
|
|
if ok {
|
|
|
|
|
|
|
|
md = requestMetadata.Copy()
|
|
|
|
|
|
|
|
} else {
|
|
|
|
|
|
|
|
md = metadata.MD{}
|
|
|
|
md = metadata.MD{}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
tr := otel.Tracer(ztrace.TraceName)
|
|
|
|
tr := otel.Tracer(ztrace.TraceName)
|
|
|
|