example_scheduler

Documentation

Index

• type ExampleScheduler
  • func (s *ExampleScheduler) Disconnected(scheduler.SchedulerDriver)
  • func (sched *ExampleScheduler) Error(driver scheduler.SchedulerDriver, err string)
  • func (sched *ExampleScheduler) ExecutorLost(s scheduler.SchedulerDriver, exId *mesosproto.ExecutorID, ...)
  • func (sched *ExampleScheduler) FrameworkMessage(s scheduler.SchedulerDriver, exId *mesosproto.ExecutorID, ...)
  • func (sched *ExampleScheduler) OfferRescinded(s scheduler.SchedulerDriver, id *mesosproto.OfferID)
  • func (s *ExampleScheduler) Registered(driver scheduler.SchedulerDriver, frameworkId *mesosproto.FrameworkID, ...)
  • func (s *ExampleScheduler) Reregistered(driver scheduler.SchedulerDriver, masterInfo *mesosproto.MasterInfo)
  • func (s *ExampleScheduler) ResourceOffers(driver scheduler.SchedulerDriver, offers []*mesosproto.Offer)
  • func (sched *ExampleScheduler) SlaveLost(s scheduler.SchedulerDriver, id *mesosproto.SlaveID)
  • func (s *ExampleScheduler) StatusUpdate(driver scheduler.SchedulerDriver, status *mesosproto.TaskStatus)

Types

type ExampleScheduler

type ExampleScheduler struct {
	ExecutorInfo *mesosproto.ExecutorInfo

	//The CPUs that the tasks need
	NeededCpu float64

	//The RAM that the tasks need
	NeededRam float64
	// contains filtered or unexported fields
}

func (*ExampleScheduler) Disconnected

func (s *ExampleScheduler) Disconnected(scheduler.SchedulerDriver)

func (*ExampleScheduler) Error

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

func (*ExampleScheduler) ExecutorLost

func (sched *ExampleScheduler) ExecutorLost(s scheduler.SchedulerDriver, exId *mesosproto.ExecutorID, slvId *mesosproto.SlaveID, i int)

func (*ExampleScheduler) FrameworkMessage

func (sched *ExampleScheduler) FrameworkMessage(s scheduler.SchedulerDriver, exId *mesosproto.ExecutorID, slvId *mesosproto.SlaveID, msg string)

func (*ExampleScheduler) OfferRescinded

func (sched *ExampleScheduler) OfferRescinded(s scheduler.SchedulerDriver, id *mesosproto.OfferID)

func (*ExampleScheduler) Registered

func (s *ExampleScheduler) Registered(driver scheduler.SchedulerDriver, frameworkId *mesosproto.FrameworkID, masterInfo *mesosproto.MasterInfo)

func (*ExampleScheduler) Reregistered

func (s *ExampleScheduler) Reregistered(driver scheduler.SchedulerDriver, masterInfo *mesosproto.MasterInfo)

func (*ExampleScheduler) ResourceOffers

func (s *ExampleScheduler) ResourceOffers(driver scheduler.SchedulerDriver, offers []*mesosproto.Offer)

ResourceOffers will be called by the Mesos framework to provide an array of offers to this framework. Is up to you to check the content of the offers and to accept or reject them if they don't fit the needs of the framework

func (*ExampleScheduler) SlaveLost

func (sched *ExampleScheduler) SlaveLost(s scheduler.SchedulerDriver, id *mesosproto.SlaveID)

func (*ExampleScheduler) StatusUpdate

func (s *ExampleScheduler) StatusUpdate(driver scheduler.SchedulerDriver, status *mesosproto.TaskStatus)

StatusUpdate is called by a running task to provide status information to the scheduler.