Documentation ¶
Index ¶
- type Processing
- type Processing_Expecter
- type Processing_Processing_Call
- func (_c *Processing_Processing_Call) Return() *Processing_Processing_Call
- func (_c *Processing_Processing_Call) Run(run func(ctx context.Context, input interface{})) *Processing_Processing_Call
- func (_c *Processing_Processing_Call) RunAndReturn(run func(context.Context, interface{})) *Processing_Processing_Call
- type Processing_Result_Call
- type Task
- func (_m *Task) EXPECT() *Task_Expecter
- func (_m *Task) GetError() error
- func (_m *Task) Run()
- func (_m *Task) SetContext(ctx context.Context) error
- func (_m *Task) SetDoneChannel(done chan struct{}) error
- func (_m *Task) SetWaitGroup(wg *sync.WaitGroup) error
- func (_m *Task) Stop()
- func (_m *Task) String() string
- type Task_Expecter
- func (_e *Task_Expecter) GetError() *Task_GetError_Call
- func (_e *Task_Expecter) Run() *Task_Run_Call
- func (_e *Task_Expecter) SetContext(ctx interface{}) *Task_SetContext_Call
- func (_e *Task_Expecter) SetDoneChannel(done interface{}) *Task_SetDoneChannel_Call
- func (_e *Task_Expecter) SetWaitGroup(wg interface{}) *Task_SetWaitGroup_Call
- func (_e *Task_Expecter) Stop() *Task_Stop_Call
- func (_e *Task_Expecter) String() *Task_String_Call
- type Task_GetError_Call
- type Task_Run_Call
- type Task_SetContext_Call
- type Task_SetDoneChannel_Call
- type Task_SetWaitGroup_Call
- type Task_Stop_Call
- type Task_String_Call
- type Worker
- func (_m *Worker) EXPECT() *Worker_Expecter
- func (_m *Worker) GetError() chan *worker.Error
- func (_m *Worker) GetRetry() int32
- func (_m *Worker) GetStatus() worker.Status
- func (_m *Worker) Restart(wg *sync.WaitGroup)
- func (_m *Worker) SetContext(ctx context.Context) error
- func (_m *Worker) SetQueue(queue chan worker.Task) error
- func (_m *Worker) SetWorkerErrChannel(errCh chan *worker.Error) error
- func (_m *Worker) Start(wg *sync.WaitGroup)
- func (_m *Worker) Stop() <-chan struct{}
- func (_m *Worker) String() string
- type Worker_Expecter
- func (_e *Worker_Expecter) GetError() *Worker_GetError_Call
- func (_e *Worker_Expecter) GetRetry() *Worker_GetRetry_Call
- func (_e *Worker_Expecter) GetStatus() *Worker_GetStatus_Call
- func (_e *Worker_Expecter) Restart(wg interface{}) *Worker_Restart_Call
- func (_e *Worker_Expecter) SetContext(ctx interface{}) *Worker_SetContext_Call
- func (_e *Worker_Expecter) SetQueue(queue interface{}) *Worker_SetQueue_Call
- func (_e *Worker_Expecter) SetWorkerErrChannel(errCh interface{}) *Worker_SetWorkerErrChannel_Call
- func (_e *Worker_Expecter) Start(wg interface{}) *Worker_Start_Call
- func (_e *Worker_Expecter) Stop() *Worker_Stop_Call
- func (_e *Worker_Expecter) String() *Worker_String_Call
- type Worker_GetError_Call
- type Worker_GetRetry_Call
- type Worker_GetStatus_Call
- type Worker_Restart_Call
- type Worker_SetContext_Call
- type Worker_SetQueue_Call
- type Worker_SetWorkerErrChannel_Call
- func (_c *Worker_SetWorkerErrChannel_Call) Return(_a0 error) *Worker_SetWorkerErrChannel_Call
- func (_c *Worker_SetWorkerErrChannel_Call) Run(run func(errCh chan *worker.Error)) *Worker_SetWorkerErrChannel_Call
- func (_c *Worker_SetWorkerErrChannel_Call) RunAndReturn(run func(chan *worker.Error) error) *Worker_SetWorkerErrChannel_Call
- type Worker_Start_Call
- type Worker_Stop_Call
- type Worker_String_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Processing ¶
Processing is an autogenerated mock type for the Processing type
func NewProcessing ¶
func NewProcessing(t interface { mock.TestingT Cleanup(func()) }) *Processing
NewProcessing creates a new instance of Processing. 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 (*Processing) EXPECT ¶
func (_m *Processing) EXPECT() *Processing_Expecter
func (*Processing) Processing ¶
func (_m *Processing) Processing(ctx context.Context, input interface{})
Processing provides a mock function with given fields: ctx, input
func (*Processing) Result ¶
func (_m *Processing) Result() chan interface{}
Result provides a mock function with given fields:
type Processing_Expecter ¶
type Processing_Expecter struct {
// contains filtered or unexported fields
}
func (*Processing_Expecter) Processing ¶
func (_e *Processing_Expecter) Processing(ctx interface{}, input interface{}) *Processing_Processing_Call
Processing is a helper method to define mock.On call
- ctx context.Context
- input interface{}
func (*Processing_Expecter) Result ¶
func (_e *Processing_Expecter) Result() *Processing_Result_Call
Result is a helper method to define mock.On call
type Processing_Processing_Call ¶
Processing_Processing_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Processing'
func (*Processing_Processing_Call) Return ¶
func (_c *Processing_Processing_Call) Return() *Processing_Processing_Call
func (*Processing_Processing_Call) Run ¶
func (_c *Processing_Processing_Call) Run(run func(ctx context.Context, input interface{})) *Processing_Processing_Call
func (*Processing_Processing_Call) RunAndReturn ¶
func (_c *Processing_Processing_Call) RunAndReturn(run func(context.Context, interface{})) *Processing_Processing_Call
type Processing_Result_Call ¶
Processing_Result_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Result'
func (*Processing_Result_Call) Return ¶
func (_c *Processing_Result_Call) Return(_a0 chan interface{}) *Processing_Result_Call
func (*Processing_Result_Call) Run ¶
func (_c *Processing_Result_Call) Run(run func()) *Processing_Result_Call
func (*Processing_Result_Call) RunAndReturn ¶
func (_c *Processing_Result_Call) RunAndReturn(run func() chan interface{}) *Processing_Result_Call
type Task ¶
Task is an autogenerated mock type for the Task type
func NewTask ¶
NewTask creates a new instance of Task. 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 (*Task) EXPECT ¶
func (_m *Task) EXPECT() *Task_Expecter
func (*Task) SetContext ¶
SetContext provides a mock function with given fields: ctx
func (*Task) SetDoneChannel ¶
SetDoneChannel provides a mock function with given fields: done
func (*Task) SetWaitGroup ¶
SetWaitGroup provides a mock function with given fields: wg
type Task_Expecter ¶
type Task_Expecter struct {
// contains filtered or unexported fields
}
func (*Task_Expecter) GetError ¶
func (_e *Task_Expecter) GetError() *Task_GetError_Call
GetError is a helper method to define mock.On call
func (*Task_Expecter) Run ¶
func (_e *Task_Expecter) Run() *Task_Run_Call
Run is a helper method to define mock.On call
func (*Task_Expecter) SetContext ¶
func (_e *Task_Expecter) SetContext(ctx interface{}) *Task_SetContext_Call
SetContext is a helper method to define mock.On call
- ctx context.Context
func (*Task_Expecter) SetDoneChannel ¶
func (_e *Task_Expecter) SetDoneChannel(done interface{}) *Task_SetDoneChannel_Call
SetDoneChannel is a helper method to define mock.On call
- done chan struct{}
func (*Task_Expecter) SetWaitGroup ¶
func (_e *Task_Expecter) SetWaitGroup(wg interface{}) *Task_SetWaitGroup_Call
SetWaitGroup is a helper method to define mock.On call
- wg *sync.WaitGroup
func (*Task_Expecter) Stop ¶
func (_e *Task_Expecter) Stop() *Task_Stop_Call
Stop is a helper method to define mock.On call
func (*Task_Expecter) String ¶
func (_e *Task_Expecter) String() *Task_String_Call
String is a helper method to define mock.On call
type Task_GetError_Call ¶
Task_GetError_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetError'
func (*Task_GetError_Call) Return ¶
func (_c *Task_GetError_Call) Return(_a0 error) *Task_GetError_Call
func (*Task_GetError_Call) Run ¶
func (_c *Task_GetError_Call) Run(run func()) *Task_GetError_Call
func (*Task_GetError_Call) RunAndReturn ¶
func (_c *Task_GetError_Call) RunAndReturn(run func() error) *Task_GetError_Call
type Task_Run_Call ¶
Task_Run_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Run'
func (*Task_Run_Call) Return ¶
func (_c *Task_Run_Call) Return() *Task_Run_Call
func (*Task_Run_Call) Run ¶
func (_c *Task_Run_Call) Run(run func()) *Task_Run_Call
func (*Task_Run_Call) RunAndReturn ¶
func (_c *Task_Run_Call) RunAndReturn(run func()) *Task_Run_Call
type Task_SetContext_Call ¶
Task_SetContext_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetContext'
func (*Task_SetContext_Call) Return ¶
func (_c *Task_SetContext_Call) Return(_a0 error) *Task_SetContext_Call
func (*Task_SetContext_Call) Run ¶
func (_c *Task_SetContext_Call) Run(run func(ctx context.Context)) *Task_SetContext_Call
func (*Task_SetContext_Call) RunAndReturn ¶
func (_c *Task_SetContext_Call) RunAndReturn(run func(context.Context) error) *Task_SetContext_Call
type Task_SetDoneChannel_Call ¶
Task_SetDoneChannel_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetDoneChannel'
func (*Task_SetDoneChannel_Call) Return ¶
func (_c *Task_SetDoneChannel_Call) Return(_a0 error) *Task_SetDoneChannel_Call
func (*Task_SetDoneChannel_Call) Run ¶
func (_c *Task_SetDoneChannel_Call) Run(run func(done chan struct{})) *Task_SetDoneChannel_Call
func (*Task_SetDoneChannel_Call) RunAndReturn ¶
func (_c *Task_SetDoneChannel_Call) RunAndReturn(run func(chan struct{}) error) *Task_SetDoneChannel_Call
type Task_SetWaitGroup_Call ¶
Task_SetWaitGroup_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetWaitGroup'
func (*Task_SetWaitGroup_Call) Return ¶
func (_c *Task_SetWaitGroup_Call) Return(_a0 error) *Task_SetWaitGroup_Call
func (*Task_SetWaitGroup_Call) Run ¶
func (_c *Task_SetWaitGroup_Call) Run(run func(wg *sync.WaitGroup)) *Task_SetWaitGroup_Call
func (*Task_SetWaitGroup_Call) RunAndReturn ¶
func (_c *Task_SetWaitGroup_Call) RunAndReturn(run func(*sync.WaitGroup) error) *Task_SetWaitGroup_Call
type Task_Stop_Call ¶
Task_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'
func (*Task_Stop_Call) Return ¶
func (_c *Task_Stop_Call) Return() *Task_Stop_Call
func (*Task_Stop_Call) Run ¶
func (_c *Task_Stop_Call) Run(run func()) *Task_Stop_Call
func (*Task_Stop_Call) RunAndReturn ¶
func (_c *Task_Stop_Call) RunAndReturn(run func()) *Task_Stop_Call
type Task_String_Call ¶
Task_String_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'String'
func (*Task_String_Call) Return ¶
func (_c *Task_String_Call) Return(_a0 string) *Task_String_Call
func (*Task_String_Call) Run ¶
func (_c *Task_String_Call) Run(run func()) *Task_String_Call
func (*Task_String_Call) RunAndReturn ¶
func (_c *Task_String_Call) RunAndReturn(run func() string) *Task_String_Call
type Worker ¶
Worker is an autogenerated mock type for the Worker type
func NewWorker ¶
NewWorker creates a new instance of Worker. 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 (*Worker) EXPECT ¶
func (_m *Worker) EXPECT() *Worker_Expecter
func (*Worker) SetContext ¶
SetContext provides a mock function with given fields: ctx
func (*Worker) SetWorkerErrChannel ¶
SetWorkerErrChannel provides a mock function with given fields: errCh
type Worker_Expecter ¶
type Worker_Expecter struct {
// contains filtered or unexported fields
}
func (*Worker_Expecter) GetError ¶
func (_e *Worker_Expecter) GetError() *Worker_GetError_Call
GetError is a helper method to define mock.On call
func (*Worker_Expecter) GetRetry ¶
func (_e *Worker_Expecter) GetRetry() *Worker_GetRetry_Call
GetRetry is a helper method to define mock.On call
func (*Worker_Expecter) GetStatus ¶
func (_e *Worker_Expecter) GetStatus() *Worker_GetStatus_Call
GetStatus is a helper method to define mock.On call
func (*Worker_Expecter) Restart ¶
func (_e *Worker_Expecter) Restart(wg interface{}) *Worker_Restart_Call
Restart is a helper method to define mock.On call
- wg *sync.WaitGroup
func (*Worker_Expecter) SetContext ¶
func (_e *Worker_Expecter) SetContext(ctx interface{}) *Worker_SetContext_Call
SetContext is a helper method to define mock.On call
- ctx context.Context
func (*Worker_Expecter) SetQueue ¶
func (_e *Worker_Expecter) SetQueue(queue interface{}) *Worker_SetQueue_Call
SetQueue is a helper method to define mock.On call
- queue chan worker.Task
func (*Worker_Expecter) SetWorkerErrChannel ¶
func (_e *Worker_Expecter) SetWorkerErrChannel(errCh interface{}) *Worker_SetWorkerErrChannel_Call
SetWorkerErrChannel is a helper method to define mock.On call
- errCh chan *worker.Error
func (*Worker_Expecter) Start ¶
func (_e *Worker_Expecter) Start(wg interface{}) *Worker_Start_Call
Start is a helper method to define mock.On call
- wg *sync.WaitGroup
func (*Worker_Expecter) Stop ¶
func (_e *Worker_Expecter) Stop() *Worker_Stop_Call
Stop is a helper method to define mock.On call
func (*Worker_Expecter) String ¶
func (_e *Worker_Expecter) String() *Worker_String_Call
String is a helper method to define mock.On call
type Worker_GetError_Call ¶
Worker_GetError_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetError'
func (*Worker_GetError_Call) Return ¶
func (_c *Worker_GetError_Call) Return(_a0 chan *worker.Error) *Worker_GetError_Call
func (*Worker_GetError_Call) Run ¶
func (_c *Worker_GetError_Call) Run(run func()) *Worker_GetError_Call
func (*Worker_GetError_Call) RunAndReturn ¶
func (_c *Worker_GetError_Call) RunAndReturn(run func() chan *worker.Error) *Worker_GetError_Call
type Worker_GetRetry_Call ¶
Worker_GetRetry_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetRetry'
func (*Worker_GetRetry_Call) Return ¶
func (_c *Worker_GetRetry_Call) Return(_a0 int32) *Worker_GetRetry_Call
func (*Worker_GetRetry_Call) Run ¶
func (_c *Worker_GetRetry_Call) Run(run func()) *Worker_GetRetry_Call
func (*Worker_GetRetry_Call) RunAndReturn ¶
func (_c *Worker_GetRetry_Call) RunAndReturn(run func() int32) *Worker_GetRetry_Call
type Worker_GetStatus_Call ¶
Worker_GetStatus_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetStatus'
func (*Worker_GetStatus_Call) Return ¶
func (_c *Worker_GetStatus_Call) Return(_a0 worker.Status) *Worker_GetStatus_Call
func (*Worker_GetStatus_Call) Run ¶
func (_c *Worker_GetStatus_Call) Run(run func()) *Worker_GetStatus_Call
func (*Worker_GetStatus_Call) RunAndReturn ¶
func (_c *Worker_GetStatus_Call) RunAndReturn(run func() worker.Status) *Worker_GetStatus_Call
type Worker_Restart_Call ¶
Worker_Restart_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Restart'
func (*Worker_Restart_Call) Return ¶
func (_c *Worker_Restart_Call) Return() *Worker_Restart_Call
func (*Worker_Restart_Call) Run ¶
func (_c *Worker_Restart_Call) Run(run func(wg *sync.WaitGroup)) *Worker_Restart_Call
func (*Worker_Restart_Call) RunAndReturn ¶
func (_c *Worker_Restart_Call) RunAndReturn(run func(*sync.WaitGroup)) *Worker_Restart_Call
type Worker_SetContext_Call ¶
Worker_SetContext_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetContext'
func (*Worker_SetContext_Call) Return ¶
func (_c *Worker_SetContext_Call) Return(_a0 error) *Worker_SetContext_Call
func (*Worker_SetContext_Call) Run ¶
func (_c *Worker_SetContext_Call) Run(run func(ctx context.Context)) *Worker_SetContext_Call
func (*Worker_SetContext_Call) RunAndReturn ¶
func (_c *Worker_SetContext_Call) RunAndReturn(run func(context.Context) error) *Worker_SetContext_Call
type Worker_SetQueue_Call ¶
Worker_SetQueue_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetQueue'
func (*Worker_SetQueue_Call) Return ¶
func (_c *Worker_SetQueue_Call) Return(_a0 error) *Worker_SetQueue_Call
func (*Worker_SetQueue_Call) Run ¶
func (_c *Worker_SetQueue_Call) Run(run func(queue chan worker.Task)) *Worker_SetQueue_Call
func (*Worker_SetQueue_Call) RunAndReturn ¶
func (_c *Worker_SetQueue_Call) RunAndReturn(run func(chan worker.Task) error) *Worker_SetQueue_Call
type Worker_SetWorkerErrChannel_Call ¶
Worker_SetWorkerErrChannel_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetWorkerErrChannel'
func (*Worker_SetWorkerErrChannel_Call) Return ¶
func (_c *Worker_SetWorkerErrChannel_Call) Return(_a0 error) *Worker_SetWorkerErrChannel_Call
func (*Worker_SetWorkerErrChannel_Call) Run ¶
func (_c *Worker_SetWorkerErrChannel_Call) Run(run func(errCh chan *worker.Error)) *Worker_SetWorkerErrChannel_Call
func (*Worker_SetWorkerErrChannel_Call) RunAndReturn ¶
func (_c *Worker_SetWorkerErrChannel_Call) RunAndReturn(run func(chan *worker.Error) error) *Worker_SetWorkerErrChannel_Call
type Worker_Start_Call ¶
Worker_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'
func (*Worker_Start_Call) Return ¶
func (_c *Worker_Start_Call) Return() *Worker_Start_Call
func (*Worker_Start_Call) Run ¶
func (_c *Worker_Start_Call) Run(run func(wg *sync.WaitGroup)) *Worker_Start_Call
func (*Worker_Start_Call) RunAndReturn ¶
func (_c *Worker_Start_Call) RunAndReturn(run func(*sync.WaitGroup)) *Worker_Start_Call
type Worker_Stop_Call ¶
Worker_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'
func (*Worker_Stop_Call) Return ¶
func (_c *Worker_Stop_Call) Return(_a0 <-chan struct{}) *Worker_Stop_Call
func (*Worker_Stop_Call) Run ¶
func (_c *Worker_Stop_Call) Run(run func()) *Worker_Stop_Call
func (*Worker_Stop_Call) RunAndReturn ¶
func (_c *Worker_Stop_Call) RunAndReturn(run func() <-chan struct{}) *Worker_Stop_Call
type Worker_String_Call ¶
Worker_String_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'String'
func (*Worker_String_Call) Return ¶
func (_c *Worker_String_Call) Return(_a0 string) *Worker_String_Call
func (*Worker_String_Call) Run ¶
func (_c *Worker_String_Call) Run(run func()) *Worker_String_Call
func (*Worker_String_Call) RunAndReturn ¶
func (_c *Worker_String_Call) RunAndReturn(run func() string) *Worker_String_Call