Struct ConnectionManager 

pub struct ConnectionManager { /* private fields */ }

Main connection manager that orchestrates reconnection, heartbeat, and subscription management

Implementations

impl ConnectionManager

pub fn new( client: Weak<Mutex<LightstreamerClient>>, reconnection_config: ReconnectionConfig, heartbeat_config: HeartbeatConfig, ) -> Arc<Self>

Creates a new connection manager

pub async fn start_monitoring(&self)

Starts the connection monitoring tasks

pub async fn handle_disconnection(&self, reason: DisconnectionReason)

Handles disconnection and triggers reconnection if needed

pub async fn get_connection_state(&self) -> ConnectionState

Gets the current connection state

pub async fn get_metrics(&self) -> ConnectionMetrics

Gets connection metrics

pub async fn force_reconnect(&self) -> Result<(), ReconnectionError>

Forces a reconnection attempt

pub async fn shutdown(&self)

Shuts down the connection manager

Trait Implementations

impl Debug for ConnectionManager

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

Formats the value using the given formatter.