Struct deadpool_postgres::Manager

pub struct Manager {
    pub statement_caches: StatementCaches,
    // some fields omitted
}

The manager for creating and recyling postgresql connections

Fields

statement_caches: StatementCaches

This field provides access to the statement caches of clients handed out by the pool.

Implementations

impl Manager

pub fn new<T>(pg_config: Config, tls: T) -> Manager where
    T: MakeTlsConnect<Socket> + Clone + Sync + Send + 'static,
    T::Stream: Sync + Send,
    T::TlsConnect: Sync + Send,
    <T::TlsConnect as TlsConnect<Socket>>::Future: Send, 

Create manager using a tokio_postgres::Config and a TlsConnector.

pub fn from_config<T>(
    pg_config: Config,
    tls: T,
    config: ManagerConfig
) -> Manager where
    T: MakeTlsConnect<Socket> + Clone + Sync + Send + 'static,
    T::Stream: Sync + Send,
    T::TlsConnect: Sync + Send,
    <T::TlsConnect as TlsConnect<Socket>>::Future: Send, 

Create manager using a tokio_postgres::Config and a TlsConnector and deadpool_postgres::ManagerConfig.

Trait Implementations

impl Manager for Manager

type Type = ClientWrapper

Type that the manager creates and recycles.

type Error = Error

The error that the manager can return when creating and recycling objects.

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

Create a new instance of Type

fn recycle<'life0, 'life1, 'async_trait>(
    &'life0 self,
    client: &'life1 mut ClientWrapper
) -> Pin<Box<dyn Future<Output = RecycleResult<Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Try to recycle an instance of Type returning an Error if the object could not be recycled.

fn detach(&self, object: &mut ClientWrapper)

Detach an instance of Type from this manager. This method is called when using the Object::take function for removing an object from the pool. If the manager doesn’t hold any references to the handed out objects the default implementation can be used which does nothing.