fix unit-tests

Author: pooknull

cmd/postgres-operator/main.go

@@ -113,6 +113,9 @@ func main() {
 	options, err := initManager(ctx)
 	assertNoError(err)
 
+	options.LeaderElection = true
+	options.LeaderElectionID = perconaRuntime.ElectionID
+
 	mgr, err := perconaRuntime.CreateRuntimeManager(
 		cfg,
 		features,

config/manager/default/manager.yaml

@@ -35,6 +35,8 @@ spec:
             value: INFO
           - name: DISABLE_TELEMETRY
             value: "false"
+          - name: PGO_WORKERS
+            value: "1"
         ports:
           - containerPort: 8080
             name: metrics

deploy/cw-bundle.yaml

@@ -47673,6 +47673,8 @@ spec:
           value: INFO
         - name: DISABLE_TELEMETRY
           value: "false"
+        - name: PGO_WORKERS
+          value: "1"
         image: perconalab/percona-postgresql-operator:main
         imagePullPolicy: Always
         livenessProbe:

percona/controller/pgcluster/controller_test.go

@@ -7,6 +7,7 @@ import (
 	"context"
 	"crypto/md5" //nolint:gosec
 	"fmt"
+	"os"
 	"strconv"
 	"sync"
 	"time"
@@ -24,8 +25,10 @@ import (
 	"k8s.io/apimachinery/pkg/types"
 	ctrl "sigs.k8s.io/controller-runtime"
 	"sigs.k8s.io/controller-runtime/pkg/client"
+	metricsServer "sigs.k8s.io/controller-runtime/pkg/metrics/server"
 
 	"github.com/percona/percona-postgresql-operator/internal/controller/postgrescluster"
+	internalRuntime "github.com/percona/percona-postgresql-operator/internal/controller/runtime"
 	"github.com/percona/percona-postgresql-operator/internal/feature"
 	"github.com/percona/percona-postgresql-operator/internal/naming"
 	perconaController "github.com/percona/percona-postgresql-operator/percona/controller"
@@ -539,7 +542,15 @@ var _ = Describe("Watching secrets", Ordered, func() {
 		Expect(err).NotTo(HaveOccurred())
 
 		Expect(err).To(Not(HaveOccurred()))
-		mgr, err := runtime.CreateRuntimeManager(namespace.Name, cfg, true, true, gate)
+
+		os.Setenv("PGO_TARGET_NAMESPACE", "")
+		mgr, err := runtime.CreateRuntimeManager(cfg, gate, internalRuntime.Options{
+			LeaderElection:         false,
+			HealthProbeBindAddress: "0",
+			Metrics: metricsServer.Options{
+				BindAddress: "0",
+			},
+		})
 		Expect(err).To(Succeed())
 		Expect(v2.AddToScheme(mgr.GetScheme())).To(Succeed())
 

percona/runtime/runtime.go

@@ -18,14 +18,12 @@ import (
 // default refresh interval in minutes
 const refreshInterval time.Duration = 60 * time.Minute
 
-const electionID string = "08db3feb.percona.com"
+const ElectionID string = "08db3feb.percona.com"
 
 // CreateRuntimeManager wraps internal/controller/runtime.NewManager and modifies the given options:
 //   - Fully overwrites the Cache field
 //   - Sets Cache.SyncPeriod to refreshInterval const
 //   - Sets Cache.DefaultNamespaces by using k8s.GetWatchNamespace() split by ","
-//   - Sets LeaderElection to true
-//   - Sets LeaderElectionID to the electionID const
 //   - Sets BaseContext to include the provided feature gates
 func CreateRuntimeManager(config *rest.Config, features feature.MutableGate, options manager.Options) (manager.Manager, error) {
 	namespaces, err := k8s.GetWatchNamespace()
@@ -45,9 +43,6 @@ func CreateRuntimeManager(config *rest.Config, features feature.MutableGate, opt
 		options.Cache.DefaultNamespaces = namespaces
 	}
 
-	options.LeaderElection = true
-	options.LeaderElectionID = electionID
-
 	options.BaseContext = func() context.Context {
 		ctx := context.Background()
 		return feature.NewContext(ctx, features)