Add condition for backup disruption

Signed-off-by: Md. Ishtiaq Islam <[email protected]>
stashed · Aug 16, 2024 · 3fc7148 · 3fc7148
1 parent be71027
commit 3fc7148
Show file tree

Hide file tree

Showing 4 changed files with 21 additions and 1 deletion.
diff --git a/apis/stash/v1beta1/backup_session_types.go b/apis/stash/v1beta1/backup_session_types.go
@@ -236,6 +236,9 @@ const (
 
 	// DeadlineExceeded  indicates whether the session deadline was exceeded or not
 	DeadlineExceeded = "DeadlineExceeded"
+
+	// BackupDisrupted indicates whether the backup was disrupted or not
+	BackupDisrupted = "BackupDisrupted"
 )
 
 // =========================== Condition Reasons =======================
@@ -276,4 +279,6 @@ const (
 	FailedToExecutePostBackupHook      = "FailedToExecutePostBackupHook"
 
 	FailedToCompleteWithinDeadline = "FailedToCompleteWithinDeadline"
+
+	FailedToCompleteDueToDisruption = "FailedToCompleteDueToDisruption"
 )
diff --git a/pkg/conditions/backupsession.go b/pkg/conditions/backupsession.go
@@ -399,3 +399,17 @@ func SetBackupDeadlineExceededConditionToTrue(session *invoker.BackupSessionHand
 		},
 	})
 }
+
+func SetBackupDisruptedConditionToTrue(session *invoker.BackupSessionHandler, err error) error {
+	return session.UpdateStatus(&v1beta1.BackupSessionStatus{
+		Conditions: []kmapi.Condition{
+			{
+				Type:               v1beta1.BackupDisrupted,
+				Status:             metav1.ConditionTrue,
+				Reason:             v1beta1.FailedToCompleteDueToDisruption,
+				Message:            fmt.Sprintf("Failed to complete backup. Reason: %v.", err.Error()),
+				LastTransitionTime: metav1.Now(),
+			},
+		},
+	})
+}
diff --git a/pkg/invoker/backupsession.go b/pkg/invoker/backupsession.go
@@ -250,6 +250,7 @@ func calculateBackupSessionPhase(status *v1beta1.BackupSessionStatus) v1beta1.Ba
 
 	if cutil.IsConditionTrue(status.Conditions, v1beta1.MetricsPushed) &&
 		(cutil.IsConditionTrue(status.Conditions, v1beta1.DeadlineExceeded) ||
+			cutil.IsConditionTrue(status.Conditions, v1beta1.BackupDisrupted) ||
 			cutil.IsConditionFalse(status.Conditions, v1beta1.BackupHistoryCleaned) ||
 			cutil.IsConditionFalse(status.Conditions, v1beta1.GlobalPreBackupHookSucceeded) ||
 			cutil.IsConditionFalse(status.Conditions, v1beta1.GlobalPostBackupHookSucceeded)) {

diff --git a/pkg/invoker/restoresession.go b/pkg/invoker/restoresession.go
@@ -377,7 +377,7 @@ func checkRestoreFailureInHostStatus(status []v1beta1.HostRestoreStats) (bool, s
 
 func checkFailureInConditions(conditions []kmapi.Condition) (bool, string) {
 	for _, c := range conditions {
-		if c.Status == metav1.ConditionFalse || c.Type == v1beta1.DeadlineExceeded {
+		if c.Status == metav1.ConditionFalse || c.Type == v1beta1.DeadlineExceeded || c.Type == v1beta1.BackupDisrupted {
 			return true, c.Message
 		}
 	}