Documentation ¶
Overview ¶
This file was generated by counterfeiter
This file was generated by counterfeiter
Index ¶
- type FakeClient
- func (fake *FakeClient) ActualLRPGroupByProcessGuidAndIndex(processGuid string, index int) (*models.ActualLRPGroup, error)
- func (fake *FakeClient) ActualLRPGroupByProcessGuidAndIndexArgsForCall(i int) (string, int)
- func (fake *FakeClient) ActualLRPGroupByProcessGuidAndIndexCallCount() int
- func (fake *FakeClient) ActualLRPGroupByProcessGuidAndIndexReturns(result1 *models.ActualLRPGroup, result2 error)
- func (fake *FakeClient) ActualLRPGroups(arg1 models.ActualLRPFilter) ([]*models.ActualLRPGroup, error)
- func (fake *FakeClient) ActualLRPGroupsArgsForCall(i int) models.ActualLRPFilter
- func (fake *FakeClient) ActualLRPGroupsByProcessGuid(processGuid string) ([]*models.ActualLRPGroup, error)
- func (fake *FakeClient) ActualLRPGroupsByProcessGuidArgsForCall(i int) string
- func (fake *FakeClient) ActualLRPGroupsByProcessGuidCallCount() int
- func (fake *FakeClient) ActualLRPGroupsByProcessGuidReturns(result1 []*models.ActualLRPGroup, result2 error)
- func (fake *FakeClient) ActualLRPGroupsCallCount() int
- func (fake *FakeClient) ActualLRPGroupsReturns(result1 []*models.ActualLRPGroup, result2 error)
- func (fake *FakeClient) CancelTask(taskGuid string) error
- func (fake *FakeClient) CancelTaskArgsForCall(i int) string
- func (fake *FakeClient) CancelTaskCallCount() int
- func (fake *FakeClient) CancelTaskReturns(result1 error)
- func (fake *FakeClient) Cells() ([]*models.CellPresence, error)
- func (fake *FakeClient) CellsCallCount() int
- func (fake *FakeClient) CellsReturns(result1 []*models.CellPresence, result2 error)
- func (fake *FakeClient) ClaimActualLRP(processGuid string, index int, instanceKey *models.ActualLRPInstanceKey) error
- func (fake *FakeClient) ClaimActualLRPArgsForCall(i int) (string, int, *models.ActualLRPInstanceKey)
- func (fake *FakeClient) ClaimActualLRPCallCount() int
- func (fake *FakeClient) ClaimActualLRPReturns(result1 error)
- func (fake *FakeClient) CompleteTask(taskGuid string, cellId string, failed bool, failureReason string, ...) error
- func (fake *FakeClient) CompleteTaskArgsForCall(i int) (string, string, bool, string, string)
- func (fake *FakeClient) CompleteTaskCallCount() int
- func (fake *FakeClient) CompleteTaskReturns(result1 error)
- func (fake *FakeClient) ConvergeLRPs() error
- func (fake *FakeClient) ConvergeLRPsCallCount() int
- func (fake *FakeClient) ConvergeLRPsReturns(result1 error)
- func (fake *FakeClient) ConvergeTasks(kickTaskDuration time.Duration, expirePendingTaskDuration time.Duration, ...) error
- func (fake *FakeClient) ConvergeTasksArgsForCall(i int) (time.Duration, time.Duration, time.Duration)
- func (fake *FakeClient) ConvergeTasksCallCount() int
- func (fake *FakeClient) ConvergeTasksReturns(result1 error)
- func (fake *FakeClient) CrashActualLRP(key *models.ActualLRPKey, instanceKey *models.ActualLRPInstanceKey, ...) error
- func (fake *FakeClient) CrashActualLRPArgsForCall(i int) (*models.ActualLRPKey, *models.ActualLRPInstanceKey, string)
- func (fake *FakeClient) CrashActualLRPCallCount() int
- func (fake *FakeClient) CrashActualLRPReturns(result1 error)
- func (fake *FakeClient) DeleteTask(taskGuid string) error
- func (fake *FakeClient) DeleteTaskArgsForCall(i int) string
- func (fake *FakeClient) DeleteTaskCallCount() int
- func (fake *FakeClient) DeleteTaskReturns(result1 error)
- func (fake *FakeClient) DesireLRP(arg1 *models.DesiredLRP) error
- func (fake *FakeClient) DesireLRPArgsForCall(i int) *models.DesiredLRP
- func (fake *FakeClient) DesireLRPCallCount() int
- func (fake *FakeClient) DesireLRPReturns(result1 error)
- func (fake *FakeClient) DesireTask(guid string, domain string, def *models.TaskDefinition) error
- func (fake *FakeClient) DesireTaskArgsForCall(i int) (string, string, *models.TaskDefinition)
- func (fake *FakeClient) DesireTaskCallCount() int
- func (fake *FakeClient) DesireTaskReturns(result1 error)
- func (fake *FakeClient) DesiredLRPByProcessGuid(processGuid string) (*models.DesiredLRP, error)
- func (fake *FakeClient) DesiredLRPByProcessGuidArgsForCall(i int) string
- func (fake *FakeClient) DesiredLRPByProcessGuidCallCount() int
- func (fake *FakeClient) DesiredLRPByProcessGuidReturns(result1 *models.DesiredLRP, result2 error)
- func (fake *FakeClient) DesiredLRPSchedulingInfos(arg1 models.DesiredLRPFilter) ([]*models.DesiredLRPSchedulingInfo, error)
- func (fake *FakeClient) DesiredLRPSchedulingInfosArgsForCall(i int) models.DesiredLRPFilter
- func (fake *FakeClient) DesiredLRPSchedulingInfosCallCount() int
- func (fake *FakeClient) DesiredLRPSchedulingInfosReturns(result1 []*models.DesiredLRPSchedulingInfo, result2 error)
- func (fake *FakeClient) DesiredLRPs(arg1 models.DesiredLRPFilter) ([]*models.DesiredLRP, error)
- func (fake *FakeClient) DesiredLRPsArgsForCall(i int) models.DesiredLRPFilter
- func (fake *FakeClient) DesiredLRPsCallCount() int
- func (fake *FakeClient) DesiredLRPsReturns(result1 []*models.DesiredLRP, result2 error)
- func (fake *FakeClient) Domains() ([]string, error)
- func (fake *FakeClient) DomainsCallCount() int
- func (fake *FakeClient) DomainsReturns(result1 []string, result2 error)
- func (fake *FakeClient) EvacuateClaimedActualLRP(arg1 *models.ActualLRPKey, arg2 *models.ActualLRPInstanceKey) (bool, error)
- func (fake *FakeClient) EvacuateClaimedActualLRPArgsForCall(i int) (*models.ActualLRPKey, *models.ActualLRPInstanceKey)
- func (fake *FakeClient) EvacuateClaimedActualLRPCallCount() int
- func (fake *FakeClient) EvacuateClaimedActualLRPReturns(result1 bool, result2 error)
- func (fake *FakeClient) EvacuateCrashedActualLRP(arg1 *models.ActualLRPKey, arg2 *models.ActualLRPInstanceKey, arg3 string) (bool, error)
- func (fake *FakeClient) EvacuateCrashedActualLRPArgsForCall(i int) (*models.ActualLRPKey, *models.ActualLRPInstanceKey, string)
- func (fake *FakeClient) EvacuateCrashedActualLRPCallCount() int
- func (fake *FakeClient) EvacuateCrashedActualLRPReturns(result1 bool, result2 error)
- func (fake *FakeClient) EvacuateRunningActualLRP(arg1 *models.ActualLRPKey, arg2 *models.ActualLRPInstanceKey, ...) (bool, error)
- func (fake *FakeClient) EvacuateRunningActualLRPArgsForCall(i int) (*models.ActualLRPKey, *models.ActualLRPInstanceKey, *models.ActualLRPNetInfo, ...)
- func (fake *FakeClient) EvacuateRunningActualLRPCallCount() int
- func (fake *FakeClient) EvacuateRunningActualLRPReturns(result1 bool, result2 error)
- func (fake *FakeClient) EvacuateStoppedActualLRP(arg1 *models.ActualLRPKey, arg2 *models.ActualLRPInstanceKey) (bool, error)
- func (fake *FakeClient) EvacuateStoppedActualLRPArgsForCall(i int) (*models.ActualLRPKey, *models.ActualLRPInstanceKey)
- func (fake *FakeClient) EvacuateStoppedActualLRPCallCount() int
- func (fake *FakeClient) EvacuateStoppedActualLRPReturns(result1 bool, result2 error)
- func (fake *FakeClient) FailActualLRP(key *models.ActualLRPKey, errorMessage string) error
- func (fake *FakeClient) FailActualLRPArgsForCall(i int) (*models.ActualLRPKey, string)
- func (fake *FakeClient) FailActualLRPCallCount() int
- func (fake *FakeClient) FailActualLRPReturns(result1 error)
- func (fake *FakeClient) FailTask(taskGuid string, failureReason string) error
- func (fake *FakeClient) FailTaskArgsForCall(i int) (string, string)
- func (fake *FakeClient) FailTaskCallCount() int
- func (fake *FakeClient) FailTaskReturns(result1 error)
- func (fake *FakeClient) Ping() bool
- func (fake *FakeClient) PingCallCount() int
- func (fake *FakeClient) PingReturns(result1 bool)
- func (fake *FakeClient) RemoveActualLRP(processGuid string, index int) error
- func (fake *FakeClient) RemoveActualLRPArgsForCall(i int) (string, int)
- func (fake *FakeClient) RemoveActualLRPCallCount() int
- func (fake *FakeClient) RemoveActualLRPReturns(result1 error)
- func (fake *FakeClient) RemoveDesiredLRP(processGuid string) error
- func (fake *FakeClient) RemoveDesiredLRPArgsForCall(i int) string
- func (fake *FakeClient) RemoveDesiredLRPCallCount() int
- func (fake *FakeClient) RemoveDesiredLRPReturns(result1 error)
- func (fake *FakeClient) RemoveEvacuatingActualLRP(arg1 *models.ActualLRPKey, arg2 *models.ActualLRPInstanceKey) error
- func (fake *FakeClient) RemoveEvacuatingActualLRPArgsForCall(i int) (*models.ActualLRPKey, *models.ActualLRPInstanceKey)
- func (fake *FakeClient) RemoveEvacuatingActualLRPCallCount() int
- func (fake *FakeClient) RemoveEvacuatingActualLRPReturns(result1 error)
- func (fake *FakeClient) ResolvingTask(taskGuid string) error
- func (fake *FakeClient) ResolvingTaskArgsForCall(i int) string
- func (fake *FakeClient) ResolvingTaskCallCount() int
- func (fake *FakeClient) ResolvingTaskReturns(result1 error)
- func (fake *FakeClient) RetireActualLRP(key *models.ActualLRPKey) error
- func (fake *FakeClient) RetireActualLRPArgsForCall(i int) *models.ActualLRPKey
- func (fake *FakeClient) RetireActualLRPCallCount() int
- func (fake *FakeClient) RetireActualLRPReturns(result1 error)
- func (fake *FakeClient) StartActualLRP(key *models.ActualLRPKey, instanceKey *models.ActualLRPInstanceKey, ...) error
- func (fake *FakeClient) StartActualLRPArgsForCall(i int) (*models.ActualLRPKey, *models.ActualLRPInstanceKey, *models.ActualLRPNetInfo)
- func (fake *FakeClient) StartActualLRPCallCount() int
- func (fake *FakeClient) StartActualLRPReturns(result1 error)
- func (fake *FakeClient) StartTask(taskGuid string, cellID string) (bool, error)
- func (fake *FakeClient) StartTaskArgsForCall(i int) (string, string)
- func (fake *FakeClient) StartTaskCallCount() int
- func (fake *FakeClient) StartTaskReturns(result1 bool, result2 error)
- func (fake *FakeClient) SubscribeToActualLRPEvents() (events.EventSource, error)
- func (fake *FakeClient) SubscribeToActualLRPEventsCallCount() int
- func (fake *FakeClient) SubscribeToActualLRPEventsReturns(result1 events.EventSource, result2 error)
- func (fake *FakeClient) SubscribeToDesiredLRPEvents() (events.EventSource, error)
- func (fake *FakeClient) SubscribeToDesiredLRPEventsCallCount() int
- func (fake *FakeClient) SubscribeToDesiredLRPEventsReturns(result1 events.EventSource, result2 error)
- func (fake *FakeClient) SubscribeToEvents() (events.EventSource, error)
- func (fake *FakeClient) SubscribeToEventsCallCount() int
- func (fake *FakeClient) SubscribeToEventsReturns(result1 events.EventSource, result2 error)
- func (fake *FakeClient) SubscribeToTaskEvents() (events.EventSource, error)
- func (fake *FakeClient) SubscribeToTaskEventsCallCount() int
- func (fake *FakeClient) SubscribeToTaskEventsReturns(result1 events.EventSource, result2 error)
- func (fake *FakeClient) TaskByGuid(guid string) (*models.Task, error)
- func (fake *FakeClient) TaskByGuidArgsForCall(i int) string
- func (fake *FakeClient) TaskByGuidCallCount() int
- func (fake *FakeClient) TaskByGuidReturns(result1 *models.Task, result2 error)
- func (fake *FakeClient) Tasks() ([]*models.Task, error)
- func (fake *FakeClient) TasksByCellID(cellId string) ([]*models.Task, error)
- func (fake *FakeClient) TasksByCellIDArgsForCall(i int) string
- func (fake *FakeClient) TasksByCellIDCallCount() int
- func (fake *FakeClient) TasksByCellIDReturns(result1 []*models.Task, result2 error)
- func (fake *FakeClient) TasksByDomain(domain string) ([]*models.Task, error)
- func (fake *FakeClient) TasksByDomainArgsForCall(i int) string
- func (fake *FakeClient) TasksByDomainCallCount() int
- func (fake *FakeClient) TasksByDomainReturns(result1 []*models.Task, result2 error)
- func (fake *FakeClient) TasksCallCount() int
- func (fake *FakeClient) TasksReturns(result1 []*models.Task, result2 error)
- func (fake *FakeClient) UpdateDesiredLRP(processGuid string, update *models.DesiredLRPUpdate) error
- func (fake *FakeClient) UpdateDesiredLRPArgsForCall(i int) (string, *models.DesiredLRPUpdate)
- func (fake *FakeClient) UpdateDesiredLRPCallCount() int
- func (fake *FakeClient) UpdateDesiredLRPReturns(result1 error)
- func (fake *FakeClient) UpsertDomain(domain string, ttl time.Duration) error
- func (fake *FakeClient) UpsertDomainArgsForCall(i int) (string, time.Duration)
- func (fake *FakeClient) UpsertDomainCallCount() int
- func (fake *FakeClient) UpsertDomainReturns(result1 error)
- type FakeServiceClient
- func (fake *FakeServiceClient) CellById(logger lager.Logger, cellId string) (*models.CellPresence, error)
- func (fake *FakeServiceClient) CellByIdArgsForCall(i int) (lager.Logger, string)
- func (fake *FakeServiceClient) CellByIdCallCount() int
- func (fake *FakeServiceClient) CellByIdReturns(result1 *models.CellPresence, result2 error)
- func (fake *FakeServiceClient) CellEvents(logger lager.Logger) <-chan models.CellEvent
- func (fake *FakeServiceClient) CellEventsArgsForCall(i int) lager.Logger
- func (fake *FakeServiceClient) CellEventsCallCount() int
- func (fake *FakeServiceClient) CellEventsReturns(result1 <-chan models.CellEvent)
- func (fake *FakeServiceClient) Cells(logger lager.Logger) (models.CellSet, error)
- func (fake *FakeServiceClient) CellsArgsForCall(i int) lager.Logger
- func (fake *FakeServiceClient) CellsCallCount() int
- func (fake *FakeServiceClient) CellsReturns(result1 models.CellSet, result2 error)
- func (fake *FakeServiceClient) CurrentBBS(logger lager.Logger) (*models.BBSPresence, error)
- func (fake *FakeServiceClient) CurrentBBSArgsForCall(i int) lager.Logger
- func (fake *FakeServiceClient) CurrentBBSCallCount() int
- func (fake *FakeServiceClient) CurrentBBSReturns(result1 *models.BBSPresence, result2 error)
- func (fake *FakeServiceClient) CurrentBBSURL(logger lager.Logger) (string, error)
- func (fake *FakeServiceClient) CurrentBBSURLArgsForCall(i int) lager.Logger
- func (fake *FakeServiceClient) CurrentBBSURLCallCount() int
- func (fake *FakeServiceClient) CurrentBBSURLReturns(result1 string, result2 error)
- func (fake *FakeServiceClient) NewBBSLockRunner(logger lager.Logger, bbsPresence *models.BBSPresence, ...) (ifrit.Runner, error)
- func (fake *FakeServiceClient) NewBBSLockRunnerArgsForCall(i int) (lager.Logger, *models.BBSPresence, time.Duration, time.Duration)
- func (fake *FakeServiceClient) NewBBSLockRunnerCallCount() int
- func (fake *FakeServiceClient) NewBBSLockRunnerReturns(result1 ifrit.Runner, result2 error)
- func (fake *FakeServiceClient) NewCellPresenceRunner(logger lager.Logger, cellPresence *models.CellPresence, ...) ifrit.Runner
- func (fake *FakeServiceClient) NewCellPresenceRunnerArgsForCall(i int) (lager.Logger, *models.CellPresence, time.Duration, time.Duration)
- func (fake *FakeServiceClient) NewCellPresenceRunnerCallCount() int
- func (fake *FakeServiceClient) NewCellPresenceRunnerReturns(result1 ifrit.Runner)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FakeClient ¶
type FakeClient struct { PingStub func() bool DomainsStub func() ([]string, error) UpsertDomainStub func(domain string, ttl time.Duration) error ActualLRPGroupsStub func(models.ActualLRPFilter) ([]*models.ActualLRPGroup, error) ActualLRPGroupsByProcessGuidStub func(processGuid string) ([]*models.ActualLRPGroup, error) ActualLRPGroupByProcessGuidAndIndexStub func(processGuid string, index int) (*models.ActualLRPGroup, error) RetireActualLRPStub func(key *models.ActualLRPKey) error DesiredLRPsStub func(models.DesiredLRPFilter) ([]*models.DesiredLRP, error) DesiredLRPByProcessGuidStub func(processGuid string) (*models.DesiredLRP, error) DesiredLRPSchedulingInfosStub func(models.DesiredLRPFilter) ([]*models.DesiredLRPSchedulingInfo, error) DesireLRPStub func(*models.DesiredLRP) error UpdateDesiredLRPStub func(processGuid string, update *models.DesiredLRPUpdate) error RemoveDesiredLRPStub func(processGuid string) error TasksStub func() ([]*models.Task, error) TasksByDomainStub func(domain string) ([]*models.Task, error) TasksByCellIDStub func(cellId string) ([]*models.Task, error) TaskByGuidStub func(guid string) (*models.Task, error) DesireTaskStub func(guid, domain string, def *models.TaskDefinition) error CancelTaskStub func(taskGuid string) error SubscribeToEventsStub func() (events.EventSource, error) SubscribeToDesiredLRPEventsStub func() (events.EventSource, error) SubscribeToActualLRPEventsStub func() (events.EventSource, error) SubscribeToTaskEventsStub func() (events.EventSource, error) CellsStub func() ([]*models.CellPresence, error) ClaimActualLRPStub func(processGuid string, index int, instanceKey *models.ActualLRPInstanceKey) error StartActualLRPStub func(key *models.ActualLRPKey, instanceKey *models.ActualLRPInstanceKey, netInfo *models.ActualLRPNetInfo) error CrashActualLRPStub func(key *models.ActualLRPKey, instanceKey *models.ActualLRPInstanceKey, errorMessage string) error FailActualLRPStub func(key *models.ActualLRPKey, errorMessage string) error RemoveActualLRPStub func(processGuid string, index int) error EvacuateClaimedActualLRPStub func(*models.ActualLRPKey, *models.ActualLRPInstanceKey) (bool, error) EvacuateRunningActualLRPStub func(*models.ActualLRPKey, *models.ActualLRPInstanceKey, *models.ActualLRPNetInfo, uint64) (bool, error) EvacuateStoppedActualLRPStub func(*models.ActualLRPKey, *models.ActualLRPInstanceKey) (bool, error) EvacuateCrashedActualLRPStub func(*models.ActualLRPKey, *models.ActualLRPInstanceKey, string) (bool, error) RemoveEvacuatingActualLRPStub func(*models.ActualLRPKey, *models.ActualLRPInstanceKey) error ConvergeLRPsStub func() error ConvergeTasksStub func(kickTaskDuration, expirePendingTaskDuration, expireCompletedTaskDuration time.Duration) error StartTaskStub func(taskGuid string, cellID string) (bool, error) FailTaskStub func(taskGuid, failureReason string) error CompleteTaskStub func(taskGuid, cellId string, failed bool, failureReason, result string) error ResolvingTaskStub func(taskGuid string) error DeleteTaskStub func(taskGuid string) error // contains filtered or unexported fields }
func (*FakeClient) ActualLRPGroupByProcessGuidAndIndex ¶
func (fake *FakeClient) ActualLRPGroupByProcessGuidAndIndex(processGuid string, index int) (*models.ActualLRPGroup, error)
func (*FakeClient) ActualLRPGroupByProcessGuidAndIndexArgsForCall ¶
func (fake *FakeClient) ActualLRPGroupByProcessGuidAndIndexArgsForCall(i int) (string, int)
func (*FakeClient) ActualLRPGroupByProcessGuidAndIndexCallCount ¶
func (fake *FakeClient) ActualLRPGroupByProcessGuidAndIndexCallCount() int
func (*FakeClient) ActualLRPGroupByProcessGuidAndIndexReturns ¶
func (fake *FakeClient) ActualLRPGroupByProcessGuidAndIndexReturns(result1 *models.ActualLRPGroup, result2 error)
func (*FakeClient) ActualLRPGroups ¶
func (fake *FakeClient) ActualLRPGroups(arg1 models.ActualLRPFilter) ([]*models.ActualLRPGroup, error)
func (*FakeClient) ActualLRPGroupsArgsForCall ¶
func (fake *FakeClient) ActualLRPGroupsArgsForCall(i int) models.ActualLRPFilter
func (*FakeClient) ActualLRPGroupsByProcessGuid ¶
func (fake *FakeClient) ActualLRPGroupsByProcessGuid(processGuid string) ([]*models.ActualLRPGroup, error)
func (*FakeClient) ActualLRPGroupsByProcessGuidArgsForCall ¶
func (fake *FakeClient) ActualLRPGroupsByProcessGuidArgsForCall(i int) string
func (*FakeClient) ActualLRPGroupsByProcessGuidCallCount ¶
func (fake *FakeClient) ActualLRPGroupsByProcessGuidCallCount() int
func (*FakeClient) ActualLRPGroupsByProcessGuidReturns ¶
func (fake *FakeClient) ActualLRPGroupsByProcessGuidReturns(result1 []*models.ActualLRPGroup, result2 error)
func (*FakeClient) ActualLRPGroupsCallCount ¶
func (fake *FakeClient) ActualLRPGroupsCallCount() int
func (*FakeClient) ActualLRPGroupsReturns ¶
func (fake *FakeClient) ActualLRPGroupsReturns(result1 []*models.ActualLRPGroup, result2 error)
func (*FakeClient) CancelTask ¶
func (fake *FakeClient) CancelTask(taskGuid string) error
func (*FakeClient) CancelTaskArgsForCall ¶
func (fake *FakeClient) CancelTaskArgsForCall(i int) string
func (*FakeClient) CancelTaskCallCount ¶
func (fake *FakeClient) CancelTaskCallCount() int
func (*FakeClient) CancelTaskReturns ¶
func (fake *FakeClient) CancelTaskReturns(result1 error)
func (*FakeClient) Cells ¶
func (fake *FakeClient) Cells() ([]*models.CellPresence, error)
func (*FakeClient) CellsCallCount ¶
func (fake *FakeClient) CellsCallCount() int
func (*FakeClient) CellsReturns ¶
func (fake *FakeClient) CellsReturns(result1 []*models.CellPresence, result2 error)
func (*FakeClient) ClaimActualLRP ¶
func (fake *FakeClient) ClaimActualLRP(processGuid string, index int, instanceKey *models.ActualLRPInstanceKey) error
func (*FakeClient) ClaimActualLRPArgsForCall ¶
func (fake *FakeClient) ClaimActualLRPArgsForCall(i int) (string, int, *models.ActualLRPInstanceKey)
func (*FakeClient) ClaimActualLRPCallCount ¶
func (fake *FakeClient) ClaimActualLRPCallCount() int
func (*FakeClient) ClaimActualLRPReturns ¶
func (fake *FakeClient) ClaimActualLRPReturns(result1 error)
func (*FakeClient) CompleteTask ¶
func (*FakeClient) CompleteTaskArgsForCall ¶
func (*FakeClient) CompleteTaskCallCount ¶
func (fake *FakeClient) CompleteTaskCallCount() int
func (*FakeClient) CompleteTaskReturns ¶
func (fake *FakeClient) CompleteTaskReturns(result1 error)
func (*FakeClient) ConvergeLRPs ¶
func (fake *FakeClient) ConvergeLRPs() error
func (*FakeClient) ConvergeLRPsCallCount ¶
func (fake *FakeClient) ConvergeLRPsCallCount() int
func (*FakeClient) ConvergeLRPsReturns ¶
func (fake *FakeClient) ConvergeLRPsReturns(result1 error)
func (*FakeClient) ConvergeTasks ¶
func (*FakeClient) ConvergeTasksArgsForCall ¶
func (*FakeClient) ConvergeTasksCallCount ¶
func (fake *FakeClient) ConvergeTasksCallCount() int
func (*FakeClient) ConvergeTasksReturns ¶
func (fake *FakeClient) ConvergeTasksReturns(result1 error)
func (*FakeClient) CrashActualLRP ¶
func (fake *FakeClient) CrashActualLRP(key *models.ActualLRPKey, instanceKey *models.ActualLRPInstanceKey, errorMessage string) error
func (*FakeClient) CrashActualLRPArgsForCall ¶
func (fake *FakeClient) CrashActualLRPArgsForCall(i int) (*models.ActualLRPKey, *models.ActualLRPInstanceKey, string)
func (*FakeClient) CrashActualLRPCallCount ¶
func (fake *FakeClient) CrashActualLRPCallCount() int
func (*FakeClient) CrashActualLRPReturns ¶
func (fake *FakeClient) CrashActualLRPReturns(result1 error)
func (*FakeClient) DeleteTask ¶
func (fake *FakeClient) DeleteTask(taskGuid string) error
func (*FakeClient) DeleteTaskArgsForCall ¶
func (fake *FakeClient) DeleteTaskArgsForCall(i int) string
func (*FakeClient) DeleteTaskCallCount ¶
func (fake *FakeClient) DeleteTaskCallCount() int
func (*FakeClient) DeleteTaskReturns ¶
func (fake *FakeClient) DeleteTaskReturns(result1 error)
func (*FakeClient) DesireLRP ¶
func (fake *FakeClient) DesireLRP(arg1 *models.DesiredLRP) error
func (*FakeClient) DesireLRPArgsForCall ¶
func (fake *FakeClient) DesireLRPArgsForCall(i int) *models.DesiredLRP
func (*FakeClient) DesireLRPCallCount ¶
func (fake *FakeClient) DesireLRPCallCount() int
func (*FakeClient) DesireLRPReturns ¶
func (fake *FakeClient) DesireLRPReturns(result1 error)
func (*FakeClient) DesireTask ¶
func (fake *FakeClient) DesireTask(guid string, domain string, def *models.TaskDefinition) error
func (*FakeClient) DesireTaskArgsForCall ¶
func (fake *FakeClient) DesireTaskArgsForCall(i int) (string, string, *models.TaskDefinition)
func (*FakeClient) DesireTaskCallCount ¶
func (fake *FakeClient) DesireTaskCallCount() int
func (*FakeClient) DesireTaskReturns ¶
func (fake *FakeClient) DesireTaskReturns(result1 error)
func (*FakeClient) DesiredLRPByProcessGuid ¶
func (fake *FakeClient) DesiredLRPByProcessGuid(processGuid string) (*models.DesiredLRP, error)
func (*FakeClient) DesiredLRPByProcessGuidArgsForCall ¶
func (fake *FakeClient) DesiredLRPByProcessGuidArgsForCall(i int) string
func (*FakeClient) DesiredLRPByProcessGuidCallCount ¶
func (fake *FakeClient) DesiredLRPByProcessGuidCallCount() int
func (*FakeClient) DesiredLRPByProcessGuidReturns ¶
func (fake *FakeClient) DesiredLRPByProcessGuidReturns(result1 *models.DesiredLRP, result2 error)
func (*FakeClient) DesiredLRPSchedulingInfos ¶
func (fake *FakeClient) DesiredLRPSchedulingInfos(arg1 models.DesiredLRPFilter) ([]*models.DesiredLRPSchedulingInfo, error)
func (*FakeClient) DesiredLRPSchedulingInfosArgsForCall ¶
func (fake *FakeClient) DesiredLRPSchedulingInfosArgsForCall(i int) models.DesiredLRPFilter
func (*FakeClient) DesiredLRPSchedulingInfosCallCount ¶
func (fake *FakeClient) DesiredLRPSchedulingInfosCallCount() int
func (*FakeClient) DesiredLRPSchedulingInfosReturns ¶
func (fake *FakeClient) DesiredLRPSchedulingInfosReturns(result1 []*models.DesiredLRPSchedulingInfo, result2 error)
func (*FakeClient) DesiredLRPs ¶
func (fake *FakeClient) DesiredLRPs(arg1 models.DesiredLRPFilter) ([]*models.DesiredLRP, error)
func (*FakeClient) DesiredLRPsArgsForCall ¶
func (fake *FakeClient) DesiredLRPsArgsForCall(i int) models.DesiredLRPFilter
func (*FakeClient) DesiredLRPsCallCount ¶
func (fake *FakeClient) DesiredLRPsCallCount() int
func (*FakeClient) DesiredLRPsReturns ¶
func (fake *FakeClient) DesiredLRPsReturns(result1 []*models.DesiredLRP, result2 error)
func (*FakeClient) Domains ¶
func (fake *FakeClient) Domains() ([]string, error)
func (*FakeClient) DomainsCallCount ¶
func (fake *FakeClient) DomainsCallCount() int
func (*FakeClient) DomainsReturns ¶
func (fake *FakeClient) DomainsReturns(result1 []string, result2 error)
func (*FakeClient) EvacuateClaimedActualLRP ¶
func (fake *FakeClient) EvacuateClaimedActualLRP(arg1 *models.ActualLRPKey, arg2 *models.ActualLRPInstanceKey) (bool, error)
func (*FakeClient) EvacuateClaimedActualLRPArgsForCall ¶
func (fake *FakeClient) EvacuateClaimedActualLRPArgsForCall(i int) (*models.ActualLRPKey, *models.ActualLRPInstanceKey)
func (*FakeClient) EvacuateClaimedActualLRPCallCount ¶
func (fake *FakeClient) EvacuateClaimedActualLRPCallCount() int
func (*FakeClient) EvacuateClaimedActualLRPReturns ¶
func (fake *FakeClient) EvacuateClaimedActualLRPReturns(result1 bool, result2 error)
func (*FakeClient) EvacuateCrashedActualLRP ¶
func (fake *FakeClient) EvacuateCrashedActualLRP(arg1 *models.ActualLRPKey, arg2 *models.ActualLRPInstanceKey, arg3 string) (bool, error)
func (*FakeClient) EvacuateCrashedActualLRPArgsForCall ¶
func (fake *FakeClient) EvacuateCrashedActualLRPArgsForCall(i int) (*models.ActualLRPKey, *models.ActualLRPInstanceKey, string)
func (*FakeClient) EvacuateCrashedActualLRPCallCount ¶
func (fake *FakeClient) EvacuateCrashedActualLRPCallCount() int
func (*FakeClient) EvacuateCrashedActualLRPReturns ¶
func (fake *FakeClient) EvacuateCrashedActualLRPReturns(result1 bool, result2 error)
func (*FakeClient) EvacuateRunningActualLRP ¶
func (fake *FakeClient) EvacuateRunningActualLRP(arg1 *models.ActualLRPKey, arg2 *models.ActualLRPInstanceKey, arg3 *models.ActualLRPNetInfo, arg4 uint64) (bool, error)
func (*FakeClient) EvacuateRunningActualLRPArgsForCall ¶
func (fake *FakeClient) EvacuateRunningActualLRPArgsForCall(i int) (*models.ActualLRPKey, *models.ActualLRPInstanceKey, *models.ActualLRPNetInfo, uint64)
func (*FakeClient) EvacuateRunningActualLRPCallCount ¶
func (fake *FakeClient) EvacuateRunningActualLRPCallCount() int
func (*FakeClient) EvacuateRunningActualLRPReturns ¶
func (fake *FakeClient) EvacuateRunningActualLRPReturns(result1 bool, result2 error)
func (*FakeClient) EvacuateStoppedActualLRP ¶
func (fake *FakeClient) EvacuateStoppedActualLRP(arg1 *models.ActualLRPKey, arg2 *models.ActualLRPInstanceKey) (bool, error)
func (*FakeClient) EvacuateStoppedActualLRPArgsForCall ¶
func (fake *FakeClient) EvacuateStoppedActualLRPArgsForCall(i int) (*models.ActualLRPKey, *models.ActualLRPInstanceKey)
func (*FakeClient) EvacuateStoppedActualLRPCallCount ¶
func (fake *FakeClient) EvacuateStoppedActualLRPCallCount() int
func (*FakeClient) EvacuateStoppedActualLRPReturns ¶
func (fake *FakeClient) EvacuateStoppedActualLRPReturns(result1 bool, result2 error)
func (*FakeClient) FailActualLRP ¶
func (fake *FakeClient) FailActualLRP(key *models.ActualLRPKey, errorMessage string) error
func (*FakeClient) FailActualLRPArgsForCall ¶
func (fake *FakeClient) FailActualLRPArgsForCall(i int) (*models.ActualLRPKey, string)
func (*FakeClient) FailActualLRPCallCount ¶
func (fake *FakeClient) FailActualLRPCallCount() int
func (*FakeClient) FailActualLRPReturns ¶
func (fake *FakeClient) FailActualLRPReturns(result1 error)
func (*FakeClient) FailTask ¶
func (fake *FakeClient) FailTask(taskGuid string, failureReason string) error
func (*FakeClient) FailTaskArgsForCall ¶
func (fake *FakeClient) FailTaskArgsForCall(i int) (string, string)
func (*FakeClient) FailTaskCallCount ¶
func (fake *FakeClient) FailTaskCallCount() int
func (*FakeClient) FailTaskReturns ¶
func (fake *FakeClient) FailTaskReturns(result1 error)
func (*FakeClient) Ping ¶
func (fake *FakeClient) Ping() bool
func (*FakeClient) PingCallCount ¶
func (fake *FakeClient) PingCallCount() int
func (*FakeClient) PingReturns ¶
func (fake *FakeClient) PingReturns(result1 bool)
func (*FakeClient) RemoveActualLRP ¶
func (fake *FakeClient) RemoveActualLRP(processGuid string, index int) error
func (*FakeClient) RemoveActualLRPArgsForCall ¶
func (fake *FakeClient) RemoveActualLRPArgsForCall(i int) (string, int)
func (*FakeClient) RemoveActualLRPCallCount ¶
func (fake *FakeClient) RemoveActualLRPCallCount() int
func (*FakeClient) RemoveActualLRPReturns ¶
func (fake *FakeClient) RemoveActualLRPReturns(result1 error)
func (*FakeClient) RemoveDesiredLRP ¶
func (fake *FakeClient) RemoveDesiredLRP(processGuid string) error
func (*FakeClient) RemoveDesiredLRPArgsForCall ¶
func (fake *FakeClient) RemoveDesiredLRPArgsForCall(i int) string
func (*FakeClient) RemoveDesiredLRPCallCount ¶
func (fake *FakeClient) RemoveDesiredLRPCallCount() int
func (*FakeClient) RemoveDesiredLRPReturns ¶
func (fake *FakeClient) RemoveDesiredLRPReturns(result1 error)
func (*FakeClient) RemoveEvacuatingActualLRP ¶
func (fake *FakeClient) RemoveEvacuatingActualLRP(arg1 *models.ActualLRPKey, arg2 *models.ActualLRPInstanceKey) error
func (*FakeClient) RemoveEvacuatingActualLRPArgsForCall ¶
func (fake *FakeClient) RemoveEvacuatingActualLRPArgsForCall(i int) (*models.ActualLRPKey, *models.ActualLRPInstanceKey)
func (*FakeClient) RemoveEvacuatingActualLRPCallCount ¶
func (fake *FakeClient) RemoveEvacuatingActualLRPCallCount() int
func (*FakeClient) RemoveEvacuatingActualLRPReturns ¶
func (fake *FakeClient) RemoveEvacuatingActualLRPReturns(result1 error)
func (*FakeClient) ResolvingTask ¶
func (fake *FakeClient) ResolvingTask(taskGuid string) error
func (*FakeClient) ResolvingTaskArgsForCall ¶
func (fake *FakeClient) ResolvingTaskArgsForCall(i int) string
func (*FakeClient) ResolvingTaskCallCount ¶
func (fake *FakeClient) ResolvingTaskCallCount() int
func (*FakeClient) ResolvingTaskReturns ¶
func (fake *FakeClient) ResolvingTaskReturns(result1 error)
func (*FakeClient) RetireActualLRP ¶
func (fake *FakeClient) RetireActualLRP(key *models.ActualLRPKey) error
func (*FakeClient) RetireActualLRPArgsForCall ¶
func (fake *FakeClient) RetireActualLRPArgsForCall(i int) *models.ActualLRPKey
func (*FakeClient) RetireActualLRPCallCount ¶
func (fake *FakeClient) RetireActualLRPCallCount() int
func (*FakeClient) RetireActualLRPReturns ¶
func (fake *FakeClient) RetireActualLRPReturns(result1 error)
func (*FakeClient) StartActualLRP ¶
func (fake *FakeClient) StartActualLRP(key *models.ActualLRPKey, instanceKey *models.ActualLRPInstanceKey, netInfo *models.ActualLRPNetInfo) error
func (*FakeClient) StartActualLRPArgsForCall ¶
func (fake *FakeClient) StartActualLRPArgsForCall(i int) (*models.ActualLRPKey, *models.ActualLRPInstanceKey, *models.ActualLRPNetInfo)
func (*FakeClient) StartActualLRPCallCount ¶
func (fake *FakeClient) StartActualLRPCallCount() int
func (*FakeClient) StartActualLRPReturns ¶
func (fake *FakeClient) StartActualLRPReturns(result1 error)
func (*FakeClient) StartTask ¶
func (fake *FakeClient) StartTask(taskGuid string, cellID string) (bool, error)
func (*FakeClient) StartTaskArgsForCall ¶
func (fake *FakeClient) StartTaskArgsForCall(i int) (string, string)
func (*FakeClient) StartTaskCallCount ¶
func (fake *FakeClient) StartTaskCallCount() int
func (*FakeClient) StartTaskReturns ¶
func (fake *FakeClient) StartTaskReturns(result1 bool, result2 error)
func (*FakeClient) SubscribeToActualLRPEvents ¶
func (fake *FakeClient) SubscribeToActualLRPEvents() (events.EventSource, error)
func (*FakeClient) SubscribeToActualLRPEventsCallCount ¶
func (fake *FakeClient) SubscribeToActualLRPEventsCallCount() int
func (*FakeClient) SubscribeToActualLRPEventsReturns ¶
func (fake *FakeClient) SubscribeToActualLRPEventsReturns(result1 events.EventSource, result2 error)
func (*FakeClient) SubscribeToDesiredLRPEvents ¶
func (fake *FakeClient) SubscribeToDesiredLRPEvents() (events.EventSource, error)
func (*FakeClient) SubscribeToDesiredLRPEventsCallCount ¶
func (fake *FakeClient) SubscribeToDesiredLRPEventsCallCount() int
func (*FakeClient) SubscribeToDesiredLRPEventsReturns ¶
func (fake *FakeClient) SubscribeToDesiredLRPEventsReturns(result1 events.EventSource, result2 error)
func (*FakeClient) SubscribeToEvents ¶
func (fake *FakeClient) SubscribeToEvents() (events.EventSource, error)
func (*FakeClient) SubscribeToEventsCallCount ¶
func (fake *FakeClient) SubscribeToEventsCallCount() int
func (*FakeClient) SubscribeToEventsReturns ¶
func (fake *FakeClient) SubscribeToEventsReturns(result1 events.EventSource, result2 error)
func (*FakeClient) SubscribeToTaskEvents ¶
func (fake *FakeClient) SubscribeToTaskEvents() (events.EventSource, error)
func (*FakeClient) SubscribeToTaskEventsCallCount ¶
func (fake *FakeClient) SubscribeToTaskEventsCallCount() int
func (*FakeClient) SubscribeToTaskEventsReturns ¶
func (fake *FakeClient) SubscribeToTaskEventsReturns(result1 events.EventSource, result2 error)
func (*FakeClient) TaskByGuid ¶
func (fake *FakeClient) TaskByGuid(guid string) (*models.Task, error)
func (*FakeClient) TaskByGuidArgsForCall ¶
func (fake *FakeClient) TaskByGuidArgsForCall(i int) string
func (*FakeClient) TaskByGuidCallCount ¶
func (fake *FakeClient) TaskByGuidCallCount() int
func (*FakeClient) TaskByGuidReturns ¶
func (fake *FakeClient) TaskByGuidReturns(result1 *models.Task, result2 error)
func (*FakeClient) TasksByCellID ¶
func (fake *FakeClient) TasksByCellID(cellId string) ([]*models.Task, error)
func (*FakeClient) TasksByCellIDArgsForCall ¶
func (fake *FakeClient) TasksByCellIDArgsForCall(i int) string
func (*FakeClient) TasksByCellIDCallCount ¶
func (fake *FakeClient) TasksByCellIDCallCount() int
func (*FakeClient) TasksByCellIDReturns ¶
func (fake *FakeClient) TasksByCellIDReturns(result1 []*models.Task, result2 error)
func (*FakeClient) TasksByDomain ¶
func (fake *FakeClient) TasksByDomain(domain string) ([]*models.Task, error)
func (*FakeClient) TasksByDomainArgsForCall ¶
func (fake *FakeClient) TasksByDomainArgsForCall(i int) string
func (*FakeClient) TasksByDomainCallCount ¶
func (fake *FakeClient) TasksByDomainCallCount() int
func (*FakeClient) TasksByDomainReturns ¶
func (fake *FakeClient) TasksByDomainReturns(result1 []*models.Task, result2 error)
func (*FakeClient) TasksCallCount ¶
func (fake *FakeClient) TasksCallCount() int
func (*FakeClient) TasksReturns ¶
func (fake *FakeClient) TasksReturns(result1 []*models.Task, result2 error)
func (*FakeClient) UpdateDesiredLRP ¶
func (fake *FakeClient) UpdateDesiredLRP(processGuid string, update *models.DesiredLRPUpdate) error
func (*FakeClient) UpdateDesiredLRPArgsForCall ¶
func (fake *FakeClient) UpdateDesiredLRPArgsForCall(i int) (string, *models.DesiredLRPUpdate)
func (*FakeClient) UpdateDesiredLRPCallCount ¶
func (fake *FakeClient) UpdateDesiredLRPCallCount() int
func (*FakeClient) UpdateDesiredLRPReturns ¶
func (fake *FakeClient) UpdateDesiredLRPReturns(result1 error)
func (*FakeClient) UpsertDomain ¶
func (fake *FakeClient) UpsertDomain(domain string, ttl time.Duration) error
func (*FakeClient) UpsertDomainArgsForCall ¶
func (fake *FakeClient) UpsertDomainArgsForCall(i int) (string, time.Duration)
func (*FakeClient) UpsertDomainCallCount ¶
func (fake *FakeClient) UpsertDomainCallCount() int
func (*FakeClient) UpsertDomainReturns ¶
func (fake *FakeClient) UpsertDomainReturns(result1 error)
type FakeServiceClient ¶
type FakeServiceClient struct { CellByIdStub func(logger lager.Logger, cellId string) (*models.CellPresence, error) CellsStub func(logger lager.Logger) (models.CellSet, error) CellEventsStub func(logger lager.Logger) <-chan models.CellEvent NewCellPresenceRunnerStub func(logger lager.Logger, cellPresence *models.CellPresence, retryInterval, lockTTL time.Duration) ifrit.Runner NewBBSLockRunnerStub func(logger lager.Logger, bbsPresence *models.BBSPresence, retryInterval, lockTTL time.Duration) (ifrit.Runner, error) CurrentBBSStub func(logger lager.Logger) (*models.BBSPresence, error) CurrentBBSURLStub func(logger lager.Logger) (string, error) // contains filtered or unexported fields }
func (*FakeServiceClient) CellById ¶
func (fake *FakeServiceClient) CellById(logger lager.Logger, cellId string) (*models.CellPresence, error)
func (*FakeServiceClient) CellByIdArgsForCall ¶
func (fake *FakeServiceClient) CellByIdArgsForCall(i int) (lager.Logger, string)
func (*FakeServiceClient) CellByIdCallCount ¶
func (fake *FakeServiceClient) CellByIdCallCount() int
func (*FakeServiceClient) CellByIdReturns ¶
func (fake *FakeServiceClient) CellByIdReturns(result1 *models.CellPresence, result2 error)
func (*FakeServiceClient) CellEvents ¶
func (fake *FakeServiceClient) CellEvents(logger lager.Logger) <-chan models.CellEvent
func (*FakeServiceClient) CellEventsArgsForCall ¶
func (fake *FakeServiceClient) CellEventsArgsForCall(i int) lager.Logger
func (*FakeServiceClient) CellEventsCallCount ¶
func (fake *FakeServiceClient) CellEventsCallCount() int
func (*FakeServiceClient) CellEventsReturns ¶
func (fake *FakeServiceClient) CellEventsReturns(result1 <-chan models.CellEvent)
func (*FakeServiceClient) CellsArgsForCall ¶
func (fake *FakeServiceClient) CellsArgsForCall(i int) lager.Logger
func (*FakeServiceClient) CellsCallCount ¶
func (fake *FakeServiceClient) CellsCallCount() int
func (*FakeServiceClient) CellsReturns ¶
func (fake *FakeServiceClient) CellsReturns(result1 models.CellSet, result2 error)
func (*FakeServiceClient) CurrentBBS ¶
func (fake *FakeServiceClient) CurrentBBS(logger lager.Logger) (*models.BBSPresence, error)
func (*FakeServiceClient) CurrentBBSArgsForCall ¶
func (fake *FakeServiceClient) CurrentBBSArgsForCall(i int) lager.Logger
func (*FakeServiceClient) CurrentBBSCallCount ¶
func (fake *FakeServiceClient) CurrentBBSCallCount() int
func (*FakeServiceClient) CurrentBBSReturns ¶
func (fake *FakeServiceClient) CurrentBBSReturns(result1 *models.BBSPresence, result2 error)
func (*FakeServiceClient) CurrentBBSURL ¶
func (fake *FakeServiceClient) CurrentBBSURL(logger lager.Logger) (string, error)
func (*FakeServiceClient) CurrentBBSURLArgsForCall ¶
func (fake *FakeServiceClient) CurrentBBSURLArgsForCall(i int) lager.Logger
func (*FakeServiceClient) CurrentBBSURLCallCount ¶
func (fake *FakeServiceClient) CurrentBBSURLCallCount() int
func (*FakeServiceClient) CurrentBBSURLReturns ¶
func (fake *FakeServiceClient) CurrentBBSURLReturns(result1 string, result2 error)
func (*FakeServiceClient) NewBBSLockRunner ¶
func (*FakeServiceClient) NewBBSLockRunnerArgsForCall ¶
func (fake *FakeServiceClient) NewBBSLockRunnerArgsForCall(i int) (lager.Logger, *models.BBSPresence, time.Duration, time.Duration)
func (*FakeServiceClient) NewBBSLockRunnerCallCount ¶
func (fake *FakeServiceClient) NewBBSLockRunnerCallCount() int
func (*FakeServiceClient) NewBBSLockRunnerReturns ¶
func (fake *FakeServiceClient) NewBBSLockRunnerReturns(result1 ifrit.Runner, result2 error)
func (*FakeServiceClient) NewCellPresenceRunner ¶
func (*FakeServiceClient) NewCellPresenceRunnerArgsForCall ¶
func (fake *FakeServiceClient) NewCellPresenceRunnerArgsForCall(i int) (lager.Logger, *models.CellPresence, time.Duration, time.Duration)
func (*FakeServiceClient) NewCellPresenceRunnerCallCount ¶
func (fake *FakeServiceClient) NewCellPresenceRunnerCallCount() int
func (*FakeServiceClient) NewCellPresenceRunnerReturns ¶
func (fake *FakeServiceClient) NewCellPresenceRunnerReturns(result1 ifrit.Runner)
Click to show internal directories.
Click to hide internal directories.