ha

Documentation

Overview

Package ha encapsulates high-availability scheduler concerns.

Index

• func NewCandidate(s *SchedulerProcess, f DriverFactory, v ValidationFunc) election.Service
• type DriverFactory
• type SchedulerProcess
  • func New(framework 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

Functions

func NewCandidate

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

Types

type DriverFactory

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

type SchedulerProcess

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

func New

func New(framework bindings.Scheduler) *SchedulerProcess

func (*SchedulerProcess) Disconnected

func (self *SchedulerProcess) Disconnected(drv bindings.SchedulerDriver)

func (*SchedulerProcess) Elect

func (self *SchedulerProcess) Elect(newDriver DriverFactory)

func (*SchedulerProcess) Elected

func (self *SchedulerProcess) Elected() <-chan struct{}

func (*SchedulerProcess) End

func (self *SchedulerProcess) End() <-chan struct{}

func (*SchedulerProcess) Error

func (self *SchedulerProcess) Error(drv bindings.SchedulerDriver, msg string)

func (*SchedulerProcess) ExecutorLost

func (self *SchedulerProcess) ExecutorLost(drv bindings.SchedulerDriver, eid *mesos.ExecutorID, sid *mesos.SlaveID, x int)

func (*SchedulerProcess) Failover

func (self *SchedulerProcess) Failover() <-chan struct{}

func (*SchedulerProcess) FrameworkMessage

func (self *SchedulerProcess) FrameworkMessage(drv bindings.SchedulerDriver, eid *mesos.ExecutorID, sid *mesos.SlaveID, m string)

func (*SchedulerProcess) Master

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 (*SchedulerProcess) OfferRescinded

func (self *SchedulerProcess) OfferRescinded(drv bindings.SchedulerDriver, oid *mesos.OfferID)

func (*SchedulerProcess) Registered

func (self *SchedulerProcess) Registered(drv bindings.SchedulerDriver, fid *mesos.FrameworkID, mi *mesos.MasterInfo)

func (*SchedulerProcess) Reregistered

func (self *SchedulerProcess) Reregistered(drv bindings.SchedulerDriver, mi *mesos.MasterInfo)

func (*SchedulerProcess) ResourceOffers

func (self *SchedulerProcess) ResourceOffers(drv bindings.SchedulerDriver, off []*mesos.Offer)

func (*SchedulerProcess) SlaveLost

func (self *SchedulerProcess) SlaveLost(drv bindings.SchedulerDriver, sid *mesos.SlaveID)

func (*SchedulerProcess) StatusUpdate

func (self *SchedulerProcess) StatusUpdate(drv bindings.SchedulerDriver, ts *mesos.TaskStatus)

func (*SchedulerProcess) Terminal

func (self *SchedulerProcess) Terminal() <-chan struct{}

type ValidationFunc

type ValidationFunc func(desiredUid, currentUid string)