(userID string, querierID string)
| 181 | } |
| 182 | |
| 183 | func (q *RequestQueue) getPriorityForQuerier(userID string, querierID string) (int64, bool) { |
| 184 | if priority, ok := q.queues.userQueues[userID].reservedQueriers[querierID]; ok { |
| 185 | return priority, true |
| 186 | } |
| 187 | return 0, false |
| 188 | } |
| 189 | |
| 190 | func (q *RequestQueue) forgetDisconnectedQueriers(_ context.Context) error { |
| 191 | q.mtx.Lock() |
no outgoing calls
no test coverage detected