| 96 | } |
| 97 | |
| 98 | type ScheduledRunnableTask struct { |
| 99 | id int |
| 100 | task Task |
| 101 | taskMu sync.RWMutex |
| 102 | triggerTime time.Time |
| 103 | period time.Duration |
| 104 | fixedRate bool |
| 105 | cancelled bool |
| 106 | } |
| 107 | |
| 108 | func CreateScheduledRunnableTask(id int, task Task, triggerTime time.Time, period time.Duration, fixedRate bool) (*ScheduledRunnableTask, error) { |
| 109 | if task == nil { |
nothing calls this directly
no outgoing calls
no test coverage detected