scheduler

package
v0.182.1 Latest Latest
Warning

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

 Go to latest Published: Aug 27, 2026 License: Apache-2.0 Imports: 5 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 FakeBackgroundShellService 

type FakeBackgroundShellService struct {
	CancelShellStub func(string) error

	DetachToBackgroundStub func(context.Context, *exec.Cmd, string, domain.OutputRingBuffer, <-chan struct{}) (string, error)

	GetAllShellsStub func() []*domain.BackgroundShell

	GetShellStub func(string) *domain.BackgroundShell

	GetShellOutputStub func(string, int64) (string, int64, domain.ShellState, error)

	GetShellOutputWithFilterStub func(string, int64, string) (string, int64, domain.ShellState, error)

	RemoveShellStub func(string) error
	// contains filtered or unexported fields
}

func (*FakeBackgroundShellService) CancelShell 

func (fake *FakeBackgroundShellService) CancelShell(arg1 string) error

func (*FakeBackgroundShellService) CancelShellArgsForCall 

func (fake *FakeBackgroundShellService) CancelShellArgsForCall(i int) string

func (*FakeBackgroundShellService) CancelShellCallCount 

func (fake *FakeBackgroundShellService) CancelShellCallCount() int

func (*FakeBackgroundShellService) CancelShellCalls 

func (fake *FakeBackgroundShellService) CancelShellCalls(stub func(string) error)

func (*FakeBackgroundShellService) CancelShellReturns 

func (fake *FakeBackgroundShellService) CancelShellReturns(result1 error)

func (*FakeBackgroundShellService) CancelShellReturnsOnCall 

func (fake *FakeBackgroundShellService) CancelShellReturnsOnCall(i int, result1 error)

func (*FakeBackgroundShellService) DetachToBackground 

func (fake *FakeBackgroundShellService) DetachToBackground(arg1 context.Context, arg2 *exec.Cmd, arg3 string, arg4 domain.OutputRingBuffer, arg5 <-chan struct{}) (string, error)

func (*FakeBackgroundShellService) DetachToBackgroundArgsForCall 

func (fake *FakeBackgroundShellService) DetachToBackgroundArgsForCall(i int) (context.Context, *exec.Cmd, string, domain.OutputRingBuffer, <-chan struct{})

func (*FakeBackgroundShellService) DetachToBackgroundCallCount 

func (fake *FakeBackgroundShellService) DetachToBackgroundCallCount() int

func (*FakeBackgroundShellService) DetachToBackgroundCalls 

func (fake *FakeBackgroundShellService) DetachToBackgroundCalls(stub func(context.Context, *exec.Cmd, string, domain.OutputRingBuffer, <-chan struct{}) (string, error))

func (*FakeBackgroundShellService) DetachToBackgroundReturns 

func (fake *FakeBackgroundShellService) DetachToBackgroundReturns(result1 string, result2 error)

func (*FakeBackgroundShellService) DetachToBackgroundReturnsOnCall 

func (fake *FakeBackgroundShellService) DetachToBackgroundReturnsOnCall(i int, result1 string, result2 error)

func (*FakeBackgroundShellService) GetAllShells 

func (fake *FakeBackgroundShellService) GetAllShells() []*domain.BackgroundShell

func (*FakeBackgroundShellService) GetAllShellsCallCount 

func (fake *FakeBackgroundShellService) GetAllShellsCallCount() int

func (*FakeBackgroundShellService) GetAllShellsCalls 

func (fake *FakeBackgroundShellService) GetAllShellsCalls(stub func() []*domain.BackgroundShell)

func (*FakeBackgroundShellService) GetAllShellsReturns 

func (fake *FakeBackgroundShellService) GetAllShellsReturns(result1 []*domain.BackgroundShell)

func (*FakeBackgroundShellService) GetAllShellsReturnsOnCall 

func (fake *FakeBackgroundShellService) GetAllShellsReturnsOnCall(i int, result1 []*domain.BackgroundShell)

func (*FakeBackgroundShellService) GetShell 

func (fake *FakeBackgroundShellService) GetShell(arg1 string) *domain.BackgroundShell

func (*FakeBackgroundShellService) GetShellArgsForCall 

func (fake *FakeBackgroundShellService) GetShellArgsForCall(i int) string

func (*FakeBackgroundShellService) GetShellCallCount 

func (fake *FakeBackgroundShellService) GetShellCallCount() int

func (*FakeBackgroundShellService) GetShellCalls 

func (fake *FakeBackgroundShellService) GetShellCalls(stub func(string) *domain.BackgroundShell)

func (*FakeBackgroundShellService) GetShellOutput 

func (fake *FakeBackgroundShellService) GetShellOutput(arg1 string, arg2 int64) (string, int64, domain.ShellState, error)

func (*FakeBackgroundShellService) GetShellOutputArgsForCall 

func (fake *FakeBackgroundShellService) GetShellOutputArgsForCall(i int) (string, int64)

func (*FakeBackgroundShellService) GetShellOutputCallCount 

func (fake *FakeBackgroundShellService) GetShellOutputCallCount() int

func (*FakeBackgroundShellService) GetShellOutputCalls 

func (fake *FakeBackgroundShellService) GetShellOutputCalls(stub func(string, int64) (string, int64, domain.ShellState, error))

func (*FakeBackgroundShellService) GetShellOutputReturns 

func (fake *FakeBackgroundShellService) GetShellOutputReturns(result1 string, result2 int64, result3 domain.ShellState, result4 error)

func (*FakeBackgroundShellService) GetShellOutputReturnsOnCall 

func (fake *FakeBackgroundShellService) GetShellOutputReturnsOnCall(i int, result1 string, result2 int64, result3 domain.ShellState, result4 error)

func (*FakeBackgroundShellService) GetShellOutputWithFilter 

func (fake *FakeBackgroundShellService) GetShellOutputWithFilter(arg1 string, arg2 int64, arg3 string) (string, int64, domain.ShellState, error)

func (*FakeBackgroundShellService) GetShellOutputWithFilterArgsForCall 

func (fake *FakeBackgroundShellService) GetShellOutputWithFilterArgsForCall(i int) (string, int64, string)

func (*FakeBackgroundShellService) GetShellOutputWithFilterCallCount 

func (fake *FakeBackgroundShellService) GetShellOutputWithFilterCallCount() int

func (*FakeBackgroundShellService) GetShellOutputWithFilterCalls 

func (fake *FakeBackgroundShellService) GetShellOutputWithFilterCalls(stub func(string, int64, string) (string, int64, domain.ShellState, error))

func (*FakeBackgroundShellService) GetShellOutputWithFilterReturns 

func (fake *FakeBackgroundShellService) GetShellOutputWithFilterReturns(result1 string, result2 int64, result3 domain.ShellState, result4 error)

func (*FakeBackgroundShellService) GetShellOutputWithFilterReturnsOnCall 

func (fake *FakeBackgroundShellService) GetShellOutputWithFilterReturnsOnCall(i int, result1 string, result2 int64, result3 domain.ShellState, result4 error)

func (*FakeBackgroundShellService) GetShellReturns 

func (fake *FakeBackgroundShellService) GetShellReturns(result1 *domain.BackgroundShell)

func (*FakeBackgroundShellService) GetShellReturnsOnCall 

func (fake *FakeBackgroundShellService) GetShellReturnsOnCall(i int, result1 *domain.BackgroundShell)

func (*FakeBackgroundShellService) Invocations 

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

func (*FakeBackgroundShellService) RemoveShell 

func (fake *FakeBackgroundShellService) RemoveShell(arg1 string) error

func (*FakeBackgroundShellService) RemoveShellArgsForCall 

func (fake *FakeBackgroundShellService) RemoveShellArgsForCall(i int) string

func (*FakeBackgroundShellService) RemoveShellCallCount 

func (fake *FakeBackgroundShellService) RemoveShellCallCount() int

func (*FakeBackgroundShellService) RemoveShellCalls 

func (fake *FakeBackgroundShellService) RemoveShellCalls(stub func(string) error)

func (*FakeBackgroundShellService) RemoveShellReturns 

func (fake *FakeBackgroundShellService) RemoveShellReturns(result1 error)

func (*FakeBackgroundShellService) RemoveShellReturnsOnCall 

func (fake *FakeBackgroundShellService) RemoveShellReturnsOnCall(i int, result1 error)

type FakeBackgroundTaskRegistry 

type FakeBackgroundTaskRegistry struct {
	AddStub func(*domain.BackgroundShell) error

	AddSubagentStub func(*domain.SubagentState) error

	AddTaskStub func(string, string)

	ClearAllAgentsStub func()

	CountRunningStub func() int

	CountRunningJobsStub func(domain.JobKind) int

	CountRunningSubagentsStub func() int

	GetStub func(string) *domain.BackgroundShell

	GetAllStub func() []*domain.BackgroundShell

	GetAllPollingTasksStub func() []string

	GetAllSubagentsStub func() []*domain.SubagentState

	GetLatestContextForAgentStub func(string) string

	GetLatestTaskForContextStub func(string) string

	GetPollingStateStub func(string) *domaina.TaskPollingState

	GetSubagentStub func(string) *domain.SubagentState

	HasContextStub func(string) bool

	HasPendingStub func() bool

	IsJobRunningStub func(string) bool

	RegisterContextStub func(string, string)

	RemoveStub func(string) error

	RemoveSubagentStub func(string) error

	RemoveTaskStub func(string)

	SetSubagentStatusStub func(string, domain.SubagentStatus) error

	SnapshotStub func() []domain.TrackedJob

	StartPollingStub func(string, *domaina.TaskPollingState)

	StopPollingStub func(string)

	SubmitStub func(domain.BackgroundJob)

	WindJobStub func(string, domain.WindSignal) error
	// contains filtered or unexported fields
}

func (*FakeBackgroundTaskRegistry) Add 

func (fake *FakeBackgroundTaskRegistry) Add(arg1 *domain.BackgroundShell) error

func (*FakeBackgroundTaskRegistry) AddArgsForCall 

func (fake *FakeBackgroundTaskRegistry) AddArgsForCall(i int) *domain.BackgroundShell

func (*FakeBackgroundTaskRegistry) AddCallCount 

func (fake *FakeBackgroundTaskRegistry) AddCallCount() int

func (*FakeBackgroundTaskRegistry) AddCalls 

func (fake *FakeBackgroundTaskRegistry) AddCalls(stub func(*domain.BackgroundShell) error)

func (*FakeBackgroundTaskRegistry) AddReturns 

func (fake *FakeBackgroundTaskRegistry) AddReturns(result1 error)

func (*FakeBackgroundTaskRegistry) AddReturnsOnCall 

func (fake *FakeBackgroundTaskRegistry) AddReturnsOnCall(i int, result1 error)

func (*FakeBackgroundTaskRegistry) AddSubagent 

func (fake *FakeBackgroundTaskRegistry) AddSubagent(arg1 *domain.SubagentState) error

func (*FakeBackgroundTaskRegistry) AddSubagentArgsForCall 

func (fake *FakeBackgroundTaskRegistry) AddSubagentArgsForCall(i int) *domain.SubagentState

func (*FakeBackgroundTaskRegistry) AddSubagentCallCount 

func (fake *FakeBackgroundTaskRegistry) AddSubagentCallCount() int

func (*FakeBackgroundTaskRegistry) AddSubagentCalls 

func (fake *FakeBackgroundTaskRegistry) AddSubagentCalls(stub func(*domain.SubagentState) error)

func (*FakeBackgroundTaskRegistry) AddSubagentReturns 

func (fake *FakeBackgroundTaskRegistry) AddSubagentReturns(result1 error)

func (*FakeBackgroundTaskRegistry) AddSubagentReturnsOnCall 

func (fake *FakeBackgroundTaskRegistry) AddSubagentReturnsOnCall(i int, result1 error)

func (*FakeBackgroundTaskRegistry) AddTask 

func (fake *FakeBackgroundTaskRegistry) AddTask(arg1 string, arg2 string)

func (*FakeBackgroundTaskRegistry) AddTaskArgsForCall 

func (fake *FakeBackgroundTaskRegistry) AddTaskArgsForCall(i int) (string, string)

func (*FakeBackgroundTaskRegistry) AddTaskCallCount 

func (fake *FakeBackgroundTaskRegistry) AddTaskCallCount() int

func (*FakeBackgroundTaskRegistry) AddTaskCalls 

func (fake *FakeBackgroundTaskRegistry) AddTaskCalls(stub func(string, string))

func (*FakeBackgroundTaskRegistry) ClearAllAgents 

func (fake *FakeBackgroundTaskRegistry) ClearAllAgents()

func (*FakeBackgroundTaskRegistry) ClearAllAgentsCallCount 

func (fake *FakeBackgroundTaskRegistry) ClearAllAgentsCallCount() int

func (*FakeBackgroundTaskRegistry) ClearAllAgentsCalls 

func (fake *FakeBackgroundTaskRegistry) ClearAllAgentsCalls(stub func())

func (*FakeBackgroundTaskRegistry) CountRunning 

func (fake *FakeBackgroundTaskRegistry) CountRunning() int

func (*FakeBackgroundTaskRegistry) CountRunningCallCount 

func (fake *FakeBackgroundTaskRegistry) CountRunningCallCount() int

func (*FakeBackgroundTaskRegistry) CountRunningCalls 

func (fake *FakeBackgroundTaskRegistry) CountRunningCalls(stub func() int)

func (*FakeBackgroundTaskRegistry) CountRunningJobs 

func (fake *FakeBackgroundTaskRegistry) CountRunningJobs(arg1 domain.JobKind) int

func (*FakeBackgroundTaskRegistry) CountRunningJobsArgsForCall 

func (fake *FakeBackgroundTaskRegistry) CountRunningJobsArgsForCall(i int) domain.JobKind

func (*FakeBackgroundTaskRegistry) CountRunningJobsCallCount 

func (fake *FakeBackgroundTaskRegistry) CountRunningJobsCallCount() int

func (*FakeBackgroundTaskRegistry) CountRunningJobsCalls 

func (fake *FakeBackgroundTaskRegistry) CountRunningJobsCalls(stub func(domain.JobKind) int)

func (*FakeBackgroundTaskRegistry) CountRunningJobsReturns 

func (fake *FakeBackgroundTaskRegistry) CountRunningJobsReturns(result1 int)

func (*FakeBackgroundTaskRegistry) CountRunningJobsReturnsOnCall 

func (fake *FakeBackgroundTaskRegistry) CountRunningJobsReturnsOnCall(i int, result1 int)

func (*FakeBackgroundTaskRegistry) CountRunningReturns 

func (fake *FakeBackgroundTaskRegistry) CountRunningReturns(result1 int)

func (*FakeBackgroundTaskRegistry) CountRunningReturnsOnCall 

func (fake *FakeBackgroundTaskRegistry) CountRunningReturnsOnCall(i int, result1 int)

func (*FakeBackgroundTaskRegistry) CountRunningSubagents 

func (fake *FakeBackgroundTaskRegistry) CountRunningSubagents() int

func (*FakeBackgroundTaskRegistry) CountRunningSubagentsCallCount 

func (fake *FakeBackgroundTaskRegistry) CountRunningSubagentsCallCount() int

func (*FakeBackgroundTaskRegistry) CountRunningSubagentsCalls 

func (fake *FakeBackgroundTaskRegistry) CountRunningSubagentsCalls(stub func() int)

func (*FakeBackgroundTaskRegistry) CountRunningSubagentsReturns 

func (fake *FakeBackgroundTaskRegistry) CountRunningSubagentsReturns(result1 int)

func (*FakeBackgroundTaskRegistry) CountRunningSubagentsReturnsOnCall 

func (fake *FakeBackgroundTaskRegistry) CountRunningSubagentsReturnsOnCall(i int, result1 int)

func (*FakeBackgroundTaskRegistry) Get 

func (fake *FakeBackgroundTaskRegistry) Get(arg1 string) *domain.BackgroundShell

func (*FakeBackgroundTaskRegistry) GetAll 

func (fake *FakeBackgroundTaskRegistry) GetAll() []*domain.BackgroundShell

func (*FakeBackgroundTaskRegistry) GetAllCallCount 

func (fake *FakeBackgroundTaskRegistry) GetAllCallCount() int

func (*FakeBackgroundTaskRegistry) GetAllCalls 

func (fake *FakeBackgroundTaskRegistry) GetAllCalls(stub func() []*domain.BackgroundShell)

func (*FakeBackgroundTaskRegistry) GetAllPollingTasks 

func (fake *FakeBackgroundTaskRegistry) GetAllPollingTasks() []string

func (*FakeBackgroundTaskRegistry) GetAllPollingTasksCallCount 

func (fake *FakeBackgroundTaskRegistry) GetAllPollingTasksCallCount() int

func (*FakeBackgroundTaskRegistry) GetAllPollingTasksCalls 

func (fake *FakeBackgroundTaskRegistry) GetAllPollingTasksCalls(stub func() []string)

func (*FakeBackgroundTaskRegistry) GetAllPollingTasksReturns 

func (fake *FakeBackgroundTaskRegistry) GetAllPollingTasksReturns(result1 []string)

func (*FakeBackgroundTaskRegistry) GetAllPollingTasksReturnsOnCall 

func (fake *FakeBackgroundTaskRegistry) GetAllPollingTasksReturnsOnCall(i int, result1 []string)

func (*FakeBackgroundTaskRegistry) GetAllReturns 

func (fake *FakeBackgroundTaskRegistry) GetAllReturns(result1 []*domain.BackgroundShell)

func (*FakeBackgroundTaskRegistry) GetAllReturnsOnCall 

func (fake *FakeBackgroundTaskRegistry) GetAllReturnsOnCall(i int, result1 []*domain.BackgroundShell)

func (*FakeBackgroundTaskRegistry) GetAllSubagents 

func (fake *FakeBackgroundTaskRegistry) GetAllSubagents() []*domain.SubagentState

func (*FakeBackgroundTaskRegistry) GetAllSubagentsCallCount 

func (fake *FakeBackgroundTaskRegistry) GetAllSubagentsCallCount() int

func (*FakeBackgroundTaskRegistry) GetAllSubagentsCalls 

func (fake *FakeBackgroundTaskRegistry) GetAllSubagentsCalls(stub func() []*domain.SubagentState)

func (*FakeBackgroundTaskRegistry) GetAllSubagentsReturns 

func (fake *FakeBackgroundTaskRegistry) GetAllSubagentsReturns(result1 []*domain.SubagentState)

func (*FakeBackgroundTaskRegistry) GetAllSubagentsReturnsOnCall 

func (fake *FakeBackgroundTaskRegistry) GetAllSubagentsReturnsOnCall(i int, result1 []*domain.SubagentState)

func (*FakeBackgroundTaskRegistry) GetArgsForCall 

func (fake *FakeBackgroundTaskRegistry) GetArgsForCall(i int) string

func (*FakeBackgroundTaskRegistry) GetCallCount 

func (fake *FakeBackgroundTaskRegistry) GetCallCount() int

func (*FakeBackgroundTaskRegistry) GetCalls 

func (fake *FakeBackgroundTaskRegistry) GetCalls(stub func(string) *domain.BackgroundShell)

func (*FakeBackgroundTaskRegistry) GetLatestContextForAgent 

func (fake *FakeBackgroundTaskRegistry) GetLatestContextForAgent(arg1 string) string

func (*FakeBackgroundTaskRegistry) GetLatestContextForAgentArgsForCall 

func (fake *FakeBackgroundTaskRegistry) GetLatestContextForAgentArgsForCall(i int) string

func (*FakeBackgroundTaskRegistry) GetLatestContextForAgentCallCount 

func (fake *FakeBackgroundTaskRegistry) GetLatestContextForAgentCallCount() int

func (*FakeBackgroundTaskRegistry) GetLatestContextForAgentCalls 

func (fake *FakeBackgroundTaskRegistry) GetLatestContextForAgentCalls(stub func(string) string)

func (*FakeBackgroundTaskRegistry) GetLatestContextForAgentReturns 

func (fake *FakeBackgroundTaskRegistry) GetLatestContextForAgentReturns(result1 string)

func (*FakeBackgroundTaskRegistry) GetLatestContextForAgentReturnsOnCall 

func (fake *FakeBackgroundTaskRegistry) GetLatestContextForAgentReturnsOnCall(i int, result1 string)

func (*FakeBackgroundTaskRegistry) GetLatestTaskForContext 

func (fake *FakeBackgroundTaskRegistry) GetLatestTaskForContext(arg1 string) string

func (*FakeBackgroundTaskRegistry) GetLatestTaskForContextArgsForCall 

func (fake *FakeBackgroundTaskRegistry) GetLatestTaskForContextArgsForCall(i int) string

func (*FakeBackgroundTaskRegistry) GetLatestTaskForContextCallCount 

func (fake *FakeBackgroundTaskRegistry) GetLatestTaskForContextCallCount() int

func (*FakeBackgroundTaskRegistry) GetLatestTaskForContextCalls 

func (fake *FakeBackgroundTaskRegistry) GetLatestTaskForContextCalls(stub func(string) string)

func (*FakeBackgroundTaskRegistry) GetLatestTaskForContextReturns 

func (fake *FakeBackgroundTaskRegistry) GetLatestTaskForContextReturns(result1 string)

func (*FakeBackgroundTaskRegistry) GetLatestTaskForContextReturnsOnCall 

func (fake *FakeBackgroundTaskRegistry) GetLatestTaskForContextReturnsOnCall(i int, result1 string)

func (*FakeBackgroundTaskRegistry) GetPollingState 

func (fake *FakeBackgroundTaskRegistry) GetPollingState(arg1 string) *domaina.TaskPollingState

func (*FakeBackgroundTaskRegistry) GetPollingStateArgsForCall 

func (fake *FakeBackgroundTaskRegistry) GetPollingStateArgsForCall(i int) string

func (*FakeBackgroundTaskRegistry) GetPollingStateCallCount 

func (fake *FakeBackgroundTaskRegistry) GetPollingStateCallCount() int

func (*FakeBackgroundTaskRegistry) GetPollingStateCalls 

func (fake *FakeBackgroundTaskRegistry) GetPollingStateCalls(stub func(string) *domaina.TaskPollingState)

func (*FakeBackgroundTaskRegistry) GetPollingStateReturns 

func (fake *FakeBackgroundTaskRegistry) GetPollingStateReturns(result1 *domaina.TaskPollingState)

func (*FakeBackgroundTaskRegistry) GetPollingStateReturnsOnCall 

func (fake *FakeBackgroundTaskRegistry) GetPollingStateReturnsOnCall(i int, result1 *domaina.TaskPollingState)

func (*FakeBackgroundTaskRegistry) GetReturns 

func (fake *FakeBackgroundTaskRegistry) GetReturns(result1 *domain.BackgroundShell)

func (*FakeBackgroundTaskRegistry) GetReturnsOnCall 

func (fake *FakeBackgroundTaskRegistry) GetReturnsOnCall(i int, result1 *domain.BackgroundShell)

func (*FakeBackgroundTaskRegistry) GetSubagent 

func (fake *FakeBackgroundTaskRegistry) GetSubagent(arg1 string) *domain.SubagentState

func (*FakeBackgroundTaskRegistry) GetSubagentArgsForCall 

func (fake *FakeBackgroundTaskRegistry) GetSubagentArgsForCall(i int) string

func (*FakeBackgroundTaskRegistry) GetSubagentCallCount 

func (fake *FakeBackgroundTaskRegistry) GetSubagentCallCount() int

func (*FakeBackgroundTaskRegistry) GetSubagentCalls 

func (fake *FakeBackgroundTaskRegistry) GetSubagentCalls(stub func(string) *domain.SubagentState)

func (*FakeBackgroundTaskRegistry) GetSubagentReturns 

func (fake *FakeBackgroundTaskRegistry) GetSubagentReturns(result1 *domain.SubagentState)

func (*FakeBackgroundTaskRegistry) GetSubagentReturnsOnCall 

func (fake *FakeBackgroundTaskRegistry) GetSubagentReturnsOnCall(i int, result1 *domain.SubagentState)

func (*FakeBackgroundTaskRegistry) HasContext 

func (fake *FakeBackgroundTaskRegistry) HasContext(arg1 string) bool

func (*FakeBackgroundTaskRegistry) HasContextArgsForCall 

func (fake *FakeBackgroundTaskRegistry) HasContextArgsForCall(i int) string

func (*FakeBackgroundTaskRegistry) HasContextCallCount 

func (fake *FakeBackgroundTaskRegistry) HasContextCallCount() int

func (*FakeBackgroundTaskRegistry) HasContextCalls 

func (fake *FakeBackgroundTaskRegistry) HasContextCalls(stub func(string) bool)

func (*FakeBackgroundTaskRegistry) HasContextReturns 

func (fake *FakeBackgroundTaskRegistry) HasContextReturns(result1 bool)

func (*FakeBackgroundTaskRegistry) HasContextReturnsOnCall 

func (fake *FakeBackgroundTaskRegistry) HasContextReturnsOnCall(i int, result1 bool)

func (*FakeBackgroundTaskRegistry) HasPending 

func (fake *FakeBackgroundTaskRegistry) HasPending() bool

func (*FakeBackgroundTaskRegistry) HasPendingCallCount 

func (fake *FakeBackgroundTaskRegistry) HasPendingCallCount() int

func (*FakeBackgroundTaskRegistry) HasPendingCalls 

func (fake *FakeBackgroundTaskRegistry) HasPendingCalls(stub func() bool)

func (*FakeBackgroundTaskRegistry) HasPendingReturns 

func (fake *FakeBackgroundTaskRegistry) HasPendingReturns(result1 bool)

func (*FakeBackgroundTaskRegistry) HasPendingReturnsOnCall 

func (fake *FakeBackgroundTaskRegistry) HasPendingReturnsOnCall(i int, result1 bool)

func (*FakeBackgroundTaskRegistry) Invocations 

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

func (*FakeBackgroundTaskRegistry) IsJobRunning 

func (fake *FakeBackgroundTaskRegistry) IsJobRunning(arg1 string) bool

func (*FakeBackgroundTaskRegistry) IsJobRunningArgsForCall 

func (fake *FakeBackgroundTaskRegistry) IsJobRunningArgsForCall(i int) string

func (*FakeBackgroundTaskRegistry) IsJobRunningCallCount 

func (fake *FakeBackgroundTaskRegistry) IsJobRunningCallCount() int

func (*FakeBackgroundTaskRegistry) IsJobRunningCalls 

func (fake *FakeBackgroundTaskRegistry) IsJobRunningCalls(stub func(string) bool)

func (*FakeBackgroundTaskRegistry) IsJobRunningReturns 

func (fake *FakeBackgroundTaskRegistry) IsJobRunningReturns(result1 bool)

func (*FakeBackgroundTaskRegistry) IsJobRunningReturnsOnCall 

func (fake *FakeBackgroundTaskRegistry) IsJobRunningReturnsOnCall(i int, result1 bool)

func (*FakeBackgroundTaskRegistry) RegisterContext 

func (fake *FakeBackgroundTaskRegistry) RegisterContext(arg1 string, arg2 string)

func (*FakeBackgroundTaskRegistry) RegisterContextArgsForCall 

func (fake *FakeBackgroundTaskRegistry) RegisterContextArgsForCall(i int) (string, string)

func (*FakeBackgroundTaskRegistry) RegisterContextCallCount 

func (fake *FakeBackgroundTaskRegistry) RegisterContextCallCount() int

func (*FakeBackgroundTaskRegistry) RegisterContextCalls 

func (fake *FakeBackgroundTaskRegistry) RegisterContextCalls(stub func(string, string))

func (*FakeBackgroundTaskRegistry) Remove 

func (fake *FakeBackgroundTaskRegistry) Remove(arg1 string) error

func (*FakeBackgroundTaskRegistry) RemoveArgsForCall 

func (fake *FakeBackgroundTaskRegistry) RemoveArgsForCall(i int) string

func (*FakeBackgroundTaskRegistry) RemoveCallCount 

func (fake *FakeBackgroundTaskRegistry) RemoveCallCount() int

func (*FakeBackgroundTaskRegistry) RemoveCalls 

func (fake *FakeBackgroundTaskRegistry) RemoveCalls(stub func(string) error)

func (*FakeBackgroundTaskRegistry) RemoveReturns 

func (fake *FakeBackgroundTaskRegistry) RemoveReturns(result1 error)

func (*FakeBackgroundTaskRegistry) RemoveReturnsOnCall 

func (fake *FakeBackgroundTaskRegistry) RemoveReturnsOnCall(i int, result1 error)

func (*FakeBackgroundTaskRegistry) RemoveSubagent 

func (fake *FakeBackgroundTaskRegistry) RemoveSubagent(arg1 string) error

func (*FakeBackgroundTaskRegistry) RemoveSubagentArgsForCall 

func (fake *FakeBackgroundTaskRegistry) RemoveSubagentArgsForCall(i int) string

func (*FakeBackgroundTaskRegistry) RemoveSubagentCallCount 

func (fake *FakeBackgroundTaskRegistry) RemoveSubagentCallCount() int

func (*FakeBackgroundTaskRegistry) RemoveSubagentCalls 

func (fake *FakeBackgroundTaskRegistry) RemoveSubagentCalls(stub func(string) error)

func (*FakeBackgroundTaskRegistry) RemoveSubagentReturns 

func (fake *FakeBackgroundTaskRegistry) RemoveSubagentReturns(result1 error)

func (*FakeBackgroundTaskRegistry) RemoveSubagentReturnsOnCall 

func (fake *FakeBackgroundTaskRegistry) RemoveSubagentReturnsOnCall(i int, result1 error)

func (*FakeBackgroundTaskRegistry) RemoveTask 

func (fake *FakeBackgroundTaskRegistry) RemoveTask(arg1 string)

func (*FakeBackgroundTaskRegistry) RemoveTaskArgsForCall 

func (fake *FakeBackgroundTaskRegistry) RemoveTaskArgsForCall(i int) string

func (*FakeBackgroundTaskRegistry) RemoveTaskCallCount 

func (fake *FakeBackgroundTaskRegistry) RemoveTaskCallCount() int

func (*FakeBackgroundTaskRegistry) RemoveTaskCalls 

func (fake *FakeBackgroundTaskRegistry) RemoveTaskCalls(stub func(string))

func (*FakeBackgroundTaskRegistry) SetSubagentStatus 

func (fake *FakeBackgroundTaskRegistry) SetSubagentStatus(arg1 string, arg2 domain.SubagentStatus) error

func (*FakeBackgroundTaskRegistry) SetSubagentStatusArgsForCall 

func (fake *FakeBackgroundTaskRegistry) SetSubagentStatusArgsForCall(i int) (string, domain.SubagentStatus)

func (*FakeBackgroundTaskRegistry) SetSubagentStatusCallCount 

func (fake *FakeBackgroundTaskRegistry) SetSubagentStatusCallCount() int

func (*FakeBackgroundTaskRegistry) SetSubagentStatusCalls 

func (fake *FakeBackgroundTaskRegistry) SetSubagentStatusCalls(stub func(string, domain.SubagentStatus) error)

func (*FakeBackgroundTaskRegistry) SetSubagentStatusReturns 

func (fake *FakeBackgroundTaskRegistry) SetSubagentStatusReturns(result1 error)

func (*FakeBackgroundTaskRegistry) SetSubagentStatusReturnsOnCall 

func (fake *FakeBackgroundTaskRegistry) SetSubagentStatusReturnsOnCall(i int, result1 error)

func (*FakeBackgroundTaskRegistry) Snapshot 

func (fake *FakeBackgroundTaskRegistry) Snapshot() []domain.TrackedJob

func (*FakeBackgroundTaskRegistry) SnapshotCallCount 

func (fake *FakeBackgroundTaskRegistry) SnapshotCallCount() int

func (*FakeBackgroundTaskRegistry) SnapshotCalls 

func (fake *FakeBackgroundTaskRegistry) SnapshotCalls(stub func() []domain.TrackedJob)

func (*FakeBackgroundTaskRegistry) SnapshotReturns 

func (fake *FakeBackgroundTaskRegistry) SnapshotReturns(result1 []domain.TrackedJob)

func (*FakeBackgroundTaskRegistry) SnapshotReturnsOnCall 

func (fake *FakeBackgroundTaskRegistry) SnapshotReturnsOnCall(i int, result1 []domain.TrackedJob)

func (*FakeBackgroundTaskRegistry) StartPolling 

func (fake *FakeBackgroundTaskRegistry) StartPolling(arg1 string, arg2 *domaina.TaskPollingState)

func (*FakeBackgroundTaskRegistry) StartPollingArgsForCall 

func (fake *FakeBackgroundTaskRegistry) StartPollingArgsForCall(i int) (string, *domaina.TaskPollingState)

func (*FakeBackgroundTaskRegistry) StartPollingCallCount 

func (fake *FakeBackgroundTaskRegistry) StartPollingCallCount() int

func (*FakeBackgroundTaskRegistry) StartPollingCalls 

func (fake *FakeBackgroundTaskRegistry) StartPollingCalls(stub func(string, *domaina.TaskPollingState))

func (*FakeBackgroundTaskRegistry) StopPolling 

func (fake *FakeBackgroundTaskRegistry) StopPolling(arg1 string)

func (*FakeBackgroundTaskRegistry) StopPollingArgsForCall 

func (fake *FakeBackgroundTaskRegistry) StopPollingArgsForCall(i int) string

func (*FakeBackgroundTaskRegistry) StopPollingCallCount 

func (fake *FakeBackgroundTaskRegistry) StopPollingCallCount() int

func (*FakeBackgroundTaskRegistry) StopPollingCalls 

func (fake *FakeBackgroundTaskRegistry) StopPollingCalls(stub func(string))

func (*FakeBackgroundTaskRegistry) Submit 

func (fake *FakeBackgroundTaskRegistry) Submit(arg1 domain.BackgroundJob)

func (*FakeBackgroundTaskRegistry) SubmitArgsForCall 

func (fake *FakeBackgroundTaskRegistry) SubmitArgsForCall(i int) domain.BackgroundJob

func (*FakeBackgroundTaskRegistry) SubmitCallCount 

func (fake *FakeBackgroundTaskRegistry) SubmitCallCount() int

func (*FakeBackgroundTaskRegistry) SubmitCalls 

func (fake *FakeBackgroundTaskRegistry) SubmitCalls(stub func(domain.BackgroundJob))

func (*FakeBackgroundTaskRegistry) WindJob 

func (fake *FakeBackgroundTaskRegistry) WindJob(arg1 string, arg2 domain.WindSignal) error

func (*FakeBackgroundTaskRegistry) WindJobArgsForCall 

func (fake *FakeBackgroundTaskRegistry) WindJobArgsForCall(i int) (string, domain.WindSignal)

func (*FakeBackgroundTaskRegistry) WindJobCallCount 

func (fake *FakeBackgroundTaskRegistry) WindJobCallCount() int

func (*FakeBackgroundTaskRegistry) WindJobCalls 

func (fake *FakeBackgroundTaskRegistry) WindJobCalls(stub func(string, domain.WindSignal) error)

func (*FakeBackgroundTaskRegistry) WindJobReturns 

func (fake *FakeBackgroundTaskRegistry) WindJobReturns(result1 error)

func (*FakeBackgroundTaskRegistry) WindJobReturnsOnCall 

func (fake *FakeBackgroundTaskRegistry) WindJobReturnsOnCall(i int, result1 error)

type FakeBackgroundTaskService 

type FakeBackgroundTaskService struct {
	CancelBackgroundTaskStub func(string) error

	GetBackgroundTasksStub func() []domaina.TaskPollingState
	// contains filtered or unexported fields
}

func (*FakeBackgroundTaskService) CancelBackgroundTask 

func (fake *FakeBackgroundTaskService) CancelBackgroundTask(arg1 string) error

func (*FakeBackgroundTaskService) CancelBackgroundTaskArgsForCall 

func (fake *FakeBackgroundTaskService) CancelBackgroundTaskArgsForCall(i int) string

func (*FakeBackgroundTaskService) CancelBackgroundTaskCallCount 

func (fake *FakeBackgroundTaskService) CancelBackgroundTaskCallCount() int

func (*FakeBackgroundTaskService) CancelBackgroundTaskCalls 

func (fake *FakeBackgroundTaskService) CancelBackgroundTaskCalls(stub func(string) error)

func (*FakeBackgroundTaskService) CancelBackgroundTaskReturns 

func (fake *FakeBackgroundTaskService) CancelBackgroundTaskReturns(result1 error)

func (*FakeBackgroundTaskService) CancelBackgroundTaskReturnsOnCall 

func (fake *FakeBackgroundTaskService) CancelBackgroundTaskReturnsOnCall(i int, result1 error)

func (*FakeBackgroundTaskService) GetBackgroundTasks 

func (fake *FakeBackgroundTaskService) GetBackgroundTasks() []domaina.TaskPollingState

func (*FakeBackgroundTaskService) GetBackgroundTasksCallCount 

func (fake *FakeBackgroundTaskService) GetBackgroundTasksCallCount() int

func (*FakeBackgroundTaskService) GetBackgroundTasksCalls 

func (fake *FakeBackgroundTaskService) GetBackgroundTasksCalls(stub func() []domaina.TaskPollingState)

func (*FakeBackgroundTaskService) GetBackgroundTasksReturns 

func (fake *FakeBackgroundTaskService) GetBackgroundTasksReturns(result1 []domaina.TaskPollingState)

func (*FakeBackgroundTaskService) GetBackgroundTasksReturnsOnCall 

func (fake *FakeBackgroundTaskService) GetBackgroundTasksReturnsOnCall(i int, result1 []domaina.TaskPollingState)

func (*FakeBackgroundTaskService) Invocations 

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

type FakeJobLivenessReporter 

type FakeJobLivenessReporter struct {
	IsJobRunningStub func(string) bool
	// contains filtered or unexported fields
}

func (*FakeJobLivenessReporter) Invocations 

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

func (*FakeJobLivenessReporter) IsJobRunning 

func (fake *FakeJobLivenessReporter) IsJobRunning(arg1 string) bool

func (*FakeJobLivenessReporter) IsJobRunningArgsForCall 

func (fake *FakeJobLivenessReporter) IsJobRunningArgsForCall(i int) string

func (*FakeJobLivenessReporter) IsJobRunningCallCount 

func (fake *FakeJobLivenessReporter) IsJobRunningCallCount() int

func (*FakeJobLivenessReporter) IsJobRunningCalls 

func (fake *FakeJobLivenessReporter) IsJobRunningCalls(stub func(string) bool)

func (*FakeJobLivenessReporter) IsJobRunningReturns 

func (fake *FakeJobLivenessReporter) IsJobRunningReturns(result1 bool)

func (*FakeJobLivenessReporter) IsJobRunningReturnsOnCall 

func (fake *FakeJobLivenessReporter) IsJobRunningReturnsOnCall(i int, result1 bool)

type FakeJobStopper 

type FakeJobStopper struct {
	WindJobStub func(string, domain.WindSignal) error
	// contains filtered or unexported fields
}

func (*FakeJobStopper) Invocations 

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

func (*FakeJobStopper) WindJob 

func (fake *FakeJobStopper) WindJob(arg1 string, arg2 domain.WindSignal) error

func (*FakeJobStopper) WindJobArgsForCall 

func (fake *FakeJobStopper) WindJobArgsForCall(i int) (string, domain.WindSignal)

func (*FakeJobStopper) WindJobCallCount 

func (fake *FakeJobStopper) WindJobCallCount() int

func (*FakeJobStopper) WindJobCalls 

func (fake *FakeJobStopper) WindJobCalls(stub func(string, domain.WindSignal) error)

func (*FakeJobStopper) WindJobReturns 

func (fake *FakeJobStopper) WindJobReturns(result1 error)

func (*FakeJobStopper) WindJobReturnsOnCall 

func (fake *FakeJobStopper) WindJobReturnsOnCall(i int, result1 error)

type FakeTaskRetentionService 

type FakeTaskRetentionService struct {
	AddTaskStub func(domain.TaskInfo)

	ClearStub func()

	GetMaxRetentionStub func() int

	GetTasksStub func() []domain.TaskInfo

	SetMaxRetentionStub func(int)
	// contains filtered or unexported fields
}

func (*FakeTaskRetentionService) AddTask 

func (fake *FakeTaskRetentionService) AddTask(arg1 domain.TaskInfo)

func (*FakeTaskRetentionService) AddTaskArgsForCall 

func (fake *FakeTaskRetentionService) AddTaskArgsForCall(i int) domain.TaskInfo

func (*FakeTaskRetentionService) AddTaskCallCount 

func (fake *FakeTaskRetentionService) AddTaskCallCount() int

func (*FakeTaskRetentionService) AddTaskCalls 

func (fake *FakeTaskRetentionService) AddTaskCalls(stub func(domain.TaskInfo))

func (*FakeTaskRetentionService) Clear 

func (fake *FakeTaskRetentionService) Clear()

func (*FakeTaskRetentionService) ClearCallCount 

func (fake *FakeTaskRetentionService) ClearCallCount() int

func (*FakeTaskRetentionService) ClearCalls 

func (fake *FakeTaskRetentionService) ClearCalls(stub func())

func (*FakeTaskRetentionService) GetMaxRetention 

func (fake *FakeTaskRetentionService) GetMaxRetention() int

func (*FakeTaskRetentionService) GetMaxRetentionCallCount 

func (fake *FakeTaskRetentionService) GetMaxRetentionCallCount() int

func (*FakeTaskRetentionService) GetMaxRetentionCalls 

func (fake *FakeTaskRetentionService) GetMaxRetentionCalls(stub func() int)

func (*FakeTaskRetentionService) GetMaxRetentionReturns 

func (fake *FakeTaskRetentionService) GetMaxRetentionReturns(result1 int)

func (*FakeTaskRetentionService) GetMaxRetentionReturnsOnCall 

func (fake *FakeTaskRetentionService) GetMaxRetentionReturnsOnCall(i int, result1 int)

func (*FakeTaskRetentionService) GetTasks 

func (fake *FakeTaskRetentionService) GetTasks() []domain.TaskInfo

func (*FakeTaskRetentionService) GetTasksCallCount 

func (fake *FakeTaskRetentionService) GetTasksCallCount() int

func (*FakeTaskRetentionService) GetTasksCalls 

func (fake *FakeTaskRetentionService) GetTasksCalls(stub func() []domain.TaskInfo)

func (*FakeTaskRetentionService) GetTasksReturns 

func (fake *FakeTaskRetentionService) GetTasksReturns(result1 []domain.TaskInfo)

func (*FakeTaskRetentionService) GetTasksReturnsOnCall 

func (fake *FakeTaskRetentionService) GetTasksReturnsOnCall(i int, result1 []domain.TaskInfo)

func (*FakeTaskRetentionService) Invocations 

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

func (*FakeTaskRetentionService) SetMaxRetention 

func (fake *FakeTaskRetentionService) SetMaxRetention(arg1 int)

func (*FakeTaskRetentionService) SetMaxRetentionArgsForCall 

func (fake *FakeTaskRetentionService) SetMaxRetentionArgsForCall(i int) int

func (*FakeTaskRetentionService) SetMaxRetentionCallCount 

func (fake *FakeTaskRetentionService) SetMaxRetentionCallCount() int

func (*FakeTaskRetentionService) SetMaxRetentionCalls 

func (fake *FakeTaskRetentionService) SetMaxRetentionCalls(stub func(int))

type FakeTitleGenerator 

type FakeTitleGenerator struct {
	ProcessPendingTitlesStub func(context.Context) error
	// contains filtered or unexported fields
}

func (*FakeTitleGenerator) Invocations 

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

func (*FakeTitleGenerator) ProcessPendingTitles 

func (fake *FakeTitleGenerator) ProcessPendingTitles(arg1 context.Context) error

func (*FakeTitleGenerator) ProcessPendingTitlesArgsForCall 

func (fake *FakeTitleGenerator) ProcessPendingTitlesArgsForCall(i int) context.Context

func (*FakeTitleGenerator) ProcessPendingTitlesCallCount 

func (fake *FakeTitleGenerator) ProcessPendingTitlesCallCount() int

func (*FakeTitleGenerator) ProcessPendingTitlesCalls 

func (fake *FakeTitleGenerator) ProcessPendingTitlesCalls(stub func(context.Context) error)

func (*FakeTitleGenerator) ProcessPendingTitlesReturns 

func (fake *FakeTitleGenerator) ProcessPendingTitlesReturns(result1 error)

func (*FakeTitleGenerator) ProcessPendingTitlesReturnsOnCall 

func (fake *FakeTitleGenerator) ProcessPendingTitlesReturnsOnCall(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.