ha

package
v1.1.5-beta.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 8, 2016 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Overview

Package ha encapsulates high-availability scheduler concerns.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL