(querierID string)
| 234 | } |
| 235 | |
| 236 | func (q *RequestQueue) NotifyQuerierShutdown(querierID string) { |
| 237 | q.mtx.Lock() |
| 238 | defer q.mtx.Unlock() |
| 239 | q.queues.notifyQuerierShutdown(querierID) |
| 240 | } |
| 241 | |
| 242 | // When querier is waiting for next request, this unblocks the method. |
| 243 | func (q *RequestQueue) QuerierDisconnecting() { |
nothing calls this directly
no test coverage detected