tk-redis 0.1.3

A minimal redis client library based on futures+tokio-core
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

use cmd::Cmd;
use std::io;
use tokio_core::io::{Codec, EasyBuf};
use value::Value;

pub struct RedisCodec;

impl Codec for RedisCodec {
    type In = Value;
    type Out = Cmd;

    fn decode(&mut self, buf: &mut EasyBuf) -> io::Result<Option<Value>> {
        if let Some((value, len)) = Value::parse(buf.as_slice())? {
            buf.drain_to(len);
            Ok(Some(value))
        } else {
            Ok(None)
        }
    }

    fn encode(&mut self, cmd: Cmd, buf: &mut Vec<u8>) -> io::Result<()> {
        buf.reserve(cmd.encode_len());
        cmd.encode(buf);
        Ok(())
    }
}