mocks

Sep 25, 2026

Changes in this version

+ type FakeServiceReconcileLoop struct

+ ReconcileOnceStub func(context.Context) error

+ RunStub func(context.Context) error

+ 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 struct

+ ReconcileServiceStub func(context.Context, v1.Config, pkg.AgentConfiguration) error

+ UndeployServiceStub func(context.Context, string) error

+ 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)

Sep 4, 2026

Changes in this version

+ type FakeGitRestClient struct

+ GetStub func(context.Context, string) ([]byte, error)

+ IsReadyStub func(context.Context) (bool, error)

+ ListStub func(context.Context, string) ([]string, error)

+ func (fake *FakeGitRestClient) Get(arg1 context.Context, arg2 string) ([]byte, error)

+ func (fake *FakeGitRestClient) GetArgsForCall(i int) (context.Context, string)

+ func (fake *FakeGitRestClient) GetCallCount() int

+ func (fake *FakeGitRestClient) GetCalls(stub func(context.Context, string) ([]byte, error))

+ func (fake *FakeGitRestClient) GetReturns(result1 []byte, result2 error)

+ func (fake *FakeGitRestClient) GetReturnsOnCall(i int, result1 []byte, result2 error)

+ func (fake *FakeGitRestClient) Invocations() map[string][][]interface{}

+ func (fake *FakeGitRestClient) IsReady(arg1 context.Context) (bool, error)

+ func (fake *FakeGitRestClient) IsReadyArgsForCall(i int) context.Context

+ func (fake *FakeGitRestClient) IsReadyCallCount() int

+ func (fake *FakeGitRestClient) IsReadyCalls(stub func(context.Context) (bool, error))

+ func (fake *FakeGitRestClient) IsReadyReturns(result1 bool, result2 error)

+ func (fake *FakeGitRestClient) IsReadyReturnsOnCall(i int, result1 bool, result2 error)

+ func (fake *FakeGitRestClient) List(arg1 context.Context, arg2 string) ([]string, error)

+ func (fake *FakeGitRestClient) ListArgsForCall(i int) (context.Context, string)

+ func (fake *FakeGitRestClient) ListCallCount() int

+ func (fake *FakeGitRestClient) ListCalls(stub func(context.Context, string) ([]string, error))

+ func (fake *FakeGitRestClient) ListReturns(result1 []string, result2 error)

+ func (fake *FakeGitRestClient) ListReturnsOnCall(i int, result1 []string, result2 error)

type FakeTaskEventHandler

+ ReconcileOnceStub func(context.Context) error

+ RunReconcileLoopStub func(context.Context) error

+ 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) 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)

Sep 3, 2026

Changes in this version

type FakeResultPublisher

+ PublishClearCurrentJobStub func(context.Context, lib.Task, string) error

+ 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)

Sep 1, 2026

Changes in this version

type FakeResultPublisher

+ PublishSetTriggerScopeStub func(context.Context, lib.Task, string, int) 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)

Aug 12, 2026

Changes in this version

type FakeJobSpawner

+ CountActiveJobsStub func(context.Context, string) (int, error)

+ 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)

Jul 4, 2026

Changes in this version

+ type FakeConfigResolver struct

+ ResolveStub func(context.Context, string) (pkg.AgentConfiguration, error)

+ 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) 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 struct

+ IsJobActiveStub func(context.Context, lib.TaskIdentifier) (bool, error)

+ SpawnJobStub func(context.Context, lib.Task, pkg.AgentConfiguration) (string, 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) 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 struct

+ HandleJobStub func(context.Context, *v1.Job)

+ HandlePodStub func(context.Context, *v1a.Pod)

+ PodListerStub func() v1b.PodLister

+ RunStub func(context.Context) error

+ 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 struct

+ ListenStub func(context.Context, k8s.Namespace, cache.ResourceEventHandler) error

+ SetupCustomResourceDefinitionStub func(context.Context) error

+ 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 struct

+ PublishFailureStub func(context.Context, lib.Task, string, string) error

+ PublishIncrementTriggerCountStub func(context.Context, lib.Task) error

+ PublishRawStub func(context.Context, base.CommandOperation, interface{}) error

+ PublishSpawnNotificationStub func(context.Context, lib.Task, string) error

+ PublishTypeMismatchFailureStub func(context.Context, lib.Task, string) error

+ func (fake *FakeResultPublisher) Invocations() map[string][][]interface{}

+ 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) 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) 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 FakeTaskEventHandler struct

+ ConsumeMessageStub func(context.Context, *sarama.ConsumerMessage) error

+ EvalDeferredRespawnsStub func(context.Context) error

+ RunDeferredRespawnLoopStub func(context.Context) error

+ 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) 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)

+ type FakeZombieSweeper struct

+ RunStub func(context.Context) error

+ SweepOnceStub func(context.Context) error

+ 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)