adds New functions to the scorers for consistency (#975)

* adds New functions to the scorers for consistency

Signed-off-by: Nir Rozenbaum <[email protected]>

* update main to use the scorer new functions

Signed-off-by: Nir Rozenbaum <[email protected]>

---------

Signed-off-by: Nir Rozenbaum <[email protected]>

Author: nirrozenbaum

cmd/epp/runner/runner.go

@@ -272,8 +272,8 @@ func (r *Runner) initializeScheduler(datastore datastore.Datastore) (*scheduling
 		kvCacheScorerWeight := envutil.GetEnvInt("KV_CACHE_SCORE_WEIGHT", scorer.DefaultKVCacheScorerWeight, setupLog)
 
 		schedulerProfile := framework.NewSchedulerProfile().
-			WithScorers(framework.NewWeightedScorer(&scorer.QueueScorer{}, queueScorerWeight),
-				framework.NewWeightedScorer(&scorer.KVCacheScorer{}, kvCacheScorerWeight)).
+			WithScorers(framework.NewWeightedScorer(scorer.NewQueueScorer(), queueScorerWeight),
+				framework.NewWeightedScorer(scorer.NewKVCacheScorer(), kvCacheScorerWeight)).
 			WithPicker(picker.NewMaxScorePicker())
 
 		if prefixCacheScheduling {

pkg/epp/scheduling/framework/plugins/scorer/kvcache.go

@@ -30,6 +30,11 @@ const (
 // compile-time type assertion
 var _ framework.Scorer = &KVCacheScorer{}
 
+// NewKVCacheScorer initializes a new KVCacheScorer and returns its pointer.
+func NewKVCacheScorer() *KVCacheScorer {
+	return &KVCacheScorer{}
+}
+
 // KVCacheScorer scores list of candidate pods based on KV cache utilization.
 type KVCacheScorer struct{}
 

pkg/epp/scheduling/framework/plugins/scorer/queue.go

@@ -31,6 +31,11 @@ const (
 // compile-time type assertion
 var _ framework.Scorer = &QueueScorer{}
 
+// NewQueueScorer initializes a new QueueScorer and returns its pointer.
+func NewQueueScorer() *QueueScorer {
+	return &QueueScorer{}
+}
+
 // QueueScorer scores list of candidate pods based on the pod's waiting queue size.
 // the less waiting queue size the pod has, the higher score it will get (since it's more available to serve new request).
 type QueueScorer struct{}