deploy/util/healthz/healthz.go

package healthz

import (
	"fmt"
	"net/http"
	"time"

	log "github.com/sirupsen/logrus"
)

// ServeHealthCheck serves the health check endpoint.
// ServeHealthCheck relies on the provided function to return an error if unhealthy and nil otherwise.
func ServeHealthCheck(mux *http.ServeMux, f func(r *http.Request) error) {
	mux.HandleFunc("/healthz", func(w http.ResponseWriter, r *http.Request) {
		startTs := time.Now()
		if err := f(r); err != nil {
			w.WriteHeader(http.StatusServiceUnavailable)
			log.WithFields(log.Fields{
				"duration":  time.Since(startTs),
				"component": "healthcheck",
			}).WithError(err).Error("Error serving health check request")
		} else {
			fmt.Fprintln(w, "ok")
		}
	})
}