Upgrade operator-sdk bump version to 0.9.0

[demo.git] / vnfs / DAaaS / microservices / collectd-operator / pkg / controller / collectdplugin / collectdplugin_controller.go

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 4ce32eb..0e3af8d 100644 (file)
--- 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,9 +7,10 @@ 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"
+       onapv1alpha1 "collectd-operator/pkg/apis/onap/v1alpha1"
+       collectdutils "collectd-operator/pkg/controller/utils"
 
        appsv1 "k8s.io/api/apps/v1"
        corev1 "k8s.io/api/core/v1"
@@ -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
        }