linkpay/invoke
4
0
Fork 0
Code Releases Activity

update etcd variable

Browse Source
This commit is contained in:
dc.To 2025-08-07 10:03:10 +08:00
parent 981e1e0cf0
commit 54834f31b7
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
grpcx/grpcx.go
View File

@ -12,12 +12,12 @@ import (
"google.golang.org/grpc/reflection" "google.golang.org/grpc/reflection"
) )
var Endpoint = os.Getenv("ETCD_ENDPOINTS") var Endpoints = os.Getenv("ETCD_ENDPOINTS")
var GrpcConfig *grpcx.GrpcServerConfig = grpcx.Server.NewConfig() var GrpcConfig *grpcx.GrpcServerConfig = grpcx.Server.NewConfig()
func Etcd() *etcd.Registry { func Etcd() *etcd.Registry {
return etcd.New(Endpoint) return etcd.New(Endpoints)
} }
func SetOptions(o ...grpc.ServerOption) *grpcx.GrpcServerConfig { func SetOptions(o ...grpc.ServerOption) *grpcx.GrpcServerConfig {
@ -40,7 +40,7 @@ func Registry(f ...func(s *grpcx.GrpcServer)) *grpcx.GrpcServer {
chain.ClientMetadataUnaryChain, chain.ClientMetadataUnaryChain,
)}..., )}...,
) )
if Endpoint != "" { if Endpoints != "" {
grpcx.Resolver.Register(Etcd()) grpcx.Resolver.Register(Etcd())
} }
@ -65,7 +65,7 @@ func Registry(f ...func(s *grpcx.GrpcServer)) *grpcx.GrpcServer {
* @version 20250427 * @version 20250427
*/ */
func Reflect(s reflection.GRPCServer, f ...func()) { func Reflect(s reflection.GRPCServer, f ...func()) {
if Endpoint == "" { if Endpoints == "" {
reflection.Register(s) reflection.Register(s)
} }
for _, fn := range f { for _, fn := range f {