From fd25946b1c39c3f81f0d56951eef7530a8b83900 Mon Sep 17 00:00:00 2001 From: skiffer-git <44203734@qq.com> Date: Mon, 13 May 2024 12:17:56 +0800 Subject: [PATCH] Add etcd as a service discovery mechanism --- pkg/common/discoveryregister/etcd/etcd.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/common/discoveryregister/etcd/etcd.go b/pkg/common/discoveryregister/etcd/etcd.go index af827e4b7..5d0e37d0f 100644 --- a/pkg/common/discoveryregister/etcd/etcd.go +++ b/pkg/common/discoveryregister/etcd/etcd.go @@ -100,7 +100,7 @@ func (r *SvcDiscoveryRegistryImpl) GetConns(ctx context.Context, serviceName str for _, kv := range resp.Kvs { endpoint := string(kv.Key[len(fullServiceKey)+1:]) // Extract the endpoint address - target := fmt.Sprintf("etcd://%s", endpoint) + target := fmt.Sprintf("etcd://%s/%s/%s", r.rootDirectory, serviceName, endpoint) conn, err := grpc.DialContext(ctx, target, append(append(r.dialOptions, opts...), grpc.WithResolvers(r.resolver))...) if err != nil { fmt.Println("DialContext ", target, err.Error())