From 3d1e26dc3e9af8cc066bef9971bb870b841c903b Mon Sep 17 00:00:00 2001 From: Dileep Ranganathan Date: Wed, 7 Aug 2019 11:43:43 -0700 Subject: [PATCH] Added GenerationChangePredicate for CollectdPlugin Added Predicate to discard events for status update Issue-ID: ONAPARC-461 Signed-off-by: Dileep Ranganathan Change-Id: I867b321de4b0a461ec6d0264e98761b5cdc01b77 --- .../pkg/controller/collectdplugin/collectdplugin_controller.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/vnfs/DAaaS/microservices/collectd-operator/pkg/controller/collectdplugin/collectdplugin_controller.go b/vnfs/DAaaS/microservices/collectd-operator/pkg/controller/collectdplugin/collectdplugin_controller.go index 4ce32eb2..c9b8ab1c 100644 --- a/vnfs/DAaaS/microservices/collectd-operator/pkg/controller/collectdplugin/collectdplugin_controller.go +++ b/vnfs/DAaaS/microservices/collectd-operator/pkg/controller/collectdplugin/collectdplugin_controller.go @@ -7,6 +7,7 @@ import ( "strings" "github.com/go-logr/logr" + "github.com/operator-framework/operator-sdk/pkg/predicate" onapv1alpha1 "demo/vnfs/DAaaS/microservices/collectd-operator/pkg/apis/onap/v1alpha1" collectdutils "demo/vnfs/DAaaS/microservices/collectd-operator/pkg/controller/utils" @@ -51,7 +52,7 @@ func add(mgr manager.Manager, r reconcile.Reconciler) error { // Watch for changes to primary resource CollectdPlugin log.V(1).Info("Add watcher for primary resource CollectdPlugin") - err = c.Watch(&source.Kind{Type: &onapv1alpha1.CollectdPlugin{}}, &handler.EnqueueRequestForObject{}) + err = c.Watch(&source.Kind{Type: &onapv1alpha1.CollectdPlugin{}}, &handler.EnqueueRequestForObject{}, predicate.GenerationChangedPredicate{}) if err != nil { return err } -- 2.16.6