mirror of
https://github.com/storytold/voder-proxy.git
synced 2026-10-19 07:43:12 +00:00
add proxy healthcheck endpoint
This commit is contained in:
@@ -97,6 +97,11 @@ fn _debug_request(req: Request<Body>) -> BoxFut {
|
|||||||
Box::new(future::ok(response))
|
Box::new(future::ok(response))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
fn health_check_response(_req: Request<Body>) -> BoxFut {
|
||||||
|
let response = Response::new(Body::from("healthy"));
|
||||||
|
Box::new(future::ok(response))
|
||||||
|
}
|
||||||
|
|
||||||
struct RequestDetails {
|
struct RequestDetails {
|
||||||
pub request_bytes: Vec<u8>,
|
pub request_bytes: Vec<u8>,
|
||||||
pub speaker: String,
|
pub speaker: String,
|
||||||
@@ -227,6 +232,8 @@ fn main() -> AnyhowResult<()> {
|
|||||||
speak_proxy(req, remote_addr.clone(), router3, "/speak"),
|
speak_proxy(req, remote_addr.clone(), router3, "/speak"),
|
||||||
(&Method::POST, "/speak_spectrogram") =>
|
(&Method::POST, "/speak_spectrogram") =>
|
||||||
speak_proxy(req, remote_addr.clone(), router3, "/speak_spectrogram"),
|
speak_proxy(req, remote_addr.clone(), router3, "/speak_spectrogram"),
|
||||||
|
(&Method::GET, "/proxy_health") =>
|
||||||
|
health_check_response(req),
|
||||||
_ => {
|
_ => {
|
||||||
let forward = router3.get_random_host();
|
let forward = router3.get_random_host();
|
||||||
info!("Forwarding to `{}` random host: {}", &forward, req.uri());
|
info!("Forwarding to `{}` random host: {}", &forward, req.uri());
|
||||||
|
|||||||
Reference in New Issue
Block a user