add replicas.idle to set idleReplicaCount on SO

Signed-off-by: Luca Kuendig <[email protected]>

config/crd/bases/http.keda.sh_httpscaledobjects.yaml

@@ -33,6 +33,9 @@ spec:
     - jsonPath: .spec.replicas.max
       name: MaxReplicas
       type: integer
+    - jsonPath: .spec.replicas.idle
+      name: IdleReplicas
+      type: integer
     - jsonPath: .metadata.creationTimestamp
       name: Age
       type: date
@@ -66,6 +69,11 @@ spec:
               replicas:
                 description: (optional) Replica information
                 properties:
+                  idle:
+                    description: Amount of replicas to have in the deployment while
+                      being idle
+                    format: int32
+                    type: integer
                   max:
                     description: Maximum amount of replicas to have in the deployment
                       (Default 100)

e2e/k8s.go

@@ -46,6 +46,7 @@ func getScaledObject(
 		"",
 		1,
 		2,
+		0,
 		30,
 	)
 	if err != nil {

examples/xkcd/templates/httpscaledobject.yaml

@@ -12,3 +12,4 @@ spec:
     replicas:
         min: {{ .Values.autoscaling.http.minReplicas }}
         max: {{ .Values.autoscaling.http.maxReplicas }}
+        idle: {{ .Values.autoscaling.http.idleReplicas }}

examples/xkcd/values.yaml

@@ -46,3 +46,4 @@ autoscaling:
   http:
     minReplicas: 0
     maxReplicas: 10
+    idleReplicas: 0

operator/api/v1alpha1/httpscaledobject_types.go

@@ -84,6 +84,8 @@ type ReplicaStruct struct {
 	Min int32 `json:"min,omitempty" description:"Minimum amount of replicas to have in the deployment (Default 0)"`
 	// Maximum amount of replicas to have in the deployment (Default 100)
 	Max int32 `json:"max,omitempty" description:"Maximum amount of replicas to have in the deployment (Default 100)"`
+	// Amount of replicas to have in the deployment while being idle
+	Idle int32 `json:"idle,omitempty" description:"Amount of replicas to have in the deployment while being idle"`
 }
 
 // HTTPScaledObjectSpec defines the desired state of HTTPScaledObject
@@ -133,6 +135,7 @@ type HTTPScaledObjectStatus struct {
 // +kubebuilder:printcolumn:name="ScaleTargetPort",type="integer",JSONPath=".spec.scaleTargetRef"
 // +kubebuilder:printcolumn:name="MinReplicas",type="integer",JSONPath=".spec.replicas.min"
 // +kubebuilder:printcolumn:name="MaxReplicas",type="integer",JSONPath=".spec.replicas.max"
+// +kubebuilder:printcolumn:name="IdleReplicas",type="integer",JSONPath=".spec.replicas.idle"
 // +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp"
 // +kubebuilder:printcolumn:name="Active",type="string",JSONPath=".status.conditions[?(@.type==\"HTTPScaledObjectIsReady\")].status"
 

operator/controllers/scaled_object.go

@@ -25,7 +25,7 @@ func createOrUpdateScaledObject(
 	httpso *v1alpha1.HTTPScaledObject,
 ) error {
 	logger.Info("Creating scaled objects", "external scaler host name", externalScalerHostName)
-
+	logger.Info("This is the current httpso object", "output", httpso.Spec)
 	appScaledObject, appErr := k8s.NewScaledObject(
 		httpso.GetNamespace(),
 		fmt.Sprintf("%s-app", httpso.GetName()), // HTTPScaledObject name is the same as the ScaledObject name
@@ -34,6 +34,7 @@ func createOrUpdateScaledObject(
 		httpso.Spec.Host,
 		httpso.Spec.Replicas.Min,
 		httpso.Spec.Replicas.Max,
+		httpso.Spec.Replicas.Idle,
 		httpso.Spec.CooldownPeriod,
 	)
 	if appErr != nil {

operator/controllers/scaled_object_test.go

@@ -60,7 +60,7 @@ func TestCreateOrUpdateScaledObject(t *testing.T) {
 		metadata["name"],
 	)
 
-	// HTTPScaledObject min/max replicas are int32s,
+	// HTTPScaledObject min/max/idle replicas are int32s,
 	// but the ScaledObject's spec is decoded into
 	// an *unsructured.Unstructured (basically a map[string]interface{})
 	// which is an int64. we need to convert the
@@ -73,11 +73,16 @@ func TestCreateOrUpdateScaledObject(t *testing.T) {
 		int64(testInfra.httpso.Spec.Replicas.Max),
 		spec["maxReplicaCount"],
 	)
+	r.Equal(
+		int64(testInfra.httpso.Spec.Replicas.Idle),
+		spec["idleReplicaCount"],
+	)
 
 	// now update the min and max replicas on the httpso
 	// and call createOrUpdateScaledObject again
 	testInfra.httpso.Spec.Replicas.Min++
 	testInfra.httpso.Spec.Replicas.Max++
+	testInfra.httpso.Spec.Replicas.Idle++
 	r.NoError(createOrUpdateScaledObject(
 		testInfra.ctx,
 		testInfra.cl,
@@ -104,6 +109,10 @@ func TestCreateOrUpdateScaledObject(t *testing.T) {
 		int64(testInfra.httpso.Spec.Replicas.Max),
 		spec["maxReplicaCount"],
 	)
+	r.Equal(
+		int64(testInfra.httpso.Spec.Replicas.Idle),
+		spec["idleReplicaCount"],
+	)
 }
 
 func getSO(

operator/controllers/suite_test.go

@@ -72,8 +72,9 @@ func newCommonTestInfra(namespace, appName string) *commonTestInfra {
 				Port:       8081,
 			},
 			Replicas: v1alpha1.ReplicaStruct{
-				Min: 0,
-				Max: 20,
+				Min:  0,
+				Max:  20,
+				Idle: 0,
 			},
 		},
 	}

pkg/k8s/scaledobject.go

@@ -53,6 +53,7 @@ func NewScaledObject(
 	host string,
 	minReplicas,
 	maxReplicas int32,
+	idleReplicas int32,
 	cooldownPeriod int32,
 ) (*unstructured.Unstructured, error) {
 	// https://keda.sh/docs/1.5/faq/
@@ -79,6 +80,7 @@ func NewScaledObject(
 		"Labels":         labels,
 		"MinReplicas":    minReplicas,
 		"MaxReplicas":    maxReplicas,
+		"IdleReplicas":   idleReplicas,
 		"DeploymentName": deploymentName,
 		"ScalerAddress":  scalerAddress,
 		"Host":           host,

pkg/k8s/templates/scaledobject.yaml

@@ -10,6 +10,7 @@ metadata:
 spec:
   minReplicaCount: {{ .MinReplicas }}
   maxReplicaCount: {{ .MaxReplicas }}
+  idleReplicaCount: {{ .IdleReplicas }}
   cooldownPeriod: {{ .CooldownPeriod }}
   pollingInterval: 1
   scaleTargetRef: