laminar-core 0.26.0

Core streaming engine for LaminarDB - operators, checkpoint barriers, and streaming primitives
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
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

//! Tiny duration-string parser shared by connector configs.
//!
//! Accepts `"5"` (bare seconds), `"100ms"`, `"5s"`, `"10m"`, `"2h"`,
//! `"1d"`. Whitespace is trimmed. Multi-unit strings (`"1h30m"`) are
//! not supported — config files use one unit at a time.

use std::time::Duration;

/// Parses a config duration string. Returns `None` on malformed input.
///
/// See the module docs for the accepted grammar.
#[must_use]
pub fn parse_duration_str(s: &str) -> Option<Duration> {
    let s = s.trim();
    if s.is_empty() {
        return None;
    }

    // Longest suffixes first so "ms" doesn't get eaten by "s".
    for (suffix, scale_secs) in [("ms", 0u64), ("s", 1), ("m", 60), ("h", 3600), ("d", 86400)] {
        if let Some(head) = s.strip_suffix(suffix) {
            let n: u64 = head.trim().parse().ok()?;
            return Some(if suffix == "ms" {
                Duration::from_millis(n)
            } else {
                Duration::from_secs(n.checked_mul(scale_secs)?)
            });
        }
    }

    // Bare number: seconds.
    s.parse::<u64>().ok().map(Duration::from_secs)
}

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

    #[test]
    fn bare_seconds() {
        assert_eq!(parse_duration_str("5"), Some(Duration::from_secs(5)));
        assert_eq!(parse_duration_str(" 42 "), Some(Duration::from_secs(42)));
    }

    #[test]
    fn suffixed() {
        assert_eq!(
            parse_duration_str("250ms"),
            Some(Duration::from_millis(250))
        );
        assert_eq!(parse_duration_str("5s"), Some(Duration::from_secs(5)));
        assert_eq!(parse_duration_str("10m"), Some(Duration::from_secs(600)));
        assert_eq!(parse_duration_str("2h"), Some(Duration::from_secs(7200)));
        assert_eq!(parse_duration_str("1d"), Some(Duration::from_secs(86_400)));
    }

    #[test]
    fn malformed() {
        assert_eq!(parse_duration_str(""), None);
        assert_eq!(parse_duration_str("abc"), None);
        assert_eq!(parse_duration_str("5x"), None);
        assert_eq!(parse_duration_str("ms"), None);
    }
}