scheduler

Documentation

Index

• type ReflexScheduler
  • func NewScheduler(exec *mesos.ExecutorInfo) *ReflexScheduler
  • func (sched *ReflexScheduler) Disconnected(sched.SchedulerDriver)
  • func (sched *ReflexScheduler) Error(driver sched.SchedulerDriver, err string)
  • func (sched *ReflexScheduler) ExecutorLost(sched.SchedulerDriver, *mesos.ExecutorID, *mesos.SlaveID, int)
  • func (sched *ReflexScheduler) FrameworkMessage(sched.SchedulerDriver, *mesos.ExecutorID, *mesos.SlaveID, string)
  • func (sched *ReflexScheduler) OfferRescinded(sched.SchedulerDriver, *mesos.OfferID)
  • func (sched *ReflexScheduler) Registered(driver sched.SchedulerDriver, frameworkId *mesos.FrameworkID, ...)
  • func (sched *ReflexScheduler) Reregistered(driver sched.SchedulerDriver, masterInfo *mesos.MasterInfo)
  • func (sched *ReflexScheduler) ResourceOffers(driver sched.SchedulerDriver, offers []*mesos.Offer)
  • func (sched *ReflexScheduler) SlaveLost(sched.SchedulerDriver, *mesos.SlaveID)
  • func (sched *ReflexScheduler) StatusUpdate(driver sched.SchedulerDriver, status *mesos.TaskStatus)
  • func (sched *ReflexScheduler) Stop()

Types

type ReflexScheduler

type ReflexScheduler struct {
	In  chan *state.IOPair
	Out chan *state.Event
	// contains filtered or unexported fields
}

func NewScheduler

func NewScheduler(exec *mesos.ExecutorInfo) *ReflexScheduler

func (*ReflexScheduler) Disconnected

func (sched *ReflexScheduler) Disconnected(sched.SchedulerDriver)

func (*ReflexScheduler) Error

func (sched *ReflexScheduler) Error(driver sched.SchedulerDriver, err string)

func (*ReflexScheduler) ExecutorLost

func (sched *ReflexScheduler) ExecutorLost(sched.SchedulerDriver, *mesos.ExecutorID, *mesos.SlaveID, int)

func (*ReflexScheduler) FrameworkMessage

func (sched *ReflexScheduler) FrameworkMessage(sched.SchedulerDriver, *mesos.ExecutorID, *mesos.SlaveID, string)

func (*ReflexScheduler) OfferRescinded

func (sched *ReflexScheduler) OfferRescinded(sched.SchedulerDriver, *mesos.OfferID)

func (*ReflexScheduler) Registered

func (sched *ReflexScheduler) Registered(driver sched.SchedulerDriver, frameworkId *mesos.FrameworkID, masterInfo *mesos.MasterInfo)

func (*ReflexScheduler) Reregistered

func (sched *ReflexScheduler) Reregistered(driver sched.SchedulerDriver, masterInfo *mesos.MasterInfo)

func (*ReflexScheduler) ResourceOffers

func (sched *ReflexScheduler) ResourceOffers(driver sched.SchedulerDriver, offers []*mesos.Offer)

func (*ReflexScheduler) SlaveLost

func (sched *ReflexScheduler) SlaveLost(sched.SchedulerDriver, *mesos.SlaveID)

func (*ReflexScheduler) StatusUpdate

func (sched *ReflexScheduler) StatusUpdate(driver sched.SchedulerDriver, status *mesos.TaskStatus)

func (*ReflexScheduler) Stop

func (sched *ReflexScheduler) Stop()