hyprstream 0.1.0-alpha-6

High-performance metrics storage and query service using Arrow Flight SQL
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

use hyprstream_core::aggregation::TimeWindow;
use std::time::Duration;

#[test]
fn test_window_bounds_none() {
    let window = TimeWindow::None;
    let timestamp = 1000;
    let (start, end) = window.window_bounds(timestamp);
    assert_eq!(start, i64::MIN);
    assert_eq!(end, i64::MAX);
}

#[test]
fn test_window_bounds_fixed() {
    let window = TimeWindow::Fixed(Duration::from_secs(60)); // 1 minute window
    let timestamp = 100; // Should round down to nearest minute
    let (start, end) = window.window_bounds(timestamp);
    assert_eq!(start, 60); // Rounds down to nearest 60
    assert_eq!(end, 120); // Next window boundary
}

#[test]
fn test_window_bounds_sliding() {
    let window = TimeWindow::Sliding {
        window: Duration::from_secs(300), // 5 minute window
        slide: Duration::from_secs(60),   // 1 minute slide
    };
    let timestamp = 100;
    let (start, end) = window.window_bounds(timestamp);
    assert_eq!(start, 60);  // Rounds down to nearest slide
    assert_eq!(end, 360);   // Window size (300) added to start
}

#[test]
fn test_window_sql_generation() {
    // Test None window
    let window = TimeWindow::None;
    assert!(window.to_sql().is_none());

    // Test Fixed window
    let window = TimeWindow::Fixed(Duration::from_secs(60));
    let sql = window.to_sql().unwrap();
    assert!(sql.contains("timestamp / 60"));
    assert!(sql.contains("window_start"));
    assert!(sql.contains("window_end"));

    // Test Sliding window
    let window = TimeWindow::Sliding {
        window: Duration::from_secs(300),
        slide: Duration::from_secs(60),
    };
    let sql = window.to_sql().unwrap();
    assert!(sql.contains("timestamp / 60"));
    assert!(sql.contains("window_start"));
    assert!(sql.contains("window_end"));
    assert!(sql.contains("300")); // Window size
}