Help us shape the future of Go! Take the 2026 Go Developer Survey

mocks

package
v0.26.2 Latest Latest
Warning

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

Go to latest
Published: Oct 22, 2026 License: BSD-2-Clause Imports: 16 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.

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 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 (fake *FakeClaimJobControl) IsJobRunning(arg1 context.Context, arg2 string) (bool, error)

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 (fake *FakeClaimJobControl) IsJobRunningCalls(stub func(context.Context, string) (bool, error))

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) Delete added in v0.24.0

func (fake *FakeClaimRefClient) Delete(arg1 context.Context, arg2 string, arg3 string) error

func (*FakeClaimRefClient) DeleteArgsForCall added in v0.24.0

func (fake *FakeClaimRefClient) DeleteArgsForCall(i int) (context.Context, string, string)

func (*FakeClaimRefClient) DeleteCallCount added in v0.24.0

func (fake *FakeClaimRefClient) DeleteCallCount() int

func (*FakeClaimRefClient) DeleteCalls added in v0.24.0

func (fake *FakeClaimRefClient) DeleteCalls(stub func(context.Context, string, string) error)

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) List added in v0.24.0

func (fake *FakeClaimRefClient) List(arg1 context.Context, arg2 string) ([]claim.ClaimRef, error)

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) ListCalls added in v0.24.0

func (fake *FakeClaimRefClient) ListCalls(stub func(context.Context, string) ([]claim.ClaimRef, error))

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) Put added in v0.24.0

func (fake *FakeClaimRefClient) Put(arg1 context.Context, arg2 string, arg3 string, arg4 string, arg5 string, arg6 time.DateTime) (string, error)

func (*FakeClaimRefClient) PutArgsForCall added in v0.24.0

func (fake *FakeClaimRefClient) PutArgsForCall(i int) (context.Context, string, string, string, string, time.DateTime)

func (*FakeClaimRefClient) PutCallCount added in v0.24.0

func (fake *FakeClaimRefClient) PutCallCount() int

func (*FakeClaimRefClient) PutCalls added in v0.24.0

func (fake *FakeClaimRefClient) PutCalls(stub func(context.Context, string, string, string, string, time.DateTime) (string, error))

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 (fake *FakeConfigResolver) ResolveByTaskTypeArgsForCall(i int) (context.Context, string, string)

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 (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) 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 (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 (*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 (fake *FakeResultPublisher) PublishClearCurrentJob(arg1 context.Context, arg2 lib.Task, arg3 string) error

func (*FakeResultPublisher) PublishClearCurrentJobArgsForCall added in v0.9.1

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

func (*FakeResultPublisher) PublishClearCurrentJobCallCount added in v0.9.1

func (fake *FakeResultPublisher) PublishClearCurrentJobCallCount() int

func (*FakeResultPublisher) PublishClearCurrentJobCalls added in v0.9.1

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

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 (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) PublishQueueEntry added in v0.19.0

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

func (*FakeResultPublisher) PublishQueueEntryArgsForCall added in v0.19.0

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

func (*FakeResultPublisher) PublishQueueEntryCallCount added in v0.19.0

func (fake *FakeResultPublisher) PublishQueueEntryCallCount() int

func (*FakeResultPublisher) PublishQueueEntryCalls added in v0.19.0

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

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 (fake *FakeResultPublisher) PublishRestoreAssignee(arg1 context.Context, arg2 lib.Task, arg3 string) error

func (*FakeResultPublisher) PublishRestoreAssigneeArgsForCall added in v0.18.11

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

func (*FakeResultPublisher) PublishRestoreAssigneeCallCount added in v0.18.11

func (fake *FakeResultPublisher) PublishRestoreAssigneeCallCount() int

func (*FakeResultPublisher) PublishRestoreAssigneeCalls added in v0.18.11

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

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 (fake *FakeResultPublisher) PublishSetTriggerScope(arg1 context.Context, arg2 lib.Task, arg3 string, arg4 int) error

func (*FakeResultPublisher) PublishSetTriggerScopeArgsForCall added in v0.8.0

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

func (*FakeResultPublisher) PublishSetTriggerScopeCallCount added in v0.8.0

func (fake *FakeResultPublisher) PublishSetTriggerScopeCallCount() int

func (*FakeResultPublisher) PublishSetTriggerScopeCalls added in v0.8.0

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

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 (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 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 (*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) 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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL