Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var TaskExistsErr = errors.New("task already exists")
Functions ¶
func RegisterTask ¶
func RegisterTask(task Task, cfg *TaskConfig) error
func RemoveTask ¶
func RemoveTask(name string)
Types ¶
type Scheduler ¶
type Scheduler struct {
// contains filtered or unexported fields
}
func (*Scheduler) GetTaskStatus ¶
func (s *Scheduler) GetTaskStatus(name string) *TaskStatus
func (*Scheduler) RegisterTask ¶
func (s *Scheduler) RegisterTask(task Task, cfg *TaskConfig) (err error)
func (*Scheduler) RemoveTask ¶
type TaskConfig ¶
type TaskConfig struct {
Name string `json:"name,omitempty"`
Cron string `json:"cron,omitempty"`
Interval int64 `json:"interval,omitempty"`
Params map[string]interface{} `json:"params,omitempty"`
}
func (*TaskConfig) AddParam ¶
func (cfg *TaskConfig) AddParam(key string, value interface{})
func (*TaskConfig) Check ¶
func (cfg *TaskConfig) Check() (err error)
type TaskStatus ¶
func GetTaskStatus ¶
func GetTaskStatus(name string) *TaskStatus
Click to show internal directories.
Click to hide internal directories.