From b1d14bd5c8cfadd6d8eb15ab2ed94324a1c13c29 Mon Sep 17 00:00:00 2001 From: Nader Ziada Date: Wed, 15 Aug 2018 10:57:56 -0400 Subject: [PATCH] update filter when using EnqueueControllerOf in route controller (#1862) --- pkg/reconciler/v1alpha1/route/route.go | 18 ++++++++++++------ 1 file changed, 12 insertions(+), 6 deletions(-) diff --git a/pkg/reconciler/v1alpha1/route/route.go b/pkg/reconciler/v1alpha1/route/route.go index b32bad78f32b..a777f0d50b77 100644 --- a/pkg/reconciler/v1alpha1/route/route.go +++ b/pkg/reconciler/v1alpha1/route/route.go @@ -107,14 +107,20 @@ func NewController( UpdateFunc: controller.PassNew(c.EnqueueReferringRoute(impl)), }) - serviceInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ - AddFunc: impl.EnqueueControllerOf, - UpdateFunc: controller.PassNew(impl.EnqueueControllerOf), + serviceInformer.Informer().AddEventHandler(cache.FilteringResourceEventHandler{ + FilterFunc: controller.Filter(v1alpha1.SchemeGroupVersion.WithKind("Route")), + Handler: cache.ResourceEventHandlerFuncs{ + AddFunc: impl.EnqueueControllerOf, + UpdateFunc: controller.PassNew(impl.EnqueueControllerOf), + }, }) - virtualServiceInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ - AddFunc: impl.EnqueueControllerOf, - UpdateFunc: controller.PassNew(impl.EnqueueControllerOf), + virtualServiceInformer.Informer().AddEventHandler(cache.FilteringResourceEventHandler{ + FilterFunc: controller.Filter(v1alpha1.SchemeGroupVersion.WithKind("Route")), + Handler: cache.ResourceEventHandlerFuncs{ + AddFunc: impl.EnqueueControllerOf, + UpdateFunc: controller.PassNew(impl.EnqueueControllerOf), + }, }) c.Logger.Info("Setting up ConfigMap receivers")