From eeb5ba4c7bb6a56b7a85e3dda34b884040a5f1ae Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Thu, 15 Sep 2022 19:55:24 +0800 Subject: [PATCH] prome --- internal/rpc/group/group.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/internal/rpc/group/group.go b/internal/rpc/group/group.go index 740919ee2..27838b4e2 100644 --- a/internal/rpc/group/group.go +++ b/internal/rpc/group/group.go @@ -68,11 +68,10 @@ func (s *groupServer) Run() { //grpc server recvSize := 1024 * 1024 * constant.GroupRPCRecvSize sendSize := 1024 * 1024 * constant.GroupRPCSendSize - var options = []grpc.ServerOption{ + var grpcOpts = []grpc.ServerOption{ grpc.MaxRecvMsgSize(recvSize), grpc.MaxSendMsgSize(sendSize), } - var grpcOpts []grpc.ServerOption if config.Config.Prometheus.Enable { promePkg.NewGrpcRequestCounter() promePkg.NewGrpcRequestFailedCounter() @@ -83,7 +82,7 @@ func (s *groupServer) Run() { grpc.UnaryInterceptor(grpcPrometheus.UnaryServerInterceptor), }...) } - srv := grpc.NewServer(options...) + srv := grpc.NewServer(grpcOpts...) defer srv.GracefulStop() //Service registers with etcd pbGroup.RegisterGroupServer(srv, s)