rakka-dashboard 0.2.1

Live web UI over a running rakka system — REST + WebSocket + embedded React SPA, Prometheus / OTLP exporters.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

//! Dead-letter listing with optional `?limit=` parameter.

use axum::extract::{Query, State};
use axum::Json;
use serde::Deserialize;

use rakka_telemetry::dto::DeadLetterRecord;

use crate::AppState;

#[derive(Debug, Deserialize)]
pub struct DeadLetterQuery {
    pub limit: Option<usize>,
}

pub async fn list_dead_letters(
    State(state): State<AppState>,
    Query(q): Query<DeadLetterQuery>,
) -> Json<Vec<DeadLetterRecord>> {
    Json(state.telemetry.dead_letters.recent(q.limit.unwrap_or(100)))
}