add watch filter value to AzureASO... controllers

Author: nojnhuh

exp/controllers/azureasomanagedcluster_controller.go

@@ -20,19 +20,29 @@ import (
 	"context"
 
 	infrav1exp "sigs.k8s.io/cluster-api-provider-azure/exp/api/v1alpha1"
+	"sigs.k8s.io/cluster-api-provider-azure/util/tele"
+	"sigs.k8s.io/cluster-api/util/predicates"
 	ctrl "sigs.k8s.io/controller-runtime"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 )
 
 // AzureASOManagedClusterReconciler reconciles a AzureASOManagedCluster object.
 type AzureASOManagedClusterReconciler struct {
 	client.Client
+	WatchFilterValue string
 }
 
 // SetupWithManager sets up the controller with the Manager.
 func (r *AzureASOManagedClusterReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager) error {
+	_, log, done := tele.StartSpanWithLogger(ctx,
+		"controllers.AzureASOManagedClusterReconciler.SetupWithManager",
+		tele.KVP("controller", infrav1exp.AzureASOManagedClusterKind),
+	)
+	defer done()
+
 	_, err := ctrl.NewControllerManagedBy(mgr).
 		For(&infrav1exp.AzureASOManagedCluster{}).
+		WithEventFilter(predicates.ResourceHasFilterLabel(log, r.WatchFilterValue)).
 		Build(r)
 	if err != nil {
 		return err

exp/controllers/azureasomanagedcontrolplane_controller.go

@@ -20,19 +20,29 @@ import (
 	"context"
 
 	infrav1exp "sigs.k8s.io/cluster-api-provider-azure/exp/api/v1alpha1"
+	"sigs.k8s.io/cluster-api-provider-azure/util/tele"
+	"sigs.k8s.io/cluster-api/util/predicates"
 	ctrl "sigs.k8s.io/controller-runtime"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 )
 
 // AzureASOManagedControlPlaneReconciler reconciles a AzureASOManagedControlPlane object.
 type AzureASOManagedControlPlaneReconciler struct {
 	client.Client
+	WatchFilterValue string
 }
 
 // SetupWithManager sets up the controller with the Manager.
 func (r *AzureASOManagedControlPlaneReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager) error {
+	_, log, done := tele.StartSpanWithLogger(ctx,
+		"controllers.AzureASOManagedControlPlaneReconciler.SetupWithManager",
+		tele.KVP("controller", infrav1exp.AzureASOManagedControlPlaneKind),
+	)
+	defer done()
+
 	_, err := ctrl.NewControllerManagedBy(mgr).
 		For(&infrav1exp.AzureASOManagedControlPlane{}).
+		WithEventFilter(predicates.ResourceHasFilterLabel(log, r.WatchFilterValue)).
 		Build(r)
 	if err != nil {
 		return err

exp/controllers/azureasomanagedmachinepool_controller.go

@@ -20,19 +20,29 @@ import (
 	"context"
 
 	infrav1exp "sigs.k8s.io/cluster-api-provider-azure/exp/api/v1alpha1"
+	"sigs.k8s.io/cluster-api-provider-azure/util/tele"
+	"sigs.k8s.io/cluster-api/util/predicates"
 	ctrl "sigs.k8s.io/controller-runtime"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 )
 
 // AzureASOManagedMachinePoolReconciler reconciles a AzureASOManagedMachinePool object.
 type AzureASOManagedMachinePoolReconciler struct {
 	client.Client
+	WatchFilterValue string
 }
 
 // SetupWithManager sets up the controller with the Manager.
 func (r *AzureASOManagedMachinePoolReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager) error {
+	_, log, done := tele.StartSpanWithLogger(ctx,
+		"controllers.AzureASOManagedMachinePoolReconciler.SetupWithManager",
+		tele.KVP("controller", infrav1exp.AzureASOManagedMachinePoolKind),
+	)
+	defer done()
+
 	_, err := ctrl.NewControllerManagedBy(mgr).
 		For(&infrav1exp.AzureASOManagedMachinePool{}).
+		WithEventFilter(predicates.ResourceHasFilterLabel(log, r.WatchFilterValue)).
 		Build(r)
 	if err != nil {
 		return err

main.go

@@ -502,21 +502,24 @@ func registerControllers(ctx context.Context, mgr manager.Manager) {
 
 	if feature.Gates.Enabled(feature.ASOAPI) {
 		if err := (&infrav1controllersexp.AzureASOManagedClusterReconciler{
-			Client: mgr.GetClient(),
+			Client:           mgr.GetClient(),
+			WatchFilterValue: watchFilterValue,
 		}).SetupWithManager(ctx, mgr); err != nil {
 			setupLog.Error(err, "unable to create controller", "controller", "AzureASOManagedCluster")
 			os.Exit(1)
 		}
 
 		if err := (&infrav1controllersexp.AzureASOManagedControlPlaneReconciler{
-			Client: mgr.GetClient(),
+			Client:           mgr.GetClient(),
+			WatchFilterValue: watchFilterValue,
 		}).SetupWithManager(ctx, mgr); err != nil {
 			setupLog.Error(err, "unable to create controller", "controller", "AzureASOManagedControlPlane")
 			os.Exit(1)
 		}
 
 		if err := (&infrav1controllersexp.AzureASOManagedMachinePoolReconciler{
-			Client: mgr.GetClient(),
+			Client:           mgr.GetClient(),
+			WatchFilterValue: watchFilterValue,
 		}).SetupWithManager(ctx, mgr); err != nil {
 			setupLog.Error(err, "unable to create controller", "controller", "AzureASOManagedMachinePool")
 			os.Exit(1)