Move /healthz handler to handlers package

Signed-off-by: Vivek Singh <vivekkmr45@yahoo.in>
This commit is contained in:
Vivek Singh 2019-02-26 18:57:51 +05:30 committed by Alex Ellis
parent 40dbede065
commit b87ecde60f
2 changed files with 23 additions and 16 deletions

View File

@ -0,0 +1,20 @@
// Copyright (c) OpenFaaS Author(s) 2019. All rights reserved.
// Licensed under the MIT license. See LICENSE file in the project root for full license information.
package handlers
import "net/http"
//HealthzHandler healthz hanlder for mertics server
func HealthzHandler(w http.ResponseWriter, r *http.Request) {
switch r.Method {
case http.MethodGet:
w.WriteHeader(http.StatusOK)
w.Write([]byte("OK"))
break
default:
w.WriteHeader(http.StatusMethodNotAllowed)
}
}

View File

@ -232,11 +232,11 @@ func runMetricsServer() {
metricsHandler := metrics.PrometheusHandler() metricsHandler := metrics.PrometheusHandler()
router := mux.NewRouter() router := mux.NewRouter()
router.Handle("/metrics", metricsHandler) router.Handle("/metrics", metricsHandler)
router.HandleFunc("/healthz", healthzHandler) router.HandleFunc("/healthz", handlers.HealthzHandler)
port := 8082 port := 8082
readTimeout := time.Duration(5) * time.Second readTimeout := 5 * time.Second
writeTimeout := time.Duration(5) * time.Second writeTimeout := 5 * time.Second
s := &http.Server{ s := &http.Server{
Addr: fmt.Sprintf(":%d", port), Addr: fmt.Sprintf(":%d", port),
@ -248,16 +248,3 @@ func runMetricsServer() {
log.Fatal(s.ListenAndServe()) log.Fatal(s.ListenAndServe())
} }
func healthzHandler(w http.ResponseWriter, r *http.Request) {
switch r.Method {
case http.MethodGet:
w.WriteHeader(http.StatusOK)
w.Write([]byte("OK"))
break
default:
w.WriteHeader(http.StatusMethodNotAllowed)
}
}