K8SPG-761: Apply PGO_WORKERS to all controllers (#1189)

* K8SPG-761: Apply PGO_WORKERS to all controllers

* fix unit tests

* fix golangci-lint

---------

Co-authored-by: Viacheslav Sarzhan <slava.sarzhan@percona.com>

Author: egegunes

cmd/postgres-operator/main.go

@@ -305,12 +305,20 @@ func initManager(ctx context.Context) (runtime.Options, error) {
 	}
 
 	options.Controller.GroupKindConcurrency = map[string]int{
-		"PostgresCluster." + v1beta1.GroupVersion.Group: 2,
+		"PostgresCluster." + v1beta1.GroupVersion.Group: 1,
+		"PGUpgrade." + v1beta1.GroupVersion.Group:       1,
+		"PGAdmin." + v1beta1.GroupVersion.Group:         1,
+		"PerconaPGCluster." + v2.GroupVersion.Group:     1,
+		"PerconaPGUpgrade." + v2.GroupVersion.Group:     1,
+		"PerconaPGBackup." + v2.GroupVersion.Group:      1,
+		"PerconaPGRestore." + v2.GroupVersion.Group:     1,
 	}
 
 	if s := os.Getenv("PGO_WORKERS"); s != "" {
 		if i, err := strconv.Atoi(s); err == nil && i > 0 {
-			options.Controller.GroupKindConcurrency["PostgresCluster."+v1beta1.GroupVersion.Group] = i
+			for kind := range options.Controller.GroupKindConcurrency {
+				options.Controller.GroupKindConcurrency[kind] = i
+			}
 		} else {
 			log.Error(err, "PGO_WORKERS must be a positive number")
 		}

cmd/postgres-operator/main_test.go

@@ -28,7 +28,13 @@ func TestInitManager(t *testing.T) {
 
 		assert.DeepEqual(t, options.Controller.GroupKindConcurrency,
 			map[string]int{
-				"PostgresCluster.postgres-operator.crunchydata.com": 2,
+				"PGAdmin.postgres-operator.crunchydata.com":         1,
+				"PGUpgrade.postgres-operator.crunchydata.com":       1,
+				"PerconaPGBackup.pgv2.percona.com":                  1,
+				"PerconaPGCluster.pgv2.percona.com":                 1,
+				"PerconaPGRestore.pgv2.percona.com":                 1,
+				"PerconaPGUpgrade.pgv2.percona.com":                 1,
+				"PostgresCluster.postgres-operator.crunchydata.com": 1,
 			})
 
 		assert.Assert(t, options.Cache.DefaultNamespaces == nil)
@@ -103,7 +109,13 @@ func TestInitManager(t *testing.T) {
 				assert.NilError(t, err)
 				assert.DeepEqual(t, options.Controller.GroupKindConcurrency,
 					map[string]int{
-						"PostgresCluster.postgres-operator.crunchydata.com": 2,
+						"PGAdmin.postgres-operator.crunchydata.com":         1,
+						"PGUpgrade.postgres-operator.crunchydata.com":       1,
+						"PerconaPGBackup.pgv2.percona.com":                  1,
+						"PerconaPGCluster.pgv2.percona.com":                 1,
+						"PerconaPGRestore.pgv2.percona.com":                 1,
+						"PerconaPGUpgrade.pgv2.percona.com":                 1,
+						"PostgresCluster.postgres-operator.crunchydata.com": 1,
 					})
 			}
 		})
@@ -115,6 +127,12 @@ func TestInitManager(t *testing.T) {
 			assert.NilError(t, err)
 			assert.DeepEqual(t, options.Controller.GroupKindConcurrency,
 				map[string]int{
+					"PGAdmin.postgres-operator.crunchydata.com":         19,
+					"PGUpgrade.postgres-operator.crunchydata.com":       19,
+					"PerconaPGBackup.pgv2.percona.com":                  19,
+					"PerconaPGCluster.pgv2.percona.com":                 19,
+					"PerconaPGRestore.pgv2.percona.com":                 19,
+					"PerconaPGUpgrade.pgv2.percona.com":                 19,
 					"PostgresCluster.postgres-operator.crunchydata.com": 19,
 				})
 		})