mix update.

Author: zlianzhuang

platforms/kubernetes/postgres-operator/deploy/postgres-operator.yaml.template

@@ -159,6 +159,8 @@ spec:
                           properties:
                             image:
                               type: string
+                            name:
+                              type: string
                             resources:
                               type: object
                               x-kubernetes-preserve-unknown-fields: true
@@ -220,6 +222,8 @@ spec:
                               properties:
                                 image:
                                   type: string
+                                name:
+                                  type: string
                                 resources:
                                   type: object
                                   x-kubernetes-preserve-unknown-fields: true
@@ -262,6 +266,8 @@ spec:
                               properties:
                                 image:
                                   type: string
+                                name:
+                                  type: string
                                 resources:
                                   type: object
                                   x-kubernetes-preserve-unknown-fields: true

platforms/kubernetes/postgres-operator/deploy/postgresql.yaml

@@ -31,16 +31,13 @@ spec:
     podspec:
       terminationGracePeriodSeconds: 60
       containers:
-        - image: radondb-postgresql:12.9-v1.0.0
+        - image: docker.io/library/radondb-postgresql:14.5-v1.0.0
           imagePullPolicy: IfNotPresent
           name: postgresql #can't change the name
           volumeMounts:
             - name: data # can't change the name
               mountPath: /var/lib/postgresql/data
           resources:
-            requests:
-              memory: "200Mi"
-              cpu: "0.2"
             limits:
               memory: "200Mi"
               cpu: "0.2"
@@ -57,8 +54,6 @@ spec:
       admin:
         - name: root
           password: root
-        - name: root1
-          password: root1
       normal:
         - name: lzzhang
           password: lzzhang
@@ -74,19 +69,16 @@ spec:
       podspec:
         terminationGracePeriodSeconds: 60
         containers:
-          - image: radondb-postgresql:12.9-v1.0.0
+          - image: docker.io/library/radondb-postgresql:14.5-v1.0.0
             imagePullPolicy: IfNotPresent
             name: postgresql #can't change the name
             volumeMounts:
               - name: data # can't change the name
                 mountPath: /var/lib/postgresql/data
             resources:
-              requests:
-                memory: "200Mi"
-                cpu: "0.3"
               limits:
                 memory: "200Mi"
-                cpu: "0.3"
+                cpu: "0.2"
       volumeClaimTemplates:
         - metadata:
             name: data
@@ -101,19 +93,16 @@ spec:
       podspec:
         terminationGracePeriodSeconds: 60
         containers:
-          - image: radondb-postgresql:12.9-v1.0.0
+          - image: docker.io/library/radondb-postgresql:14.5-v1.0.0
             imagePullPolicy: IfNotPresent
             name: postgresql #can't change the name
             volumeMounts:
               - name: data # can't change the name
                 mountPath: /var/lib/postgresql/data
             resources:
-              requests:
-                memory: "200Mi"
-                cpu: "0.3"
               limits:
                 memory: "200Mi"
-                cpu: "0.3"
+                cpu: "0.2"
       volumeClaimTemplates:
         - metadata:
             name: data

platforms/kubernetes/postgres-operator/postgres/constants.py

@@ -18,7 +18,7 @@
 SPEC = "spec"
 CONTAINERS = "containers"
 CONTAINER_NAME = "name"
-POSTGRESQL_CONTAINER = "postgresql"
+PODSPEC_CONTAINERS_POSTGRESQL_CONTAINER = "postgresql"
 PRIME_SERVICE_PORT_NAME = "prime"
 HBAS = "hbas"
 CONFIGS = "configs"

platforms/kubernetes/postgres-operator/postgres/handle.py

@@ -29,7 +29,7 @@
     SPEC,
     CONTAINERS,
     CONTAINER_NAME,
-    POSTGRESQL_CONTAINER,
+    PODSPEC_CONTAINERS_POSTGRESQL_CONTAINER,
     PRIME_SERVICE_PORT_NAME,
     HBAS,
     CONFIGS,
@@ -527,13 +527,17 @@ def waiting_instance_ready(conns: InstanceConnections, logger: logging.Logger):
 
 
 def create_statefulset(
+    meta: kopf.Meta,
+    spec: kopf.Spec,
+    patch: kopf.Patch,
+    status: kopf.Status,
+    logger: logging.Logger,
     name: str,
     namespace: str,
     labels: LabelType,
     podspec_need_copy: TypedDict,
     vct: TypedDict,
     env: TypedDict,
-    logger: logging.Logger,
 ) -> None:
 
     apps_v1_api = client.AppsV1Api()
@@ -550,7 +554,7 @@ def create_statefulset(
     podspec = podspec_need_copy.copy()
     podspec["restartPolicy"] = "Always"
     for container in podspec[CONTAINERS]:
-        if container[CONTAINER_NAME] == POSTGRESQL_CONTAINER:
+        if container[CONTAINER_NAME] == PODSPEC_CONTAINERS_POSTGRESQL_CONTAINER:
             container["args"] = ["auto_failover"]
             container["env"] = env
             container["readinessProbe"] = {
@@ -655,7 +659,7 @@ def create_postgresql(
         machine_data_path = operator_config.DATA_PATH_POSTGRESQL
 
     for container in localspec[PODSPEC][CONTAINERS]:
-        if container[CONTAINER_NAME] == POSTGRESQL_CONTAINER:
+        if container[CONTAINER_NAME] == PODSPEC_CONTAINERS_POSTGRESQL_CONTAINER:
             postgresql_image = container[IMAGE]
 
     if mode == MACHINE_MODE:
@@ -681,12 +685,14 @@ def create_postgresql(
     for config in configs:
         name = config.split("=")[0].strip()
         value = config[config.find("=") + 1:].strip()
-        config = name + "=" + value
+
         if name in PG_CONFIG_IGNORE:
             continue
+
         if field == get_field(AUTOFAILOVER) and name == 'port':
-            continue
+            value = str(AUTO_FAILOVER_PORT)
 
+        config = name + "=" + value
         if mode == MACHINE_MODE:
             machine_env += PG_CONFIG_PREFIX + config + "\n"
         else:
@@ -896,9 +902,9 @@ def create_postgresql(
                 statefulset_name_get_service_name(name),
                 statefulset_name_get_external_service_name(name), namespace,
                 labels, logger, meta)
-            create_statefulset(name, namespace, labels, localspec[PODSPEC],
-                               localspec[VOLUMECLAIMTEMPLATES], k8s_env,
-                               logger)
+            create_statefulset(meta, spec, patch, status, logger,
+                               name, namespace, labels, localspec[PODSPEC],
+                               localspec[VOLUMECLAIMTEMPLATES], k8s_env)
 
         # wait primary node create finish
         if wait_primary == True and field == get_field(
@@ -2279,7 +2285,7 @@ def correct_user_password(
     PASSWORD_FAILED_MESSAGEd = "password authentication failed for user"
 
     if get_conn_role(conn) == AUTOFAILOVER:
-        port = 55555
+        port = AUTO_FAILOVER_PORT
         user = AUTOCTL_NODE
         password = patch.status.get(AUTOCTL_NODE)
         if password == None: