From 1d20bd47061ea26e2e0cfed8bc934b6cb3475d90 Mon Sep 17 00:00:00 2001 From: cguran-ionos Date: Wed, 27 Nov 2024 13:07:29 +0200 Subject: [PATCH] fix: add event filter (#280) --- examples/ionoscloud/compute/statefulserverset.yaml | 2 +- examples/ionoscloud/compute/volume.yaml | 6 ------ .../alb/applicationloadbalancer/applicationloadbalancer.go | 1 + internal/controller/alb/forwardingrule/forwardingrule.go | 1 + internal/controller/alb/targetgroup/targetgroup.go | 1 + internal/controller/backup/backupunit/backupunit.go | 1 + internal/controller/compute/cubeserver/cubeserver.go | 1 + internal/controller/compute/datacenter/datacenter.go | 1 + internal/controller/compute/firewallrule/firewallrule.go | 1 + internal/controller/compute/group/group.go | 1 + internal/controller/compute/ipblock/ipblock.go | 1 + internal/controller/compute/ipfailover/ipfailover.go | 1 + internal/controller/compute/lan/lan.go | 1 + internal/controller/compute/nic/nic.go | 1 + .../compute/privatecrossconnect/privatecrossconnect.go | 1 + internal/controller/compute/s3key/s3Key.go | 1 + internal/controller/compute/server/server.go | 1 + internal/controller/compute/statefulserverset/setup.go | 1 + internal/controller/compute/user/user.go | 1 + internal/controller/compute/volume/volume.go | 1 + internal/controller/config/config.go | 1 + .../dataplatform/dataplatformcluster/dataplatformcluster.go | 1 + .../dataplatformnodepool/dataplatformnodepool.go | 1 + internal/controller/dbaas/mongocluster/mongoluster.go | 1 + internal/controller/dbaas/mongouser/mongouser.go | 1 + .../controller/dbaas/postgrescluster/postgrescluster.go | 1 + .../controller/dbaas/postgresdatabase/postgresdatabase.go | 1 + internal/controller/dbaas/postgresuser/postgresuser.go | 1 + internal/controller/k8s/k8scluster/cluster.go | 1 + internal/controller/k8s/k8snodepool/nodepool.go | 1 + internal/controller/nlb/flowlog/flowlog.go | 1 + internal/controller/nlb/forwardingrule/forwardingrule.go | 1 + .../nlb/networkloadbalancer/networkloadbalancer.go | 1 + internal/controller/serverset/setup.go | 1 + internal/controller/volumeselector/volumeselector.go | 1 + 35 files changed, 34 insertions(+), 7 deletions(-) diff --git a/examples/ionoscloud/compute/statefulserverset.yaml b/examples/ionoscloud/compute/statefulserverset.yaml index 039b4032..2cc85679 100644 --- a/examples/ionoscloud/compute/statefulserverset.yaml +++ b/examples/ionoscloud/compute/statefulserverset.yaml @@ -18,7 +18,7 @@ metadata: name: sss-example spec: forProvider: - replicas: 1 + replicas: 2 deploymentStrategy: type: ZONES datacenterConfig: diff --git a/examples/ionoscloud/compute/volume.yaml b/examples/ionoscloud/compute/volume.yaml index 04955bd1..555183e6 100644 --- a/examples/ionoscloud/compute/volume.yaml +++ b/examples/ionoscloud/compute/volume.yaml @@ -19,12 +19,6 @@ spec: bus: VIRTIO licenceType: LINUX availabilityZone: AUTO - substitutions: - - key: $NIC0_ipv6Address - type: random-ipv6 - unique: true - additionalProperties: - cidr: fd00:1337:1::/64 # imageAlias: ubuntu:latest # imagePassword: datacenterConfig: diff --git a/internal/controller/alb/applicationloadbalancer/applicationloadbalancer.go b/internal/controller/alb/applicationloadbalancer/applicationloadbalancer.go index b403cf59..605a6cd8 100644 --- a/internal/controller/alb/applicationloadbalancer/applicationloadbalancer.go +++ b/internal/controller/alb/applicationloadbalancer/applicationloadbalancer.go @@ -53,6 +53,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.ApplicationLoadBalancer{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.ApplicationLoadBalancerGroupVersionKind), diff --git a/internal/controller/alb/forwardingrule/forwardingrule.go b/internal/controller/alb/forwardingrule/forwardingrule.go index cfec33e6..4c5491e3 100644 --- a/internal/controller/alb/forwardingrule/forwardingrule.go +++ b/internal/controller/alb/forwardingrule/forwardingrule.go @@ -54,6 +54,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.ForwardingRule{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.ForwardingRuleGroupVersionKind), diff --git a/internal/controller/alb/targetgroup/targetgroup.go b/internal/controller/alb/targetgroup/targetgroup.go index 1e1f5551..36883466 100644 --- a/internal/controller/alb/targetgroup/targetgroup.go +++ b/internal/controller/alb/targetgroup/targetgroup.go @@ -51,6 +51,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.TargetGroup{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.TargetGroupGroupVersionKind), diff --git a/internal/controller/backup/backupunit/backupunit.go b/internal/controller/backup/backupunit/backupunit.go index 300ed0f4..c98529a6 100644 --- a/internal/controller/backup/backupunit/backupunit.go +++ b/internal/controller/backup/backupunit/backupunit.go @@ -50,6 +50,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.BackupUnit{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.BackupUnitGroupVersionKind), diff --git a/internal/controller/compute/cubeserver/cubeserver.go b/internal/controller/compute/cubeserver/cubeserver.go index 937a3d4a..1ee48cb1 100644 --- a/internal/controller/compute/cubeserver/cubeserver.go +++ b/internal/controller/compute/cubeserver/cubeserver.go @@ -53,6 +53,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.CubeServer{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.CubeServerGroupVersionKind), diff --git a/internal/controller/compute/datacenter/datacenter.go b/internal/controller/compute/datacenter/datacenter.go index 2a98ea21..ea0dab55 100644 --- a/internal/controller/compute/datacenter/datacenter.go +++ b/internal/controller/compute/datacenter/datacenter.go @@ -50,6 +50,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.Datacenter{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.DatacenterGroupVersionKind), diff --git a/internal/controller/compute/firewallrule/firewallrule.go b/internal/controller/compute/firewallrule/firewallrule.go index dd0157e8..c99ba10f 100644 --- a/internal/controller/compute/firewallrule/firewallrule.go +++ b/internal/controller/compute/firewallrule/firewallrule.go @@ -51,6 +51,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.FirewallRule{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.FirewallRuleGroupVersionKind), diff --git a/internal/controller/compute/group/group.go b/internal/controller/compute/group/group.go index 32b07215..0c1fd830 100644 --- a/internal/controller/compute/group/group.go +++ b/internal/controller/compute/group/group.go @@ -56,6 +56,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.Group{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.GroupGroupVersionKind), diff --git a/internal/controller/compute/ipblock/ipblock.go b/internal/controller/compute/ipblock/ipblock.go index fa060978..16231796 100644 --- a/internal/controller/compute/ipblock/ipblock.go +++ b/internal/controller/compute/ipblock/ipblock.go @@ -51,6 +51,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.IPBlock{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.IPBlockGroupVersionKind), diff --git a/internal/controller/compute/ipfailover/ipfailover.go b/internal/controller/compute/ipfailover/ipfailover.go index ab98ec7f..38fc22f9 100644 --- a/internal/controller/compute/ipfailover/ipfailover.go +++ b/internal/controller/compute/ipfailover/ipfailover.go @@ -52,6 +52,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.IPFailover{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.IPFailoverGroupVersionKind), diff --git a/internal/controller/compute/lan/lan.go b/internal/controller/compute/lan/lan.go index d4ef2ec9..bd564813 100644 --- a/internal/controller/compute/lan/lan.go +++ b/internal/controller/compute/lan/lan.go @@ -52,6 +52,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.Lan{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.LanGroupVersionKind), diff --git a/internal/controller/compute/nic/nic.go b/internal/controller/compute/nic/nic.go index 38313e75..446b9a7c 100644 --- a/internal/controller/compute/nic/nic.go +++ b/internal/controller/compute/nic/nic.go @@ -52,6 +52,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.Nic{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.NicGroupVersionKind), diff --git a/internal/controller/compute/privatecrossconnect/privatecrossconnect.go b/internal/controller/compute/privatecrossconnect/privatecrossconnect.go index 79a21253..4ec67f53 100644 --- a/internal/controller/compute/privatecrossconnect/privatecrossconnect.go +++ b/internal/controller/compute/privatecrossconnect/privatecrossconnect.go @@ -50,6 +50,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.Pcc{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.PrivateCrossConnectGroupVersionKind), diff --git a/internal/controller/compute/s3key/s3Key.go b/internal/controller/compute/s3key/s3Key.go index bcbabf25..761faa2a 100644 --- a/internal/controller/compute/s3key/s3Key.go +++ b/internal/controller/compute/s3key/s3Key.go @@ -61,6 +61,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.S3Key{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.S3KeyGroupVersionKind), diff --git a/internal/controller/compute/server/server.go b/internal/controller/compute/server/server.go index cc88194b..7cdcecb0 100644 --- a/internal/controller/compute/server/server.go +++ b/internal/controller/compute/server/server.go @@ -53,6 +53,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.Server{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.ServerGroupVersionKind), diff --git a/internal/controller/compute/statefulserverset/setup.go b/internal/controller/compute/statefulserverset/setup.go index c1d81780..ded723b7 100644 --- a/internal/controller/compute/statefulserverset/setup.go +++ b/internal/controller/compute/statefulserverset/setup.go @@ -18,6 +18,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.StatefulServerSet{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.StatefulServerSetGroupVersionKind), diff --git a/internal/controller/compute/user/user.go b/internal/controller/compute/user/user.go index dfd57252..6ce0c5ac 100644 --- a/internal/controller/compute/user/user.go +++ b/internal/controller/compute/user/user.go @@ -66,6 +66,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.User{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.UserGroupVersionKind), diff --git a/internal/controller/compute/volume/volume.go b/internal/controller/compute/volume/volume.go index 08c15f73..32105aba 100644 --- a/internal/controller/compute/volume/volume.go +++ b/internal/controller/compute/volume/volume.go @@ -53,6 +53,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.Volume{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.VolumeGroupVersionKind), diff --git a/internal/controller/config/config.go b/internal/controller/config/config.go index 0658fe7e..961e1d72 100644 --- a/internal/controller/config/config.go +++ b/internal/controller/config/config.go @@ -39,6 +39,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.ProviderConfig{}). Watches(&v1alpha1.ProviderConfigUsage{}, &resource.EnqueueRequestForProviderConfig{}). diff --git a/internal/controller/dataplatform/dataplatformcluster/dataplatformcluster.go b/internal/controller/dataplatform/dataplatformcluster/dataplatformcluster.go index 2feddfd4..6646174b 100644 --- a/internal/controller/dataplatform/dataplatformcluster/dataplatformcluster.go +++ b/internal/controller/dataplatform/dataplatformcluster/dataplatformcluster.go @@ -35,6 +35,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.DataplatformCluster{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.DataplatformClusterGroupVersionKind), diff --git a/internal/controller/dataplatform/dataplatformnodepool/dataplatformnodepool.go b/internal/controller/dataplatform/dataplatformnodepool/dataplatformnodepool.go index 2fe39bba..22674f4e 100644 --- a/internal/controller/dataplatform/dataplatformnodepool/dataplatformnodepool.go +++ b/internal/controller/dataplatform/dataplatformnodepool/dataplatformnodepool.go @@ -35,6 +35,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.DataplatformNodepool{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.DataplatformNodepoolGroupVersionKind), diff --git a/internal/controller/dbaas/mongocluster/mongoluster.go b/internal/controller/dbaas/mongocluster/mongoluster.go index 18d176db..c5c24da3 100644 --- a/internal/controller/dbaas/mongocluster/mongoluster.go +++ b/internal/controller/dbaas/mongocluster/mongoluster.go @@ -52,6 +52,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.MongoCluster{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.MongoClusterGroupVersionKind), diff --git a/internal/controller/dbaas/mongouser/mongouser.go b/internal/controller/dbaas/mongouser/mongouser.go index 152d1a82..c6551d81 100644 --- a/internal/controller/dbaas/mongouser/mongouser.go +++ b/internal/controller/dbaas/mongouser/mongouser.go @@ -53,6 +53,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.MongoUser{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.MongoUserGroupVersionKind), diff --git a/internal/controller/dbaas/postgrescluster/postgrescluster.go b/internal/controller/dbaas/postgrescluster/postgrescluster.go index cf113a9d..3e5b8263 100644 --- a/internal/controller/dbaas/postgrescluster/postgrescluster.go +++ b/internal/controller/dbaas/postgrescluster/postgrescluster.go @@ -54,6 +54,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.PostgresCluster{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.PostgresClusterGroupVersionKind), diff --git a/internal/controller/dbaas/postgresdatabase/postgresdatabase.go b/internal/controller/dbaas/postgresdatabase/postgresdatabase.go index cf734347..a27b7ab7 100644 --- a/internal/controller/dbaas/postgresdatabase/postgresdatabase.go +++ b/internal/controller/dbaas/postgresdatabase/postgresdatabase.go @@ -48,6 +48,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.PostgresDatabase{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.PostgresDatabaseGroupVersionKind), diff --git a/internal/controller/dbaas/postgresuser/postgresuser.go b/internal/controller/dbaas/postgresuser/postgresuser.go index 4f7cf9eb..4fd8fe00 100644 --- a/internal/controller/dbaas/postgresuser/postgresuser.go +++ b/internal/controller/dbaas/postgresuser/postgresuser.go @@ -52,6 +52,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.PostgresUser{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.PostgresUserGroupVersionKind), diff --git a/internal/controller/k8s/k8scluster/cluster.go b/internal/controller/k8s/k8scluster/cluster.go index 8ac374d9..ac01a5c5 100644 --- a/internal/controller/k8s/k8scluster/cluster.go +++ b/internal/controller/k8s/k8scluster/cluster.go @@ -64,6 +64,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.Cluster{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.ClusterGroupVersionKind), diff --git a/internal/controller/k8s/k8snodepool/nodepool.go b/internal/controller/k8s/k8snodepool/nodepool.go index 852102da..7c25247f 100644 --- a/internal/controller/k8s/k8snodepool/nodepool.go +++ b/internal/controller/k8s/k8snodepool/nodepool.go @@ -55,6 +55,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.NodePool{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.NodePoolGroupVersionKind), diff --git a/internal/controller/nlb/flowlog/flowlog.go b/internal/controller/nlb/flowlog/flowlog.go index bfe0f15c..2f8f8587 100644 --- a/internal/controller/nlb/flowlog/flowlog.go +++ b/internal/controller/nlb/flowlog/flowlog.go @@ -50,6 +50,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.FlowLog{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.FlowLogGroupVersionKind), diff --git a/internal/controller/nlb/forwardingrule/forwardingrule.go b/internal/controller/nlb/forwardingrule/forwardingrule.go index 5a16ecc2..d492f3f9 100644 --- a/internal/controller/nlb/forwardingrule/forwardingrule.go +++ b/internal/controller/nlb/forwardingrule/forwardingrule.go @@ -56,6 +56,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.ForwardingRule{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.ForwardingRuleGroupVersionKind), diff --git a/internal/controller/nlb/networkloadbalancer/networkloadbalancer.go b/internal/controller/nlb/networkloadbalancer/networkloadbalancer.go index c251acc5..e7e30112 100644 --- a/internal/controller/nlb/networkloadbalancer/networkloadbalancer.go +++ b/internal/controller/nlb/networkloadbalancer/networkloadbalancer.go @@ -52,6 +52,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.NetworkLoadBalancer{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.NetworkLoadBalancerGroupVersionKind), diff --git a/internal/controller/serverset/setup.go b/internal/controller/serverset/setup.go index ecaef981..e3464293 100644 --- a/internal/controller/serverset/setup.go +++ b/internal/controller/serverset/setup.go @@ -22,6 +22,7 @@ func SetupServerSet(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.ServerSet{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.ServerSetGroupVersionKind), diff --git a/internal/controller/volumeselector/volumeselector.go b/internal/controller/volumeselector/volumeselector.go index ebf5a26c..284c1cbf 100644 --- a/internal/controller/volumeselector/volumeselector.go +++ b/internal/controller/volumeselector/volumeselector.go @@ -44,6 +44,7 @@ func Setup(mgr ctrl.Manager, opts *utils.ConfigurationOptions) error { return ctrl.NewControllerManagedBy(mgr). Named(name). WithOptions(opts.CtrlOpts.ForControllerRuntime()). + WithEventFilter(resource.DesiredStateChanged()). For(&v1alpha1.Volumeselector{}). Complete(managed.NewReconciler(mgr, resource.ManagedKind(v1alpha1.VolumeselectorGroupVersionKind),