Versions in this module Expand all Collapse all v0 v0.1.1 Dec 6, 2022 Changes in this version + const Version + type CronJob struct + Name string + Queue string + Retry int + func NewCronJob(name string) *CronJob + func NewCronJobWithQueue(name string, queue string) *CronJob + type CronJobHandlerFunc func(ctx context.Context) error + type CronJobs interface + Register func(spec string, cJob *CronJob, handler CronJobHandlerFunc) error + type Job struct + Name string + Payload interface{} + ProcessAt *time.Time + Queue string + Retry int + Timeout time.Duration + func NewJob(name string, payload interface{}) *Job + func NewJobWithQueue(name string, queue string, p interface{}) *Job + type JobHandlerFunc func(context.Context, Payload) error + type Jobs interface + Push func(context.Context, *Job) error + type Payload interface + Decode func(payload interface{}) error + func NewJsonPayload(p []byte) Payload + type Worker interface + Register func(name string, handlerFunc JobHandlerFunc) error
Go to main page