novax_redis_async/
lib.rs

1use std::collections::HashMap;
2use redis::streams::{StreamClaimOptions,StreamClaimReply};
3use redis::{Connection, Cmd, Commands,RedisResult, Pipeline};
4use redis::Value;
5use redis::aio::ConnectionManager;
6
7type RedisErr = redis::RedisError;
8
9pub struct RedisConn {
10    port:   i16,
11    user:   String,
12    pwd:    String,
13    host:   String
14}
15
16pub async fn redis(cn: RedisConn) -> Result<ConnectionManager, RedisErr> {
17    let redis_client = redis::Client::open(
18        &format!("redis://{}:{}@{}:{}/", 
19            cn.user, cn.pwd,
20            cn.host, cn.port)[..]
21    )?;
22    let cn_mgr = ConnectionManager::new(redis_client).await?;
23    Ok(cn_mgr)
24}
25
26
27#[cfg(test)]
28mod tests {
29    use super::*;
30
31   
32}
novax_redis_async/lib.rs

novax_redis_async/
lib.rs
