Skip to content

Commit 61346b9

Browse files
striker2000willnorris
authored andcommitted
Add a metric "http_requests_in_flight"
1 parent ba76dfa commit 61346b9

File tree

2 files changed

+12
-1
lines changed

2 files changed

+12
-1
lines changed

imageproxy.go

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -223,7 +223,12 @@ func (p *Proxy) ServeHTTP(w http.ResponseWriter, r *http.Request) {
223223
}
224224

225225
timer := prometheus.NewTimer(metricRequestDuration)
226-
defer timer.ObserveDuration()
226+
metricRequestsInFlight.Inc()
227+
defer func() {
228+
timer.ObserveDuration()
229+
metricRequestsInFlight.Dec()
230+
}()
231+
227232
h.ServeHTTP(w, r)
228233
}
229234

metrics.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,11 +29,17 @@ var (
2929
Name: "request_duration_seconds",
3030
Help: "Request response times",
3131
})
32+
metricRequestsInFlight = prometheus.NewGauge(prometheus.GaugeOpts{
33+
Namespace: "http",
34+
Name: "requests_in_flight",
35+
Help: "Number of requests in flight",
36+
})
3237
)
3338

3439
func init() {
3540
prometheus.MustRegister(metricTransformationDuration)
3641
prometheus.MustRegister(metricServedFromCache)
3742
prometheus.MustRegister(metricRemoteErrors)
3843
prometheus.MustRegister(metricRequestDuration)
44+
prometheus.MustRegister(metricRequestsInFlight)
3945
}

0 commit comments

Comments
 (0)