Struct PoolCensus 

pub struct PoolCensus {
    pub workers_in_pool: usize,
    pub workers_serving_activity: usize,
    pub compatible_workers: usize,
    pub eligible_compatible_workers: usize,
    pub compatible_workers_reachability_lost: 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.

Deliberately NOT filtered by dispatch eligibility, so classify can tell an empty pool from an excluded one (#197 R3).

eligible_compatible_workers: usize

Of Self::compatible_workers, those a dispatch could actually be handed to right now — the rest are excluded by the liveness verdict.

compatible_workers_reachability_lost: usize

Of the excluded compatible workers, those excluded by DispatchExclusion::ReachabilityLost rather than by an opening probation.

🔴 The whole point of the distinction. An opening probation clears itself in seconds, so parking silently through one is correct and announcing it would be noise on every healthy connect. A lost reachability does NOT clear on its own, so a dispatch parked on one waits indefinitely — and must say so, or it is a silent stall.

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 compatible worker REGISTERED, whatever its dispatch eligibility.

A field-level fact, not a decision. It stays deliberately blind to eligibility because classify needs the blind count to tell an empty pool from an excluded one (#197 R3). Callers asking “will a dispatch aimed here actually proceed?” want Self::will_be_served.

pub const fn will_be_served(&self) -> bool

Whether a dispatch aimed here can be expected to proceed without an operator doing something first.

🔴 The distinction Self::is_served cannot draw. A pool whose workers are all serving an opening probation is not dispatchable this instant but will be within seconds, so it answers true — waiting is the correct outcome and the caller should not be warned. A pool whose workers have all LOST reachability answers false: nothing about it improves on its own, so a caller told “served” would be told a run is about to proceed when it is about to park indefinitely.

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