Struct ConnectionManager 

pub struct ConnectionManager { /* private fields */ }

Connection manager for Interactive Brokers clients.

Handles automatic reconnection with exponential backoff, connection monitoring, and subscription resubscription on reconnect.

Implementations

impl ConnectionManager

pub fn new(host: String, port: u16, client_id: i32, max_attempts: u32) -> Self

Create a new connection manager.

Arguments

• host - Host address
• port - Port number
• client_id - Client ID
• max_attempts - Maximum connection attempts (0 = infinite)

pub async fn connect_with_retry(&self) -> Result<Arc<Client>>

Connect to IB Gateway/TWS with automatic retry.

Returns

Returns the connected client on success.

Errors

Returns an error if connection fails after max attempts.

Panics

Panics if the mutex is poisoned.

pub fn is_connected(&self) -> bool

Check if currently connected.

pub fn mark_disconnected(&self)

Mark connection as disconnected.

Panics

Panics if the mutex is poisoned.

pub fn attempt_count(&self) -> u32

Get current attempt count.

pub fn current_backoff(&self) -> Duration

Get current backoff duration.

Panics

Panics if the mutex is poisoned.

pub fn time_since_disconnection(&self) -> Option<Duration>

Get time since last disconnection.

Panics

Panics if the mutex is poisoned.

Trait Implementations

impl Clone for ConnectionManager

fn clone(&self) -> ConnectionManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConnectionManager

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

Formats the value using the given formatter.