chainmq 1.1.1

A Redis-backed, type-safe job queue for Rust. Provides job registration and execution, delayed jobs, retries with backoff, and scalable workers.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

use std::time::Duration;

use redis::{
    Client,
    aio::{ConnectionManager, ConnectionManagerConfig},
};

use crate::Result;

#[derive(Debug, Clone)]
pub enum RedisClient {
    Url(String),
    Manager(ConnectionManager),
    Client(Client),
}

impl RedisClient {
    pub async fn build_connection_manager_from_url(url: &str) -> Result<ConnectionManager> {
        let client = Client::open(url)?;
        Self::build_connection_manager_from_client(client).await
    }

    pub async fn build_connection_manager_from_client(client: Client) -> Result<ConnectionManager> {
        let redis_cm_config = ConnectionManagerConfig::new()
            .set_connection_timeout(Some(Duration::from_secs(10)))
            .set_response_timeout(Some(Duration::from_secs(5)));
        Ok(ConnectionManager::new_with_config(client, redis_cm_config).await?)
    }
}