@@ -45,7 +45,7 @@ import (
4545 "sigs.k8s.io/gateway-api-inference-extension/pkg/epp/datastore"
4646 "sigs.k8s.io/gateway-api-inference-extension/pkg/epp/metrics"
4747 "sigs.k8s.io/gateway-api-inference-extension/pkg/epp/requestcontrol"
48- "sigs.k8s.io/gateway-api-inference-extension/pkg/epp/saturationdetector"
48+ "sigs.k8s.io/gateway-api-inference-extension/pkg/epp/saturationdetector/framework/plugins/utilizationdetector "
4949 "sigs.k8s.io/gateway-api-inference-extension/pkg/epp/scheduling"
5050 "sigs.k8s.io/gateway-api-inference-extension/pkg/epp/scheduling/framework"
5151 "sigs.k8s.io/gateway-api-inference-extension/pkg/epp/scheduling/framework/plugins/multi/prefix"
@@ -144,12 +144,12 @@ func NewTestHarness(t *testing.T, ctx context.Context) *TestHarness {
144144 profileHandler := profile .NewSingleProfileHandler ()
145145 schedulerConfig := scheduling .NewSchedulerConfig (profileHandler , map [string ]* framework.SchedulerProfile {"default" : defaultProfile })
146146
147- sdConfig := & saturationdetector .Config {
148- QueueDepthThreshold : saturationdetector .DefaultQueueDepthThreshold ,
149- KVCacheUtilThreshold : saturationdetector .DefaultKVCacheUtilThreshold ,
150- MetricsStalenessThreshold : saturationdetector .DefaultMetricsStalenessThreshold ,
147+ sdConfig := & utilizationdetector .Config {
148+ QueueDepthThreshold : utilizationdetector .DefaultQueueDepthThreshold ,
149+ KVCacheUtilThreshold : utilizationdetector .DefaultKVCacheUtilThreshold ,
150+ MetricsStalenessThreshold : utilizationdetector .DefaultMetricsStalenessThreshold ,
151151 }
152- runner .SaturationDetector = saturationdetector .NewDetector (sdConfig , logger .WithName ("sd" ))
152+ runner .SaturationDetector = utilizationdetector .NewDetector (sdConfig , logger .WithName ("sd" ))
153153 locator := requestcontrol .NewDatastorePodLocator (runner .Datastore )
154154 runner .Director = requestcontrol .NewDirectorWithConfig (
155155 runner .Datastore ,
0 commit comments