alter cluster_create field to state

Author: yanboer

docs/index.yaml

@@ -3,9 +3,9 @@ entries:
   postgres-operator:
   - apiVersion: v2
     appVersion: v0.9.0
-    created: "2022-10-26T11:23:13.433386984+08:00"
+    created: "2022-10-28T12:26:56.118402102+08:00"
     description: A Helm chart for Kubernetes
-    digest: ce205b9aa4ec8f96d6c632fb9767e3702dde5ea6ac56a988d63a618ebd1f8ff9
+    digest: a321f1cc510f737fab2b240d850c447b533accb14b7fe60c978f236fa515bef4
     home: https://github.com/radondb/multi-platform-postgresql
     keywords:
     - operator
@@ -25,4 +25,4 @@ entries:
     urls:
     - https://radondb.github.io/multi-platform-postgresql/postgres-operator-v1.0.0.tgz
     version: v1.0.0
-generated: "2022-10-26T11:23:13.432936706+08:00"
+generated: "2022-10-28T12:26:56.117932431+08:00"

docs/postgres-operator-v1.0.0.tgz

@@ -28,9 +28,9 @@ spec:
       name: DeletePvc
       type: boolean
       priority: 0           # show in standard view
-    - jsonPath: .status.cluster_create
+    - jsonPath: .status.state
       description: The postgresql cluster status
-      name: Clusterstatus
+      name: State
       type: string
       priority: 0           # show in standard view
     - jsonPath: .spec.autofailover.podspec.containers[0].image

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

@@ -28,9 +28,9 @@ spec:
       name: DeletePvc
       type: boolean
       priority: 0           # show in standard view
-    - jsonPath: .status.cluster_create
+    - jsonPath: .status.state
       description: The postgresql cluster status
-      name: Clusterstatus
+      name: State
       type: string
       priority: 0           # show in standard view
     - jsonPath: .spec.autofailover.podspec.containers[0].image

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

@@ -64,7 +64,7 @@
 RESOURCE_KIND_POSTGRESQL = "PostgreSQL"
 
 # status.CLUSTER_CREATE_CLUSTER
-CLUSTER_CREATE_CLUSTER = "cluster_create"
+CLUSTER_STATE = "state"
 CLUSTER_CREATE_BEGIN = "begin"
 CLUSTER_CREATE_ADD_FAILOVER = "addition failover"
 CLUSTER_CREATE_ADD_READWRITE = "addition readwrite"

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

@@ -64,7 +64,7 @@
     API_VERSION_V1,
     RESOURCE_POSTGRESQL,
     RESOURCE_KIND_POSTGRESQL,
-    CLUSTER_CREATE_CLUSTER,
+    CLUSTER_STATE,
     CLUSTER_CREATE_BEGIN,
     CLUSTER_CREATE_ADD_FAILOVER,
     CLUSTER_CREATE_ADD_READWRITE,
@@ -2513,7 +2513,7 @@ async def create_cluster(
     logger: logging.Logger,
 ) -> None:
     try:
-        set_cluster_status(meta, CLUSTER_CREATE_CLUSTER, CLUSTER_STATUS_CREATE,
+        set_cluster_status(meta, CLUSTER_STATE, CLUSTER_STATUS_CREATE,
                            logger)
 
         logging.info("check create_cluster params")
@@ -2529,13 +2529,13 @@ async def create_cluster(
         time.sleep(5)
         # cluster running
         update_number_sync_standbys(meta, spec, patch, status, logger)
-        set_cluster_status(meta, CLUSTER_CREATE_CLUSTER, CLUSTER_STATUS_RUN,
+        set_cluster_status(meta, CLUSTER_STATE, CLUSTER_STATUS_RUN,
                            logger)
     except Exception as e:
         logger.error(f"error occurs, {e}")
         traceback.print_exc()
         traceback.format_exc()
-        set_cluster_status(meta, CLUSTER_CREATE_CLUSTER,
+        set_cluster_status(meta, CLUSTER_STATE,
                            CLUSTER_STATUS_CREATE_FAILED, logger)
 
 
@@ -2546,7 +2546,7 @@ async def delete_cluster(
     status: kopf.Status,
     logger: logging.Logger,
 ) -> None:
-    set_cluster_status(meta, CLUSTER_CREATE_CLUSTER, CLUSTER_STATUS_TERMINATE,
+    set_cluster_status(meta, CLUSTER_STATE, CLUSTER_STATUS_TERMINATE,
                        logger)
     await delete_postgresql_cluster(meta, spec, patch, status, logger)
 
@@ -3677,7 +3677,7 @@ async def update_cluster(
     diffs: kopf.Diff,
 ) -> None:
     try:
-        set_cluster_status(meta, CLUSTER_CREATE_CLUSTER, CLUSTER_STATUS_UPDATE,
+        set_cluster_status(meta, CLUSTER_STATE, CLUSTER_STATUS_UPDATE,
                            logger)
         logger.info("check update_cluster params")
         check_param(spec, logger, create=False)
@@ -3749,11 +3749,11 @@ async def update_cluster(
         else:
             cluster_status = CLUSTER_STATUS_RUN
         # set Running
-        set_cluster_status(meta, CLUSTER_CREATE_CLUSTER, cluster_status,
+        set_cluster_status(meta, CLUSTER_STATE, cluster_status,
                            logger)
     except Exception as e:
         logger.error(f"error occurs, {e}")
         traceback.print_exc()
         traceback.format_exc()
-        set_cluster_status(meta, CLUSTER_CREATE_CLUSTER,
+        set_cluster_status(meta, CLUSTER_STATE,
                            CLUSTER_STATUS_UPDATE_FAILED, logger)