fix(grpc): Chain interceptor

ethpandaops · Apr 8, 2024 · d388e0e · d388e0e
1 parent 73ffc37
commit d388e0e
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pkg/server/server.go b/pkg/server/server.go
@@ -235,6 +235,9 @@ func (x *Xatu) startGrpcServer(ctx context.Context) error {
 			Time:                  1 * time.Minute,
 			Timeout:               15 * time.Second,
 		}),
+		grpc.ChainStreamInterceptor(
+			grpc.StreamServerInterceptor(grpc_prometheus.StreamServerInterceptor),
+		),
 		grpc.ChainUnaryInterceptor(
 			grpc.UnaryServerInterceptor(grpc_prometheus.UnaryServerInterceptor),
 			func(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error) {