mod grpc tracing

protocol/grpc/client.go

@@ -53,9 +53,7 @@ func NewClient(url common.URL) *Client {
 	tracer = opentracing.GlobalTracer()
 	conn, err = grpc.Dial(url.Location, grpc.WithInsecure(), grpc.WithBlock(),
 		grpc.WithUnaryInterceptor(
-			otgrpc.OpenTracingClientInterceptor(tracer, otgrpc.LogPayloads())),
-		grpc.WithStreamInterceptor(
-			otgrpc.OpenTracingStreamClientInterceptor(tracer, otgrpc.LogPayloads())))
+			otgrpc.OpenTracingClientInterceptor(tracer, otgrpc.LogPayloads())))
 	if err != nil {
 		panic(err)
 	}

protocol/grpc/server.go

@@ -73,8 +73,7 @@ func (s *Server) Start(url common.URL) {
 	// if global trace instance was set ,  then server tracer instance can be get. If not , will return Nooptracer
 	tracer := opentracing.GlobalTracer()
 	server = grpc.NewServer(
-		grpc.UnaryInterceptor(otgrpc.OpenTracingServerInterceptor(tracer)),
-		grpc.StreamInterceptor(otgrpc.OpenTracingStreamServerInterceptor(tracer)))
+		grpc.UnaryInterceptor(otgrpc.OpenTracingServerInterceptor(tracer)))
 
 	key := url.GetParam(constant.BEAN_NAME_KEY, "")
 	service := config.GetProviderService(key)