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

//! Supervisor specification tests.
//!
//! These tests verify child and supervisor declaration validation.

use rust_supervisor::id::types::ChildId;
use rust_supervisor::spec::child::{ChildSpec, TaskKind};
use rust_supervisor::spec::supervisor::SupervisorSpec;
use rust_supervisor::task::factory::{TaskResult, service_fn};
use std::sync::Arc;

/// Verifies worker child specification field validation.
#[test]
fn child_spec_validates_worker_fields() {
    let factory = service_fn(|_ctx| async { TaskResult::Succeeded });
    let spec = ChildSpec::worker(
        ChildId::new("worker"),
        "worker",
        TaskKind::AsyncWorker,
        Arc::new(factory),
    );

    assert!(spec.validate().is_ok());
}

/// Verifies supervisor specification validation for child declarations.
#[test]
fn supervisor_spec_validates_children() {
    let spec = SupervisorSpec::root(Vec::new());

    assert!(spec.validate().is_ok());
}