rust-tokio-supervisor 0.1.1

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
59
60
61
62
63
64
65

//! Source layout integration tests.
//!
//! These tests enforce the top-level directory module layout used by the crate.

use std::path::Path;

/// Returns the project root path supplied by Cargo.
fn project_root() -> &'static Path {
    Path::new(env!("CARGO_MANIFEST_DIR"))
}

/// Returns the top-level source modules owned by the crate.
fn source_modules() -> Vec<&'static str> {
    vec![
        "child_runner",
        "config",
        "control",
        "error",
        "event",
        "health",
        "id",
        "journal",
        "observe",
        "policy",
        "readiness",
        "registry",
        "runtime",
        "shutdown",
        "spec",
        "state",
        "summary",
        "task",
        "test_support",
        "tree",
    ]
}

/// Verifies that every core module uses a top-level directory module.
#[test]
fn source_layout_uses_top_level_directory_modules() {
    let root = project_root();

    assert!(root.join("src/lib.rs").is_file());
    assert!(!root.join("src/supervision").exists());
    assert!(!root.join("src/supervision_o").exists());

    for module in source_modules() {
        assert!(
            root.join("src").join(module).is_dir(),
            "missing module {module}"
        );
        assert!(
            root.join("src").join(module).join("mod.rs").is_file(),
            "missing mod.rs for {module}"
        );
        assert!(
            root.join("src").join(module).join("tests").is_dir(),
            "missing tests directory for {module}"
        );
        assert!(
            !root.join("src").join(format!("{module}.rs")).exists(),
            "flat module file is forbidden for {module}"
        );
    }
}