mudhorn/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus.git synced 2024-11-10 15:44:05 -08:00
Code Issues Actions 3 Packages Projects Releases Wiki Activity

Merge pull request #1090 from prometheus/compress

Browse source 
Apply HTTP handler compression everywhere
This commit is contained in:
Fabian Reinartz 2015-09-17 15:09:30 +02:00
parent c42035abff f8a25f6af7
commit 704d72334c
2 changed files with 10 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
web/api/v1/api.go
View file

@ -16,6 +16,7 @@ import (
"github.com/prometheus/prometheus/promql" "github.com/prometheus/prometheus/promql"
"github.com/prometheus/prometheus/storage/local" "github.com/prometheus/prometheus/storage/local"
"github.com/prometheus/prometheus/storage/metric" "github.com/prometheus/prometheus/storage/metric"
"github.com/prometheus/prometheus/util/httputil"
"github.com/prometheus/prometheus/util/route" "github.com/prometheus/prometheus/util/route"
"github.com/prometheus/prometheus/util/strutil" "github.com/prometheus/prometheus/util/strutil"
) )
@ -79,7 +80,7 @@ func (api *API) Register(r *route.Router) {
} }
instr := func(name string, f apiFunc) http.HandlerFunc { instr := func(name string, f apiFunc) http.HandlerFunc {
return prometheus.InstrumentHandlerFunc(name, func(w http.ResponseWriter, r *http.Request) { hf := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
setCORS(w) setCORS(w)
if data, err := f(r); err != nil { if data, err := f(r); err != nil {
respondError(w, err, data) respondError(w, err, data)
@ -87,6 +88,7 @@ func (api *API) Register(r *route.Router) {
respond(w, data) respond(w, data)
} }
}) })
return prometheus.InstrumentHandler(name, httputil.CompressionHandler{hf})
} }
r.Get("/query", instr("query", api.query)) r.Get("/query", instr("query", api.query))

9
web/web.go
View file

@ -41,6 +41,7 @@ import (
"github.com/prometheus/prometheus/rules" "github.com/prometheus/prometheus/rules"
"github.com/prometheus/prometheus/storage/local" "github.com/prometheus/prometheus/storage/local"
"github.com/prometheus/prometheus/template" "github.com/prometheus/prometheus/template"
"github.com/prometheus/prometheus/util/httputil"
"github.com/prometheus/prometheus/util/route" "github.com/prometheus/prometheus/util/route"
"github.com/prometheus/prometheus/version" "github.com/prometheus/prometheus/version"
"github.com/prometheus/prometheus/web/api/legacy" "github.com/prometheus/prometheus/web/api/legacy"
@ -155,8 +156,12 @@ func New(st local.Storage, qe *promql.Engine, rm *rules.Manager, status *Prometh
router = router.WithPrefix(o.ExternalURL.Path) router = router.WithPrefix(o.ExternalURL.Path)
} }
instrf := prometheus.InstrumentHandlerFunc instrh := func(name string, h http.Handler) http.HandlerFunc {
instrh := prometheus.InstrumentHandler return prometheus.InstrumentHandler(name, httputil.CompressionHandler{h})
}
instrf := func(name string, f http.HandlerFunc) http.HandlerFunc {
return instrh(name, f)
}
router.Get("/", func(w http.ResponseWriter, r *http.Request) { router.Get("/", func(w http.ResponseWriter, r *http.Request) {
http.Redirect(w, r, "/graph", http.StatusFound) http.Redirect(w, r, "/graph", http.StatusFound)