From 6a0e39e5eee7fcdd622fffe6545481ca10e94f08 Mon Sep 17 00:00:00 2001 From: Brice Fernandes Date: Tue, 31 Oct 2017 15:35:53 +0000 Subject: [PATCH] Minor refactor for clarity --- prog/kube-peers/main.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/prog/kube-peers/main.go b/prog/kube-peers/main.go index 12e74fae..6589e74a 100644 --- a/prog/kube-peers/main.go +++ b/prog/kube-peers/main.go @@ -59,6 +59,7 @@ const ( // update the list of all peers that have gone through this code path func addMyselfToPeerList(cml *configMapAnnotations, c *kubernetes.Clientset, peerName, name string) (*peerList, error) { + common.Log.Infoln("Adding myself to peer list") var list *peerList err := cml.LoopUpdate(func() error { var err error @@ -181,11 +182,12 @@ func main() { } if justReclaim { cml := newConfigMapAnnotations(configMapNamespace, configMapName, c) - common.Log.Infoln("Adding myself to peer list") + _, err := addMyselfToPeerList(cml, c, peerName, nodeName) if err != nil { log.Fatalf("Could not get peer list: %v", err) } + weave := weaveapi.NewClient(os.Getenv("WEAVE_HTTP_ADDR"), common.Log) err = reclaimRemovedPeers(weave, cml, peers, peerName) if err != nil {