Struct FailsafeConnectionManager 

pub struct FailsafeConnectionManager<T, U>
where
    T: ManageConnection,
    U: CircuitBreaker + Send + Sync + 'static,
{ /* private fields */ }

A genric bb8::ConnectionManager wrapped in failsafe-rs

Implementations

impl<T, U> FailsafeConnectionManager<T, U>

where T: ManageConnection, U: CircuitBreaker + Send + Sync + 'static,

pub fn new( connection_manager: T, circuit_breaker: U, ) -> FailsafeConnectionManager<T, U>

Create a new FailsafeConnectionManager consuming a ConnectionManager and CircuitBreaker

Trait Implementations

impl<T, U> Clone for FailsafeConnectionManager<T, U>

where T: ManageConnection + Clone, U: CircuitBreaker + Send + Sync + 'static + Clone,

fn clone(&self) -> FailsafeConnectionManager<T, U>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T, U> ManageConnection for FailsafeConnectionManager<T, U>

where T: ManageConnection, U: CircuitBreaker + Send + Sync + 'static,

type Connection = <T as ManageConnection>::Connection

The connection type this manager deals with.

type Error = Error<<T as ManageConnection>::Error>

The error type returned by Connections.

async fn connect(&self) -> Result<Self::Connection, Self::Error>

Attempts to create a new connection.

async fn is_valid(&self, conn: &mut Self::Connection) -> Result<(), Self::Error>

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.