crontab

package

v0.0.4 Latest Latest Go to latest Published: Jan 14, 2024 License: MIT Imports: 11 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrJobBlocked = errors.New("job is blocked")
	BlockedLimit  = 2 * time.Second
)

func DataStats() *jsongen.Map

func IsRealBlocked() error

IsRealBlocked 场景: 任务设置了立即执行, 00:59.999 刚开始执行, 下次执行时间 01:00 跟着就到了, 再次启动了任务, 但没抢到锁, 忽略该次 Blocked

func Runtime() error

Runtime 重新加载配置时运行

func Start() error

Start 程序启动时初始化

func Stop() error

Stop 程序退出时运行

func StopJob(name string) bool

StopJob 通过名称停止任务

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

func AddJob(ctx context.Context, name, spec string, runner Runner, opts ...cron.EntryOption) (*Job, error)

AddJob 添加任务

func GetJob(name string) (*Job, bool)

GetJob 通过名称获取任务对象

func (j *Job) IsRunning() bool

func (j *Job) Name() string

func (j *Job) Next() time.Time

func (j *Job) Prev() time.Time

func (j *Job) Stop()

type Runner interface {
	Run(ctx context.Context) error
}