ha

package

v1.0.2 Latest Latest Go to latest Published: Aug 1, 2015 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Package ha encapsulates high-availability scheduler concerns.

This section is empty.

This section is empty.

func NewCandidate(s *SchedulerProcess, f DriverFactory, v ValidationFunc) election.Service

type DriverFactory func() (bindings.SchedulerDriver, error)

type SchedulerProcess struct {
	proc.Process
	bindings.Scheduler
	// contains filtered or unexported fields
}

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, m string)

func (self *SchedulerProcess) Master() proc.Process

returns a Process instance that will only execute a proc.Action if the scheduler is the elected master

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)