Struct QueueServiceState 

pub struct QueueServiceState { /* private fields */ }

Shared handle onto the live unserved-queue state.

Implementations

impl QueueServiceState

pub fn mark(&self, parked: Parked<'_>) -> Result<(), ServerError>

Record (or refresh) one dispatch parked on an unserved address.

Errors

Returns ServerError::LockPoisoned if the state lock is poisoned.

pub fn clear( &self, address: &ServiceAddress, workflow_id: &WorkflowId, activity_id: &ActivityId, ) -> Result<(), ServerError>

Drop one dispatch from the unserved state, dropping the address itself when nothing waits on it any more.

Errors

Returns ServerError::LockPoisoned if the state lock is poisoned.

pub fn unserved(&self) -> Result<Vec<UnservedQueue>, ServerError>

Every address currently unserved, in stable address order.

Errors

Returns ServerError::LockPoisoned if the state lock is poisoned.

pub fn parked_on_queue(&self, task_queue: &str) -> Result<usize, ServerError>

How many dispatches are currently parked across every address on task_queue, in any namespace.

Read by the worker-expiry sweep so the deregistration of a dead worker states the operational consequence in the same breath as the cause: “this worker is gone AND seven dispatches are already parked on the queue it was serving” is an alertable sentence; “worker deregistered” alone is not. Queue-scoped rather than address-scoped because a worker serves a whole queue, not one activity type on it.

Errors

Returns ServerError::LockPoisoned if the state lock is poisoned.

pub fn is_unserved( &self, workflow_id: &WorkflowId, activity_id: &ActivityId, ) -> Result<bool, ServerError>

Whether one run’s activity is currently parked on an unserved queue.

Errors

Returns ServerError::LockPoisoned if the state lock is poisoned.

Trait Implementations

impl Clone for QueueServiceState

fn clone(&self) -> QueueServiceState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueueServiceState

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

Formats the value using the given formatter.

impl Default for QueueServiceState

fn default() -> QueueServiceState

Returns the “default value” for a type.