bcl-ddog 0.1.0

A fast CLI for querying Datadog logs.
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

mod aggregate;
mod facets;
mod get;
mod search;
mod tail;

use clap::{Args, Subcommand};

use crate::cli::Ctx;

#[derive(Debug, Args)]
pub struct LogsArgs {
    #[command(subcommand)]
    pub command: LogsCommand,
}

#[derive(Debug, Subcommand)]
pub enum LogsCommand {
    /// One-shot query over a time range.
    Search(search::SearchArgs),
    /// Stream new matching logs (polling).
    Tail(tail::TailArgs),
    /// Fetch a single log event by ID.
    Get(get::GetArgs),
    /// Run an aggregation query.
    Aggregate(aggregate::AggregateArgs),
    /// Discover facets (not yet implemented).
    Facets(facets::FacetsArgs),
}

pub async fn dispatch(ctx: Ctx, args: LogsArgs) -> anyhow::Result<()> {
    match args.command {
        LogsCommand::Search(a) => search::run(ctx, a).await,
        LogsCommand::Tail(a) => tail::run(ctx, a).await,
        LogsCommand::Get(a) => get::run(ctx, a).await,
        LogsCommand::Aggregate(a) => aggregate::run(ctx, a).await,
        LogsCommand::Facets(a) => facets::run(ctx, a).await,
    }
}

pub fn parse_fields(raw: Option<String>) -> Vec<String> {
    raw.map(|s| {
        s.split(',')
            .map(|p| p.trim().to_string())
            .filter(|p| !p.is_empty())
            .collect()
    })
    .unwrap_or_default()
}

pub fn parse_indexes(raw: Option<String>) -> Option<Vec<String>> {
    raw.map(|s| {
        s.split(',')
            .map(|p| p.trim().to_string())
            .filter(|p| !p.is_empty())
            .collect()
    })
}