iconoclast 0.3.1

Reusable code for Rust-based business μServices
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

//! managment service (health check, etc.) implemented with axum

use axum::routing::get;
use axum::{Json, Router};
use serde::Serialize;
use tokio::io;
use tokio::net::TcpListener;

#[derive(Serialize)]
struct HealthResponse {
    status: &'static str,
}

impl Default for HealthResponse {
    fn default() -> Self {
        Self { status: "ok" }
    }
}

/// provide a management service for healthz endpoints (and metrics in the future)
///
/// # Errors
///
/// May fail to bind to the given port.
pub async fn start(port: u16) -> Result<(), io::Error> {
    let app = Router::new().route("/healthz", get(async || Json(HealthResponse::default())));

    let listener = TcpListener::bind(("0.0.0.0", port)).await?;

    axum::serve(listener, app).await
}