loco-rs 0.2.2

The one-person framework 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
23
24
25
26
27
28
29
30
31
32
33
34
35
36

//! # Redis Operations
//!
//! This module defines functions and operations related to the application's
//! redis interactions.
use bb8::Pool;
use sidekiq::redis_rs::cmd;

use crate::{worker::RedisConnectionManager, Result};

/// converge Redis logic
pub async fn converge(
    pool: &Pool<RedisConnectionManager>,
    config: &Option<crate::config::Redis>,
) -> Result<()> {
    if let Some(cfg) = config {
        if cfg.dangerously_flush {
            let mut conn = pool.get().await?;
            cmd("FLUSHDB")
                .query_async::<_, ()>(conn.unnamespaced_borrow_mut())
                .await?;

            return Ok(());
        }
    }

    Ok(())
}

#[cfg(feature = "with-db")]
/// Run Redis ping command
pub async fn ping(pool: &Pool<RedisConnectionManager>) -> Result<()> {
    let mut conn = pool.get().await?;
    Ok(cmd("PING")
        .query_async::<_, ()>(conn.unnamespaced_borrow_mut())
        .await?)
}