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 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.