queue

type ExplicitKey string

type Option func(*priorityQueueOptions)

type PreEnqueueCheck func(stage *meta.Stage) bool

type PriorityQueue struct {
	// StageNominator abstracts the operations to maintain nominated Stages.
	framework.StageNominator
	// contains filtered or unexported fields
}

type SchedulingQueue interface {
	framework.StageNominator
	Add(stage *meta.Stage) error
	// Activate moves the given stages to activeQ iff they're in unschedulableStages or backoffQ.
	// The passed-in stages are originally compiled from plugins that want to activate Stages,
	// by injecting the stages through a reserved CycleState struct (StagesToActivate).
	Activate(stages map[string]*meta.Stage)
	// AddUnschedulableIfNotPresent adds an unschedulable stage back to scheduling queue.
	// The stageSchedulingCycle represents the current scheduling cycle number which can be
	// returned by calling SchedulingCycle().
	AddUnschedulableIfNotPresent(stage *framework.QueuedStageInfo, stageSchedulingCycle int64) error
	// SchedulingCycle returns the current number of scheduling cycle which is
	// cached by scheduling queue. Normally, incrementing this number whenever
	// a stage is popped (e.g. called Pop()) is enough.
	SchedulingCycle() int64
	// Pop removes the head of the queue and returns it. It blocks if the
	// queue is empty and waits until a new item is added to the queue.
	Pop() (*framework.QueuedStageInfo, error)
	Update(oldStage, newStage *meta.Stage) error
	Delete(stage *meta.Stage) error
	MoveAllToActiveOrBackoffQueue(event framework.ClusterEvent, preCheck PreEnqueueCheck)
	AssignedStageAdded(stage *meta.Stage)
	AssignedStageUpdated(stage *meta.Stage)
	PendingStages() []*meta.Stage
	// Close closes the SchedulingQueue so that the goroutine which is
	// waiting to pop items can exit gracefully.
	Close()
	// Run starts the goroutines managing the queue.
	Run()
}

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