fast-cache 0.1.0

Embedded-first thread-per-core in-memory cache with optional Redis-compatible server
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
39
40
41
42
43

use super::commands::{
    FastCommandDispatcher, FcnpCommandContext, FcnpCommandDispatcher, FcnpFrame,
    RawCommandDispatcher,
};
use super::fast_write::FastWriteQueue;
use super::wire::*;
use super::*;

mod borrowed;
mod fast;
mod fcnp;
mod read;
mod request;
mod resp;

pub(super) struct DirectProtocol;

#[cfg(feature = "embedded")]
pub(super) type RespDirectArgs<'a> = smallvec::SmallVec<[&'a [u8]; 8]>;

#[cfg(feature = "embedded")]
pub(super) type RespDirectCommandBox<'a> = Box<dyn RespDirectCommand<'a> + 'a>;

#[cfg(feature = "embedded")]
pub(super) trait RespDirectCommand<'a> {
    fn mutates_value(&self) -> bool;

    fn execute(
        self: Box<Self>,
        store: &EmbeddedStore,
        out: &mut BytesMut,
        fast_write_queue: Option<&mut FastWriteQueue>,
        single_threaded: bool,
        started_at: Instant,
    );
}

#[derive(Debug)]
pub(crate) enum FcnpDispatch {
    Complete(usize),
    Incomplete,
    Unsupported,
}