Documentation
¶
Overview ¶
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
Index ¶
- type FakeClaimJobControl
- func (fake *FakeClaimJobControl) DeleteJob(arg1 context.Context, arg2 string) error
- func (fake *FakeClaimJobControl) DeleteJobArgsForCall(i int) (context.Context, string)
- func (fake *FakeClaimJobControl) DeleteJobCallCount() int
- func (fake *FakeClaimJobControl) DeleteJobCalls(stub func(context.Context, string) error)
- func (fake *FakeClaimJobControl) DeleteJobReturns(result1 error)
- func (fake *FakeClaimJobControl) DeleteJobReturnsOnCall(i int, result1 error)
- func (fake *FakeClaimJobControl) Invocations() map[string][][]interface{}
- func (fake *FakeClaimJobControl) IsJobRunning(arg1 context.Context, arg2 string) (bool, error)
- func (fake *FakeClaimJobControl) IsJobRunningArgsForCall(i int) (context.Context, string)
- func (fake *FakeClaimJobControl) IsJobRunningCallCount() int
- func (fake *FakeClaimJobControl) IsJobRunningCalls(stub func(context.Context, string) (bool, error))
- func (fake *FakeClaimJobControl) IsJobRunningReturns(result1 bool, result2 error)
- func (fake *FakeClaimJobControl) IsJobRunningReturnsOnCall(i int, result1 bool, result2 error)
- type FakeClaimRefClient
- func (fake *FakeClaimRefClient) Delete(arg1 context.Context, arg2 string, arg3 string) error
- func (fake *FakeClaimRefClient) DeleteArgsForCall(i int) (context.Context, string, string)
- func (fake *FakeClaimRefClient) DeleteCallCount() int
- func (fake *FakeClaimRefClient) DeleteCalls(stub func(context.Context, string, string) error)
- func (fake *FakeClaimRefClient) DeleteReturns(result1 error)
- func (fake *FakeClaimRefClient) DeleteReturnsOnCall(i int, result1 error)
- func (fake *FakeClaimRefClient) Invocations() map[string][][]interface{}
- func (fake *FakeClaimRefClient) List(arg1 context.Context, arg2 string) ([]claim.ClaimRef, error)
- func (fake *FakeClaimRefClient) ListArgsForCall(i int) (context.Context, string)
- func (fake *FakeClaimRefClient) ListCallCount() int
- func (fake *FakeClaimRefClient) ListCalls(stub func(context.Context, string) ([]claim.ClaimRef, error))
- func (fake *FakeClaimRefClient) ListReturns(result1 []claim.ClaimRef, result2 error)
- func (fake *FakeClaimRefClient) ListReturnsOnCall(i int, result1 []claim.ClaimRef, result2 error)
- func (fake *FakeClaimRefClient) Put(arg1 context.Context, arg2 string, arg3 string, arg4 string, arg5 string, ...) (string, error)
- func (fake *FakeClaimRefClient) PutArgsForCall(i int) (context.Context, string, string, string, string, time.DateTime)
- func (fake *FakeClaimRefClient) PutCallCount() int
- func (fake *FakeClaimRefClient) PutCalls(...)
- func (fake *FakeClaimRefClient) PutReturns(result1 string, result2 error)
- func (fake *FakeClaimRefClient) PutReturnsOnCall(i int, result1 string, result2 error)
- type FakeConfigResolver
- func (fake *FakeConfigResolver) Invocations() map[string][][]interface{}
- func (fake *FakeConfigResolver) Resolve(arg1 context.Context, arg2 string) (pkg.AgentConfiguration, error)
- func (fake *FakeConfigResolver) ResolveArgsForCall(i int) (context.Context, string)
- func (fake *FakeConfigResolver) ResolveByTaskType(arg1 context.Context, arg2 string, arg3 string) (pkg.AgentConfiguration, error)
- func (fake *FakeConfigResolver) ResolveByTaskTypeArgsForCall(i int) (context.Context, string, string)
- func (fake *FakeConfigResolver) ResolveByTaskTypeCallCount() int
- func (fake *FakeConfigResolver) ResolveByTaskTypeCalls(stub func(context.Context, string, string) (pkg.AgentConfiguration, error))
- func (fake *FakeConfigResolver) ResolveByTaskTypeReturns(result1 pkg.AgentConfiguration, result2 error)
- func (fake *FakeConfigResolver) ResolveByTaskTypeReturnsOnCall(i int, result1 pkg.AgentConfiguration, result2 error)
- func (fake *FakeConfigResolver) ResolveCallCount() int
- func (fake *FakeConfigResolver) ResolveCalls(stub func(context.Context, string) (pkg.AgentConfiguration, error))
- func (fake *FakeConfigResolver) ResolveReturns(result1 pkg.AgentConfiguration, result2 error)
- func (fake *FakeConfigResolver) ResolveReturnsOnCall(i int, result1 pkg.AgentConfiguration, result2 error)
- type FakeJobSpawner
- func (fake *FakeJobSpawner) CountActiveJobs(arg1 context.Context, arg2 string) (int, error)
- func (fake *FakeJobSpawner) CountActiveJobsArgsForCall(i int) (context.Context, string)
- func (fake *FakeJobSpawner) CountActiveJobsCallCount() int
- func (fake *FakeJobSpawner) CountActiveJobsCalls(stub func(context.Context, string) (int, error))
- func (fake *FakeJobSpawner) CountActiveJobsReturns(result1 int, result2 error)
- func (fake *FakeJobSpawner) CountActiveJobsReturnsOnCall(i int, result1 int, result2 error)
- func (fake *FakeJobSpawner) Invocations() map[string][][]interface{}
- func (fake *FakeJobSpawner) IsJobActive(arg1 context.Context, arg2 lib.TaskIdentifier) (bool, error)
- func (fake *FakeJobSpawner) IsJobActiveArgsForCall(i int) (context.Context, lib.TaskIdentifier)
- func (fake *FakeJobSpawner) IsJobActiveCallCount() int
- func (fake *FakeJobSpawner) IsJobActiveCalls(stub func(context.Context, lib.TaskIdentifier) (bool, error))
- func (fake *FakeJobSpawner) IsJobActiveReturns(result1 bool, result2 error)
- func (fake *FakeJobSpawner) IsJobActiveReturnsOnCall(i int, result1 bool, result2 error)
- func (fake *FakeJobSpawner) ListActiveJobs(arg1 context.Context, arg2 string) (map[lib.TaskIdentifier]bool, error)
- func (fake *FakeJobSpawner) ListActiveJobsArgsForCall(i int) (context.Context, string)
- func (fake *FakeJobSpawner) ListActiveJobsCallCount() int
- func (fake *FakeJobSpawner) ListActiveJobsCalls(stub func(context.Context, string) (map[lib.TaskIdentifier]bool, error))
- func (fake *FakeJobSpawner) ListActiveJobsReturns(result1 map[lib.TaskIdentifier]bool, result2 error)
- func (fake *FakeJobSpawner) ListActiveJobsReturnsOnCall(i int, result1 map[lib.TaskIdentifier]bool, result2 error)
- func (fake *FakeJobSpawner) SpawnJob(arg1 context.Context, arg2 lib.Task, arg3 pkg.AgentConfiguration) (string, error)
- func (fake *FakeJobSpawner) SpawnJobArgsForCall(i int) (context.Context, lib.Task, pkg.AgentConfiguration)
- func (fake *FakeJobSpawner) SpawnJobCallCount() int
- func (fake *FakeJobSpawner) SpawnJobCalls(stub func(context.Context, lib.Task, pkg.AgentConfiguration) (string, error))
- func (fake *FakeJobSpawner) SpawnJobReturns(result1 string, result2 error)
- func (fake *FakeJobSpawner) SpawnJobReturnsOnCall(i int, result1 string, result2 error)
- type FakeJobWatcher
- func (fake *FakeJobWatcher) HandleJob(arg1 context.Context, arg2 *v1.Job)
- func (fake *FakeJobWatcher) HandleJobArgsForCall(i int) (context.Context, *v1.Job)
- func (fake *FakeJobWatcher) HandleJobCallCount() int
- func (fake *FakeJobWatcher) HandleJobCalls(stub func(context.Context, *v1.Job))
- func (fake *FakeJobWatcher) HandlePod(arg1 context.Context, arg2 *v1a.Pod)
- func (fake *FakeJobWatcher) HandlePodArgsForCall(i int) (context.Context, *v1a.Pod)
- func (fake *FakeJobWatcher) HandlePodCallCount() int
- func (fake *FakeJobWatcher) HandlePodCalls(stub func(context.Context, *v1a.Pod))
- func (fake *FakeJobWatcher) Invocations() map[string][][]interface{}
- func (fake *FakeJobWatcher) PodLister() v1b.PodLister
- func (fake *FakeJobWatcher) PodListerCallCount() int
- func (fake *FakeJobWatcher) PodListerCalls(stub func() v1b.PodLister)
- func (fake *FakeJobWatcher) PodListerReturns(result1 v1b.PodLister)
- func (fake *FakeJobWatcher) PodListerReturnsOnCall(i int, result1 v1b.PodLister)
- func (fake *FakeJobWatcher) Run(arg1 context.Context) error
- func (fake *FakeJobWatcher) RunArgsForCall(i int) context.Context
- func (fake *FakeJobWatcher) RunCallCount() int
- func (fake *FakeJobWatcher) RunCalls(stub func(context.Context) error)
- func (fake *FakeJobWatcher) RunReturns(result1 error)
- func (fake *FakeJobWatcher) RunReturnsOnCall(i int, result1 error)
- type FakeK8sConnector
- func (fake *FakeK8sConnector) Invocations() map[string][][]interface{}
- func (fake *FakeK8sConnector) Listen(arg1 context.Context, arg2 k8s.Namespace, arg3 cache.ResourceEventHandler) error
- func (fake *FakeK8sConnector) ListenArgsForCall(i int) (context.Context, k8s.Namespace, cache.ResourceEventHandler)
- func (fake *FakeK8sConnector) ListenCallCount() int
- func (fake *FakeK8sConnector) ListenCalls(stub func(context.Context, k8s.Namespace, cache.ResourceEventHandler) error)
- func (fake *FakeK8sConnector) ListenReturns(result1 error)
- func (fake *FakeK8sConnector) ListenReturnsOnCall(i int, result1 error)
- func (fake *FakeK8sConnector) SetupCustomResourceDefinition(arg1 context.Context) error
- func (fake *FakeK8sConnector) SetupCustomResourceDefinitionArgsForCall(i int) context.Context
- func (fake *FakeK8sConnector) SetupCustomResourceDefinitionCallCount() int
- func (fake *FakeK8sConnector) SetupCustomResourceDefinitionCalls(stub func(context.Context) error)
- func (fake *FakeK8sConnector) SetupCustomResourceDefinitionReturns(result1 error)
- func (fake *FakeK8sConnector) SetupCustomResourceDefinitionReturnsOnCall(i int, result1 error)
- type FakeResultPublisher
- func (fake *FakeResultPublisher) Invocations() map[string][][]interface{}
- func (fake *FakeResultPublisher) PublishClearCurrentJob(arg1 context.Context, arg2 lib.Task, arg3 string) error
- func (fake *FakeResultPublisher) PublishClearCurrentJobArgsForCall(i int) (context.Context, lib.Task, string)
- func (fake *FakeResultPublisher) PublishClearCurrentJobCallCount() int
- func (fake *FakeResultPublisher) PublishClearCurrentJobCalls(stub func(context.Context, lib.Task, string) error)
- func (fake *FakeResultPublisher) PublishClearCurrentJobReturns(result1 error)
- func (fake *FakeResultPublisher) PublishClearCurrentJobReturnsOnCall(i int, result1 error)
- func (fake *FakeResultPublisher) PublishFailure(arg1 context.Context, arg2 lib.Task, arg3 string, arg4 string) error
- func (fake *FakeResultPublisher) PublishFailureArgsForCall(i int) (context.Context, lib.Task, string, string)
- func (fake *FakeResultPublisher) PublishFailureCallCount() int
- func (fake *FakeResultPublisher) PublishFailureCalls(stub func(context.Context, lib.Task, string, string) error)
- func (fake *FakeResultPublisher) PublishFailureReturns(result1 error)
- func (fake *FakeResultPublisher) PublishFailureReturnsOnCall(i int, result1 error)
- func (fake *FakeResultPublisher) PublishIncrementTriggerCount(arg1 context.Context, arg2 lib.Task) error
- func (fake *FakeResultPublisher) PublishIncrementTriggerCountArgsForCall(i int) (context.Context, lib.Task)
- func (fake *FakeResultPublisher) PublishIncrementTriggerCountCallCount() int
- func (fake *FakeResultPublisher) PublishIncrementTriggerCountCalls(stub func(context.Context, lib.Task) error)
- func (fake *FakeResultPublisher) PublishIncrementTriggerCountReturns(result1 error)
- func (fake *FakeResultPublisher) PublishIncrementTriggerCountReturnsOnCall(i int, result1 error)
- func (fake *FakeResultPublisher) PublishQueueEntry(arg1 context.Context, arg2 lib.Task, arg3 string) error
- func (fake *FakeResultPublisher) PublishQueueEntryArgsForCall(i int) (context.Context, lib.Task, string)
- func (fake *FakeResultPublisher) PublishQueueEntryCallCount() int
- func (fake *FakeResultPublisher) PublishQueueEntryCalls(stub func(context.Context, lib.Task, string) error)
- func (fake *FakeResultPublisher) PublishQueueEntryReturns(result1 error)
- func (fake *FakeResultPublisher) PublishQueueEntryReturnsOnCall(i int, result1 error)
- func (fake *FakeResultPublisher) PublishRaw(arg1 context.Context, arg2 base.CommandOperation, arg3 interface{}) error
- func (fake *FakeResultPublisher) PublishRawArgsForCall(i int) (context.Context, base.CommandOperation, interface{})
- func (fake *FakeResultPublisher) PublishRawCallCount() int
- func (fake *FakeResultPublisher) PublishRawCalls(stub func(context.Context, base.CommandOperation, interface{}) error)
- func (fake *FakeResultPublisher) PublishRawReturns(result1 error)
- func (fake *FakeResultPublisher) PublishRawReturnsOnCall(i int, result1 error)
- func (fake *FakeResultPublisher) PublishRestoreAssignee(arg1 context.Context, arg2 lib.Task, arg3 string) error
- func (fake *FakeResultPublisher) PublishRestoreAssigneeArgsForCall(i int) (context.Context, lib.Task, string)
- func (fake *FakeResultPublisher) PublishRestoreAssigneeCallCount() int
- func (fake *FakeResultPublisher) PublishRestoreAssigneeCalls(stub func(context.Context, lib.Task, string) error)
- func (fake *FakeResultPublisher) PublishRestoreAssigneeReturns(result1 error)
- func (fake *FakeResultPublisher) PublishRestoreAssigneeReturnsOnCall(i int, result1 error)
- func (fake *FakeResultPublisher) PublishSetTriggerScope(arg1 context.Context, arg2 lib.Task, arg3 string, arg4 int) error
- func (fake *FakeResultPublisher) PublishSetTriggerScopeArgsForCall(i int) (context.Context, lib.Task, string, int)
- func (fake *FakeResultPublisher) PublishSetTriggerScopeCallCount() int
- func (fake *FakeResultPublisher) PublishSetTriggerScopeCalls(stub func(context.Context, lib.Task, string, int) error)
- func (fake *FakeResultPublisher) PublishSetTriggerScopeReturns(result1 error)
- func (fake *FakeResultPublisher) PublishSetTriggerScopeReturnsOnCall(i int, result1 error)
- func (fake *FakeResultPublisher) PublishSpawnNotification(arg1 context.Context, arg2 lib.Task, arg3 string) error
- func (fake *FakeResultPublisher) PublishSpawnNotificationArgsForCall(i int) (context.Context, lib.Task, string)
- func (fake *FakeResultPublisher) PublishSpawnNotificationCallCount() int
- func (fake *FakeResultPublisher) PublishSpawnNotificationCalls(stub func(context.Context, lib.Task, string) error)
- func (fake *FakeResultPublisher) PublishSpawnNotificationReturns(result1 error)
- func (fake *FakeResultPublisher) PublishSpawnNotificationReturnsOnCall(i int, result1 error)
- func (fake *FakeResultPublisher) PublishTypeMismatchFailure(arg1 context.Context, arg2 lib.Task, arg3 string) error
- func (fake *FakeResultPublisher) PublishTypeMismatchFailureArgsForCall(i int) (context.Context, lib.Task, string)
- func (fake *FakeResultPublisher) PublishTypeMismatchFailureCallCount() int
- func (fake *FakeResultPublisher) PublishTypeMismatchFailureCalls(stub func(context.Context, lib.Task, string) error)
- func (fake *FakeResultPublisher) PublishTypeMismatchFailureReturns(result1 error)
- func (fake *FakeResultPublisher) PublishTypeMismatchFailureReturnsOnCall(i int, result1 error)
- type FakeServiceReconcileLoop
- func (fake *FakeServiceReconcileLoop) Invocations() map[string][][]interface{}
- func (fake *FakeServiceReconcileLoop) ReconcileOnce(arg1 context.Context) error
- func (fake *FakeServiceReconcileLoop) ReconcileOnceArgsForCall(i int) context.Context
- func (fake *FakeServiceReconcileLoop) ReconcileOnceCallCount() int
- func (fake *FakeServiceReconcileLoop) ReconcileOnceCalls(stub func(context.Context) error)
- func (fake *FakeServiceReconcileLoop) ReconcileOnceReturns(result1 error)
- func (fake *FakeServiceReconcileLoop) ReconcileOnceReturnsOnCall(i int, result1 error)
- func (fake *FakeServiceReconcileLoop) Run(arg1 context.Context) error
- func (fake *FakeServiceReconcileLoop) RunArgsForCall(i int) context.Context
- func (fake *FakeServiceReconcileLoop) RunCallCount() int
- func (fake *FakeServiceReconcileLoop) RunCalls(stub func(context.Context) error)
- func (fake *FakeServiceReconcileLoop) RunReturns(result1 error)
- func (fake *FakeServiceReconcileLoop) RunReturnsOnCall(i int, result1 error)
- type FakeServiceReconciler
- func (fake *FakeServiceReconciler) Invocations() map[string][][]interface{}
- func (fake *FakeServiceReconciler) ReconcileService(arg1 context.Context, arg2 v1.Config, arg3 pkg.AgentConfiguration) error
- func (fake *FakeServiceReconciler) ReconcileServiceArgsForCall(i int) (context.Context, v1.Config, pkg.AgentConfiguration)
- func (fake *FakeServiceReconciler) ReconcileServiceCallCount() int
- func (fake *FakeServiceReconciler) ReconcileServiceCalls(stub func(context.Context, v1.Config, pkg.AgentConfiguration) error)
- func (fake *FakeServiceReconciler) ReconcileServiceReturns(result1 error)
- func (fake *FakeServiceReconciler) ReconcileServiceReturnsOnCall(i int, result1 error)
- func (fake *FakeServiceReconciler) UndeployService(arg1 context.Context, arg2 string) error
- func (fake *FakeServiceReconciler) UndeployServiceArgsForCall(i int) (context.Context, string)
- func (fake *FakeServiceReconciler) UndeployServiceCallCount() int
- func (fake *FakeServiceReconciler) UndeployServiceCalls(stub func(context.Context, string) error)
- func (fake *FakeServiceReconciler) UndeployServiceReturns(result1 error)
- func (fake *FakeServiceReconciler) UndeployServiceReturnsOnCall(i int, result1 error)
- type FakeTaskEventHandler
- func (fake *FakeTaskEventHandler) ConsumeMessage(arg1 context.Context, arg2 *sarama.ConsumerMessage) error
- func (fake *FakeTaskEventHandler) ConsumeMessageArgsForCall(i int) (context.Context, *sarama.ConsumerMessage)
- func (fake *FakeTaskEventHandler) ConsumeMessageCallCount() int
- func (fake *FakeTaskEventHandler) ConsumeMessageCalls(stub func(context.Context, *sarama.ConsumerMessage) error)
- func (fake *FakeTaskEventHandler) ConsumeMessageReturns(result1 error)
- func (fake *FakeTaskEventHandler) ConsumeMessageReturnsOnCall(i int, result1 error)
- func (fake *FakeTaskEventHandler) EvalDeferredRespawns(arg1 context.Context) error
- func (fake *FakeTaskEventHandler) EvalDeferredRespawnsArgsForCall(i int) context.Context
- func (fake *FakeTaskEventHandler) EvalDeferredRespawnsCallCount() int
- func (fake *FakeTaskEventHandler) EvalDeferredRespawnsCalls(stub func(context.Context) error)
- func (fake *FakeTaskEventHandler) EvalDeferredRespawnsReturns(result1 error)
- func (fake *FakeTaskEventHandler) EvalDeferredRespawnsReturnsOnCall(i int, result1 error)
- func (fake *FakeTaskEventHandler) Invocations() map[string][][]interface{}
- func (fake *FakeTaskEventHandler) ReconcileOnce(arg1 context.Context) error
- func (fake *FakeTaskEventHandler) ReconcileOnceArgsForCall(i int) context.Context
- func (fake *FakeTaskEventHandler) ReconcileOnceCallCount() int
- func (fake *FakeTaskEventHandler) ReconcileOnceCalls(stub func(context.Context) error)
- func (fake *FakeTaskEventHandler) ReconcileOnceReturns(result1 error)
- func (fake *FakeTaskEventHandler) ReconcileOnceReturnsOnCall(i int, result1 error)
- func (fake *FakeTaskEventHandler) RunDeferredRespawnLoop(arg1 context.Context) error
- func (fake *FakeTaskEventHandler) RunDeferredRespawnLoopArgsForCall(i int) context.Context
- func (fake *FakeTaskEventHandler) RunDeferredRespawnLoopCallCount() int
- func (fake *FakeTaskEventHandler) RunDeferredRespawnLoopCalls(stub func(context.Context) error)
- func (fake *FakeTaskEventHandler) RunDeferredRespawnLoopReturns(result1 error)
- func (fake *FakeTaskEventHandler) RunDeferredRespawnLoopReturnsOnCall(i int, result1 error)
- func (fake *FakeTaskEventHandler) RunReconcileLoop(arg1 context.Context) error
- func (fake *FakeTaskEventHandler) RunReconcileLoopArgsForCall(i int) context.Context
- func (fake *FakeTaskEventHandler) RunReconcileLoopCallCount() int
- func (fake *FakeTaskEventHandler) RunReconcileLoopCalls(stub func(context.Context) error)
- func (fake *FakeTaskEventHandler) RunReconcileLoopReturns(result1 error)
- func (fake *FakeTaskEventHandler) RunReconcileLoopReturnsOnCall(i int, result1 error)
- type FakeTaskView
- func (fake *FakeTaskView) CaptureHighWaterMarks(arg1 context.Context) error
- func (fake *FakeTaskView) CaptureHighWaterMarksArgsForCall(i int) context.Context
- func (fake *FakeTaskView) CaptureHighWaterMarksCallCount() int
- func (fake *FakeTaskView) CaptureHighWaterMarksCalls(stub func(context.Context) error)
- func (fake *FakeTaskView) CaptureHighWaterMarksReturns(result1 error)
- func (fake *FakeTaskView) CaptureHighWaterMarksReturnsOnCall(i int, result1 error)
- func (fake *FakeTaskView) ConsumeMessage(arg1 context.Context, arg2 *sarama.ConsumerMessage) error
- func (fake *FakeTaskView) ConsumeMessageArgsForCall(i int) (context.Context, *sarama.ConsumerMessage)
- func (fake *FakeTaskView) ConsumeMessageCallCount() int
- func (fake *FakeTaskView) ConsumeMessageCalls(stub func(context.Context, *sarama.ConsumerMessage) error)
- func (fake *FakeTaskView) ConsumeMessageReturns(result1 error)
- func (fake *FakeTaskView) ConsumeMessageReturnsOnCall(i int, result1 error)
- func (fake *FakeTaskView) Get(arg1 lib.TaskIdentifier) (lib.Task, bool)
- func (fake *FakeTaskView) GetArgsForCall(i int) lib.TaskIdentifier
- func (fake *FakeTaskView) GetCallCount() int
- func (fake *FakeTaskView) GetCalls(stub func(lib.TaskIdentifier) (lib.Task, bool))
- func (fake *FakeTaskView) GetReturns(result1 lib.Task, result2 bool)
- func (fake *FakeTaskView) GetReturnsOnCall(i int, result1 lib.Task, result2 bool)
- func (fake *FakeTaskView) Invocations() map[string][][]interface{}
- func (fake *FakeTaskView) Ready() bool
- func (fake *FakeTaskView) ReadyCallCount() int
- func (fake *FakeTaskView) ReadyCalls(stub func() bool)
- func (fake *FakeTaskView) ReadyReturns(result1 bool)
- func (fake *FakeTaskView) ReadyReturnsOnCall(i int, result1 bool)
- func (fake *FakeTaskView) Snapshot() []lib.Task
- func (fake *FakeTaskView) SnapshotCallCount() int
- func (fake *FakeTaskView) SnapshotCalls(stub func() []lib.Task)
- func (fake *FakeTaskView) SnapshotReturns(result1 []lib.Task)
- func (fake *FakeTaskView) SnapshotReturnsOnCall(i int, result1 []lib.Task)
- type FakeZombieSweeper
- func (fake *FakeZombieSweeper) Invocations() map[string][][]interface{}
- func (fake *FakeZombieSweeper) Run(arg1 context.Context) error
- func (fake *FakeZombieSweeper) RunArgsForCall(i int) context.Context
- func (fake *FakeZombieSweeper) RunCallCount() int
- func (fake *FakeZombieSweeper) RunCalls(stub func(context.Context) error)
- func (fake *FakeZombieSweeper) RunReturns(result1 error)
- func (fake *FakeZombieSweeper) RunReturnsOnCall(i int, result1 error)
- func (fake *FakeZombieSweeper) SweepOnce(arg1 context.Context) error
- func (fake *FakeZombieSweeper) SweepOnceArgsForCall(i int) context.Context
- func (fake *FakeZombieSweeper) SweepOnceCallCount() int
- func (fake *FakeZombieSweeper) SweepOnceCalls(stub func(context.Context) error)
- func (fake *FakeZombieSweeper) SweepOnceReturns(result1 error)
- func (fake *FakeZombieSweeper) SweepOnceReturnsOnCall(i int, result1 error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FakeClaimJobControl ¶ added in v0.24.0
type FakeClaimJobControl struct {
DeleteJobStub func(context.Context, string) error
IsJobRunningStub func(context.Context, string) (bool, error)
// contains filtered or unexported fields
}
func (*FakeClaimJobControl) DeleteJob ¶ added in v0.24.0
func (fake *FakeClaimJobControl) DeleteJob(arg1 context.Context, arg2 string) error
func (*FakeClaimJobControl) DeleteJobArgsForCall ¶ added in v0.24.0
func (fake *FakeClaimJobControl) DeleteJobArgsForCall(i int) (context.Context, string)
func (*FakeClaimJobControl) DeleteJobCallCount ¶ added in v0.24.0
func (fake *FakeClaimJobControl) DeleteJobCallCount() int
func (*FakeClaimJobControl) DeleteJobCalls ¶ added in v0.24.0
func (fake *FakeClaimJobControl) DeleteJobCalls(stub func(context.Context, string) error)
func (*FakeClaimJobControl) DeleteJobReturns ¶ added in v0.24.0
func (fake *FakeClaimJobControl) DeleteJobReturns(result1 error)
func (*FakeClaimJobControl) DeleteJobReturnsOnCall ¶ added in v0.24.0
func (fake *FakeClaimJobControl) DeleteJobReturnsOnCall(i int, result1 error)
func (*FakeClaimJobControl) Invocations ¶ added in v0.24.0
func (fake *FakeClaimJobControl) Invocations() map[string][][]interface{}
func (*FakeClaimJobControl) IsJobRunning ¶ added in v0.24.0
func (*FakeClaimJobControl) IsJobRunningArgsForCall ¶ added in v0.24.0
func (fake *FakeClaimJobControl) IsJobRunningArgsForCall(i int) (context.Context, string)
func (*FakeClaimJobControl) IsJobRunningCallCount ¶ added in v0.24.0
func (fake *FakeClaimJobControl) IsJobRunningCallCount() int
func (*FakeClaimJobControl) IsJobRunningCalls ¶ added in v0.24.0
func (*FakeClaimJobControl) IsJobRunningReturns ¶ added in v0.24.0
func (fake *FakeClaimJobControl) IsJobRunningReturns(result1 bool, result2 error)
func (*FakeClaimJobControl) IsJobRunningReturnsOnCall ¶ added in v0.24.0
func (fake *FakeClaimJobControl) IsJobRunningReturnsOnCall(i int, result1 bool, result2 error)
type FakeClaimRefClient ¶ added in v0.24.0
type FakeClaimRefClient struct {
DeleteStub func(context.Context, string, string) error
ListStub func(context.Context, string) ([]claim.ClaimRef, error)
PutStub func(context.Context, string, string, string, string, time.DateTime) (string, error)
// contains filtered or unexported fields
}
func (*FakeClaimRefClient) DeleteArgsForCall ¶ added in v0.24.0
func (*FakeClaimRefClient) DeleteCallCount ¶ added in v0.24.0
func (fake *FakeClaimRefClient) DeleteCallCount() int
func (*FakeClaimRefClient) DeleteCalls ¶ added in v0.24.0
func (*FakeClaimRefClient) DeleteReturns ¶ added in v0.24.0
func (fake *FakeClaimRefClient) DeleteReturns(result1 error)
func (*FakeClaimRefClient) DeleteReturnsOnCall ¶ added in v0.24.0
func (fake *FakeClaimRefClient) DeleteReturnsOnCall(i int, result1 error)
func (*FakeClaimRefClient) Invocations ¶ added in v0.24.0
func (fake *FakeClaimRefClient) Invocations() map[string][][]interface{}
func (*FakeClaimRefClient) ListArgsForCall ¶ added in v0.24.0
func (fake *FakeClaimRefClient) ListArgsForCall(i int) (context.Context, string)
func (*FakeClaimRefClient) ListCallCount ¶ added in v0.24.0
func (fake *FakeClaimRefClient) ListCallCount() int
func (*FakeClaimRefClient) ListReturns ¶ added in v0.24.0
func (fake *FakeClaimRefClient) ListReturns(result1 []claim.ClaimRef, result2 error)
func (*FakeClaimRefClient) ListReturnsOnCall ¶ added in v0.24.0
func (fake *FakeClaimRefClient) ListReturnsOnCall(i int, result1 []claim.ClaimRef, result2 error)
func (*FakeClaimRefClient) PutArgsForCall ¶ added in v0.24.0
func (*FakeClaimRefClient) PutCallCount ¶ added in v0.24.0
func (fake *FakeClaimRefClient) PutCallCount() int
func (*FakeClaimRefClient) PutReturns ¶ added in v0.24.0
func (fake *FakeClaimRefClient) PutReturns(result1 string, result2 error)
func (*FakeClaimRefClient) PutReturnsOnCall ¶ added in v0.24.0
func (fake *FakeClaimRefClient) PutReturnsOnCall(i int, result1 string, result2 error)
type FakeConfigResolver ¶
type FakeConfigResolver struct {
ResolveStub func(context.Context, string) (pkg.AgentConfiguration, error)
ResolveByTaskTypeStub func(context.Context, string, string) (pkg.AgentConfiguration, error)
// contains filtered or unexported fields
}
func (*FakeConfigResolver) Invocations ¶
func (fake *FakeConfigResolver) Invocations() map[string][][]interface{}
func (*FakeConfigResolver) Resolve ¶
func (fake *FakeConfigResolver) Resolve(arg1 context.Context, arg2 string) (pkg.AgentConfiguration, error)
func (*FakeConfigResolver) ResolveArgsForCall ¶
func (fake *FakeConfigResolver) ResolveArgsForCall(i int) (context.Context, string)
func (*FakeConfigResolver) ResolveByTaskType ¶ added in v0.18.11
func (fake *FakeConfigResolver) ResolveByTaskType(arg1 context.Context, arg2 string, arg3 string) (pkg.AgentConfiguration, error)
func (*FakeConfigResolver) ResolveByTaskTypeArgsForCall ¶ added in v0.18.11
func (*FakeConfigResolver) ResolveByTaskTypeCallCount ¶ added in v0.18.11
func (fake *FakeConfigResolver) ResolveByTaskTypeCallCount() int
func (*FakeConfigResolver) ResolveByTaskTypeCalls ¶ added in v0.18.11
func (fake *FakeConfigResolver) ResolveByTaskTypeCalls(stub func(context.Context, string, string) (pkg.AgentConfiguration, error))
func (*FakeConfigResolver) ResolveByTaskTypeReturns ¶ added in v0.18.11
func (fake *FakeConfigResolver) ResolveByTaskTypeReturns(result1 pkg.AgentConfiguration, result2 error)
func (*FakeConfigResolver) ResolveByTaskTypeReturnsOnCall ¶ added in v0.18.11
func (fake *FakeConfigResolver) ResolveByTaskTypeReturnsOnCall(i int, result1 pkg.AgentConfiguration, result2 error)
func (*FakeConfigResolver) ResolveCallCount ¶
func (fake *FakeConfigResolver) ResolveCallCount() int
func (*FakeConfigResolver) ResolveCalls ¶
func (fake *FakeConfigResolver) ResolveCalls(stub func(context.Context, string) (pkg.AgentConfiguration, error))
func (*FakeConfigResolver) ResolveReturns ¶
func (fake *FakeConfigResolver) ResolveReturns(result1 pkg.AgentConfiguration, result2 error)
func (*FakeConfigResolver) ResolveReturnsOnCall ¶
func (fake *FakeConfigResolver) ResolveReturnsOnCall(i int, result1 pkg.AgentConfiguration, result2 error)
type FakeJobSpawner ¶
type FakeJobSpawner struct {
CountActiveJobsStub func(context.Context, string) (int, error)
IsJobActiveStub func(context.Context, lib.TaskIdentifier) (bool, error)
ListActiveJobsStub func(context.Context, string) (map[lib.TaskIdentifier]bool, error)
SpawnJobStub func(context.Context, lib.Task, pkg.AgentConfiguration) (string, error)
// contains filtered or unexported fields
}
func (*FakeJobSpawner) CountActiveJobs ¶ added in v0.5.0
func (*FakeJobSpawner) CountActiveJobsArgsForCall ¶ added in v0.5.0
func (fake *FakeJobSpawner) CountActiveJobsArgsForCall(i int) (context.Context, string)
func (*FakeJobSpawner) CountActiveJobsCallCount ¶ added in v0.5.0
func (fake *FakeJobSpawner) CountActiveJobsCallCount() int
func (*FakeJobSpawner) CountActiveJobsCalls ¶ added in v0.5.0
func (*FakeJobSpawner) CountActiveJobsReturns ¶ added in v0.5.0
func (fake *FakeJobSpawner) CountActiveJobsReturns(result1 int, result2 error)
func (*FakeJobSpawner) CountActiveJobsReturnsOnCall ¶ added in v0.5.0
func (fake *FakeJobSpawner) CountActiveJobsReturnsOnCall(i int, result1 int, result2 error)
func (*FakeJobSpawner) Invocations ¶
func (fake *FakeJobSpawner) Invocations() map[string][][]interface{}
func (*FakeJobSpawner) IsJobActive ¶
func (fake *FakeJobSpawner) IsJobActive(arg1 context.Context, arg2 lib.TaskIdentifier) (bool, error)
func (*FakeJobSpawner) IsJobActiveArgsForCall ¶
func (fake *FakeJobSpawner) IsJobActiveArgsForCall(i int) (context.Context, lib.TaskIdentifier)
func (*FakeJobSpawner) IsJobActiveCallCount ¶
func (fake *FakeJobSpawner) IsJobActiveCallCount() int
func (*FakeJobSpawner) IsJobActiveCalls ¶
func (fake *FakeJobSpawner) IsJobActiveCalls(stub func(context.Context, lib.TaskIdentifier) (bool, error))
func (*FakeJobSpawner) IsJobActiveReturns ¶
func (fake *FakeJobSpawner) IsJobActiveReturns(result1 bool, result2 error)
func (*FakeJobSpawner) IsJobActiveReturnsOnCall ¶
func (fake *FakeJobSpawner) IsJobActiveReturnsOnCall(i int, result1 bool, result2 error)
func (*FakeJobSpawner) ListActiveJobs ¶ added in v0.18.13
func (fake *FakeJobSpawner) ListActiveJobs(arg1 context.Context, arg2 string) (map[lib.TaskIdentifier]bool, error)
func (*FakeJobSpawner) ListActiveJobsArgsForCall ¶ added in v0.18.13
func (fake *FakeJobSpawner) ListActiveJobsArgsForCall(i int) (context.Context, string)
func (*FakeJobSpawner) ListActiveJobsCallCount ¶ added in v0.18.13
func (fake *FakeJobSpawner) ListActiveJobsCallCount() int
func (*FakeJobSpawner) ListActiveJobsCalls ¶ added in v0.18.13
func (fake *FakeJobSpawner) ListActiveJobsCalls(stub func(context.Context, string) (map[lib.TaskIdentifier]bool, error))
func (*FakeJobSpawner) ListActiveJobsReturns ¶ added in v0.18.13
func (fake *FakeJobSpawner) ListActiveJobsReturns(result1 map[lib.TaskIdentifier]bool, result2 error)
func (*FakeJobSpawner) ListActiveJobsReturnsOnCall ¶ added in v0.18.13
func (fake *FakeJobSpawner) ListActiveJobsReturnsOnCall(i int, result1 map[lib.TaskIdentifier]bool, result2 error)
func (*FakeJobSpawner) SpawnJob ¶
func (fake *FakeJobSpawner) SpawnJob(arg1 context.Context, arg2 lib.Task, arg3 pkg.AgentConfiguration) (string, error)
func (*FakeJobSpawner) SpawnJobArgsForCall ¶
func (fake *FakeJobSpawner) SpawnJobArgsForCall(i int) (context.Context, lib.Task, pkg.AgentConfiguration)
func (*FakeJobSpawner) SpawnJobCallCount ¶
func (fake *FakeJobSpawner) SpawnJobCallCount() int
func (*FakeJobSpawner) SpawnJobCalls ¶
func (fake *FakeJobSpawner) SpawnJobCalls(stub func(context.Context, lib.Task, pkg.AgentConfiguration) (string, error))
func (*FakeJobSpawner) SpawnJobReturns ¶
func (fake *FakeJobSpawner) SpawnJobReturns(result1 string, result2 error)
func (*FakeJobSpawner) SpawnJobReturnsOnCall ¶
func (fake *FakeJobSpawner) SpawnJobReturnsOnCall(i int, result1 string, result2 error)
type FakeJobWatcher ¶
type FakeJobWatcher struct {
HandleJobStub func(context.Context, *v1.Job)
HandlePodStub func(context.Context, *v1a.Pod)
PodListerStub func() v1b.PodLister
RunStub func(context.Context) error
// contains filtered or unexported fields
}
func (*FakeJobWatcher) HandleJob ¶
func (fake *FakeJobWatcher) HandleJob(arg1 context.Context, arg2 *v1.Job)
func (*FakeJobWatcher) HandleJobArgsForCall ¶
func (*FakeJobWatcher) HandleJobCallCount ¶
func (fake *FakeJobWatcher) HandleJobCallCount() int
func (*FakeJobWatcher) HandleJobCalls ¶
func (fake *FakeJobWatcher) HandleJobCalls(stub func(context.Context, *v1.Job))
func (*FakeJobWatcher) HandlePod ¶
func (fake *FakeJobWatcher) HandlePod(arg1 context.Context, arg2 *v1a.Pod)
func (*FakeJobWatcher) HandlePodArgsForCall ¶
func (*FakeJobWatcher) HandlePodCallCount ¶
func (fake *FakeJobWatcher) HandlePodCallCount() int
func (*FakeJobWatcher) HandlePodCalls ¶
func (fake *FakeJobWatcher) HandlePodCalls(stub func(context.Context, *v1a.Pod))
func (*FakeJobWatcher) Invocations ¶
func (fake *FakeJobWatcher) Invocations() map[string][][]interface{}
func (*FakeJobWatcher) PodLister ¶
func (fake *FakeJobWatcher) PodLister() v1b.PodLister
func (*FakeJobWatcher) PodListerCallCount ¶
func (fake *FakeJobWatcher) PodListerCallCount() int
func (*FakeJobWatcher) PodListerCalls ¶
func (fake *FakeJobWatcher) PodListerCalls(stub func() v1b.PodLister)
func (*FakeJobWatcher) PodListerReturns ¶
func (fake *FakeJobWatcher) PodListerReturns(result1 v1b.PodLister)
func (*FakeJobWatcher) PodListerReturnsOnCall ¶
func (fake *FakeJobWatcher) PodListerReturnsOnCall(i int, result1 v1b.PodLister)
func (*FakeJobWatcher) RunArgsForCall ¶
func (fake *FakeJobWatcher) RunArgsForCall(i int) context.Context
func (*FakeJobWatcher) RunCallCount ¶
func (fake *FakeJobWatcher) RunCallCount() int
func (*FakeJobWatcher) RunCalls ¶
func (fake *FakeJobWatcher) RunCalls(stub func(context.Context) error)
func (*FakeJobWatcher) RunReturns ¶
func (fake *FakeJobWatcher) RunReturns(result1 error)
func (*FakeJobWatcher) RunReturnsOnCall ¶
func (fake *FakeJobWatcher) RunReturnsOnCall(i int, result1 error)
type FakeK8sConnector ¶
type FakeK8sConnector struct {
ListenStub func(context.Context, k8s.Namespace, cache.ResourceEventHandler) error
SetupCustomResourceDefinitionStub func(context.Context) error
// contains filtered or unexported fields
}
func (*FakeK8sConnector) Invocations ¶
func (fake *FakeK8sConnector) Invocations() map[string][][]interface{}
func (*FakeK8sConnector) Listen ¶
func (fake *FakeK8sConnector) Listen(arg1 context.Context, arg2 k8s.Namespace, arg3 cache.ResourceEventHandler) error
func (*FakeK8sConnector) ListenArgsForCall ¶
func (fake *FakeK8sConnector) ListenArgsForCall(i int) (context.Context, k8s.Namespace, cache.ResourceEventHandler)
func (*FakeK8sConnector) ListenCallCount ¶
func (fake *FakeK8sConnector) ListenCallCount() int
func (*FakeK8sConnector) ListenCalls ¶
func (fake *FakeK8sConnector) ListenCalls(stub func(context.Context, k8s.Namespace, cache.ResourceEventHandler) error)
func (*FakeK8sConnector) ListenReturns ¶
func (fake *FakeK8sConnector) ListenReturns(result1 error)
func (*FakeK8sConnector) ListenReturnsOnCall ¶
func (fake *FakeK8sConnector) ListenReturnsOnCall(i int, result1 error)
func (*FakeK8sConnector) SetupCustomResourceDefinition ¶
func (fake *FakeK8sConnector) SetupCustomResourceDefinition(arg1 context.Context) error
func (*FakeK8sConnector) SetupCustomResourceDefinitionArgsForCall ¶
func (fake *FakeK8sConnector) SetupCustomResourceDefinitionArgsForCall(i int) context.Context
func (*FakeK8sConnector) SetupCustomResourceDefinitionCallCount ¶
func (fake *FakeK8sConnector) SetupCustomResourceDefinitionCallCount() int
func (*FakeK8sConnector) SetupCustomResourceDefinitionCalls ¶
func (fake *FakeK8sConnector) SetupCustomResourceDefinitionCalls(stub func(context.Context) error)
func (*FakeK8sConnector) SetupCustomResourceDefinitionReturns ¶
func (fake *FakeK8sConnector) SetupCustomResourceDefinitionReturns(result1 error)
func (*FakeK8sConnector) SetupCustomResourceDefinitionReturnsOnCall ¶
func (fake *FakeK8sConnector) SetupCustomResourceDefinitionReturnsOnCall(i int, result1 error)
type FakeResultPublisher ¶
type FakeResultPublisher struct {
PublishClearCurrentJobStub func(context.Context, lib.Task, string) error
PublishFailureStub func(context.Context, lib.Task, string, string) error
PublishIncrementTriggerCountStub func(context.Context, lib.Task) error
PublishQueueEntryStub func(context.Context, lib.Task, string) error
PublishRawStub func(context.Context, base.CommandOperation, interface{}) error
PublishRestoreAssigneeStub func(context.Context, lib.Task, string) error
PublishSetTriggerScopeStub func(context.Context, lib.Task, string, int) error
PublishSpawnNotificationStub func(context.Context, lib.Task, string) error
PublishTypeMismatchFailureStub func(context.Context, lib.Task, string) error
// contains filtered or unexported fields
}
func (*FakeResultPublisher) Invocations ¶
func (fake *FakeResultPublisher) Invocations() map[string][][]interface{}
func (*FakeResultPublisher) PublishClearCurrentJob ¶ added in v0.9.1
func (*FakeResultPublisher) PublishClearCurrentJobArgsForCall ¶ added in v0.9.1
func (*FakeResultPublisher) PublishClearCurrentJobCallCount ¶ added in v0.9.1
func (fake *FakeResultPublisher) PublishClearCurrentJobCallCount() int
func (*FakeResultPublisher) PublishClearCurrentJobCalls ¶ added in v0.9.1
func (*FakeResultPublisher) PublishClearCurrentJobReturns ¶ added in v0.9.1
func (fake *FakeResultPublisher) PublishClearCurrentJobReturns(result1 error)
func (*FakeResultPublisher) PublishClearCurrentJobReturnsOnCall ¶ added in v0.9.1
func (fake *FakeResultPublisher) PublishClearCurrentJobReturnsOnCall(i int, result1 error)
func (*FakeResultPublisher) PublishFailure ¶
func (*FakeResultPublisher) PublishFailureArgsForCall ¶
func (*FakeResultPublisher) PublishFailureCallCount ¶
func (fake *FakeResultPublisher) PublishFailureCallCount() int
func (*FakeResultPublisher) PublishFailureCalls ¶
func (*FakeResultPublisher) PublishFailureReturns ¶
func (fake *FakeResultPublisher) PublishFailureReturns(result1 error)
func (*FakeResultPublisher) PublishFailureReturnsOnCall ¶
func (fake *FakeResultPublisher) PublishFailureReturnsOnCall(i int, result1 error)
func (*FakeResultPublisher) PublishIncrementTriggerCount ¶
func (*FakeResultPublisher) PublishIncrementTriggerCountArgsForCall ¶
func (*FakeResultPublisher) PublishIncrementTriggerCountCallCount ¶
func (fake *FakeResultPublisher) PublishIncrementTriggerCountCallCount() int
func (*FakeResultPublisher) PublishIncrementTriggerCountCalls ¶
func (*FakeResultPublisher) PublishIncrementTriggerCountReturns ¶
func (fake *FakeResultPublisher) PublishIncrementTriggerCountReturns(result1 error)
func (*FakeResultPublisher) PublishIncrementTriggerCountReturnsOnCall ¶
func (fake *FakeResultPublisher) PublishIncrementTriggerCountReturnsOnCall(i int, result1 error)
func (*FakeResultPublisher) PublishQueueEntry ¶ added in v0.19.0
func (*FakeResultPublisher) PublishQueueEntryArgsForCall ¶ added in v0.19.0
func (*FakeResultPublisher) PublishQueueEntryCallCount ¶ added in v0.19.0
func (fake *FakeResultPublisher) PublishQueueEntryCallCount() int
func (*FakeResultPublisher) PublishQueueEntryCalls ¶ added in v0.19.0
func (*FakeResultPublisher) PublishQueueEntryReturns ¶ added in v0.19.0
func (fake *FakeResultPublisher) PublishQueueEntryReturns(result1 error)
func (*FakeResultPublisher) PublishQueueEntryReturnsOnCall ¶ added in v0.19.0
func (fake *FakeResultPublisher) PublishQueueEntryReturnsOnCall(i int, result1 error)
func (*FakeResultPublisher) PublishRaw ¶
func (fake *FakeResultPublisher) PublishRaw(arg1 context.Context, arg2 base.CommandOperation, arg3 interface{}) error
func (*FakeResultPublisher) PublishRawArgsForCall ¶
func (fake *FakeResultPublisher) PublishRawArgsForCall(i int) (context.Context, base.CommandOperation, interface{})
func (*FakeResultPublisher) PublishRawCallCount ¶
func (fake *FakeResultPublisher) PublishRawCallCount() int
func (*FakeResultPublisher) PublishRawCalls ¶
func (fake *FakeResultPublisher) PublishRawCalls(stub func(context.Context, base.CommandOperation, interface{}) error)
func (*FakeResultPublisher) PublishRawReturns ¶
func (fake *FakeResultPublisher) PublishRawReturns(result1 error)
func (*FakeResultPublisher) PublishRawReturnsOnCall ¶
func (fake *FakeResultPublisher) PublishRawReturnsOnCall(i int, result1 error)
func (*FakeResultPublisher) PublishRestoreAssignee ¶ added in v0.18.11
func (*FakeResultPublisher) PublishRestoreAssigneeArgsForCall ¶ added in v0.18.11
func (*FakeResultPublisher) PublishRestoreAssigneeCallCount ¶ added in v0.18.11
func (fake *FakeResultPublisher) PublishRestoreAssigneeCallCount() int
func (*FakeResultPublisher) PublishRestoreAssigneeCalls ¶ added in v0.18.11
func (*FakeResultPublisher) PublishRestoreAssigneeReturns ¶ added in v0.18.11
func (fake *FakeResultPublisher) PublishRestoreAssigneeReturns(result1 error)
func (*FakeResultPublisher) PublishRestoreAssigneeReturnsOnCall ¶ added in v0.18.11
func (fake *FakeResultPublisher) PublishRestoreAssigneeReturnsOnCall(i int, result1 error)
func (*FakeResultPublisher) PublishSetTriggerScope ¶ added in v0.8.0
func (*FakeResultPublisher) PublishSetTriggerScopeArgsForCall ¶ added in v0.8.0
func (*FakeResultPublisher) PublishSetTriggerScopeCallCount ¶ added in v0.8.0
func (fake *FakeResultPublisher) PublishSetTriggerScopeCallCount() int
func (*FakeResultPublisher) PublishSetTriggerScopeCalls ¶ added in v0.8.0
func (*FakeResultPublisher) PublishSetTriggerScopeReturns ¶ added in v0.8.0
func (fake *FakeResultPublisher) PublishSetTriggerScopeReturns(result1 error)
func (*FakeResultPublisher) PublishSetTriggerScopeReturnsOnCall ¶ added in v0.8.0
func (fake *FakeResultPublisher) PublishSetTriggerScopeReturnsOnCall(i int, result1 error)
func (*FakeResultPublisher) PublishSpawnNotification ¶
func (*FakeResultPublisher) PublishSpawnNotificationArgsForCall ¶
func (*FakeResultPublisher) PublishSpawnNotificationCallCount ¶
func (fake *FakeResultPublisher) PublishSpawnNotificationCallCount() int
func (*FakeResultPublisher) PublishSpawnNotificationCalls ¶
func (*FakeResultPublisher) PublishSpawnNotificationReturns ¶
func (fake *FakeResultPublisher) PublishSpawnNotificationReturns(result1 error)
func (*FakeResultPublisher) PublishSpawnNotificationReturnsOnCall ¶
func (fake *FakeResultPublisher) PublishSpawnNotificationReturnsOnCall(i int, result1 error)
func (*FakeResultPublisher) PublishTypeMismatchFailure ¶
func (*FakeResultPublisher) PublishTypeMismatchFailureArgsForCall ¶
func (*FakeResultPublisher) PublishTypeMismatchFailureCallCount ¶
func (fake *FakeResultPublisher) PublishTypeMismatchFailureCallCount() int
func (*FakeResultPublisher) PublishTypeMismatchFailureCalls ¶
func (*FakeResultPublisher) PublishTypeMismatchFailureReturns ¶
func (fake *FakeResultPublisher) PublishTypeMismatchFailureReturns(result1 error)
func (*FakeResultPublisher) PublishTypeMismatchFailureReturnsOnCall ¶
func (fake *FakeResultPublisher) PublishTypeMismatchFailureReturnsOnCall(i int, result1 error)
type FakeServiceReconcileLoop ¶ added in v0.18.0
type FakeServiceReconcileLoop struct {
ReconcileOnceStub func(context.Context) error
RunStub func(context.Context) error
// contains filtered or unexported fields
}
func (*FakeServiceReconcileLoop) Invocations ¶ added in v0.18.0
func (fake *FakeServiceReconcileLoop) Invocations() map[string][][]interface{}
func (*FakeServiceReconcileLoop) ReconcileOnce ¶ added in v0.18.0
func (fake *FakeServiceReconcileLoop) ReconcileOnce(arg1 context.Context) error
func (*FakeServiceReconcileLoop) ReconcileOnceArgsForCall ¶ added in v0.18.0
func (fake *FakeServiceReconcileLoop) ReconcileOnceArgsForCall(i int) context.Context
func (*FakeServiceReconcileLoop) ReconcileOnceCallCount ¶ added in v0.18.0
func (fake *FakeServiceReconcileLoop) ReconcileOnceCallCount() int
func (*FakeServiceReconcileLoop) ReconcileOnceCalls ¶ added in v0.18.0
func (fake *FakeServiceReconcileLoop) ReconcileOnceCalls(stub func(context.Context) error)
func (*FakeServiceReconcileLoop) ReconcileOnceReturns ¶ added in v0.18.0
func (fake *FakeServiceReconcileLoop) ReconcileOnceReturns(result1 error)
func (*FakeServiceReconcileLoop) ReconcileOnceReturnsOnCall ¶ added in v0.18.0
func (fake *FakeServiceReconcileLoop) ReconcileOnceReturnsOnCall(i int, result1 error)
func (*FakeServiceReconcileLoop) Run ¶ added in v0.18.0
func (fake *FakeServiceReconcileLoop) Run(arg1 context.Context) error
func (*FakeServiceReconcileLoop) RunArgsForCall ¶ added in v0.18.0
func (fake *FakeServiceReconcileLoop) RunArgsForCall(i int) context.Context
func (*FakeServiceReconcileLoop) RunCallCount ¶ added in v0.18.0
func (fake *FakeServiceReconcileLoop) RunCallCount() int
func (*FakeServiceReconcileLoop) RunCalls ¶ added in v0.18.0
func (fake *FakeServiceReconcileLoop) RunCalls(stub func(context.Context) error)
func (*FakeServiceReconcileLoop) RunReturns ¶ added in v0.18.0
func (fake *FakeServiceReconcileLoop) RunReturns(result1 error)
func (*FakeServiceReconcileLoop) RunReturnsOnCall ¶ added in v0.18.0
func (fake *FakeServiceReconcileLoop) RunReturnsOnCall(i int, result1 error)
type FakeServiceReconciler ¶ added in v0.18.0
type FakeServiceReconciler struct {
ReconcileServiceStub func(context.Context, v1.Config, pkg.AgentConfiguration) error
UndeployServiceStub func(context.Context, string) error
// contains filtered or unexported fields
}
func (*FakeServiceReconciler) Invocations ¶ added in v0.18.0
func (fake *FakeServiceReconciler) Invocations() map[string][][]interface{}
func (*FakeServiceReconciler) ReconcileService ¶ added in v0.18.0
func (fake *FakeServiceReconciler) ReconcileService(arg1 context.Context, arg2 v1.Config, arg3 pkg.AgentConfiguration) error
func (*FakeServiceReconciler) ReconcileServiceArgsForCall ¶ added in v0.18.0
func (fake *FakeServiceReconciler) ReconcileServiceArgsForCall(i int) (context.Context, v1.Config, pkg.AgentConfiguration)
func (*FakeServiceReconciler) ReconcileServiceCallCount ¶ added in v0.18.0
func (fake *FakeServiceReconciler) ReconcileServiceCallCount() int
func (*FakeServiceReconciler) ReconcileServiceCalls ¶ added in v0.18.0
func (fake *FakeServiceReconciler) ReconcileServiceCalls(stub func(context.Context, v1.Config, pkg.AgentConfiguration) error)
func (*FakeServiceReconciler) ReconcileServiceReturns ¶ added in v0.18.0
func (fake *FakeServiceReconciler) ReconcileServiceReturns(result1 error)
func (*FakeServiceReconciler) ReconcileServiceReturnsOnCall ¶ added in v0.18.0
func (fake *FakeServiceReconciler) ReconcileServiceReturnsOnCall(i int, result1 error)
func (*FakeServiceReconciler) UndeployService ¶ added in v0.18.0
func (fake *FakeServiceReconciler) UndeployService(arg1 context.Context, arg2 string) error
func (*FakeServiceReconciler) UndeployServiceArgsForCall ¶ added in v0.18.0
func (fake *FakeServiceReconciler) UndeployServiceArgsForCall(i int) (context.Context, string)
func (*FakeServiceReconciler) UndeployServiceCallCount ¶ added in v0.18.0
func (fake *FakeServiceReconciler) UndeployServiceCallCount() int
func (*FakeServiceReconciler) UndeployServiceCalls ¶ added in v0.18.0
func (fake *FakeServiceReconciler) UndeployServiceCalls(stub func(context.Context, string) error)
func (*FakeServiceReconciler) UndeployServiceReturns ¶ added in v0.18.0
func (fake *FakeServiceReconciler) UndeployServiceReturns(result1 error)
func (*FakeServiceReconciler) UndeployServiceReturnsOnCall ¶ added in v0.18.0
func (fake *FakeServiceReconciler) UndeployServiceReturnsOnCall(i int, result1 error)
type FakeTaskEventHandler ¶
type FakeTaskEventHandler struct {
ConsumeMessageStub func(context.Context, *sarama.ConsumerMessage) error
EvalDeferredRespawnsStub func(context.Context) error
ReconcileOnceStub func(context.Context) error
RunDeferredRespawnLoopStub func(context.Context) error
RunReconcileLoopStub func(context.Context) error
// contains filtered or unexported fields
}
func (*FakeTaskEventHandler) ConsumeMessage ¶
func (fake *FakeTaskEventHandler) ConsumeMessage(arg1 context.Context, arg2 *sarama.ConsumerMessage) error
func (*FakeTaskEventHandler) ConsumeMessageArgsForCall ¶
func (fake *FakeTaskEventHandler) ConsumeMessageArgsForCall(i int) (context.Context, *sarama.ConsumerMessage)
func (*FakeTaskEventHandler) ConsumeMessageCallCount ¶
func (fake *FakeTaskEventHandler) ConsumeMessageCallCount() int
func (*FakeTaskEventHandler) ConsumeMessageCalls ¶
func (fake *FakeTaskEventHandler) ConsumeMessageCalls(stub func(context.Context, *sarama.ConsumerMessage) error)
func (*FakeTaskEventHandler) ConsumeMessageReturns ¶
func (fake *FakeTaskEventHandler) ConsumeMessageReturns(result1 error)
func (*FakeTaskEventHandler) ConsumeMessageReturnsOnCall ¶
func (fake *FakeTaskEventHandler) ConsumeMessageReturnsOnCall(i int, result1 error)
func (*FakeTaskEventHandler) EvalDeferredRespawns ¶
func (fake *FakeTaskEventHandler) EvalDeferredRespawns(arg1 context.Context) error
func (*FakeTaskEventHandler) EvalDeferredRespawnsArgsForCall ¶
func (fake *FakeTaskEventHandler) EvalDeferredRespawnsArgsForCall(i int) context.Context
func (*FakeTaskEventHandler) EvalDeferredRespawnsCallCount ¶
func (fake *FakeTaskEventHandler) EvalDeferredRespawnsCallCount() int
func (*FakeTaskEventHandler) EvalDeferredRespawnsCalls ¶
func (fake *FakeTaskEventHandler) EvalDeferredRespawnsCalls(stub func(context.Context) error)
func (*FakeTaskEventHandler) EvalDeferredRespawnsReturns ¶
func (fake *FakeTaskEventHandler) EvalDeferredRespawnsReturns(result1 error)
func (*FakeTaskEventHandler) EvalDeferredRespawnsReturnsOnCall ¶
func (fake *FakeTaskEventHandler) EvalDeferredRespawnsReturnsOnCall(i int, result1 error)
func (*FakeTaskEventHandler) Invocations ¶
func (fake *FakeTaskEventHandler) Invocations() map[string][][]interface{}
func (*FakeTaskEventHandler) ReconcileOnce ¶ added in v0.11.0
func (fake *FakeTaskEventHandler) ReconcileOnce(arg1 context.Context) error
func (*FakeTaskEventHandler) ReconcileOnceArgsForCall ¶ added in v0.11.0
func (fake *FakeTaskEventHandler) ReconcileOnceArgsForCall(i int) context.Context
func (*FakeTaskEventHandler) ReconcileOnceCallCount ¶ added in v0.11.0
func (fake *FakeTaskEventHandler) ReconcileOnceCallCount() int
func (*FakeTaskEventHandler) ReconcileOnceCalls ¶ added in v0.11.0
func (fake *FakeTaskEventHandler) ReconcileOnceCalls(stub func(context.Context) error)
func (*FakeTaskEventHandler) ReconcileOnceReturns ¶ added in v0.11.0
func (fake *FakeTaskEventHandler) ReconcileOnceReturns(result1 error)
func (*FakeTaskEventHandler) ReconcileOnceReturnsOnCall ¶ added in v0.11.0
func (fake *FakeTaskEventHandler) ReconcileOnceReturnsOnCall(i int, result1 error)
func (*FakeTaskEventHandler) RunDeferredRespawnLoop ¶
func (fake *FakeTaskEventHandler) RunDeferredRespawnLoop(arg1 context.Context) error
func (*FakeTaskEventHandler) RunDeferredRespawnLoopArgsForCall ¶
func (fake *FakeTaskEventHandler) RunDeferredRespawnLoopArgsForCall(i int) context.Context
func (*FakeTaskEventHandler) RunDeferredRespawnLoopCallCount ¶
func (fake *FakeTaskEventHandler) RunDeferredRespawnLoopCallCount() int
func (*FakeTaskEventHandler) RunDeferredRespawnLoopCalls ¶
func (fake *FakeTaskEventHandler) RunDeferredRespawnLoopCalls(stub func(context.Context) error)
func (*FakeTaskEventHandler) RunDeferredRespawnLoopReturns ¶
func (fake *FakeTaskEventHandler) RunDeferredRespawnLoopReturns(result1 error)
func (*FakeTaskEventHandler) RunDeferredRespawnLoopReturnsOnCall ¶
func (fake *FakeTaskEventHandler) RunDeferredRespawnLoopReturnsOnCall(i int, result1 error)
func (*FakeTaskEventHandler) RunReconcileLoop ¶ added in v0.11.0
func (fake *FakeTaskEventHandler) RunReconcileLoop(arg1 context.Context) error
func (*FakeTaskEventHandler) RunReconcileLoopArgsForCall ¶ added in v0.11.0
func (fake *FakeTaskEventHandler) RunReconcileLoopArgsForCall(i int) context.Context
func (*FakeTaskEventHandler) RunReconcileLoopCallCount ¶ added in v0.11.0
func (fake *FakeTaskEventHandler) RunReconcileLoopCallCount() int
func (*FakeTaskEventHandler) RunReconcileLoopCalls ¶ added in v0.11.0
func (fake *FakeTaskEventHandler) RunReconcileLoopCalls(stub func(context.Context) error)
func (*FakeTaskEventHandler) RunReconcileLoopReturns ¶ added in v0.11.0
func (fake *FakeTaskEventHandler) RunReconcileLoopReturns(result1 error)
func (*FakeTaskEventHandler) RunReconcileLoopReturnsOnCall ¶ added in v0.11.0
func (fake *FakeTaskEventHandler) RunReconcileLoopReturnsOnCall(i int, result1 error)
type FakeTaskView ¶ added in v0.25.0
type FakeTaskView struct {
CaptureHighWaterMarksStub func(context.Context) error
ConsumeMessageStub func(context.Context, *sarama.ConsumerMessage) error
GetStub func(lib.TaskIdentifier) (lib.Task, bool)
ReadyStub func() bool
SnapshotStub func() []lib.Task
// contains filtered or unexported fields
}
func (*FakeTaskView) CaptureHighWaterMarks ¶ added in v0.25.0
func (fake *FakeTaskView) CaptureHighWaterMarks(arg1 context.Context) error
func (*FakeTaskView) CaptureHighWaterMarksArgsForCall ¶ added in v0.25.0
func (fake *FakeTaskView) CaptureHighWaterMarksArgsForCall(i int) context.Context
func (*FakeTaskView) CaptureHighWaterMarksCallCount ¶ added in v0.25.0
func (fake *FakeTaskView) CaptureHighWaterMarksCallCount() int
func (*FakeTaskView) CaptureHighWaterMarksCalls ¶ added in v0.25.0
func (fake *FakeTaskView) CaptureHighWaterMarksCalls(stub func(context.Context) error)
func (*FakeTaskView) CaptureHighWaterMarksReturns ¶ added in v0.25.0
func (fake *FakeTaskView) CaptureHighWaterMarksReturns(result1 error)
func (*FakeTaskView) CaptureHighWaterMarksReturnsOnCall ¶ added in v0.25.0
func (fake *FakeTaskView) CaptureHighWaterMarksReturnsOnCall(i int, result1 error)
func (*FakeTaskView) ConsumeMessage ¶ added in v0.25.0
func (fake *FakeTaskView) ConsumeMessage(arg1 context.Context, arg2 *sarama.ConsumerMessage) error
func (*FakeTaskView) ConsumeMessageArgsForCall ¶ added in v0.25.0
func (fake *FakeTaskView) ConsumeMessageArgsForCall(i int) (context.Context, *sarama.ConsumerMessage)
func (*FakeTaskView) ConsumeMessageCallCount ¶ added in v0.25.0
func (fake *FakeTaskView) ConsumeMessageCallCount() int
func (*FakeTaskView) ConsumeMessageCalls ¶ added in v0.25.0
func (fake *FakeTaskView) ConsumeMessageCalls(stub func(context.Context, *sarama.ConsumerMessage) error)
func (*FakeTaskView) ConsumeMessageReturns ¶ added in v0.25.0
func (fake *FakeTaskView) ConsumeMessageReturns(result1 error)
func (*FakeTaskView) ConsumeMessageReturnsOnCall ¶ added in v0.25.0
func (fake *FakeTaskView) ConsumeMessageReturnsOnCall(i int, result1 error)
func (*FakeTaskView) Get ¶ added in v0.25.0
func (fake *FakeTaskView) Get(arg1 lib.TaskIdentifier) (lib.Task, bool)
func (*FakeTaskView) GetArgsForCall ¶ added in v0.25.0
func (fake *FakeTaskView) GetArgsForCall(i int) lib.TaskIdentifier
func (*FakeTaskView) GetCallCount ¶ added in v0.25.0
func (fake *FakeTaskView) GetCallCount() int
func (*FakeTaskView) GetCalls ¶ added in v0.25.0
func (fake *FakeTaskView) GetCalls(stub func(lib.TaskIdentifier) (lib.Task, bool))
func (*FakeTaskView) GetReturns ¶ added in v0.25.0
func (fake *FakeTaskView) GetReturns(result1 lib.Task, result2 bool)
func (*FakeTaskView) GetReturnsOnCall ¶ added in v0.25.0
func (fake *FakeTaskView) GetReturnsOnCall(i int, result1 lib.Task, result2 bool)
func (*FakeTaskView) Invocations ¶ added in v0.25.0
func (fake *FakeTaskView) Invocations() map[string][][]interface{}
func (*FakeTaskView) Ready ¶ added in v0.25.0
func (fake *FakeTaskView) Ready() bool
func (*FakeTaskView) ReadyCallCount ¶ added in v0.25.0
func (fake *FakeTaskView) ReadyCallCount() int
func (*FakeTaskView) ReadyCalls ¶ added in v0.25.0
func (fake *FakeTaskView) ReadyCalls(stub func() bool)
func (*FakeTaskView) ReadyReturns ¶ added in v0.25.0
func (fake *FakeTaskView) ReadyReturns(result1 bool)
func (*FakeTaskView) ReadyReturnsOnCall ¶ added in v0.25.0
func (fake *FakeTaskView) ReadyReturnsOnCall(i int, result1 bool)
func (*FakeTaskView) Snapshot ¶ added in v0.25.0
func (fake *FakeTaskView) Snapshot() []lib.Task
func (*FakeTaskView) SnapshotCallCount ¶ added in v0.25.0
func (fake *FakeTaskView) SnapshotCallCount() int
func (*FakeTaskView) SnapshotCalls ¶ added in v0.25.0
func (fake *FakeTaskView) SnapshotCalls(stub func() []lib.Task)
func (*FakeTaskView) SnapshotReturns ¶ added in v0.25.0
func (fake *FakeTaskView) SnapshotReturns(result1 []lib.Task)
func (*FakeTaskView) SnapshotReturnsOnCall ¶ added in v0.25.0
func (fake *FakeTaskView) SnapshotReturnsOnCall(i int, result1 []lib.Task)
type FakeZombieSweeper ¶
type FakeZombieSweeper struct {
RunStub func(context.Context) error
SweepOnceStub func(context.Context) error
// contains filtered or unexported fields
}
func (*FakeZombieSweeper) Invocations ¶
func (fake *FakeZombieSweeper) Invocations() map[string][][]interface{}
func (*FakeZombieSweeper) RunArgsForCall ¶
func (fake *FakeZombieSweeper) RunArgsForCall(i int) context.Context
func (*FakeZombieSweeper) RunCallCount ¶
func (fake *FakeZombieSweeper) RunCallCount() int
func (*FakeZombieSweeper) RunCalls ¶
func (fake *FakeZombieSweeper) RunCalls(stub func(context.Context) error)
func (*FakeZombieSweeper) RunReturns ¶
func (fake *FakeZombieSweeper) RunReturns(result1 error)
func (*FakeZombieSweeper) RunReturnsOnCall ¶
func (fake *FakeZombieSweeper) RunReturnsOnCall(i int, result1 error)
func (*FakeZombieSweeper) SweepOnce ¶
func (fake *FakeZombieSweeper) SweepOnce(arg1 context.Context) error
func (*FakeZombieSweeper) SweepOnceArgsForCall ¶
func (fake *FakeZombieSweeper) SweepOnceArgsForCall(i int) context.Context
func (*FakeZombieSweeper) SweepOnceCallCount ¶
func (fake *FakeZombieSweeper) SweepOnceCallCount() int
func (*FakeZombieSweeper) SweepOnceCalls ¶
func (fake *FakeZombieSweeper) SweepOnceCalls(stub func(context.Context) error)
func (*FakeZombieSweeper) SweepOnceReturns ¶
func (fake *FakeZombieSweeper) SweepOnceReturns(result1 error)
func (*FakeZombieSweeper) SweepOnceReturnsOnCall ¶
func (fake *FakeZombieSweeper) SweepOnceReturnsOnCall(i int, result1 error)
Click to show internal directories.
Click to hide internal directories.