x

Author: chenquan

zrpc/internal/rpcpubserver.go

@@ -18,7 +18,7 @@ const (
 	envPodIp = "POD_IP"
 )
 
-var notReadyError = errors.New("service is not ready for a limited time")
+var errorNotReady = errors.New("service is not ready for a limited time")
 
 // NewRpcPubServer returns a Server.
 func NewRpcPubServer(etcd discov.EtcdConf, listenOn string,
@@ -69,7 +69,7 @@ func (s keepAliveServer) Start(fn RegisterFn) error {
 					return
 				}
 			case <-ctx.Done():
-				logx.Must(notReadyError)
+				logx.Must(errorNotReady)
 				return
 			}
 		}

zrpc/internal/serverinterceptors/shutdowninterceptor.go

@@ -13,7 +13,7 @@ import (
 
 var (
 	shutdown      int32
-	shutdownError = status.Error(codes.Unavailable, "server is shutting down")
+	errorShutdown = status.Error(codes.Unavailable, "server is shutting down")
 )
 
 func init() {
@@ -44,7 +44,7 @@ func UnaryShutdownInterceptor(ctx context.Context, req any, _ *grpc.UnaryServerI
 
 func handleShutdown(f func() error) error {
 	if atomic.LoadInt32(&shutdown) == 1 {
-		return shutdownError
+		return errorShutdown
 	}
 	return f()
 }