adding rollingStepSize to helm chart proxy spec

Signed-off-by: Chaitanya Kolluru <[email protected]>

Author: chaitanyakolluru

api/v1alpha1/condition_consts.go

@@ -42,9 +42,20 @@ const (
 	// ClusterSelectionFailedReason indicates that the HelmChartProxy controller failed to select the workload Clusters.
 	ClusterSelectionFailedReason = "ClusterSelectionFailed"
 
+	// HelmReleaseProxiesRolloutNotReady indicates that the initial rollout
+	// of HelmReleaseProxies has not been completed.
+	HelmReleaseProxiesRolloutNotReady = "HelmReleaseProxiesRolloutNotReady"
+
+	// HelmReleaseProxiesRolloutUndefined indicates that HelmChartProxy doesn't
+	// use Rollout Step Size to reconcile HelmReleaseProxies.
+	HelmReleaseProxiesRolloutUndefined = "HelmReleaseProxiesRolloutUndefined"
+
 	// HelmReleaseProxiesReadyCondition indicates that the HelmReleaseProxies are ready, meaning that the Helm installation, upgrade
 	// or deletion is complete.
 	HelmReleaseProxiesReadyCondition clusterv1.ConditionType = "HelmReleaseProxiesReady"
+
+	// HelmReleaseProxiesRolloutCompletedCondition indicates if the initial rollout of HelmReleaseProxies is complete.
+	HelmReleaseProxiesRolloutCompletedCondition clusterv1.ConditionType = "HelmReleaseProxiesRolloutCompleted"
 )
 
 // HelmReleaseProxy Conditions and Reasons.

api/v1alpha1/helmchartproxy_types.go

@@ -19,6 +19,7 @@ package v1alpha1
 import (
 	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/util/intstr"
 	clusterv1 "sigs.k8s.io/cluster-api/api/v1beta1"
 )
 
@@ -84,6 +85,14 @@ type HelmChartProxySpec struct {
 	// +optional
 	ReconcileStrategy string `json:"reconcileStrategy,omitempty"`
 
+	// RolloutStepSize is an opt-in feature that defines the step size during
+	// initial rollout of HelmReleaseProxy resources on matching clusters.
+	// Once all existing HelmReleaseProxy resources are ready=true, the next
+	// batch of HelmReleaseProxy resources are reconciled.
+	// If undefined, will default to creating HelmReleaseProxy resources for all
+	// matching clusters.
+	RolloutStepSize *intstr.IntOrString `json:"rolloutStepSize,omitempty"`
+
 	// Options represents CLI flags passed to Helm operations (i.e. install, upgrade, delete) and
 	// include options such as wait, skipCRDs, timeout, waitForJobs, etc.
 	// +optional
@@ -288,6 +297,17 @@ func (c *HelmChartProxy) SetConditions(conditions clusterv1.Conditions) {
 	c.Status.Conditions = conditions
 }
 
+func (c *HelmChartProxy) GetHelmReleaseProxyReadyCondition() *clusterv1.Condition {
+	cnds := c.GetConditions()
+	for _, cnd := range cnds {
+		if cnd.Type == HelmReleaseProxiesReadyCondition {
+			return &cnd
+		}
+	}
+
+	return nil
+}
+
 // SetMatchingClusters will set the given list of matching clusters on an HelmChartProxy object.
 func (c *HelmChartProxy) SetMatchingClusters(clusterList []clusterv1.Cluster) {
 	matchingClusters := make([]corev1.ObjectReference, 0, len(clusterList))

api/v1alpha1/zz_generated.deepcopy.go

@@ -279,6 +279,18 @@ spec:
                   RepoURL is the URL of the Helm chart repository.
                   e.g. chart-path oci://repo-url/chart-name as repoURL: oci://repo-url and https://repo-url/chart-name as repoURL: https://repo-url
                 type: string
+              rolloutStepSize:
+                anyOf:
+                - type: integer
+                - type: string
+                description: |-
+                  RolloutStepSize is an opt-in feature that defines the step size during
+                  initial rollout of HelmReleaseProxy resources on matching clusters.
+                  Once all existing HelmReleaseProxy resources are ready=true, the next
+                  batch of HelmReleaseProxy resources are reconciled.
+                  If undefined, will default to creating HelmReleaseProxy resources for all
+                  matching clusters.
+                x-kubernetes-int-or-string: true
               tlsConfig:
                 description: TLSConfig contains the TLS configuration for a HelmChartProxy.
                 properties: