Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for ScheduleOne (0.15 sec)

  1. pkg/scheduler/scheduler.go

    func (sched *Scheduler) Run(ctx context.Context) {
    	logger := klog.FromContext(ctx)
    	sched.SchedulingQueue.Run(logger)
    
    	// We need to start scheduleOne loop in a dedicated goroutine,
    	// because scheduleOne function hangs on getting the next item
    	// from the SchedulingQueue.
    	// If there are no new pods to schedule, it will be hanging there
    	// and if done in this goroutine it will be blocking closing
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 20.8K bytes
    - Viewed (0)
  2. pkg/scheduler/schedule_one_test.go

    				if e.Reason != item.eventReason {
    					t.Errorf("got event %v, want %v", e.Reason, item.eventReason)
    				}
    				close(called)
    			})
    			if err != nil {
    				t.Fatal(err)
    			}
    			sched.ScheduleOne(ctx)
    			<-called
    			if e, a := item.expectAssumedPod, gotAssumedPod; !reflect.DeepEqual(e, a) {
    				t.Errorf("assumed pod: wanted %v, got %v", e, a)
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
  3. pkg/scheduler/schedule_one.go

    	// to be included in ScheduleResult.
    	numberOfHighestScoredNodesToReport = 3
    )
    
    // ScheduleOne does the entire scheduling workflow for a single pod. It is serialized on the scheduling algorithm's host fitting.
    func (sched *Scheduler) ScheduleOne(ctx context.Context) {
    	logger := klog.FromContext(ctx)
    	podInfo, err := sched.NextPod(logger)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 13:28:08 UTC 2024
    - 43.4K bytes
    - Viewed (0)
Back to top