jobsscheduler

Documentation

Index

• type Scheduler
  • func New(ctx context.Context, roles []string, stor storage, secr secrets, ...) *Scheduler
  • func (sched *Scheduler) FindTasksForOffer(ctx context.Context, offer *mesos.Offer) []mesos.TaskInfo
  • func (sched *Scheduler) HandleTaskStateUpdate(status *mesos.TaskStatus)

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

func (sched *Scheduler) FindTasksForOffer(ctx context.Context, offer *mesos.Offer) []mesos.TaskInfo

FindTasksForOffer returns tasks to run for passed offer.

func (*Scheduler) HandleTaskStateUpdate

func (sched *Scheduler) HandleTaskStateUpdate(status *mesos.TaskStatus)

HandleTaskStateUpdate processes task state change.