Adding fields value reference in values.yaml

helm-charts/aerospike-cluster/values.yaml

@@ -113,3 +113,23 @@ operatorClientCert: {}
 
 ## Dev Mode
 devMode: false
+
+## maxUnavailable defines percentage/number of pods that can be allowed to go down or unavailable
+## before application disruption.
+maxUnavailable: 1
+
+## Disable the PodDisruptionBudget creation for the Aerospike cluster.
+disablePDB: false
+
+## enableDynamicConfigUpdate enables dynamic config update flow of the operator.
+enableDynamicConfigUpdate: false
+
+## rosterNodeBlockList is a list of blocked nodeIDs from roster in a strong-consistency setup
+## Replace the value with aerospike node id which needs to be blocked.
+rosterNodeBlockList:
+  - <aerospike-node-id>
+
+## k8sNodeBlockList is a list of Kubernetes nodes which are not used for Aerospike pods.
+## Replace the value with kubernetes cluster node name which needs to be blocked.
+k8sNodeBlockList:
+  - <node-name>

test/on_demand_operations_test.go

@@ -3,6 +3,7 @@ package test
 import (
 	goctx "context"
 	"fmt"
+	"time"
 
 	. "github.com/onsi/ginkgo/v2"
 	. "github.com/onsi/gomega"
@@ -80,7 +81,7 @@ var _ = Describe(
 				)
 
 				It(
-					"Should execute podRestart operations on all pods", func() {
+					"Should execute podRestart operation on all pods", func() {
 						aeroCluster, err := getCluster(
 							k8sClient, ctx, clusterNamespacedName,
 						)
@@ -138,16 +139,17 @@ var _ = Describe(
 						err = k8sClient.Update(ctx, aeroCluster)
 						Expect(err).ToNot(HaveOccurred())
 
-						aeroCluster, err = getCluster(
-							k8sClient, ctx, clusterNamespacedName,
-						)
-						Expect(err).ToNot(HaveOccurred())
+						Eventually(func() error {
+							aeroCluster, err = getCluster(
+								k8sClient, ctx, clusterNamespacedName,
+							)
+							Expect(err).ToNot(HaveOccurred())
 
-						aeroCluster.Spec.Operations[0].Kind = asdbv1.OperationPodRestart
-						aeroCluster.Spec.Operations[0].ID = "2"
+							aeroCluster.Spec.Operations[0].Kind = asdbv1.OperationPodRestart
+							aeroCluster.Spec.Operations[0].ID = "2"
 
-						err = updateCluster(k8sClient, ctx, aeroCluster)
-						Expect(err).ToNot(HaveOccurred())
+							return updateCluster(k8sClient, ctx, aeroCluster)
+						}, 1*time.Minute).ShouldNot(HaveOccurred())
 
 						operationTypeMap := map[string]asdbv1.OperationKind{
 							"operations-1-0": asdbv1.OperationPodRestart,