rebased to features/database-controllers

Author: DmytroPI-dev

internal/controller/postgrescluster_controller.go

@@ -20,8 +20,6 @@ import (
 	"context"
 	"errors"
 	"fmt"
-	"time"
-
 	cnpgv1 "github.com/cloudnative-pg/cloudnative-pg/api/v1"
 	enterprisev4 "github.com/splunk/splunk-operator/api/v4"
 	corev1 "k8s.io/api/core/v1"
@@ -125,7 +123,7 @@ func (r *PostgresClusterReconciler) Reconcile(ctx context.Context, req ctrl.Requ
 		return ctrl.Result{RequeueAfter: retryDelay}, nil
 	case err != nil:
 		logger.Error(err, "Failed to get CNPG Cluster")
-		r.setCondition(postgresCluster, metav1.ConditionFalse, "ClusterGetFailed", err.Error())
+		r.setCondition(postgresCluster, "Ready", metav1.ConditionFalse, "ClusterGetFailed", err.Error())
 		return res, err
 	}
 	cnpgCluster = existingCNPG
@@ -152,7 +150,7 @@ func (r *PostgresClusterReconciler) Reconcile(ctx context.Context, req ctrl.Requ
 	// 7. Reconcile ManagedRoles from PostgresCluster to CNPG Cluster
 	if err := r.reconcileManagedRoles(ctx, postgresCluster, cnpgCluster); err != nil {
 		logger.Error(err, "Failed to reconcile managed roles")
-		r.setCondition(postgresCluster, metav1.ConditionFalse, "ManagedRolesFailed", err.Error())
+		r.setCondition(postgresCluster, "Ready", metav1.ConditionFalse, "ManagedRolesFailed", err.Error())
 		return res, err
 	}
 	// 7. Reconcile Connection Pooler if enabled in class
@@ -164,7 +162,7 @@ func (r *PostgresClusterReconciler) Reconcile(ctx context.Context, req ctrl.Requ
 		return res, poolerErr
 	}
 	if requeuePooler {
-		return ctrl.Result{RequeueAfter: retryDelaytimer}, nil
+		return ctrl.Result{RequeueAfter: retryDelay}, nil
 	}
 	// 7. Report progress back to the user and manage the reconciliation lifecycle.
 	logger.Info("Reconciliation completed successfully", "name", postgresCluster.Name)
@@ -350,7 +348,6 @@ func (r *PostgresClusterReconciler) deleteConnectionPoolers(ctx context.Context,
 	return nil
 }
 
-// ensureConnectionPooler creates a CNPG Pooler resource if it doesn't exist.
 // ensureConnectionPooler creates a CNPG Pooler resource if it doesn't exist.
 func (r *PostgresClusterReconciler) ensureConnectionPooler(
 	ctx context.Context,