RepoMirrors
/
alertmanager
mirror of https://github.com/prometheus/alertmanager
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add web handler instrumentation

This commit is contained in:
Fabian Reinartz 2016-01-09 13:16:00 +01:00
parent b887885bf6
commit 1eb64b4263
2 changed files with 32 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
api.go
View File

@ -21,6 +21,7 @@ import (
"sync" "sync"
"time" "time"
"github.com/prometheus/client_golang/prometheus"
"github.com/prometheus/common/log" "github.com/prometheus/common/log"
"github.com/prometheus/common/model" "github.com/prometheus/common/model"
"github.com/prometheus/common/route" "github.com/prometheus/common/route"
@ -60,23 +61,24 @@ func NewAPI(alerts provider.Alerts, silences provider.Silences, gf func() AlertO
// Register regieters the API handlers under their correct routes // Register regieters the API handlers under their correct routes
// in the given router. // in the given router.
func (api *API) Register(r *route.Router) { func (api *API) Register(r *route.Router) {
ihf := prometheus.InstrumentHandlerFunc
// Register legacy forwarder for alert pushing. // Register legacy forwarder for alert pushing.
r.Post("/alerts", api.legacyAddAlerts) r.Post("/alerts", ihf("legacy_add_alerts", api.legacyAddAlerts))
// Register actual API. // Register actual API.
r = r.WithPrefix("/v1") r = r.WithPrefix("/v1")
r.Get("/status", api.status) r.Get("/status", ihf("status", api.status))
r.Get("/alerts/groups", api.alertGroups) r.Get("/alerts/groups", ihf("alert_groups", api.alertGroups))
r.Get("/alerts", api.listAlerts) r.Get("/alerts", ihf("list_alerts", api.listAlerts))
r.Post("/alerts", api.addAlerts) r.Post("/alerts", ihf("add_alerts", api.addAlerts))
r.Get("/silences", api.listSilences) r.Get("/silences", ihf("list_silences", api.listSilences))
r.Post("/silences", api.addSilence) r.Post("/silences", ihf("add_silence", api.addSilence))
r.Get("/silence/:sid", ihf("get_silence", api.getSilence))
r.Get("/silence/:sid", api.getSilence) r.Del("/silence/:sid", ihf("del_silence", api.delSilence))
r.Del("/silence/:sid", api.delSilence)
} }
// Update sets the configuration string to a new value. // Update sets the configuration string to a new value.

30
web.go
View File

@ -19,6 +19,7 @@ import (
"net/http" "net/http"
"path/filepath" "path/filepath"
"github.com/prometheus/client_golang/prometheus"
"github.com/prometheus/common/log" "github.com/prometheus/common/log"
"github.com/prometheus/common/route" "github.com/prometheus/common/route"
@ -46,15 +47,24 @@ func serveAsset(w http.ResponseWriter, req *http.Request, fp string) {
// RegisterWeb registers handlers to serve files for the web interface. // RegisterWeb registers handlers to serve files for the web interface.
func RegisterWeb(r *route.Router) { func RegisterWeb(r *route.Router) {
r.Get("/app/*filepath", func(w http.ResponseWriter, req *http.Request) { ihf := prometheus.InstrumentHandlerFunc
fp := route.Param(route.Context(req), "filepath")
serveAsset(w, req, filepath.Join("ui/app", fp)) r.Get("/app/*filepath", ihf("app_files",
}) func(w http.ResponseWriter, req *http.Request) {
r.Get("/lib/*filepath", func(w http.ResponseWriter, req *http.Request) { fp := route.Param(route.Context(req), "filepath")
fp := route.Param(route.Context(req), "filepath") serveAsset(w, req, filepath.Join("ui/app", fp))
serveAsset(w, req, filepath.Join("ui/lib", fp)) },
}) ))
r.Get("/", func(w http.ResponseWriter, req *http.Request) { r.Get("/lib/*filepath", ihf("lib_files",
func(w http.ResponseWriter, req *http.Request) {
fp := route.Param(route.Context(req), "filepath")
serveAsset(w, req, filepath.Join("ui/lib", fp))
},
))
r.Get("/metrics", prometheus.Handler().ServeHTTP)
r.Get("/", ihf("index", func(w http.ResponseWriter, req *http.Request) {
serveAsset(w, req, "ui/app/index.html") serveAsset(w, req, "ui/app/index.html")
}) }))
} }