Struct WorkerConfig 

pub struct WorkerConfig {
    pub namespace: String,
    pub subject: String,
    pub endpoint: String,
    pub task_queue: 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 task queue without an explicit auth setup.

Fields

namespace: String

Namespace advertised in x-aion-namespaces worker stream metadata.

subject: String

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

endpoint: String

Engine worker endpoint URI.

task_queue: String

Task queue advertised to the engine. The current AW wire names this field namespace; this SDK maps the task queue value to that owned wire shape.

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for WorkerConfig