From 0e4e7966ec0dbd71e0f578c0f70f5eefcb563c5b Mon Sep 17 00:00:00 2001 From: jaime Date: Thu, 1 Sep 2022 09:48:58 +0800 Subject: [PATCH] Refine grpc server options of interceptor (#18943) Signed-off-by: yun.zhang Signed-off-by: yun.zhang --- internal/distributed/proxy/service.go | 10 ---------- 1 file changed, 10 deletions(-) diff --git a/internal/distributed/proxy/service.go b/internal/distributed/proxy/service.go index a35ea9c604..0bc66157c8 100644 --- a/internal/distributed/proxy/service.go +++ b/internal/distributed/proxy/service.go @@ -174,10 +174,6 @@ func (s *Server) startExternalGrpc(grpcPort int, errChan chan error) { proxy.UnaryServerInterceptor(proxy.PrivilegeInterceptor), logutil.UnaryTraceLoggerInterceptor, )), - grpc.StreamInterceptor(grpc_middleware.ChainStreamServer( - ot.StreamServerInterceptor(opts...), - grpc_auth.StreamServerInterceptor(proxy.AuthenticationInterceptor), - logutil.StreamTraceLoggerInterceptor)), } if Params.TLSMode == 1 { @@ -263,14 +259,8 @@ func (s *Server) startInternalGrpc(grpcPort int, errChan chan error) { grpc.MaxSendMsgSize(Params.ServerMaxSendSize), grpc.UnaryInterceptor(grpc_middleware.ChainUnaryServer( ot.UnaryServerInterceptor(opts...), - grpc_auth.UnaryServerInterceptor(proxy.AuthenticationInterceptor), logutil.UnaryTraceLoggerInterceptor, )), - grpc.StreamInterceptor(grpc_middleware.ChainStreamServer( - ot.StreamServerInterceptor(opts...), - grpc_auth.StreamServerInterceptor(proxy.AuthenticationInterceptor), - logutil.StreamTraceLoggerInterceptor, - )), ) proxypb.RegisterProxyServer(s.grpcInternalServer, s) milvuspb.RegisterMilvusServiceServer(s.grpcInternalServer, s)