Documentation ¶
Index ¶
- Constants
- func SendNotification(taskModel models.Task, taskResult TaskResult)
- type ConcurrencyQueue
- type HTTPHandler
- type Handler
- type Instance
- type RPCHandler
- type Task
- func (task Task) Add(taskModel models.Task)
- func (task Task) BatchAdd(tasks []models.Task)
- func (task Task) Initialize()
- func (task Task) NextRunTime(taskModel models.Task) time.Time
- func (task Task) Remove(id int)
- func (task Task) RemoveAndAdd(taskModel models.Task)
- func (task Task) Run(taskModel models.Task)
- func (task Task) Stop(ip string, port int, id int64)
- func (task Task) WaitAndExit()
- type TaskCount
- type TaskResult
Constants ¶
View Source
const HttpExecTimeout = 300
http任务执行时间不超过300秒
Variables ¶
This section is empty.
Functions ¶
func SendNotification ¶
func SendNotification(taskModel models.Task, taskResult TaskResult)
发送任务结果通知
Types ¶
type ConcurrencyQueue ¶
type ConcurrencyQueue struct {
// contains filtered or unexported fields
}
并发队列
func (*ConcurrencyQueue) Add ¶
func (cq *ConcurrencyQueue) Add()
func (*ConcurrencyQueue) Done ¶
func (cq *ConcurrencyQueue) Done()
type TaskResult ¶
Click to show internal directories.
Click to hide internal directories.