(user string)
| 176 | } |
| 177 | |
| 178 | func (f *Frontend) cleanupInactiveUserMetrics(user string) { |
| 179 | f.queueLength.DeletePartialMatch(prometheus.Labels{ |
| 180 | "user": user, |
| 181 | }) |
| 182 | f.discardedRequests.DeletePartialMatch(prometheus.Labels{ |
| 183 | "user": user, |
| 184 | }) |
| 185 | f.requestQueue.CleanupInactiveUserMetrics(user) |
| 186 | } |
| 187 | |
| 188 | // RoundTripGRPC round trips a proto (instead of a HTTP request). |
| 189 | func (f *Frontend) RoundTripGRPC(ctx context.Context, req *httpgrpc.HTTPRequest) (*httpgrpc.HTTPResponse, error) { |