feat: add NewVariableContext for StreamInterceptorFilter (#1055)

* add NewVariableContext for StreamInterceptorFilter * fix go lint --------- Co-authored-by: 文徐 <[email protected]>
mosn · Jul 4, 2024 · 3bf8bca · 3bf8bca
1 parent 4c666d8
commit 3bf8bca
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/diagnostics/grpc_tracing.go b/diagnostics/grpc_tracing.go
@@ -8,6 +8,7 @@ import (
 
 	"google.golang.org/grpc"
 	"mosn.io/mosn/pkg/trace"
+	"mosn.io/pkg/variable"
 
 	ltrace "mosn.io/layotto/components/trace"
 	lgrpc "mosn.io/layotto/diagnostics/grpc"
@@ -50,6 +51,7 @@ func StreamInterceptorFilter(srv interface{}, ss grpc.ServerStream, info *grpc.S
 	// get tracer
 	tracer := trace.Tracer(protocol.Layotto)
 	ctx := ss.Context()
+	ctx = variable.NewVariableContext(ctx)
 	// start a span
 	span := tracer.Start(ctx, &lgrpc.RequestInfo{
 		FullMethod: info.FullMethod,