feat: pending cache for configurable list of gvks

cmd/manager/main.go

@@ -65,6 +65,7 @@ import (
 	"github.com/cobaltcore-dev/cortex/internal/scheduling/reservations/failover"
 	"github.com/cobaltcore-dev/cortex/internal/scheduling/reservations/inflight"
 	"github.com/cobaltcore-dev/cortex/internal/scheduling/reservations/quota"
+	"github.com/cobaltcore-dev/cortex/pkg/cache"
 	"github.com/cobaltcore-dev/cortex/pkg/conf"
 	"github.com/cobaltcore-dev/cortex/pkg/monitoring"
 	"github.com/cobaltcore-dev/cortex/pkg/multicluster"
@@ -391,6 +392,10 @@ func main() {
 		},
 	}
 	multiclusterClientConfig := conf.GetConfigOrDie[multicluster.ClientConfig]()
+
+	if c := conf.GetConfigOrDie[cache.RootConfig](); c.Cache.Enabled {
+		multiclusterClient.Wrappers = append(multiclusterClient.Wrappers, cache.NewWrapper(c.Cache))
+	}
 	if err := multiclusterClient.InitFromConf(ctx, mgr, multiclusterClientConfig); err != nil {
 		setupLog.Error(err, "unable to initialize multicluster client")
 		os.Exit(1)

helm/bundles/cortex-nova/values.yaml

@@ -74,6 +74,12 @@ kvm:
   # Useful when rolling out a new KVM region before it is production-ready.
   criticalAlerts: true
 
+# Cache configuration for the transparent in-process overlay cache.
+cache:
+  enabled: true
+  gvks:
+    - cortex.cloud/v1alpha1/Reservation
+
 cortex: &cortex
   crd: {enable: false}
   # Disable the default ServiceMonitor and metrics service from the kubebuilder stack.
@@ -185,7 +191,7 @@ cortex-scheduling-controllers:
       # How long after a VM is allocated to a reservation before it is expected to appear
       # on the target host; allocations not confirmed within this window are removed
       allocationGracePeriod: "15m"
-      # How long to wait after detecting host over-subscription before evicting reservation slots. 
+      # How long to wait after detecting host over-subscription before evicting reservation slots.
       # Gives other controllers (e.g. failover) time to self-heal.
       oversubscriptionGracePeriod: "3m"
       # Minimum time between consecutive over-subscription checks for the same host.

internal/shim/placement/field_index_test.go

@@ -50,6 +50,10 @@ type stubCluster struct {
 func (s *stubCluster) GetClient() client.Client { return s.cl }
 func (s *stubCluster) GetCache() cache.Cache    { return s.cache }
 
+// GetFieldIndexer returns the cache, which implements client.FieldIndexer via
+// its IndexField method — mirroring an unwrapped controller-runtime cluster.
+func (s *stubCluster) GetFieldIndexer() client.FieldIndexer { return s.cache }
+
 type stubManager struct {
 	manager.Manager
 }