dial9-viewer 0.5.0-rc2

CLI trace viewer and S3 browser for dial9-tokio-telemetry
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

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

use crate::server::AppState;
use crate::server::credentials::MaybeCreds;
use crate::server::error::storage_error_response;

#[derive(Deserialize)]
pub struct PrefixParams {
    pub bucket: Option<String>,
    pub prefix: Option<String>,
}

pub async fn list_prefixes(
    State(state): State<AppState>,
    creds: MaybeCreds,
    Query(params): Query<PrefixParams>,
) -> Result<Json<Vec<String>>, (StatusCode, String)> {
    let backend = state.resolve(creds).await?;

    let bucket = params
        .bucket
        .or(state.default_bucket.clone())
        .ok_or((StatusCode::BAD_REQUEST, "bucket is required".to_string()))?;

    let prefix = params.prefix.unwrap_or_default();

    let prefixes = backend
        .list_prefixes(&bucket, &prefix)
        .await
        .map_err(storage_error_response)?;

    Ok(Json(prefixes))
}