improve cache

Author: jpinsonneau

internal/controller/demoloki/demoloki_objects.go

@@ -42,7 +42,8 @@ func newBuilder(info *reconcilers.Instance, desired *flowslatest.FlowCollectorSp
 	return builder{
 		info: info,
 		labels: map[string]string{
-			"app": name,
+			"part-of": constants.OperatorName,
+			"app":     name,
 		},
 		selector: map[string]string{
 			"app": name,

internal/pkg/manager/manager.go

@@ -5,13 +5,17 @@ import (
 	"fmt"
 
 	flowslatest "github.com/netobserv/netobserv-operator/api/flowcollector/v1beta2"
+	"github.com/netobserv/netobserv-operator/internal/controller/constants"
 	"github.com/netobserv/netobserv-operator/internal/pkg/cluster"
 	"github.com/netobserv/netobserv-operator/internal/pkg/manager/status"
 	"github.com/netobserv/netobserv-operator/internal/pkg/migrator"
 	"github.com/netobserv/netobserv-operator/internal/pkg/narrowcache"
+	corev1 "k8s.io/api/core/v1"
+	"k8s.io/apimachinery/pkg/labels"
 	"k8s.io/client-go/discovery"
 	"k8s.io/client-go/rest"
 	ctrl "sigs.k8s.io/controller-runtime"
+	"sigs.k8s.io/controller-runtime/pkg/cache"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 	"sigs.k8s.io/controller-runtime/pkg/log"
 	"sigs.k8s.io/controller-runtime/pkg/manager"
@@ -86,6 +90,13 @@ func NewManager(
 		narrowcache.EndpointSlices,
 	)
 	opts.Client = client.Options{Cache: narrowCache.ControllerRuntimeClientCacheOptions()}
+	opts.Cache = cache.Options{
+		ByObject: map[client.Object]cache.ByObject{
+			&corev1.Pod{}: {
+				Label: labels.SelectorFromSet(map[string]string{"part-of": constants.OperatorName}),
+			},
+		},
+	}
 
 	internalManager, err := ctrl.NewManager(kcfg, *opts)
 	if err != nil {