Struct ClientConnectionManager 

pub struct ClientConnectionManager<S> { /* private fields */ }

Struct to help implementing pooling with bb8

TODO

• Move the cache out of the Client struct so we can share the cache across all connections in the pool

Implementations

impl<S: MembershipStorage + 'static> ClientConnectionManager<S>

pub fn new(members_storage: S) -> Self

pub fn pool() -> Builder<Self>

Trait Implementations

impl<S: MembershipStorage + 'static> ManageConnection for ClientConnectionManager<S>

type Connection = Client<S>

The connection type this manager deals with.

type Error = ClientError

The error type returned by Connections.

fn connect( &self, ) -> impl Future<Output = Result<Self::Connection, Self::Error>> + Send

Attempts to create a new connection.

fn is_valid( &self, _conn: &mut Self::Connection, ) -> impl Future<Output = Result<(), Self::Error>> + Send

Determines if the connection is still connected to the database.

fn has_broken(&self, _conn: &mut Self::Connection) -> bool

Synchronously determine if the connection is no longer usable, if possible.