mocks

package
v0.8.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 1, 2026 License: BSD-2-Clause Imports: 13 Imported by: 0

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.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FakeConfigResolver 

type FakeConfigResolver struct {
	ResolveStub func(context.Context, 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) 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)

	SpawnJobStub func(context.Context, lib.Task, pkg.AgentConfiguration) (string, error)
	// contains filtered or unexported fields
}

func (*FakeJobSpawner) CountActiveJobs added in v0.5.0 

func (fake *FakeJobSpawner) CountActiveJobs(arg1 context.Context, arg2 string) (int, error)

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 (fake *FakeJobSpawner) CountActiveJobsCalls(stub func(context.Context, string) (int, error))

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) 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 (fake *FakeJobWatcher) HandleJobArgsForCall(i int) (context.Context, *v1.Job)

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 (fake *FakeJobWatcher) HandlePodArgsForCall(i int) (context.Context, *v1a.Pod)

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

func (fake *FakeJobWatcher) Run(arg1 context.Context) error

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 {
	PublishFailureStub func(context.Context, lib.Task, string, string) error

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

	PublishRawStub func(context.Context, base.CommandOperation, interface{}) 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) PublishFailure 

func (fake *FakeResultPublisher) PublishFailure(arg1 context.Context, arg2 lib.Task, arg3 string, arg4 string) error

func (*FakeResultPublisher) PublishFailureArgsForCall 

func (fake *FakeResultPublisher) PublishFailureArgsForCall(i int) (context.Context, lib.Task, string, string)

func (*FakeResultPublisher) PublishFailureCallCount 

func (fake *FakeResultPublisher) PublishFailureCallCount() int

func (*FakeResultPublisher) PublishFailureCalls 

func (fake *FakeResultPublisher) PublishFailureCalls(stub func(context.Context, lib.Task, string, string) error)

func (*FakeResultPublisher) PublishFailureReturns 

func (fake *FakeResultPublisher) PublishFailureReturns(result1 error)

func (*FakeResultPublisher) PublishFailureReturnsOnCall 

func (fake *FakeResultPublisher) PublishFailureReturnsOnCall(i int, result1 error)

func (*FakeResultPublisher) PublishIncrementTriggerCount 

func (fake *FakeResultPublisher) PublishIncrementTriggerCount(arg1 context.Context, arg2 lib.Task) error

func (*FakeResultPublisher) PublishIncrementTriggerCountArgsForCall 

func (fake *FakeResultPublisher) PublishIncrementTriggerCountArgsForCall(i int) (context.Context, lib.Task)

func (*FakeResultPublisher) PublishIncrementTriggerCountCallCount 

func (fake *FakeResultPublisher) PublishIncrementTriggerCountCallCount() int

func (*FakeResultPublisher) PublishIncrementTriggerCountCalls 

func (fake *FakeResultPublisher) PublishIncrementTriggerCountCalls(stub func(context.Context, lib.Task) error)

func (*FakeResultPublisher) PublishIncrementTriggerCountReturns 

func (fake *FakeResultPublisher) PublishIncrementTriggerCountReturns(result1 error)

func (*FakeResultPublisher) PublishIncrementTriggerCountReturnsOnCall 

func (fake *FakeResultPublisher) PublishIncrementTriggerCountReturnsOnCall(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) PublishSetTriggerScope added in v0.8.2 

func (fake *FakeResultPublisher) PublishSetTriggerScope(arg1 context.Context, arg2 lib.Task, arg3 string, arg4 int) error

func (*FakeResultPublisher) PublishSetTriggerScopeArgsForCall added in v0.8.2 

func (fake *FakeResultPublisher) PublishSetTriggerScopeArgsForCall(i int) (context.Context, lib.Task, string, int)

func (*FakeResultPublisher) PublishSetTriggerScopeCallCount added in v0.8.2 

func (fake *FakeResultPublisher) PublishSetTriggerScopeCallCount() int

func (*FakeResultPublisher) PublishSetTriggerScopeCalls added in v0.8.2 

func (fake *FakeResultPublisher) PublishSetTriggerScopeCalls(stub func(context.Context, lib.Task, string, int) error)

func (*FakeResultPublisher) PublishSetTriggerScopeReturns added in v0.8.2 

func (fake *FakeResultPublisher) PublishSetTriggerScopeReturns(result1 error)

func (*FakeResultPublisher) PublishSetTriggerScopeReturnsOnCall added in v0.8.2 

func (fake *FakeResultPublisher) PublishSetTriggerScopeReturnsOnCall(i int, result1 error)

func (*FakeResultPublisher) PublishSpawnNotification 

func (fake *FakeResultPublisher) PublishSpawnNotification(arg1 context.Context, arg2 lib.Task, arg3 string) error

func (*FakeResultPublisher) PublishSpawnNotificationArgsForCall 

func (fake *FakeResultPublisher) PublishSpawnNotificationArgsForCall(i int) (context.Context, lib.Task, string)

func (*FakeResultPublisher) PublishSpawnNotificationCallCount 

func (fake *FakeResultPublisher) PublishSpawnNotificationCallCount() int

func (*FakeResultPublisher) PublishSpawnNotificationCalls 

func (fake *FakeResultPublisher) PublishSpawnNotificationCalls(stub func(context.Context, lib.Task, string) error)

func (*FakeResultPublisher) PublishSpawnNotificationReturns 

func (fake *FakeResultPublisher) PublishSpawnNotificationReturns(result1 error)

func (*FakeResultPublisher) PublishSpawnNotificationReturnsOnCall 

func (fake *FakeResultPublisher) PublishSpawnNotificationReturnsOnCall(i int, result1 error)

func (*FakeResultPublisher) PublishTypeMismatchFailure 

func (fake *FakeResultPublisher) PublishTypeMismatchFailure(arg1 context.Context, arg2 lib.Task, arg3 string) error

func (*FakeResultPublisher) PublishTypeMismatchFailureArgsForCall 

func (fake *FakeResultPublisher) PublishTypeMismatchFailureArgsForCall(i int) (context.Context, lib.Task, string)

func (*FakeResultPublisher) PublishTypeMismatchFailureCallCount 

func (fake *FakeResultPublisher) PublishTypeMismatchFailureCallCount() int

func (*FakeResultPublisher) PublishTypeMismatchFailureCalls 

func (fake *FakeResultPublisher) PublishTypeMismatchFailureCalls(stub func(context.Context, lib.Task, string) error)

func (*FakeResultPublisher) PublishTypeMismatchFailureReturns 

func (fake *FakeResultPublisher) PublishTypeMismatchFailureReturns(result1 error)

func (*FakeResultPublisher) PublishTypeMismatchFailureReturnsOnCall 

func (fake *FakeResultPublisher) PublishTypeMismatchFailureReturnsOnCall(i int, result1 error)

type FakeTaskEventHandler 

type FakeTaskEventHandler struct {
	ConsumeMessageStub func(context.Context, *sarama.ConsumerMessage) error

	EvalDeferredRespawnsStub func(context.Context) error

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

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

func (fake *FakeZombieSweeper) Run(arg1 context.Context) error

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)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.