Struct WorkerHandle 

pub struct WorkerHandle { /* private fields */ }

Cloneable handle for a registered worker stream.

A worker serves a SET of namespaces under a single task_queue, so it is indexed under one (namespace, task_queue, activity_type) key per namespace in its set. node is an OPTIONAL locality affinity (a locality, not a process — many handles may share a node id) used as a within-pool filter at selection time; None means the worker advertised no locality.

Implementations

impl WorkerHandle

pub const fn id(&self) -> WorkerId

Worker identifier assigned by this server process.

pub const fn namespaces(&self) -> &BTreeSet<String>

Namespaces authorized for this worker stream. The worker is reachable for a dispatch only when its set includes the workflow’s namespace.

pub fn identity(&self) -> &str

The identity string this worker registered under, exactly as the registration frame carried it (empty when the worker sent none).

pub fn task_queue(&self) -> &str

Task queue (pool/flavour) this worker serves within each namespace.

pub fn node(&self) -> Option<&str>

Optional locality affinity this worker advertised. None means the worker carries no node and is reachable only for unpinned dispatches.

pub fn activity_types(&self) -> &BTreeSet<String>

Activity types advertised by this worker.

pub const fn instance(&self) -> Option<&WorkerInstanceIdentity>

Optional durable deployment/instance association supplied at registration.

pub const fn max_concurrency(&self) -> Option<NonZeroU32>

How many activities this worker runs AT ONCE, as it advertised, or None while it has registered but not yet said.

A dispatch PRECONDITION, read by [eligible_candidates_in_rotation]: a worker holding this many in-flight activities is passed over rather than pushed past its own admission. Pushing past it is what produced a worker that stopped reading its stream, answered no pings, and was then deregistered as lost while it was in fact working.

None is reachable only on the liminal transport, whose published registration frame has no capacity field, and only for the one round trip between that registration and the worker’s capacity announcement. It means UNKNOWN, never unlimited: selection treats an unknown capacity as full, because the alternative is to invent a number for a process that is about to state its own.

pub fn is_connected(&self) -> bool

Whether the server still holds an OPEN push channel to this worker.

The explicit connected fact, as opposed to the absence of noise. Silence alone cannot tell a worker that is gone from one that is busy, and the expiry sweep used to read the second as the first; this is the third input that separates them.

gRPC answers from the stream sender itself — a closed receiver means the tonic task that owned the stream is gone. Liminal answers from its connection: the transport holds a live push connection or it does not.

pub const fn delivery(&self) -> &WorkerDelivery

The transport this worker is delivered to through.

pub const fn intervention_capabilities(&self) -> &InterventionCapabilities

The neutral intervention primitives this worker’s harness advertises (NOI-6).

The intervention router gates on this set and never routes an unadvertised primitive. Empty (the default for a plain activity worker) means the worker is observability-only: the router refuses every intervention command for it.

pub fn sender(&self) -> Option<&WorkerTaskSender>

gRPC stream sender used by the gRPC dispatch path to push work, or None when this worker is delivered to over a non-gRPC transport (liminal).

The gRPC dispatch path registers every worker with a WorkerDelivery::Grpc delivery, so this is always Some for a gRPC-registered worker — the behaviour the path relied on before delivery became transport-agnostic.

Trait Implementations

impl Clone for WorkerHandle

fn clone(&self) -> WorkerHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerHandle

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

Formats the value using the given formatter.