Struct deadpool_tiberius::Manager

pub struct Manager { /* private fields */ }

Connection pool Manager served as Builder. Call create_pool after filling out your configs.

Implementations

impl Manager

pub fn new() -> Self

Create new ConnectionPool Manager

pub fn from_ado_string(conn_str: &str) -> SqlServerResult<Self>

Create a new ConnectionPool Manager and fills connection configs from ado string. For more details about ADO_String pleas refer to tiberius::Config::from_ado_string and Connection Strings in ADO.NET.

pub fn from_jdbc_string(conn_str: &str) -> SqlServerResult<Self>

Create new ConnectionPool Manager and fills connection config from jdbc string. For more details about jdbc_string pls refer to Building JDBC connection URL.

pub fn create_pool(self) -> Result<Pool, SqlServerError>

Consume self, builds a pool.

pub fn host(self, host: impl ToString) -> Self

Server host, defaults to localhost.

pub fn port(self, port: u16) -> Self

Server port, defaults to 1433.

pub fn database(self, database: impl ToString) -> Self

Database, defaults to master.

pub fn basic_authentication( self, username: impl ToString, password: impl ToString ) -> Self

Simplified authentication for those using username and password as login method.

pub fn authentication(self, authentication: AuthMethod) -> Self

Set tiberius::AuthMethod as authentication method.

pub fn trust_cert(self) -> Self

See tiberius::Config::trust_cert

pub fn encryption(self, encryption: EncryptionLevel) -> Self

Set tiberius::EncryptionLevel as enctryption method.

pub fn trust_cert_ca(self, path: impl ToString) -> Self

See tiberius::Config::trust_cert_ca

pub fn instance_name(self, name: impl ToString) -> Self

Instance name defined in Sql Browser, defaults to None.

pub fn application_name(self, name: impl ToString) -> Self

See tiberius::Config::application_name

pub fn max_size(self, value: usize) -> Self

Set pool size, defaults to 10.

pub fn wait_timeout<T: Into<f64> + Copy>(self, value: T) -> Self

Set timeout for when waiting for a connection object to become available.

pub fn create_timeout<T: Into<f64> + Copy>(self, value: T) -> Self

Set timeout for when creating a new connection object.

pub fn recycle_timeout<T: Into<f64> + Copy>(self, value: T) -> Self

Set timeout for when recycling a connection object.

pub fn pre_recycle_sync<T>(self, hook: T) -> Self

where T: Fn(&mut Client, &Metrics) -> HookResult<Error> + Sync + Send + 'static,

Attach a sync fn as hook to connection pool. The hook will be called each time before a connection deadpool::managed::Object is recycled.

pub fn pre_recycle_async<T>(self, hook: T) -> Self

where T: for<'a> Fn(&'a mut Client, &'a Metrics) -> HookFuture<'a, Error> + Sync + Send + 'static,

Attach an async fn as hook to connection pool. The hook will be called each time before a connection deadpool::managed::Object is recycled.

pub fn post_recycle_sync<T>(self, hook: T) -> Self

where T: Fn(&mut Client, &Metrics) -> HookResult<Error> + Sync + Send + 'static,

Attach a sync fn as hook to connection pool. The hook will be called each time af after a connection deadpool::managed::Object is recycled.

pub fn post_recycle_async<T>(self, hook: T) -> Self

where T: for<'a> Fn(&'a mut Client, &'a Metrics) -> HookFuture<'a, Error> + Sync + Send + 'static,

Attach an async fn as hook to connection pool. The hook will be called each time after a connection deadpool::managed::Object is recycled.

pub fn post_create_sync<T>(self, hook: T) -> Self

where T: Fn(&mut Client, &Metrics) -> HookResult<Error> + Sync + Send + 'static,

Attach a sync fn as hook to connection pool. The hook will be called each time after a connection deadpool::managed::Object is created.

pub fn post_create_async<T>(self, hook: T) -> Self

where T: for<'a> Fn(&'a mut Client, &'a Metrics) -> HookFuture<'a, Error> + Sync + Send + 'static,

Attach an async fn as hook to connection pool. The hook will be called each time after a connection deadpool::managed::Object is created.

Trait Implementations

impl Manager for Manager

type Type = Client<Compat<TcpStream>>

Type of Objects that this Manager creates and recycles.

type Error = Error

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

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

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

Creates a new instance of Manager::Type.

fn recycle<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, obj: &'life1 mut Self::Type, _metrics: &'life2 Metrics ) -> Pin<Box<dyn Future<Output = RecycleResult<Self::Error>> + Send + 'async_trait>>

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

Tries to recycle an instance of Manager::Type.

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

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