CreateLoopTask create new loop task and register to task service
(taskID string, isRun bool, dueTime int64, interval int64, handler TaskHandle, taskData interface{})
| 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) { |
| 233 | task, err := NewLoopTask(taskID, isRun, dueTime, interval, handler, taskData) |
| 234 | if err != nil { |
| 235 | return task, err |
| 236 | } |
| 237 | task.SetTaskService(service) |
| 238 | service.AddTask(task) |
| 239 | return task, nil |
| 240 | } |
| 241 | |
| 242 | // CreateQueueTask create new queue task and register to task service |
| 243 | func (service *TaskService) CreateQueueTask(taskID string, isRun bool, interval int64, handler TaskHandle, taskData interface{}, queueSize int64) (Task, error) { |
no test coverage detected