Documentation
¶
Index ¶
- type Client
- func (_mock *Client) CancelTask(ctx context.Context, taskID string, activeDBClient db.Database) error
- func (_mock *Client) DefineAndRunImmediateOneShotTask(ctx context.Context, params task.DefineTaskParams, activeDBClient db.Database) (models.Task, error)
- func (_mock *Client) DefineAndRunScheduledOneShotTask(ctx context.Context, params task.DefineTaskParams, targetRuntime time.Time, ...) (models.Task, error)
- func (_mock *Client) DefineImmediateOneShotTask(ctx context.Context, params task.DefineTaskParams, activeDBClient db.Database) (models.Task, error)
- func (_mock *Client) DefineScheduledOneShotTask(ctx context.Context, params task.DefineTaskParams, targetRuntime time.Time, ...) (models.Task, error)
- func (_mock *Client) DeleteTask(ctx context.Context, taskID string, activeDBClient db.Database) error
- func (_m *Client) EXPECT() *Client_Expecter
- func (_mock *Client) GetTask(ctx context.Context, taskID string, activeDBClient db.Database) (models.Task, error)
- func (_mock *Client) GetTaskExecution(ctx context.Context, instanceID string, activeDBClient db.Database) (models.TaskExecution, error)
- func (_mock *Client) ListTaskExecutions(ctx context.Context, taskID string, filters db.TaskExecutionQueryFilter, ...) ([]models.TaskExecution, error)
- func (_mock *Client) ListTasks(ctx context.Context, filters db.TaskQueryFilter, activeDBClient db.Database) ([]models.Task, error)
- func (_mock *Client) SubmitTask(ctx context.Context, taskID string) error
- type Client_CancelTask_Call
- func (_c *Client_CancelTask_Call) Return(err error) *Client_CancelTask_Call
- func (_c *Client_CancelTask_Call) Run(run func(ctx context.Context, taskID string, activeDBClient db.Database)) *Client_CancelTask_Call
- func (_c *Client_CancelTask_Call) RunAndReturn(run func(ctx context.Context, taskID string, activeDBClient db.Database) error) *Client_CancelTask_Call
- type Client_DefineAndRunImmediateOneShotTask_Call
- func (_c *Client_DefineAndRunImmediateOneShotTask_Call) Return(task1 models.Task, err error) *Client_DefineAndRunImmediateOneShotTask_Call
- func (_c *Client_DefineAndRunImmediateOneShotTask_Call) Run(...) *Client_DefineAndRunImmediateOneShotTask_Call
- func (_c *Client_DefineAndRunImmediateOneShotTask_Call) RunAndReturn(...) *Client_DefineAndRunImmediateOneShotTask_Call
- type Client_DefineAndRunScheduledOneShotTask_Call
- func (_c *Client_DefineAndRunScheduledOneShotTask_Call) Return(task1 models.Task, err error) *Client_DefineAndRunScheduledOneShotTask_Call
- func (_c *Client_DefineAndRunScheduledOneShotTask_Call) Run(...) *Client_DefineAndRunScheduledOneShotTask_Call
- func (_c *Client_DefineAndRunScheduledOneShotTask_Call) RunAndReturn(...) *Client_DefineAndRunScheduledOneShotTask_Call
- type Client_DefineImmediateOneShotTask_Call
- func (_c *Client_DefineImmediateOneShotTask_Call) Return(task1 models.Task, err error) *Client_DefineImmediateOneShotTask_Call
- func (_c *Client_DefineImmediateOneShotTask_Call) Run(...) *Client_DefineImmediateOneShotTask_Call
- func (_c *Client_DefineImmediateOneShotTask_Call) RunAndReturn(...) *Client_DefineImmediateOneShotTask_Call
- type Client_DefineScheduledOneShotTask_Call
- func (_c *Client_DefineScheduledOneShotTask_Call) Return(task1 models.Task, err error) *Client_DefineScheduledOneShotTask_Call
- func (_c *Client_DefineScheduledOneShotTask_Call) Run(...) *Client_DefineScheduledOneShotTask_Call
- func (_c *Client_DefineScheduledOneShotTask_Call) RunAndReturn(...) *Client_DefineScheduledOneShotTask_Call
- type Client_DeleteTask_Call
- func (_c *Client_DeleteTask_Call) Return(err error) *Client_DeleteTask_Call
- func (_c *Client_DeleteTask_Call) Run(run func(ctx context.Context, taskID string, activeDBClient db.Database)) *Client_DeleteTask_Call
- func (_c *Client_DeleteTask_Call) RunAndReturn(run func(ctx context.Context, taskID string, activeDBClient db.Database) error) *Client_DeleteTask_Call
- type Client_Expecter
- func (_e *Client_Expecter) CancelTask(ctx interface{}, taskID interface{}, activeDBClient interface{}) *Client_CancelTask_Call
- func (_e *Client_Expecter) DefineAndRunImmediateOneShotTask(ctx interface{}, params interface{}, activeDBClient interface{}) *Client_DefineAndRunImmediateOneShotTask_Call
- func (_e *Client_Expecter) DefineAndRunScheduledOneShotTask(ctx interface{}, params interface{}, targetRuntime interface{}, ...) *Client_DefineAndRunScheduledOneShotTask_Call
- func (_e *Client_Expecter) DefineImmediateOneShotTask(ctx interface{}, params interface{}, activeDBClient interface{}) *Client_DefineImmediateOneShotTask_Call
- func (_e *Client_Expecter) DefineScheduledOneShotTask(ctx interface{}, params interface{}, targetRuntime interface{}, ...) *Client_DefineScheduledOneShotTask_Call
- func (_e *Client_Expecter) DeleteTask(ctx interface{}, taskID interface{}, activeDBClient interface{}) *Client_DeleteTask_Call
- func (_e *Client_Expecter) GetTask(ctx interface{}, taskID interface{}, activeDBClient interface{}) *Client_GetTask_Call
- func (_e *Client_Expecter) GetTaskExecution(ctx interface{}, instanceID interface{}, activeDBClient interface{}) *Client_GetTaskExecution_Call
- func (_e *Client_Expecter) ListTaskExecutions(ctx interface{}, taskID interface{}, filters interface{}, ...) *Client_ListTaskExecutions_Call
- func (_e *Client_Expecter) ListTasks(ctx interface{}, filters interface{}, activeDBClient interface{}) *Client_ListTasks_Call
- func (_e *Client_Expecter) SubmitTask(ctx interface{}, taskID interface{}) *Client_SubmitTask_Call
- type Client_GetTaskExecution_Call
- func (_c *Client_GetTaskExecution_Call) Return(taskExecution models.TaskExecution, err error) *Client_GetTaskExecution_Call
- func (_c *Client_GetTaskExecution_Call) Run(run func(ctx context.Context, instanceID string, activeDBClient db.Database)) *Client_GetTaskExecution_Call
- func (_c *Client_GetTaskExecution_Call) RunAndReturn(...) *Client_GetTaskExecution_Call
- type Client_GetTask_Call
- type Client_ListTaskExecutions_Call
- func (_c *Client_ListTaskExecutions_Call) Return(taskExecutions []models.TaskExecution, err error) *Client_ListTaskExecutions_Call
- func (_c *Client_ListTaskExecutions_Call) Run(...) *Client_ListTaskExecutions_Call
- func (_c *Client_ListTaskExecutions_Call) RunAndReturn(...) *Client_ListTaskExecutions_Call
- type Client_ListTasks_Call
- type Client_SubmitTask_Call
- func (_c *Client_SubmitTask_Call) Return(err error) *Client_SubmitTask_Call
- func (_c *Client_SubmitTask_Call) Run(run func(ctx context.Context, taskID string)) *Client_SubmitTask_Call
- func (_c *Client_SubmitTask_Call) RunAndReturn(run func(ctx context.Context, taskID string) error) *Client_SubmitTask_Call
- type Executor
- type Executor_Expecter
- type Executor_ProcessExecutionInstance_Call
- func (_c *Executor_ProcessExecutionInstance_Call) Return(err error) *Executor_ProcessExecutionInstance_Call
- func (_c *Executor_ProcessExecutionInstance_Call) Run(run func(ctx context.Context, instanceID string)) *Executor_ProcessExecutionInstance_Call
- func (_c *Executor_ProcessExecutionInstance_Call) RunAndReturn(run func(ctx context.Context, instanceID string) error) *Executor_ProcessExecutionInstance_Call
- type Executor_Stop_Call
- type Receiver
- type Receiver_Expecter
- type Receiver_Initialize_Call
- func (_c *Receiver_Initialize_Call) Return(err error) *Receiver_Initialize_Call
- func (_c *Receiver_Initialize_Call) Run(run func(ctx context.Context, activeDBClient db.Database)) *Receiver_Initialize_Call
- func (_c *Receiver_Initialize_Call) RunAndReturn(run func(ctx context.Context, activeDBClient db.Database) error) *Receiver_Initialize_Call
- type Receiver_Start_Call
- type Receiver_Stop_Call
- type Scheduler
- type Scheduler_Expecter
- type Scheduler_Start_Call
- type Scheduler_Stop_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
Client is an autogenerated mock type for the Client type
func NewClient ¶
NewClient creates a new instance of Client. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*Client) CancelTask ¶
func (_mock *Client) CancelTask(ctx context.Context, taskID string, activeDBClient db.Database) error
CancelTask provides a mock function for the type Client
func (*Client) DefineAndRunImmediateOneShotTask ¶
func (_mock *Client) DefineAndRunImmediateOneShotTask(ctx context.Context, params task.DefineTaskParams, activeDBClient db.Database) (models.Task, error)
DefineAndRunImmediateOneShotTask provides a mock function for the type Client
func (*Client) DefineAndRunScheduledOneShotTask ¶
func (_mock *Client) DefineAndRunScheduledOneShotTask(ctx context.Context, params task.DefineTaskParams, targetRuntime time.Time, activeDBClient db.Database) (models.Task, error)
DefineAndRunScheduledOneShotTask provides a mock function for the type Client
func (*Client) DefineImmediateOneShotTask ¶
func (_mock *Client) DefineImmediateOneShotTask(ctx context.Context, params task.DefineTaskParams, activeDBClient db.Database) (models.Task, error)
DefineImmediateOneShotTask provides a mock function for the type Client
func (*Client) DefineScheduledOneShotTask ¶
func (_mock *Client) DefineScheduledOneShotTask(ctx context.Context, params task.DefineTaskParams, targetRuntime time.Time, activeDBClient db.Database) (models.Task, error)
DefineScheduledOneShotTask provides a mock function for the type Client
func (*Client) DeleteTask ¶
func (_mock *Client) DeleteTask(ctx context.Context, taskID string, activeDBClient db.Database) error
DeleteTask provides a mock function for the type Client
func (*Client) EXPECT ¶
func (_m *Client) EXPECT() *Client_Expecter
func (*Client) GetTask ¶
func (_mock *Client) GetTask(ctx context.Context, taskID string, activeDBClient db.Database) (models.Task, error)
GetTask provides a mock function for the type Client
func (*Client) GetTaskExecution ¶
func (_mock *Client) GetTaskExecution(ctx context.Context, instanceID string, activeDBClient db.Database) (models.TaskExecution, error)
GetTaskExecution provides a mock function for the type Client
func (*Client) ListTaskExecutions ¶
func (_mock *Client) ListTaskExecutions(ctx context.Context, taskID string, filters db.TaskExecutionQueryFilter, activeDBClient db.Database) ([]models.TaskExecution, error)
ListTaskExecutions provides a mock function for the type Client
type Client_CancelTask_Call ¶
Client_CancelTask_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CancelTask'
func (*Client_CancelTask_Call) Return ¶
func (_c *Client_CancelTask_Call) Return(err error) *Client_CancelTask_Call
func (*Client_CancelTask_Call) Run ¶
func (_c *Client_CancelTask_Call) Run(run func(ctx context.Context, taskID string, activeDBClient db.Database)) *Client_CancelTask_Call
func (*Client_CancelTask_Call) RunAndReturn ¶
func (_c *Client_CancelTask_Call) RunAndReturn(run func(ctx context.Context, taskID string, activeDBClient db.Database) error) *Client_CancelTask_Call
type Client_DefineAndRunImmediateOneShotTask_Call ¶
Client_DefineAndRunImmediateOneShotTask_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DefineAndRunImmediateOneShotTask'
func (*Client_DefineAndRunImmediateOneShotTask_Call) Return ¶
func (_c *Client_DefineAndRunImmediateOneShotTask_Call) Return(task1 models.Task, err error) *Client_DefineAndRunImmediateOneShotTask_Call
func (*Client_DefineAndRunImmediateOneShotTask_Call) Run ¶
func (_c *Client_DefineAndRunImmediateOneShotTask_Call) Run(run func(ctx context.Context, params task.DefineTaskParams, activeDBClient db.Database)) *Client_DefineAndRunImmediateOneShotTask_Call
func (*Client_DefineAndRunImmediateOneShotTask_Call) RunAndReturn ¶
func (_c *Client_DefineAndRunImmediateOneShotTask_Call) RunAndReturn(run func(ctx context.Context, params task.DefineTaskParams, activeDBClient db.Database) (models.Task, error)) *Client_DefineAndRunImmediateOneShotTask_Call
type Client_DefineAndRunScheduledOneShotTask_Call ¶
Client_DefineAndRunScheduledOneShotTask_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DefineAndRunScheduledOneShotTask'
func (*Client_DefineAndRunScheduledOneShotTask_Call) Return ¶
func (_c *Client_DefineAndRunScheduledOneShotTask_Call) Return(task1 models.Task, err error) *Client_DefineAndRunScheduledOneShotTask_Call
func (*Client_DefineAndRunScheduledOneShotTask_Call) Run ¶
func (_c *Client_DefineAndRunScheduledOneShotTask_Call) Run(run func(ctx context.Context, params task.DefineTaskParams, targetRuntime time.Time, activeDBClient db.Database)) *Client_DefineAndRunScheduledOneShotTask_Call
func (*Client_DefineAndRunScheduledOneShotTask_Call) RunAndReturn ¶
func (_c *Client_DefineAndRunScheduledOneShotTask_Call) RunAndReturn(run func(ctx context.Context, params task.DefineTaskParams, targetRuntime time.Time, activeDBClient db.Database) (models.Task, error)) *Client_DefineAndRunScheduledOneShotTask_Call
type Client_DefineImmediateOneShotTask_Call ¶
Client_DefineImmediateOneShotTask_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DefineImmediateOneShotTask'
func (*Client_DefineImmediateOneShotTask_Call) Return ¶
func (_c *Client_DefineImmediateOneShotTask_Call) Return(task1 models.Task, err error) *Client_DefineImmediateOneShotTask_Call
func (*Client_DefineImmediateOneShotTask_Call) Run ¶
func (_c *Client_DefineImmediateOneShotTask_Call) Run(run func(ctx context.Context, params task.DefineTaskParams, activeDBClient db.Database)) *Client_DefineImmediateOneShotTask_Call
func (*Client_DefineImmediateOneShotTask_Call) RunAndReturn ¶
func (_c *Client_DefineImmediateOneShotTask_Call) RunAndReturn(run func(ctx context.Context, params task.DefineTaskParams, activeDBClient db.Database) (models.Task, error)) *Client_DefineImmediateOneShotTask_Call
type Client_DefineScheduledOneShotTask_Call ¶
Client_DefineScheduledOneShotTask_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DefineScheduledOneShotTask'
func (*Client_DefineScheduledOneShotTask_Call) Return ¶
func (_c *Client_DefineScheduledOneShotTask_Call) Return(task1 models.Task, err error) *Client_DefineScheduledOneShotTask_Call
func (*Client_DefineScheduledOneShotTask_Call) Run ¶
func (_c *Client_DefineScheduledOneShotTask_Call) Run(run func(ctx context.Context, params task.DefineTaskParams, targetRuntime time.Time, activeDBClient db.Database)) *Client_DefineScheduledOneShotTask_Call
func (*Client_DefineScheduledOneShotTask_Call) RunAndReturn ¶
func (_c *Client_DefineScheduledOneShotTask_Call) RunAndReturn(run func(ctx context.Context, params task.DefineTaskParams, targetRuntime time.Time, activeDBClient db.Database) (models.Task, error)) *Client_DefineScheduledOneShotTask_Call
type Client_DeleteTask_Call ¶
Client_DeleteTask_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteTask'
func (*Client_DeleteTask_Call) Return ¶
func (_c *Client_DeleteTask_Call) Return(err error) *Client_DeleteTask_Call
func (*Client_DeleteTask_Call) Run ¶
func (_c *Client_DeleteTask_Call) Run(run func(ctx context.Context, taskID string, activeDBClient db.Database)) *Client_DeleteTask_Call
func (*Client_DeleteTask_Call) RunAndReturn ¶
func (_c *Client_DeleteTask_Call) RunAndReturn(run func(ctx context.Context, taskID string, activeDBClient db.Database) error) *Client_DeleteTask_Call
type Client_Expecter ¶
type Client_Expecter struct {
// contains filtered or unexported fields
}
func (*Client_Expecter) CancelTask ¶
func (_e *Client_Expecter) CancelTask(ctx interface{}, taskID interface{}, activeDBClient interface{}) *Client_CancelTask_Call
CancelTask is a helper method to define mock.On call
- ctx context.Context
- taskID string
- activeDBClient db.Database
func (*Client_Expecter) DefineAndRunImmediateOneShotTask ¶
func (_e *Client_Expecter) DefineAndRunImmediateOneShotTask(ctx interface{}, params interface{}, activeDBClient interface{}) *Client_DefineAndRunImmediateOneShotTask_Call
DefineAndRunImmediateOneShotTask is a helper method to define mock.On call
- ctx context.Context
- params task.DefineTaskParams
- activeDBClient db.Database
func (*Client_Expecter) DefineAndRunScheduledOneShotTask ¶
func (_e *Client_Expecter) DefineAndRunScheduledOneShotTask(ctx interface{}, params interface{}, targetRuntime interface{}, activeDBClient interface{}) *Client_DefineAndRunScheduledOneShotTask_Call
DefineAndRunScheduledOneShotTask is a helper method to define mock.On call
- ctx context.Context
- params task.DefineTaskParams
- targetRuntime time.Time
- activeDBClient db.Database
func (*Client_Expecter) DefineImmediateOneShotTask ¶
func (_e *Client_Expecter) DefineImmediateOneShotTask(ctx interface{}, params interface{}, activeDBClient interface{}) *Client_DefineImmediateOneShotTask_Call
DefineImmediateOneShotTask is a helper method to define mock.On call
- ctx context.Context
- params task.DefineTaskParams
- activeDBClient db.Database
func (*Client_Expecter) DefineScheduledOneShotTask ¶
func (_e *Client_Expecter) DefineScheduledOneShotTask(ctx interface{}, params interface{}, targetRuntime interface{}, activeDBClient interface{}) *Client_DefineScheduledOneShotTask_Call
DefineScheduledOneShotTask is a helper method to define mock.On call
- ctx context.Context
- params task.DefineTaskParams
- targetRuntime time.Time
- activeDBClient db.Database
func (*Client_Expecter) DeleteTask ¶
func (_e *Client_Expecter) DeleteTask(ctx interface{}, taskID interface{}, activeDBClient interface{}) *Client_DeleteTask_Call
DeleteTask is a helper method to define mock.On call
- ctx context.Context
- taskID string
- activeDBClient db.Database
func (*Client_Expecter) GetTask ¶
func (_e *Client_Expecter) GetTask(ctx interface{}, taskID interface{}, activeDBClient interface{}) *Client_GetTask_Call
GetTask is a helper method to define mock.On call
- ctx context.Context
- taskID string
- activeDBClient db.Database
func (*Client_Expecter) GetTaskExecution ¶
func (_e *Client_Expecter) GetTaskExecution(ctx interface{}, instanceID interface{}, activeDBClient interface{}) *Client_GetTaskExecution_Call
GetTaskExecution is a helper method to define mock.On call
- ctx context.Context
- instanceID string
- activeDBClient db.Database
func (*Client_Expecter) ListTaskExecutions ¶
func (_e *Client_Expecter) ListTaskExecutions(ctx interface{}, taskID interface{}, filters interface{}, activeDBClient interface{}) *Client_ListTaskExecutions_Call
ListTaskExecutions is a helper method to define mock.On call
- ctx context.Context
- taskID string
- filters db.TaskExecutionQueryFilter
- activeDBClient db.Database
func (*Client_Expecter) ListTasks ¶
func (_e *Client_Expecter) ListTasks(ctx interface{}, filters interface{}, activeDBClient interface{}) *Client_ListTasks_Call
ListTasks is a helper method to define mock.On call
- ctx context.Context
- filters db.TaskQueryFilter
- activeDBClient db.Database
func (*Client_Expecter) SubmitTask ¶
func (_e *Client_Expecter) SubmitTask(ctx interface{}, taskID interface{}) *Client_SubmitTask_Call
SubmitTask is a helper method to define mock.On call
- ctx context.Context
- taskID string
type Client_GetTaskExecution_Call ¶
Client_GetTaskExecution_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTaskExecution'
func (*Client_GetTaskExecution_Call) Return ¶
func (_c *Client_GetTaskExecution_Call) Return(taskExecution models.TaskExecution, err error) *Client_GetTaskExecution_Call
func (*Client_GetTaskExecution_Call) Run ¶
func (_c *Client_GetTaskExecution_Call) Run(run func(ctx context.Context, instanceID string, activeDBClient db.Database)) *Client_GetTaskExecution_Call
func (*Client_GetTaskExecution_Call) RunAndReturn ¶
func (_c *Client_GetTaskExecution_Call) RunAndReturn(run func(ctx context.Context, instanceID string, activeDBClient db.Database) (models.TaskExecution, error)) *Client_GetTaskExecution_Call
type Client_GetTask_Call ¶
Client_GetTask_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTask'
func (*Client_GetTask_Call) Return ¶
func (_c *Client_GetTask_Call) Return(task1 models.Task, err error) *Client_GetTask_Call
func (*Client_GetTask_Call) Run ¶
func (_c *Client_GetTask_Call) Run(run func(ctx context.Context, taskID string, activeDBClient db.Database)) *Client_GetTask_Call
func (*Client_GetTask_Call) RunAndReturn ¶
func (_c *Client_GetTask_Call) RunAndReturn(run func(ctx context.Context, taskID string, activeDBClient db.Database) (models.Task, error)) *Client_GetTask_Call
type Client_ListTaskExecutions_Call ¶
Client_ListTaskExecutions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListTaskExecutions'
func (*Client_ListTaskExecutions_Call) Return ¶
func (_c *Client_ListTaskExecutions_Call) Return(taskExecutions []models.TaskExecution, err error) *Client_ListTaskExecutions_Call
func (*Client_ListTaskExecutions_Call) Run ¶
func (_c *Client_ListTaskExecutions_Call) Run(run func(ctx context.Context, taskID string, filters db.TaskExecutionQueryFilter, activeDBClient db.Database)) *Client_ListTaskExecutions_Call
func (*Client_ListTaskExecutions_Call) RunAndReturn ¶
func (_c *Client_ListTaskExecutions_Call) RunAndReturn(run func(ctx context.Context, taskID string, filters db.TaskExecutionQueryFilter, activeDBClient db.Database) ([]models.TaskExecution, error)) *Client_ListTaskExecutions_Call
type Client_ListTasks_Call ¶
Client_ListTasks_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListTasks'
func (*Client_ListTasks_Call) Return ¶
func (_c *Client_ListTasks_Call) Return(tasks []models.Task, err error) *Client_ListTasks_Call
func (*Client_ListTasks_Call) Run ¶
func (_c *Client_ListTasks_Call) Run(run func(ctx context.Context, filters db.TaskQueryFilter, activeDBClient db.Database)) *Client_ListTasks_Call
func (*Client_ListTasks_Call) RunAndReturn ¶
func (_c *Client_ListTasks_Call) RunAndReturn(run func(ctx context.Context, filters db.TaskQueryFilter, activeDBClient db.Database) ([]models.Task, error)) *Client_ListTasks_Call
type Client_SubmitTask_Call ¶
Client_SubmitTask_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SubmitTask'
func (*Client_SubmitTask_Call) Return ¶
func (_c *Client_SubmitTask_Call) Return(err error) *Client_SubmitTask_Call
func (*Client_SubmitTask_Call) Run ¶
func (_c *Client_SubmitTask_Call) Run(run func(ctx context.Context, taskID string)) *Client_SubmitTask_Call
func (*Client_SubmitTask_Call) RunAndReturn ¶
func (_c *Client_SubmitTask_Call) RunAndReturn(run func(ctx context.Context, taskID string) error) *Client_SubmitTask_Call
type Executor ¶
Executor is an autogenerated mock type for the Executor type
func NewExecutor ¶
NewExecutor creates a new instance of Executor. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*Executor) EXPECT ¶
func (_m *Executor) EXPECT() *Executor_Expecter
func (*Executor) ProcessExecutionInstance ¶
ProcessExecutionInstance provides a mock function for the type Executor
type Executor_Expecter ¶
type Executor_Expecter struct {
// contains filtered or unexported fields
}
func (*Executor_Expecter) ProcessExecutionInstance ¶
func (_e *Executor_Expecter) ProcessExecutionInstance(ctx interface{}, instanceID interface{}) *Executor_ProcessExecutionInstance_Call
ProcessExecutionInstance is a helper method to define mock.On call
- ctx context.Context
- instanceID string
func (*Executor_Expecter) Stop ¶
func (_e *Executor_Expecter) Stop(ctx interface{}) *Executor_Stop_Call
Stop is a helper method to define mock.On call
- ctx context.Context
type Executor_ProcessExecutionInstance_Call ¶
Executor_ProcessExecutionInstance_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ProcessExecutionInstance'
func (*Executor_ProcessExecutionInstance_Call) Return ¶
func (_c *Executor_ProcessExecutionInstance_Call) Return(err error) *Executor_ProcessExecutionInstance_Call
func (*Executor_ProcessExecutionInstance_Call) Run ¶
func (_c *Executor_ProcessExecutionInstance_Call) Run(run func(ctx context.Context, instanceID string)) *Executor_ProcessExecutionInstance_Call
func (*Executor_ProcessExecutionInstance_Call) RunAndReturn ¶
func (_c *Executor_ProcessExecutionInstance_Call) RunAndReturn(run func(ctx context.Context, instanceID string) error) *Executor_ProcessExecutionInstance_Call
type Executor_Stop_Call ¶
Executor_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'
func (*Executor_Stop_Call) Return ¶
func (_c *Executor_Stop_Call) Return(err error) *Executor_Stop_Call
func (*Executor_Stop_Call) Run ¶
func (_c *Executor_Stop_Call) Run(run func(ctx context.Context)) *Executor_Stop_Call
func (*Executor_Stop_Call) RunAndReturn ¶
func (_c *Executor_Stop_Call) RunAndReturn(run func(ctx context.Context) error) *Executor_Stop_Call
type Receiver ¶
Receiver is an autogenerated mock type for the Receiver type
func NewReceiver ¶
NewReceiver creates a new instance of Receiver. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*Receiver) EXPECT ¶
func (_m *Receiver) EXPECT() *Receiver_Expecter
func (*Receiver) Initialize ¶
Initialize provides a mock function for the type Receiver
type Receiver_Expecter ¶
type Receiver_Expecter struct {
// contains filtered or unexported fields
}
func (*Receiver_Expecter) Initialize ¶
func (_e *Receiver_Expecter) Initialize(ctx interface{}, activeDBClient interface{}) *Receiver_Initialize_Call
Initialize is a helper method to define mock.On call
- ctx context.Context
- activeDBClient db.Database
func (*Receiver_Expecter) Start ¶
func (_e *Receiver_Expecter) Start(ctx interface{}) *Receiver_Start_Call
Start is a helper method to define mock.On call
- ctx context.Context
func (*Receiver_Expecter) Stop ¶
func (_e *Receiver_Expecter) Stop(ctx interface{}) *Receiver_Stop_Call
Stop is a helper method to define mock.On call
- ctx context.Context
type Receiver_Initialize_Call ¶
Receiver_Initialize_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Initialize'
func (*Receiver_Initialize_Call) Return ¶
func (_c *Receiver_Initialize_Call) Return(err error) *Receiver_Initialize_Call
func (*Receiver_Initialize_Call) Run ¶
func (_c *Receiver_Initialize_Call) Run(run func(ctx context.Context, activeDBClient db.Database)) *Receiver_Initialize_Call
func (*Receiver_Initialize_Call) RunAndReturn ¶
func (_c *Receiver_Initialize_Call) RunAndReturn(run func(ctx context.Context, activeDBClient db.Database) error) *Receiver_Initialize_Call
type Receiver_Start_Call ¶
Receiver_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'
func (*Receiver_Start_Call) Return ¶
func (_c *Receiver_Start_Call) Return(err error) *Receiver_Start_Call
func (*Receiver_Start_Call) Run ¶
func (_c *Receiver_Start_Call) Run(run func(ctx context.Context)) *Receiver_Start_Call
func (*Receiver_Start_Call) RunAndReturn ¶
func (_c *Receiver_Start_Call) RunAndReturn(run func(ctx context.Context) error) *Receiver_Start_Call
type Receiver_Stop_Call ¶
Receiver_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'
func (*Receiver_Stop_Call) Return ¶
func (_c *Receiver_Stop_Call) Return(err error) *Receiver_Stop_Call
func (*Receiver_Stop_Call) Run ¶
func (_c *Receiver_Stop_Call) Run(run func(ctx context.Context)) *Receiver_Stop_Call
func (*Receiver_Stop_Call) RunAndReturn ¶
func (_c *Receiver_Stop_Call) RunAndReturn(run func(ctx context.Context) error) *Receiver_Stop_Call
type Scheduler ¶
Scheduler is an autogenerated mock type for the Scheduler type
func NewScheduler ¶
NewScheduler creates a new instance of Scheduler. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*Scheduler) EXPECT ¶
func (_m *Scheduler) EXPECT() *Scheduler_Expecter
type Scheduler_Expecter ¶
type Scheduler_Expecter struct {
// contains filtered or unexported fields
}
func (*Scheduler_Expecter) Start ¶
func (_e *Scheduler_Expecter) Start(ctx interface{}) *Scheduler_Start_Call
Start is a helper method to define mock.On call
- ctx context.Context
func (*Scheduler_Expecter) Stop ¶
func (_e *Scheduler_Expecter) Stop(ctx interface{}) *Scheduler_Stop_Call
Stop is a helper method to define mock.On call
- ctx context.Context
type Scheduler_Start_Call ¶
Scheduler_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'
func (*Scheduler_Start_Call) Return ¶
func (_c *Scheduler_Start_Call) Return(err error) *Scheduler_Start_Call
func (*Scheduler_Start_Call) Run ¶
func (_c *Scheduler_Start_Call) Run(run func(ctx context.Context)) *Scheduler_Start_Call
func (*Scheduler_Start_Call) RunAndReturn ¶
func (_c *Scheduler_Start_Call) RunAndReturn(run func(ctx context.Context) error) *Scheduler_Start_Call
type Scheduler_Stop_Call ¶
Scheduler_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'
func (*Scheduler_Stop_Call) Return ¶
func (_c *Scheduler_Stop_Call) Return(err error) *Scheduler_Stop_Call
func (*Scheduler_Stop_Call) Run ¶
func (_c *Scheduler_Stop_Call) Run(run func(ctx context.Context)) *Scheduler_Stop_Call
func (*Scheduler_Stop_Call) RunAndReturn ¶
func (_c *Scheduler_Stop_Call) RunAndReturn(run func(ctx context.Context) error) *Scheduler_Stop_Call