1 2 3 4 5 6 7 8 9 10 11 12
//! Streams snapshot. use axum::extract::State; use axum::Json; use rakka_telemetry::dto::StreamsSnapshot; use crate::AppState; pub async fn get_streams(State(state): State<AppState>) -> Json<StreamsSnapshot> { Json(state.telemetry.streams.snapshot()) }