change update strategy

charts/redisoperator/Chart.yaml

@@ -1,4 +1,4 @@
 apiVersion: v1
 description: A Helm chart for the Spotahome Redis Operator
 name: redisoperator
-version: 3.0.0
+version: 3.1.0

operator/redisfailover/checker.go

@@ -11,6 +11,61 @@ const (
 	timeToPrepare = 2 * time.Minute
 )
 
+//Checks if the running version of pods are equal to the statefulset one
+func (r *RedisFailoverHandler) UpdateRedisesPods(rf *redisfailoverv1.RedisFailover) error {
+	redises, err := r.rfChecker.GetRedisesIPs(rf)
+	if err != nil {
+		return err
+	}
+
+	//If we have syincing nodes we finish checks
+	for _, rp := range redises {
+		sync, err := r.rfChecker.CheckRedisSyncing(rp, rf)
+		if err != nil {
+			return err
+		}
+		if sync {
+			//currently syncing, we wait next round
+			return nil
+		}
+	}
+
+	ssUR, err := r.rfChecker.GetStatefulSetUpdateRevision(rf)
+	if err != nil {
+		return err
+	}
+
+	redisesPods, err := r.rfChecker.GetRedisesSlavesPods(rf)
+	if err != nil {
+		return err
+	}
+
+	//If some slaves are not in the correct version, delete them
+	for _, pod := range redisesPods {
+		revision, err := r.rfChecker.GetRedisRevisionHash(pod, rf)
+		if err != nil {
+			return err
+		}
+		if revision != ssUR {
+			//Delete pod and wait next round to check if the new one is synced
+			r.rfHealer.DeletePod(pod, rf)
+			return nil
+		}
+	}
+
+	//If all slaves are up and synced, we check master
+	master, err := r.rfChecker.GetRedisesMasterPod(rf)
+
+	masterRevision, err := r.rfChecker.GetRedisRevisionHash(master, rf)
+	if masterRevision != ssUR {
+		//Delete pod and wait next round to check if the new one is synced
+		r.rfHealer.DeletePod(master, rf)
+		return nil
+	}
+
+	return nil
+}
+
 func (r *RedisFailoverHandler) CheckAndHeal(rf *redisfailoverv1.RedisFailover) error {
 	// Number of redis is equal as the set on the RF spec
 	// Number of sentinel is equal as the set on the RF spec
@@ -87,6 +142,11 @@ func (r *RedisFailoverHandler) CheckAndHeal(rf *redisfailoverv1.RedisFailover) e
 		}
 	}
 
+	err = r.UpdateRedisesPods(rf)
+	if err != nil {
+		return err
+	}
+
 	sentinels, err := r.rfChecker.GetSentinelsIPs(rf)
 	if err != nil {
 		return err