Struct DrainState 

pub struct DrainState { /* private fields */ }

Cloneable gate shared by transports, dispatchers, worker streams, and the shutdown coordinator.

Implementations

impl DrainState

pub fn is_draining(&self) -> bool

Return whether drain has begun and new workflow/activity starts must be rejected.

pub fn begin(&self) -> bool

Mark the server draining. Returns true for the first caller that changed the state.

pub fn ensure_accepting( &self, namespace: &str, activity_type: &str, ) -> Result<(), ServerError>

Reject a new unit of work if drain has already begun.

Errors

Returns ServerError::WorkerDispatch with a stable drain message when work is closed.

pub fn notify_activity_drained(&self)

Wake waiters after in-flight accounting may have reached zero.

Trait Implementations

impl Clone for DrainState

fn clone(&self) -> DrainState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DrainState

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

Formats the value using the given formatter.

impl Default for DrainState

fn default() -> DrainState

Returns the “default value” for a type.