Struct WorkerOptions 

pub struct WorkerOptions { /* private fields */ }

Configures a pull crate::Worker and its outbound Dex connection.

Defaults connect to Dex at 127.0.0.1:8801, use PullWorkerOptions::default, and allow two minutes for Attribute-index synchronization. Workers need only an outbound connection. Changed in 1.25.0: every Worker uses pull mode; no listener or Worker target is configured.

Implementations

impl WorkerOptions

pub fn new() -> Self

Creates Worker options with local development defaults.

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

Sets the Dex FlowService address used by the Worker.

With TLS, accepts host:port, dns:///host:port, or dns://authority/host:port.

pub fn flow_service_tls(self, value: FlowServiceTlsOptions) -> Self

Enables TLS for every outbound Worker FlowService connection.

Omitted by default, preserving plaintext gRPC. Takes ownership of value and returns these options with TLS enabled. crate::Worker::try_new validates the address, additional roots, and server name, returning crate::SdkError::InvalidArgument for invalid input. See FlowServiceTlsOptions for defaults and a complete example.

pub fn credential(self, value: Arc<dyn Credential>) -> Self

Sends a bearer token on FlowService calls and pull Worker task streams.

The default sends no authorization metadata. The credential may be called concurrently; errors fail calls locally. Pull streams evaluate it at opening and again on reconnect. Enable Self::flow_service_tls to protect the token on the network.

pub fn pull(self, value: PullWorkerOptions) -> Self

Configures pull capacity, queue registration, and graceful shutdown.

Every Worker uses pull; this builder overrides PullWorkerOptions::default. Takes ownership of value and returns these Worker options with its settings applied. crate::Worker::try_new validates capacity, identity, and timeout settings. See PullWorkerOptions for defaults and a complete Worker and Client example.

pub fn attribute_index_sync_timeout(self, value: Duration) -> Self

Sets the startup Indexed Attribute synchronization deadline.

The default is two minutes. Worker::try_new rejects Duration::ZERO.

Trait Implementations

impl Clone for WorkerOptions

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerOptions

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

Formats the value using the given formatter.

impl Default for WorkerOptions

fn default() -> Self

Returns the “default value” for a type.