pub struct WorkerRegistration {
pub namespaces: Vec<String>,
pub task_queue: String,
pub node: Option<String>,
pub activity_types: Vec<String>,
pub identity: String,
pub activities: Vec<WorkerActivityDescriptor>,
}Expand description
Self-describing worker registration carried by Frame::WorkerRegister.
A worker announces the routing dimensions it serves plus a stable identity so
the server can associate the worker with its connection and the application can
route work to it. node is optional locality (the routing model treats node as
an optional dimension); the codec encodes it with a presence byte rather than
flattening None to an empty string.
Fields§
§namespaces: Vec<String>Further subjects this worker declares it serves, each decided as serve
at registration and checked against a site’s declared subjects in its trial.
These declarations confer no prefix grant over task_queue.
task_queue: StringThe exact subject routed to this worker, decided as serve before the
namespaces at registration and bound unchanged for each routed reply.
node: Option<String>Optional node locality; None when the worker declares no node affinity.
activity_types: Vec<String>Activity types this worker can execute.
identity: StringStable worker identity.
activities: Vec<WorkerActivityDescriptor>Typed action descriptors; empty identifies a pre-contract worker.