[#77]: feat: status code in gRPC request metric

Author: rustatian

go.sum

@@ -46,8 +46,6 @@ github.com/roadrunner-server/goridge/v3 v3.6.2 h1:LH5HXfCygDp05KnOaXpa4fqVPWTsH7
 github.com/roadrunner-server/goridge/v3 v3.6.2/go.mod h1:3B95k/wM5GGAD0h2hZlJagS9PlTDGs5jh8MpZYC12vA=
 github.com/roadrunner-server/sdk/v4 v4.2.0 h1:hqNlqJV2MXZ8DF1wJnouUdV/55Hae6VL37fVXT1aIr8=
 github.com/roadrunner-server/sdk/v4 v4.2.0/go.mod h1:aIzXmg8DZBJ4Tbtvihp/s6VH4e2oSdivOqm/8V+HuUc=
-github.com/roadrunner-server/tcplisten v1.2.1 h1:9hVVMlCRvMPewnJCnfSe/kKAqn2ZOF3wHy+ji0M/NKU=
-github.com/roadrunner-server/tcplisten v1.2.1/go.mod h1:TRJLGwIruiJ7QhmGVRgJFY5Ch72mPoLhLAxuxLnavpU=
 github.com/roadrunner-server/tcplisten v1.3.0 h1:VDd6IbP8oIjm5vKvMVozeZgeHgOcoP0XYLOyOqcZHCY=
 github.com/roadrunner-server/tcplisten v1.3.0/go.mod h1:VR6Ob5am0oEuLMOeLiVvQxG9ShykAEgrlvZddX8EfoU=
 github.com/rogpeppe/go-internal v1.9.0 h1:73kH8U+JUqXU8lRuOHeVHaa/SZPifC7BkcraZVejAe8=

plugin.go

@@ -97,7 +97,7 @@ func (p *Plugin) Init(cfg common.Configurer, log common.Logger, server common.Se
 		Namespace: namespace,
 		Name:      "request_total",
 		Help:      "Total number of handled GRPC requests after server restart.",
-	}, []string{"grpc_method"})
+	}, []string{"grpc_method", "grpc_code"})
 
 	p.requestDuration = prometheus.NewHistogramVec(
 		prometheus.HistogramOpts{

server.go

@@ -15,8 +15,10 @@ import (
 	"github.com/roadrunner-server/grpc/v4/proxy"
 	"go.uber.org/zap"
 	"google.golang.org/grpc"
+	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/credentials"
 	"google.golang.org/grpc/keepalive"
+	"google.golang.org/grpc/status"
 )
 
 func (p *Plugin) createGRPCserver(interceptors map[string]common.Interceptor) (*grpc.Server, error) {
@@ -78,8 +80,16 @@ func (p *Plugin) interceptor(ctx context.Context, req any, info *grpc.UnaryServe
 
 	resp, err := handler(ctx, req)
 
+	s, ok := status.FromError(err)
+	var statusCode codes.Code
+	if ok {
+		statusCode = s.Code()
+	} else {
+		statusCode = status.New(codes.Unknown, err.Error()).Code()
+	}
+
 	defer func() {
-		p.requestCounter.WithLabelValues(info.FullMethod).Inc()
+		p.requestCounter.WithLabelValues(info.FullMethod, statusCode.String()).Inc()
 		p.requestDuration.WithLabelValues(info.FullMethod).Observe(time.Since(start).Seconds())
 		p.queueSize.Dec()
 	}()