cron_line

Documentation

Index

• type CronDispatch
  • func (c *CronDispatch) Clear()
  • func (c *CronDispatch) ClearCron(jobid string)
  • func (c *CronDispatch) DsAddCron(job *CronJob)
  • func (c *CronDispatch) GetJobForId(jobId string) CronJob
  • func (c *CronDispatch) GetRunCountForId(jobId string) int
  • func (c *CronDispatch) RunCount() int
  • func (c *CronDispatch) RunCron(jobid string)
  • func (c *CronDispatch) Start()
  • func (c *CronDispatch) Stop()
  • func (c *CronDispatch) StopCron(jobid string)
• type CronJob
  • func (c *CronJob) Run()
  • func (c *CronJob) Stop()
• type CronQueue
  • func CQNew() *CronQueue
  • func (q *CronQueue) Clear()
  • func (q CronQueue) Find(num int) (c CronJob)
  • func (q CronQueue) First() (c CronJob)
  • func (q *CronQueue) Last() (c CronJob)
  • func (q *CronQueue) Pop() CronJob
  • func (q *CronQueue) Push(c CronJob)
  • func (q CronQueue) Size() int
• type JobFunc

Types

type CronDispatch

type CronDispatch struct {
	ScheduleTable map[string]*CronJob // 停止消息

	Dispatch chan *CronJob // 任务调度器

	Log log.Logger // 日志接口
	// contains filtered or unexported fields
}

CronDispatch 定时任务调度器

func (*CronDispatch) Clear

func (c *CronDispatch) Clear()

Clear 删除所有任务

func (*CronDispatch) ClearCron

func (c *CronDispatch) ClearCron(jobid string)

ClearCron 删除任务

func (*CronDispatch) DsAddCron

func (c *CronDispatch) DsAddCron(job *CronJob)

DsAddCron 添加定时任务

func (*CronDispatch) GetJobForId

func (c *CronDispatch) GetJobForId(jobId string) CronJob

GetJobForId 获取一个任务

func (*CronDispatch) GetRunCountForId

func (c *CronDispatch) GetRunCountForId(jobId string) int

GetRunCountForId 获取一个任务的执行次数

func (*CronDispatch) RunCount

func (c *CronDispatch) RunCount() int

RunCount 在运行的任务个数

func (*CronDispatch) RunCron

func (c *CronDispatch) RunCron(jobid string)

RunCron 启用定时任务

func (*CronDispatch) Start

func (c *CronDispatch) Start()

Start 启动定时任务计划功能

func (*CronDispatch) Stop

func (c *CronDispatch) Stop()

Stop 停用所有任务

func (*CronDispatch) StopCron

func (c *CronDispatch) StopCron(jobid string)

StopCron 停止任务

type CronJob

type CronJob struct {
	Name      string               // 任务名称
	JobID     string               // 任务ID 由sha 哈希生成
	ExprStr   string               // 任务表达式字符串
	Expr      *cronexpr.Expression // 解析表达式
	NextTime  time.Time            // expr.Next(now) 下一次执行的时间
	JobFunc   JobFunc              // 需要执行的方法
	Type      int                  // 任务类型 0 方法， 1 脚本
	Status    int                  // 状态 1 启用 0 停用
	Disable   chan struct{}        // 停用信号量
	Enabled   bool                 // 启用状态
	ScriptTyp int                  // 脚本类型  0 数据库脚本 1 shell 脚本 2 其他
	Script    string               // 脚本

	Log      log.Logger // 日志接口
	RunCount int        // 执行次数
	// contains filtered or unexported fields
}

CronJob 代表一个任务

func (*CronJob) Run

func (c *CronJob) Run()

func (*CronJob) Stop

func (c *CronJob) Stop()

Stop 修改状态为停用

type CronQueue

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

func CQNew

func CQNew() *CronQueue

func (*CronQueue) Clear

func (q *CronQueue) Clear()

清空队列

func (CronQueue) Find

func (q CronQueue) Find(num int) (c CronJob)

func (CronQueue) First

func (q CronQueue) First() (c CronJob)

获取队列第一个 不出栈

func (*CronQueue) Last

func (q *CronQueue) Last() (c CronJob)

获取最后一个 不出栈

func (*CronQueue) Pop

func (q *CronQueue) Pop() CronJob

出栈

func (*CronQueue) Push

func (q *CronQueue) Push(c CronJob)

入栈

func (CronQueue) Size

func (q CronQueue) Size() int

队列长度

type JobFunc

type JobFunc = func()

JobFunc 需要执行的脚本