Fix backend switching

kyma-project · Aug 29, 2024 · 9211171 · 9211171
1 parent 67a5abc
commit 9211171
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/internal/controller/eventing/subscription/eventmesh/reconciler.go b/internal/controller/eventing/subscription/eventmesh/reconciler.go
@@ -19,6 +19,7 @@ import (
 	klabels "k8s.io/apimachinery/pkg/labels"
 	ktypes "k8s.io/apimachinery/pkg/types"
 	"k8s.io/client-go/tools/record"
+	"k8s.io/utils/ptr"
 	kctrl "sigs.k8s.io/controller-runtime"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 	"sigs.k8s.io/controller-runtime/pkg/controller"
@@ -753,7 +754,8 @@ func (r *Reconciler) emitConditionEvent(subscription *eventingv1alpha2.Subscript
 
 // SetupUnmanaged creates a controller under the client control.
 func (r *Reconciler) SetupUnmanaged(ctx context.Context, mgr kctrl.Manager) error {
-	ctru, err := controller.NewUnmanaged(reconcilerName, mgr, controller.Options{Reconciler: r})
+	opts := controller.Options{Reconciler: r, SkipNameValidation: ptr.To(true)}
+	ctru, err := controller.NewUnmanaged(reconcilerName, mgr, opts)
 	if err != nil {
 		return fmt.Errorf("failed to create unmanaged controller: %w", err)
 	}

diff --git a/internal/controller/eventing/subscription/jetstream/reconciler.go b/internal/controller/eventing/subscription/jetstream/reconciler.go
@@ -11,6 +11,7 @@ import (
 	"go.uber.org/zap"
 	ktypes "k8s.io/apimachinery/pkg/types"
 	"k8s.io/client-go/tools/record"
+	"k8s.io/utils/ptr"
 	kctrl "sigs.k8s.io/controller-runtime"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 	"sigs.k8s.io/controller-runtime/pkg/controller"
@@ -68,7 +69,8 @@ func NewReconciler(client client.Client, jsBackend jetstream.Backend,
 
 // SetupUnmanaged creates a controller under the client control.
 func (r *Reconciler) SetupUnmanaged(ctx context.Context, mgr kctrl.Manager) error {
-	ctru, err := controller.NewUnmanaged(reconcilerName, mgr, controller.Options{Reconciler: r})
+	opts := controller.Options{Reconciler: r, SkipNameValidation: ptr.To(true)}
+	ctru, err := controller.NewUnmanaged(reconcilerName, mgr, opts)
 	if err != nil {
 		r.namedLogger().Errorw("Failed to create unmanaged controller", "error", err)
 		return err