rust-tokio-supervisor 0.1.2

A Rust tokio supervisor with declarative task supervision, restart policy, shutdown coordination, and observability.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

//! Heartbeat health tests.
//!
//! These tests verify heartbeat freshness and stale detection.

use rust_supervisor::health::heartbeat::{HealthPolicy, Heartbeat};
use rust_supervisor::id::types::ChildId;
use std::time::{Duration, Instant};

/// Verifies that heartbeat stale detection uses monotonic time.
/// Verifies stale heartbeat detection against monotonic time.
#[test]
fn stale_detection_uses_monotonic_time() {
    let policy = HealthPolicy::new(Duration::from_secs(1), Duration::from_secs(3));
    let now = Instant::now();
    let heartbeat = Heartbeat::new(ChildId::new("worker"), now, None);

    assert!(!policy.is_stale(&heartbeat, now + Duration::from_secs(3)));
    assert!(policy.is_stale(&heartbeat, now + Duration::from_secs(4)));
}