// Run starts connecting to others and never returns unless Stop is called.
Run starts connecting to others and never returns unless Stop is called.
// Run starts connecting to others and never returns unless Stop is called .
func (c *Cluster) Run() {
	for {
		c.WaitForMastership()
		c.ch = make(chan struct{})
		close(c.ch)
	}
}
func ( c * Cluster ) Run ( ) { for { c . WaitForMastership ( ) c . ch = make ( chan struct { } ) close ( c . ch ) } }
Run starts connecting to others and never returns unless Stop is called.
Run starts connecting to others and never returns unless Stop is called .
// wait till we lose mastership