dcron

Nov 10, 2023

Changes in this version

type CronOption

+ func WithContext(ctx context.Context) CronOption

Feb 9, 2021

Changes in this version

+ type Group interface

+ func NewGroup(limit int) Group

type JobOption

+ func WithGroup(group Group) JobOption

Mar 11, 2020

Changes in this version

type Statistics

+ func (s Statistics) Add(delta Statistics) Statistics

Mar 3, 2020

Changes in this version

type Cron

+ func (c *Cron) Jobs() []JobMeta

+ func (c *Cron) Statistics() Statistics

type CronMeta

+ Jobs func() []JobMeta

+ Statistics func() Statistics

type CronOption

+ func WithLocation(loc *time.Location) CronOption

type Job

+ Key func() string

+ Spec func() string

type JobMeta

+ Statistics func() Statistics

+ type Statistics struct

+ FailedRun int64

+ FailedTask int64

+ MissedTask int64

+ PassedRun int64

+ PassedTask int64

+ RetriedRun int64

+ SkippedTask int64

+ TotalRun int64

+ TotalTask int64

Mar 3, 2020

Changes in this version

type Job

+ func NewJobWithAutoKey(spec string, run RunFunc, options ...JobOption) Job

Mar 3, 2020

Changes in this version

type Job

+ func NewJobWithNonAnonymousFunc(spec string, run RunFunc, options ...JobOption) Job

Mar 3, 2020

Changes in this version

+ type Atomic interface

+ SetIfNotExists func(key, value string) bool

type CronOption

+ func WithAtomic(atomic Atomic) CronOption

Mar 2, 2020

Changes in this version

type JobOption

+ func WithNoMutex() JobOption

Mar 2, 2020

Changes in this version

type Cron

+ func (c *Cron) AddJobs(jobs ...Job) error

type Task

+ func TaskFromContext(ctx context.Context) (Task, bool)

Mar 2, 2020

Changes in this version

+ type AfterFunc func(task Task)

+ type BeforeFunc func(task Task) (skip bool)

+ type Cron struct

+ func NewCron(options ...CronOption) *Cron

+ func (c *Cron) AddJob(job Job) error

+ func (c *Cron) Hostname() string

+ func (c *Cron) Key() string

+ func (c *Cron) Run()

+ func (c *Cron) Start()

+ func (c *Cron) Stop() context.Context

+ type CronMeta interface

+ Hostname func() string

+ Key func() string

+ type CronOption func(c *Cron)

+ func WithHostname(hostname string) CronOption

+ func WithKey(key string) CronOption

+ func WithMutex(mutex Mutex) CronOption

+ type Job interface

+ Options func() []JobOption

+ Run func(task Task) error

+ func NewJob(key, spec string, run RunFunc, options ...JobOption) Job

+ type JobMeta interface

+ Key func() string

+ Spec func() string

+ type JobOption func(job *innerJob)

+ func WithAfterFunc(after AfterFunc) JobOption

+ func WithBeforeFunc(before BeforeFunc) JobOption

+ func WithRetryInterval(retryInterval RetryInterval) JobOption

+ func WithRetryTimes(retryTimes int) JobOption

+ type Mutex interface

+ SetIfNotExists func(key, value string) bool

+ type RetryInterval func(triedTimes int) time.Duration

+ type RunFunc func(task Task) error

+ type Task struct

+ BeginAt *time.Time

+ Cron CronMeta

+ EndAt *time.Time

+ Job JobMeta

+ Key string

+ Missed bool

+ PlanAt time.Time

+ Return error

+ Skipped bool

+ TriedTimes int

+ func (t Task) Deadline() (deadline time.Time, ok bool)

+ func (t Task) Done() <-chan struct{}

+ func (t Task) Err() error

+ func (t Task) Value(key interface{}) interface{}