Struct ConnectionPool 

pub struct ConnectionPool { /* private fields */ }

Configurable pool for remote SDK connections.

Implementations

impl ConnectionPool

pub fn new( config: ConnectionPoolConfig, reconnect_config: ReconnectConfig, ) -> Result<Self, SdkError>

Creates a pool with exactly the caller-supplied connection count.

Errors

Returns SdkError if the supplied configuration is invalid.

pub const fn config(&self) -> ConnectionPoolConfig

Returns the caller-supplied pool configuration.

pub const fn max_connections(&self) -> usize

Returns the caller-supplied maximum connection count.

pub fn connection_count(&self) -> usize

Returns the number of managed connection slots.

pub fn assign_subscription( &mut self, subscription_id: SubscriptionId, ) -> Result<SubscriptionAssignment, SdkError>

Assigns a subscription to the least-loaded pooled connection.

Errors

Returns SdkError if the pool has no available connection entries.

pub fn acknowledge( &mut self, subscription_id: SubscriptionId, sequence: u64, ) -> Result<(), SdkError>

Records an acknowledged sequence for the connection that owns a subscription.

Errors

Returns SdkError when the subscription is not active in this pool.

pub fn unsubscribe( &mut self, subscription_id: SubscriptionId, ) -> Result<(), SdkError>

Removes a subscription assignment and its recovery state.

Errors

Returns SdkError when the subscription is not active in this pool.

pub fn resume_requests_for_transition( &self, event: &ConnectionEvent, ) -> Result<Vec<ResumeRequest>, SdkError>

Builds subscription resume requests for every pooled connection on reconnect.

Errors

Returns SdkError if any active subscription cannot compute a resume sequence.

pub fn connection_for_subscription( &self, subscription_id: SubscriptionId, ) -> Option<PoolConnectionId>

Returns the connection assigned to a subscription, if it is active.

pub fn subscription_count( &self, connection_id: PoolConnectionId, ) -> Result<usize, SdkError>

Returns the number of active subscriptions on a connection.

Errors

Returns SdkError if the connection identifier is not part of this pool.

pub fn recovery( &self, connection_id: PoolConnectionId, ) -> Result<&SubscriptionRecovery, SdkError>

Returns recovery state for a pooled connection.

Errors

Returns SdkError if the connection identifier is not part of this pool.

pub fn lifecycle( &self, connection_id: PoolConnectionId, ) -> Result<&ConnectionLifecycle, SdkError>

Returns lifecycle state for a pooled connection.

Errors

Returns SdkError if the connection identifier is not part of this pool.

Trait Implementations

impl Debug for ConnectionPool

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

Formats the value using the given formatter.