()
| 32 | } |
| 33 | |
| 34 | func NewPrometheusStatsReporter() *PrometheusStatsReporter { |
| 35 | inFlightRequestsGauge := promauto.NewGaugeVec(prometheus.GaugeOpts{ |
| 36 | Name: "cortex_in_flight_requests", |
| 37 | Help: "The number of in-flight requests for a cortex API", |
| 38 | }, []string{"api_name"}) |
| 39 | |
| 40 | return &PrometheusStatsReporter{ |
| 41 | handler: promhttp.Handler(), |
| 42 | inFlightRequests: inFlightRequestsGauge, |
| 43 | } |
| 44 | } |
| 45 | |
| 46 | func (r *PrometheusStatsReporter) AddAPI(apiName string) { |
| 47 | r.inFlightRequests.WithLabelValues(apiName).Set(0) |