cron

Documentation

Index

• func AddJob(spec string, job *Job) bool
• func Close()
• func CmdParams(command string) []string
• func GetEntries(size int) []*cron.Entry
• func GetEntryById(id uint) *cron.Entry
• func HistoryJobsRunning() bool
• func InitJobs() error
• func Initial(sizes ...int)
• func InitialMailTpl()
• func MailTpl() *template.Template
• func MainCron(mustStart bool) *cron.Cron
• func NewCmdRec(max uint64) *cmdRec
• func Parse(spec string) error
• func RemoveJob(id uint)
• func Running() bool
• func SendMail(toEmail string, toUsername string, title string, content []byte, ...) error
• type Job
  • func NewCommandJob(id uint, name string, command string) *Job
  • func NewJobFromTask(task *dbschema.Task) (*Job, error)
  • func (j *Job) Id() uint
  • func (j *Job) LogId() uint
  • func (j *Job) Name() string
  • func (j *Job) Run()
  • func (j *Job) Status() int

Functions

func AddJob

func AddJob(spec string, job *Job) bool

func Close

func Close()

func CmdParams

func CmdParams(command string) []string

func GetEntries

func GetEntries(size int) []*cron.Entry

func GetEntryById

func GetEntryById(id uint) *cron.Entry

func HistoryJobsRunning

func HistoryJobsRunning() bool

func InitJobs

func InitJobs() error

func Initial

func Initial(sizes ...int)

func InitialMailTpl

func InitialMailTpl()

func MailTpl

func MailTpl() *template.Template

func MainCron

func MainCron(mustStart bool) *cron.Cron

func NewCmdRec

func NewCmdRec(max uint64) *cmdRec

func Parse

func Parse(spec string) error

func RemoveJob

func RemoveJob(id uint)

func Running

func Running() bool

func SendMail

func SendMail(toEmail string, toUsername string, title string, content []byte, ccList ...string) error

Types

type Job

type Job struct {
	Concurrent bool // 同一个任务是否允许并行执行
	// contains filtered or unexported fields
}

func NewCommandJob

func NewCommandJob(id uint, name string, command string) *Job

func NewJobFromTask

func NewJobFromTask(task *dbschema.Task) (*Job, error)

func (*Job) Id

func (j *Job) Id() uint

func (*Job) LogId

func (j *Job) LogId() uint

func (*Job) Name

func (j *Job) Name() string

func (*Job) Run

func (j *Job) Run()

func (*Job) Status

func (j *Job) Status() int