From fa6904033817254637693d3496285ca405b35363 Mon Sep 17 00:00:00 2001 From: skiffer-git <44203734@qq.com> Date: Sat, 11 May 2024 10:19:05 +0800 Subject: [PATCH] add etcd --- pkg/common/discoveryregister/etcd/etcd.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/common/discoveryregister/etcd/etcd.go b/pkg/common/discoveryregister/etcd/etcd.go index cb8284e72..81ec77600 100644 --- a/pkg/common/discoveryregister/etcd/etcd.go +++ b/pkg/common/discoveryregister/etcd/etcd.go @@ -49,7 +49,7 @@ func (r *SvcDiscoveryRegistryImpl) GetUserIdHashGatewayHost(ctx context.Context, } func (r *SvcDiscoveryRegistryImpl) GetConns(ctx context.Context, serviceName string, opts ...grpc.DialOption) ([]*grpc.ClientConn, error) { target := fmt.Sprintf("%s:///%s", r.schema, serviceName) - conn, err := grpc.DialContext(ctx, target, append(r.dialOptions, opts...)...) + conn, err := grpc.DialContext(ctx, target, grpc.WithResolvers(r.resolver)) if err != nil { return nil, err } @@ -58,7 +58,7 @@ func (r *SvcDiscoveryRegistryImpl) GetConns(ctx context.Context, serviceName str func (r *SvcDiscoveryRegistryImpl) GetConn(ctx context.Context, serviceName string, opts ...grpc.DialOption) (*grpc.ClientConn, error) { target := fmt.Sprintf("%s:///%s", r.schema, serviceName) - return grpc.DialContext(ctx, target, append(r.dialOptions, opts...)...) + return grpc.DialContext(ctx, target, grpc.WithResolvers(r.resolver)) } func (r *SvcDiscoveryRegistryImpl) GetSelfConnTarget() string {