Documentation
¶
Index ¶
- type Completer
- func (_m *Completer) Complete(taskID int64) error
- func (_m *Completer) EXPECT() *Completer_Expecter
- func (_m *Completer) Fail(taskID int64, message string) error
- func (_m *Completer) Retry(taskID int64, blockedTill time.Time, message string) error
- func (_m *Completer) Snooze(taskID int64, blockedTill time.Time) error
- func (_m *Completer) Start(ctx context.Context) error
- func (_m *Completer) Stop()
- type Completer_Complete_Call
- type Completer_Expecter
- func (_e *Completer_Expecter) Complete(taskID interface{}) *Completer_Complete_Call
- func (_e *Completer_Expecter) Fail(taskID interface{}, message interface{}) *Completer_Fail_Call
- func (_e *Completer_Expecter) Retry(taskID interface{}, blockedTill interface{}, message interface{}) *Completer_Retry_Call
- func (_e *Completer_Expecter) Snooze(taskID interface{}, blockedTill interface{}) *Completer_Snooze_Call
- func (_e *Completer_Expecter) Start(ctx interface{}) *Completer_Start_Call
- func (_e *Completer_Expecter) Stop() *Completer_Stop_Call
- type Completer_Fail_Call
- type Completer_Retry_Call
- func (_c *Completer_Retry_Call) Return(_a0 error) *Completer_Retry_Call
- func (_c *Completer_Retry_Call) Run(run func(taskID int64, blockedTill time.Time, message string)) *Completer_Retry_Call
- func (_c *Completer_Retry_Call) RunAndReturn(run func(int64, time.Time, string) error) *Completer_Retry_Call
- type Completer_Snooze_Call
- type Completer_Start_Call
- type Completer_Stop_Call
- type Pool
- func (_m *Pool) EXPECT() *Pool_Expecter
- func (_m *Pool) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
- func (_m *Pool) GetContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error
- func (_m *Pool) PingContext(ctx context.Context) error
- func (_m *Pool) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
- func (_m *Pool) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row
- func (_m *Pool) SelectContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error
- type Pool_ExecContext_Call
- func (_c *Pool_ExecContext_Call) Return(_a0 sql.Result, _a1 error) *Pool_ExecContext_Call
- func (_c *Pool_ExecContext_Call) Run(run func(ctx context.Context, query string, args ...interface{})) *Pool_ExecContext_Call
- func (_c *Pool_ExecContext_Call) RunAndReturn(run func(context.Context, string, ...interface{}) (sql.Result, error)) *Pool_ExecContext_Call
- type Pool_Expecter
- func (_e *Pool_Expecter) ExecContext(ctx interface{}, query interface{}, args ...interface{}) *Pool_ExecContext_Call
- func (_e *Pool_Expecter) GetContext(ctx interface{}, dest interface{}, query interface{}, args ...interface{}) *Pool_GetContext_Call
- func (_e *Pool_Expecter) PingContext(ctx interface{}) *Pool_PingContext_Call
- func (_e *Pool_Expecter) QueryContext(ctx interface{}, query interface{}, args ...interface{}) *Pool_QueryContext_Call
- func (_e *Pool_Expecter) QueryRowContext(ctx interface{}, query interface{}, args ...interface{}) *Pool_QueryRowContext_Call
- func (_e *Pool_Expecter) SelectContext(ctx interface{}, dest interface{}, query interface{}, args ...interface{}) *Pool_SelectContext_Call
- type Pool_GetContext_Call
- type Pool_PingContext_Call
- type Pool_QueryContext_Call
- func (_c *Pool_QueryContext_Call) Return(_a0 *sql.Rows, _a1 error) *Pool_QueryContext_Call
- func (_c *Pool_QueryContext_Call) Run(run func(ctx context.Context, query string, args ...interface{})) *Pool_QueryContext_Call
- func (_c *Pool_QueryContext_Call) RunAndReturn(run func(context.Context, string, ...interface{}) (*sql.Rows, error)) *Pool_QueryContext_Call
- type Pool_QueryRowContext_Call
- func (_c *Pool_QueryRowContext_Call) Return(_a0 *sql.Row) *Pool_QueryRowContext_Call
- func (_c *Pool_QueryRowContext_Call) Run(run func(ctx context.Context, query string, args ...interface{})) *Pool_QueryRowContext_Call
- func (_c *Pool_QueryRowContext_Call) RunAndReturn(run func(context.Context, string, ...interface{}) *sql.Row) *Pool_QueryRowContext_Call
- type Pool_SelectContext_Call
- type TaskHandler
- type TaskHandler_Expecter
- type TaskHandler_Handle_Call
- func (_c *TaskHandler_Handle_Call) Return(_a0 error) *TaskHandler_Handle_Call
- func (_c *TaskHandler_Handle_Call) Run(run func(ctx context.Context, task *asynqpg.TaskInfo)) *TaskHandler_Handle_Call
- func (_c *TaskHandler_Handle_Call) RunAndReturn(run func(context.Context, *asynqpg.TaskInfo) error) *TaskHandler_Handle_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Completer ¶
Completer is an autogenerated mock type for the Completer type
func NewCompleter ¶
NewCompleter creates a new instance of Completer. 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 (*Completer) EXPECT ¶
func (_m *Completer) EXPECT() *Completer_Expecter
func (*Completer) Retry ¶
Retry provides a mock function with given fields: taskID, blockedTill, message
type Completer_Complete_Call ¶
Completer_Complete_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Complete'
func (*Completer_Complete_Call) Return ¶
func (_c *Completer_Complete_Call) Return(_a0 error) *Completer_Complete_Call
func (*Completer_Complete_Call) Run ¶
func (_c *Completer_Complete_Call) Run(run func(taskID int64)) *Completer_Complete_Call
func (*Completer_Complete_Call) RunAndReturn ¶
func (_c *Completer_Complete_Call) RunAndReturn(run func(int64) error) *Completer_Complete_Call
type Completer_Expecter ¶
type Completer_Expecter struct {
// contains filtered or unexported fields
}
func (*Completer_Expecter) Complete ¶
func (_e *Completer_Expecter) Complete(taskID interface{}) *Completer_Complete_Call
Complete is a helper method to define mock.On call
- taskID int64
func (*Completer_Expecter) Fail ¶
func (_e *Completer_Expecter) Fail(taskID interface{}, message interface{}) *Completer_Fail_Call
Fail is a helper method to define mock.On call
- taskID int64
- message string
func (*Completer_Expecter) Retry ¶
func (_e *Completer_Expecter) Retry(taskID interface{}, blockedTill interface{}, message interface{}) *Completer_Retry_Call
Retry is a helper method to define mock.On call
- taskID int64
- blockedTill time.Time
- message string
func (*Completer_Expecter) Snooze ¶
func (_e *Completer_Expecter) Snooze(taskID interface{}, blockedTill interface{}) *Completer_Snooze_Call
Snooze is a helper method to define mock.On call
- taskID int64
- blockedTill time.Time
func (*Completer_Expecter) Start ¶
func (_e *Completer_Expecter) Start(ctx interface{}) *Completer_Start_Call
Start is a helper method to define mock.On call
- ctx context.Context
func (*Completer_Expecter) Stop ¶
func (_e *Completer_Expecter) Stop() *Completer_Stop_Call
Stop is a helper method to define mock.On call
type Completer_Fail_Call ¶
Completer_Fail_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Fail'
func (*Completer_Fail_Call) Return ¶
func (_c *Completer_Fail_Call) Return(_a0 error) *Completer_Fail_Call
func (*Completer_Fail_Call) Run ¶
func (_c *Completer_Fail_Call) Run(run func(taskID int64, message string)) *Completer_Fail_Call
func (*Completer_Fail_Call) RunAndReturn ¶
func (_c *Completer_Fail_Call) RunAndReturn(run func(int64, string) error) *Completer_Fail_Call
type Completer_Retry_Call ¶
Completer_Retry_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Retry'
func (*Completer_Retry_Call) Return ¶
func (_c *Completer_Retry_Call) Return(_a0 error) *Completer_Retry_Call
func (*Completer_Retry_Call) Run ¶
func (_c *Completer_Retry_Call) Run(run func(taskID int64, blockedTill time.Time, message string)) *Completer_Retry_Call
func (*Completer_Retry_Call) RunAndReturn ¶
func (_c *Completer_Retry_Call) RunAndReturn(run func(int64, time.Time, string) error) *Completer_Retry_Call
type Completer_Snooze_Call ¶
Completer_Snooze_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Snooze'
func (*Completer_Snooze_Call) Return ¶
func (_c *Completer_Snooze_Call) Return(_a0 error) *Completer_Snooze_Call
func (*Completer_Snooze_Call) Run ¶
func (_c *Completer_Snooze_Call) Run(run func(taskID int64, blockedTill time.Time)) *Completer_Snooze_Call
func (*Completer_Snooze_Call) RunAndReturn ¶
func (_c *Completer_Snooze_Call) RunAndReturn(run func(int64, time.Time) error) *Completer_Snooze_Call
type Completer_Start_Call ¶
Completer_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'
func (*Completer_Start_Call) Return ¶
func (_c *Completer_Start_Call) Return(_a0 error) *Completer_Start_Call
func (*Completer_Start_Call) Run ¶
func (_c *Completer_Start_Call) Run(run func(ctx context.Context)) *Completer_Start_Call
func (*Completer_Start_Call) RunAndReturn ¶
func (_c *Completer_Start_Call) RunAndReturn(run func(context.Context) error) *Completer_Start_Call
type Completer_Stop_Call ¶
Completer_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'
func (*Completer_Stop_Call) Return ¶
func (_c *Completer_Stop_Call) Return() *Completer_Stop_Call
func (*Completer_Stop_Call) Run ¶
func (_c *Completer_Stop_Call) Run(run func()) *Completer_Stop_Call
func (*Completer_Stop_Call) RunAndReturn ¶
func (_c *Completer_Stop_Call) RunAndReturn(run func()) *Completer_Stop_Call
type Pool ¶
Pool is an autogenerated mock type for the pool type
func NewPool ¶
NewPool creates a new instance of Pool. 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 (*Pool) EXPECT ¶
func (_m *Pool) EXPECT() *Pool_Expecter
func (*Pool) ExecContext ¶
func (_m *Pool) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
ExecContext provides a mock function with given fields: ctx, query, args
func (*Pool) GetContext ¶
func (_m *Pool) GetContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error
GetContext provides a mock function with given fields: ctx, dest, query, args
func (*Pool) PingContext ¶
PingContext provides a mock function with given fields: ctx
func (*Pool) QueryContext ¶
func (_m *Pool) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
QueryContext provides a mock function with given fields: ctx, query, args
func (*Pool) QueryRowContext ¶
QueryRowContext provides a mock function with given fields: ctx, query, args
type Pool_ExecContext_Call ¶
Pool_ExecContext_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ExecContext'
func (*Pool_ExecContext_Call) Return ¶
func (_c *Pool_ExecContext_Call) Return(_a0 sql.Result, _a1 error) *Pool_ExecContext_Call
func (*Pool_ExecContext_Call) Run ¶
func (_c *Pool_ExecContext_Call) Run(run func(ctx context.Context, query string, args ...interface{})) *Pool_ExecContext_Call
func (*Pool_ExecContext_Call) RunAndReturn ¶
func (_c *Pool_ExecContext_Call) RunAndReturn(run func(context.Context, string, ...interface{}) (sql.Result, error)) *Pool_ExecContext_Call
type Pool_Expecter ¶
type Pool_Expecter struct {
// contains filtered or unexported fields
}
func (*Pool_Expecter) ExecContext ¶
func (_e *Pool_Expecter) ExecContext(ctx interface{}, query interface{}, args ...interface{}) *Pool_ExecContext_Call
ExecContext is a helper method to define mock.On call
- ctx context.Context
- query string
- args ...interface{}
func (*Pool_Expecter) GetContext ¶
func (_e *Pool_Expecter) GetContext(ctx interface{}, dest interface{}, query interface{}, args ...interface{}) *Pool_GetContext_Call
GetContext is a helper method to define mock.On call
- ctx context.Context
- dest interface{}
- query string
- args ...interface{}
func (*Pool_Expecter) PingContext ¶
func (_e *Pool_Expecter) PingContext(ctx interface{}) *Pool_PingContext_Call
PingContext is a helper method to define mock.On call
- ctx context.Context
func (*Pool_Expecter) QueryContext ¶
func (_e *Pool_Expecter) QueryContext(ctx interface{}, query interface{}, args ...interface{}) *Pool_QueryContext_Call
QueryContext is a helper method to define mock.On call
- ctx context.Context
- query string
- args ...interface{}
func (*Pool_Expecter) QueryRowContext ¶
func (_e *Pool_Expecter) QueryRowContext(ctx interface{}, query interface{}, args ...interface{}) *Pool_QueryRowContext_Call
QueryRowContext is a helper method to define mock.On call
- ctx context.Context
- query string
- args ...interface{}
func (*Pool_Expecter) SelectContext ¶
func (_e *Pool_Expecter) SelectContext(ctx interface{}, dest interface{}, query interface{}, args ...interface{}) *Pool_SelectContext_Call
SelectContext is a helper method to define mock.On call
- ctx context.Context
- dest interface{}
- query string
- args ...interface{}
type Pool_GetContext_Call ¶
Pool_GetContext_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetContext'
func (*Pool_GetContext_Call) Return ¶
func (_c *Pool_GetContext_Call) Return(_a0 error) *Pool_GetContext_Call
func (*Pool_GetContext_Call) Run ¶
func (_c *Pool_GetContext_Call) Run(run func(ctx context.Context, dest interface{}, query string, args ...interface{})) *Pool_GetContext_Call
func (*Pool_GetContext_Call) RunAndReturn ¶
func (_c *Pool_GetContext_Call) RunAndReturn(run func(context.Context, interface{}, string, ...interface{}) error) *Pool_GetContext_Call
type Pool_PingContext_Call ¶
Pool_PingContext_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PingContext'
func (*Pool_PingContext_Call) Return ¶
func (_c *Pool_PingContext_Call) Return(_a0 error) *Pool_PingContext_Call
func (*Pool_PingContext_Call) Run ¶
func (_c *Pool_PingContext_Call) Run(run func(ctx context.Context)) *Pool_PingContext_Call
func (*Pool_PingContext_Call) RunAndReturn ¶
func (_c *Pool_PingContext_Call) RunAndReturn(run func(context.Context) error) *Pool_PingContext_Call
type Pool_QueryContext_Call ¶
Pool_QueryContext_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'QueryContext'
func (*Pool_QueryContext_Call) Return ¶
func (_c *Pool_QueryContext_Call) Return(_a0 *sql.Rows, _a1 error) *Pool_QueryContext_Call
func (*Pool_QueryContext_Call) Run ¶
func (_c *Pool_QueryContext_Call) Run(run func(ctx context.Context, query string, args ...interface{})) *Pool_QueryContext_Call
func (*Pool_QueryContext_Call) RunAndReturn ¶
func (_c *Pool_QueryContext_Call) RunAndReturn(run func(context.Context, string, ...interface{}) (*sql.Rows, error)) *Pool_QueryContext_Call
type Pool_QueryRowContext_Call ¶
Pool_QueryRowContext_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'QueryRowContext'
func (*Pool_QueryRowContext_Call) Return ¶
func (_c *Pool_QueryRowContext_Call) Return(_a0 *sql.Row) *Pool_QueryRowContext_Call
func (*Pool_QueryRowContext_Call) Run ¶
func (_c *Pool_QueryRowContext_Call) Run(run func(ctx context.Context, query string, args ...interface{})) *Pool_QueryRowContext_Call
func (*Pool_QueryRowContext_Call) RunAndReturn ¶
func (_c *Pool_QueryRowContext_Call) RunAndReturn(run func(context.Context, string, ...interface{}) *sql.Row) *Pool_QueryRowContext_Call
type Pool_SelectContext_Call ¶
Pool_SelectContext_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SelectContext'
func (*Pool_SelectContext_Call) Return ¶
func (_c *Pool_SelectContext_Call) Return(_a0 error) *Pool_SelectContext_Call
func (*Pool_SelectContext_Call) Run ¶
func (_c *Pool_SelectContext_Call) Run(run func(ctx context.Context, dest interface{}, query string, args ...interface{})) *Pool_SelectContext_Call
func (*Pool_SelectContext_Call) RunAndReturn ¶
func (_c *Pool_SelectContext_Call) RunAndReturn(run func(context.Context, interface{}, string, ...interface{}) error) *Pool_SelectContext_Call
type TaskHandler ¶
TaskHandler is an autogenerated mock type for the TaskHandler type
func NewTaskHandler ¶
func NewTaskHandler(t interface {
mock.TestingT
Cleanup(func())
}) *TaskHandler
NewTaskHandler creates a new instance of TaskHandler. 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 (*TaskHandler) EXPECT ¶
func (_m *TaskHandler) EXPECT() *TaskHandler_Expecter
type TaskHandler_Expecter ¶
type TaskHandler_Expecter struct {
// contains filtered or unexported fields
}
func (*TaskHandler_Expecter) Handle ¶
func (_e *TaskHandler_Expecter) Handle(ctx interface{}, task interface{}) *TaskHandler_Handle_Call
Handle is a helper method to define mock.On call
- ctx context.Context
- task *asynqpg.TaskInfo
type TaskHandler_Handle_Call ¶
TaskHandler_Handle_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Handle'
func (*TaskHandler_Handle_Call) Return ¶
func (_c *TaskHandler_Handle_Call) Return(_a0 error) *TaskHandler_Handle_Call
func (*TaskHandler_Handle_Call) Run ¶
func (_c *TaskHandler_Handle_Call) Run(run func(ctx context.Context, task *asynqpg.TaskInfo)) *TaskHandler_Handle_Call
func (*TaskHandler_Handle_Call) RunAndReturn ¶
func (_c *TaskHandler_Handle_Call) RunAndReturn(run func(context.Context, *asynqpg.TaskInfo) error) *TaskHandler_Handle_Call