|
|
@ -101,11 +101,11 @@ func NewClient(zkServers []string, zkRoot string, options ...ZkOption) (*ZkClien
|
|
|
|
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)
|
|
|
|
// go client.watch(&wg)
|
|
|
|
// go client.watch(&wg)
|
|
|
|
wg.Wait()
|
|
|
|
// wg.Wait()
|
|
|
|
return client, nil
|
|
|
|
return client, nil
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|