CreateCronTask create new cron task and register to task service
(taskID string, isRun bool, express string, handler TaskHandle, taskData interface{})
| 219 | |
| 220 | // CreateCronTask create new cron task and register to task service |
| 221 | func (service *TaskService) CreateCronTask(taskID string, isRun bool, express string, handler TaskHandle, taskData interface{}) (Task, error) { |
| 222 | task, err := NewCronTask(taskID, isRun, express, handler, taskData) |
| 223 | if err != nil { |
| 224 | return task, err |
| 225 | } |
| 226 | task.SetTaskService(service) |
| 227 | service.AddTask(task) |
| 228 | return task, nil |
| 229 | } |
| 230 | |
| 231 | // CreateLoopTask create new loop task and register to task service |
| 232 | func (service *TaskService) CreateLoopTask(taskID string, isRun bool, dueTime int64, interval int64, handler TaskHandle, taskData interface{}) (Task, error) { |
no test coverage detected