cron

Documentation

Index

• Variables
• func AddJobs(jos ...Job)
• func Init() error
• func Stop()
• type Job
• type JobWrapper
• type Option
  • func SingleNode() Option
  • func Wrappers(wrappers ...JobWrapper) Option
• type Options

Variables

var (
	EmptyOptions []Option

	Recover             = cron.Recover(newLog())
	SkipIfStillRunning  = cron.SkipIfStillRunning(newLog())
	DelayIfStillRunning = cron.DelayIfStillRunning(newLog())
)

Functions

func AddJobs

func AddJobs(jos ...Job)

func Init

func Init() error

func Stop

func Stop()

Types

type Job

type Job interface {
	Name() string
	Spec() string
	Options() []Option
	Run()
}

type JobWrapper

type JobWrapper = cron.JobWrapper

type Option

type Option func(*Options)

func SingleNode

func SingleNode() Option

func Wrappers

func Wrappers(wrappers ...JobWrapper) Option

type Options

type Options struct {
	Wrappers   []JobWrapper
	SingleNode bool
}