devrig 0.30.1

Local development orchestrator
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

use axum::extract::{Path, Query, State};
use axum::http::StatusCode;
use axum::response::IntoResponse;
use axum::Json;

use crate::otel::query::TraceQuery;

use super::DashboardState;

pub async fn list_traces(
    State(state): State<DashboardState>,
    Query(query): Query<TraceQuery>,
) -> impl IntoResponse {
    let store = state.store.read().await;
    let traces = store.query_traces(&query);
    Json(traces).into_response()
}

pub async fn get_trace(
    State(state): State<DashboardState>,
    Path(trace_id): Path<String>,
) -> impl IntoResponse {
    let store = state.store.read().await;
    match store.get_trace(&trace_id) {
        Some(detail) => Json(detail).into_response(),
        None => StatusCode::NOT_FOUND.into_response(),
    }
}

pub async fn get_related(
    State(state): State<DashboardState>,
    Path(trace_id): Path<String>,
) -> impl IntoResponse {
    let store = state.store.read().await;
    let related = store.get_related(&trace_id);
    Json(related).into_response()
}