- 优化 etcd

2 years ago · 4f469f6f7a
parent f4c272801a
commit 4f469f6f7a
3 changed files with 3 additions and 2 deletions
--- a/etcd.go
+++ b/etcd.go
@ -40,5 +40,5 @@ func (e Etcd) GetWatchKey() string {

 // IssueWatchKey 下发的key
 func (e Etcd) IssueWatchKey(ip string) string {
-	return JobSaveDir + ip + "/"
+	return JobSaveDir + ip
 }
--- a/etcd_worker.go
+++ b/etcd_worker.go
@ -100,6 +100,7 @@ func (e Etcd) RegisterWorker() {
 		}

 	RETRY:
+		log.Println("异常 RETRY ", regKey)
 		time.Sleep(1 * time.Second)
 		if cancelFunc != nil {
 			cancelFunc()
--- a/version.go
+++ b/version.go
@ -1,3 +1,3 @@
 package gojobs

-const Version = "1.0.13"
+const Version = "1.0.14"