Figured out the channel is closing. Adding restart.

Author: arlaneenalra

cmd/root.go

@@ -126,7 +126,14 @@ func run(cmd *cobra.Command, args []string) {
 		nodeListeners[i] = m
 	}
 
-	if err := client.NodeWatch(nodeListeners); err != nil {
-		cobra.CheckErr(err.Error())
+	// This should never exit.
+	for restarts := 0; restarts < 5; restarts++ {
+		if err := client.NodeWatch(nodeListeners); err != nil {
+			cobra.CheckErr(err.Error())
+		}
+
+		log.WithFields(log.Fields{
+			"restarts": restarts,
+		}).Warn("node watch exited, restarting")
 	}
 }

internal/k8s/client.go

@@ -79,8 +79,7 @@ func (c *Client) NodeWatch(listeners []NodeListener) error {
 
 	eventChannel := nodeWatch.ResultChan()
 
-	for {
-		event := <-eventChannel
+	for event := range eventChannel {
 
 		// This will need to be revisited at a later date.
 		// TODO: Fix error handling
@@ -92,13 +91,6 @@ func (c *Client) NodeWatch(listeners []NodeListener) error {
 			continue
 		}
 
-		if event.Object == nil {
-			log.WithFields(log.Fields{
-				"type": event.Type,
-			}).Error("event with nil object, ignoring")
-      continue
-		}
-
 		node := event.Object.(*v1.Node)
 		endpoint := NewEndpoint(node.Spec.ProviderID, node.Status.Addresses)
 
@@ -131,5 +123,7 @@ func (c *Client) NodeWatch(listeners []NodeListener) error {
 		}
 	}
 
+	log.WithFields(log.Fields{}).Warn("watcher disconnected")
+
 	return nil
 }