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
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67

//! REST + WebSocket route registration. Each resource gets its own
//! submodule. All handlers share [`crate::AppState`].

use axum::routing::get;
use axum::Router;

use crate::ws::WsHub;
use crate::AppState;

pub mod actors;
pub mod cluster;
pub mod ddata;
pub mod dead_letters;
pub mod overview;
pub mod persistence;
pub mod remote;
pub mod sharding;
pub mod streams;

#[cfg(feature = "metrics-prometheus")]
pub mod metrics;

#[cfg(feature = "aggregator")]
pub mod cluster_wide;

pub fn build_router(state: AppState, ws_capacity: usize) -> Router {
    let hub = WsHub::new(state.telemetry.bus.clone(), ws_capacity);

    let api = Router::new()
        .route("/overview", get(overview::get_overview))
        .route("/actors/tree", get(actors::get_tree))
        .route("/actors", get(actors::list_actors))
        .route("/dead-letters", get(dead_letters::list_dead_letters))
        .route("/cluster/state", get(cluster::get_state))
        .route("/cluster/reachability", get(cluster::get_reachability))
        .route("/sharding", get(sharding::get_sharding))
        .route("/persistence", get(persistence::get_persistence))
        .route("/remote", get(remote::get_remote))
        .route("/streams", get(streams::get_streams))
        .route("/ddata", get(ddata::get_ddata))
        .route("/snapshot", get(overview::get_full_snapshot))
        .with_state(state.clone());

    #[allow(unused_mut)]
    let mut app = Router::new()
        .nest("/api", api)
        .route("/ws", get(crate::ws::ws_handler))
        .route("/healthz", get(|| async { "ok" }))
        .with_state(hub);

    #[cfg(feature = "metrics-prometheus")]
    {
        app = app.merge(metrics::metrics_router(state.clone()));
    }

    #[cfg(feature = "aggregator")]
    {
        app = app.merge(cluster_wide::router(state.clone()));
    }

    #[cfg(feature = "embed-ui")]
    {
        app = app.fallback(crate::spa::serve_embedded);
    }

    app.layer(tower_http::cors::CorsLayer::permissive())
}