tinyredis 1.0.0

A Redis-compatible server written in Rust. Uses RESP2, persists writes to an append-only file, and accepts connections from any standard Redis client.
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

use crate::error::{Error, Result};
use crate::parser::Frame;
use crate::persistence::{AofEntry, AofSender};
use bytes::Bytes;

pub fn parse_u64(b: &Bytes) -> Result<u64> {
    std::str::from_utf8(b)
        .ok()
        .and_then(|s| s.parse().ok())
        .ok_or(Error::NotInteger)
}

pub fn to_str(b: &Bytes, cmd: &'static str) -> Result<String> {
    std::str::from_utf8(b)
        .map(String::from)
        .map_err(|_| Error::WrongArity(cmd))
}

pub async fn aof_log(aof: &Option<AofSender>, frame: Frame) {
    if let Some(tx) = aof {
        let _ = tx
            .send(AofEntry {
                raw: frame.serialize(),
            })
            .await;
    }
}

pub fn parse_i64(b: &Bytes) -> Result<i64> {
    std::str::from_utf8(b)
        .ok()
        .and_then(|s| s.parse().ok())
        .ok_or(Error::NotInteger)
}