Struct AsyncFnFactory 

pub struct AsyncFnFactory<T> { /* private fields */ }

An AsyncConnectionFactory built from closures returning [BoxFuture]s.

Implementations

impl<T> AsyncFnFactory<T>

pub fn new<F>(create: F) -> Self

where F: Fn() -> Pin<Box<dyn Future<Output = Result<T, FactoryError>> + Send + 'static>> + Send + Sync + 'static,

Builds a factory from a create closure returning a boxed future.

pub fn with_validate<F>(self, f: F) -> Self

where F: for<'a> Fn(&'a T) -> Pin<Box<dyn Future<Output = bool> + Send + 'a>> + Send + Sync + 'static,

Sets the liveness check.

pub fn with_reset<F>(self, f: F) -> Self

where F: for<'a> Fn(&'a T) -> Pin<Box<dyn Future<Output = Result<(), FactoryError>> + Send + 'a>> + Send + Sync + 'static,

Sets the release-time reset.

pub fn with_close<F>(self, f: F) -> Self

where F: for<'a> Fn(&'a T) -> Pin<Box<dyn Future<Output = Result<(), FactoryError>> + Send + 'a>> + Send + Sync + 'static,

Sets the disposal hook.

pub fn with_is_fatal_error<F>(self, f: F) -> Self

where F: Fn(&(dyn Error + 'static)) -> bool + Send + Sync + 'static,

Sets the fatal-error classifier.

Trait Implementations

impl<T> AsyncConnectionFactory<T> for AsyncFnFactory<T>

where T: Send + Sync,

fn create(&self) -> impl Future<Output = Result<T, FactoryError>> + Send

Opens a new connection.

async fn validate(&self, conn: &T) -> bool

A cheap liveness check. Defaults to true.

async fn reset(&self, conn: &T) -> Result<(), FactoryError>

Scrubs session state on release. Defaults to a no-op.

async fn close(&self, conn: &T) -> Result<(), FactoryError>

Disposes of a connection. Defaults to a no-op.

fn is_fatal_error(&self, err: &(dyn Error + 'static)) -> bool

Whether err proves the connection is broken. Defaults to false.