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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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.
Source Files
Click to show internal directories.
Click to hide internal directories.