From 59fb880b75750cbb9f4ff4af973f4f8a2f3d281d Mon Sep 17 00:00:00 2001 From: Victor Vieux Date: Mon, 19 Jan 2015 22:38:42 +0000 Subject: [PATCH] emitCustomEvent -> emitEvent Signed-off-by: Victor Vieux --- cluster/node.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/cluster/node.go b/cluster/node.go index 3889c8e523..e43bb1c381 100644 --- a/cluster/node.go +++ b/cluster/node.go @@ -95,7 +95,7 @@ func (n *Node) connectClient(client dockerclient.Client) error { // Start monitoring events from the Node. n.client.StartMonitorEvents(n.handler) - n.emitCustomEvent("node_connect") + n.emitEvent("node_connect") return nil } @@ -261,7 +261,7 @@ func (n *Node) refreshLoop() { if err != nil { if n.healthy { - n.emitCustomEvent("node_disconnect") + n.emitEvent("node_disconnect") } n.healthy = false log.Errorf("[%s/%s] Flagging node as dead. Updated state failed: %v", n.ID, n.Name, err) @@ -270,7 +270,7 @@ func (n *Node) refreshLoop() { log.Infof("[%s/%s] Node came back to life. Hooray!", n.ID, n.Name) n.client.StopAllMonitorEvents() n.client.StartMonitorEvents(n.handler) - n.emitCustomEvent("node_reconnect") + n.emitEvent("node_reconnect") if err := n.updateSpecs(); err != nil { log.Errorf("[%s/%s] Update node specs failed: %v", n.ID, n.Name, err) } @@ -280,7 +280,7 @@ func (n *Node) refreshLoop() { } } -func (n *Node) emitCustomEvent(event string) { +func (n *Node) emitEvent(event string) { // If there is no event handler registered, abort right now. if n.eventHandler == nil { return