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
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

//! Module-owned tests for dashboard public entry points.

use rust_supervisor::config::configurable::{
    DashboardIpcBindMode, DashboardIpcConfig, DashboardRegistrationConfig,
};
use rust_supervisor::dashboard::config::validate_dashboard_ipc_config;
use rust_supervisor::dashboard::registration::build_registration_payload;

/// Verifies that dashboard registration keeps target identity stable.
#[test]
fn dashboard_registration_payload_uses_validated_target_identity() {
    let config = DashboardIpcConfig {
        enabled: true,
        target_id: Some("orders-supervisor".to_string()),
        path: Some("/tmp/orders-supervisor.sock".into()),
        permissions: Some("0600".to_string()),
        bind_mode: Some(DashboardIpcBindMode::ReplaceStale),
        registration: Some(DashboardRegistrationConfig {
            enabled: true,
            relay_registration_path: Some("/tmp/rust-supervisor-relay/register.sock".into()),
            display_name: Some("Orders Supervisor".to_string()),
            lease_seconds: Some(30),
            registration_heartbeat_interval_seconds: Some(15),
        }),
    };

    let validated = validate_dashboard_ipc_config(Some(&config))
        .expect("validate dashboard IPC")
        .expect("enabled dashboard IPC");
    let registration = build_registration_payload(&validated).expect("build registration payload");

    assert_eq!(registration.target_id, "orders-supervisor");
    assert_eq!(registration.ipc_path, "/tmp/orders-supervisor.sock");
    assert_eq!(registration.lease_seconds, 30);
    assert!(
        registration
            .supported_commands
            .iter()
            .any(|command| command.name == "restart_child")
    );
}

/// Verifies that module-owned validation accepts an absolute IPC path.
#[test]
fn dashboard_validation_accepts_absolute_socket_paths() {
    let config = DashboardIpcConfig {
        enabled: true,
        target_id: Some("billing-supervisor".to_string()),
        path: Some("/tmp/billing-supervisor.sock".into()),
        permissions: None,
        bind_mode: None,
        registration: None,
    };

    let result = validate_dashboard_ipc_config(Some(&config));

    assert!(result.is_ok());
}