bbs

Documentation

Index

• type AppManagerBBS
  • func NewAppManagerBBS(store storeadapter.StoreAdapter, timeProvider timeprovider.TimeProvider, ...) AppManagerBBS
• type AuctioneerBBS
  • func NewAuctioneerBBS(store storeadapter.StoreAdapter, timeProvider timeprovider.TimeProvider, ...) AuctioneerBBS
• type BBS
  • func NewBBS(store storeadapter.StoreAdapter, timeProvider timeprovider.TimeProvider, ...) *BBS
• type ConvergerBBS
  • func NewConvergerBBS(store storeadapter.StoreAdapter, timeProvider timeprovider.TimeProvider, ...) ConvergerBBS
• type FileServerBBS
  • func NewFileServerBBS(store storeadapter.StoreAdapter, timeProvider timeprovider.TimeProvider, ...) FileServerBBS
• type MetricsBBS
  • func NewMetricsBBS(store storeadapter.StoreAdapter, timeProvider timeprovider.TimeProvider, ...) MetricsBBS
• type NsyncBBS
  • func NewNsyncBBS(store storeadapter.StoreAdapter, timeProvider timeprovider.TimeProvider, ...) NsyncBBS
• type RepBBS
  • func NewRepBBS(store storeadapter.StoreAdapter, timeProvider timeprovider.TimeProvider, ...) RepBBS
• type RouteEmitterBBS
  • func NewRouteEmitterBBS(store storeadapter.StoreAdapter, timeProvider timeprovider.TimeProvider, ...) RouteEmitterBBS
• type StagerBBS
  • func NewStagerBBS(store storeadapter.StoreAdapter, timeProvider timeprovider.TimeProvider, ...) StagerBBS
• type TPSBBS
  • func NewTPSBBS(store storeadapter.StoreAdapter, timeProvider timeprovider.TimeProvider, ...) TPSBBS

Types

type AppManagerBBS

type AppManagerBBS interface {
	//lrp
	GetActualLRPsByProcessGuid(string) ([]models.ActualLRP, error)
	RequestStopLRPInstance(stopInstance models.StopLRPInstance) error
	WatchForDesiredLRPChanges() (<-chan models.DesiredLRPChange, chan<- bool, <-chan error)

	//start auction
	RequestLRPStartAuction(models.LRPStartAuction) error

	//stop auction
	RequestLRPStopAuction(models.LRPStopAuction) error

	//services
	GetAvailableFileServer() (string, error)
}

func NewAppManagerBBS

func NewAppManagerBBS(store storeadapter.StoreAdapter, timeProvider timeprovider.TimeProvider, logger lager.Logger) AppManagerBBS

type AuctioneerBBS

type AuctioneerBBS interface {
	//services
	GetAllExecutors() ([]models.ExecutorPresence, error)

	//start auction
	WatchForLRPStartAuction() (<-chan models.LRPStartAuction, chan<- bool, <-chan error)
	ClaimLRPStartAuction(models.LRPStartAuction) error
	ResolveLRPStartAuction(models.LRPStartAuction) error

	//stop auction
	WatchForLRPStopAuction() (<-chan models.LRPStopAuction, chan<- bool, <-chan error)
	ClaimLRPStopAuction(models.LRPStopAuction) error
	ResolveLRPStopAuction(models.LRPStopAuction) error

	//lock
	MaintainAuctioneerLock(interval time.Duration, auctioneerID string) (<-chan bool, chan<- chan bool, error)
}

func NewAuctioneerBBS

func NewAuctioneerBBS(store storeadapter.StoreAdapter, timeProvider timeprovider.TimeProvider, logger lager.Logger) AuctioneerBBS

type BBS

type BBS struct {
	*lock_bbs.LockBBS
	*lrp_bbs.LRPBBS
	*start_auction_bbs.StartAuctionBBS
	*stop_auction_bbs.StopAuctionBBS
	*services_bbs.ServicesBBS
	*task_bbs.TaskBBS
}

func NewBBS

func NewBBS(store storeadapter.StoreAdapter, timeProvider timeprovider.TimeProvider, logger lager.Logger) *BBS

type ConvergerBBS

type ConvergerBBS interface {
	//lrp
	ConvergeLRPs()

	//start auction
	ConvergeLRPStartAuctions(kickPendingDuration time.Duration, expireClaimedDuration time.Duration)

	//stop auction
	ConvergeLRPStopAuctions(kickPendingDuration time.Duration, expireClaimedDuration time.Duration)

	//task
	ConvergeTask(timeToClaim time.Duration, converganceInterval time.Duration)

	//lock
	MaintainConvergeLock(interval time.Duration, executorID string) (disappeared <-chan bool, stop chan<- chan bool, err error)
}

func NewConvergerBBS

func NewConvergerBBS(store storeadapter.StoreAdapter, timeProvider timeprovider.TimeProvider, logger lager.Logger) ConvergerBBS

type FileServerBBS

type FileServerBBS interface {
	//services
	MaintainFileServerPresence(
		heartbeatInterval time.Duration,
		fileServerURL string,
		fileServerId string,
	) (presence services_bbs.Presence, disappeared <-chan bool, err error)
}

func NewFileServerBBS

func NewFileServerBBS(store storeadapter.StoreAdapter, timeProvider timeprovider.TimeProvider, logger lager.Logger) FileServerBBS

type MetricsBBS

type MetricsBBS interface {
	//task
	GetAllTasks() ([]models.Task, error)

	//services
	GetServiceRegistrations() (models.ServiceRegistrations, error)
}

func NewMetricsBBS

func NewMetricsBBS(store storeadapter.StoreAdapter, timeProvider timeprovider.TimeProvider, logger lager.Logger) MetricsBBS

type NsyncBBS

type NsyncBBS interface {
	// lrp
	DesireLRP(models.DesiredLRP) error
	RemoveDesiredLRPByProcessGuid(guid string) error
	GetAllDesiredLRPs() ([]models.DesiredLRP, error)
	ChangeDesiredLRP(change models.DesiredLRPChange) error
}

func NewNsyncBBS

func NewNsyncBBS(store storeadapter.StoreAdapter, timeProvider timeprovider.TimeProvider, logger lager.Logger) NsyncBBS

type RepBBS

type RepBBS interface {
	//services
	MaintainExecutorPresence(heartbeatInterval time.Duration, executorPresence models.ExecutorPresence) (services_bbs.Presence, <-chan bool, error)

	//task
	WatchForDesiredTask() (<-chan models.Task, chan<- bool, <-chan error)
	ClaimTask(taskGuid string, executorID string) error
	StartTask(taskGuid string, executorID string, containerHandle string) error
	CompleteTask(taskGuid string, failed bool, failureReason string, result string) error

	///lrp
	ReportActualLRPAsStarting(lrp models.ActualLRP, executorID string) error
	ReportActualLRPAsRunning(lrp models.ActualLRP, executorId string) error
	RemoveActualLRP(lrp models.ActualLRP) error
	RemoveActualLRPForIndex(processGuid string, index int, instanceGuid string) error
	WatchForStopLRPInstance() (<-chan models.StopLRPInstance, chan<- bool, <-chan error)
	ResolveStopLRPInstance(stopInstance models.StopLRPInstance) error
}

func NewRepBBS

func NewRepBBS(store storeadapter.StoreAdapter, timeProvider timeprovider.TimeProvider, logger lager.Logger) RepBBS

type RouteEmitterBBS

type RouteEmitterBBS interface {
	// lrp
	WatchForDesiredLRPChanges() (<-chan models.DesiredLRPChange, chan<- bool, <-chan error)
	WatchForActualLRPChanges() (<-chan models.ActualLRPChange, chan<- bool, <-chan error)
	GetAllDesiredLRPs() ([]models.DesiredLRP, error)
	GetRunningActualLRPs() ([]models.ActualLRP, error)
	GetDesiredLRPByProcessGuid(processGuid string) (models.DesiredLRP, error)
	GetRunningActualLRPsByProcessGuid(processGuid string) ([]models.ActualLRP, error)
}

func NewRouteEmitterBBS

func NewRouteEmitterBBS(store storeadapter.StoreAdapter, timeProvider timeprovider.TimeProvider, logger lager.Logger) RouteEmitterBBS

type StagerBBS

type StagerBBS interface {
	//task
	WatchForCompletedTask() (<-chan models.Task, chan<- bool, <-chan error)
	DesireTask(models.Task) error
	ResolvingTask(taskGuid string) error
	ResolveTask(taskGuid string) error

	//services
	GetAvailableFileServer() (string, error)
}

func NewStagerBBS

func NewStagerBBS(store storeadapter.StoreAdapter, timeProvider timeprovider.TimeProvider, logger lager.Logger) StagerBBS

type TPSBBS

type TPSBBS interface {
	//lrp
	GetActualLRPsByProcessGuid(string) ([]models.ActualLRP, error)
}

func NewTPSBBS

func NewTPSBBS(store storeadapter.StoreAdapter, timeProvider timeprovider.TimeProvider, logger lager.Logger) TPSBBS