When querier is waiting for next request, this unblocks the method.
()
| 241 | |
| 242 | // When querier is waiting for next request, this unblocks the method. |
| 243 | func (q *RequestQueue) QuerierDisconnecting() { |
| 244 | q.cond.Broadcast() |
| 245 | } |
| 246 | |
| 247 | func (q *RequestQueue) GetConnectedQuerierWorkersMetric() float64 { |
| 248 | return float64(q.connectedQuerierWorkers.Load()) |
no test coverage detected