From fed21bfb86cfc4c422a794e6b5abcdfef92b8621 Mon Sep 17 00:00:00 2001 From: "dc.To" Date: Thu, 7 Aug 2025 10:03:10 +0800 Subject: [PATCH] update etcd variable --- grpcx/grpcx.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/grpcx/grpcx.go b/grpcx/grpcx.go index d09e8af..9524d2c 100644 --- a/grpcx/grpcx.go +++ b/grpcx/grpcx.go @@ -12,12 +12,12 @@ import ( "google.golang.org/grpc/reflection" ) -var Endpoint = os.Getenv("ETCD_ENDPOINTS") +var Endpoints = os.Getenv("ETCD_ENDPOINTS") var GrpcConfig *grpcx.GrpcServerConfig = grpcx.Server.NewConfig() func Etcd() *etcd.Registry { - return etcd.New(Endpoint) + return etcd.New(Endpoints) } func SetOptions(o ...grpc.ServerOption) *grpcx.GrpcServerConfig { @@ -40,7 +40,7 @@ func Registry(f ...func(s *grpcx.GrpcServer)) *grpcx.GrpcServer { chain.ClientMetadataUnaryChain, )}..., ) - if Endpoint != "" { + if Endpoints != "" { grpcx.Resolver.Register(Etcd()) } @@ -65,7 +65,7 @@ func Registry(f ...func(s *grpcx.GrpcServer)) *grpcx.GrpcServer { * @version 20250427 */ func Reflect(s reflection.GRPCServer, f ...func()) { - if Endpoint == "" { + if Endpoints == "" { reflection.Register(s) } for _, fn := range f {