queue

package
v1.15.6 Latest Latest
Warning

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

 Go to latest Published: Mar 29, 2025 License: MIT Imports: 3 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Job 

type Job struct {
	mock.Mock
}

Job is an autogenerated mock type for the Job type

func NewJob 

func NewJob(t interface {
	mock.TestingT
	Cleanup(func())
}) *Job

NewJob creates a new instance of Job. 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 (*Job) EXPECT 

func (_m *Job) EXPECT() *Job_Expecter

func (*Job) Handle 

func (_m *Job) Handle(args ...interface{}) error

Handle provides a mock function with given fields: args

func (*Job) Signature 

func (_m *Job) Signature() string

Signature provides a mock function with no fields

type Job_Expecter 

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

func (*Job_Expecter) Handle 

func (_e *Job_Expecter) Handle(args ...interface{}) *Job_Handle_Call

Handle is a helper method to define mock.On call

  • args ...interface{}

func (*Job_Expecter) Signature 

func (_e *Job_Expecter) Signature() *Job_Signature_Call

Signature is a helper method to define mock.On call

type Job_Handle_Call 

type Job_Handle_Call struct {
	*mock.Call
}

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

func (*Job_Handle_Call) Return 

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

func (*Job_Handle_Call) Run 

func (_c *Job_Handle_Call) Run(run func(args ...interface{})) *Job_Handle_Call

func (*Job_Handle_Call) RunAndReturn 

func (_c *Job_Handle_Call) RunAndReturn(run func(...interface{}) error) *Job_Handle_Call

type Job_Signature_Call 

type Job_Signature_Call struct {
	*mock.Call
}

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

func (*Job_Signature_Call) Return 

func (_c *Job_Signature_Call) Return(_a0 string) *Job_Signature_Call

func (*Job_Signature_Call) Run 

func (_c *Job_Signature_Call) Run(run func()) *Job_Signature_Call

func (*Job_Signature_Call) RunAndReturn 

func (_c *Job_Signature_Call) RunAndReturn(run func() string) *Job_Signature_Call

type Queue 

type Queue struct {
	mock.Mock
}

Queue is an autogenerated mock type for the Queue type

func NewQueue 

func NewQueue(t interface {
	mock.TestingT
	Cleanup(func())
}) *Queue

NewQueue creates a new instance of Queue. 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 (*Queue) Chain 

func (_m *Queue) Chain(jobs []queue.Jobs) queue.Task

Chain provides a mock function with given fields: jobs

func (*Queue) EXPECT 

func (_m *Queue) EXPECT() *Queue_Expecter

func (*Queue) GetJobs 

func (_m *Queue) GetJobs() []queue.Job

GetJobs provides a mock function with no fields

func (*Queue) Job 

func (_m *Queue) Job(job queue.Job, args []queue.Arg) queue.Task

Job provides a mock function with given fields: job, args

func (*Queue) Register 

func (_m *Queue) Register(jobs []queue.Job)

Register provides a mock function with given fields: jobs

func (*Queue) Worker 

func (_m *Queue) Worker(args ...queue.Args) queue.Worker

Worker provides a mock function with given fields: args

type Queue_Chain_Call 

type Queue_Chain_Call struct {
	*mock.Call
}

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

func (*Queue_Chain_Call) Return 

func (_c *Queue_Chain_Call) Return(_a0 queue.Task) *Queue_Chain_Call

func (*Queue_Chain_Call) Run 

func (_c *Queue_Chain_Call) Run(run func(jobs []queue.Jobs)) *Queue_Chain_Call

func (*Queue_Chain_Call) RunAndReturn 

func (_c *Queue_Chain_Call) RunAndReturn(run func([]queue.Jobs) queue.Task) *Queue_Chain_Call

type Queue_Expecter 

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

func (*Queue_Expecter) Chain 

func (_e *Queue_Expecter) Chain(jobs interface{}) *Queue_Chain_Call

Chain is a helper method to define mock.On call

  • jobs []queue.Jobs

func (*Queue_Expecter) GetJobs 

func (_e *Queue_Expecter) GetJobs() *Queue_GetJobs_Call

GetJobs is a helper method to define mock.On call

func (*Queue_Expecter) Job 

func (_e *Queue_Expecter) Job(job interface{}, args interface{}) *Queue_Job_Call

Job is a helper method to define mock.On call

  • job queue.Job
  • args []queue.Arg

func (*Queue_Expecter) Register 

func (_e *Queue_Expecter) Register(jobs interface{}) *Queue_Register_Call

Register is a helper method to define mock.On call

  • jobs []queue.Job

func (*Queue_Expecter) Worker 

func (_e *Queue_Expecter) Worker(args ...interface{}) *Queue_Worker_Call

Worker is a helper method to define mock.On call

  • args ...queue.Args

type Queue_GetJobs_Call 

type Queue_GetJobs_Call struct {
	*mock.Call
}

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

func (*Queue_GetJobs_Call) Return 

func (_c *Queue_GetJobs_Call) Return(_a0 []queue.Job) *Queue_GetJobs_Call

func (*Queue_GetJobs_Call) Run 

func (_c *Queue_GetJobs_Call) Run(run func()) *Queue_GetJobs_Call

func (*Queue_GetJobs_Call) RunAndReturn 

func (_c *Queue_GetJobs_Call) RunAndReturn(run func() []queue.Job) *Queue_GetJobs_Call

type Queue_Job_Call 

type Queue_Job_Call struct {
	*mock.Call
}

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

func (*Queue_Job_Call) Return 

func (_c *Queue_Job_Call) Return(_a0 queue.Task) *Queue_Job_Call

func (*Queue_Job_Call) Run 

func (_c *Queue_Job_Call) Run(run func(job queue.Job, args []queue.Arg)) *Queue_Job_Call

func (*Queue_Job_Call) RunAndReturn 

func (_c *Queue_Job_Call) RunAndReturn(run func(queue.Job, []queue.Arg) queue.Task) *Queue_Job_Call

type Queue_Register_Call 

type Queue_Register_Call struct {
	*mock.Call
}

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

func (*Queue_Register_Call) Return 

func (_c *Queue_Register_Call) Return() *Queue_Register_Call

func (*Queue_Register_Call) Run 

func (_c *Queue_Register_Call) Run(run func(jobs []queue.Job)) *Queue_Register_Call

func (*Queue_Register_Call) RunAndReturn 

func (_c *Queue_Register_Call) RunAndReturn(run func([]queue.Job)) *Queue_Register_Call

type Queue_Worker_Call 

type Queue_Worker_Call struct {
	*mock.Call
}

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

func (*Queue_Worker_Call) Return 

func (_c *Queue_Worker_Call) Return(_a0 queue.Worker) *Queue_Worker_Call

func (*Queue_Worker_Call) Run 

func (_c *Queue_Worker_Call) Run(run func(args ...queue.Args)) *Queue_Worker_Call

func (*Queue_Worker_Call) RunAndReturn 

func (_c *Queue_Worker_Call) RunAndReturn(run func(...queue.Args) queue.Worker) *Queue_Worker_Call

type Task 

type Task struct {
	mock.Mock
}

Task is an autogenerated mock type for the Task type

func NewTask 

func NewTask(t interface {
	mock.TestingT
	Cleanup(func())
}) *Task

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) Delay 

func (_m *Task) Delay(_a0 time.Time) queue.Task

Delay provides a mock function with given fields: _a0

func (*Task) Dispatch 

func (_m *Task) Dispatch() error

Dispatch provides a mock function with no fields

func (*Task) DispatchSync 

func (_m *Task) DispatchSync() error

DispatchSync provides a mock function with no fields

func (*Task) EXPECT 

func (_m *Task) EXPECT() *Task_Expecter

func (*Task) OnConnection 

func (_m *Task) OnConnection(connection string) queue.Task

OnConnection provides a mock function with given fields: connection

func (*Task) OnQueue 

func (_m *Task) OnQueue(_a0 string) queue.Task

OnQueue provides a mock function with given fields: _a0

type Task_Delay_Call 

type Task_Delay_Call struct {
	*mock.Call
}

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

func (*Task_Delay_Call) Return 

func (_c *Task_Delay_Call) Return(_a0 queue.Task) *Task_Delay_Call

func (*Task_Delay_Call) Run 

func (_c *Task_Delay_Call) Run(run func(_a0 time.Time)) *Task_Delay_Call

func (*Task_Delay_Call) RunAndReturn 

func (_c *Task_Delay_Call) RunAndReturn(run func(time.Time) queue.Task) *Task_Delay_Call

type Task_DispatchSync_Call 

type Task_DispatchSync_Call struct {
	*mock.Call
}

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

func (*Task_DispatchSync_Call) Return 

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

func (*Task_DispatchSync_Call) Run 

func (_c *Task_DispatchSync_Call) Run(run func()) *Task_DispatchSync_Call

func (*Task_DispatchSync_Call) RunAndReturn 

func (_c *Task_DispatchSync_Call) RunAndReturn(run func() error) *Task_DispatchSync_Call

type Task_Dispatch_Call 

type Task_Dispatch_Call struct {
	*mock.Call
}

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

func (*Task_Dispatch_Call) Return 

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

func (*Task_Dispatch_Call) Run 

func (_c *Task_Dispatch_Call) Run(run func()) *Task_Dispatch_Call

func (*Task_Dispatch_Call) RunAndReturn 

func (_c *Task_Dispatch_Call) RunAndReturn(run func() error) *Task_Dispatch_Call

type Task_Expecter 

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

func (*Task_Expecter) Delay 

func (_e *Task_Expecter) Delay(_a0 interface{}) *Task_Delay_Call

Delay is a helper method to define mock.On call

  • _a0 time.Time

func (*Task_Expecter) Dispatch 

func (_e *Task_Expecter) Dispatch() *Task_Dispatch_Call

Dispatch is a helper method to define mock.On call

func (*Task_Expecter) DispatchSync 

func (_e *Task_Expecter) DispatchSync() *Task_DispatchSync_Call

DispatchSync is a helper method to define mock.On call

func (*Task_Expecter) OnConnection 

func (_e *Task_Expecter) OnConnection(connection interface{}) *Task_OnConnection_Call

OnConnection is a helper method to define mock.On call

  • connection string

func (*Task_Expecter) OnQueue 

func (_e *Task_Expecter) OnQueue(_a0 interface{}) *Task_OnQueue_Call

OnQueue is a helper method to define mock.On call

  • _a0 string

type Task_OnConnection_Call 

type Task_OnConnection_Call struct {
	*mock.Call
}

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

func (*Task_OnConnection_Call) Return 

func (_c *Task_OnConnection_Call) Return(_a0 queue.Task) *Task_OnConnection_Call

func (*Task_OnConnection_Call) Run 

func (_c *Task_OnConnection_Call) Run(run func(connection string)) *Task_OnConnection_Call

func (*Task_OnConnection_Call) RunAndReturn 

func (_c *Task_OnConnection_Call) RunAndReturn(run func(string) queue.Task) *Task_OnConnection_Call

type Task_OnQueue_Call 

type Task_OnQueue_Call struct {
	*mock.Call
}

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

func (*Task_OnQueue_Call) Return 

func (_c *Task_OnQueue_Call) Return(_a0 queue.Task) *Task_OnQueue_Call

func (*Task_OnQueue_Call) Run 

func (_c *Task_OnQueue_Call) Run(run func(_a0 string)) *Task_OnQueue_Call

func (*Task_OnQueue_Call) RunAndReturn 

func (_c *Task_OnQueue_Call) RunAndReturn(run func(string) queue.Task) *Task_OnQueue_Call

type Worker 

type Worker struct {
	mock.Mock
}

Worker is an autogenerated mock type for the Worker type

func NewWorker 

func NewWorker(t interface {
	mock.TestingT
	Cleanup(func())
}) *Worker

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) Run 

func (_m *Worker) Run() error

Run provides a mock function with no fields

type Worker_Expecter 

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

func (*Worker_Expecter) Run 

func (_e *Worker_Expecter) Run() *Worker_Run_Call

Run is a helper method to define mock.On call

type Worker_Run_Call 

type Worker_Run_Call struct {
	*mock.Call
}

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

func (*Worker_Run_Call) Return 

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

func (*Worker_Run_Call) Run 

func (_c *Worker_Run_Call) Run(run func()) *Worker_Run_Call

func (*Worker_Run_Call) RunAndReturn 

func (_c *Worker_Run_Call) RunAndReturn(run func() error) *Worker_Run_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.