- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for NewWaitingPodsMap (0.13 sec)
-
pkg/scheduler/framework/runtime/framework_test.go
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/schedule_one_test.go
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, NextPod: func(logger klog.Logger) (*framework.QueuedPodInfo, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 128.1K bytes - Viewed (0)