metrics/grpc/client.go

@@ -15,9 +15,6 @@ var clientMetrics = grpcprom.NewClientMetrics(
 	grpcprom.WithClientStreamRecvHistogram(
 		grpcprom.WithHistogramBuckets(prometheus.DefBuckets),
 	),
-	grpcprom.WithClientStreamSendHistogram(
-		grpcprom.WithHistogramBuckets(prometheus.DefBuckets),
-	),
 )
 
 func init() {
@@ -60,12 +57,6 @@ func init() {
 			Help:           "Histogram of response latency (seconds) of the gRPC single message receive.",
 			VariableLabels: []string{"grpc_type", "grpc_service", "grpc_method"},
 		},
-		{
-			Name:           "grpc_client_msg_send_handling_seconds",
-			Type:           dto.MetricType_HISTOGRAM.String(),
-			Help:           "Histogram of response latency (seconds) of the gRPC single message send.",
-			VariableLabels: []string{"grpc_type", "grpc_service", "grpc_method"},
-		},
 	}
 	metrics.MustRegister(clientMetrics, descs...)
 }

tracing/examples/grpc/main.go

@@ -82,7 +82,7 @@ func main() {
 	cc, err := grpc.NewClient(":7000",
 		grpc.WithTransportCredentials(insecure.NewCredentials()),
 		grpc.WithChainUnaryInterceptor(
-			tracing_grpc.NewUnaryClientInterceptor(),
+			tracing_grpc.NewUnaryClientInteceptor(),
 			verifyClientTraceID,
 		),
 		grpc.WithChainStreamInterceptor(

tracing/grpc/interceptors.go

@@ -15,8 +15,8 @@ import (
 	"google.golang.org/grpc/status"
 )
 
-// NewUnaryClientInterceptor creates new gRPC unary interceptor to save gRPC client traces.
-func NewUnaryClientInterceptor() grpc.UnaryClientInterceptor {
+// NewUnaryClientInteceptor creates new gRPC unary interceptor to save gRPC client traces.
+func NewUnaryClientInteceptor() grpc.UnaryClientInterceptor {
 	return func(ctx context.Context, method string, req, reply any, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error {
 		ctx, span := startClientSpan(ctx, cc, method)
 		defer span.End()