Compare commits

..

No commits in common. "master" and "fix/grpc_client_metrics" have entirely different histories.

2 changed files with 3 additions and 3 deletions

View file

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

View file

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