[Draft]: Upgrade statemachine

.github/workflows/helm-test-workflow.yml

@@ -2,6 +2,7 @@ name: Helm Test WorkFlow
 on:
   push:
     branches:
+      - CSPL-2094-LM-upgrade-strategy
       - develop
       - main
 jobs:

.github/workflows/int-test-workflow.yml

@@ -2,6 +2,7 @@ name: Integration Test WorkFlow
 on:
   push:
     branches:
+      - CSPL-2094-LM-upgrade-strategy
       - develop
       - main
       - feature**

api/v4/clustermanager_types.go

@@ -67,6 +67,28 @@ type ClusterManagerStatus struct {
 
 	// Telemetry App installation flag
 	TelAppInstalled bool `json:"telAppInstalled"`
+
+	// Information tracked by the provisioner.
+	Provisioning ProvisionStatus `json:"provisioning"`
+
+	// OperationHistory holds information about operations performed
+	// on this splunk instance.
+	OperationHistory OperationHistory `json:"operationHistory,omitempty"`
+
+	// OperationalStatus holds the status of the splunk operations in upgrade
+	// +kubebuilder:validation:Enum="";OK;discovered;error;delayed;detached
+	OperationalStatus OperationalStatus `json:"operationalStatus"`
+
+	// ErrorCount records how many times the splunk has encoutered an error since the last successful operation
+	// +kubebuilder:default:=0
+	ErrorCount int `json:"errorCount"`
+
+	// the last error message reported by the provisioning subsystem
+	ErrorMessage string `json:"errorMessage"`
+
+	// ErrorType indicates the type of failure encountered when the
+	// OperationalStatus is OperationalStatusError
+	ErrorType ErrorType `json:"errorType,omitempty"`
 }
 
 // BundlePushInfo Indicates if bundle push required
@@ -109,6 +131,46 @@ func init() {
 	SchemeBuilder.Register(&ClusterManager{}, &ClusterManagerList{})
 }
 
+// SetOperationalStatus updates the OperationalStatus field and returns
+// true when a change is made or false when no change is made.
+func (cmstr *ClusterManager) SetOperationalStatus(status OperationalStatus) bool {
+	if cmstr.Status.OperationalStatus != status {
+		cmstr.Status.OperationalStatus = status
+		return true
+	}
+	return false
+}
+
+// OperationMetricForState returns a pointer to the metric for the given
+// provisioning state.
+func (cmstr *ClusterManager) OperationMetricForState(operation ProvisioningState) (metric *OperationMetric) {
+	history := &cmstr.Status.OperationHistory
+	switch operation {
+
+	case StateClusterManagerPrepare:
+		metric = &history.Prepare
+
+	case StateClusterManagerRestore:
+		metric = &history.Restore
+
+	case StateClusterManagerBackup:
+		metric = &history.Backup
+
+	case StateClusterManagerUpgrade:
+		metric = &history.Upgrade
+
+	case StateClusterManagerVerification:
+		metric = &history.Verification
+
+	case StateClusterManagerReady:
+		metric = &history.Ready
+
+	case StateClusterManagerError:
+		metric = &history.Error
+	}
+	return
+}
+
 // NewEvent creates a new event associated with the object and ready
 // to be published to the kubernetes API.
 func (cmstr *ClusterManager) NewEvent(eventType, reason, message string) corev1.Event {