beachcomber 0.4.0

A centralized daemon that caches shell state (git, battery, hostname, etc.) so every consumer reads from one fast cache instead of independently forking shells
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

use beachcomber::scheduler::{BackoffStage, BackoffState};
use std::time::Duration;

#[test]
fn backoff_starts_in_grace() {
    let state = BackoffState::new(Duration::from_secs(30));
    assert!(matches!(state.stage(), BackoffStage::Grace));
}

#[test]
fn backoff_advances_through_stages() {
    let mut state = BackoffState::new(Duration::from_secs(0));
    state.advance();
    assert!(matches!(state.stage(), BackoffStage::SlowPoll));
    state.advance();
    assert!(matches!(state.stage(), BackoffStage::Frozen));
    state.advance();
    assert!(matches!(state.stage(), BackoffStage::Evict));
}

#[test]
fn backoff_resets() {
    let mut state = BackoffState::new(Duration::from_secs(0));
    state.advance();
    state.advance();
    state.reset(Duration::from_secs(30));
    assert!(matches!(state.stage(), BackoffStage::Grace));
}

#[test]
fn backoff_should_watch() {
    let state = BackoffState::new(Duration::from_secs(0));
    assert!(state.should_watch(), "Grace keeps watches");

    let mut state = BackoffState::new(Duration::from_secs(0));
    state.advance();
    assert!(!state.should_watch(), "SlowPoll drops watches");
}