NewFilteredEvictor returns a new evictor that evicts all jobs for which jobIdsToEvict[jobId] is true on nodes for which nodeIdsToEvict[nodeId] is true.

NewOversubscribedEvictor returns a new evictor that for each node evicts all preemptible jobs of a priority class for which at least one job could not be scheduled.

PreemptedJobsFromSchedulerResult returns the slice of preempted jobs in the result.

ScheduledJobsFromSchedulerResult returns the slice of scheduled jobs in the result.

CandidateGangIterator determines which gang to try scheduling next across queues.

FairSchedulingAlgo is a SchedulingAlgo based on PreemptingQueueScheduler.

GangScheduler schedules one gang at a time.

MultiJobsIterator chains several JobIterators together in the order provided.

PreemptingQueueScheduler is a scheduler that makes a unified decisions on which jobs to preempt and schedule.

QueueCandidateGangIteratorPQ is a priority queue used by CandidateGangIterator to determine from which queue to schedule the next job.

QueuedGangIterator is an iterator over queued gangs.

QueuedJobsIterator is an iterator over all jobs in a queue.

QueueScheduler is responsible for choosing the order in which to attempt scheduling queued gangs.

SchedulerResult is returned by Rescheduler.Schedule().

SchedulingAlgo is the interface between the Pulsar-backed scheduler and the algorithm deciding which jobs to schedule and preempt.