| 103 | } |
| 104 | |
| 105 | type AgentTaskRuntime struct { |
| 106 | mu sync.Mutex |
| 107 | records map[string]*AgentTaskRecord |
| 108 | notifications map[string][]TaskNotification |
| 109 | waiters map[string][]chan struct{} |
| 110 | workers map[string]context.CancelFunc |
| 111 | workerSpecs map[string]workerSpec |
| 112 | scopes map[string]struct{} |
| 113 | childCounts map[string]int |
| 114 | taskParentScopes map[string]string |
| 115 | expiredTaskParentScopes map[string]string |
| 116 | recordCleanupCancels map[string]context.CancelFunc |
| 117 | idleTTLCancels map[string]context.CancelFunc |
| 118 | taskEventSink TaskEventSink |
| 119 | taskEventObserver TaskEventSink |
| 120 | } |
| 121 | |
| 122 | type workerSpec struct { |
nothing calls this directly
no outgoing calls
no test coverage detected