diff --git a/pkg/controller/cache/managed.go b/pkg/controller/cache/managed.go index 21d69c782..1a526e495 100644 --- a/pkg/controller/cache/managed.go +++ b/pkg/controller/cache/managed.go @@ -77,6 +77,7 @@ func SetupCloudMemorystoreInstance(mgr ctrl.Manager, o controller.Options) error return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(o.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1beta1.CloudMemorystoreInstance{}). Complete(ratelimiter.NewReconciler(name, r, o.GlobalRateLimiter)) } diff --git a/pkg/controller/compute/address.go b/pkg/controller/compute/address.go index eaa01c255..6a82b9587 100644 --- a/pkg/controller/compute/address.go +++ b/pkg/controller/compute/address.go @@ -71,6 +71,7 @@ func SetupAddress(mgr ctrl.Manager, o controller.Options) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(o.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1beta1.Address{}). Complete(ratelimiter.NewReconciler(name, r, o.GlobalRateLimiter)) } diff --git a/pkg/controller/compute/firewall.go b/pkg/controller/compute/firewall.go index 2d83d72ed..bc6fa42dc 100644 --- a/pkg/controller/compute/firewall.go +++ b/pkg/controller/compute/firewall.go @@ -73,6 +73,7 @@ func SetupFirewall(mgr ctrl.Manager, o controller.Options) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(o.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.Firewall{}). Complete(ratelimiter.NewReconciler(name, r, o.GlobalRateLimiter)) } diff --git a/pkg/controller/compute/globaladdress.go b/pkg/controller/compute/globaladdress.go index 7fe3e0ddf..49c5764a0 100644 --- a/pkg/controller/compute/globaladdress.go +++ b/pkg/controller/compute/globaladdress.go @@ -72,6 +72,7 @@ func SetupGlobalAddress(mgr ctrl.Manager, o controller.Options) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(o.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1beta1.GlobalAddress{}). Complete(ratelimiter.NewReconciler(name, r, o.GlobalRateLimiter)) } diff --git a/pkg/controller/compute/network.go b/pkg/controller/compute/network.go index bedf05419..16c5dc0f9 100644 --- a/pkg/controller/compute/network.go +++ b/pkg/controller/compute/network.go @@ -76,6 +76,7 @@ func SetupNetwork(mgr ctrl.Manager, o controller.Options) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(o.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1beta1.Network{}). Complete(ratelimiter.NewReconciler(name, r, o.GlobalRateLimiter)) } diff --git a/pkg/controller/compute/router.go b/pkg/controller/compute/router.go index ff902e661..c14bd6832 100644 --- a/pkg/controller/compute/router.go +++ b/pkg/controller/compute/router.go @@ -72,6 +72,7 @@ func SetupRouter(mgr ctrl.Manager, o controller.Options) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(o.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.Router{}). Complete(ratelimiter.NewReconciler(name, r, o.GlobalRateLimiter)) } diff --git a/pkg/controller/compute/subnetwork.go b/pkg/controller/compute/subnetwork.go index 7996cb164..cf38b3e99 100644 --- a/pkg/controller/compute/subnetwork.go +++ b/pkg/controller/compute/subnetwork.go @@ -76,6 +76,7 @@ func SetupSubnetwork(mgr ctrl.Manager, o controller.Options) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(o.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1beta1.Subnetwork{}). Complete(ratelimiter.NewReconciler(name, r, o.GlobalRateLimiter)) } diff --git a/pkg/controller/config/config.go b/pkg/controller/config/config.go index 3892258ee..ec5d06dd5 100644 --- a/pkg/controller/config/config.go +++ b/pkg/controller/config/config.go @@ -46,6 +46,7 @@ func Setup(mgr ctrl.Manager, o controller.Options) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(o.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1beta1.ProviderConfig{}). Watches(&source.Kind{Type: &v1beta1.ProviderConfigUsage{}}, &resource.EnqueueRequestForProviderConfig{}). Complete(ratelimiter.NewReconciler(name, r, o.GlobalRateLimiter)) diff --git a/pkg/controller/container/cluster.go b/pkg/controller/container/cluster.go index dd4e93cc2..a4b6f9cd4 100644 --- a/pkg/controller/container/cluster.go +++ b/pkg/controller/container/cluster.go @@ -75,6 +75,7 @@ func SetupCluster(mgr ctrl.Manager, o controller.Options) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(o.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1beta2.Cluster{}). Complete(ratelimiter.NewReconciler(name, r, o.GlobalRateLimiter)) } diff --git a/pkg/controller/container/nodepool.go b/pkg/controller/container/nodepool.go index 7fd952f78..4425090b7 100644 --- a/pkg/controller/container/nodepool.go +++ b/pkg/controller/container/nodepool.go @@ -73,6 +73,7 @@ func SetupNodePool(mgr ctrl.Manager, o controller.Options) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(o.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1beta1.NodePool{}). Complete(ratelimiter.NewReconciler(name, r, o.GlobalRateLimiter)) } diff --git a/pkg/controller/database/cloudsql.go b/pkg/controller/database/cloudsql.go index c3c0092fb..e122c923b 100644 --- a/pkg/controller/database/cloudsql.go +++ b/pkg/controller/database/cloudsql.go @@ -79,6 +79,7 @@ func SetupCloudSQLInstance(mgr ctrl.Manager, o controller.Options) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(o.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1beta1.CloudSQLInstance{}). Complete(ratelimiter.NewReconciler(name, r, o.GlobalRateLimiter)) } diff --git a/pkg/controller/dns/policy.go b/pkg/controller/dns/policy.go index c962326a8..7e6eed02f 100644 --- a/pkg/controller/dns/policy.go +++ b/pkg/controller/dns/policy.go @@ -70,6 +70,7 @@ func SetupPolicy(mgr ctrl.Manager, o controller.Options) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(o.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.Policy{}). Complete(ratelimiter.NewReconciler(name, r, o.GlobalRateLimiter)) } diff --git a/pkg/controller/dns/resource_record_set.go b/pkg/controller/dns/resource_record_set.go index 8c8ebb40f..260feefb1 100644 --- a/pkg/controller/dns/resource_record_set.go +++ b/pkg/controller/dns/resource_record_set.go @@ -73,6 +73,7 @@ func SetupResourceRecordSet(mgr ctrl.Manager, o controller.Options) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(o.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.ResourceRecordSet{}). Complete(ratelimiter.NewReconciler(name, r, o.GlobalRateLimiter)) } diff --git a/pkg/controller/iam/serviceaccount.go b/pkg/controller/iam/serviceaccount.go index 9934fedaa..833e2c19e 100644 --- a/pkg/controller/iam/serviceaccount.go +++ b/pkg/controller/iam/serviceaccount.go @@ -71,6 +71,7 @@ func SetupServiceAccount(mgr ctrl.Manager, o controller.Options) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(o.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.ServiceAccount{}). Complete(ratelimiter.NewReconciler(name, r, o.GlobalRateLimiter)) } diff --git a/pkg/controller/iam/serviceaccountkey.go b/pkg/controller/iam/serviceaccountkey.go index b7333423f..692fbd4b8 100644 --- a/pkg/controller/iam/serviceaccountkey.go +++ b/pkg/controller/iam/serviceaccountkey.go @@ -86,6 +86,7 @@ func SetupServiceAccountKey(mgr ctrl.Manager, o controller.Options) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(o.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.ServiceAccountKey{}). Complete(ratelimiter.NewReconciler(name, r, o.GlobalRateLimiter)) } diff --git a/pkg/controller/iam/serviceaccountpolicy.go b/pkg/controller/iam/serviceaccountpolicy.go index 1c2191c18..16fc67f1b 100644 --- a/pkg/controller/iam/serviceaccountpolicy.go +++ b/pkg/controller/iam/serviceaccountpolicy.go @@ -67,6 +67,7 @@ func SetupServiceAccountPolicy(mgr ctrl.Manager, o controller.Options) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(o.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.ServiceAccountPolicy{}). Complete(ratelimiter.NewReconciler(name, r, o.GlobalRateLimiter)) } diff --git a/pkg/controller/kms/cryptokey.go b/pkg/controller/kms/cryptokey.go index 49bd05dba..2de449309 100644 --- a/pkg/controller/kms/cryptokey.go +++ b/pkg/controller/kms/cryptokey.go @@ -67,6 +67,7 @@ func SetupCryptoKey(mgr ctrl.Manager, o controller.Options) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(o.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.CryptoKey{}). Complete(ratelimiter.NewReconciler(name, r, o.GlobalRateLimiter)) } diff --git a/pkg/controller/kms/cryptokeypolicy.go b/pkg/controller/kms/cryptokeypolicy.go index b6b85d98a..15e233fef 100644 --- a/pkg/controller/kms/cryptokeypolicy.go +++ b/pkg/controller/kms/cryptokeypolicy.go @@ -66,6 +66,7 @@ func SetupCryptoKeyPolicy(mgr ctrl.Manager, o controller.Options) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(o.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.CryptoKeyPolicy{}). Complete(ratelimiter.NewReconciler(name, r, o.GlobalRateLimiter)) } diff --git a/pkg/controller/kms/keyring.go b/pkg/controller/kms/keyring.go index a3b978da8..7a07dc981 100644 --- a/pkg/controller/kms/keyring.go +++ b/pkg/controller/kms/keyring.go @@ -70,6 +70,7 @@ func SetupKeyRing(mgr ctrl.Manager, o controller.Options) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(o.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.KeyRing{}). Complete(ratelimiter.NewReconciler(name, r, o.GlobalRateLimiter)) } diff --git a/pkg/controller/pubsub/subscription.go b/pkg/controller/pubsub/subscription.go index e5124ac39..f4ade5c7a 100644 --- a/pkg/controller/pubsub/subscription.go +++ b/pkg/controller/pubsub/subscription.go @@ -70,6 +70,7 @@ func SetupSubscription(mgr ctrl.Manager, o controller.Options) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(o.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.Subscription{}). Complete(ratelimiter.NewReconciler(name, r, o.GlobalRateLimiter)) } diff --git a/pkg/controller/pubsub/topic.go b/pkg/controller/pubsub/topic.go index eac220cfd..01aee2170 100644 --- a/pkg/controller/pubsub/topic.go +++ b/pkg/controller/pubsub/topic.go @@ -71,6 +71,7 @@ func SetupTopic(mgr ctrl.Manager, o controller.Options) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(o.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.Topic{}). Complete(ratelimiter.NewReconciler(name, r, o.GlobalRateLimiter)) } diff --git a/pkg/controller/registry/containerregistry.go b/pkg/controller/registry/containerregistry.go index acea42b0b..06f2a8d05 100644 --- a/pkg/controller/registry/containerregistry.go +++ b/pkg/controller/registry/containerregistry.go @@ -78,6 +78,7 @@ func SetupContainerRegistry(mgr ctrl.Manager, o controller.Options) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(o.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.ContainerRegistry{}). Complete(ratelimiter.NewReconciler(name, r, o.GlobalRateLimiter)) } diff --git a/pkg/controller/servicenetworking/connection.go b/pkg/controller/servicenetworking/connection.go index 4415bc791..51e6ea564 100644 --- a/pkg/controller/servicenetworking/connection.go +++ b/pkg/controller/servicenetworking/connection.go @@ -96,6 +96,7 @@ func SetupConnection(mgr ctrl.Manager, o controller.Options) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(o.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1beta1.Connection{}). Complete(ratelimiter.NewReconciler(name, r, o.GlobalRateLimiter)) } diff --git a/pkg/controller/storage/bucket.go b/pkg/controller/storage/bucket.go index f14880601..b1bd0b73a 100644 --- a/pkg/controller/storage/bucket.go +++ b/pkg/controller/storage/bucket.go @@ -72,6 +72,7 @@ func SetupBucket(mgr ctrl.Manager, o controller.Options) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(o.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha3.Bucket{}). Complete(ratelimiter.NewReconciler(name, r, o.GlobalRateLimiter)) } diff --git a/pkg/controller/storage/bucketpolicy.go b/pkg/controller/storage/bucketpolicy.go index b31a5cbb7..0d8ad71a0 100644 --- a/pkg/controller/storage/bucketpolicy.go +++ b/pkg/controller/storage/bucketpolicy.go @@ -68,6 +68,7 @@ func SetupBucketPolicy(mgr ctrl.Manager, o controller.Options) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(o.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.BucketPolicy{}). Complete(ratelimiter.NewReconciler(name, r, o.GlobalRateLimiter)) } diff --git a/pkg/controller/storage/bucketpolicymember.go b/pkg/controller/storage/bucketpolicymember.go index 1cb3e8bed..72e7225cc 100644 --- a/pkg/controller/storage/bucketpolicymember.go +++ b/pkg/controller/storage/bucketpolicymember.go @@ -64,6 +64,7 @@ func SetupBucketPolicyMember(mgr ctrl.Manager, o controller.Options) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(o.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.BucketPolicyMember{}). Complete(ratelimiter.NewReconciler(name, r, o.GlobalRateLimiter)) }