redis-module 1.0.1

A toolkit for building Redis modules in 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

#[macro_use]
extern crate redis_module;

use redis_module::{Context, RedisResult, RedisString, ThreadSafeContext};
use std::mem::drop;
use std::thread;
use std::time::Duration;

fn threads(_: &Context, _args: Vec<RedisString>) -> RedisResult {
    thread::spawn(move || {
        let thread_ctx = ThreadSafeContext::new();

        loop {
            let ctx = thread_ctx.lock();
            ctx.call("INCR", &["threads"]).unwrap();
            // release the lock as soon as we're done accessing redis memory
            drop(ctx);
            thread::sleep(Duration::from_millis(1000));
        }
    });

    Ok(().into())
}

//////////////////////////////////////////////////////

redis_module! {
    name: "threads",
    version: 1,
    data_types: [],
    commands: [
        ["threads", threads, "", 0, 0, 0],
    ],
}