Versions in this module Expand all Collapse all v1 v1.0.0 Jun 22, 2023 Changes in this version + const Binding + const DriverRedis + const DriverSync + type Application struct + func NewApplication(config configcontract.Config) *Application + func (app *Application) Chain(jobs []queue.Jobs) queue.Task + func (app *Application) GetJobs() []queue.Job + func (app *Application) Job(job queue.Job, args []queue.Arg) queue.Task + func (app *Application) Register(jobs []queue.Job) + func (app *Application) Worker(args *queue.Args) queue.Worker + type Config struct + func NewConfig(config configcontract.Config) *Config + func (r *Config) DefaultConnection() string + func (r *Config) Driver(connection string) string + func (r *Config) Queue(connection, queue string) string + func (r *Config) Redis(queueConnection string) (dsn string, database int, queue string) + type Machinery struct + func NewMachinery(config *Config) *Machinery + func (m *Machinery) Server(connection string, queue string) (*machinery.Server, error) + type ServiceProvider struct + func (receiver *ServiceProvider) Boot(app foundation.Application) + func (receiver *ServiceProvider) Register(app foundation.Application) + type Task struct + func NewChainTask(config *Config, jobs []queue.Jobs) *Task + func NewTask(config *Config, job queue.Job, args []queue.Arg) *Task + 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 + func NewWorker(config *Config, concurrent int, connection string, jobs []queue.Job, ...) *Worker + func (receiver *Worker) Run() error