[VOL-5478] Enable grpc stats
Change-Id: Ib84fccc0a0348bab355ac72a9726e1d2e6e5955d
Signed-off-by: Abhay Kumar <abhay.kumar@radisys.com>
diff --git a/VERSION b/VERSION
index dd812d3..15f5321 100644
--- a/VERSION
+++ b/VERSION
@@ -1 +1 @@
-7.6.10
+7.6.11
\ No newline at end of file
diff --git a/go.mod b/go.mod
index 99252f2..8f4ccc5 100644
--- a/go.mod
+++ b/go.mod
@@ -18,6 +18,7 @@
github.com/golang/protobuf v1.5.2
github.com/google/uuid v1.3.0
github.com/grpc-ecosystem/go-grpc-middleware v1.3.0
+ github.com/grpc-ecosystem/go-grpc-prometheus v1.2.0
github.com/jhump/protoreflect v1.10.2
github.com/opencord/voltha-protos/v5 v5.6.3
github.com/opentracing/opentracing-go v1.2.0
@@ -51,7 +52,6 @@
github.com/golang/snappy v0.0.3 // indirect
github.com/google/btree v1.0.1 // indirect
github.com/gorilla/websocket v1.4.2 // indirect
- github.com/grpc-ecosystem/go-grpc-prometheus v1.2.0 // indirect
github.com/grpc-ecosystem/grpc-gateway v1.16.0 // indirect
github.com/hashicorp/go-uuid v1.0.2 // indirect
github.com/jcmturner/aescts/v2 v2.0.0 // indirect
diff --git a/pkg/grpc/client.go b/pkg/grpc/client.go
index 2cd54a0..6d8a93c 100644
--- a/pkg/grpc/client.go
+++ b/pkg/grpc/client.go
@@ -25,6 +25,7 @@
grpc_middleware "github.com/grpc-ecosystem/go-grpc-middleware"
grpc_opentracing "github.com/grpc-ecosystem/go-grpc-middleware/tracing/opentracing"
+ grpc_prometheus "github.com/grpc-ecosystem/go-grpc-prometheus"
"github.com/jhump/protoreflect/dynamic/grpcdynamic"
"github.com/jhump/protoreflect/grpcreflect"
"github.com/opencord/voltha-lib-go/v7/pkg/log"
@@ -611,8 +612,12 @@
// 1. automatically inject
// 2. publish Open Tracing Spans by this GRPC Client
// 3. detect connection failure on client calls such that the reconnection process can begin
- interceptor_opts := []grpc.UnaryClientInterceptor{grpc_opentracing.UnaryClientInterceptor(grpc_opentracing.WithTracer(log.ActiveTracerProxy{}))}
+ interceptor_opts := []grpc.UnaryClientInterceptor{
+ grpc_opentracing.UnaryClientInterceptor(grpc_opentracing.WithTracer(log.ActiveTracerProxy{})),
+ grpc_prometheus.UnaryClientInterceptor,
+ }
+ grpc_prometheus.EnableClientHandlingTimeHistogram()
if len(retry_interceptor) > 0 {
interceptor_opts = append(interceptor_opts, retry_interceptor...)
}
@@ -621,6 +626,7 @@
grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(grpcRecvMsgSizeLimit*1024*1024)),
grpc.WithStreamInterceptor(grpc_middleware.ChainStreamClient(
grpc_opentracing.StreamClientInterceptor(grpc_opentracing.WithTracer(log.ActiveTracerProxy{})),
+ grpc_prometheus.StreamClientInterceptor,
)),
grpc.WithUnaryInterceptor(grpc_middleware.ChainUnaryClient(interceptor_opts...)),
)