Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Scheduler ¶
type Scheduler struct {
// contains filtered or unexported fields
}
Scheduler decides which jobs to run in response to received offers.
func New ¶
func New(ctx context.Context, roles []string, stor storage, secr secrets, frameworkID, leaderURL func() string) *Scheduler
New creates fresh instance of jobs scheduler.
func (*Scheduler) FindTasksForOffer ¶
FindTasksForOffer returns tasks to run for passed offer.
func (*Scheduler) HandleTaskStateUpdate ¶
func (sched *Scheduler) HandleTaskStateUpdate(status *mesos.TaskStatus)
HandleTaskStateUpdate processes task state change.
Source Files
Click to show internal directories.
Click to hide internal directories.