x

Author: chenquan

zrpc/internal/config.go

@@ -23,7 +23,6 @@ type (
 		StatConf   StatConf `json:",optional"`
 		Prometheus bool     `json:",default=true"`
 		Breaker    bool     `json:",default=true"`
-		Shutdown   bool     `json:",default=true"`
 	}
 
 	// MethodTimeoutConf defines specified timeout for gRPC methods.

zrpc/internal/serverinterceptors/shutdowninterceptor.go

@@ -140,9 +140,6 @@ func setupStreamInterceptors(svr internal.Server, c RpcServerConf) {
 	if c.Middlewares.Breaker {
 		svr.AddStreamInterceptors(serverinterceptors.StreamBreakerInterceptor)
 	}
-	if c.Middlewares.Shutdown {
-		svr.AddStreamInterceptors(serverinterceptors.StreamShutdownInterceptor)
-	}
 }
 
 func setupUnaryInterceptors(svr internal.Server, c RpcServerConf, metrics *stat.Metrics) {
@@ -161,9 +158,6 @@ func setupUnaryInterceptors(svr internal.Server, c RpcServerConf, metrics *stat.
 	if c.Middlewares.Breaker {
 		svr.AddUnaryInterceptors(serverinterceptors.UnaryBreakerInterceptor)
 	}
-	if c.Middlewares.Shutdown {
-		svr.AddUnaryInterceptors(serverinterceptors.UnaryShutdownInterceptor)
-	}
 	if c.CpuThreshold > 0 {
 		shedder := load.NewAdaptiveShedder(load.WithCpuThreshold(c.CpuThreshold))
 		svr.AddUnaryInterceptors(serverinterceptors.UnarySheddingInterceptor(shedder, metrics))