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 }