hyperi-rustlib 2.5.4

Opinionated Rust framework for high-throughput data pipelines at PB scale. Auto-wiring config, logging, metrics, tracing, health, and graceful shutdown — built from many years of production infrastructure experience.
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
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90

// Project:   hyperi-rustlib
// File:      src/top/config.rs
// Purpose:   TUI dashboard configuration
// Language:  Rust
//
// License:   FSL-1.1-ALv2
// Copyright: (c) 2026 HYPERI PTY LIMITED

//! Configuration for the `top` TUI dashboard.

/// Output mode for the `top` command.
#[derive(Debug, Clone, PartialEq, Eq, Default)]
pub enum TopOutputMode {
    /// Interactive TUI dashboard.
    #[default]
    Tui,
    /// Single scrape, table to stdout.
    Once,
    /// Single scrape, JSON to stdout.
    Json,
}

/// Configuration for the metrics dashboard.
#[derive(Debug, Clone)]
pub struct TopConfig {
    /// Metrics endpoint URL to poll (e.g. `http://127.0.0.1:9090/metrics`).
    pub metrics_url: String,

    /// Poll interval in seconds.
    pub interval_secs: u64,

    /// Output mode (TUI, once, or JSON).
    pub output_mode: TopOutputMode,

    /// Optional regex filter for metric names.
    pub filter: Option<String>,
}

impl Default for TopConfig {
    fn default() -> Self {
        Self {
            metrics_url: "http://127.0.0.1:9090/metrics".to_string(),
            interval_secs: 2,
            output_mode: TopOutputMode::default(),
            filter: None,
        }
    }
}

impl TopConfig {
    /// Create from CLI `TopArgs`.
    #[must_use]
    pub fn from_args(args: &crate::cli::TopArgs) -> Self {
        let output_mode = if args.json {
            TopOutputMode::Json
        } else if args.once {
            TopOutputMode::Once
        } else {
            TopOutputMode::Tui
        };

        Self {
            metrics_url: args.metrics_url.clone(),
            interval_secs: args.interval,
            output_mode,
            filter: args.filter.clone(),
        }
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn test_defaults() {
        let config = TopConfig::default();
        assert_eq!(config.metrics_url, "http://127.0.0.1:9090/metrics");
        assert_eq!(config.interval_secs, 2);
        assert_eq!(config.output_mode, TopOutputMode::Tui);
        assert!(config.filter.is_none());
    }

    #[test]
    fn test_output_mode_json_implies_once() {
        // JSON mode should be its own variant, not depend on --once
        assert_ne!(TopOutputMode::Json, TopOutputMode::Once);
        assert_ne!(TopOutputMode::Json, TopOutputMode::Tui);
    }
}