bugfix:etcdv3 autoreconnect

mhchlib · Feb 20, 2021 · 5b3375a · 5b3375a
1 parent cc938d5
commit 5b3375a
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/sd/etcdv3/client.go b/sd/etcdv3/client.go
@@ -4,6 +4,7 @@ import (
 	"context"
 	"crypto/tls"
 	"errors"
+	"fmt"
 	"time"
 
 	"go.etcd.io/etcd/clientv3"
@@ -212,6 +213,10 @@ func (c *client) Register(s Service) error {
 			case r := <-c.hbch:
 				// avoid dead loop when channel was closed
 				if r == nil {
+					if err := c.Register(s); err != nil {
+						fmt.Println(err.Error())
+						time.Sleep(10 * time.Second)
+					}
 					return
 				}
 			case <-c.ctx.Done():