(id uint64)
| 155 | } |
| 156 | |
| 157 | func (qs *QuerySupervisor) ExecutionTime(id uint64) (time.Duration, bool) { |
| 158 | qs.m.RLock() |
| 159 | defer qs.m.RUnlock() |
| 160 | if val, exists := qs.queryMap[id]; exists { |
| 161 | return time.Since(val.addedAt), true |
| 162 | } |
| 163 | |
| 164 | return 0, false |
| 165 | } |
| 166 | |
| 167 | func (qs *QuerySupervisor) KillQuery(id uint64) bool { |
| 168 | qs.m.Lock() |
no outgoing calls