Create MAX_CONCURRENT_RECONCILES env var

Author: pooknull

deploy/cw-bundle.yaml

@@ -811,6 +811,8 @@ spec:
               fieldPath: metadata.name
         - name: OPERATOR_NAME
           value: percona-xtradb-cluster-operator
+        - name: MAX_CONCURRENT_RECONCILES
+          value: "20"
         image: percona/percona-xtradb-cluster-operator:1.10.0
         imagePullPolicy: Always
         resources:

deploy/cw-operator.yaml

@@ -36,6 +36,8 @@ spec:
               fieldPath: metadata.name
         - name: OPERATOR_NAME
           value: percona-xtradb-cluster-operator
+        - name: MAX_CONCURRENT_RECONCILES
+          value: "20"
         image: percona/percona-xtradb-cluster-operator:1.10.0
         imagePullPolicy: Always
         resources:

deploy/operator.yaml

@@ -39,6 +39,8 @@ spec:
               fieldPath: metadata.name
         - name: OPERATOR_NAME
           value: percona-xtradb-cluster-operator
+        - name: MAX_CONCURRENT_RECONCILES
+          value: "20"
         image: perconalab/percona-xtradb-cluster-operator:main
         imagePullPolicy: Always
         livenessProbe:

pkg/controller/pxc/controller.go

@@ -4,7 +4,9 @@ import (
 	"context"
 	"encoding/base64"
 	"encoding/json"
+	"os"
 	"reflect"
+	"strconv"
 	"strings"
 	"sync"
 	"sync/atomic"
@@ -81,10 +83,31 @@ func newReconciler(mgr manager.Manager) (reconcile.Reconciler, error) {
 	}, nil
 }
 
+const (
+	MaxConcurrentReconcilesEnvVar = "MAX_CONCURRENT_RECONCILES"
+)
+
+func getMaxConcurrentReconciles() (int, error) {
+	s, found := os.LookupEnv(MaxConcurrentReconcilesEnvVar)
+	if !found {
+		return 0, errors.Errorf("%s must be set", MaxConcurrentReconcilesEnvVar)
+	}
+
+	value, err := strconv.Atoi(s)
+	if err != nil {
+		return 0, errors.Wrapf(err, "%s must be int", MaxConcurrentReconcilesEnvVar)
+	}
+	return value, nil
+}
+
 // add adds a new Controller to mgr with r as the reconcile.Reconciler
 func add(mgr manager.Manager, r reconcile.Reconciler) error {
+	mcr, err := getMaxConcurrentReconciles()
+	if err != nil {
+		return err
+	}
 	// Create a new controller
-	c, err := controller.New("perconaxtradbcluster-controller", mgr, controller.Options{MaxConcurrentReconciles: 20, Reconciler: r})
+	c, err := controller.New("perconaxtradbcluster-controller", mgr, controller.Options{MaxConcurrentReconciles: mcr, Reconciler: r})
 	if err != nil {
 		return err
 	}