#redis #pool #async #await

mobc-redis

Redis support for the mobc connection pool

18 releases

0.8.2 Nov 20, 2023
0.8.0 Jan 22, 2023
0.7.0 Jan 13, 2021
0.5.4 Nov 14, 2020
0.3.0 Nov 30, 2019

#4 in #redis-pool

Download history 1213/week @ 2023-11-05 1001/week @ 2023-11-12 1232/week @ 2023-11-19 1245/week @ 2023-11-26 1299/week @ 2023-12-03 1230/week @ 2023-12-10 885/week @ 2023-12-17 548/week @ 2023-12-24 773/week @ 2023-12-31 1272/week @ 2024-01-07 1094/week @ 2024-01-14 1247/week @ 2024-01-21 1128/week @ 2024-01-28 1330/week @ 2024-02-04 1490/week @ 2024-02-11 1523/week @ 2024-02-18

5,518 downloads per month
Used in 7 crates (5 directly)

MIT/Apache

58KB
944 lines

mobc-redis

crates.io

Documentation

Example

use mobc::Pool;
use mobc_redis::redis;
use redis::AsyncCommands;
use mobc_redis::RedisConnectionManager;
use std::time::Instant;

const TEST_KEY: &'static str = "mobc::redis::test";

#[tokio::main]
async fn main() {
    let client = redis::Client::open("redis://127.0.0.1/").unwrap();
    let manager = RedisConnectionManager::new(client);
    let pool = Pool::builder().max_open(20).build(manager);

    let mut conn = pool.get().await.unwrap();
    let _: () = conn.set(TEST_KEY, "hello").await.unwrap();

    const MAX: usize = 5000;

    let now = Instant::now();
    let (tx, mut rx) = tokio::sync::mpsc::channel::<usize>(5000);
    for i in 0..MAX {
        let pool = pool.clone();
        let tx_c = tx.clone();
        tokio::spawn(async move {
            let mut conn = pool.get().await.unwrap();
            let s: String = conn.get(TEST_KEY).await.unwrap();
            assert_eq!(s.as_str(), "hello");
            tx_c.send(i).await.unwrap();
        });
    }
    for _ in 0..MAX {
        rx.recv().await.unwrap();
    }

    println!("cost: {:?}", now.elapsed());
}

Runtimes

You can use either tokio, or async-std as your async runtime.

The default is tokio-comp, but you can use async-std by setting it in the mobc-redis features.

mobc-redis = { version = "0.7", default-features = false, features = ["async-std-comp"] }

Dependencies

~8–21MB
~314K SLoC