Struct Worker 

pub struct Worker<T> { /* private fields */ }

Server worker.

A worker runs one service instance on its own arbiter thread. It receives items through an unbounded channel. Clones refer to the same worker.

Implementations

impl<T> Worker<T>

pub fn start<F>(name: String, cfg: F, cid: Option<CoreId>) -> Worker<T>

where T: Send + 'static, F: ServerConfiguration<Item = T>,

Starts a worker on a new arbiter thread.

Returns immediately. The worker reports Unavailable until its service is created. If cid is set, the worker thread is pinned to that core.

pub fn name(&self) -> &str

Returns the worker name.

pub fn send(&self, msg: T) -> Result<(), T>

Sends a message to the worker.

Returns Ok if the message was queued. The message is queued even if the worker is currently unavailable. Returns the message as Err if the worker has stopped.

pub fn status(&self) -> WorkerStatus

Returns the current worker status.

pub async fn wait_for_status(&mut self) -> WorkerStatus

Waits for the next worker status change and returns the new status.

Returns immediately if the worker has failed.

pub fn stop(&self, timeout: Millis) -> WorkerStop

Stops the worker.

The worker stops accepting items and shuts down its service, waiting up to timeout. A zero timeout uses the default of 3 seconds.

Trait Implementations

impl<T> Clone for Worker<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for Worker<T>

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

Formats the value using the given formatter.

impl<T> Eq for Worker<T>

impl<T> Hash for Worker<T>

fn hash<H: Hasher>(&self, state: &mut H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl<T> Ord for Worker<T>

fn cmp(&self, other: &Self) -> Ordering

This method returns an Ordering between self and other.

fn max(self, other: Self) -> Self

where Self: Sized,

Compares and returns the maximum of two values.

fn min(self, other: Self) -> Self

where Self: Sized,

Compares and returns the minimum of two values.

fn clamp(self, min: Self, max: Self) -> Self

where Self: Sized,

Restrict a value to a certain interval.

impl<T> PartialEq for Worker<T>

fn eq(&self, other: &Worker<T>) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl<T> PartialOrd for Worker<T>

fn partial_cmp(&self, other: &Self) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

fn lt(&self, other: &Rhs) -> bool

Tests less than (for self and other) and is used by the < operator.

fn le(&self, other: &Rhs) -> bool

Tests less than or equal to (for self and other) and is used by the <= operator.

fn gt(&self, other: &Rhs) -> bool

Tests greater than (for self and other) and is used by the > operator.

fn ge(&self, other: &Rhs) -> bool

Tests greater than or equal to (for self and other) and is used by the >= operator.