diff --git a/controllers/postgres_controller.go b/controllers/postgres_controller.go index 8d85efdd..9a5c9338 100644 --- a/controllers/postgres_controller.go +++ b/controllers/postgres_controller.go @@ -156,9 +156,15 @@ func (r *PostgresReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error) { return ctrl.Result{}, err } - // todo: Check the port. The default port of postgres is used. + // Check if socket port is ready + port :=instance.Status.Socket.Port + if port == 0 { + log.Info("socket port not ready") + return ctrl.Result{Requeue: true}, nil + } + // Update status will be handled by the StatusReconciler, based on the Zalando Status - if err := r.createOrUpdateCWNP(ctx, instance, 5432); err != nil { + if err := r.createOrUpdateCWNP(ctx, instance, int(port)); err != nil { return ctrl.Result{}, fmt.Errorf("unable to create or update corresponding CRD ClusterwideNetworkPolicy: %W", err) }