Merge pull request #202 from yunheL/health-check-api

Support health check API

app/api.go

@@ -287,6 +287,17 @@ func (a *App) handleClusteringGet(w http.ResponseWriter, r *http.Request) {
 	w.Write(b)
 }
 
+func (a *App) handleHealthzGet(w http.ResponseWriter, r *http.Request) {
+	s := map[string]string{"status": "healthy",}
+	b, err := json.Marshal(s)
+	if err != nil {
+		w.WriteHeader(http.StatusInternalServerError)
+		json.NewEncoder(w).Encode(APIErrors{Errors: []string{err.Error()}})
+		return
+	}
+	w.Write(b)
+}
+
 func (a *App) handleClusteringMembersGet(w http.ResponseWriter, r *http.Request) {
 	if a.Config.Clustering == nil {
 		return

app/routes.go

@@ -19,7 +19,7 @@ func (a *App) routes() {
 	a.clusterRoutes(apiV1)
 	a.configRoutes(apiV1)
 	a.targetRoutes(apiV1)
-
+	a.healthRoutes(apiV1)
 }
 
 func (a *App) clusterRoutes(r *mux.Router) {
@@ -59,3 +59,7 @@ func (a *App) targetRoutes(r *mux.Router) {
 	r.HandleFunc("/targets/{id}", a.handleTargetsPost).Methods(http.MethodPost)
 	r.HandleFunc("/targets/{id}", a.handleTargetsDelete).Methods(http.MethodDelete)
 }
+
+func (a *App) healthRoutes(r *mux.Router) {
+	r.HandleFunc("/healthz", a.handleHealthzGet).Methods(http.MethodGet)
+}