sd/etcdv3: serve the keepalive response channel (#803)

read and discard keepalive response, make etcd library not to complain fix #799
go-kit · Mar 11, 2019 · 90f6ad6 · 90f6ad6
1 parent aef3868
commit 90f6ad6
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/sd/etcdv3/client.go b/sd/etcdv3/client.go
@@ -204,6 +204,18 @@ func (c *client) Register(s Service) error {
 		return err
 	}
 
+	// discard the keepalive response, make etcd library not to complain
+	// fix bug #799
+	go func() {
+		for {
+			select {
+			case <-c.hbch:
+			case <-c.ctx.Done():
+				return
+			}
+		}
+	}()
+
 	return nil
 }