cron

Documentation

Index

• Variables
• func SendNotification(Job model.VCron, TaskResult model.TaskResult)
• type Handler
• type VCron
  • func (c VCron) AddJobToSchedule(Job model.VCron) (err error)
  • func (c VCron) AfterExecJob(Job model.VCron, TaskResult model.TaskResult, Taskid int64)
  • func (c VCron) BeforeExecJob(Job model.VCron) (taskLogId int64)
  • func (c VCron) CreateJob(Job model.VCron) cron.FuncJob
  • func (c VCron) CronWithNoSeconds() cron.Option
  • func (c VCron) DoTaskTimeOut(Job model.VCron, TaskId int64) (s int64, e string)
  • func (c VCron) ExecJob(Job model.VCron, TaskId int64) model.TaskResult
  • func (c VCron) GetDispacherRedisLock(Job model.VCron) bool
  • func (c VCron) GetNextQueryTime(Rule string) int64
  • func (c VCron) IsLastTaskRunning(Job model.VCron) bool
  • func (c VCron) ReleaseLock(Jobid int64)
  • func (c VCron) Start()

Variables

var Mycron *cron.Cron

定时任务调度管理器

var Parser = cron.NewParser(cron.Minute | cron.Hour | cron.Dom | cron.Month | cron.Dow | cron.Descriptor)

Functions

func SendNotification

func SendNotification(Job model.VCron, TaskResult model.TaskResult)

发送任务结果通知

Types

type Handler

type Handler interface {
	Run(Job model.VCron, Taskid int64) (model.TaskResult, error)
}

type VCron

type VCron struct{}

func (VCron) AddJobToSchedule

func (c VCron) AddJobToSchedule(Job model.VCron) (err error)

添加任务

func (VCron) AfterExecJob

func (c VCron) AfterExecJob(Job model.VCron, TaskResult model.TaskResult, Taskid int64)

任务执行后置操作

func (VCron) BeforeExecJob

func (c VCron) BeforeExecJob(Job model.VCron) (taskLogId int64)

任务前置操作

func (VCron) CreateJob

func (c VCron) CreateJob(Job model.VCron) cron.FuncJob

创建任务

func (VCron) CronWithNoSeconds

func (c VCron) CronWithNoSeconds() cron.Option

设置cron最小粒度为分钟

func (VCron) DoTaskTimeOut

func (c VCron) DoTaskTimeOut(Job model.VCron, TaskId int64) (s int64, e string)

超时处理

func (VCron) ExecJob

func (c VCron) ExecJob(Job model.VCron, TaskId int64) model.TaskResult

执行具体任务

func (VCron) GetDispacherRedisLock

func (c VCron) GetDispacherRedisLock(Job model.VCron) bool

防并发锁

func (VCron) GetNextQueryTime

func (c VCron) GetNextQueryTime(Rule string) int64

根据rule规则获取下一次执行时间

func (VCron) IsLastTaskRunning

func (c VCron) IsLastTaskRunning(Job model.VCron) bool

当前job是否已经有作业在运行

func (VCron) ReleaseLock

func (c VCron) ReleaseLock(Jobid int64)

释放锁

func (VCron) Start

func (c VCron) Start()

初始化任务, 从数据库取出所有任务, 添加到定时任务并运行