redis-queue-rs 0.1.7

Redis Queue with sync and async support for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use std::env;

#[allow(dead_code)]
pub fn initialize_redis_client() -> redis::Client {
    let host = env::var("REDIS_HOST").unwrap_or("127.0.0.1".to_string());
    let port = env::var("REDIS_PORT").unwrap_or("6379".to_string());
    
    redis::Client::open(format!("redis://{}:{}", host, port)).unwrap()
}

#[allow(dead_code)]
pub fn initialize_redis() -> redis::Connection {
    initialize_redis_client().get_connection().unwrap()
}

#[allow(dead_code)]
pub async fn initialize_async_redis() -> redis::aio::MultiplexedConnection {
    initialize_redis_client()
        .get_multiplexed_async_connection()
        .await
        .unwrap()
}