From d597ca32bd6c008a091541939107b358fb1b0d89 Mon Sep 17 00:00:00 2001 From: Michael Crosby Date: Fri, 14 Sep 2018 16:46:26 -0400 Subject: [PATCH] Join peers in create --- start.go | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/start.go b/start.go index 2ecde43..b4d9488 100644 --- a/start.go +++ b/start.go @@ -7,7 +7,7 @@ import ( ) // Start handles cluster events -func (a *Agent) Start(s chan os.Signal) { +func (a *Agent) Start(s chan os.Signal) error { go func() { for range a.peerUpdateChan { if err := a.members.UpdateNode(nodeUpdateTimeout); err != nil { @@ -15,4 +15,10 @@ func (a *Agent) Start(s chan os.Signal) { } } }() + if len(a.config.Peers) > 0 { + if _, err := a.members.Join(a.config.Peers); err != nil { + return err + } + } + return nil }