From 6c325b6b0b6ed022df72e9651d27cc24a07b665f Mon Sep 17 00:00:00 2001 From: "Lim, Kian-An" Date: Wed, 17 Feb 2021 13:36:40 +0100 Subject: [PATCH] Use socket port for cwnp --- controllers/postgres_controller.go | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) 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) }