ListBySession returns all tasks for a session (any state).
(sessionID string)
| 126 | |
| 127 | // ListBySession returns all tasks for a session (any state). |
| 128 | func (tm *TaskManager) ListBySession(sessionID string) []*Task { |
| 129 | tm.mu.RLock() |
| 130 | defer tm.mu.RUnlock() |
| 131 | |
| 132 | var out []*Task |
| 133 | for k, t := range tm.tasks { |
| 134 | if k.sessionID == sessionID { |
| 135 | out = append(out, t) |
| 136 | } |
| 137 | } |
| 138 | return out |
| 139 | } |
| 140 | |
| 141 | // ActiveBySession returns tasks in Pending or Running state for a session. |
| 142 | func (tm *TaskManager) ActiveBySession(sessionID string) []*Task { |
no outgoing calls