Struct ActivityReachability 

pub struct ActivityReachability<'a> {
    pub registry: &'a ConnectedWorkerRegistry,
    pub declarations: &'a QueueDeclarationSource,
    pub state: &'a QueueServiceState,
}

The live fleet seams an in-flight activity’s reachability is judged against.

Exactly the three the dispatcher’s selection wait holds: the connected-worker registry (the census), the deployed queue declarations (the structural verdict), and the parked-dispatch state (whether this process is waiting).

Fields

registry: &'a ConnectedWorkerRegistry

Live connected-worker registry.

declarations: &'a QueueDeclarationSource

Deployed queue declarations.

state: &'a QueueServiceState

Live parked-dispatch state.

Implementations

impl ActivityReachability<'_>

pub fn unserved( &self, namespace: &str, workflow_id: &WorkflowId, history: &[Event], ) -> Result<Vec<UnservedActivity>, ServerError>

Every in-flight activity in history the fleet cannot currently serve.

Returns an EMPTY vector for a run whose in-flight activities all have a live compatible worker, and for a run with no in-flight activity at all.

Errors

Returns ServerError when the connected-worker registry or the parked dispatch state cannot be read. Never guesses: an unreadable fleet is reported, not rendered as “everything is fine”.