Refine grpc server options of interceptor (#18943)

Signed-off-by: yun.zhang <yun.zhang@zilliz.com> Signed-off-by: yun.zhang <yun.zhang@zilliz.com>
milvus-io · Sep 1, 2022 · 0e4e796 · 0e4e796
1 parent 237d912
commit 0e4e796
Showing 1 changed file with 0 additions and 10 deletions.
diff --git 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)