Versions in this module Expand all Collapse all v1 v1.10.1 Mar 31, 2023 Changes in this version + const DriverRedis + const DriverSync + func GetQueueName(connection, queue string) string + func GetServer(connection string, queue string) (*machinery.Server, error) + type Task struct + Args []queue.Arg + Chain bool + Job queue.Job + Jobs []queue.Jobs + func (receiver *Task) Delay(delay time.Time) queue.Task + func (receiver *Task) Dispatch() error + func (receiver *Task) DispatchSync() error + func (receiver *Task) OnConnection(connection string) queue.Task + func (receiver *Task) OnQueue(queue string) queue.Task + type Worker struct + Concurrent int + Connection string + Queue string + func (receiver *Worker) Run() error
Go to main page