Versions in this module Expand all Collapse all v1 v1.0.0 Jun 22, 2023 Changes in this version + type Queue struct + 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 struct + 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