Documentation
¶
Index ¶
- type TaskQueue
- type TaskQueue_Close_Call
- type TaskQueue_Consume_Call
- type TaskQueue_Enqueue_Call
- func (_c *TaskQueue_Enqueue_Call) Return(_a0 error) *TaskQueue_Enqueue_Call
- func (_c *TaskQueue_Enqueue_Call) Run(run func(ctx context.Context, taskType string, payload []byte, ...)) *TaskQueue_Enqueue_Call
- func (_c *TaskQueue_Enqueue_Call) RunAndReturn(run func(context.Context, string, []byte, ...task.EnqueueOption) error) *TaskQueue_Enqueue_Call
- type TaskQueue_Expecter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TaskQueue ¶
TaskQueue is an autogenerated mock type for the TaskQueue type
func NewTaskQueue ¶
NewTaskQueue creates a new instance of TaskQueue. 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 (*TaskQueue) Consume ¶
func (_m *TaskQueue) Consume(ctx context.Context, handler func(context.Context, string, []byte) error) error
Consume provides a mock function with given fields: ctx, handler
func (*TaskQueue) EXPECT ¶
func (_m *TaskQueue) EXPECT() *TaskQueue_Expecter
type TaskQueue_Close_Call ¶
TaskQueue_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'
func (*TaskQueue_Close_Call) Return ¶
func (_c *TaskQueue_Close_Call) Return(_a0 error) *TaskQueue_Close_Call
func (*TaskQueue_Close_Call) Run ¶
func (_c *TaskQueue_Close_Call) Run(run func()) *TaskQueue_Close_Call
func (*TaskQueue_Close_Call) RunAndReturn ¶
func (_c *TaskQueue_Close_Call) RunAndReturn(run func() error) *TaskQueue_Close_Call
type TaskQueue_Consume_Call ¶
TaskQueue_Consume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Consume'
func (*TaskQueue_Consume_Call) Return ¶
func (_c *TaskQueue_Consume_Call) Return(_a0 error) *TaskQueue_Consume_Call
func (*TaskQueue_Consume_Call) Run ¶
func (_c *TaskQueue_Consume_Call) Run(run func(ctx context.Context, handler func(context.Context, string, []byte) error)) *TaskQueue_Consume_Call
func (*TaskQueue_Consume_Call) RunAndReturn ¶
func (_c *TaskQueue_Consume_Call) RunAndReturn(run func(context.Context, func(context.Context, string, []byte) error) error) *TaskQueue_Consume_Call
type TaskQueue_Enqueue_Call ¶
TaskQueue_Enqueue_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Enqueue'
func (*TaskQueue_Enqueue_Call) Return ¶
func (_c *TaskQueue_Enqueue_Call) Return(_a0 error) *TaskQueue_Enqueue_Call
func (*TaskQueue_Enqueue_Call) Run ¶
func (_c *TaskQueue_Enqueue_Call) Run(run func(ctx context.Context, taskType string, payload []byte, opts ...task.EnqueueOption)) *TaskQueue_Enqueue_Call
func (*TaskQueue_Enqueue_Call) RunAndReturn ¶
func (_c *TaskQueue_Enqueue_Call) RunAndReturn(run func(context.Context, string, []byte, ...task.EnqueueOption) error) *TaskQueue_Enqueue_Call
type TaskQueue_Expecter ¶
type TaskQueue_Expecter struct {
// contains filtered or unexported fields
}
func (*TaskQueue_Expecter) Close ¶
func (_e *TaskQueue_Expecter) Close() *TaskQueue_Close_Call
Close is a helper method to define mock.On call
func (*TaskQueue_Expecter) Consume ¶
func (_e *TaskQueue_Expecter) Consume(ctx interface{}, handler interface{}) *TaskQueue_Consume_Call
Consume is a helper method to define mock.On call
- ctx context.Context
- handler func(context.Context , string , []byte) error
func (*TaskQueue_Expecter) Enqueue ¶
func (_e *TaskQueue_Expecter) Enqueue(ctx interface{}, taskType interface{}, payload interface{}, opts ...interface{}) *TaskQueue_Enqueue_Call
Enqueue is a helper method to define mock.On call
- ctx context.Context
- taskType string
- payload []byte
- opts ...task.EnqueueOption
Source Files