Struct Options 

pub struct Options { /* private fields */ }

Heartbeat, retry, timeout, buffering, and telemetry settings.

Implementations

impl Options

pub fn heartbeat_interval(self, interval: Duration) -> Self

Sets how often the connected driver sends automatic heartbeats.

pub fn heartbeat_timeout(self, timeout: Duration) -> Self

Sets how long an automatic heartbeat acknowledgement may take.

pub fn connect_timeout(self, timeout: Duration) -> Self

Sets the maximum duration of one transport connection attempt.

pub fn request_timeout(self, timeout: Duration) -> Self

Sets the join, call, and leave timeout to one common value.

pub fn join_timeout(self, timeout: Duration) -> Self

Sets the default channel join timeout.

pub fn call_timeout(self, timeout: Duration) -> Self

Sets the default correlated call timeout.

pub fn leave_timeout(self, timeout: Duration) -> Self

Sets the default channel leave timeout.

pub fn reconnect_delay(self, delay: impl Fn(u32) -> Duration + 'static) -> Self

Sets the delay function used by the default reconnect policy.

pub fn reconnect_policy( self, policy: impl Fn(ReconnectContext) -> ReconnectAction + 'static, ) -> Self

Installs a policy that classifies every disconnect and selects a retry.

pub fn rejoin_delay(self, delay: impl Fn(u32) -> Duration + 'static) -> Self

Sets the delay before each automatic channel rejoin attempt.

pub fn command_capacity(self, capacity: usize) -> Self

Sets the bounded capacity of the driver command queue.

pub fn push_buffer_capacity(self, capacity: usize) -> Self

Sets how many calls may wait for a socket connection or channel join.

pub fn event_capacity(self, capacity: usize) -> Self

Sets the capacity of each socket or channel event subscriber.

pub fn connect_on_start(self, enabled: bool) -> Self

Selects whether the driver connects immediately when it starts.

pub fn telemetry(self, hook: TelemetryHook) -> Self

Installs a callback for structured client telemetry.

Trait Implementations

impl Clone for Options

fn clone(&self) -> Options

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for Options

fn default() -> Self

Returns the “default value” for a type.