Struct Supervisor 

pub struct Supervisor(pub(crate) Arc<Inner>);

The process’s supervisor. Cheap to clone; every clone reaches the same registry.

Tuple Fields

0: Arc<Inner>

Implementations

impl Supervisor

pub fn new() -> Self

Build the registry and start its driver on the current runtime.

A caller with no runtime gets a registry whose driver starts on the first Self::spawn inside one, so construction never needs a runtime of its own.

pub fn spawn<F, Fut>(&self, name: &str, policy: Policy, factory: F) -> bool

where F: Fn() -> Fut + Send + Sync + 'static, Fut: Future<Output = ()> + Send + 'static,

Register name and start its first run.

Returns true when this call started the member and false when it was already running, so a caller that must know whether its factory was adopted can read the answer. A second call while the member runs is a no-op, which is what replaces each member’s own idempotency flag. A call after a stop or a give-up starts a new run and resets the counter.

pub fn stop(&self, name: &str)

Stop name deliberately: cancel its run, abort it, and never resurrect it.

The stop names the generation it took down, so a run replaced by a fresh spawn in the same window is left alone.

pub fn forget(&self, name: &str)

Remove name from the registry, abort its run, and forget its factory. A call after a stop is what keeps a per-host member name from accumulating dead rows.

pub fn snapshot(&self) -> Vec<Member>

Every member, ordered by name.

Trait Implementations

impl Clone for Supervisor

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for Supervisor

fn default() -> Self

Returns the “default value” for a type.