controller

Author: robertgraeff

cmd/openmcp-operator/app/run.go

@@ -11,6 +11,7 @@ import (
 	"github.com/spf13/cobra"
 	flag "github.com/spf13/pflag"
 	"k8s.io/apimachinery/pkg/runtime"
+	"k8s.io/apimachinery/pkg/runtime/schema"
 	utilruntime "k8s.io/apimachinery/pkg/util/runtime"
 	clientgoscheme "k8s.io/client-go/kubernetes/scheme"
 	"k8s.io/client-go/tools/clientcmd/api"
@@ -48,8 +49,8 @@ func NewRunCommand(_ context.Context) *cobra.Command {
 
 type runOptions struct {
 	PlatformCluster *clusters.Cluster
-
-	Log logging.Logger
+	GVKList         []schema.GroupVersionKind
+	Log             logging.Logger
 }
 
 func (o *runOptions) addFlags(fs *flag.FlagSet) {
@@ -67,6 +68,7 @@ func (o *runOptions) complete() (err error) {
 	if err = o.setupPlatformClusterClient(); err != nil {
 		return err
 	}
+	o.setupGVKList()
 
 	return nil
 }
@@ -91,6 +93,13 @@ func (o *runOptions) setupPlatformClusterClient() error {
 	return nil
 }
 
+func (o *runOptions) setupGVKList() {
+	o.GVKList = []schema.GroupVersionKind{
+		{Group: "openmcp.cloud", Version: "v1alpha1", Kind: "ClusterProvider"},
+		{Group: "openmcp.cloud", Version: "v1alpha1", Kind: "MCPServiceProvider"},
+	}
+}
+
 func (o *runOptions) run() error {
 	o.Log.Info("starting openmcp-operator", "platform-cluster", o.PlatformCluster.ConfigPath())
 
@@ -110,7 +119,7 @@ func (o *runOptions) run() error {
 	if err = (&controller.DeployableReconciler{
 		PlatformClient: mgr.GetClient(),
 		Scheme:         mgr.GetScheme(),
-	}).SetupWithManager(mgr); err != nil {
+	}).SetupWithManager(mgr, o.GVKList); err != nil {
 		return fmt.Errorf("unable to create controller: %w", err)
 	}
 

internal/controller/deployable_controller.go

@@ -54,14 +54,9 @@ func (r *DeployableReconciler) Reconcile(ctx context.Context, req ctrl.Request)
 }
 
 // SetupWithManager sets up the controller with the Manager.
-func (r *DeployableReconciler) SetupWithManager(mgr ctrl.Manager) error {
+func (r *DeployableReconciler) SetupWithManager(mgr ctrl.Manager, gvkList []schema.GroupVersionKind) error {
 	allErrs := field.ErrorList{}
 
-	gvkList := []schema.GroupVersionKind{
-		{Group: "openmcp.cloud", Version: "v1alpha1", Kind: "ClusterProvider"},
-		{Group: "openmcp.cloud", Version: "v1alpha1", Kind: "MCPServiceProvider"},
-	}
-
 	r.Reconcilers = make([]*GVKReconciler, 0, len(gvkList))
 
 	for i, gvk := range gvkList {