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 async fn wait_for_drain(&self)

Resolve as soon as drain has begun — Self::is_draining in awaitable form, over the same latch.

For the seam that must block on an external arrival (a worker registering) and therefore cannot re-read a flag between iterations. Waking here decides nothing on its own: the woken caller re-runs its normal loop and meets Self::ensure_accepting, which is still the only place a drain refusal is produced.

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.