murr 0.2.0-rc2

Columnar in-memory cache for AI/ML inference workloads
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

use crate::core::{MurrError, TableSchema};

pub mod manifest;
pub mod memory;
pub mod rocksdb;
pub mod snapshot;

pub use manifest::Manifest;

pub struct KeyValue {
    pub key: Vec<u8>,
    pub value: Vec<u8>,
}

impl KeyValue {
    pub fn new(key: impl Into<Vec<u8>>, value: impl Into<Vec<u8>>) -> Self {
        Self {
            key: key.into(),
            value: value.into(),
        }
    }
}

pub trait ReadResult {
    fn bytes(&self) -> impl Iterator<Item = Result<Option<&[u8]>, MurrError>>;
}

pub trait Store {
    type R<'a>: ReadResult
    where
        Self: 'a;
    fn create_table(&mut self, table: &str, schema: &TableSchema) -> Result<(), MurrError>;
    fn write(
        &mut self,
        table: &str,
        rows: impl IntoIterator<Item = KeyValue>,
    ) -> Result<(), MurrError>;
    fn read<'a>(&'a self, table: &str, keys: &[&[u8]]) -> Result<Self::R<'a>, MurrError>;
    fn compact(&self, table: &str) -> Result<(), MurrError>;
    fn manifest(&self) -> &Manifest;
}