Crate mobc

A generic connection pool, but async/await.

Opening a new database connection every time one is needed is both inefficient and can lead to resource exhaustion under high traffic conditions. A connection pool maintains a set of open connections to a database, handing them out for repeated use.

mobc is agnostic to the connection type it is managing. Implementors of the ManageConnection trait provide the database-specific logic to create and check the health of connections.

Example

Using an imaginary "foodb" database.

use tokio;

extern crate mobc;
extern crate mobc_foodb;

#[tokio::main]
async fn main() {
    let manager = mobc_foodb::FooConnectionManager::new("localhost:1234");
    let pool = mobc::Pool::builder()
        .max_size(15)
        .build(manager)
        .await
        .unwrap();

    for _ in 0..20 {
        let pool = pool.clone();
        tokio::spawn(async {
            let conn = pool.get().await.unwrap();
            // use the connection
            // it will be returned to the pool when it falls out of scope.
        });
    }
}

Re-exports

pub use futures;

Structs

DefaultExecutor	Executes futures on the default executor for the current execution context.
Pool	A generic connection pool.
PooledConnection	A smart pointer wrapping a connection.
State	Information about the state of a Pool.

Enums

Error

The error type returned by methods in this crate.

Traits

ConnectionManager	A trait which provides connection-specific functionality.
Executor	A value that executes futures. see tokio::Executor

Type Definitions

AnyFuture

Future alias