Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewWaitingPodsMap (0.13 sec)

  1. 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)
  2. 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)
Back to top