Documentation ¶
Index ¶
- type LRPBBS
- func (bbs *LRPBBS) ChangeDesiredLRP(change models.DesiredLRPChange) error
- func (bbs *LRPBBS) ConvergeLRPs()
- func (bbs *LRPBBS) DesireLRP(lrp models.DesiredLRP) error
- func (bbs *LRPBBS) GetActualLRPsByProcessGuid(processGuid string) ([]models.ActualLRP, error)
- func (bbs *LRPBBS) GetAllActualLRPs() ([]models.ActualLRP, error)
- func (bbs *LRPBBS) GetAllDesiredLRPs() ([]models.DesiredLRP, error)
- func (bbs *LRPBBS) GetAllStopLRPInstances() ([]models.StopLRPInstance, error)
- func (bbs *LRPBBS) GetDesiredLRPByProcessGuid(processGuid string) (models.DesiredLRP, error)
- func (bbs *LRPBBS) GetRunningActualLRPs() ([]models.ActualLRP, error)
- func (bbs *LRPBBS) GetRunningActualLRPsByProcessGuid(processGuid string) ([]models.ActualLRP, error)
- func (bbs *LRPBBS) RemoveActualLRP(lrp models.ActualLRP) error
- func (bbs *LRPBBS) RemoveActualLRPForIndex(processGuid string, index int, instanceGuid string) error
- func (bbs *LRPBBS) RemoveDesiredLRPByProcessGuid(processGuid string) error
- func (bbs *LRPBBS) ReportActualLRPAsRunning(lrp models.ActualLRP, executorID string) error
- func (bbs *LRPBBS) ReportActualLRPAsStarting(lrp models.ActualLRP, executorID string) error
- func (bbs *LRPBBS) RequestStopLRPInstance(stopInstance models.StopLRPInstance) error
- func (bbs *LRPBBS) RequestStopLRPInstances(stopInstances []models.StopLRPInstance) error
- func (bbs *LRPBBS) ResolveStopLRPInstance(stopInstance models.StopLRPInstance) error
- func (bbs *LRPBBS) WatchForActualLRPChanges() (<-chan models.ActualLRPChange, chan<- bool, <-chan error)
- func (bbs *LRPBBS) WatchForDesiredLRPChanges() (<-chan models.DesiredLRPChange, chan<- bool, <-chan error)
- func (bbs *LRPBBS) WatchForStopLRPInstance() (<-chan models.StopLRPInstance, chan<- bool, <-chan error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type LRPBBS ¶
type LRPBBS struct {
// contains filtered or unexported fields
}
func New ¶
func New(store storeadapter.StoreAdapter, timeProvider timeprovider.TimeProvider, logger lager.Logger) *LRPBBS
func (*LRPBBS) ChangeDesiredLRP ¶
func (bbs *LRPBBS) ChangeDesiredLRP(change models.DesiredLRPChange) error
func (*LRPBBS) ConvergeLRPs ¶
func (bbs *LRPBBS) ConvergeLRPs()
func (*LRPBBS) GetActualLRPsByProcessGuid ¶
func (*LRPBBS) GetAllDesiredLRPs ¶
func (bbs *LRPBBS) GetAllDesiredLRPs() ([]models.DesiredLRP, error)
func (*LRPBBS) GetAllStopLRPInstances ¶
func (bbs *LRPBBS) GetAllStopLRPInstances() ([]models.StopLRPInstance, error)
func (*LRPBBS) GetDesiredLRPByProcessGuid ¶
func (bbs *LRPBBS) GetDesiredLRPByProcessGuid(processGuid string) (models.DesiredLRP, error)
func (*LRPBBS) GetRunningActualLRPs ¶
func (*LRPBBS) GetRunningActualLRPsByProcessGuid ¶
func (*LRPBBS) RemoveActualLRPForIndex ¶
func (*LRPBBS) RemoveDesiredLRPByProcessGuid ¶
func (*LRPBBS) ReportActualLRPAsRunning ¶
func (*LRPBBS) ReportActualLRPAsStarting ¶
func (*LRPBBS) RequestStopLRPInstance ¶
func (bbs *LRPBBS) RequestStopLRPInstance(stopInstance models.StopLRPInstance) error
func (*LRPBBS) RequestStopLRPInstances ¶
func (bbs *LRPBBS) RequestStopLRPInstances(stopInstances []models.StopLRPInstance) error
func (*LRPBBS) ResolveStopLRPInstance ¶
func (bbs *LRPBBS) ResolveStopLRPInstance(stopInstance models.StopLRPInstance) error
func (*LRPBBS) WatchForActualLRPChanges ¶
func (bbs *LRPBBS) WatchForActualLRPChanges() (<-chan models.ActualLRPChange, chan<- bool, <-chan error)
func (*LRPBBS) WatchForDesiredLRPChanges ¶
func (bbs *LRPBBS) WatchForDesiredLRPChanges() (<-chan models.DesiredLRPChange, chan<- bool, <-chan error)
func (*LRPBBS) WatchForStopLRPInstance ¶
func (bbs *LRPBBS) WatchForStopLRPInstance() (<-chan models.StopLRPInstance, chan<- bool, <-chan error)
Click to show internal directories.
Click to hide internal directories.