Merge pull request #2122 from ntoofu/fix-2121

fix: Add filtering for Lease metrics
kubernetes · Jul 26, 2023 · 71e099b · 71e099b
2 parents 89c1bc3 + dc79b3e
commit 71e099b
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/internal/store/lease.go b/internal/store/lease.go
@@ -116,13 +116,15 @@ func wrapLeaseFunc(f func(*coordinationv1.Lease) *metric.Family) func(interface{
 	}
 }
 
-func createLeaseListWatch(kubeClient clientset.Interface, _ string, _ string) cache.ListerWatcher {
+func createLeaseListWatch(kubeClient clientset.Interface, ns string, fieldSelector string) cache.ListerWatcher {
 	return &cache.ListWatch{
 		ListFunc: func(opts metav1.ListOptions) (runtime.Object, error) {
-			return kubeClient.CoordinationV1().Leases("").List(context.TODO(), opts)
+			opts.FieldSelector = fieldSelector
+			return kubeClient.CoordinationV1().Leases(ns).List(context.TODO(), opts)
 		},
 		WatchFunc: func(opts metav1.ListOptions) (watch.Interface, error) {
-			return kubeClient.CoordinationV1().Leases("").Watch(context.TODO(), opts)
+			opts.FieldSelector = fieldSelector
+			return kubeClient.CoordinationV1().Leases(ns).Watch(context.TODO(), opts)
 		},
 	}
 }