mod grpc tracing

protocol/grpc/client.go

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

protocol/grpc/server.go

@@ -73,7 +73,9 @@ func (s *Server) Start(url common.URL) {
 	// 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)))
+		server = grpc.NewServer(
+			grpc.UnaryInterceptor(otgrpc.OpenTracingServerInterceptor(tracer)),
+			grpc.StreamInterceptor(otgrpc.OpenTracingStreamServerInterceptor(tracer)))
 	} else {
 		server = grpc.NewServer()
 	}