From 28cb3a37fad22e0e7a487ba6db3ac1076cb547b0 Mon Sep 17 00:00:00 2001
From: skiffer-git <44203734@qq.com>
Date: Sat, 11 May 2024 10:30:47 +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 81ec77600..871bc07a0 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, grpc.WithResolvers(r.resolver))
+	conn, err := grpc.DialContext(ctx, target, append(append(r.dialOptions, opts...), 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, grpc.WithResolvers(r.resolver))
+	return grpc.DialContext(ctx, target, append(append(r.dialOptions, opts...), grpc.WithResolvers(r.resolver))...)
 }
 
 func (r *SvcDiscoveryRegistryImpl) GetSelfConnTarget() string {