From 4ae79a8ff7e1667db28b4d8a08b903ff99121caa Mon Sep 17 00:00:00 2001 From: Victor Vieux Date: Sat, 24 Jan 2015 11:13:36 -0800 Subject: [PATCH] update for dockerclient Signed-off-by: Victor Vieux --- cluster/node.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/cluster/node.go b/cluster/node.go index 4eb3e8fdbf..e0970e8af3 100644 --- a/cluster/node.go +++ b/cluster/node.go @@ -98,7 +98,7 @@ func (n *Node) connectClient(client dockerclient.Client) error { go n.refreshLoop() // Start monitoring events from the Node. - n.client.StartMonitorEvents(n.handler) + n.client.StartMonitorEvents(n.handler, nil) n.emitEvent("node_connect") return nil @@ -273,7 +273,7 @@ func (n *Node) refreshLoop() { if !n.healthy { log.Infof("[%s/%s] Node came back to life. Hooray!", n.ID, n.Name) n.client.StopAllMonitorEvents() - n.client.StartMonitorEvents(n.handler) + n.client.StartMonitorEvents(n.handler, nil) n.emitEvent("node_reconnect") if err := n.updateSpecs(); err != nil { log.Errorf("[%s/%s] Update node specs failed: %v", n.ID, n.Name, err) @@ -438,7 +438,7 @@ func (n *Node) String() string { return fmt.Sprintf("node %s addr %s", n.ID, n.Addr) } -func (n *Node) handler(ev *dockerclient.Event, args ...interface{}) { +func (n *Node) handler(ev *dockerclient.Event, _ chan error, args ...interface{}) { // Something changed - refresh our internal state. if ev.Status == "pull" || ev.Status == "untag" || ev.Status == "delete" { n.refreshImages()