tideway 0.7.17

A batteries-included Rust web framework built on Axum for building SaaS applications quickly
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

use crate::app::AppContext;
use axum::body::Body;
use axum::http::StatusCode;
use axum::response::Response;

/// Handler for the /metrics endpoint
pub async fn metrics_handler(
    axum::extract::State(ctx): axum::extract::State<AppContext>,
) -> Result<Response<Body>, StatusCode> {
    use prometheus::Encoder;

    let collector = ctx.metrics_opt().ok_or(StatusCode::SERVICE_UNAVAILABLE)?;

    let encoder = prometheus::TextEncoder::new();
    let metric_families = collector.registry().gather();

    let mut buffer = Vec::new();
    encoder
        .encode(&metric_families, &mut buffer)
        .map_err(|_| StatusCode::INTERNAL_SERVER_ERROR)?;

    let response = Response::builder()
        .status(StatusCode::OK)
        .header("content-type", "text/plain; version=0.0.4; charset=utf-8")
        .body(Body::from(buffer))
        .map_err(|_| StatusCode::INTERNAL_SERVER_ERROR)?;

    Ok(response)
}