Merge pull request #84785 from ahg-g/ahg-predicatemeta

expose PredicateMetadataProducer in generic scheduler

pkg/scheduler/core/generic_scheduler.go

@@ -131,6 +131,10 @@ type ScheduleAlgorithm interface {
 	// Extenders returns a slice of extender config. This is exposed for
 	// testing.
 	Extenders() []algorithm.SchedulerExtender
+	// GetPredicateMetadataProducer returns the predicate metadata producer. This is needed
+	// for cluster autoscaler integration.
+	// TODO(ahg-g): remove this once CA migrates to creating a Framework instead of a full scheduler.
+	PredicateMetadataProducer() predicates.PredicateMetadataProducer
 }
 
 // ScheduleResult represents the result of one pod scheduled. It will contain
@@ -171,6 +175,13 @@ func (g *genericScheduler) snapshot() error {
 	return g.cache.UpdateNodeInfoSnapshot(g.nodeInfoSnapshot)
 }
 
+// GetPredicateMetadataProducer returns the predicate metadata producer. This is needed
+// for cluster autoscaler integration.
+func (g *genericScheduler) PredicateMetadataProducer() predicates.PredicateMetadataProducer {
+	return g.predicateMetaProducer
+
+}
+
 // Schedule tries to schedule the given pod to one of the nodes in the node list.
 // If it succeeds, it will return the name of the node.
 // If it fails, it will return a FitError error with reasons.

pkg/scheduler/scheduler_test.go

@@ -152,6 +152,11 @@ type mockScheduler struct {
 	err    error
 }
 
+func (es mockScheduler) PredicateMetadataProducer() predicates.PredicateMetadataProducer {
+	return nil
+
+}
+
 func (es mockScheduler) Schedule(ctx context.Context, state *framework.CycleState, pod *v1.Pod) (core.ScheduleResult, error) {
 	return es.result, es.err
 }