This is an automated email from the ASF dual-hosted git repository. squakez pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-k.git
commit 12d41ac17050627d27f1238852f2c4c8f384cf6b Author: chaojixinren <[email protected]> AuthorDate: Fri Apr 17 15:39:38 2026 +0800 chore(controller): move catalog action declarations from reconcile to init --- pkg/controller/catalog/catalog_controller.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/pkg/controller/catalog/catalog_controller.go b/pkg/controller/catalog/catalog_controller.go index 58aa4eacb..bfdf5e0ba 100644 --- a/pkg/controller/catalog/catalog_controller.go +++ b/pkg/controller/catalog/catalog_controller.go @@ -57,6 +57,10 @@ func newReconciler(mgr manager.Manager, c client.Client) reconcile.Reconciler { client: c, scheme: mgr.GetScheme(), recorder: mgr.GetEventRecorder("camel-k-catalog-controller"), + actions: []Action{ + NewInitializeAction(), + NewMonitorAction(), + }, }, schema.GroupVersionKind{ Group: v1.SchemeGroupVersion.Group, @@ -107,6 +111,7 @@ type reconcileCatalog struct { client client.Client scheme *runtime.Scheme recorder events.EventRecorder + actions []Action } // Reconcile reads that state of the cluster for a catalog object and makes changes based @@ -150,18 +155,13 @@ func (r *reconcileCatalog) Reconcile(ctx context.Context, request reconcile.Requ return reconcile.Result{}, nil } - actions := []Action{ - NewInitializeAction(), - NewMonitorAction(), - } - var targetPhase v1.CamelCatalogPhase var err error target := instance.DeepCopy() targetLog := rlog.ForCatalog(target) - for _, a := range actions { + for _, a := range r.actions { a.InjectClient(r.client) a.InjectLogger(targetLog)
