diff --git a/etcd.go b/etcd.go index 0d4c3d5..a3db378 100644 --- a/etcd.go +++ b/etcd.go @@ -25,12 +25,15 @@ func (e Etcd) Close() { // NewEtcd 创建etcd func NewEtcd(config *EtcdConfig) *Etcd { + e := &Etcd{} + e.Endpoints = config.Endpoints + e.DialTimeout = config.DialTimeout var err error e.c, err = clientv3.New(clientv3.Config{ - Endpoints: config.Endpoints, - DialTimeout: config.DialTimeout, + Endpoints: e.Endpoints, + DialTimeout: e.DialTimeout, }) if err != nil { panic("连接失败:" + err.Error()) diff --git a/version.go b/version.go index 3ad13a6..d119ead 100644 --- a/version.go +++ b/version.go @@ -1,3 +1,3 @@ package gojobs -const Version = "1.0.4" +const Version = "1.0.5"