Versions in this module Expand all Collapse all v1 v1.10.2 Jun 26, 2023 v1.10.1 Mar 31, 2023 Changes in this version + type Arg struct + Type string + Value any + type Args struct + Concurrent int + Connection string + Queue string + type Job interface + Handle func(args ...any) error + Signature func() string + type Jobs struct + Args []Arg + Job Job + type Queue interface + Chain func(jobs []Jobs) Task + GetJobs func() []Job + Job func(job Job, args []Arg) Task + Register func(jobs []Job) + Worker func(args *Args) Worker + type Task interface + Delay func(time time.Time) Task + Dispatch func() error + DispatchSync func() error + OnConnection func(connection string) Task + OnQueue func(queue string) Task + type Worker interface + Run func() error
Go to main page