bbs

Documentation

Index

• Constants
• type AuctioneerBBS
  • func NewAuctioneerBBS(store storeadapter.StoreAdapter, consul *consuladapter.Session, ...) AuctioneerBBS
• type BBS
  • func NewBBS(store storeadapter.StoreAdapter, consul *consuladapter.Session, ...) *BBS
• type ConvergerBBS
  • func NewConvergerBBS(store storeadapter.StoreAdapter, consul *consuladapter.Session, ...) ConvergerBBS
• type MetricsBBS
  • func NewMetricsBBS(consul *consuladapter.Session, clock clock.Clock, logger lager.Logger) MetricsBBS
• type NsyncBBS
  • func NewNsyncBBS(consul *consuladapter.Session, clock clock.Clock, logger lager.Logger) NsyncBBS
• type ReceptorBBS
  • func NewReceptorBBS(store storeadapter.StoreAdapter, consul *consuladapter.Session, ...) ReceptorBBS
• type RepBBS
  • func NewRepBBS(store storeadapter.StoreAdapter, consul *consuladapter.Session, ...) RepBBS
• type RouteEmitterBBS
  • func NewRouteEmitterBBS(consul *consuladapter.Session, clock clock.Clock, logger lager.Logger) RouteEmitterBBS
• type TpsBBS
  • func NewTpsBBS(consul *consuladapter.Session, clock clock.Clock, logger lager.Logger) TpsBBS
• type VeritasBBS
  • func NewVeritasBBS(store storeadapter.StoreAdapter, consul *consuladapter.Session, ...) VeritasBBS

Constants

const ConvergerBBSWorkPoolSize = 50

Types

type AuctioneerBBS

type AuctioneerBBS interface {
	//services
	Cells() ([]models.CellPresence, error)

	// task
	FailTask(logger lager.Logger, taskGuid string, failureReason string) error

	//lock
	NewAuctioneerLock(auctioneerPresence models.AuctioneerPresence, retryInterval time.Duration) (ifrit.Runner, error)
}

func NewAuctioneerBBS

func NewAuctioneerBBS(store storeadapter.StoreAdapter, consul *consuladapter.Session, receptorTaskHandlerURL string, clock clock.Clock, logger lager.Logger) AuctioneerBBS

type BBS

type BBS struct {
	*lock_bbs.LockBBS
	*lrp_bbs.LRPBBS
	*services_bbs.ServicesBBS
	*task_bbs.TaskBBS
}

func NewBBS

func NewBBS(store storeadapter.StoreAdapter, consul *consuladapter.Session, receptorTaskHandlerURL string, clock clock.Clock, logger lager.Logger) *BBS

type ConvergerBBS

type ConvergerBBS interface {
	//lock
	NewConvergeLock(convergerID string, retryInterval time.Duration) ifrit.Runner

	//lrp
	ConvergeLRPs(logger lager.Logger, cellsLoader *services_bbs.CellsLoader)

	//task
	ConvergeTasks(logger lager.Logger, timeToClaim, convergenceInterval, timeToResolve time.Duration, cellsLoader *services_bbs.CellsLoader)

	//cell loader
	NewCellsLoader() *services_bbs.CellsLoader

	//cells
	CellEvents() <-chan services_bbs.CellEvent
}

func NewConvergerBBS

func NewConvergerBBS(store storeadapter.StoreAdapter, consul *consuladapter.Session, receptorTaskHandlerURL string, clock clock.Clock, logger lager.Logger) ConvergerBBS

type MetricsBBS

type MetricsBBS interface {
	//lock
	NewRuntimeMetricsLock(runtimeMetricsID string, retryInterval time.Duration) ifrit.Runner
}

func NewMetricsBBS

func NewMetricsBBS(consul *consuladapter.Session, clock clock.Clock, logger lager.Logger) MetricsBBS

type NsyncBBS

type NsyncBBS interface {
	//lock
	NewNsyncBulkerLock(bulkerID string, retryInterval time.Duration) ifrit.Runner
}

func NewNsyncBBS

func NewNsyncBBS(consul *consuladapter.Session, clock clock.Clock, logger lager.Logger) NsyncBBS

type ReceptorBBS

type ReceptorBBS interface {
	//task
	DesireTask(lager.Logger, models.Task) error
	Tasks(logger lager.Logger) ([]models.Task, error)
	TasksByDomain(logger lager.Logger, domain string) ([]models.Task, error)
	TaskByGuid(logger lager.Logger, taskGuid string) (models.Task, error)
	ResolvingTask(logger lager.Logger, taskGuid string) error
	ResolveTask(logger lager.Logger, taskGuid string) error
	CancelTask(logger lager.Logger, taskGuid string) error

	//desired lrp
	DesireLRP(lager.Logger, models.DesiredLRP) error
	UpdateDesiredLRP(logger lager.Logger, processGuid string, update models.DesiredLRPUpdate) error
	RemoveDesiredLRPByProcessGuid(logger lager.Logger, processGuid string) error

	//actual lrp
	RetireActualLRPs(lager.Logger, []models.ActualLRPKey)

	// cells
	Cells() ([]models.CellPresence, error)
}

func NewReceptorBBS

func NewReceptorBBS(store storeadapter.StoreAdapter, consul *consuladapter.Session, receptorTaskHandlerURL string, clock clock.Clock, logger lager.Logger) ReceptorBBS

type RepBBS

type RepBBS interface {
	//services
	NewCellPresence(cellPresence models.CellPresence, retryInterval time.Duration) ifrit.Runner

	//task
	StartTask(logger lager.Logger, taskGuid string, cellID string) (bool, error)
	TaskByGuid(logger lager.Logger, taskGuid string) (models.Task, error)
	TasksByCellID(logger lager.Logger, cellID string) ([]models.Task, error)
	FailTask(logger lager.Logger, taskGuid string, failureReason string) error
	CompleteTask(logger lager.Logger, taskGuid string, cellID string, failed bool, failureReason string, result string) error

	//lrp
	CrashActualLRP(lager.Logger, models.ActualLRPKey, models.ActualLRPInstanceKey, string) error

	// LRP evacuation
	EvacuateClaimedActualLRP(lager.Logger, models.ActualLRPKey, models.ActualLRPInstanceKey) (shared.ContainerRetainment, error)
	EvacuateRunningActualLRP(lager.Logger, models.ActualLRPKey, models.ActualLRPInstanceKey, models.ActualLRPNetInfo, uint64) (shared.ContainerRetainment, error)
	EvacuateStoppedActualLRP(lager.Logger, models.ActualLRPKey, models.ActualLRPInstanceKey) (shared.ContainerRetainment, error)
	EvacuateCrashedActualLRP(lager.Logger, models.ActualLRPKey, models.ActualLRPInstanceKey, string) (shared.ContainerRetainment, error)
	RemoveEvacuatingActualLRP(lager.Logger, models.ActualLRPKey, models.ActualLRPInstanceKey) error
}

func NewRepBBS

func NewRepBBS(store storeadapter.StoreAdapter, consul *consuladapter.Session, receptorTaskHandlerURL string, clock clock.Clock, logger lager.Logger) RepBBS

type RouteEmitterBBS

type RouteEmitterBBS interface {
	//lock
	NewRouteEmitterLock(emitterID string, retryInterval time.Duration) ifrit.Runner
}

func NewRouteEmitterBBS

func NewRouteEmitterBBS(consul *consuladapter.Session, clock clock.Clock, logger lager.Logger) RouteEmitterBBS

type TpsBBS

type TpsBBS interface {
	//lock
	NewTpsWatcherLock(watcherID string, retryInterval time.Duration) ifrit.Runner
}

func NewTpsBBS

func NewTpsBBS(consul *consuladapter.Session, clock clock.Clock, logger lager.Logger) TpsBBS

type VeritasBBS

type VeritasBBS interface {
	//task
	Tasks(logger lager.Logger) ([]models.Task, error)

	//lrp
	DesireLRP(lager.Logger, models.DesiredLRP) error
	RemoveDesiredLRPByProcessGuid(logger lager.Logger, guid string) error

	//services
	Cells() ([]models.CellPresence, error)
	AuctioneerAddress() (string, error)
}

func NewVeritasBBS

func NewVeritasBBS(store storeadapter.StoreAdapter, consul *consuladapter.Session, clock clock.Clock, logger lager.Logger) VeritasBBS