cron

Documentation

Index

• type Cron
  • func New() *Cron
  • func (c *Cron) Add(jobID string, cronExpr string, run func()) error
  • func (c *Cron) HasStarted() bool
  • func (c *Cron) MustAdd(jobID string, cronExpr string, run func())
  • func (c *Cron) Remove(jobID string)
  • func (c *Cron) RemoveAll()
  • func (c *Cron) SetInterval(d time.Duration)
  • func (c *Cron) SetTimezone(l *time.Location)
  • func (c *Cron) Start()
  • func (c *Cron) Stop()
  • func (c *Cron) Total() int
• type Moment
  • func NewMoment(t time.Time) *Moment
• type Schedule
  • func NewSchedule(cronExpr string) (*Schedule, error)
  • func (s *Schedule) IsDue(m *Moment) bool

Types

type Cron

type Cron struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Cron is a crontab-like struct for tasks/jobs scheduling.

func New

func New() *Cron

New create a new Cron struct with default tick interval of 1 minute and timezone in UTC.

You can change the default tick interval with Cron.SetInterval(). You can change the default timezone with Cron.SetTimezone().

func (*Cron) Add

func (c *Cron) Add(jobID string, cronExpr string, run func()) error

Add registers a single cron job.

If there is already a job with the provided id, then the old job will be replaced with the new one.

cronExpr is a regular cron expression, eg. "0 */3 * * *" (aka. at minute 0 past every 3rd hour). Check cron.NewSchedule() for the supported tokens.

func (*Cron) HasStarted

func (c *Cron) HasStarted() bool

HasStarted checks whether the current Cron ticker has been started.

func (*Cron) MustAdd

func (c *Cron) MustAdd(jobID string, cronExpr string, run func())

MustAdd is similar to Add() but panic on failure.

func (*Cron) Remove

func (c *Cron) Remove(jobID string)

Remove removes a single cron job by its id.

func (*Cron) RemoveAll

func (c *Cron) RemoveAll()

RemoveAll removes all registered cron jobs.

func (*Cron) SetInterval

func (c *Cron) SetInterval(d time.Duration)

SetInterval changes the current cron tick interval (it usually should be >= 1 minute).

func (*Cron) SetTimezone

func (c *Cron) SetTimezone(l *time.Location)

SetTimezone changes the current cron tick timezone.

func (*Cron) Start

func (c *Cron) Start()

Start starts the cron ticker.

Calling Start() on already started cron will restart the ticker.

func (*Cron) Stop

func (c *Cron) Stop()

Stop stops the current cron ticker (if not already).

You can resume the ticker by calling Start().

func (*Cron) Total

func (c *Cron) Total() int

Total returns the current total number of registered cron jobs.

type Moment

type Moment struct {
	Minute    int `json:"minute"`
	Hour      int `json:"hour"`
	Day       int `json:"day"`
	Month     int `json:"month"`
	DayOfWeek int `json:"dayOfWeek"`
}

Moment represents a parsed single time moment.

func NewMoment

func NewMoment(t time.Time) *Moment

NewMoment creates a new Moment from the specified time.

type Schedule

type Schedule struct {
	Minutes    map[int]struct{} `json:"minutes"`
	Hours      map[int]struct{} `json:"hours"`
	Days       map[int]struct{} `json:"days"`
	Months     map[int]struct{} `json:"months"`
	DaysOfWeek map[int]struct{} `json:"daysOfWeek"`
}

Schedule stores parsed information for each time component when a cron job should run.

func NewSchedule

func NewSchedule(cronExpr string) (*Schedule, error)

NewSchedule creates a new Schedule from a cron expression.

A cron expression is consisted of 5 segments separated by space, representing: minute, hour, day of the month, month and day of the week.

Each segment could be in the following formats:

• wildcard: *
• range: 1-30
• step: */n or 1-30/n
• list: 1,2,3,10-20/n

func (*Schedule) IsDue

func (s *Schedule) IsDue(m *Moment) bool

IsDue checks whether the provided Moment satisfies the current Schedule.