cron_line

package

v0.1.0 Latest Latest Go to latest Published: Oct 26, 2021 License: Apache-2.0 Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

gitee.com/1994net/yecron

Documentation ¶

Index ¶

type CronDispatch
type CronJob
- func (c *CronJob) Run()
- func (c *CronJob) Stop()
type CronQueue
- func CQNew() *CronQueue
type JobFunc

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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 ¶ added in v0.0.3

func (c *CronDispatch) ClearCron(jobid string)

ClearCron 删除任务

func (*CronDispatch) DsAddCron ¶ added in v0.0.5

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

DsAddCron 添加定时任务

func (*CronDispatch) GetJobForId ¶ added in v0.1.0

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

GetJobForId 获取一个任务

func (*CronDispatch) GetRunCountForId ¶ added in v0.1.0

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

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

func (*CronDispatch) RunCount ¶ added in v0.0.3

func (c *CronDispatch) RunCount() int

RunCount 在运行的任务个数

func (*CronDispatch) RunCron ¶ added in v0.0.3

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 ¶ added in v0.0.3

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 ¶ added in v0.0.2

type JobFunc = func()

JobFunc 需要执行的脚本

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL