mirror of
https://github.com/TwiN/gatus.git
synced 2025-02-16 18:21:07 +01:00
Expose metrics on /metrics
This commit is contained in:
parent
0bd58f8cd7
commit
0ed525e032
14
main.go
14
main.go
@ -2,11 +2,12 @@ package main
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
"log"
|
"github.com/TwinProduction/gatus/config"
|
||||||
"net/http"
|
|
||||||
|
|
||||||
"github.com/TwinProduction/gatus/core"
|
"github.com/TwinProduction/gatus/core"
|
||||||
"github.com/TwinProduction/gatus/watchdog"
|
"github.com/TwinProduction/gatus/watchdog"
|
||||||
|
"github.com/prometheus/client_golang/prometheus/promhttp"
|
||||||
|
"log"
|
||||||
|
"net/http"
|
||||||
)
|
)
|
||||||
|
|
||||||
func main() {
|
func main() {
|
||||||
@ -14,17 +15,20 @@ func main() {
|
|||||||
http.HandleFunc("/api/v1/results", serviceResultsHandler)
|
http.HandleFunc("/api/v1/results", serviceResultsHandler)
|
||||||
http.HandleFunc("/health", healthHandler)
|
http.HandleFunc("/health", healthHandler)
|
||||||
http.Handle("/", http.FileServer(http.Dir("./static")))
|
http.Handle("/", http.FileServer(http.Dir("./static")))
|
||||||
|
if config.Get().Metrics {
|
||||||
|
http.Handle("/metrics", promhttp.Handler())
|
||||||
|
}
|
||||||
log.Println("[main][main] Listening on port 8080")
|
log.Println("[main][main] Listening on port 8080")
|
||||||
log.Fatal(http.ListenAndServe(":8080", nil))
|
log.Fatal(http.ListenAndServe(":8080", nil))
|
||||||
}
|
}
|
||||||
|
|
||||||
func serviceResultsHandler(writer http.ResponseWriter, request *http.Request) {
|
func serviceResultsHandler(writer http.ResponseWriter, _ *http.Request) {
|
||||||
serviceResults := watchdog.GetServiceResults()
|
serviceResults := watchdog.GetServiceResults()
|
||||||
writer.WriteHeader(http.StatusOK)
|
writer.WriteHeader(http.StatusOK)
|
||||||
_, _ = writer.Write(structToJsonBytes(serviceResults))
|
_, _ = writer.Write(structToJsonBytes(serviceResults))
|
||||||
}
|
}
|
||||||
|
|
||||||
func healthHandler(writer http.ResponseWriter, request *http.Request) {
|
func healthHandler(writer http.ResponseWriter, _ *http.Request) {
|
||||||
writer.WriteHeader(http.StatusOK)
|
writer.WriteHeader(http.StatusOK)
|
||||||
_, _ = writer.Write(structToJsonBytes(&core.HealthStatus{Status: "UP"}))
|
_, _ = writer.Write(structToJsonBytes(&core.HealthStatus{Status: "UP"}))
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user