diff --git a/pkg/etcd/etcd.go b/pkg/etcd/etcd.go index 93ffe8c8f..3517e04fe 100644 --- a/pkg/etcd/etcd.go +++ b/pkg/etcd/etcd.go @@ -47,9 +47,10 @@ func NewClient(cli *clientv3.Client, root string) *Client { // NewClientFromCfg returns a wrapped etcd client func NewClientFromCfg(endpoints []string, dialTimeout time.Duration, root string, security *tls.Config) (*Client, error) { cli, err := clientv3.New(clientv3.Config{ - Endpoints: endpoints, - DialTimeout: dialTimeout, - TLS: security, + Endpoints: endpoints, + DialTimeout: dialTimeout, + TLS: security, + AutoSyncInterval: 30 * time.Second, }) if err != nil { return nil, errors.Trace(err)