Documentation
¶
Index ¶
- type TaskRepository
- func (_m *TaskRepository) CancelTaskByID(ctx context.Context, id int64) (*repository.FullTask, bool, error)
- func (_m *TaskRepository) CancelTaskByIDWithTx(ctx context.Context, tx asynqpg.Tx, id int64) (*repository.FullTask, bool, error)
- func (_m *TaskRepository) DeleteTaskByID(ctx context.Context, id int64) (*repository.FullTask, bool, error)
- func (_m *TaskRepository) DeleteTaskByIDWithTx(ctx context.Context, tx asynqpg.Tx, id int64) (*repository.FullTask, bool, error)
- func (_m *TaskRepository) EXPECT() *TaskRepository_Expecter
- func (_m *TaskRepository) GetTaskByID(ctx context.Context, id int64) (*repository.FullTask, error)
- func (_m *TaskRepository) GetTaskByIDWithTx(ctx context.Context, tx asynqpg.Tx, id int64) (*repository.FullTask, error)
- func (_m *TaskRepository) ListTasks(ctx context.Context, params repository.ListTasksParams) (*repository.ListTasksResult, error)
- func (_m *TaskRepository) ListTasksWithTx(ctx context.Context, tx asynqpg.Tx, params repository.ListTasksParams) (*repository.ListTasksResult, error)
- func (_m *TaskRepository) RetryTaskByID(ctx context.Context, id int64) (*repository.FullTask, bool, error)
- func (_m *TaskRepository) RetryTaskByIDWithTx(ctx context.Context, tx asynqpg.Tx, id int64) (*repository.FullTask, bool, error)
- type TaskRepository_CancelTaskByIDWithTx_Call
- func (_c *TaskRepository_CancelTaskByIDWithTx_Call) Return(_a0 *repository.FullTask, _a1 bool, _a2 error) *TaskRepository_CancelTaskByIDWithTx_Call
- func (_c *TaskRepository_CancelTaskByIDWithTx_Call) Run(run func(ctx context.Context, tx asynqpg.Tx, id int64)) *TaskRepository_CancelTaskByIDWithTx_Call
- func (_c *TaskRepository_CancelTaskByIDWithTx_Call) RunAndReturn(...) *TaskRepository_CancelTaskByIDWithTx_Call
- type TaskRepository_CancelTaskByID_Call
- func (_c *TaskRepository_CancelTaskByID_Call) Return(_a0 *repository.FullTask, _a1 bool, _a2 error) *TaskRepository_CancelTaskByID_Call
- func (_c *TaskRepository_CancelTaskByID_Call) Run(run func(ctx context.Context, id int64)) *TaskRepository_CancelTaskByID_Call
- func (_c *TaskRepository_CancelTaskByID_Call) RunAndReturn(run func(context.Context, int64) (*repository.FullTask, bool, error)) *TaskRepository_CancelTaskByID_Call
- type TaskRepository_DeleteTaskByIDWithTx_Call
- func (_c *TaskRepository_DeleteTaskByIDWithTx_Call) Return(_a0 *repository.FullTask, _a1 bool, _a2 error) *TaskRepository_DeleteTaskByIDWithTx_Call
- func (_c *TaskRepository_DeleteTaskByIDWithTx_Call) Run(run func(ctx context.Context, tx asynqpg.Tx, id int64)) *TaskRepository_DeleteTaskByIDWithTx_Call
- func (_c *TaskRepository_DeleteTaskByIDWithTx_Call) RunAndReturn(...) *TaskRepository_DeleteTaskByIDWithTx_Call
- type TaskRepository_DeleteTaskByID_Call
- func (_c *TaskRepository_DeleteTaskByID_Call) Return(_a0 *repository.FullTask, _a1 bool, _a2 error) *TaskRepository_DeleteTaskByID_Call
- func (_c *TaskRepository_DeleteTaskByID_Call) Run(run func(ctx context.Context, id int64)) *TaskRepository_DeleteTaskByID_Call
- func (_c *TaskRepository_DeleteTaskByID_Call) RunAndReturn(run func(context.Context, int64) (*repository.FullTask, bool, error)) *TaskRepository_DeleteTaskByID_Call
- type TaskRepository_Expecter
- func (_e *TaskRepository_Expecter) CancelTaskByID(ctx interface{}, id interface{}) *TaskRepository_CancelTaskByID_Call
- func (_e *TaskRepository_Expecter) CancelTaskByIDWithTx(ctx interface{}, tx interface{}, id interface{}) *TaskRepository_CancelTaskByIDWithTx_Call
- func (_e *TaskRepository_Expecter) DeleteTaskByID(ctx interface{}, id interface{}) *TaskRepository_DeleteTaskByID_Call
- func (_e *TaskRepository_Expecter) DeleteTaskByIDWithTx(ctx interface{}, tx interface{}, id interface{}) *TaskRepository_DeleteTaskByIDWithTx_Call
- func (_e *TaskRepository_Expecter) GetTaskByID(ctx interface{}, id interface{}) *TaskRepository_GetTaskByID_Call
- func (_e *TaskRepository_Expecter) GetTaskByIDWithTx(ctx interface{}, tx interface{}, id interface{}) *TaskRepository_GetTaskByIDWithTx_Call
- func (_e *TaskRepository_Expecter) ListTasks(ctx interface{}, params interface{}) *TaskRepository_ListTasks_Call
- func (_e *TaskRepository_Expecter) ListTasksWithTx(ctx interface{}, tx interface{}, params interface{}) *TaskRepository_ListTasksWithTx_Call
- func (_e *TaskRepository_Expecter) RetryTaskByID(ctx interface{}, id interface{}) *TaskRepository_RetryTaskByID_Call
- func (_e *TaskRepository_Expecter) RetryTaskByIDWithTx(ctx interface{}, tx interface{}, id interface{}) *TaskRepository_RetryTaskByIDWithTx_Call
- type TaskRepository_GetTaskByIDWithTx_Call
- func (_c *TaskRepository_GetTaskByIDWithTx_Call) Return(_a0 *repository.FullTask, _a1 error) *TaskRepository_GetTaskByIDWithTx_Call
- func (_c *TaskRepository_GetTaskByIDWithTx_Call) Run(run func(ctx context.Context, tx asynqpg.Tx, id int64)) *TaskRepository_GetTaskByIDWithTx_Call
- func (_c *TaskRepository_GetTaskByIDWithTx_Call) RunAndReturn(run func(context.Context, asynqpg.Tx, int64) (*repository.FullTask, error)) *TaskRepository_GetTaskByIDWithTx_Call
- type TaskRepository_GetTaskByID_Call
- func (_c *TaskRepository_GetTaskByID_Call) Return(_a0 *repository.FullTask, _a1 error) *TaskRepository_GetTaskByID_Call
- func (_c *TaskRepository_GetTaskByID_Call) Run(run func(ctx context.Context, id int64)) *TaskRepository_GetTaskByID_Call
- func (_c *TaskRepository_GetTaskByID_Call) RunAndReturn(run func(context.Context, int64) (*repository.FullTask, error)) *TaskRepository_GetTaskByID_Call
- type TaskRepository_ListTasksWithTx_Call
- func (_c *TaskRepository_ListTasksWithTx_Call) Return(_a0 *repository.ListTasksResult, _a1 error) *TaskRepository_ListTasksWithTx_Call
- func (_c *TaskRepository_ListTasksWithTx_Call) Run(...) *TaskRepository_ListTasksWithTx_Call
- func (_c *TaskRepository_ListTasksWithTx_Call) RunAndReturn(...) *TaskRepository_ListTasksWithTx_Call
- type TaskRepository_ListTasks_Call
- func (_c *TaskRepository_ListTasks_Call) Return(_a0 *repository.ListTasksResult, _a1 error) *TaskRepository_ListTasks_Call
- func (_c *TaskRepository_ListTasks_Call) Run(run func(ctx context.Context, params repository.ListTasksParams)) *TaskRepository_ListTasks_Call
- func (_c *TaskRepository_ListTasks_Call) RunAndReturn(...) *TaskRepository_ListTasks_Call
- type TaskRepository_RetryTaskByIDWithTx_Call
- func (_c *TaskRepository_RetryTaskByIDWithTx_Call) Return(_a0 *repository.FullTask, _a1 bool, _a2 error) *TaskRepository_RetryTaskByIDWithTx_Call
- func (_c *TaskRepository_RetryTaskByIDWithTx_Call) Run(run func(ctx context.Context, tx asynqpg.Tx, id int64)) *TaskRepository_RetryTaskByIDWithTx_Call
- func (_c *TaskRepository_RetryTaskByIDWithTx_Call) RunAndReturn(...) *TaskRepository_RetryTaskByIDWithTx_Call
- type TaskRepository_RetryTaskByID_Call
- func (_c *TaskRepository_RetryTaskByID_Call) Return(_a0 *repository.FullTask, _a1 bool, _a2 error) *TaskRepository_RetryTaskByID_Call
- func (_c *TaskRepository_RetryTaskByID_Call) Run(run func(ctx context.Context, id int64)) *TaskRepository_RetryTaskByID_Call
- func (_c *TaskRepository_RetryTaskByID_Call) RunAndReturn(run func(context.Context, int64) (*repository.FullTask, bool, error)) *TaskRepository_RetryTaskByID_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TaskRepository ¶
TaskRepository is an autogenerated mock type for the taskRepository type
func NewTaskRepository ¶
func NewTaskRepository(t interface {
mock.TestingT
Cleanup(func())
}) *TaskRepository
NewTaskRepository creates a new instance of TaskRepository. 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 (*TaskRepository) CancelTaskByID ¶
func (_m *TaskRepository) CancelTaskByID(ctx context.Context, id int64) (*repository.FullTask, bool, error)
CancelTaskByID provides a mock function with given fields: ctx, id
func (*TaskRepository) CancelTaskByIDWithTx ¶
func (_m *TaskRepository) CancelTaskByIDWithTx(ctx context.Context, tx asynqpg.Tx, id int64) (*repository.FullTask, bool, error)
CancelTaskByIDWithTx provides a mock function with given fields: ctx, tx, id
func (*TaskRepository) DeleteTaskByID ¶
func (_m *TaskRepository) DeleteTaskByID(ctx context.Context, id int64) (*repository.FullTask, bool, error)
DeleteTaskByID provides a mock function with given fields: ctx, id
func (*TaskRepository) DeleteTaskByIDWithTx ¶
func (_m *TaskRepository) DeleteTaskByIDWithTx(ctx context.Context, tx asynqpg.Tx, id int64) (*repository.FullTask, bool, error)
DeleteTaskByIDWithTx provides a mock function with given fields: ctx, tx, id
func (*TaskRepository) EXPECT ¶
func (_m *TaskRepository) EXPECT() *TaskRepository_Expecter
func (*TaskRepository) GetTaskByID ¶
func (_m *TaskRepository) GetTaskByID(ctx context.Context, id int64) (*repository.FullTask, error)
GetTaskByID provides a mock function with given fields: ctx, id
func (*TaskRepository) GetTaskByIDWithTx ¶
func (_m *TaskRepository) GetTaskByIDWithTx(ctx context.Context, tx asynqpg.Tx, id int64) (*repository.FullTask, error)
GetTaskByIDWithTx provides a mock function with given fields: ctx, tx, id
func (*TaskRepository) ListTasks ¶
func (_m *TaskRepository) ListTasks(ctx context.Context, params repository.ListTasksParams) (*repository.ListTasksResult, error)
ListTasks provides a mock function with given fields: ctx, params
func (*TaskRepository) ListTasksWithTx ¶
func (_m *TaskRepository) ListTasksWithTx(ctx context.Context, tx asynqpg.Tx, params repository.ListTasksParams) (*repository.ListTasksResult, error)
ListTasksWithTx provides a mock function with given fields: ctx, tx, params
func (*TaskRepository) RetryTaskByID ¶
func (_m *TaskRepository) RetryTaskByID(ctx context.Context, id int64) (*repository.FullTask, bool, error)
RetryTaskByID provides a mock function with given fields: ctx, id
func (*TaskRepository) RetryTaskByIDWithTx ¶
func (_m *TaskRepository) RetryTaskByIDWithTx(ctx context.Context, tx asynqpg.Tx, id int64) (*repository.FullTask, bool, error)
RetryTaskByIDWithTx provides a mock function with given fields: ctx, tx, id
type TaskRepository_CancelTaskByIDWithTx_Call ¶
TaskRepository_CancelTaskByIDWithTx_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CancelTaskByIDWithTx'
func (*TaskRepository_CancelTaskByIDWithTx_Call) Return ¶
func (_c *TaskRepository_CancelTaskByIDWithTx_Call) Return(_a0 *repository.FullTask, _a1 bool, _a2 error) *TaskRepository_CancelTaskByIDWithTx_Call
func (*TaskRepository_CancelTaskByIDWithTx_Call) Run ¶
func (_c *TaskRepository_CancelTaskByIDWithTx_Call) Run(run func(ctx context.Context, tx asynqpg.Tx, id int64)) *TaskRepository_CancelTaskByIDWithTx_Call
func (*TaskRepository_CancelTaskByIDWithTx_Call) RunAndReturn ¶
func (_c *TaskRepository_CancelTaskByIDWithTx_Call) RunAndReturn(run func(context.Context, asynqpg.Tx, int64) (*repository.FullTask, bool, error)) *TaskRepository_CancelTaskByIDWithTx_Call
type TaskRepository_CancelTaskByID_Call ¶
TaskRepository_CancelTaskByID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CancelTaskByID'
func (*TaskRepository_CancelTaskByID_Call) Return ¶
func (_c *TaskRepository_CancelTaskByID_Call) Return(_a0 *repository.FullTask, _a1 bool, _a2 error) *TaskRepository_CancelTaskByID_Call
func (*TaskRepository_CancelTaskByID_Call) Run ¶
func (_c *TaskRepository_CancelTaskByID_Call) Run(run func(ctx context.Context, id int64)) *TaskRepository_CancelTaskByID_Call
func (*TaskRepository_CancelTaskByID_Call) RunAndReturn ¶
func (_c *TaskRepository_CancelTaskByID_Call) RunAndReturn(run func(context.Context, int64) (*repository.FullTask, bool, error)) *TaskRepository_CancelTaskByID_Call
type TaskRepository_DeleteTaskByIDWithTx_Call ¶
TaskRepository_DeleteTaskByIDWithTx_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteTaskByIDWithTx'
func (*TaskRepository_DeleteTaskByIDWithTx_Call) Return ¶
func (_c *TaskRepository_DeleteTaskByIDWithTx_Call) Return(_a0 *repository.FullTask, _a1 bool, _a2 error) *TaskRepository_DeleteTaskByIDWithTx_Call
func (*TaskRepository_DeleteTaskByIDWithTx_Call) Run ¶
func (_c *TaskRepository_DeleteTaskByIDWithTx_Call) Run(run func(ctx context.Context, tx asynqpg.Tx, id int64)) *TaskRepository_DeleteTaskByIDWithTx_Call
func (*TaskRepository_DeleteTaskByIDWithTx_Call) RunAndReturn ¶
func (_c *TaskRepository_DeleteTaskByIDWithTx_Call) RunAndReturn(run func(context.Context, asynqpg.Tx, int64) (*repository.FullTask, bool, error)) *TaskRepository_DeleteTaskByIDWithTx_Call
type TaskRepository_DeleteTaskByID_Call ¶
TaskRepository_DeleteTaskByID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteTaskByID'
func (*TaskRepository_DeleteTaskByID_Call) Return ¶
func (_c *TaskRepository_DeleteTaskByID_Call) Return(_a0 *repository.FullTask, _a1 bool, _a2 error) *TaskRepository_DeleteTaskByID_Call
func (*TaskRepository_DeleteTaskByID_Call) Run ¶
func (_c *TaskRepository_DeleteTaskByID_Call) Run(run func(ctx context.Context, id int64)) *TaskRepository_DeleteTaskByID_Call
func (*TaskRepository_DeleteTaskByID_Call) RunAndReturn ¶
func (_c *TaskRepository_DeleteTaskByID_Call) RunAndReturn(run func(context.Context, int64) (*repository.FullTask, bool, error)) *TaskRepository_DeleteTaskByID_Call
type TaskRepository_Expecter ¶
type TaskRepository_Expecter struct {
// contains filtered or unexported fields
}
func (*TaskRepository_Expecter) CancelTaskByID ¶
func (_e *TaskRepository_Expecter) CancelTaskByID(ctx interface{}, id interface{}) *TaskRepository_CancelTaskByID_Call
CancelTaskByID is a helper method to define mock.On call
- ctx context.Context
- id int64
func (*TaskRepository_Expecter) CancelTaskByIDWithTx ¶
func (_e *TaskRepository_Expecter) CancelTaskByIDWithTx(ctx interface{}, tx interface{}, id interface{}) *TaskRepository_CancelTaskByIDWithTx_Call
CancelTaskByIDWithTx is a helper method to define mock.On call
- ctx context.Context
- tx asynqpg.Tx
- id int64
func (*TaskRepository_Expecter) DeleteTaskByID ¶
func (_e *TaskRepository_Expecter) DeleteTaskByID(ctx interface{}, id interface{}) *TaskRepository_DeleteTaskByID_Call
DeleteTaskByID is a helper method to define mock.On call
- ctx context.Context
- id int64
func (*TaskRepository_Expecter) DeleteTaskByIDWithTx ¶
func (_e *TaskRepository_Expecter) DeleteTaskByIDWithTx(ctx interface{}, tx interface{}, id interface{}) *TaskRepository_DeleteTaskByIDWithTx_Call
DeleteTaskByIDWithTx is a helper method to define mock.On call
- ctx context.Context
- tx asynqpg.Tx
- id int64
func (*TaskRepository_Expecter) GetTaskByID ¶
func (_e *TaskRepository_Expecter) GetTaskByID(ctx interface{}, id interface{}) *TaskRepository_GetTaskByID_Call
GetTaskByID is a helper method to define mock.On call
- ctx context.Context
- id int64
func (*TaskRepository_Expecter) GetTaskByIDWithTx ¶
func (_e *TaskRepository_Expecter) GetTaskByIDWithTx(ctx interface{}, tx interface{}, id interface{}) *TaskRepository_GetTaskByIDWithTx_Call
GetTaskByIDWithTx is a helper method to define mock.On call
- ctx context.Context
- tx asynqpg.Tx
- id int64
func (*TaskRepository_Expecter) ListTasks ¶
func (_e *TaskRepository_Expecter) ListTasks(ctx interface{}, params interface{}) *TaskRepository_ListTasks_Call
ListTasks is a helper method to define mock.On call
- ctx context.Context
- params repository.ListTasksParams
func (*TaskRepository_Expecter) ListTasksWithTx ¶
func (_e *TaskRepository_Expecter) ListTasksWithTx(ctx interface{}, tx interface{}, params interface{}) *TaskRepository_ListTasksWithTx_Call
ListTasksWithTx is a helper method to define mock.On call
- ctx context.Context
- tx asynqpg.Tx
- params repository.ListTasksParams
func (*TaskRepository_Expecter) RetryTaskByID ¶
func (_e *TaskRepository_Expecter) RetryTaskByID(ctx interface{}, id interface{}) *TaskRepository_RetryTaskByID_Call
RetryTaskByID is a helper method to define mock.On call
- ctx context.Context
- id int64
func (*TaskRepository_Expecter) RetryTaskByIDWithTx ¶
func (_e *TaskRepository_Expecter) RetryTaskByIDWithTx(ctx interface{}, tx interface{}, id interface{}) *TaskRepository_RetryTaskByIDWithTx_Call
RetryTaskByIDWithTx is a helper method to define mock.On call
- ctx context.Context
- tx asynqpg.Tx
- id int64
type TaskRepository_GetTaskByIDWithTx_Call ¶
TaskRepository_GetTaskByIDWithTx_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTaskByIDWithTx'
func (*TaskRepository_GetTaskByIDWithTx_Call) Return ¶
func (_c *TaskRepository_GetTaskByIDWithTx_Call) Return(_a0 *repository.FullTask, _a1 error) *TaskRepository_GetTaskByIDWithTx_Call
func (*TaskRepository_GetTaskByIDWithTx_Call) Run ¶
func (_c *TaskRepository_GetTaskByIDWithTx_Call) Run(run func(ctx context.Context, tx asynqpg.Tx, id int64)) *TaskRepository_GetTaskByIDWithTx_Call
func (*TaskRepository_GetTaskByIDWithTx_Call) RunAndReturn ¶
func (_c *TaskRepository_GetTaskByIDWithTx_Call) RunAndReturn(run func(context.Context, asynqpg.Tx, int64) (*repository.FullTask, error)) *TaskRepository_GetTaskByIDWithTx_Call
type TaskRepository_GetTaskByID_Call ¶
TaskRepository_GetTaskByID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTaskByID'
func (*TaskRepository_GetTaskByID_Call) Return ¶
func (_c *TaskRepository_GetTaskByID_Call) Return(_a0 *repository.FullTask, _a1 error) *TaskRepository_GetTaskByID_Call
func (*TaskRepository_GetTaskByID_Call) Run ¶
func (_c *TaskRepository_GetTaskByID_Call) Run(run func(ctx context.Context, id int64)) *TaskRepository_GetTaskByID_Call
func (*TaskRepository_GetTaskByID_Call) RunAndReturn ¶
func (_c *TaskRepository_GetTaskByID_Call) RunAndReturn(run func(context.Context, int64) (*repository.FullTask, error)) *TaskRepository_GetTaskByID_Call
type TaskRepository_ListTasksWithTx_Call ¶
TaskRepository_ListTasksWithTx_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListTasksWithTx'
func (*TaskRepository_ListTasksWithTx_Call) Return ¶
func (_c *TaskRepository_ListTasksWithTx_Call) Return(_a0 *repository.ListTasksResult, _a1 error) *TaskRepository_ListTasksWithTx_Call
func (*TaskRepository_ListTasksWithTx_Call) Run ¶
func (_c *TaskRepository_ListTasksWithTx_Call) Run(run func(ctx context.Context, tx asynqpg.Tx, params repository.ListTasksParams)) *TaskRepository_ListTasksWithTx_Call
func (*TaskRepository_ListTasksWithTx_Call) RunAndReturn ¶
func (_c *TaskRepository_ListTasksWithTx_Call) RunAndReturn(run func(context.Context, asynqpg.Tx, repository.ListTasksParams) (*repository.ListTasksResult, error)) *TaskRepository_ListTasksWithTx_Call
type TaskRepository_ListTasks_Call ¶
TaskRepository_ListTasks_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListTasks'
func (*TaskRepository_ListTasks_Call) Return ¶
func (_c *TaskRepository_ListTasks_Call) Return(_a0 *repository.ListTasksResult, _a1 error) *TaskRepository_ListTasks_Call
func (*TaskRepository_ListTasks_Call) Run ¶
func (_c *TaskRepository_ListTasks_Call) Run(run func(ctx context.Context, params repository.ListTasksParams)) *TaskRepository_ListTasks_Call
func (*TaskRepository_ListTasks_Call) RunAndReturn ¶
func (_c *TaskRepository_ListTasks_Call) RunAndReturn(run func(context.Context, repository.ListTasksParams) (*repository.ListTasksResult, error)) *TaskRepository_ListTasks_Call
type TaskRepository_RetryTaskByIDWithTx_Call ¶
TaskRepository_RetryTaskByIDWithTx_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RetryTaskByIDWithTx'
func (*TaskRepository_RetryTaskByIDWithTx_Call) Return ¶
func (_c *TaskRepository_RetryTaskByIDWithTx_Call) Return(_a0 *repository.FullTask, _a1 bool, _a2 error) *TaskRepository_RetryTaskByIDWithTx_Call
func (*TaskRepository_RetryTaskByIDWithTx_Call) Run ¶
func (_c *TaskRepository_RetryTaskByIDWithTx_Call) Run(run func(ctx context.Context, tx asynqpg.Tx, id int64)) *TaskRepository_RetryTaskByIDWithTx_Call
func (*TaskRepository_RetryTaskByIDWithTx_Call) RunAndReturn ¶
func (_c *TaskRepository_RetryTaskByIDWithTx_Call) RunAndReturn(run func(context.Context, asynqpg.Tx, int64) (*repository.FullTask, bool, error)) *TaskRepository_RetryTaskByIDWithTx_Call
type TaskRepository_RetryTaskByID_Call ¶
TaskRepository_RetryTaskByID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RetryTaskByID'
func (*TaskRepository_RetryTaskByID_Call) Return ¶
func (_c *TaskRepository_RetryTaskByID_Call) Return(_a0 *repository.FullTask, _a1 bool, _a2 error) *TaskRepository_RetryTaskByID_Call
func (*TaskRepository_RetryTaskByID_Call) Run ¶
func (_c *TaskRepository_RetryTaskByID_Call) Run(run func(ctx context.Context, id int64)) *TaskRepository_RetryTaskByID_Call
func (*TaskRepository_RetryTaskByID_Call) RunAndReturn ¶
func (_c *TaskRepository_RetryTaskByID_Call) RunAndReturn(run func(context.Context, int64) (*repository.FullTask, bool, error)) *TaskRepository_RetryTaskByID_Call