in go/grpshuffle_client/lib/http.go [164:195]
func healthHandler(writer http.ResponseWriter, _ *http.Request) {
conn, err := Connect(Host, Port, NoTLS)
if err != nil {
newErrorResponse(writer, 500, "Internal Server Error")
return
}
defer CloseConnect(conn)
hc := grpc_health_v1.NewHealthClient(conn)
result, err := HealthCheck(&hc)
if err != nil {
newErrorResponse(writer, 504, "Gateway Timeout")
log.Print(err)
return
}
res, err := json.Marshal(HttpResponse{
Status: 200,
Msg: "Ok",
Result: result,
})
if err != nil {
log.Print(err)
return
}
_, err = writer.Write(res)
if err != nil {
log.Print(err)
return
}
}