mocks

package
v0.7.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 5, 2024 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DeadJobManager 

type DeadJobManager struct {
	mock.Mock
}

DeadJobManager is an autogenerated mock type for the DeadJobManager type

func NewDeadJobManager 

func NewDeadJobManager(t mockConstructorTestingTNewDeadJobManager) *DeadJobManager

NewDeadJobManager creates a new instance of DeadJobManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*DeadJobManager) ClearDeadJobs 

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

ClearDeadJobs provides a mock function with given fields: ctx, jobIDs

func (*DeadJobManager) DeadJobs 

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

DeadJobs provides a mock function with given fields: ctx, size, offset

func (*DeadJobManager) EXPECT 

func (_m *DeadJobManager) EXPECT() *DeadJobManager_Expecter

func (*DeadJobManager) Resurrect 

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

Resurrect provides a mock function with given fields: ctx, jobIDs

type DeadJobManager_ClearDeadJobs_Call 

type DeadJobManager_ClearDeadJobs_Call struct {
	*mock.Call
}

DeadJobManager_ClearDeadJobs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ClearDeadJobs'

func (*DeadJobManager_ClearDeadJobs_Call) Return 

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

func (*DeadJobManager_ClearDeadJobs_Call) Run 

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

func (*DeadJobManager_ClearDeadJobs_Call) RunAndReturn 

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

type DeadJobManager_DeadJobs_Call 

type DeadJobManager_DeadJobs_Call struct {
	*mock.Call
}

DeadJobManager_DeadJobs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeadJobs'

func (*DeadJobManager_DeadJobs_Call) Return 

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

func (*DeadJobManager_DeadJobs_Call) Run 

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

func (*DeadJobManager_DeadJobs_Call) RunAndReturn 

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

type DeadJobManager_Expecter 

type DeadJobManager_Expecter struct {
	// contains filtered or unexported fields
}

func (*DeadJobManager_Expecter) ClearDeadJobs 

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

ClearDeadJobs is a helper method to define mock.On call

  • ctx context.Context
  • jobIDs []string

func (*DeadJobManager_Expecter) DeadJobs 

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

DeadJobs is a helper method to define mock.On call

  • ctx context.Context
  • size int
  • offset int

func (*DeadJobManager_Expecter) Resurrect 

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

Resurrect is a helper method to define mock.On call

  • ctx context.Context
  • jobIDs []string

type DeadJobManager_Resurrect_Call 

type DeadJobManager_Resurrect_Call struct {
	*mock.Call
}

DeadJobManager_Resurrect_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Resurrect'

func (*DeadJobManager_Resurrect_Call) Return 

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

func (*DeadJobManager_Resurrect_Call) Run 

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

func (*DeadJobManager_Resurrect_Call) RunAndReturn 

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

type JobProcessor 

type JobProcessor struct {
	mock.Mock
}

JobProcessor is an autogenerated mock type for the JobProcessor type

func NewJobProcessor 

func NewJobProcessor(t mockConstructorTestingTNewJobProcessor) *JobProcessor

NewJobProcessor creates a new instance of JobProcessor. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*JobProcessor) EXPECT 

func (_m *JobProcessor) EXPECT() *JobProcessor_Expecter

func (*JobProcessor) Enqueue 

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

Enqueue provides a mock function with given fields: ctx, jobs

func (*JobProcessor) GetSyncJobsByService added in v0.7.0 

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

GetSyncJobsByService provides a mock function with given fields: ctx, service

func (*JobProcessor) Process 

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

Process provides a mock function with given fields: ctx, types, fn

func (*JobProcessor) Stats 

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

Stats provides a mock function with given fields: ctx

type JobProcessor_Enqueue_Call 

type JobProcessor_Enqueue_Call struct {
	*mock.Call
}

JobProcessor_Enqueue_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Enqueue'

func (*JobProcessor_Enqueue_Call) Return 

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

func (*JobProcessor_Enqueue_Call) Run 

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

func (*JobProcessor_Enqueue_Call) RunAndReturn 

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

type JobProcessor_Expecter 

type JobProcessor_Expecter struct {
	// contains filtered or unexported fields
}

func (*JobProcessor_Expecter) Enqueue 

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

Enqueue is a helper method to define mock.On call

  • ctx context.Context
  • jobs ...worker.Job

func (*JobProcessor_Expecter) GetSyncJobsByService added in v0.7.0 

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

GetSyncJobsByService is a helper method to define mock.On call

  • ctx context.Context
  • service string

func (*JobProcessor_Expecter) Process 

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

Process is a helper method to define mock.On call

  • ctx context.Context
  • types []string
  • fn worker.JobExecutorFunc

func (*JobProcessor_Expecter) Stats 

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

Stats is a helper method to define mock.On call

  • ctx context.Context

type JobProcessor_GetSyncJobsByService_Call added in v0.7.0 

type JobProcessor_GetSyncJobsByService_Call struct {
	*mock.Call
}

JobProcessor_GetSyncJobsByService_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSyncJobsByService'

func (*JobProcessor_GetSyncJobsByService_Call) Return added in v0.7.0 

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

func (*JobProcessor_GetSyncJobsByService_Call) Run added in v0.7.0 

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

func (*JobProcessor_GetSyncJobsByService_Call) RunAndReturn added in v0.7.0 

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

type JobProcessor_Process_Call 

type JobProcessor_Process_Call struct {
	*mock.Call
}

JobProcessor_Process_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Process'

func (*JobProcessor_Process_Call) Return 

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

func (*JobProcessor_Process_Call) Run 

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

func (*JobProcessor_Process_Call) RunAndReturn 

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

type JobProcessor_Stats_Call 

type JobProcessor_Stats_Call struct {
	*mock.Call
}

JobProcessor_Stats_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stats'

func (*JobProcessor_Stats_Call) Return 

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

func (*JobProcessor_Stats_Call) Run 

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

func (*JobProcessor_Stats_Call) RunAndReturn 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.