Add etcd as a service discovery mechanism

pull/2318/head
skiffer-git 6 months ago
parent f5b117e651
commit 0fed297615

@ -193,8 +193,7 @@ func (r *SvcDiscoveryRegistryImpl) refreshConnMap(prefix string) {
fmt.Printf("Failed to get endpoints: %v\n", err) fmt.Printf("Failed to get endpoints: %v\n", err)
return return
} }
r.connMap[prefix] = []*grpc.ClientConn{} // Update the connMap with new connections
// Update the connMap with new connections
for _, kv := range resp.Kvs { for _, kv := range resp.Kvs {
_, addr := r.splitEndpoint(string(kv.Key)) _, addr := r.splitEndpoint(string(kv.Key))
conn, err := grpc.DialContext(context.Background(), addr, append(r.dialOptions, grpc.WithResolvers(r.resolver))...) conn, err := grpc.DialContext(context.Background(), addr, append(r.dialOptions, grpc.WithResolvers(r.resolver))...)

Loading…
Cancel
Save