diff --git a/etcd_server.go b/etcd_server.go index c9d4f4f..5049c06 100644 --- a/etcd_server.go +++ b/etcd_server.go @@ -18,6 +18,7 @@ func NewEtcdServer(config *EtcdConfig) (*Etcd, error) { e.Endpoints = config.Endpoints e.DialTimeout = config.DialTimeout + e.LocalIP = config.LocalIP e.Client, err = clientv3.New(clientv3.Config{ Endpoints: e.Endpoints, diff --git a/etcd_worker.go b/etcd_worker.go index c3a2e23..295325f 100644 --- a/etcd_worker.go +++ b/etcd_worker.go @@ -4,6 +4,7 @@ import ( "context" "errors" "fmt" + "go.dtapp.net/goip" "go.etcd.io/etcd/client/v3" "log" "time" @@ -19,6 +20,10 @@ func NewEtcdWorker(config *EtcdConfig) (*Etcd, error) { e.Endpoints = config.Endpoints e.DialTimeout = config.DialTimeout + if config.LocalIP == "" { + config.LocalIP = goip.GetOutsideIp() + } + e.LocalIP = config.LocalIP e.Client, err = clientv3.New(clientv3.Config{ Endpoints: e.Endpoints, diff --git a/version.go b/version.go index 93043de..4d513bf 100644 --- a/version.go +++ b/version.go @@ -1,3 +1,3 @@ package gojobs -const Version = "1.0.11" +const Version = "1.0.12"