Documentation
¶
Overview ¶
This file was generated by counterfeiter
This file was generated by counterfeiter ¶
This file was generated by counterfeiter
Index ¶
- type FakeAppManagerBBS
- func (fakeBBS *FakeAppManagerBBS) DesireLRP(lrp models.DesiredLRP) error
- func (fakeBBS *FakeAppManagerBBS) DesiredLRPs() []models.DesiredLRP
- func (fakeBBS *FakeAppManagerBBS) GetActualLRPsByProcessGuid(string) ([]models.ActualLRP, error)
- func (fakeBBS *FakeAppManagerBBS) GetLRPStartAuctions() []models.LRPStartAuction
- func (fakeBBS *FakeAppManagerBBS) GetLRPStopAuctions() []models.LRPStopAuction
- func (fakeBBS *FakeAppManagerBBS) GetRemovedDesiredLRPProcessGuids() []string
- func (fakeBBS *FakeAppManagerBBS) GetStopLRPInstances() []models.StopLRPInstance
- func (fakeBBS *FakeAppManagerBBS) RemoveDesiredLRPByProcessGuid(processGuid string) error
- func (fakeBBS *FakeAppManagerBBS) RequestLRPStartAuction(lrp models.LRPStartAuction) error
- func (fakeBBS *FakeAppManagerBBS) RequestLRPStopAuction(lrp models.LRPStopAuction) error
- func (fakeBBS *FakeAppManagerBBS) RequestStopLRPInstance(lrp models.StopLRPInstance) error
- func (fakeBBS *FakeAppManagerBBS) WatchForDesiredLRPChanges() (<-chan models.DesiredLRPChange, chan<- bool, <-chan error)
- type FakeAuctioneerBBS
- func (bbs *FakeAuctioneerBBS) ClaimLRPStartAuction(auction models.LRPStartAuction) error
- func (bbs *FakeAuctioneerBBS) ClaimLRPStopAuction(auction models.LRPStopAuction) error
- func (bbs *FakeAuctioneerBBS) GetAllExecutors() ([]models.ExecutorPresence, error)
- func (bbs *FakeAuctioneerBBS) GetClaimedLRPStartAuctions() []models.LRPStartAuction
- func (bbs *FakeAuctioneerBBS) GetClaimedLRPStopAuctions() []models.LRPStopAuction
- func (bbs *FakeAuctioneerBBS) GetResolvedLRPStartAuction() models.LRPStartAuction
- func (bbs *FakeAuctioneerBBS) GetResolvedLRPStopAuction() models.LRPStopAuction
- func (bbs *FakeAuctioneerBBS) MaintainAuctioneerLock(interval time.Duration, auctioneerID string) (<-chan bool, chan<- chan bool, error)
- func (bbs *FakeAuctioneerBBS) ResolveLRPStartAuction(auction models.LRPStartAuction) error
- func (bbs *FakeAuctioneerBBS) ResolveLRPStopAuction(auction models.LRPStopAuction) error
- func (bbs *FakeAuctioneerBBS) WatchForLRPStartAuction() (<-chan models.LRPStartAuction, chan<- bool, <-chan error)
- func (bbs *FakeAuctioneerBBS) WatchForLRPStopAuction() (<-chan models.LRPStopAuction, chan<- bool, <-chan error)
- type FakeConvergerBBS
- func (fakeBBS *FakeConvergerBBS) CallsToConvergeLRPStartAuctions() int
- func (fakeBBS *FakeConvergerBBS) CallsToConvergeLRPStopAuctions() int
- func (fakeBBS *FakeConvergerBBS) CallsToConvergeLRPs() int
- func (fakeBBS *FakeConvergerBBS) CallsToConvergeTasks() int
- func (fakeBBS *FakeConvergerBBS) ConvergeLRPStartAuctions(kickPendingDuration time.Duration, expireClaimedDuration time.Duration)
- func (fakeBBS *FakeConvergerBBS) ConvergeLRPStopAuctions(kickPendingDuration time.Duration, expireClaimedDuration time.Duration)
- func (fakeBBS *FakeConvergerBBS) ConvergeLRPs()
- func (fakeBBS *FakeConvergerBBS) ConvergeTask(timeToClaim time.Duration, taskConvergenceInterval time.Duration)
- func (fakeBBS *FakeConvergerBBS) ConvergeTimeToClaimTasks() time.Duration
- func (fakeBBS *FakeConvergerBBS) MaintainConvergeLock(interval time.Duration, executorID string) (<-chan bool, chan<- chan bool, error)
- func (fakeBBS *FakeConvergerBBS) SetMaintainConvergeLockError(err error)
- type FakeMetricsBBS
- type FakeNsyncBBS
- func (fake *FakeNsyncBBS) ChangeDesiredLRP(arg1 models.DesiredLRPChange) error
- func (fake *FakeNsyncBBS) ChangeDesiredLRPArgsForCall(i int) models.DesiredLRPChange
- func (fake *FakeNsyncBBS) ChangeDesiredLRPCallCount() int
- func (fake *FakeNsyncBBS) ChangeDesiredLRPReturns(result1 error)
- func (fake *FakeNsyncBBS) DesireLRP(arg1 models.DesiredLRP) error
- func (fake *FakeNsyncBBS) DesireLRPArgsForCall(i int) models.DesiredLRP
- func (fake *FakeNsyncBBS) DesireLRPCallCount() int
- func (fake *FakeNsyncBBS) DesireLRPReturns(result1 error)
- func (fake *FakeNsyncBBS) GetAllDesiredLRPs() ([]models.DesiredLRP, error)
- func (fake *FakeNsyncBBS) GetAllDesiredLRPsCallCount() int
- func (fake *FakeNsyncBBS) GetAllDesiredLRPsReturns(result1 []models.DesiredLRP, result2 error)
- func (fake *FakeNsyncBBS) RemoveDesiredLRPByProcessGuid(arg1 string) error
- func (fake *FakeNsyncBBS) RemoveDesiredLRPByProcessGuidArgsForCall(i int) string
- func (fake *FakeNsyncBBS) RemoveDesiredLRPByProcessGuidCallCount() int
- func (fake *FakeNsyncBBS) RemoveDesiredLRPByProcessGuidReturns(result1 error)
- type FakePresence
- type FakeRepBBS
- func (fake *FakeRepBBS) ClaimTask(arg1 string, arg2 string) error
- func (fake *FakeRepBBS) ClaimTaskArgsForCall(i int) (string, string)
- func (fake *FakeRepBBS) ClaimTaskCallCount() int
- func (fake *FakeRepBBS) ClaimTaskReturns(result1 error)
- func (fake *FakeRepBBS) CompleteTask(arg1 string, arg2 bool, arg3 string, arg4 string) error
- func (fake *FakeRepBBS) CompleteTaskArgsForCall(i int) (string, bool, string, string)
- func (fake *FakeRepBBS) CompleteTaskCallCount() int
- func (fake *FakeRepBBS) CompleteTaskReturns(result1 error)
- func (fake *FakeRepBBS) MaintainExecutorPresence(arg1 time.Duration, arg2 models.ExecutorPresence) (services_bbs.Presence, <-chan bool, error)
- func (fake *FakeRepBBS) MaintainExecutorPresenceArgsForCall(i int) (time.Duration, models.ExecutorPresence)
- func (fake *FakeRepBBS) MaintainExecutorPresenceCallCount() int
- func (fake *FakeRepBBS) MaintainExecutorPresenceReturns(result1 services_bbs.Presence, result2 <-chan bool, result3 error)
- func (fake *FakeRepBBS) RemoveActualLRP(arg1 models.ActualLRP) error
- func (fake *FakeRepBBS) RemoveActualLRPArgsForCall(i int) models.ActualLRP
- func (fake *FakeRepBBS) RemoveActualLRPCallCount() int
- func (fake *FakeRepBBS) RemoveActualLRPReturns(result1 error)
- func (fake *FakeRepBBS) ReportActualLRPAsRunning(arg1 models.ActualLRP, arg2 string) error
- func (fake *FakeRepBBS) ReportActualLRPAsRunningArgsForCall(i int) (models.ActualLRP, string)
- func (fake *FakeRepBBS) ReportActualLRPAsRunningCallCount() int
- func (fake *FakeRepBBS) ReportActualLRPAsRunningReturns(result1 error)
- func (fake *FakeRepBBS) ReportActualLRPAsStarting(arg1 models.ActualLRP, arg2 string) error
- func (fake *FakeRepBBS) ReportActualLRPAsStartingArgsForCall(i int) (models.ActualLRP, string)
- func (fake *FakeRepBBS) ReportActualLRPAsStartingCallCount() int
- func (fake *FakeRepBBS) ReportActualLRPAsStartingReturns(result1 error)
- func (fake *FakeRepBBS) ResolveStopLRPInstance(arg1 models.StopLRPInstance) error
- func (fake *FakeRepBBS) ResolveStopLRPInstanceArgsForCall(i int) models.StopLRPInstance
- func (fake *FakeRepBBS) ResolveStopLRPInstanceCallCount() int
- func (fake *FakeRepBBS) ResolveStopLRPInstanceReturns(result1 error)
- func (fake *FakeRepBBS) StartTask(arg1 string, arg2 string, arg3 string) error
- func (fake *FakeRepBBS) StartTaskArgsForCall(i int) (string, string, string)
- func (fake *FakeRepBBS) StartTaskCallCount() int
- func (fake *FakeRepBBS) StartTaskReturns(result1 error)
- func (fake *FakeRepBBS) WatchForDesiredTask() (<-chan models.Task, chan<- bool, <-chan error)
- func (fake *FakeRepBBS) WatchForDesiredTaskCallCount() int
- func (fake *FakeRepBBS) WatchForDesiredTaskReturns(result1 <-chan models.Task, result2 chan<- bool, result3 <-chan error)
- func (fake *FakeRepBBS) WatchForStopLRPInstance() (<-chan models.StopLRPInstance, chan<- bool, <-chan error)
- func (fake *FakeRepBBS) WatchForStopLRPInstanceCallCount() int
- func (fake *FakeRepBBS) WatchForStopLRPInstanceReturns(result1 <-chan models.StopLRPInstance, result2 chan<- bool, ...)
- type FakeRouteEmitterBBS
- func (fakeBBS *FakeRouteEmitterBBS) GetAllDesiredLRPs() ([]models.DesiredLRP, error)
- func (fakeBBS *FakeRouteEmitterBBS) GetDesiredLRPByProcessGuid(processGuid string) (models.DesiredLRP, error)
- func (fakeBBS *FakeRouteEmitterBBS) GetRunningActualLRPs() ([]models.ActualLRP, error)
- func (fakeBBS *FakeRouteEmitterBBS) GetRunningActualLRPsByProcessGuid(processGuid string) ([]models.ActualLRP, error)
- func (fakeBBS *FakeRouteEmitterBBS) SendWatchForActualLRPChangesError(err error)
- func (fakeBBS *FakeRouteEmitterBBS) SendWatchForDesiredLRPChangesError(err error)
- func (fakeBBS *FakeRouteEmitterBBS) WatchForActualLRPChanges() (<-chan models.ActualLRPChange, chan<- bool, <-chan error)
- func (fakeBBS *FakeRouteEmitterBBS) WatchForDesiredLRPChanges() (<-chan models.DesiredLRPChange, chan<- bool, <-chan error)
- type FakeStagerBBS
- func (fake *FakeStagerBBS) DesireTask(arg1 models.Task) error
- func (fake *FakeStagerBBS) DesireTaskArgsForCall(i int) models.Task
- func (fake *FakeStagerBBS) DesireTaskCallCount() int
- func (fake *FakeStagerBBS) DesireTaskReturns(result1 error)
- func (fake *FakeStagerBBS) GetAvailableFileServer() (string, error)
- func (fake *FakeStagerBBS) GetAvailableFileServerCallCount() int
- func (fake *FakeStagerBBS) GetAvailableFileServerReturns(result1 string, result2 error)
- func (fake *FakeStagerBBS) ResolveTask(arg1 string) error
- func (fake *FakeStagerBBS) ResolveTaskArgsForCall(i int) string
- func (fake *FakeStagerBBS) ResolveTaskCallCount() int
- func (fake *FakeStagerBBS) ResolveTaskReturns(result1 error)
- func (fake *FakeStagerBBS) ResolvingTask(arg1 string) error
- func (fake *FakeStagerBBS) ResolvingTaskArgsForCall(i int) string
- func (fake *FakeStagerBBS) ResolvingTaskCallCount() int
- func (fake *FakeStagerBBS) ResolvingTaskReturns(result1 error)
- func (fake *FakeStagerBBS) WatchForCompletedTask() (<-chan models.Task, chan<- bool, <-chan error)
- func (fake *FakeStagerBBS) WatchForCompletedTaskCallCount() int
- func (fake *FakeStagerBBS) WatchForCompletedTaskReturns(result1 <-chan models.Task, result2 chan<- bool, result3 <-chan error)
- type FileServerGetter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FakeAppManagerBBS ¶
type FakeAppManagerBBS struct { FileServerGetter DesiredLRPChangeChan chan models.DesiredLRPChange DesiredLRPStopChan chan bool DesiredLRPErrChan chan error StopLRPInstanceErr error DesireLRPErr error ActualLRPs []models.ActualLRP ActualLRPsErr error LRPStartAuctionErr error WhenRequestingLRPStartAuctions func(lrp models.LRPStartAuction) error LRPStopAuctionErr error WhenRequestingLRPStopAuctions func(lrp models.LRPStopAuction) error sync.RWMutex // contains filtered or unexported fields }
func NewFakeAppManagerBBS ¶
func NewFakeAppManagerBBS() *FakeAppManagerBBS
func (*FakeAppManagerBBS) DesireLRP ¶
func (fakeBBS *FakeAppManagerBBS) DesireLRP(lrp models.DesiredLRP) error
func (*FakeAppManagerBBS) DesiredLRPs ¶
func (fakeBBS *FakeAppManagerBBS) DesiredLRPs() []models.DesiredLRP
func (*FakeAppManagerBBS) GetActualLRPsByProcessGuid ¶
func (fakeBBS *FakeAppManagerBBS) GetActualLRPsByProcessGuid(string) ([]models.ActualLRP, error)
func (*FakeAppManagerBBS) GetLRPStartAuctions ¶
func (fakeBBS *FakeAppManagerBBS) GetLRPStartAuctions() []models.LRPStartAuction
func (*FakeAppManagerBBS) GetLRPStopAuctions ¶
func (fakeBBS *FakeAppManagerBBS) GetLRPStopAuctions() []models.LRPStopAuction
func (*FakeAppManagerBBS) GetRemovedDesiredLRPProcessGuids ¶
func (fakeBBS *FakeAppManagerBBS) GetRemovedDesiredLRPProcessGuids() []string
func (*FakeAppManagerBBS) GetStopLRPInstances ¶
func (fakeBBS *FakeAppManagerBBS) GetStopLRPInstances() []models.StopLRPInstance
func (*FakeAppManagerBBS) RemoveDesiredLRPByProcessGuid ¶
func (fakeBBS *FakeAppManagerBBS) RemoveDesiredLRPByProcessGuid(processGuid string) error
func (*FakeAppManagerBBS) RequestLRPStartAuction ¶
func (fakeBBS *FakeAppManagerBBS) RequestLRPStartAuction(lrp models.LRPStartAuction) error
func (*FakeAppManagerBBS) RequestLRPStopAuction ¶
func (fakeBBS *FakeAppManagerBBS) RequestLRPStopAuction(lrp models.LRPStopAuction) error
func (*FakeAppManagerBBS) RequestStopLRPInstance ¶
func (fakeBBS *FakeAppManagerBBS) RequestStopLRPInstance(lrp models.StopLRPInstance) error
func (*FakeAppManagerBBS) WatchForDesiredLRPChanges ¶
func (fakeBBS *FakeAppManagerBBS) WatchForDesiredLRPChanges() (<-chan models.DesiredLRPChange, chan<- bool, <-chan error)
type FakeAuctioneerBBS ¶
type FakeAuctioneerBBS struct { *sync.Mutex LRPStartAuctionChan chan models.LRPStartAuction LRPStartAuctionStopChan chan bool LRPStartAuctionErrorChan chan error LRPStopAuctionChan chan models.LRPStopAuction LRPStopAuctionStopChan chan bool LRPStopAuctionErrorChan chan error LockChannel chan bool ReleaseLockChannel chan chan bool LockError error ClaimedLRPStartAuctions []models.LRPStartAuction ClaimLRPStartAuctionError error ResolvedLRPStartAuction models.LRPStartAuction ResolveLRPStartAuctionError error ClaimedLRPStopAuctions []models.LRPStopAuction ClaimLRPStopAuctionError error ResolvedLRPStopAuction models.LRPStopAuction ResolveLRPStopAuctionError error Executors []models.ExecutorPresence }
func NewFakeAuctioneerBBS ¶
func NewFakeAuctioneerBBS() *FakeAuctioneerBBS
func (*FakeAuctioneerBBS) ClaimLRPStartAuction ¶
func (bbs *FakeAuctioneerBBS) ClaimLRPStartAuction(auction models.LRPStartAuction) error
func (*FakeAuctioneerBBS) ClaimLRPStopAuction ¶
func (bbs *FakeAuctioneerBBS) ClaimLRPStopAuction(auction models.LRPStopAuction) error
func (*FakeAuctioneerBBS) GetAllExecutors ¶
func (bbs *FakeAuctioneerBBS) GetAllExecutors() ([]models.ExecutorPresence, error)
func (*FakeAuctioneerBBS) GetClaimedLRPStartAuctions ¶
func (bbs *FakeAuctioneerBBS) GetClaimedLRPStartAuctions() []models.LRPStartAuction
func (*FakeAuctioneerBBS) GetClaimedLRPStopAuctions ¶
func (bbs *FakeAuctioneerBBS) GetClaimedLRPStopAuctions() []models.LRPStopAuction
func (*FakeAuctioneerBBS) GetResolvedLRPStartAuction ¶
func (bbs *FakeAuctioneerBBS) GetResolvedLRPStartAuction() models.LRPStartAuction
func (*FakeAuctioneerBBS) GetResolvedLRPStopAuction ¶
func (bbs *FakeAuctioneerBBS) GetResolvedLRPStopAuction() models.LRPStopAuction
func (*FakeAuctioneerBBS) MaintainAuctioneerLock ¶
func (*FakeAuctioneerBBS) ResolveLRPStartAuction ¶
func (bbs *FakeAuctioneerBBS) ResolveLRPStartAuction(auction models.LRPStartAuction) error
func (*FakeAuctioneerBBS) ResolveLRPStopAuction ¶
func (bbs *FakeAuctioneerBBS) ResolveLRPStopAuction(auction models.LRPStopAuction) error
func (*FakeAuctioneerBBS) WatchForLRPStartAuction ¶
func (bbs *FakeAuctioneerBBS) WatchForLRPStartAuction() (<-chan models.LRPStartAuction, chan<- bool, <-chan error)
func (*FakeAuctioneerBBS) WatchForLRPStopAuction ¶
func (bbs *FakeAuctioneerBBS) WatchForLRPStopAuction() (<-chan models.LRPStopAuction, chan<- bool, <-chan error)
type FakeConvergerBBS ¶
type FakeConvergerBBS struct { ConvergeLockStatusChan chan bool ConvergeLockStopChan chan chan bool sync.RWMutex // contains filtered or unexported fields }
func NewFakeConvergerBBS ¶
func NewFakeConvergerBBS() *FakeConvergerBBS
func (*FakeConvergerBBS) CallsToConvergeLRPStartAuctions ¶
func (fakeBBS *FakeConvergerBBS) CallsToConvergeLRPStartAuctions() int
func (*FakeConvergerBBS) CallsToConvergeLRPStopAuctions ¶
func (fakeBBS *FakeConvergerBBS) CallsToConvergeLRPStopAuctions() int
func (*FakeConvergerBBS) CallsToConvergeLRPs ¶
func (fakeBBS *FakeConvergerBBS) CallsToConvergeLRPs() int
func (*FakeConvergerBBS) CallsToConvergeTasks ¶
func (fakeBBS *FakeConvergerBBS) CallsToConvergeTasks() int
func (*FakeConvergerBBS) ConvergeLRPStartAuctions ¶
func (fakeBBS *FakeConvergerBBS) ConvergeLRPStartAuctions(kickPendingDuration time.Duration, expireClaimedDuration time.Duration)
func (*FakeConvergerBBS) ConvergeLRPStopAuctions ¶
func (fakeBBS *FakeConvergerBBS) ConvergeLRPStopAuctions(kickPendingDuration time.Duration, expireClaimedDuration time.Duration)
func (*FakeConvergerBBS) ConvergeLRPs ¶
func (fakeBBS *FakeConvergerBBS) ConvergeLRPs()
func (*FakeConvergerBBS) ConvergeTask ¶
func (fakeBBS *FakeConvergerBBS) ConvergeTask(timeToClaim time.Duration, taskConvergenceInterval time.Duration)
func (*FakeConvergerBBS) ConvergeTimeToClaimTasks ¶
func (fakeBBS *FakeConvergerBBS) ConvergeTimeToClaimTasks() time.Duration
func (*FakeConvergerBBS) MaintainConvergeLock ¶
func (*FakeConvergerBBS) SetMaintainConvergeLockError ¶
func (fakeBBS *FakeConvergerBBS) SetMaintainConvergeLockError(err error)
type FakeMetricsBBS ¶
type FakeMetricsBBS struct { GetAllTasksReturns struct { Models []models.Task Err error } GetServiceRegistrationsReturns struct { Registrations models.ServiceRegistrations Err error } }
func NewFakeMetricsBBS ¶
func NewFakeMetricsBBS() *FakeMetricsBBS
func (*FakeMetricsBBS) GetAllTasks ¶
func (bbs *FakeMetricsBBS) GetAllTasks() ([]models.Task, error)
func (*FakeMetricsBBS) GetServiceRegistrations ¶
func (bbs *FakeMetricsBBS) GetServiceRegistrations() (models.ServiceRegistrations, error)
type FakeNsyncBBS ¶
type FakeNsyncBBS struct { DesireLRPStub func(models.DesiredLRP) error RemoveDesiredLRPByProcessGuidStub func(guid string) error GetAllDesiredLRPsStub func() ([]models.DesiredLRP, error) ChangeDesiredLRPStub func(change models.DesiredLRPChange) error // contains filtered or unexported fields }
func (*FakeNsyncBBS) ChangeDesiredLRP ¶
func (fake *FakeNsyncBBS) ChangeDesiredLRP(arg1 models.DesiredLRPChange) error
func (*FakeNsyncBBS) ChangeDesiredLRPArgsForCall ¶
func (fake *FakeNsyncBBS) ChangeDesiredLRPArgsForCall(i int) models.DesiredLRPChange
func (*FakeNsyncBBS) ChangeDesiredLRPCallCount ¶
func (fake *FakeNsyncBBS) ChangeDesiredLRPCallCount() int
func (*FakeNsyncBBS) ChangeDesiredLRPReturns ¶
func (fake *FakeNsyncBBS) ChangeDesiredLRPReturns(result1 error)
func (*FakeNsyncBBS) DesireLRP ¶
func (fake *FakeNsyncBBS) DesireLRP(arg1 models.DesiredLRP) error
func (*FakeNsyncBBS) DesireLRPArgsForCall ¶
func (fake *FakeNsyncBBS) DesireLRPArgsForCall(i int) models.DesiredLRP
func (*FakeNsyncBBS) DesireLRPCallCount ¶
func (fake *FakeNsyncBBS) DesireLRPCallCount() int
func (*FakeNsyncBBS) DesireLRPReturns ¶
func (fake *FakeNsyncBBS) DesireLRPReturns(result1 error)
func (*FakeNsyncBBS) GetAllDesiredLRPs ¶
func (fake *FakeNsyncBBS) GetAllDesiredLRPs() ([]models.DesiredLRP, error)
func (*FakeNsyncBBS) GetAllDesiredLRPsCallCount ¶
func (fake *FakeNsyncBBS) GetAllDesiredLRPsCallCount() int
func (*FakeNsyncBBS) GetAllDesiredLRPsReturns ¶
func (fake *FakeNsyncBBS) GetAllDesiredLRPsReturns(result1 []models.DesiredLRP, result2 error)
func (*FakeNsyncBBS) RemoveDesiredLRPByProcessGuid ¶
func (fake *FakeNsyncBBS) RemoveDesiredLRPByProcessGuid(arg1 string) error
func (*FakeNsyncBBS) RemoveDesiredLRPByProcessGuidArgsForCall ¶
func (fake *FakeNsyncBBS) RemoveDesiredLRPByProcessGuidArgsForCall(i int) string
func (*FakeNsyncBBS) RemoveDesiredLRPByProcessGuidCallCount ¶
func (fake *FakeNsyncBBS) RemoveDesiredLRPByProcessGuidCallCount() int
func (*FakeNsyncBBS) RemoveDesiredLRPByProcessGuidReturns ¶
func (fake *FakeNsyncBBS) RemoveDesiredLRPByProcessGuidReturns(result1 error)
type FakePresence ¶
type FakePresence struct { MaintainStatus bool Maintained bool Removed bool // contains filtered or unexported fields }
func (*FakePresence) Maintain ¶
func (p *FakePresence) Maintain(interval time.Duration) (<-chan bool, error)
func (*FakePresence) Remove ¶
func (p *FakePresence) Remove()
type FakeRepBBS ¶
type FakeRepBBS struct { MaintainExecutorPresenceStub func(heartbeatInterval time.Duration, executorPresence models.ExecutorPresence) (services_bbs.Presence, <-chan bool, error) WatchForDesiredTaskStub func() (<-chan models.Task, chan<- bool, <-chan error) ClaimTaskStub func(taskGuid string, executorID string) error StartTaskStub func(taskGuid string, executorID string, containerHandle string) error CompleteTaskStub func(taskGuid string, failed bool, failureReason string, result string) error ReportActualLRPAsStartingStub func(lrp models.ActualLRP, executorID string) error ReportActualLRPAsRunningStub func(lrp models.ActualLRP, executorId string) error RemoveActualLRPStub func(lrp models.ActualLRP) error WatchForStopLRPInstanceStub func() (<-chan models.StopLRPInstance, chan<- bool, <-chan error) ResolveStopLRPInstanceStub func(stopInstance models.StopLRPInstance) error // contains filtered or unexported fields }
func (*FakeRepBBS) ClaimTaskArgsForCall ¶
func (fake *FakeRepBBS) ClaimTaskArgsForCall(i int) (string, string)
func (*FakeRepBBS) ClaimTaskCallCount ¶
func (fake *FakeRepBBS) ClaimTaskCallCount() int
func (*FakeRepBBS) ClaimTaskReturns ¶
func (fake *FakeRepBBS) ClaimTaskReturns(result1 error)
func (*FakeRepBBS) CompleteTask ¶
func (*FakeRepBBS) CompleteTaskArgsForCall ¶
func (*FakeRepBBS) CompleteTaskCallCount ¶
func (fake *FakeRepBBS) CompleteTaskCallCount() int
func (*FakeRepBBS) CompleteTaskReturns ¶
func (fake *FakeRepBBS) CompleteTaskReturns(result1 error)
func (*FakeRepBBS) MaintainExecutorPresence ¶
func (fake *FakeRepBBS) MaintainExecutorPresence(arg1 time.Duration, arg2 models.ExecutorPresence) (services_bbs.Presence, <-chan bool, error)
func (*FakeRepBBS) MaintainExecutorPresenceArgsForCall ¶
func (fake *FakeRepBBS) MaintainExecutorPresenceArgsForCall(i int) (time.Duration, models.ExecutorPresence)
func (*FakeRepBBS) MaintainExecutorPresenceCallCount ¶
func (fake *FakeRepBBS) MaintainExecutorPresenceCallCount() int
func (*FakeRepBBS) MaintainExecutorPresenceReturns ¶
func (fake *FakeRepBBS) MaintainExecutorPresenceReturns(result1 services_bbs.Presence, result2 <-chan bool, result3 error)
func (*FakeRepBBS) RemoveActualLRP ¶
func (fake *FakeRepBBS) RemoveActualLRP(arg1 models.ActualLRP) error
func (*FakeRepBBS) RemoveActualLRPArgsForCall ¶
func (fake *FakeRepBBS) RemoveActualLRPArgsForCall(i int) models.ActualLRP
func (*FakeRepBBS) RemoveActualLRPCallCount ¶
func (fake *FakeRepBBS) RemoveActualLRPCallCount() int
func (*FakeRepBBS) RemoveActualLRPReturns ¶
func (fake *FakeRepBBS) RemoveActualLRPReturns(result1 error)
func (*FakeRepBBS) ReportActualLRPAsRunning ¶
func (fake *FakeRepBBS) ReportActualLRPAsRunning(arg1 models.ActualLRP, arg2 string) error
func (*FakeRepBBS) ReportActualLRPAsRunningArgsForCall ¶
func (fake *FakeRepBBS) ReportActualLRPAsRunningArgsForCall(i int) (models.ActualLRP, string)
func (*FakeRepBBS) ReportActualLRPAsRunningCallCount ¶
func (fake *FakeRepBBS) ReportActualLRPAsRunningCallCount() int
func (*FakeRepBBS) ReportActualLRPAsRunningReturns ¶
func (fake *FakeRepBBS) ReportActualLRPAsRunningReturns(result1 error)
func (*FakeRepBBS) ReportActualLRPAsStarting ¶
func (fake *FakeRepBBS) ReportActualLRPAsStarting(arg1 models.ActualLRP, arg2 string) error
func (*FakeRepBBS) ReportActualLRPAsStartingArgsForCall ¶
func (fake *FakeRepBBS) ReportActualLRPAsStartingArgsForCall(i int) (models.ActualLRP, string)
func (*FakeRepBBS) ReportActualLRPAsStartingCallCount ¶
func (fake *FakeRepBBS) ReportActualLRPAsStartingCallCount() int
func (*FakeRepBBS) ReportActualLRPAsStartingReturns ¶
func (fake *FakeRepBBS) ReportActualLRPAsStartingReturns(result1 error)
func (*FakeRepBBS) ResolveStopLRPInstance ¶
func (fake *FakeRepBBS) ResolveStopLRPInstance(arg1 models.StopLRPInstance) error
func (*FakeRepBBS) ResolveStopLRPInstanceArgsForCall ¶
func (fake *FakeRepBBS) ResolveStopLRPInstanceArgsForCall(i int) models.StopLRPInstance
func (*FakeRepBBS) ResolveStopLRPInstanceCallCount ¶
func (fake *FakeRepBBS) ResolveStopLRPInstanceCallCount() int
func (*FakeRepBBS) ResolveStopLRPInstanceReturns ¶
func (fake *FakeRepBBS) ResolveStopLRPInstanceReturns(result1 error)
func (*FakeRepBBS) StartTask ¶
func (fake *FakeRepBBS) StartTask(arg1 string, arg2 string, arg3 string) error
func (*FakeRepBBS) StartTaskArgsForCall ¶
func (fake *FakeRepBBS) StartTaskArgsForCall(i int) (string, string, string)
func (*FakeRepBBS) StartTaskCallCount ¶
func (fake *FakeRepBBS) StartTaskCallCount() int
func (*FakeRepBBS) StartTaskReturns ¶
func (fake *FakeRepBBS) StartTaskReturns(result1 error)
func (*FakeRepBBS) WatchForDesiredTask ¶
func (fake *FakeRepBBS) WatchForDesiredTask() (<-chan models.Task, chan<- bool, <-chan error)
func (*FakeRepBBS) WatchForDesiredTaskCallCount ¶
func (fake *FakeRepBBS) WatchForDesiredTaskCallCount() int
func (*FakeRepBBS) WatchForDesiredTaskReturns ¶
func (fake *FakeRepBBS) WatchForDesiredTaskReturns(result1 <-chan models.Task, result2 chan<- bool, result3 <-chan error)
func (*FakeRepBBS) WatchForStopLRPInstance ¶
func (fake *FakeRepBBS) WatchForStopLRPInstance() (<-chan models.StopLRPInstance, chan<- bool, <-chan error)
func (*FakeRepBBS) WatchForStopLRPInstanceCallCount ¶
func (fake *FakeRepBBS) WatchForStopLRPInstanceCallCount() int
func (*FakeRepBBS) WatchForStopLRPInstanceReturns ¶
func (fake *FakeRepBBS) WatchForStopLRPInstanceReturns(result1 <-chan models.StopLRPInstance, result2 chan<- bool, result3 <-chan error)
type FakeRouteEmitterBBS ¶
type FakeRouteEmitterBBS struct { DesiredLRPChangeChan chan models.DesiredLRPChange ActualLRPChangeChan chan models.ActualLRPChange AllDesiredLRPs []models.DesiredLRP AllActualLRPs []models.ActualLRP DesiredLRP models.DesiredLRP ActualLRPs []models.ActualLRP WhenGettingRunningActualLRPs func() ([]models.ActualLRP, error) WhenGettingAllDesiredLRPs func() ([]models.DesiredLRP, error) WhenGettingActualLRPsByProcessGuid func(string) ([]models.ActualLRP, error) WhenGettingDesiredLRPByProcessGuid func(string) (models.DesiredLRP, error) // contains filtered or unexported fields }
func NewFakeRouteEmitterBBS ¶
func NewFakeRouteEmitterBBS() *FakeRouteEmitterBBS
func (*FakeRouteEmitterBBS) GetAllDesiredLRPs ¶
func (fakeBBS *FakeRouteEmitterBBS) GetAllDesiredLRPs() ([]models.DesiredLRP, error)
func (*FakeRouteEmitterBBS) GetDesiredLRPByProcessGuid ¶
func (fakeBBS *FakeRouteEmitterBBS) GetDesiredLRPByProcessGuid(processGuid string) (models.DesiredLRP, error)
func (*FakeRouteEmitterBBS) GetRunningActualLRPs ¶
func (fakeBBS *FakeRouteEmitterBBS) GetRunningActualLRPs() ([]models.ActualLRP, error)
func (*FakeRouteEmitterBBS) GetRunningActualLRPsByProcessGuid ¶
func (fakeBBS *FakeRouteEmitterBBS) GetRunningActualLRPsByProcessGuid(processGuid string) ([]models.ActualLRP, error)
func (*FakeRouteEmitterBBS) SendWatchForActualLRPChangesError ¶
func (fakeBBS *FakeRouteEmitterBBS) SendWatchForActualLRPChangesError(err error)
func (*FakeRouteEmitterBBS) SendWatchForDesiredLRPChangesError ¶
func (fakeBBS *FakeRouteEmitterBBS) SendWatchForDesiredLRPChangesError(err error)
func (*FakeRouteEmitterBBS) WatchForActualLRPChanges ¶
func (fakeBBS *FakeRouteEmitterBBS) WatchForActualLRPChanges() (<-chan models.ActualLRPChange, chan<- bool, <-chan error)
func (*FakeRouteEmitterBBS) WatchForDesiredLRPChanges ¶
func (fakeBBS *FakeRouteEmitterBBS) WatchForDesiredLRPChanges() (<-chan models.DesiredLRPChange, chan<- bool, <-chan error)
type FakeStagerBBS ¶
type FakeStagerBBS struct { WatchForCompletedTaskStub func() (<-chan models.Task, chan<- bool, <-chan error) DesireTaskStub func(models.Task) error ResolvingTaskStub func(taskGuid string) error ResolveTaskStub func(taskGuid string) error GetAvailableFileServerStub func() (string, error) // contains filtered or unexported fields }
func (*FakeStagerBBS) DesireTask ¶
func (fake *FakeStagerBBS) DesireTask(arg1 models.Task) error
func (*FakeStagerBBS) DesireTaskArgsForCall ¶
func (fake *FakeStagerBBS) DesireTaskArgsForCall(i int) models.Task
func (*FakeStagerBBS) DesireTaskCallCount ¶
func (fake *FakeStagerBBS) DesireTaskCallCount() int
func (*FakeStagerBBS) DesireTaskReturns ¶
func (fake *FakeStagerBBS) DesireTaskReturns(result1 error)
func (*FakeStagerBBS) GetAvailableFileServer ¶
func (fake *FakeStagerBBS) GetAvailableFileServer() (string, error)
func (*FakeStagerBBS) GetAvailableFileServerCallCount ¶
func (fake *FakeStagerBBS) GetAvailableFileServerCallCount() int
func (*FakeStagerBBS) GetAvailableFileServerReturns ¶
func (fake *FakeStagerBBS) GetAvailableFileServerReturns(result1 string, result2 error)
func (*FakeStagerBBS) ResolveTask ¶
func (fake *FakeStagerBBS) ResolveTask(arg1 string) error
func (*FakeStagerBBS) ResolveTaskArgsForCall ¶
func (fake *FakeStagerBBS) ResolveTaskArgsForCall(i int) string
func (*FakeStagerBBS) ResolveTaskCallCount ¶
func (fake *FakeStagerBBS) ResolveTaskCallCount() int
func (*FakeStagerBBS) ResolveTaskReturns ¶
func (fake *FakeStagerBBS) ResolveTaskReturns(result1 error)
func (*FakeStagerBBS) ResolvingTask ¶
func (fake *FakeStagerBBS) ResolvingTask(arg1 string) error
func (*FakeStagerBBS) ResolvingTaskArgsForCall ¶
func (fake *FakeStagerBBS) ResolvingTaskArgsForCall(i int) string
func (*FakeStagerBBS) ResolvingTaskCallCount ¶
func (fake *FakeStagerBBS) ResolvingTaskCallCount() int
func (*FakeStagerBBS) ResolvingTaskReturns ¶
func (fake *FakeStagerBBS) ResolvingTaskReturns(result1 error)
func (*FakeStagerBBS) WatchForCompletedTask ¶
func (fake *FakeStagerBBS) WatchForCompletedTask() (<-chan models.Task, chan<- bool, <-chan error)
func (*FakeStagerBBS) WatchForCompletedTaskCallCount ¶
func (fake *FakeStagerBBS) WatchForCompletedTaskCallCount() int
func (*FakeStagerBBS) WatchForCompletedTaskReturns ¶
func (fake *FakeStagerBBS) WatchForCompletedTaskReturns(result1 <-chan models.Task, result2 chan<- bool, result3 <-chan error)
type FileServerGetter ¶
func (*FileServerGetter) GetAvailableFileServer ¶
func (fs *FileServerGetter) GetAvailableFileServer() (string, error)
Click to show internal directories.
Click to hide internal directories.