jobs

Documentation

Index

• func AddJob(job Job) (int, error)
• func Remove(entryID int) chan struct{}
• func Startup()
• type Base
  • func (b *Base) Expression() string
  • func (*Base) Run()
  • func (b *Base) SetEntryId(id int)
• type ExamplesOne
  • func (ExamplesOne) Exec(arg interface{}) error
• type ExecJob
  • func (e *ExecJob) Run()
• type HttpJob
  • func (h *HttpJob) Run()
• type Job
  • func Convert(item models.Job) Job
• type JobExec

Functions

func AddJob

func AddJob(job Job) (int, error)

添加任务 AddJob(invokeTarget string, jobId int, jobName string, cronExpression string)

func Remove

func Remove(entryID int) chan struct{}

移除任务

func Startup

func Startup()

初始化

Types

type Base

type Base struct {
	JobId          uint   // 数据库id
	EntryId        int    // cron id
	Name           string // 名称
	InvokeTarget   string // 调用目标名
	CronExpression string // cron linux表达式
	Args           string // 回调参数
}

Base base job

func (*Base) Expression

func (b *Base) Expression() string

Expression implement Job interface

func (*Base) Run

func (*Base) Run()

Run implement Job interface

func (*Base) SetEntryId

func (b *Base) SetEntryId(id int)

SetEntryId implement Job interface

type ExamplesOne

type ExamplesOne struct{}

新添加的job 必须按照以下格式定义，并实现Exec函数

func (ExamplesOne) Exec

func (ExamplesOne) Exec(arg interface{}) error

type ExecJob

type ExecJob struct {
	Base
}

ExecJob exec job

func (*ExecJob) Run

func (e *ExecJob) Run()

type HttpJob

type HttpJob struct {
	Base
}

HttpJob http job

func (*HttpJob) Run

func (h *HttpJob) Run()

http 任务接口

type Job

type Job interface {
	Expression() string
	Run()
	SetEntryId(id int)
}

func Convert

func Convert(item models.Job) Job

type JobExec

type JobExec interface {
	Exec(arg interface{}) error
}