Struct PoolCensus 

pub struct PoolCensus {
    pub workers_in_pool: usize,
    pub workers_serving_activity: usize,
    pub compatible_workers: usize,
    pub last_compatible_poller_age: Option<Duration>,
}

What the connected-worker registry holds for one (namespace, task_queue, activity_type[, node]) address.

Fields

workers_in_pool: usize

Workers connected for (namespace, task_queue), whatever they serve.

workers_serving_activity: usize

Of those, workers advertising this activity type.

compatible_workers: usize

Of those, workers that also satisfy the dispatch’s node pin. Equal to Self::workers_serving_activity for an unpinned dispatch.

last_compatible_poller_age: Option<Duration>

How long ago a compatible worker was last in service, or None when none has ever been seen for this address in this server’s life.

Zero while a compatible worker is connected right now.

Implementations

impl PoolCensus

pub const fn is_served(&self) -> bool

Whether the address currently has a worker that could take the dispatch.

Trait Implementations

impl Clone for PoolCensus

fn clone(&self) -> PoolCensus

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for PoolCensus

impl Debug for PoolCensus

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

Formats the value using the given formatter.

impl Default for PoolCensus

fn default() -> PoolCensus

Returns the “default value” for a type.

impl Eq for PoolCensus

impl PartialEq for PoolCensus

fn eq(&self, other: &PoolCensus) -> bool

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for PoolCensus