Add support for initialCooldownPeriod On httpScaledObjects

Signed-off-by: Shay Rybak <[email protected]>
kedacore · Dec 11, 2024 · b929705 · b929705
1 parent 45f645f
commit b929705
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 4 deletions.
diff --git a/operator/apis/http/v1alpha1/httpscaledobject_types.go b/operator/apis/http/v1alpha1/httpscaledobject_types.go
@@ -102,6 +102,9 @@ type HTTPScaledObjectSpec struct {
 	// (optional) Cooldown period value
 	// +optional
 	CooldownPeriod *int32 `json:"scaledownPeriod,omitempty" description:"Cooldown period (seconds) for resources to scale down (Default 300)"`
+	// (optional) Initial period before scaling
+	// +optional
+	InitialCooldownPeriod int32 `json:"initialCooldownPeriod,omitempty" description:"Initial period (seconds) before scaling (Default 0)"`
 	// (optional) Configuration for the metric used for scaling
 	// +optional
 	ScalingMetric *ScalingMetricSpec `json:"scalingMetric,omitempty" description:"Configuration for the metric used for scaling. If empty 'concurrency' will be used"`

diff --git a/operator/controllers/http/scaled_object.go b/operator/controllers/http/scaled_object.go
@@ -44,6 +44,7 @@ func (r *HTTPScaledObjectReconciler) createOrUpdateScaledObject(
 		minReplicaCount,
 		maxReplicaCount,
 		httpso.Spec.CooldownPeriod,
+		httpso.Spec.InitialCooldownPeriod,
 	)
 
 	// Set HTTPScaledObject instance as the owner and controller

diff --git a/pkg/k8s/scaledobject.go b/pkg/k8s/scaledobject.go
@@ -27,6 +27,7 @@ func NewScaledObject(
 	minReplicas *int32,
 	maxReplicas *int32,
 	cooldownPeriod *int32,
+	initialCooldownPeriod int32,
 ) *kedav1alpha1.ScaledObject {
 	return &kedav1alpha1.ScaledObject{
 		TypeMeta: metav1.TypeMeta{
@@ -45,10 +46,11 @@ func NewScaledObject(
 				Kind:       workloadRef.Kind,
 				Name:       workloadRef.Name,
 			},
-			PollingInterval: ptr.To[int32](soPollingInterval),
-			CooldownPeriod:  cooldownPeriod,
-			MinReplicaCount: minReplicas,
-			MaxReplicaCount: maxReplicas,
+			PollingInterval:       ptr.To[int32](soPollingInterval),
+			CooldownPeriod:        cooldownPeriod,
+			InitialCooldownPeriod: initialCooldownPeriod,
+			MinReplicaCount:       minReplicas,
+			MaxReplicaCount:       maxReplicas,
 			Advanced: &kedav1alpha1.AdvancedConfig{
 				RestoreToOriginalReplicaCount: true,
 			},