fix: add event filter (#280)

ionos-cloud · Nov 27, 2024 · 1d20bd4 · 1d20bd4
1 parent 5aedd8c
commit 1d20bd4
Show file tree

Hide file tree

Showing 35 changed files with 34 additions and 7 deletions.
diff --git 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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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),