diff --git a/v3/integrations/nrgrpc/nrgrpc_server.go b/v3/integrations/nrgrpc/nrgrpc_server.go index fe5954cb2..6b28c84f0 100644 --- a/v3/integrations/nrgrpc/nrgrpc_server.go +++ b/v3/integrations/nrgrpc/nrgrpc_server.go @@ -198,9 +198,9 @@ func ErrorInterceptorStatusHandler(ctx context.Context, txn *newrelic.Transactio Message: s.Message(), Class: "gRPC Status: " + s.Code().String(), }) - txn.AddAttribute("GrpcStatusLevel", "error") - txn.AddAttribute("GrpcStatusMessage", s.Message()) - txn.AddAttribute("GrpcStatusCode", s.Code().String()) + txn.AddAttribute("grpcStatusLevel", "error") + txn.AddAttribute("grpcStatusMessage", s.Message()) + txn.AddAttribute("grpcStatusCode", s.Code().String()) } // @@ -212,9 +212,9 @@ func ErrorInterceptorStatusHandler(ctx context.Context, txn *newrelic.Transactio // func WarningInterceptorStatusHandler(ctx context.Context, txn *newrelic.Transaction, s *status.Status) { txn.SetWebResponse(nil).WriteHeader(int(codes.OK)) - txn.AddAttribute("GrpcStatusLevel", "warning") - txn.AddAttribute("GrpcStatusMessage", s.Message()) - txn.AddAttribute("GrpcStatusCode", s.Code().String()) + txn.AddAttribute("grpcStatusLevel", "warning") + txn.AddAttribute("grpcStatusMessage", s.Message()) + txn.AddAttribute("grpcStatusCode", s.Code().String()) } // @@ -226,9 +226,9 @@ func WarningInterceptorStatusHandler(ctx context.Context, txn *newrelic.Transact // func InfoInterceptorStatusHandler(ctx context.Context, txn *newrelic.Transaction, s *status.Status) { txn.SetWebResponse(nil).WriteHeader(int(codes.OK)) - txn.AddAttribute("GrpcStatusLevel", "info") - txn.AddAttribute("GrpcStatusMessage", s.Message()) - txn.AddAttribute("GrpcStatusCode", s.Code().String()) + txn.AddAttribute("grpcStatusLevel", "info") + txn.AddAttribute("grpcStatusMessage", s.Message()) + txn.AddAttribute("grpcStatusCode", s.Code().String()) } // diff --git a/v3/integrations/nrgrpc/nrgrpc_server_test.go b/v3/integrations/nrgrpc/nrgrpc_server_test.go index f50b16a5e..103379b61 100644 --- a/v3/integrations/nrgrpc/nrgrpc_server_test.go +++ b/v3/integrations/nrgrpc/nrgrpc_server_test.go @@ -182,9 +182,9 @@ func TestUnaryServerInterceptorError(t *testing.T) { "traceId": internal.MatchAnything, }, UserAttributes: map[string]interface{}{ - "GrpcStatusMessage": "oooooops!", - "GrpcStatusCode": "DataLoss", - "GrpcStatusLevel": "error", + "grpcStatusMessage": "oooooops!", + "grpcStatusCode": "DataLoss", + "grpcStatusLevel": "error", }, AgentAttributes: map[string]interface{}{ "httpResponseCode": 0, @@ -215,9 +215,9 @@ func TestUnaryServerInterceptorError(t *testing.T) { "request.uri": "grpc://bufnet/TestApplication/DoUnaryUnaryError", }, UserAttributes: map[string]interface{}{ - "GrpcStatusMessage": "oooooops!", - "GrpcStatusCode": "DataLoss", - "GrpcStatusLevel": "error", + "grpcStatusMessage": "oooooops!", + "grpcStatusCode": "DataLoss", + "grpcStatusLevel": "error", }, }}) } @@ -592,9 +592,9 @@ func TestStreamServerInterceptorError(t *testing.T) { "traceId": internal.MatchAnything, }, UserAttributes: map[string]interface{}{ - "GrpcStatusLevel": "error", - "GrpcStatusMessage": "oooooops!", - "GrpcStatusCode": "DataLoss", + "grpcStatusLevel": "error", + "grpcStatusMessage": "oooooops!", + "grpcStatusCode": "DataLoss", }, AgentAttributes: map[string]interface{}{ "httpResponseCode": 0, @@ -625,9 +625,9 @@ func TestStreamServerInterceptorError(t *testing.T) { "request.uri": "grpc://bufnet/TestApplication/DoUnaryStreamError", }, UserAttributes: map[string]interface{}{ - "GrpcStatusLevel": "error", - "GrpcStatusMessage": "oooooops!", - "GrpcStatusCode": "DataLoss", + "grpcStatusLevel": "error", + "grpcStatusMessage": "oooooops!", + "grpcStatusCode": "DataLoss", }, }}) }