- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for WithMetricsRecorder (0.41 sec)
-
pkg/scheduler/scheduler.go
frameworkruntime.WithCaptureProfile(frameworkruntime.CaptureProfile(options.frameworkCapturer)), frameworkruntime.WithParallelism(int(options.parallelism)), frameworkruntime.WithExtenders(extenders), frameworkruntime.WithMetricsRecorder(metricsRecorder), frameworkruntime.WithWaitingPods(waitingPods), ) if err != nil { return nil, fmt.Errorf("initializing profiles: %v", err) } if len(profiles) == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 20.8K bytes - Viewed (0) -
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/framework/runtime/framework.go
func WithCaptureProfile(c CaptureProfile) Option { return func(o *frameworkOptions) { o.captureProfile = c } } // WithMetricsRecorder sets metrics recorder for the scheduling frameworkImpl. func WithMetricsRecorder(r *metrics.MetricAsyncRecorder) Option { return func(o *frameworkOptions) { o.metricsRecorder = r } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
func WithPreEnqueuePluginMap(m map[string][]framework.PreEnqueuePlugin) Option { return func(o *priorityQueueOptions) { o.preEnqueuePluginMap = m } } // WithMetricsRecorder sets metrics recorder. func WithMetricsRecorder(recorder metrics.MetricAsyncRecorder) Option { return func(o *priorityQueueOptions) { o.metricsRecorder = recorder } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K 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)