mocks

Dec 11, 2023

Changes in this version

type JobProcessor

+ func (_m *JobProcessor) GetSyncJobsByService(ctx context.Context, service string) ([]worker.Job, error)

type JobProcessor_Expecter

+ func (_e *JobProcessor_Expecter) GetSyncJobsByService(ctx interface{}, service interface{}) *JobProcessor_GetSyncJobsByService_Call

+ type JobProcessor_GetSyncJobsByService_Call struct

+ func (_c *JobProcessor_GetSyncJobsByService_Call) Return(_a0 []worker.Job, _a1 error) *JobProcessor_GetSyncJobsByService_Call

+ func (_c *JobProcessor_GetSyncJobsByService_Call) Run(run func(ctx context.Context, service string)) *JobProcessor_GetSyncJobsByService_Call

+ func (_c *JobProcessor_GetSyncJobsByService_Call) RunAndReturn(run func(context.Context, string) ([]worker.Job, error)) *JobProcessor_GetSyncJobsByService_Call

Aug 16, 2023

Changes in this version

+ type DeadJobManager struct

+ func NewDeadJobManager(t mockConstructorTestingTNewDeadJobManager) *DeadJobManager

+ func (_m *DeadJobManager) ClearDeadJobs(ctx context.Context, jobIDs []string) error

+ func (_m *DeadJobManager) DeadJobs(ctx context.Context, size int, offset int) ([]worker.Job, error)

+ func (_m *DeadJobManager) EXPECT() *DeadJobManager_Expecter

+ func (_m *DeadJobManager) Resurrect(ctx context.Context, jobIDs []string) error

+ type DeadJobManager_ClearDeadJobs_Call struct

+ func (_c *DeadJobManager_ClearDeadJobs_Call) Return(_a0 error) *DeadJobManager_ClearDeadJobs_Call

+ func (_c *DeadJobManager_ClearDeadJobs_Call) Run(run func(ctx context.Context, jobIDs []string)) *DeadJobManager_ClearDeadJobs_Call

+ func (_c *DeadJobManager_ClearDeadJobs_Call) RunAndReturn(run func(context.Context, []string) error) *DeadJobManager_ClearDeadJobs_Call

+ type DeadJobManager_DeadJobs_Call struct

+ func (_c *DeadJobManager_DeadJobs_Call) Return(_a0 []worker.Job, _a1 error) *DeadJobManager_DeadJobs_Call

+ func (_c *DeadJobManager_DeadJobs_Call) Run(run func(ctx context.Context, size int, offset int)) *DeadJobManager_DeadJobs_Call

+ func (_c *DeadJobManager_DeadJobs_Call) RunAndReturn(run func(context.Context, int, int) ([]worker.Job, error)) *DeadJobManager_DeadJobs_Call

+ type DeadJobManager_Expecter struct

+ func (_e *DeadJobManager_Expecter) ClearDeadJobs(ctx interface{}, jobIDs interface{}) *DeadJobManager_ClearDeadJobs_Call

+ func (_e *DeadJobManager_Expecter) DeadJobs(ctx interface{}, size interface{}, offset interface{}) *DeadJobManager_DeadJobs_Call

+ func (_e *DeadJobManager_Expecter) Resurrect(ctx interface{}, jobIDs interface{}) *DeadJobManager_Resurrect_Call

+ type DeadJobManager_Resurrect_Call struct

+ func (_c *DeadJobManager_Resurrect_Call) Return(_a0 error) *DeadJobManager_Resurrect_Call

+ func (_c *DeadJobManager_Resurrect_Call) Run(run func(ctx context.Context, jobIDs []string)) *DeadJobManager_Resurrect_Call

+ func (_c *DeadJobManager_Resurrect_Call) RunAndReturn(run func(context.Context, []string) error) *DeadJobManager_Resurrect_Call

+ type JobProcessor struct

+ func NewJobProcessor(t mockConstructorTestingTNewJobProcessor) *JobProcessor

+ func (_m *JobProcessor) EXPECT() *JobProcessor_Expecter

+ func (_m *JobProcessor) Enqueue(ctx context.Context, jobs ...worker.Job) error

+ func (_m *JobProcessor) Process(ctx context.Context, types []string, fn worker.JobExecutorFunc) error

+ func (_m *JobProcessor) Stats(ctx context.Context) ([]worker.JobTypeStats, error)

+ type JobProcessor_Enqueue_Call struct

+ func (_c *JobProcessor_Enqueue_Call) Return(_a0 error) *JobProcessor_Enqueue_Call

+ func (_c *JobProcessor_Enqueue_Call) Run(run func(ctx context.Context, jobs ...worker.Job)) *JobProcessor_Enqueue_Call

+ func (_c *JobProcessor_Enqueue_Call) RunAndReturn(run func(context.Context, ...worker.Job) error) *JobProcessor_Enqueue_Call

+ type JobProcessor_Expecter struct

+ func (_e *JobProcessor_Expecter) Enqueue(ctx interface{}, jobs ...interface{}) *JobProcessor_Enqueue_Call

+ func (_e *JobProcessor_Expecter) Process(ctx interface{}, types interface{}, fn interface{}) *JobProcessor_Process_Call

+ func (_e *JobProcessor_Expecter) Stats(ctx interface{}) *JobProcessor_Stats_Call

+ type JobProcessor_Process_Call struct

+ func (_c *JobProcessor_Process_Call) Return(_a0 error) *JobProcessor_Process_Call

+ func (_c *JobProcessor_Process_Call) Run(run func(ctx context.Context, types []string, fn worker.JobExecutorFunc)) *JobProcessor_Process_Call

+ func (_c *JobProcessor_Process_Call) RunAndReturn(run func(context.Context, []string, worker.JobExecutorFunc) error) *JobProcessor_Process_Call

+ type JobProcessor_Stats_Call struct

+ func (_c *JobProcessor_Stats_Call) Return(_a0 []worker.JobTypeStats, _a1 error) *JobProcessor_Stats_Call

+ func (_c *JobProcessor_Stats_Call) Run(run func(ctx context.Context)) *JobProcessor_Stats_Call

+ func (_c *JobProcessor_Stats_Call) RunAndReturn(run func(context.Context) ([]worker.JobTypeStats, error)) *JobProcessor_Stats_Call