redis-parser 0.1.2

A zero-copy parser for the RESP2 and RESP3 protocols, used by Redis
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

use nom::bytes::streaming::{is_not, take};
use nom::character::streaming::{char, crlf, digit1};
use nom::combinator::map_res;
use nom::number::streaming::double;
use nom::sequence::{delimited, terminated};
use nom::IResult;
use std::str::{from_utf8, FromStr};

#[inline(always)]
pub fn parse_str_with_prefix(input: &[u8], prefix: char) -> IResult<&[u8], &str> {
    map_res(delimited(char(prefix), is_not("\r\n"), crlf), |out| {
        from_utf8(out)
    })(input)
}

#[inline(always)]
pub fn parse_integer_with_prefix(input: &[u8], prefix: char) -> IResult<&[u8], usize> {
    map_res(delimited(char(prefix), digit1, crlf), |out| {
        usize::from_str(from_utf8(out).unwrap())
    })(input)
}

#[inline(always)]
pub fn parse_double_with_prefix(input: &[u8], prefix: char) -> IResult<&[u8], f64> {
    delimited(char(prefix), double, crlf)(input)
}

#[inline(always)]
pub fn parse_bytes_with_length(input: &[u8], length: usize) -> IResult<&[u8], &[u8]> {
    terminated(take(length), crlf)(input)
}

#[inline(always)]
pub fn parse_str_with_length(input: &[u8], length: usize) -> IResult<&[u8], &str> {
    // terminated(map_res!(input, take!($size), $crate::lib::std::str::from_utf8), crlf)(input)
    terminated(map_res(take(length), from_utf8), crlf)(input)
}