@@ -21,11 +21,10 @@ import (
2121 "sigs.k8s.io/controller-runtime/pkg/controller/controllerutil"
2222 "sigs.k8s.io/controller-runtime/pkg/event"
2323
24- "github.com/percona/percona-postgresql-operator/internal/bridge"
25- "github.com/percona/percona-postgresql-operator/internal/controller/runtime"
26- pgoRuntime "github.com/percona/percona-postgresql-operator/internal/controller/runtime"
27- "github.com/percona/percona-postgresql-operator/internal/naming"
28- "github.com/percona/percona-postgresql-operator/pkg/apis/postgres-operator.crunchydata.com/v1beta1"
24+ "github.com/percona/percona-postgresql-operator/v2/internal/bridge"
25+ pgoRuntime "github.com/percona/percona-postgresql-operator/v2/internal/controller/runtime"
26+ "github.com/percona/percona-postgresql-operator/v2/internal/naming"
27+ "github.com/percona/percona-postgresql-operator/v2/pkg/apis/postgres-operator.crunchydata.com/v1beta1"
2928)
3029
3130// CrunchyBridgeClusterReconciler reconciles a CrunchyBridgeCluster object
@@ -223,7 +222,7 @@ func (r *CrunchyBridgeClusterReconciler) Reconcile(ctx context.Context, req ctrl
223222 // TODO(crunchybridgecluster): Do we want the operator to interrupt
224223 // upgrades created through the GUI/API?
225224 if len (crunchybridgecluster .Status .OngoingUpgrade ) != 0 {
226- return runtime .RequeueWithoutBackoff (3 * time .Minute ), nil
225+ return pgoRuntime .RequeueWithoutBackoff (3 * time .Minute ), nil
227226 }
228227
229228 // Check if there's an upgrade difference for the three upgradeable fields that hit the upgrade endpoint
@@ -253,7 +252,7 @@ func (r *CrunchyBridgeClusterReconciler) Reconcile(ctx context.Context, req ctrl
253252 log .Info ("Reconciled" )
254253 // TODO(crunchybridgecluster): do we always want to requeue? Does the Watch mean we
255254 // don't need this, or do we want both?
256- return runtime .RequeueWithoutBackoff (3 * time .Minute ), nil
255+ return pgoRuntime .RequeueWithoutBackoff (3 * time .Minute ), nil
257256}
258257
259258// reconcileBridgeConnectionSecret looks for the Bridge connection secret specified by the cluster,
@@ -403,7 +402,7 @@ func (r *CrunchyBridgeClusterReconciler) handleCreateCluster(ctx context.Context
403402 Message : "The condition of the upgrade(s) is unknown." ,
404403 })
405404
406- return runtime .RequeueWithoutBackoff (3 * time .Minute )
405+ return pgoRuntime .RequeueWithoutBackoff (3 * time .Minute )
407406}
408407
409408// handleGetCluster handles getting the cluster details from Bridge and
@@ -564,7 +563,7 @@ func (r *CrunchyBridgeClusterReconciler) handleUpgrade(ctx context.Context,
564563 })
565564 }
566565
567- return runtime .RequeueWithoutBackoff (3 * time .Minute )
566+ return pgoRuntime .RequeueWithoutBackoff (3 * time .Minute )
568567}
569568
570569// handleUpgradeHA handles upgrades that hit the
@@ -611,7 +610,7 @@ func (r *CrunchyBridgeClusterReconciler) handleUpgradeHA(ctx context.Context,
611610 })
612611 }
613612
614- return runtime .RequeueWithoutBackoff (3 * time .Minute )
613+ return pgoRuntime .RequeueWithoutBackoff (3 * time .Minute )
615614}
616615
617616// handleUpdate handles upgrades that hit the "PATCH /clusters/<id>" endpoint
@@ -656,7 +655,7 @@ func (r *CrunchyBridgeClusterReconciler) handleUpdate(ctx context.Context,
656655 clusterUpdate .ClusterName , * clusterUpdate .IsProtected ),
657656 })
658657
659- return runtime .RequeueWithoutBackoff (3 * time .Minute )
658+ return pgoRuntime .RequeueWithoutBackoff (3 * time .Minute )
660659}
661660
662661// GetSecretKeys gets the secret and returns the expected API key and team id
0 commit comments