Struct Task

pub struct Task { /* private fields */ }

Defines a worker process command.

Implementations

impl Task

pub fn new(cmd: &str) -> Self

Create a new task.

pub fn args<I, S>(self, args: I) -> Self

where I: IntoIterator<Item = S>, S: AsRef<str>,

Set command arguments.

pub fn envs<I, K, V>(self, vars: I) -> Self

where I: IntoIterator<Item = (K, V)>, K: AsRef<str>, V: AsRef<str>,

Set command environment variables.

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

Set the daemon flag for the worker command.

Daemon processes are restarted if they die without being explicitly shutdown by the supervisor.

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

Set the detached flag for the worker command.

If a worker is detached it will not connect to the IPC socket.

pub fn retry_limit(self, limit: usize) -> Self

Set the retry limit when restarting dead workers.

Only applies to tasks that have the daemon flag set; non-daemon tasks are not restarted. If this value is set to zero then it overrides the daemon flag and no attempts to restart the process are made.

The default value is 5.

pub fn retry_factor(self, factor: usize) -> Self

Set the retry factor in milliseconds.

The default value is 0 which means retry attempts are performed immediately.

Trait Implementations

impl Clone for Task

fn clone(&self) -> Task

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Task

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

Formats the value using the given formatter.