Versions in this module Expand all Collapse all v1 v1.1.0 Sep 11, 2018 v1.0.0 Sep 5, 2018 Changes in this version + type Engine interface + RegisterJob func(name string, fn JobFn) error + Run func(context.Context) error + SubmitTask func(Task) error + type JobFn func(ctx context.Context, task Task) ([]Task, error) + type Task interface + GetArgs func() map[string]string + GetExecuteTime func() *time.Time + GetID func() string + GetJobName func() string + GetWorkerRejectionCount func() int + IncrementWorkerRejectionCount func() int + ToJSON func() ([]byte, error) + func NewDelayedTask(jobName string, args map[string]string, delay time.Duration) Task + func NewScheduledTask(jobName string, args map[string]string, time time.Time) Task + func NewTask(jobName string, args map[string]string) Task + func NewTaskFromJSON(jsonBytes []byte) (Task, error)
Go to main page