Struct ManagedWsConfig 

pub struct ManagedWsConfig {
    pub initial_backoff: Duration,
    pub max_backoff: Duration,
    pub max_retries: Option<u32>,
    pub channel_capacity: usize,
    pub ws_config: Option<WebsocketConfig>,
    pub idle_timeout: Duration,
    pub backoff_reset_after: Duration,
}

Configuration for managed WebSocket reconnection behavior.

Example

use bullet_rust_sdk::ManagedWsConfig;
use std::time::Duration;

let config = ManagedWsConfig::builder()
    .max_retries(10)
    .initial_backoff(Duration::from_millis(500))
    .build();

Fields

initial_backoff: Duration

Initial delay before the first reconnect attempt.

Default: 1 second

max_backoff: Duration

Maximum delay between reconnect attempts.

Default: 30 seconds

max_retries: Option<u32>

Maximum number of consecutive reconnect attempts before giving up. None means retry forever.

Default: None (infinite retries)

channel_capacity: usize

Event channel buffer size. When the buffer is full and the consumer isn’t keeping up, new events are dropped to keep the WebSocket connection alive. A warning is logged when this happens.

Default: 10_000

ws_config: Option<WebsocketConfig>

Underlying WebSocket connection config (e.g. handshake timeout).

idle_timeout: Duration

Force a reconnect if no server message arrives within this window.

Protects against zombie connections — TCP keepalives and WebSocket ping/pong keep the socket nominally alive, but the server can stop sending data without closing. Without this, the handle sits on a dead stream indefinitely.

Duration::ZERO disables the timer. Cmd-path acks (subscribe, order responses) DO count as server-pushed messages and reset the clock.

Default: 60 seconds

backoff_reset_after: Duration

How long a connection must stay up before the backoff state is considered “stable” and the next disconnect starts from initial_backoff again.

Without this, a zombie that accepts connections and immediately drops would be hammered at initial_backoff forever — the server never gets the exponential-backoff relief.

Default: 30 seconds

Implementations

impl ManagedWsConfig

pub fn builder() -> ManagedWsConfigBuilder

Create an instance of ManagedWsConfig using the builder syntax

Trait Implementations

impl Clone for ManagedWsConfig

fn clone(&self) -> ManagedWsConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ManagedWsConfig

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

Formats the value using the given formatter.

impl Default for ManagedWsConfig

fn default() -> Self

Returns the “default value” for a type.