darkredis 0.8.0

Async Redis client using std::future
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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57

use darkredis::Connection;

async fn add_comments(mut connection: Connection, post: usize, comments: Vec<&str>) {
    let key = format!("posts.{}.comments", post);
    connection.rpush_slice(&key, &comments).await.unwrap();
}

async fn add_post(mut connection: Connection, postid: usize, text: &str) {
    let key = "posts";
    let post = format!("{}\n{}", postid, text);
    connection.rpush(&key, post).await.unwrap();
}

async fn show_posts(mut connection: Connection) {
    let posts = connection.lrange("posts", 0, 10).await.unwrap();

    for post in posts {
        let post = String::from_utf8_lossy(&post);
        let id = (&post[0..1]).parse::<usize>().unwrap();
        let comment_key = format!("posts.{}.comments", id);
        println!("Post #{}: {}", id, &post[2..]);
        let comments = connection.lrange(&comment_key, 0, 10).await.unwrap();

        for (number, comment) in comments.iter().enumerate() {
            println!("Comment #{}: {}", number, String::from_utf8_lossy(comment));
        }

        connection.del(comment_key).await.unwrap();

        println!();
    }

    connection.del("posts").await.unwrap();
}

//In your own code, you'd use simply #[tokio::main] or #[async_std::main]
#[cfg_attr(feature = "runtime_tokio", tokio::main)]
#[cfg_attr(feature = "runtime_async_std", async_std::main)]
async fn main() {
    let connection = Connection::connect("127.0.0.1:6379").await.unwrap();

    //Write some posts
    let first_post = "My first ever blog post!";
    let first_comments = vec!["Cool!", "Nice!", "I'm excited!"];
    add_post(connection.clone(), 1, first_post).await;
    add_comments(connection.clone(), 1, first_comments).await;

    let second_post = "Blogging is hard work!";
    add_post(connection.clone(), 2, second_post).await;

    let last_post = "My last ever blog post...";
    let last_comments = vec!["Sad to see you go, you were good.", "It's not fair!"];
    add_post(connection.clone(), 3, last_post).await;
    add_comments(connection.clone(), 3, last_comments).await;

    show_posts(connection).await;
}