cron

Jan 20, 2022

Changes in this version

+ func GetCurrentSchedule(ctx context.Context) time.Time

+ func GetNextSchedule(ctx context.Context) time.Time

+ type Config struct

+ EnableSeconds bool

+ GlobalOptions []JobOption

+ Location *time.Location

+ Parser cron.ScheduleParser

+ type Cron struct

+ func New(config Config) *Cron

+ func (c *Cron) Add(spec string, runner func(ctx context.Context) error, middleware ...JobOption) (JobID, error)

+ func (c *Cron) Descriptors() []JobDescriptor

+ func (c *Cron) Remove(id JobID)

+ func (c *Cron) Run(ctx context.Context) error

+ type CronJobMetrics struct

+ func NewCronJobMetrics(histogram metrics.Histogram, counter metrics.Counter) *CronJobMetrics

+ func (c *CronJobMetrics) Fail()

+ func (c *CronJobMetrics) Job(job string) *CronJobMetrics

+ func (c *CronJobMetrics) Module(module string) *CronJobMetrics

+ func (c *CronJobMetrics) Observe(duration time.Duration)

+ func (c *CronJobMetrics) Schedule(schedule string) *CronJobMetrics

+ type JobDescriptor struct

+ ID JobID

+ Name string

+ RawSpec string

+ Run func(ctx context.Context) error

+ Schedule cron.Schedule

+ type JobID int

+ type JobOption func(descriptors *JobDescriptor)

+ func DelayIfOverlap() JobOption

+ func Recover(logger log.Logger) JobOption

+ func SkipIfOverlap() JobOption

+ func TimeoutIfOverlap() JobOption

+ func WithLogging(logger log.Logger) JobOption

+ func WithMetrics(metrics *CronJobMetrics) JobOption

+ func WithName(name string) JobOption

+ func WithSchedule(schedule cron.Schedule) JobOption

+ func WithTracing(tracer opentracing.Tracer) JobOption