osproxy-etcd 1.0.2

Reference distributed DirectiveStore backed by etcd v3: a watch-fed, locally-cached fleet directive set.
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

//! Unit tests for the snapshot-application logic, the fail-safe "keep last good"
//! rule and the cheap `load`. The watch/connect path is exercised by the
//! Docker-gated `tests/etcd_live.rs` integration test.

use super::*;

use osproxy_core::ManualClock;

const GOOD: &[u8] = br#"{"directives":[{"id":"a","level":"Shape","ttl_secs":600}]}"#;

#[test]
fn a_valid_value_is_applied_and_load_reflects_it() {
    let clock = ManualClock::new();
    let current = Arc::new(ArcSwap::from_pointee(DirectiveSet::new()));
    let store = EtcdDirectiveStore {
        current: Arc::clone(&current),
    };
    assert_eq!(store.load().len(), 0, "starts empty");

    apply_value(&current, GOOD, &clock);
    assert_eq!(store.load().len(), 1, "the published set is now live");
}

#[test]
fn a_malformed_value_keeps_the_last_good_snapshot() {
    // A bad publish must never blank fleet diagnostics, the previous set stays.
    let clock = ManualClock::new();
    let current = Arc::new(ArcSwap::from_pointee(DirectiveSet::new()));
    apply_value(&current, GOOD, &clock);

    apply_value(&current, b"not json", &clock);
    let store = EtcdDirectiveStore {
        current: Arc::clone(&current),
    };
    assert_eq!(
        store.load().len(),
        1,
        "the malformed update was rejected, last-good kept"
    );

    // A fail-closed field (typo'd target) is also rejected wholesale.
    apply_value(
        &current,
        br#"{"directives":[{"id":"b","level":"Shape","ttl_secs":60,"tennant":"acme"}]}"#,
        &clock,
    );
    assert_eq!(
        store.load().len(),
        1,
        "an unknown-key publish is rejected too"
    );
}