perf-sentinel 0.16.0

CLI for perf-sentinel: polyglot performance anti-pattern detector
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
68
69
70
71
72
73
74

//! `perf-sentinel jaeger-query` subcommand: fetch traces from the
//! Jaeger query HTTP API and run them through the batch pipeline.

#![cfg(feature = "jaeger-query")]

use sentinel_core::pipeline;
use tracing::info;

use crate::render::emit_report_and_gate;
use crate::{OutputFormat, apply_acknowledgments_or_exit, grouping_keys, load_config};

#[allow(clippy::too_many_arguments)]
pub(crate) async fn cmd_jaeger_query(
    endpoint: &str,
    trace_id: Option<&str>,
    service: Option<&str>,
    lookback: &str,
    from: Option<&str>,
    to: Option<&str>,
    max_traces: usize,
    auth_header: Option<&str>,
    config_path: Option<&std::path::Path>,
    format: Option<OutputFormat>,
    ci: bool,
    acknowledgments_path: Option<&std::path::Path>,
    no_acknowledgments: bool,
    show_acknowledged: bool,
) {
    if trace_id.is_none() && service.is_none() {
        eprintln!("Error: either --trace-id or --service is required");
        std::process::exit(crate::EXIT_TOOLING_ERROR);
    }
    if trace_id.is_some() && service.is_some() {
        eprintln!("Error: --trace-id and --service are mutually exclusive");
        std::process::exit(crate::EXIT_TOOLING_ERROR);
    }

    let window = crate::resolve_search_window_or_exit(lookback, from, to);

    let config = load_config(config_path);

    let events = match sentinel_core::ingest::jaeger_query::ingest_from_jaeger_query_with_grouping(
        endpoint,
        service,
        trace_id,
        window,
        max_traces,
        auth_header,
        grouping_keys(&config),
    )
    .await
    {
        Ok(events) => events,
        Err(e) => {
            eprintln!("Error fetching traces from Jaeger query API: {e}");
            std::process::exit(crate::EXIT_TOOLING_ERROR);
        }
    };

    info!(
        events = events.len(),
        "Ingested events from Jaeger query API, running analysis"
    );

    let mut report = pipeline::analyze(events, &config);
    apply_acknowledgments_or_exit(
        &mut report,
        &config,
        acknowledgments_path,
        no_acknowledgments,
        sentinel_core::acknowledgments::ReportOrigin::FreshAnalysis,
    );
    emit_report_and_gate(&mut report, format, ci, "jaeger-query", show_acknowledged);
}