FF

Author: jaronoff97

main.go

@@ -28,6 +28,8 @@ import (
 	monitoringv1 "github.com/prometheus-operator/prometheus-operator/pkg/apis/monitoring/v1"
 	"github.com/spf13/pflag"
 	colfeaturegate "go.opentelemetry.io/collector/featuregate"
+	appsv1 "k8s.io/api/apps/v1"
+	v1 "k8s.io/api/batch/v1"
 	networkingv1 "k8s.io/api/networking/v1"
 	"k8s.io/apimachinery/pkg/labels"
 	k8sruntime "k8s.io/apimachinery/pkg/runtime"
@@ -39,6 +41,7 @@ import (
 	k8sapiflag "k8s.io/component-base/cli/flag"
 	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/healthz"
 	"sigs.k8s.io/controller-runtime/pkg/log/zap"
 	"sigs.k8s.io/controller-runtime/pkg/manager"
@@ -274,12 +277,24 @@ func main() {
 			Port:    webhookPort,
 			TLSOpts: optionsTlSOptsFuncs,
 		}),
-		Cache: cache.Options{
+	}
+
+	if featuregate.EnableCacheOptions.IsEnabled() {
+		mgrOptions.Cache = cache.Options{
 			DefaultNamespaces: namespaces,
 			DefaultLabelSelector: labels.SelectorFromSet(map[string]string{
 				"app.kubernetes.io/managed-by": "opentelemetry-operator",
 			}),
-		},
+			ByObject: map[client.Object]cache.ByObject{
+				&otelv1alpha1.OpenTelemetryCollector{}: {},
+				&otelv1alpha1.OpAMPBridge{}:            {},
+				&otelv1alpha1.Instrumentation{}:        {},
+				&v1.Job{}:                              {},
+				&appsv1.Deployment{}:                   {},
+				&appsv1.DaemonSet{}:                    {},
+				&appsv1.StatefulSet{}:                  {},
+			},
+		}
 	}
 
 	mgr, err := ctrl.NewManager(restConfig, mgrOptions)

pkg/featuregate/featuregate.go

@@ -60,6 +60,14 @@ var (
 		featuregate.WithRegisterDescription("enables features associated to the Prometheus Operator"),
 		featuregate.WithRegisterFromVersion("v0.82.0"),
 	)
+
+	// EnableCacheOptions is the feature gate that sets a cache label selector to improve operator performance.
+	EnableCacheOptions = featuregate.GlobalRegistry().MustRegister(
+		"operator.cache.selector",
+		featuregate.StageBeta, // TODO: this is temporary and will be reverted prior to an e2e run
+		featuregate.WithRegisterDescription("enables the operator's cache to only select a subset of objects"),
+		featuregate.WithRegisterFromVersion("v0.98.0"),
+	)
 )
 
 // Flags creates a new FlagSet that represents the available featuregate flags using the supplied featuregate registry.