Struct WorkerConfig 

pub struct WorkerConfig {
    pub namespaces: Vec<String>,
    pub subject: String,
    pub endpoint: String,
    pub task_queue: String,
    pub node: String,
    pub identity: String,
    pub max_concurrency: usize,
    pub reconnect: ReconnectConfig,
    pub transport_credentials: Option<TransportCredentials>,
}

Operator-supplied worker connection and serving configuration.

Tunable fields remain caller-supplied. Namespace authorization metadata defaults to default/worker so development workers can register against the default namespace without an explicit auth setup.

namespaces, task_queue, and node are disjoint routing dimensions. namespaces is the SET of correctness/isolation boundaries the worker is authorized for — the same set carried (comma-joined) in the x-aion-namespaces auth metadata and in the registration scope, so a worker registers into exactly the namespaces it is authorized for. task_queue is the pool/flavour selector within each namespace. node is an OPTIONAL locality affinity the worker advertises (default = machine hostname).

Fields

namespaces: Vec<String>

Set of correctness/isolation boundaries this worker registers into. Advertised both in x-aion-namespaces worker stream metadata (comma joined) and as the registration namespace set, so authorization and registration scope agree. Must be non-empty.

subject: String

Subject advertised in x-aion-subject worker stream metadata.

endpoint: String

Engine worker endpoint URI.

task_queue: String

Pool/flavour selector within each namespace, sent as the registration’s task_queue. The worker-pool address is (namespace, task_queue).

node: String

Locality affinity advertised at registration. Defaults to the machine hostname; a dispatch pinned to this node reaches this worker.

identity: String

Worker identity used by operators and future wire metadata.

max_concurrency: usize

Maximum concurrent activities this worker may serve.

reconnect: ReconnectConfig

Operator-supplied reconnect settings.

transport_credentials: Option<TransportCredentials>

Opaque credentials for the transport implementation.

Implementations

impl WorkerConfig

pub const fn builder() -> WorkerConfigBuilder

Starts an explicit builder. The caller must provide every required field before calling WorkerConfigBuilder::build.

pub fn new( endpoint: impl Into<String>, task_queue: impl Into<String>, identity: impl Into<String>, max_concurrency: usize, reconnect: ReconnectConfig, transport_credentials: Option<TransportCredentials>, ) -> Self

Creates a worker config with default authorization metadata.

Trait Implementations

impl Clone for WorkerConfig

fn clone(&self) -> WorkerConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerConfig

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

Formats the value using the given formatter.

impl Eq for WorkerConfig

impl PartialEq for WorkerConfig

fn eq(&self, other: &WorkerConfig) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for WorkerConfig