scheduler

type ExtenderArgs struct {
	// Stage being scheduled
	Stage *meta.Stage
	// List of candidate workers where the stage can be scheduled; to be populated
	// only if Extender.WorkerCacheCapable == false
	Workers *meta.WorkerList
	// List of candidate worker names where the stage can be scheduled; to be
	// populated only if Extender.WorkerCacheCapable == true
	WorkerNames *[]string
}

type ExtenderBindingResult struct {
	// Error message indicating failure
	Error string
}

type ExtenderFilterResult struct {
	// Filtered set of workers where the stage can be scheduled; to be populated
	// only if Extender.WorkerCacheCapable == false
	Workers *meta.WorkerList
	// Filtered set of workers where the stage can be scheduled; to be populated
	// only if Extender.WorkerCacheCapable == true
	WorkerNames *[]string
	// Filtered out workers where the stage can't be scheduled and the failure messages
	FailedWorkers FailedWorkersMap
	// Filtered out workers where the stage can't be scheduled and preemption would
	// not change anything. The value is the failure message same as FailedWorkers.
	// Workers specified here takes precedence over FailedWorkers.
	FailedAndUnresolvableWorkers FailedWorkersMap
	// Error message indicating failure
	Error string
}

type ExtenderPreemptionArgs struct {
	// Stage being scheduled
	Stage *meta.Stage
	// Victims map generated by scheduler preemption phase
	// Only set WorkerNameToMetaVictims if Extender.WorkerCacheCapable == true. Otherwise, only set WorkerNameToVictims.
	WorkerNameToVictims     map[string]*Victims
	WorkerNameToMetaVictims map[string]interface{}
}

type ExtenderPreemptionResult struct {
	WorkerNameToMetaVictims map[string]interface{}
}

type FailedWorkersMap map[string]string

type FrameworkCapturer func(config.Profile)

type HTTPExtender struct {
	// contains filtered or unexported fields
}

type Option func(*schedulerOptions)

type ScheduleResult struct {
	// UID of the selected worker.
	SuggestedHost string
	// The number of workers the scheduler evaluated the stage against in the filtering
	// phase and beyond.
	EvaluatedWorkers int
	// The number of workers out of the evaluated ones that fit the stage.
	FeasibleWorkers int
}

type Scheduler struct {
	Cache cache.Cache

	Extenders []framework.Extender

	NextStage func() *framework.QueuedStageInfo

	Error func(*framework.QueuedStageInfo, error)

	ScheduleStage func(ctx context.Context, fwk framework.Framework, state *framework.CycleState, stage *meta.Stage) (ScheduleResult, error)

	StopEverything <-chan struct{}

	SchedulingQueue queue.SchedulingQueue

	// Profiles are the scheduling profiles.
	Profiles map[string]framework.Framework
	// contains filtered or unexported fields
}

type Victims struct {
	Stages           []*meta.Stage
	NumPDBViolations int64
}