cron

Documentation

Overview

Package cron emulate linux crontab

Index

• func ParseNextTime(cronLine string) (nextTime time.Time, err error)
• type Expression
  • func Parse(cronLine string) (*Expression, error)
  • func (expr *Expression) Next(fromTime time.Time) time.Time
  • func (expr *Expression) NextN(fromTime time.Time, n uint) []time.Time
• type Job
• type JobTable
  • func New() *JobTable
  • func (c *JobTable) Add(cronLine string, fn func()) (remove func(), err error)
  • func (c *JobTable) ForceRun() (nextTime time.Duration)
  • func (c *JobTable) Run(block ...bool)
  • func (c *JobTable) Stop()

Functions

func ParseNextTime

func ParseNextTime(cronLine string) (nextTime time.Time, err error)

Types

type Expression

type Expression struct {
	// contains filtered or unexported fields
}

func Parse

func Parse(cronLine string) (*Expression, error)

func (*Expression) Next

func (expr *Expression) Next(fromTime time.Time) time.Time

Next returns the closest time instant immediately following `fromTime` which matches the cron expression `expr`

func (*Expression) NextN

func (expr *Expression) NextN(fromTime time.Time, n uint) []time.Time

NextN returns a slice of `n` closest time instants immediately following `fromTime` which match the cron expression `expr`

type Job

type Job struct {
	NextTime time.Time
	// contains filtered or unexported fields
}

Job cron job

type JobTable

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

func New

func New() *JobTable

func (*JobTable) Add

func (c *JobTable) Add(cronLine string, fn func()) (remove func(), err error)

func (*JobTable) ForceRun

func (c *JobTable) ForceRun() (nextTime time.Duration)

func (*JobTable) Run

func (c *JobTable) Run(block ...bool)

func (*JobTable) Stop

func (c *JobTable) Stop()