vyre-driver 0.6.1

Driver layer: registry, runtime, pipeline, routing, diagnostics. Substrate-agnostic backend machinery. Part of the vyre GPU compiler.
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
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108

//! Integration test crate for the containing Vyre package.

use super::super::{PipelineCacheAudit, PipelineCacheAuditReport};

#[test]
fn empty_audit_reports_no_data_and_no_alarm() {
    let audit = PipelineCacheAudit::new();
    let report = audit.snapshot(8000);
    assert_eq!(
        report,
        PipelineCacheAuditReport {
            hits: 0,
            misses: 0,
            unknowns: 0,
            hit_rate_bps: None,
            below_alarm_threshold: false,
        }
    );
}

#[test]
fn audit_computes_hit_rate_bps_correctly() {
    let mut audit = PipelineCacheAudit::new();
    audit.observe(Some(true));
    audit.observe(Some(true));
    audit.observe(Some(true));
    audit.observe(Some(false));
    let report = audit.snapshot(0);
    assert_eq!(report.hits, 3);
    assert_eq!(report.misses, 1);
    assert_eq!(report.hit_rate_bps, Some(7500));
}

#[test]
fn audit_hit_rate_uses_widened_shared_ratio_for_saturated_counters() {
    let audit = PipelineCacheAudit {
        hits: u64::MAX,
        misses: 0,
        unknowns: 0,
    };
    let report = audit.snapshot(0);

    assert_eq!(report.hit_rate_bps, Some(10_000));
}

#[test]
fn audit_excludes_unknowns_from_rate_denominator() {
    let mut audit = PipelineCacheAudit::new();
    audit.observe(Some(true));
    audit.observe(None);
    audit.observe(None);
    audit.observe(Some(false));
    let report = audit.snapshot(0);
    assert_eq!(report.hits, 1);
    assert_eq!(report.misses, 1);
    assert_eq!(report.unknowns, 2);
    // 1/2 = 50%  -  unknowns must NOT dilute the rate.
    assert_eq!(report.hit_rate_bps, Some(5000));
}

#[test]
fn audit_alarms_when_hit_rate_below_threshold() {
    let mut audit = PipelineCacheAudit::new();
    for _ in 0..3 {
        audit.observe(Some(true));
    }
    for _ in 0..7 {
        audit.observe(Some(false));
    }
    let report = audit.snapshot(8000);
    assert_eq!(report.hit_rate_bps, Some(3000));
    assert!(report.below_alarm_threshold);
}

#[test]
fn audit_does_not_alarm_at_exactly_threshold() {
    let mut audit = PipelineCacheAudit::new();
    for _ in 0..8 {
        audit.observe(Some(true));
    }
    for _ in 0..2 {
        audit.observe(Some(false));
    }
    let report = audit.snapshot(8000);
    assert_eq!(report.hit_rate_bps, Some(8000));
    assert!(!report.below_alarm_threshold);
}

#[test]
fn audit_alarm_disabled_with_zero_threshold() {
    let mut audit = PipelineCacheAudit::new();
    for _ in 0..5 {
        audit.observe(Some(false));
    }
    let report = audit.snapshot(0);
    assert_eq!(report.hit_rate_bps, Some(0));
    assert!(!report.below_alarm_threshold);
}

#[test]
fn audit_no_alarm_when_no_data_even_with_threshold() {
    let mut audit = PipelineCacheAudit::new();
    audit.observe(None);
    audit.observe(None);
    let report = audit.snapshot(8000);
    assert_eq!(report.hit_rate_bps, None);
    assert!(!report.below_alarm_threshold);
}