diff --git a/contrib/registry/etcd/etcd.go b/contrib/registry/etcd/etcd.go index e0850c76e..bb05c035b 100644 --- a/contrib/registry/etcd/etcd.go +++ b/contrib/registry/etcd/etcd.go @@ -122,9 +122,13 @@ func NewWithClient(client *etcd3.Client, option ...Option) *Registry { client: client, kv: etcd3.NewKV(client), } + r.etcdConfig.DialTimeout = DefaultDialTimeout if len(option) > 0 { r.logger = option[0].Logger r.keepaliveTTL = option[0].KeepaliveTTL + if option[0].DialTimeout > 0 { + r.etcdConfig.DialTimeout = option[0].DialTimeout + } } if r.logger == nil { r.logger = g.Log()