Struct WorkerConfigBuilder 

pub struct WorkerConfigBuilder { /* private fields */ }

Builder for WorkerConfig with auth metadata defaults and explicit required fields.

Implementations

impl WorkerConfigBuilder

pub const fn new() -> Self

Creates an empty config builder.

pub fn namespace(self, namespace: impl Into<String>) -> Self

Sets the namespace advertised in worker stream authorization metadata.

pub fn subject(self, subject: impl Into<String>) -> Self

Sets the subject advertised in worker stream authorization metadata.

pub fn endpoint(self, endpoint: impl Into<String>) -> Self

Sets the engine worker endpoint URI.

pub fn task_queue(self, task_queue: impl Into<String>) -> Self

Sets the task queue advertised to the engine.

pub fn identity(self, identity: impl Into<String>) -> Self

Sets the worker identity.

pub const fn max_concurrency(self, max_concurrency: usize) -> Self

Sets the operator-configured maximum concurrency.

pub const fn reconnect_initial_backoff(self, delay: Duration) -> Self

Sets the operator-configured initial reconnect backoff delay.

pub const fn reconnect_max_backoff(self, delay: Duration) -> Self

Sets the operator-configured reconnect backoff cap.

pub const fn reconnect_max_attempts(self, attempts: usize) -> Self

Sets the operator-configured maximum reconnect attempts.

pub fn transport_credentials(self, credentials: TransportCredentials) -> Self

Sets optional opaque transport credentials.

pub fn build(self) -> Result<WorkerConfig, WorkerConfigBuildError>

Builds a WorkerConfig when every required field has been supplied.

Errors

Returns WorkerConfigBuildError naming the missing required field.

Trait Implementations

impl Clone for WorkerConfigBuilder

fn clone(&self) -> WorkerConfigBuilder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerConfigBuilder

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

Formats the value using the given formatter.

impl Default for WorkerConfigBuilder

fn default() -> WorkerConfigBuilder

Returns the “default value” for a type.