apunkt/imageproxy
1
0
Fork 0
mirror of https://github.com/willnorris/imageproxy.git synced 2026-04-25 21:06:24 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 6

Add a metric "http_requests_in_flight"

Browse source
This commit is contained in:
Ivan Ivanov 2020-06-02 20:08:03 +03:00 • committed by Will Norris
parent ba76dfa3b2
commit 61346b9f4a
2 changed files with 12 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

7
imageproxy.go
View file

@ -223,7 +223,12 @@ func (p *Proxy) ServeHTTP(w http.ResponseWriter, r *http.Request) {
} }
timer := prometheus.NewTimer(metricRequestDuration) timer := prometheus.NewTimer(metricRequestDuration)
defer timer.ObserveDuration() metricRequestsInFlight.Inc()
defer func() {
timer.ObserveDuration()
metricRequestsInFlight.Dec()
}()
h.ServeHTTP(w, r) h.ServeHTTP(w, r)
} }

6
metrics.go
View file

@ -29,6 +29,11 @@ var (
Name: "request_duration_seconds", Name: "request_duration_seconds",
Help: "Request response times", Help: "Request response times",
}) })
metricRequestsInFlight = prometheus.NewGauge(prometheus.GaugeOpts{
Namespace: "http",
Name: "requests_in_flight",
Help: "Number of requests in flight",
})
) )
func init() { func init() {
@ -36,4 +41,5 @@ func init() {
prometheus.MustRegister(metricServedFromCache) prometheus.MustRegister(metricServedFromCache)
prometheus.MustRegister(metricRemoteErrors) prometheus.MustRegister(metricRemoteErrors)
prometheus.MustRegister(metricRequestDuration) prometheus.MustRegister(metricRequestDuration)
prometheus.MustRegister(metricRequestsInFlight)
} }