task

Documentation

Index

• Constants
• type Func
  • func (r Func) Run()
• type ItaskMana
  • func NewTask() ItaskMana
• type Job
  • func New(job cron.Job) *Job
  • func (j *Job) Run()
  • func (j *Job) StatusUpdate() string
• type StatusData
• type TaskMana
  • func (t *TaskMana) Entries() []cron.Entry
  • func (t *TaskMana) Every(duration time.Duration, job cron.Job)
  • func (t *TaskMana) FindTask(jobId string) (ok bool)
  • func (t *TaskMana) In(duration time.Duration, job cron.Job)
  • func (t *TaskMana) Now(job cron.Job)
  • func (t *TaskMana) Remove(jobId string)
  • func (t *TaskMana) Schedule(spec string, jobId string, job cron.Job) (id cron.EntryID, err error)
  • func (t *TaskMana) Start(v ...int)
  • func (t *TaskMana) StatusJson() map[string]interface{}
  • func (t *TaskMana) StatusPage() []StatusData
  • func (t *TaskMana) Stop()

Constants

const DEFAULT_JOB_POOL_SIZE = 10

DEFAULT_JOB_POOL_SIZE 默认运行任务数量

const UNNAMED = "(unnamed)"

Types

type Func

type Func func()

Func Callers can use jobs.Func to wrap a raw func. (Copying the type to this package makes it more visible)

For example:

jobrunner.Schedule("cron.frequent", jobs.Func(myFunc))

func (Func) Run

func (r Func) Run()

type ItaskMana

type ItaskMana interface {
	// Start 初始化功能
	Start(v ...int)
	// Schedule 添加任务
	Schedule(spec string, jobId string, job cron.Job) (id cron.EntryID, err error)
	// Every 添加任务
	Every(duration time.Duration, job cron.Job)
	// Now 运行一个任务
	Now(job cron.Job)
	// In 定时运行一个任务
	In(duration time.Duration, job cron.Job)
	// Remove 移除一个任务
	Remove(jobId string)
	// Stop 功能停止运行
	Stop()
	// FindTask 任务是否存在
	FindTask(jobId string) (ok bool)
	// 当前任务状态
	StatusJson() map[string]interface{}
}

func NewTask

func NewTask() ItaskMana

type Job

type Job struct {
	Name string

	Status  string
	Latency string
	// contains filtered or unexported fields
}

func New

func New(job cron.Job) *Job

func (*Job) Run

func (j *Job) Run()

func (*Job) StatusUpdate

func (j *Job) StatusUpdate() string

type StatusData

type StatusData struct {
	Id        cron.EntryID
	JobRunner *Job
	Next      string
	Prev      string
}

type TaskMana

type TaskMana struct {
	// MainCron 作业调度程序单例实例.
	MainCron *cron.Cron
	// 存储当前还在调度中的任务
	Name map[string]cron.EntryID
	// contains filtered or unexported fields
}

func (*TaskMana) Entries

func (t *TaskMana) Entries() []cron.Entry

Entries Return detailed list of currently running recurring jobs to remove an entry, first retrieve the ID of entry

func (*TaskMana) Every

func (t *TaskMana) Every(duration time.Duration, job cron.Job)

Every 按照一个时间范围定期运行

func (*TaskMana) FindTask

func (t *TaskMana) FindTask(jobId string) (ok bool)

FindTask 查找是否存在任务

func (*TaskMana) In

func (t *TaskMana) In(duration time.Duration, job cron.Job)

In 延迟运行任务一次.

func (*TaskMana) Now

func (t *TaskMana) Now(job cron.Job)

Now 立即执行一个任务一次

func (*TaskMana) Remove

func (t *TaskMana) Remove(jobId string)

Remove 移除一个任务

func (*TaskMana) Schedule

func (t *TaskMana) Schedule(spec string, jobId string, job cron.Job) (id cron.EntryID, err error)

Schedule 按照时间规则运行一个任务

func (*TaskMana) Start

func (t *TaskMana) Start(v ...int)

Start 开启一个服务

func (*TaskMana) StatusJson

func (t *TaskMana) StatusJson() map[string]interface{}

StatusJson 任务的当前状态

func (*TaskMana) StatusPage

func (t *TaskMana) StatusPage() []StatusData

func (*TaskMana) Stop

func (t *TaskMana) Stop()

Stop 停止服务