- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for WithMetricsRecorder (7.47 sec)
-
pkg/scheduler/framework/runtime/framework_test.go
if !reflect.DeepEqual(status, tt.want) { t.Errorf("wrong status code. got %v, want %v", status, tt.want) } }) } } // withMetricsRecorder set metricsRecorder for the scheduling frameworkImpl. func withMetricsRecorder(recorder *metrics.MetricAsyncRecorder) Option { return func(o *frameworkOptions) { o.metricsRecorder = recorder } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 103K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
queue := NewTestQueue(ctx, newDefaultQueueSort(), WithClock(testingclock.NewFakeClock(timestamp)), WithPreEnqueuePluginMap(m), WithPluginMetricsSamplePercent(test.pluginMetricsSamplePercent), WithMetricsRecorder(*recorder)) for i, op := range test.operations { for _, pInfo := range test.operands[i] { op(t, logger, queue, pInfo) } } recorder.FlushMetrics()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0)