sierradb-server 0.3.1

SierraDB server - distributed event store server with Redis RESP3 protocol
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 std::convert::Infallible;

use combine::{Parser, value};
use redis_protocol::resp3::types::BytesFrame;

use crate::parser::FrameStream;
use crate::request::{HandleRequest, simple_str};
use crate::server::Conn;

#[derive(Clone, Copy)]
pub struct Ping {}

impl Ping {
    pub fn parser<'a>() -> impl Parser<FrameStream<'a>, Output = Ping> + 'a {
        value(Ping {})
    }
}

impl HandleRequest for Ping {
    type Error = Infallible;
    type Ok = PingResp;

    async fn handle_request(self, _conn: &mut Conn) -> Result<Option<Self::Ok>, Self::Error> {
        Ok(Some(PingResp))
    }
}

pub struct PingResp;

impl From<PingResp> for BytesFrame {
    fn from(_: PingResp) -> Self {
        simple_str("PONG")
    }
}