Documentation
¶
Index ¶
- type Options
- type Scheduler
- func (sched *Scheduler) AddJob(j jobstores.Job) error
- func (sched *Scheduler) Execute(f taskFunc, params map[string]interface{}, job jobstores.Job) bool
- func (sched *Scheduler) GetAllJobs() []jobstores.Job
- func (sched *Scheduler) LookupJob(JobID string) jobstores.Job
- func (sched *Scheduler) RegisterTask(f taskFunc)
- func (sched *Scheduler) RemoveAllJobs() error
- func (sched *Scheduler) RemoveJob(j jobstores.Job) error
- func (sched *Scheduler) Setup(options *Options)
- func (sched *Scheduler) Start(options ...*Options)
- func (sched *Scheduler) UpdateJob(j jobstores.Job) error
- func (sched *Scheduler) WakeUp()
- type TaskParams
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Options ¶
type Options struct {
MaxWorkers int
MaxAvaiWorkers int
TaskMaxRunTime int
Lock locks.LockIFace
Store jobstores.StoreInterface
}
MaxWorkers: 最大同时开启的协程数量 MaxAvaiWorkers: 允许最大空闲的携程数量 TaskMaxRunTime: 每个协程任务运行的最大时长,默认30秒
type Scheduler ¶
type Scheduler struct {
// contains filtered or unexported fields
}
var Sched Scheduler
func (*Scheduler) GetAllJobs ¶
func (*Scheduler) RegisterTask ¶
func (sched *Scheduler) RegisterTask(f taskFunc)
func (*Scheduler) RemoveAllJobs ¶
type TaskParams ¶
type TaskParams map[string]interface{}
Source Files
Click to show internal directories.
Click to hide internal directories.