fix broken c/r API

Signed-off-by: Tim Ramlot <[email protected]>

Author: inteon

controllers/issuer_controller.go

@@ -263,10 +263,7 @@ func (r *IssuerReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manage
 				IssuerPredicate{},
 			),
 		).
-		WatchesRawSource(
-			r.EventSource.AddConsumer(forObjectGvk),
-			nil,
-		)
+		WatchesRawSource(r.EventSource.AddConsumer(forObjectGvk))
 
 	if r.PreSetupWithManager != nil {
 		err := r.PreSetupWithManager(ctx, forObjectGvk, mgr, build)

internal/kubeutil/source_channel.go

@@ -24,8 +24,6 @@ import (
 	"k8s.io/apimachinery/pkg/runtime/schema"
 	"k8s.io/apimachinery/pkg/types"
 	"k8s.io/client-go/util/workqueue"
-	"sigs.k8s.io/controller-runtime/pkg/handler"
-	"sigs.k8s.io/controller-runtime/pkg/predicate"
 	"sigs.k8s.io/controller-runtime/pkg/reconcile"
 	"sigs.k8s.io/controller-runtime/pkg/source"
 )
@@ -110,7 +108,7 @@ func (cs *eventConsumer) String() string {
 }
 
 // Start implements Source and should only be called by the Controller.
-func (cs *eventConsumer) Start(_ context.Context, _ handler.EventHandler, queue workqueue.RateLimitingInterface, _ ...predicate.Predicate) error {
+func (cs *eventConsumer) Start(_ context.Context, queue workqueue.RateLimitingInterface) error {
 	if cs.register == nil {
 		return fmt.Errorf("register function not provided")
 	}