update object filter

Author: hzxuzhonghu

Diff for: cmd/epp/main.go

@@ -31,6 +31,7 @@ import (
 	"google.golang.org/grpc"
 	healthPb "google.golang.org/grpc/health/grpc_health_v1"
 	corev1 "k8s.io/api/core/v1"
+	"k8s.io/apimachinery/pkg/fields"
 	"k8s.io/apimachinery/pkg/runtime"
 	utilruntime "k8s.io/apimachinery/pkg/util/runtime"
 	clientgoscheme "k8s.io/client-go/kubernetes/scheme"
@@ -154,7 +155,11 @@ func run() error {
 				},
 				&v1alpha2.InferencePool{}: {
 					Namespaces: map[string]cache.Config{
-						*poolNamespace: {},
+						*poolNamespace: {
+							FieldSelector: fields.SelectorFromSet(fields.Set{
+								"metadata.name": *poolName,
+							}),
+						},
 					},
 				},
 				&v1alpha2.InferenceModel{}: {

Diff for: pkg/epp/controller/inferencemodel_reconciler.go

@@ -128,5 +128,5 @@ func (c *InferenceModelReconciler) SetupWithManager(ctx context.Context, mgr ctr
 }
 
 func (c *InferenceModelReconciler) eventPredicate(infModel *v1alpha2.InferenceModel) bool {
-	return (infModel.Spec.PoolRef.Name == c.PoolNamespacedName.Name) && (infModel.GetNamespace() == c.PoolNamespacedName.Namespace)
+	return infModel.Spec.PoolRef.Name == c.PoolNamespacedName.Name
 }

Diff for: pkg/epp/controller/inferencepool_reconciler.go

@@ -27,7 +27,6 @@ import (
 	ctrl "sigs.k8s.io/controller-runtime"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 	"sigs.k8s.io/controller-runtime/pkg/log"
-	"sigs.k8s.io/controller-runtime/pkg/predicate"
 	"sigs.k8s.io/gateway-api-inference-extension/api/v1alpha2"
 	"sigs.k8s.io/gateway-api-inference-extension/pkg/epp/datastore"
 	logutil "sigs.k8s.io/gateway-api-inference-extension/pkg/epp/util/logging"
@@ -90,8 +89,5 @@ func (c *InferencePoolReconciler) updateDatastore(ctx context.Context, newPool *
 func (c *InferencePoolReconciler) SetupWithManager(mgr ctrl.Manager) error {
 	return ctrl.NewControllerManagedBy(mgr).
 		For(&v1alpha2.InferencePool{}).
-		WithEventFilter(predicate.NewPredicateFuncs(func(object client.Object) bool {
-			return (object.GetNamespace() == c.PoolNamespacedName.Namespace) && (object.GetName() == c.PoolNamespacedName.Name)
-		})).
 		Complete(c)
 }

Diff for: pkg/epp/controller/pod_reconciler.go

@@ -27,7 +27,6 @@ import (
 	ctrl "sigs.k8s.io/controller-runtime"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 	"sigs.k8s.io/controller-runtime/pkg/log"
-	"sigs.k8s.io/controller-runtime/pkg/predicate"
 	"sigs.k8s.io/gateway-api-inference-extension/pkg/epp/datastore"
 	logutil "sigs.k8s.io/gateway-api-inference-extension/pkg/epp/util/logging"
 )
@@ -66,12 +65,8 @@ func (c *PodReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.R
 }
 
 func (c *PodReconciler) SetupWithManager(mgr ctrl.Manager) error {
-	// Filter specific inference pool
-	p := predicate.NewPredicateFuncs(func(object client.Object) bool {
-		return object.GetNamespace() == c.Namespace
-	})
 	return ctrl.NewControllerManagedBy(mgr).
-		For(&corev1.Pod{}).WithEventFilter(p).
+		For(&corev1.Pod{}).
 		Complete(c)
 }