package ha

import "k8s.io/kubernetes/contrib/mesos/pkg/scheduler/ha"

Package ha encapsulates high-availability scheduler concerns.

Index ¶

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

Source Files ¶

doc.go election.go ha.go