memcached-protocal 0.1.11

Memcached Text Protocal
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

use std::io::BufRead;

use ::error::ErrorKind;
use ::error::Result;
use ::byte_utils::read_until;

#[derive(Debug, PartialEq)]
pub struct DeletionCommand {
    pub command_name: String,
    pub key: String,
    pub noreply: Option<String>,
}


impl DeletionCommand {
    pub fn parse<R: BufRead>(reader: &mut R) -> Result<DeletionCommand> {
        let cmd_line = try!(read_until(reader, "\r\n"));
        let cmd_str = try!(String::from_utf8(cmd_line));
        let segments = cmd_str.split_whitespace().collect::<Vec<&str>>();
        let length = segments.len();
        if length < 2 {
            return Err(ErrorKind::ClientError("wrong size of params".to_owned()).into());
        }
        let cmd = segments[0];
        let key = segments[1];
        let noreply = if length > 2 {
            Some(segments[2].to_string())
        } else {
            None
        };

        Ok(DeletionCommand {
            command_name: cmd.to_owned(),
            key: key.to_owned(),
            noreply: noreply,
        })
    }
}