Struct Worker

pub struct Worker<H, F>
where
    H: Fn(UnixStream, String) -> F,
    F: Future<Output = Result<()>>,
{ /* private fields */ }

Worker process handler.

Implementations

impl<H, F> Worker<H, F>

where H: Fn(UnixStream, String) -> F, F: Future<Output = Result<()>>,

pub fn new() -> Self

Create a new worker.

pub fn relaxed(self, flag: bool) -> Self

Set the relaxed flag.

When a worker is relaxed it will start with or without a supervisor.

The default is false so workers expect to be run in the context of a supervisor and it is an error if no worker id is available in the environment.

When this flag is enabled and the required environment variables do not exist the worker does not attempt to connect to a supervisor.

Use this mode of operation when a worker process can be run standalone or as a worker for a supervisor process.

pub fn client(self, handler: H) -> Self

Set a client connection handler.

The handler function receives the socket stream and opaque worker identifier and can communicate with the supervisor using the socket stream.

pub async fn run(&self) -> Result<()>

Start this worker running.