s2-lite 0.31.0

Lightweight server implementation of S2, the durable streams API, backed by object storage
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
32
33
34
35

pub mod v1;

use axum::{
    extract::State,
    http::StatusCode,
    response::{IntoResponse, Response},
};

use crate::backend::Backend;

pub fn router() -> axum::Router<Backend> {
    axum::Router::new()
        .route(/* bw compat */ "/ping", axum::routing::get(health))
        .route("/health", axum::routing::get(health))
        .route("/metrics", axum::routing::get(metrics))
        .nest("/v1", v1::router())
}

async fn health(State(backend): State<Backend>) -> Response {
    match backend.db_status() {
        Ok(()) => "OK".into_response(),
        Err(err) => (StatusCode::SERVICE_UNAVAILABLE, format!("{err:?}")).into_response(),
    }
}

async fn metrics(State(_backend): State<Backend>) -> impl axum::response::IntoResponse {
    let body = crate::metrics::gather();
    (
        [(
            axum::http::header::CONTENT_TYPE,
            "text/plain; version=0.0.4",
        )],
        body,
    )
}