From: Dileep Ranganathan Date: Wed, 7 Aug 2019 18:43:43 +0000 (-0700) Subject: Added GenerationChangePredicate for CollectdPlugin X-Git-Tag: 1.5.0~27 X-Git-Url: https://gerrit.onap.org/r/gitweb?p=demo.git;a=commitdiff_plain;h=3d1e26dc3e9af8cc066bef9971bb870b841c903b Added GenerationChangePredicate for CollectdPlugin Added Predicate to discard events for status update Issue-ID: ONAPARC-461 Signed-off-by: Dileep Ranganathan Change-Id: I867b321de4b0a461ec6d0264e98761b5cdc01b77 --- 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 }