| 166 | } |
| 167 | |
| 168 | type TriggerTask struct { |
| 169 | task Task |
| 170 | currentScheduledTask *ScheduledRunnableTask |
| 171 | executor TaskExecutor |
| 172 | triggerContext *SimpleTriggerContext |
| 173 | triggerContextMu sync.RWMutex |
| 174 | trigger Trigger |
| 175 | nextTriggerTime time.Time |
| 176 | } |
| 177 | |
| 178 | func CreateTriggerTask(task Task, executor TaskExecutor, trigger Trigger) (*TriggerTask, error) { |
| 179 | if task == nil { |
nothing calls this directly
no outgoing calls
no test coverage detected