zk
This commit is contained in:
@@ -103,7 +103,7 @@ func NewClient(zkServers []string, zkRoot string, options ...ZkOption) (*ZkClien
|
|||||||
client.CloseZK()
|
client.CloseZK()
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
resolver.Register(client)
|
// resolver.Register(client)
|
||||||
var wg sync.WaitGroup
|
var wg sync.WaitGroup
|
||||||
wg.Add(2)
|
wg.Add(2)
|
||||||
go client.refresh(&wg)
|
go client.refresh(&wg)
|
||||||
|
|||||||
Reference in New Issue
Block a user