Struct SupervisorBuilder

pub struct SupervisorBuilder { /* private fields */ }

Build a supervisor.

Implementations

impl SupervisorBuilder

pub fn new() -> Self

Create a new supervisor builder.

pub fn server<F>(self, handler: F) -> Self

where F: Fn(UnixStream, Sender<Message>) + Send + Sync + 'static,

Set the IPC server handler.

pub fn path<P: AsRef<Path>>(self, path: P) -> Self

Set the socket path.

pub fn add_worker(self, task: Task) -> Self

Add a worker process.

pub fn shutdown(self, rx: Receiver<()>) -> Self

Register a shutdown handler with the supervisor.

When a message is received on the shutdown receiver all managed processes are killed.

pub fn build(self) -> Supervisor

Return the supervisor.