feat: [pod autosharding] transition from labelselector to fieldselector

pkoutsovasilis · pkoutsovasilis · commit 097ae84c0c92 · 2024-03-22T00:00:05.000+02:00
diff --git a/pkg/metricshandler/metrics_handler.go b/pkg/metricshandler/metrics_handler.go
@@ -111,12 +111,12 @@ func (m *MetricsHandler) Run(ctx context.Context) error {
 	}
 	statefulSetName := ss.Name
 
-	labelSelectorOptions := func(o *metav1.ListOptions) {
-		o.LabelSelector = fields.SelectorFromSet(ss.Labels).String()
+	fieldSelectorOptions := func(o *metav1.ListOptions) {
+		o.FieldSelector = fields.OneTermEqualSelector("metadata.name", statefulSetName).String()
 	}
 
 	i := cache.NewSharedIndexInformer(
-		cache.NewFilteredListWatchFromClient(m.kubeClient.AppsV1().RESTClient(), "statefulsets", m.opts.Namespace, labelSelectorOptions),
+		cache.NewFilteredListWatchFromClient(m.kubeClient.AppsV1().RESTClient(), "statefulsets", m.opts.Namespace, fieldSelectorOptions),
 		&appsv1.StatefulSet{}, 0, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc},
 	)
 	i.AddEventHandler(cache.ResourceEventHandlerFuncs{

Original file line number	Diff line number	Diff line change
`@@ -111,12 +111,12 @@ func (m *MetricsHandler) Run(ctx context.Context) error {`
`111`	`111`	`}`
`112`	`112`	`statefulSetName := ss.Name`
`113`	`113`
`114`		`- labelSelectorOptions := func(o *metav1.ListOptions) {`
`115`		`- o.LabelSelector = fields.SelectorFromSet(ss.Labels).String()`
	`114`	`+ fieldSelectorOptions := func(o *metav1.ListOptions) {`
	`115`	`+ o.FieldSelector = fields.OneTermEqualSelector("metadata.name", statefulSetName).String()`
`116`	`116`	`}`
`117`	`117`
`118`	`118`	`i := cache.NewSharedIndexInformer(`
`119`		`- cache.NewFilteredListWatchFromClient(m.kubeClient.AppsV1().RESTClient(), "statefulsets", m.opts.Namespace, labelSelectorOptions),`
	`119`	`+ cache.NewFilteredListWatchFromClient(m.kubeClient.AppsV1().RESTClient(), "statefulsets", m.opts.Namespace, fieldSelectorOptions),`
`120`	`120`	`&appsv1.StatefulSet{}, 0, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc},`
`121`	`121`	`)`
`122`	`122`	`i.AddEventHandler(cache.ResourceEventHandlerFuncs{`