nodedb 0.3.0

Local-first, real-time, edge-to-cloud hybrid database for multi-modal workloads
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
36
37
38
39
40
41
42
43
44
45
46
47
48

// SPDX-License-Identifier: BUSL-1.1

//! `GET /v1/cluster/debug/raft/{group_id}` — dump the Raft state for one
//! group from the node-local `raft_status_fn`.
//!
//! The status closure is published by `control::cluster::start_raft`
//! at startup. It enumerates every group this node participates in;
//! we filter to the caller's requested group so the response stays
//! bounded even on nodes hosting hundreds of groups.

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

use super::super::super::auth::{AppState, ResolvedIdentity};
use super::guard::{cluster_disabled, ensure_debug_access, json_response, ok_json};

#[derive(serde::Serialize)]
struct RaftDebugResponse {
    node_id: u64,
    group_id: u64,
    status: nodedb_cluster::GroupStatus,
}

pub async fn raft_debug(
    identity: ResolvedIdentity,
    State(state): State<AppState>,
    Path(group_id): Path<u64>,
) -> Response {
    if let Some(resp) = ensure_debug_access(&state, &identity) {
        return resp;
    }
    let Some(status_fn) = state.shared.raft_status_fn.as_ref() else {
        return cluster_disabled();
    };
    let statuses = status_fn();
    match statuses.into_iter().find(|s| s.group_id == group_id) {
        Some(status) => ok_json(&RaftDebugResponse {
            node_id: state.shared.node_id,
            group_id,
            status,
        }),
        None => json_response(
            StatusCode::NOT_FOUND,
            format!(r#"{{"error":"group not found on this node","group_id":{group_id}}}"#),
        ),
    }
}