K8SPSMDB-1610 cluster sync integration (#2392)

* K8SPSMDB-1610 cluster sync integration

* cr: check after finalize + use equals for counting the docs

* cr: address various comments

* cr: address more code review comments

* fix cr

* fixes

* leases

* backups/restores leases

* fix on error

* handle leases held by another cr

---------

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

Author: gkech

cmd/manager/main.go

@@ -115,16 +115,18 @@ func main() {
 	}
 
 	options.Controller.GroupKindConcurrency = map[string]int{
-		"PerconaServerMongoDB." + psmdbv1.SchemeGroupVersion.Group:        1,
-		"PerconaServerMongoDBBackup." + psmdbv1.SchemeGroupVersion.Group:  1,
-		"PerconaServerMongoDBRestore." + psmdbv1.SchemeGroupVersion.Group: 1,
+		"PerconaServerMongoDB." + psmdbv1.SchemeGroupVersion.Group:            1,
+		"PerconaServerMongoDBBackup." + psmdbv1.SchemeGroupVersion.Group:      1,
+		"PerconaServerMongoDBRestore." + psmdbv1.SchemeGroupVersion.Group:     1,
+		"PerconaServerMongoDBClusterSync." + psmdbv1.SchemeGroupVersion.Group: 1,
 	}
 
 	if s := os.Getenv("MAX_CONCURRENT_RECONCILES"); s != "" {
 		if i, err := strconv.Atoi(s); err == nil && i > 0 {
 			options.Controller.GroupKindConcurrency["PerconaServerMongoDB."+psmdbv1.SchemeGroupVersion.Group] = i
 			options.Controller.GroupKindConcurrency["PerconaServerMongoDBBackup."+psmdbv1.SchemeGroupVersion.Group] = i
 			options.Controller.GroupKindConcurrency["PerconaServerMongoDBRestore."+psmdbv1.SchemeGroupVersion.Group] = i
+			options.Controller.GroupKindConcurrency["PerconaServerMongoDBClusterSync."+psmdbv1.SchemeGroupVersion.Group] = i
 		} else {
 			setupLog.Error(err, "MAX_CONCURRENT_RECONCILES must be a positive number")
 			os.Exit(1)

config/crd/bases/psmdb.percona.com_perconaservermongodbclustersyncs.yaml

@@ -3,13 +3,15 @@
 # It should be run by config/default
 resources:
 - bases/psmdb.percona.com_perconaservermongodbbackups.yaml
+- bases/psmdb.percona.com_perconaservermongodbclustersyncs.yaml
 - bases/psmdb.percona.com_perconaservermongodbrestores.yaml
 - bases/psmdb.percona.com_perconaservermongodbs.yaml
 #+kubebuilder:scaffold:crdkustomizeresource
 
 patchesStrategicMerge:
   - patches/versionlabel_in_psmdb.yaml
   - patches/versionlabel_in_psmdbbackup.yaml
+  - patches/versionlabel_in_psmdbclustersync.yaml
   - patches/versionlabel_in_psmdbrestore.yaml
 
 patches:

config/crd/kustomization.yaml

@@ -0,0 +1,9 @@
+apiVersion: apiextensions.k8s.io/v1
+kind: CustomResourceDefinition
+metadata:
+  name: perconaservermongodbclustersyncs.psmdb.percona.com
+  labels:
+    app.kubernetes.io/name: percona-server-mongodb
+    app.kubernetes.io/version: v1.23.0
+    app.kubernetes.io/component: crd
+    app.kubernetes.io/part-of: percona-server-mongodb-operator

config/crd/patches/versionlabel_in_psmdbclustersync.yaml

@@ -0,0 +1,35 @@
+apiVersion: psmdb.percona.com/v1
+kind: PerconaServerMongoDBClusterSync
+metadata:
+  name: my-cluster-sync
+spec:
+  clusterName: my-target-cluster-name
+  image: percona/percona-clustersync-mongodb:0.9.0
+  # mode controls the PCSM lifecycle intent. Allowed values:
+  #   running   - start/resume replication (default)
+  #   paused    - pause an active replication
+  #   finalized - stop replication and tear down owned resources
+  mode: running
+  source:
+    uri: mongodb://source-cluster-mongos.source-namespace.svc.cluster.local:27017
+    credentialsSecret: my-cluster-sync-source
+  # excludeNamespaces lists MongoDB namespaces (db or db.collection) to skip.
+  # excludeNamespaces:
+  #   - admin
+  #   - local
+  # resources:
+  #   requests:
+  #     cpu: 500m
+  #     memory: 512Mi
+  #   limits:
+  #     cpu: "2"
+  #     memory: 2Gi
+---
+apiVersion: v1
+kind: Secret
+metadata:
+  name: my-cluster-sync-source
+type: Opaque
+stringData:
+  username: source
+  password: mys3cretpAss