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.

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 plaintext Dex FlowService host:port used by the Worker.

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. The token uses Dex’s plaintext connection, so protect the network path.

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.