rom-core 0.1.0

Core monitoring library for ROM
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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81

use std::time::SystemTime;

use rom_core::{
  cache::{BuildReportCache, format_utc_time, parse_utc_time},
  state::BuildReport,
};

#[test]
fn test_calculate_median_odd() {
  let reports = vec![
    BuildReport {
      derivation_name: "test".to_string(),
      platform:        "x86_64-linux".to_string(),
      duration_secs:   10.0,
      completed_at:    SystemTime::UNIX_EPOCH,
      host:            "localhost".to_string(),
      success:         true,
    },
    BuildReport {
      derivation_name: "test".to_string(),
      platform:        "x86_64-linux".to_string(),
      duration_secs:   20.0,
      completed_at:    SystemTime::UNIX_EPOCH,
      host:            "localhost".to_string(),
      success:         true,
    },
    BuildReport {
      derivation_name: "test".to_string(),
      platform:        "x86_64-linux".to_string(),
      duration_secs:   30.0,
      completed_at:    SystemTime::UNIX_EPOCH,
      host:            "localhost".to_string(),
      success:         true,
    },
  ];

  assert_eq!(BuildReportCache::calculate_median(&reports), Some(20));
}

#[test]
fn test_calculate_median_even() {
  let reports = vec![
    BuildReport {
      derivation_name: "test".to_string(),
      platform:        "x86_64-linux".to_string(),
      duration_secs:   10.0,
      completed_at:    SystemTime::UNIX_EPOCH,
      host:            "localhost".to_string(),
      success:         true,
    },
    BuildReport {
      derivation_name: "test".to_string(),
      platform:        "x86_64-linux".to_string(),
      duration_secs:   20.0,
      completed_at:    SystemTime::UNIX_EPOCH,
      host:            "localhost".to_string(),
      success:         true,
    },
  ];

  assert_eq!(BuildReportCache::calculate_median(&reports), Some(15));
}

#[test]
fn test_calculate_median_empty() {
  let reports = vec![];
  assert_eq!(BuildReportCache::calculate_median(&reports), None);
}

#[test]
fn test_format_parse_utc_time() {
  let time = SystemTime::UNIX_EPOCH + std::time::Duration::from_secs(1_000_000);
  let formatted = format_utc_time(time);
  let parsed = parse_utc_time(&formatted).unwrap();

  let diff = parsed
    .duration_since(time)
    .unwrap_or_else(|e| e.duration())
    .as_secs();
  assert_eq!(diff, 0);
}