mocks

Documentation

Index

• type Queue
  • func NewQueue(t mockConstructorTestingTNewQueue) *Queue
  • func (_m *Queue) Chain(jobs []queue.Jobs) queue.Task
  • func (_m *Queue) GetJobs() []queue.Job
  • func (_m *Queue) Job(job queue.Job, args []queue.Arg) queue.Task
  • func (_m *Queue) Register(jobs []queue.Job)
  • func (_m *Queue) Worker(args *queue.Args) queue.Worker
• type Task
  • func NewTask(t mockConstructorTestingTNewTask) *Task
  • func (_m *Task) Delay(_a0 time.Time) queue.Task
  • func (_m *Task) Dispatch() error
  • func (_m *Task) DispatchSync() error
  • func (_m *Task) OnConnection(connection string) queue.Task
  • func (_m *Task) OnQueue(_a0 string) queue.Task

Types

type Queue

type Queue struct {
	mock.Mock
}

Queue is an autogenerated mock type for the Queue type

func NewQueue

func NewQueue(t mockConstructorTestingTNewQueue) *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.

func (*Queue) Chain

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

Chain provides a mock function with given fields: jobs

func (*Queue) GetJobs

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

GetJobs provides a mock function with given 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 Task

type Task struct {
	mock.Mock
}

Task is an autogenerated mock type for the Task type

func NewTask

func NewTask(t mockConstructorTestingTNewTask) *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.

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 given fields:

func (*Task) DispatchSync

func (_m *Task) DispatchSync() error

DispatchSync provides a mock function with given fields:

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