remove signals from start
Signed-off-by: Evan Hazlett <ejhazlett@gmail.com>
This commit is contained in:
parent
27fd24a181
commit
f8763a7a16
1 changed files with 1 additions and 3 deletions
4
start.go
4
start.go
|
@ -1,13 +1,11 @@
|
||||||
package element
|
package element
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"os"
|
|
||||||
|
|
||||||
"github.com/sirupsen/logrus"
|
"github.com/sirupsen/logrus"
|
||||||
)
|
)
|
||||||
|
|
||||||
// Start handles cluster events
|
// Start handles cluster events
|
||||||
func (a *Agent) Start(s chan os.Signal) error {
|
func (a *Agent) Start() error {
|
||||||
go func() {
|
go func() {
|
||||||
for range a.peerUpdateChan {
|
for range a.peerUpdateChan {
|
||||||
if err := a.members.UpdateNode(nodeUpdateTimeout); err != nil {
|
if err := a.members.UpdateNode(nodeUpdateTimeout); err != nil {
|
||||||
|
|
Loading…
Reference in a new issue