Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for SchedulePod (0.19 sec)

  1. pkg/scheduler/scheduler.go

    	// FailureHandler is called upon a scheduling failure.
    	FailureHandler FailureHandlerFn
    
    	// SchedulePod tries to schedule the given pod to one of the nodes in the node list.
    	// Return a struct of ScheduleResult with the name of suggested host on success,
    	// otherwise will return a FitError with reasons.
    	SchedulePod func(ctx context.Context, fwk framework.Framework, state *framework.CycleState, pod *v1.Pod) (ScheduleResult, error)
    
    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.go

    		return false
    	}
    	return isAssumed
    }
    
    // schedulePod tries to schedule the given pod to one of the nodes in the node list.
    // If it succeeds, it will return the name of the node.
    // If it fails, it will return a FitError with reasons.
    func (sched *Scheduler) schedulePod(ctx context.Context, fwk framework.Framework, state *framework.CycleState, pod *v1.Pod) (result ScheduleResult, err error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 13:28:08 UTC 2024
    - 43.4K bytes
    - Viewed (0)
  3. pkg/scheduler/extender_test.go

    				Extenders:                extenders,
    				logger:                   logger,
    			}
    			sched.applyDefaultHandlers()
    
    			podIgnored := &v1.Pod{}
    			result, err := sched.SchedulePod(ctx, fwk, framework.NewCycleState(), podIgnored)
    			if test.expectsErr {
    				if err == nil {
    					t.Errorf("Unexpected non-error, result %+v", result)
    				}
    			} else {
    				if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  4. pkg/scheduler/schedule_one_test.go

    		},
    		SchedulingQueue: schedulingQueue,
    		Profiles:        profile.Map{testSchedulerName: fwk},
    	}
    
    	sched.SchedulePod = sched.schedulePod
    	sched.FailureHandler = func(_ context.Context, _ framework.Framework, p *framework.QueuedPodInfo, status *framework.Status, _ *framework.NominatingInfo, _ time.Time) {
    		err := status.AsError()
    		errChan <- err
    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