From 9d2c4406bf1cf06a9710aab2526317865b56978b Mon Sep 17 00:00:00 2001 From: Bryan Boreham Date: Thu, 15 Apr 2021 11:13:14 +0000 Subject: [PATCH] Watch just the one object Previous code was getting notifications of all objects with matching kind --- controllers/events/watcher.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/controllers/events/watcher.go b/controllers/events/watcher.go index 51dc58b..87f367c 100644 --- a/controllers/events/watcher.go +++ b/controllers/events/watcher.go @@ -10,6 +10,7 @@ import ( "k8s.io/apimachinery/pkg/api/meta" v1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/apis/meta/v1/unstructured" + "k8s.io/apimachinery/pkg/fields" "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/runtime/schema" "k8s.io/apimachinery/pkg/types" @@ -68,6 +69,7 @@ func (m *watchManager) watch(obj runtime.Object, ew eventNotifier) error { return err } listOptions := v1.ListOptions{ + FieldSelector: fields.OneTermEqualSelector("metadata.name", ma.GetName()).String(), ResourceVersion: ma.GetResourceVersion(), } wi.watch, err = r.Watch(listOptions)