(querier string)
| 226 | } |
| 227 | |
| 228 | func (q *RequestQueue) UnregisterQuerierConnection(querier string) { |
| 229 | q.connectedQuerierWorkers.Dec() |
| 230 | |
| 231 | q.mtx.Lock() |
| 232 | defer q.mtx.Unlock() |
| 233 | q.queues.removeQuerierConnection(querier, time.Now()) |
| 234 | } |
| 235 | |
| 236 | func (q *RequestQueue) NotifyQuerierShutdown(querierID string) { |
| 237 | q.mtx.Lock() |