- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for WithWaitingPods (0.15 sec)
-
pkg/scheduler/scheduler.go
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 { return nil, errors.New("at least one profile is required") }
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
profile := config.KubeSchedulerProfile{Plugins: configPlugins} ctx, cancel := context.WithCancel(context.Background()) defer cancel() f, err := newFrameworkWithQueueSortAndBind(ctx, registry, profile, WithWaitingPods(NewWaitingPodsMap()), ) if err != nil { t.Fatalf("fail to create framework: %s", err) } status := f.RunPermitPlugins(ctx, nil, pod, "") if !reflect.DeepEqual(status, tt.want) {
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 WithMetricsRecorder(r *metrics.MetricAsyncRecorder) Option { return func(o *frameworkOptions) { o.metricsRecorder = r } } // WithWaitingPods sets waitingPods for the scheduling frameworkImpl. func WithWaitingPods(wp *waitingPodsMap) Option { return func(o *frameworkOptions) { o.waitingPods = wp } } // WithLogger overrides the default logger from k8s.io/klog.
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/scheduler_test.go
frameworkruntime.WithClientSet(client), frameworkruntime.WithInformerFactory(informerFactory), frameworkruntime.WithEventRecorder(eventBroadcaster.NewRecorder(scheme.Scheme, testSchedulerName)), frameworkruntime.WithWaitingPods(waitingPods), ) if err != nil { return nil, nil, err } s := &Scheduler{ Cache: cache, client: client, StopEverything: ctx.Done(), SchedulingQueue: queue,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 42K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go
frameworkruntime.WithExtenders(extenders), frameworkruntime.WithSnapshotSharedLister(internalcache.NewSnapshot(tt.pods, tt.nodes)), frameworkruntime.WithLogger(logger), frameworkruntime.WithWaitingPods(frameworkruntime.NewWaitingPodsMap()), ) if err != nil { t.Fatal(err) } p := DefaultPreemption{ fh: f, podLister: informerFactory.Core().V1().Pods().Lister(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 82.8K bytes - Viewed (0) -
pkg/scheduler/schedule_one_test.go
registerPluginFuncs, testSchedulerName, frameworkruntime.WithClientSet(client), frameworkruntime.WithEventRecorder(eventBroadcaster.NewRecorder(scheme.Scheme, testSchedulerName)), frameworkruntime.WithWaitingPods(frameworkruntime.NewWaitingPodsMap()), ) if err != nil { t.Fatal(err) } sched := &Scheduler{ Cache: cache, client: client,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 128.1K bytes - Viewed (0)