Versions in this module Expand all Collapse all v0 v0.0.1 Sep 9, 2024 Changes in this version + type Processing struct + func NewProcessing(t interface{ ... }) *Processing + func (_m *Processing) EXPECT() *Processing_Expecter + func (_m *Processing) Processing(ctx context.Context, input interface{}) + func (_m *Processing) Result() chan interface{} + type Processing_Expecter struct + func (_e *Processing_Expecter) Processing(ctx interface{}, input interface{}) *Processing_Processing_Call + func (_e *Processing_Expecter) Result() *Processing_Result_Call + type Processing_Processing_Call struct + 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 struct + func (_c *Processing_Result_Call) Return(_a0 chan interface{}) *Processing_Result_Call + func (_c *Processing_Result_Call) Run(run func()) *Processing_Result_Call + func (_c *Processing_Result_Call) RunAndReturn(run func() chan interface{}) *Processing_Result_Call + type Task struct + func NewTask(t interface{ ... }) *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 struct + 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 struct + func (_c *Task_GetError_Call) Return(_a0 error) *Task_GetError_Call + func (_c *Task_GetError_Call) Run(run func()) *Task_GetError_Call + func (_c *Task_GetError_Call) RunAndReturn(run func() error) *Task_GetError_Call + type Task_Run_Call struct + func (_c *Task_Run_Call) Return() *Task_Run_Call + func (_c *Task_Run_Call) Run(run func()) *Task_Run_Call + func (_c *Task_Run_Call) RunAndReturn(run func()) *Task_Run_Call + type Task_SetContext_Call struct + func (_c *Task_SetContext_Call) Return(_a0 error) *Task_SetContext_Call + func (_c *Task_SetContext_Call) Run(run func(ctx context.Context)) *Task_SetContext_Call + func (_c *Task_SetContext_Call) RunAndReturn(run func(context.Context) error) *Task_SetContext_Call + type Task_SetDoneChannel_Call struct + func (_c *Task_SetDoneChannel_Call) Return(_a0 error) *Task_SetDoneChannel_Call + func (_c *Task_SetDoneChannel_Call) Run(run func(done chan struct{})) *Task_SetDoneChannel_Call + func (_c *Task_SetDoneChannel_Call) RunAndReturn(run func(chan struct{}) error) *Task_SetDoneChannel_Call + type Task_SetWaitGroup_Call struct + func (_c *Task_SetWaitGroup_Call) Return(_a0 error) *Task_SetWaitGroup_Call + func (_c *Task_SetWaitGroup_Call) Run(run func(wg *sync.WaitGroup)) *Task_SetWaitGroup_Call + func (_c *Task_SetWaitGroup_Call) RunAndReturn(run func(*sync.WaitGroup) error) *Task_SetWaitGroup_Call + type Task_Stop_Call struct + func (_c *Task_Stop_Call) Return() *Task_Stop_Call + func (_c *Task_Stop_Call) Run(run func()) *Task_Stop_Call + func (_c *Task_Stop_Call) RunAndReturn(run func()) *Task_Stop_Call + type Task_String_Call struct + func (_c *Task_String_Call) Return(_a0 string) *Task_String_Call + func (_c *Task_String_Call) Run(run func()) *Task_String_Call + func (_c *Task_String_Call) RunAndReturn(run func() string) *Task_String_Call + type Worker struct + func NewWorker(t interface{ ... }) *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 struct + 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 struct + func (_c *Worker_GetError_Call) Return(_a0 chan *worker.Error) *Worker_GetError_Call + func (_c *Worker_GetError_Call) Run(run func()) *Worker_GetError_Call + func (_c *Worker_GetError_Call) RunAndReturn(run func() chan *worker.Error) *Worker_GetError_Call + type Worker_GetRetry_Call struct + func (_c *Worker_GetRetry_Call) Return(_a0 int32) *Worker_GetRetry_Call + func (_c *Worker_GetRetry_Call) Run(run func()) *Worker_GetRetry_Call + func (_c *Worker_GetRetry_Call) RunAndReturn(run func() int32) *Worker_GetRetry_Call + type Worker_GetStatus_Call struct + func (_c *Worker_GetStatus_Call) Return(_a0 worker.Status) *Worker_GetStatus_Call + func (_c *Worker_GetStatus_Call) Run(run func()) *Worker_GetStatus_Call + func (_c *Worker_GetStatus_Call) RunAndReturn(run func() worker.Status) *Worker_GetStatus_Call + type Worker_Restart_Call struct + func (_c *Worker_Restart_Call) Return() *Worker_Restart_Call + func (_c *Worker_Restart_Call) Run(run func(wg *sync.WaitGroup)) *Worker_Restart_Call + func (_c *Worker_Restart_Call) RunAndReturn(run func(*sync.WaitGroup)) *Worker_Restart_Call + type Worker_SetContext_Call struct + func (_c *Worker_SetContext_Call) Return(_a0 error) *Worker_SetContext_Call + func (_c *Worker_SetContext_Call) Run(run func(ctx context.Context)) *Worker_SetContext_Call + func (_c *Worker_SetContext_Call) RunAndReturn(run func(context.Context) error) *Worker_SetContext_Call + type Worker_SetQueue_Call struct + func (_c *Worker_SetQueue_Call) Return(_a0 error) *Worker_SetQueue_Call + func (_c *Worker_SetQueue_Call) Run(run func(queue chan worker.Task)) *Worker_SetQueue_Call + func (_c *Worker_SetQueue_Call) RunAndReturn(run func(chan worker.Task) error) *Worker_SetQueue_Call + type Worker_SetWorkerErrChannel_Call struct + 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 struct + func (_c *Worker_Start_Call) Return() *Worker_Start_Call + func (_c *Worker_Start_Call) Run(run func(wg *sync.WaitGroup)) *Worker_Start_Call + func (_c *Worker_Start_Call) RunAndReturn(run func(*sync.WaitGroup)) *Worker_Start_Call + type Worker_Stop_Call struct + func (_c *Worker_Stop_Call) Return(_a0 <-chan struct{}) *Worker_Stop_Call + func (_c *Worker_Stop_Call) Run(run func()) *Worker_Stop_Call + func (_c *Worker_Stop_Call) RunAndReturn(run func() <-chan struct{}) *Worker_Stop_Call + type Worker_String_Call struct + func (_c *Worker_String_Call) Return(_a0 string) *Worker_String_Call + func (_c *Worker_String_Call) Run(run func()) *Worker_String_Call + func (_c *Worker_String_Call) RunAndReturn(run func() string) *Worker_String_Call
Go to main page