Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
19 changes: 8 additions & 11 deletions controllers/postgres_controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -153,6 +153,13 @@ func (r *PostgresReconciler) Reconcile(ctx context.Context, req ctrl.Request) (c
log.Info("corresponding NetworkPolicy deleted")
}

if err := r.removeStorageEncryptionSecretFinalizer(ctx, instance); err != nil {
log.Error(err, "error while remnoving finalizer from storage encryption secret")
} else {

log.Info("finalizer from storage encryption secret removed")
}

deletable, err := r.IsOperatorDeletable(ctx, namespace)
if err != nil {
r.recorder.Eventf(instance, "Warning", "Error", "failed to check if the operator is idle: %v", err)
Expand All @@ -174,11 +181,6 @@ func (r *PostgresReconciler) Reconcile(ctx context.Context, req ctrl.Request) (c
}
log.Info("corresponding passwords secret deleted")

if err := r.deleteStorageEncryptionSecret(ctx, instance); err != nil {
return ctrl.Result{}, fmt.Errorf("error while deleting storage encryption secret: %w", err)
}
log.Info("storage encryption secret removed")

instance.RemoveFinalizer(pg.PostgresFinalizerName)
if err := r.CtrlClient.Update(ctx, instance); err != nil {
r.recorder.Eventf(instance, "Warning", "Self-Reconcilation", "failed to remove finalizer: %v", err)
Expand Down Expand Up @@ -1342,7 +1344,7 @@ func (r *PostgresReconciler) generateRandomString() (string, error) {
return string(b), nil
}

func (r *PostgresReconciler) deleteStorageEncryptionSecret(ctx context.Context, instance *pg.Postgres) error {
func (r *PostgresReconciler) removeStorageEncryptionSecretFinalizer(ctx context.Context, instance *pg.Postgres) error {

// Fetch secret
n := storageEncryptionKeyName
Expand All @@ -1361,11 +1363,6 @@ func (r *PostgresReconciler) deleteStorageEncryptionSecret(ctx context.Context,
return fmt.Errorf("error while removing finalizer from storage secret in service cluster: %w", err)
}

// Delete secret
if err := r.SvcClient.Delete(ctx, s); err != nil {
return fmt.Errorf("error while deleting storage secret in service cluster: %w", err)
}

return nil
}

Expand Down