[−][src]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
Pool | A generic connection pool. |
PooledConnection | A smart pointer wrapping a connection. |
State | Information about the state of a |
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 |