- 修复 etcd ip地址

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,

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,

version.go

@@ -1,3 +1,3 @@
 package gojobs
 
-const Version = "1.0.11"
+const Version = "1.0.12"