Struct AsyncDieselConnectionManager

pub struct AsyncDieselConnectionManager<C> { /* private fields */ }

Available on crate feature pool only.

An connection manager for use with diesel-async.

See the concrete pool implementations for examples:

• deadpool
• bb8
• mobc

Implementations

impl<C> AsyncDieselConnectionManager<C>

where C: AsyncConnection + 'static,

pub fn new(connection_url: impl Into<String>) -> Self

where C: AsyncConnection + 'static,

Returns a new connection manager, which establishes connections to the given database URL.

pub fn new_with_config( connection_url: impl Into<String>, manager_config: ManagerConfig<C>, ) -> Self

Returns a new connection manager, which establishes connections with the given database URL and that uses the specified configuration

Trait Implementations

impl<C> Debug for AsyncDieselConnectionManager<C>

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

Formats the value using the given formatter.

impl<C> ManageConnection for AsyncDieselConnectionManager<C>

where C: PoolableConnection + 'static, select<AsExprOf<i32, Integer>>: ExecuteDsl<C>, SqlQuery: QueryFragment<C::Backend>,

Available on crate feature bb8 only.

type Connection = C

The connection type this manager deals with.

type Error = PoolError

The error type returned by Connections.

fn connect<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Self::Connection, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Attempts to create a new connection.

fn is_valid<'life0, 'life1, 'async_trait>( &'life0 self, conn: &'life1 mut Self::Connection, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

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.

impl<C> Manager for AsyncDieselConnectionManager<C>

where C: PoolableConnection + Send + 'static, select<AsExprOf<i32, Integer>>: ExecuteDsl<C>, SqlQuery: QueryFragment<C::Backend>,

Available on crate feature deadpool only.

type Type = C

Type of Objects that this Manager creates and recycles.

type Error = PoolError

Error that this Manager can return when creating and/or recycling Objects.

async fn create(&self) -> Result<Self::Type, Self::Error>

Creates a new instance of Manager::Type.

async fn recycle( &self, obj: &mut Self::Type, _: &Metrics, ) -> RecycleResult<Self::Error>

Tries to recycle an instance of Manager::Type.

fn detach(&self, _obj: &mut Self::Type)

Detaches an instance of Manager::Type from this Manager.

impl<C> Manager for AsyncDieselConnectionManager<C>

where C: PoolableConnection + 'static, select<AsExprOf<i32, Integer>>: ExecuteDsl<C>, SqlQuery: QueryFragment<C::Backend>,

Available on crate feature mobc only.

type Connection = C

The connection type this manager deals with.

type Error = PoolError

The error type returned by Connections.

fn connect<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Self::Connection, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Attempts to create a new connection.

fn check<'life0, 'async_trait>( &'life0 self, conn: Self::Connection, ) -> Pin<Box<dyn Future<Output = Result<Self::Connection, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Determines if the connection is still connected to the database when check-out.

fn spawn_task<T>(&self, task: T)

where T: Future + Send + 'static, <T as Future>::Output: Send + 'static,

Spawns a new asynchronous task.

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

Quickly determines a connection is still valid when check-in.