Documentation
¶
Index ¶
- Constants
- type Func
- type ItaskMana
- type Job
- 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 ¶
View Source
const DEFAULT_JOB_POOL_SIZE = 10
DEFAULT_JOB_POOL_SIZE 默认运行任务数量
View Source
const UNNAMED = "(unnamed)"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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))
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{}
}
type Job ¶
type Job struct {
Name string
Status string
Latency string
// contains filtered or unexported fields
}
func (*Job) StatusUpdate ¶
type TaskMana ¶
type TaskMana struct {
// MainCron 作业调度程序单例实例.
MainCron *cron.Cron
// 存储当前还在调度中的任务
Name map[string]cron.EntryID
// contains filtered or unexported fields
}
func (*TaskMana) Entries ¶
Entries Return detailed list of currently running recurring jobs to remove an entry, first retrieve the ID of entry
func (*TaskMana) StatusJson ¶
StatusJson 任务的当前状态
func (*TaskMana) StatusPage ¶
func (t *TaskMana) StatusPage() []StatusData
Source Files
Click to show internal directories.
Click to hide internal directories.