Struct ConnectionManager 

pub struct ConnectionManager { /* private fields */ }

Central orchestrator for connection lifecycle management.

Wraps ClientConfig, EndpointList, ReconnectConfig, AtomicConnectionState and ConnectionHealth.

Implementations

impl ConnectionManager

pub fn new( config: ClientConfig, endpoints: EndpointList, reconnect_config: ReconnectConfig, ) -> Self

Create a new manager from config and endpoints.

pub fn with_primary(config: ClientConfig) -> Self

Convenience: create with a single primary endpoint.

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

Set the health-check interval.

pub fn on_state_change<F>(&self, f: F)

where F: Fn(ConnectionState, ConnectionState) + Send + Sync + 'static,

Set a state-change callback.

pub fn state(&self) -> ConnectionState

Current connection state (lock-free).

pub fn health(&self) -> ConnectionHealth

Snapshot of connection health.

pub fn active_endpoint(&self) -> Option<String>

URL of the currently active endpoint, if any.

pub fn endpoints(&self) -> EndpointList

Reference to endpoint list (read-locked).

pub fn config(&self) -> &ClientConfig

Client config reference.

pub async fn connect(&self) -> Result<()>

Initiate a connection attempt.

Walks the endpoint list in priority order. On the first success the state transitions to Connected. If all endpoints fail, the state moves to Failed.

pub fn disconnect(&self)

Cleanly disconnect and reset state.

pub async fn failover(&self) -> Result<String>

Manually trigger a failover to the next endpoint.

pub fn enable_auto_reconnect(&self)

Enable automatic reconnection.

pub fn disable_auto_reconnect(&self)

Disable automatic reconnection.

pub fn is_auto_reconnect_enabled(&self) -> bool

Whether auto-reconnect is currently enabled.

pub async fn reconnect_loop(&self) -> Result<()>

Run the reconnection loop (usually spawned as a background task). Tries endpoints with exponential backoff until success or max_attempts is exhausted.

pub async fn check_health(&self) -> Result<()>

Run a single health check against the active endpoint.

Trait Implementations

impl Drop for ConnectionManager

fn drop(&mut self)

Executes the destructor for this type.