redis-cmd 0.1.2

An async Redis client for Rust built on redis crate.
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
37
38
39

use std::error::Error;
use redis_cmd::config::load_redis_config;

#[tokio::test]
async fn test() -> Result<(), Box<dyn Error>> {
    let c = load_redis_config("test_config.toml");
    let client = c.load_redis_pool().await?;
    let v =  client.clone().set("321", "123").await.unwrap();
    println!("{}", v);
    let result  = client.clone().get("321").await?;
    println!("{}", result);
    let ok = client.clone().exists("321").await.unwrap();
    println!("exists: {}", ok);
    let expire = client.clone().expire("321", 100).await?;
    println!("expire: {}", expire);

    let data = vec![("123", "321")];
    let ok = client.clone().xadd("rrrrr", &data.clone()).await?;
    println!("xadd: {}", ok);
    let v = client.clone().xgroup_create("rrrrr", "1234").await?;
    println!("xgroup_create: {:?}", v);

    // // let data = client.xinfo_groups("rrrrrr").await.unwrap();
    // // println!("xinfo_groups: {:?}", data);
    // let v =  client.clone().xread_group("rrrrr", "123", "32").await?;
    // println!("{:?}", v);
    // let data = client.clone().xclaim_auto("rrrrr", "123", "32", 60000).await.unwrap();
    // println!("xclaim_auto{:?}", data);
    // let data:String = client.get_id(&data).await.unwrap();
    // let data = client.clone().xack("rrrrr", "123", &vec![data] ).await.unwrap();
    // println!("xclaim_auto{:?}", data);
    // let data = client.clone().xpending_one("rrrrr", "123").await.unwrap();
    // let data:Vec<Vec<Value>> = from_redis_value(&data).unwrap();
    // let data = data.get(0).unwrap().get(0).unwrap();
    // let data:String = from_redis_value(data).unwrap();
    // println!("{:?}",  data);
    // assert_eq!(result, "123");
    Ok(())
}