diff --git a/pkg/cluster/cluster.go b/pkg/cluster/cluster.go index c354fb3124905a7114b46d2a2aa590d607dd9b8a..f0f7bb19e438eb9dffa9e69cdb42d54771ab2ec2 100644 --- a/pkg/cluster/cluster.go +++ b/pkg/cluster/cluster.go @@ -39,11 +39,11 @@ func (c *Cluster) Run() { // Start waiting for events events := c.ml.Events() err := c.ml.Start() - instr := c.ml.Instr() - instrUpdates := instr.Updates() if err != nil { logrus.Fatal("could not start memberlist: ", err) } + instr := c.ml.Instr() + instrUpdates := instr.Updates() go c.ml.Run() for { select {