diff --git a/etcd/etcd.go b/etcd/etcd.go index a84e0e419..90144cd08 100644 --- a/etcd/etcd.go +++ b/etcd/etcd.go @@ -46,7 +46,6 @@ type Etcd struct { listener net.Listener // Listener for Server peerListener net.Listener // Listener for PeerServer readyC chan bool // To signal when server is ready to accept connections - stopC chan bool // To signal when etcd is stopped with Stop() method } // New returns a new Etcd instance. @@ -57,7 +56,6 @@ func New(c *config.Config) *Etcd { return &Etcd{ Config: c, readyC: make(chan bool), - stopC: make(chan bool), } } @@ -220,8 +218,6 @@ func (e *Etcd) Run() { } <-peerServerClosed - close(e.stopC) // etcd instance is stopped, notify waiters. - log.Infof("etcd instance is stopped [name %s]", e.Config.Name) } @@ -231,10 +227,6 @@ func (e *Etcd) Stop() { e.listener.Close() } -func (e *Etcd) StopNotify() chan bool { - return e.stopC -} - func (e *Etcd) ReadyNotify() chan bool { return e.readyC }