Exit when losing leadership

fluxcd · Jul 7, 2019 · 266fc92 · 266fc92
1 parent b1bb9fa
commit 266fc92
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 10 deletions.
diff --git a/cmd/flagger/main.go b/cmd/flagger/main.go
@@ -265,7 +265,8 @@ func startLeaderElection(ctx context.Context, run func(), ns string, kubeClient
 				run()
 			},
 			OnStoppedLeading: func() {
-				logger.Infof("Leader election lost")
+				logger.Infof("Leadership lost")
+				os.Exit(1)
 			},
 			OnNewLeader: func(identity string) {
 				if identity != id {

diff --git a/pkg/controller/controller.go b/pkg/controller/controller.go
@@ -216,15 +216,6 @@ func (c *Controller) syncHandler(key string) error {
 	}
 
 	c.canaries.Store(fmt.Sprintf("%s.%s", cd.Name, cd.Namespace), cd)
-
-	//if cd.Spec.TargetRef.Kind == "Deployment" {
-	//	err = c.bootstrapDeployment(cd)
-	//	if err != nil {
-	//		c.logger.Warnf("%s.%s bootstrap error %v", cd.Name, cd.Namespace, err)
-	//		return err
-	//	}
-	//}
-
 	c.logger.Infof("Synced %s", key)
 
 	return nil