Struct ChildSpec 

pub struct ChildSpec {
    pub name: String,
    pub function: u32,
    pub args: Vec<Value>,
    pub restart: RestartPolicy,
}

A child the supervisor should start (and possibly restart).

function is an index into the runtime’s chunk — the same number super::runtime::Runtime::spawn takes. Args are cloned on every restart so a child always comes back with the original call.

Fields

name: String

function: u32

args: Vec<Value>

restart: RestartPolicy

Implementations

impl ChildSpec

pub fn new(name: impl Into<String>, function: u32) -> Self

Examples found in repository

examples/crash_and_restart.rs (line 47)

fn main() {
    let rt = match Runtime::with_config(
        samples::boom(),
        RuntimeConfig {
            workers: 1,
            quantum: 1_000,
            mailbox: byteflow::MailboxConfig::DEFAULT,
        },
    ) {
        Ok(rt) => rt,
        Err(e) => {
            eprintln!("runtime: {e}");
            std::process::exit(1);
        }
    };
    let Some(boom) = rt.function_index("boom") else {
        eprintln!("missing boom");
        std::process::exit(1);
    };
    let sup = match Supervisor::with_config(
        rt.spawner(),
        SupervisorConfig {
            max_restarts: 2,
            max_period: Duration::from_secs(5),
        },
    ) {
        Ok(s) => s,
        Err(e) => {
            eprintln!("supervisor: {e}");
            std::process::exit(1);
        }
    };
    if let Err(e) = sup.start_child(ChildSpec::new("boom", boom).restart(RestartPolicy::OnFailure))
    {
        eprintln!("start_child: {e}");
        std::process::exit(1);
    }

    let start = std::time::Instant::now();
    while !sup.intensity_exceeded() {
        if start.elapsed() > Duration::from_secs(2) {
            eprintln!("supervisor did not hit intensity in time");
            std::process::exit(1);
        }
        thread::sleep(Duration::from_millis(5));
    }

    let metrics = rt.metrics();
    println!("intensity exceeded after {} failures", metrics.processes_failed);
    println!("{metrics}");
    sup.shutdown();
    rt.shutdown();
}

pub fn args(self, args: Vec<Value>) -> Self

pub fn restart(self, restart: RestartPolicy) -> Self

Examples found in repository

examples/crash_and_restart.rs (line 47)

fn main() {
    let rt = match Runtime::with_config(
        samples::boom(),
        RuntimeConfig {
            workers: 1,
            quantum: 1_000,
            mailbox: byteflow::MailboxConfig::DEFAULT,
        },
    ) {
        Ok(rt) => rt,
        Err(e) => {
            eprintln!("runtime: {e}");
            std::process::exit(1);
        }
    };
    let Some(boom) = rt.function_index("boom") else {
        eprintln!("missing boom");
        std::process::exit(1);
    };
    let sup = match Supervisor::with_config(
        rt.spawner(),
        SupervisorConfig {
            max_restarts: 2,
            max_period: Duration::from_secs(5),
        },
    ) {
        Ok(s) => s,
        Err(e) => {
            eprintln!("supervisor: {e}");
            std::process::exit(1);
        }
    };
    if let Err(e) = sup.start_child(ChildSpec::new("boom", boom).restart(RestartPolicy::OnFailure))
    {
        eprintln!("start_child: {e}");
        std::process::exit(1);
    }

    let start = std::time::Instant::now();
    while !sup.intensity_exceeded() {
        if start.elapsed() > Duration::from_secs(2) {
            eprintln!("supervisor did not hit intensity in time");
            std::process::exit(1);
        }
        thread::sleep(Duration::from_millis(5));
    }

    let metrics = rt.metrics();
    println!("intensity exceeded after {} failures", metrics.processes_failed);
    println!("{metrics}");
    sup.shutdown();
    rt.shutdown();
}

Trait Implementations

impl Clone for ChildSpec

fn clone(&self) -> ChildSpec

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ChildSpec

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.