mod grpc tracing

protocol/grpc/client.go

@@ -49,22 +49,15 @@ func NewClient(url common.URL) *Client {
 		err    error
 		tracer opentracing.Tracer
 	)
-	// if global trace instance was set in filter, it means trace function enabled
-	if opentracing.IsGlobalTracerRegistered() {
-		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())))
-		if err != nil {
-			panic(err)
-		}
-	} else {
-		conn, err = grpc.Dial(url.Location, grpc.WithInsecure(), grpc.WithBlock())
-		if err != nil {
-			panic(err)
-		}
+	// if global trace instance was set , it means trace function enabled. If not , will return Nooptracer
+	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())))
+	if err != nil {
+		panic(err)
 	}
 
 	key := url.GetParam(constant.BEAN_NAME_KEY, "")

protocol/grpc/server.go

@@ -70,15 +70,11 @@ func (s *Server) Start(url common.URL) {
 		panic(err)
 	}
 
-	// if global trace instance was set, then server tracer instance can be get, and span context can also be get
-	if opentracing.IsGlobalTracerRegistered() {
-		tracer := opentracing.GlobalTracer()
-		server = grpc.NewServer(
-			grpc.UnaryInterceptor(otgrpc.OpenTracingServerInterceptor(tracer)),
-			grpc.StreamInterceptor(otgrpc.OpenTracingStreamServerInterceptor(tracer)))
-	} else {
-		server = grpc.NewServer()
-	}
+	// 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)))
 
 	key := url.GetParam(constant.BEAN_NAME_KEY, "")
 	service := config.GetProviderService(key)