|
|
@ -136,7 +136,7 @@ func (c *Cluster) setupEtcdProxy(ctx context.Context, etcdProxy etcd.Proxy) {
|
|
|
|
return
|
|
|
|
return
|
|
|
|
}
|
|
|
|
}
|
|
|
|
// We use Poll here instead of Until because we want to wait the interval before running the function.
|
|
|
|
// We use Poll here instead of Until because we want to wait the interval before running the function.
|
|
|
|
go wait.PollUntilContextCancel(ctx, 30*time.Second, true, func(ctx context.Context) (bool, error) {
|
|
|
|
go wait.PollUntilContextCancel(ctx, 30*time.Second, false, func(ctx context.Context) (bool, error) {
|
|
|
|
clientURLs, err := c.managedDB.GetMembersClientURLs(ctx)
|
|
|
|
clientURLs, err := c.managedDB.GetMembersClientURLs(ctx)
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
|
logrus.Warnf("Failed to get etcd ClientURLs: %v", err)
|
|
|
|
logrus.Warnf("Failed to get etcd ClientURLs: %v", err)
|
|
|
|