Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func PreemptedJobsFromSchedulerResult ¶
func PreemptedJobsFromSchedulerResult(sr *SchedulerResult) []*jobdb.Job
PreemptedJobsFromSchedulerResult returns the slice of preempted jobs in the result.
func ScheduledJobsFromSchedulerResult ¶
func ScheduledJobsFromSchedulerResult(sr *SchedulerResult) []*jobdb.Job
ScheduledJobsFromSchedulerResult returns the slice of scheduled jobs in the result.
Types ¶
type SchedulerResult ¶
type SchedulerResult struct {
// Running jobs that should be preempted.
PreemptedJobs []*schedulercontext.JobSchedulingContext
// Queued jobs that should be scheduled.
ScheduledJobs []*schedulercontext.JobSchedulingContext
// For each preempted job, maps the job id to the id of the node on which the job was running.
// For each scheduled job, maps the job id to the id of the node on which the job should be scheduled.
NodeIdByJobId map[string]string
// Each result may bundle the result of several scheduling decisions.
// These are the corresponding scheduling contexts.
// TODO: This doesn't seem like the right approach.
SchedulingContexts []*schedulercontext.SchedulingContext
}
SchedulerResult is returned by Rescheduler.Schedule().
Click to show internal directories.
Click to hide internal directories.