Versions in this module Expand all Collapse all v0 v0.20.0 Jun 24, 2015 Changes in this version + func NewCandidate(s *SchedulerProcess, f DriverFactory, v ValidationFunc) election.Service + type DriverFactory func() (bindings.SchedulerDriver, error) + type SchedulerProcess struct + func New(sched bindings.Scheduler) *SchedulerProcess + func (self *SchedulerProcess) Disconnected(drv bindings.SchedulerDriver) + func (self *SchedulerProcess) Elect(newDriver DriverFactory) + func (self *SchedulerProcess) Elected() <-chan struct{} + func (self *SchedulerProcess) End() <-chan struct{} + func (self *SchedulerProcess) Error(drv bindings.SchedulerDriver, msg string) + func (self *SchedulerProcess) ExecutorLost(drv bindings.SchedulerDriver, eid *mesos.ExecutorID, sid *mesos.SlaveID, x int) + func (self *SchedulerProcess) Failover() <-chan struct{} + func (self *SchedulerProcess) FrameworkMessage(drv bindings.SchedulerDriver, eid *mesos.ExecutorID, sid *mesos.SlaveID, ...) + func (self *SchedulerProcess) Master() proc.Process + func (self *SchedulerProcess) OfferRescinded(drv bindings.SchedulerDriver, oid *mesos.OfferID) + func (self *SchedulerProcess) Registered(drv bindings.SchedulerDriver, fid *mesos.FrameworkID, mi *mesos.MasterInfo) + func (self *SchedulerProcess) Reregistered(drv bindings.SchedulerDriver, mi *mesos.MasterInfo) + func (self *SchedulerProcess) ResourceOffers(drv bindings.SchedulerDriver, off []*mesos.Offer) + func (self *SchedulerProcess) SlaveLost(drv bindings.SchedulerDriver, sid *mesos.SlaveID) + func (self *SchedulerProcess) StatusUpdate(drv bindings.SchedulerDriver, ts *mesos.TaskStatus) + func (self *SchedulerProcess) Terminal() <-chan struct{} + type ValidationFunc func(desiredUid, currentUid string)