brk_vecs 0.0.85

A KISS index/value store
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

use memmap2::MmapMut;
use parking_lot::RwLockReadGuard;

use super::Region;

#[derive(Debug)]
pub struct Reader<'a> {
    mmap: RwLockReadGuard<'a, MmapMut>,
    region: RwLockReadGuard<'static, Region>,
}

impl<'a> Reader<'a> {
    pub fn new(
        mmap: RwLockReadGuard<'a, MmapMut>,
        region: RwLockReadGuard<'static, Region>,
    ) -> Self {
        Self { mmap, region }
    }

    pub fn read(&self, offset: u64, len: u64) -> &[u8] {
        assert!(offset + len <= self.region.len());
        let start = self.region.start() + offset;
        let end = start + len;
        &self.mmap[start as usize..end as usize]
    }

    pub fn read_all(&self) -> &[u8] {
        self.read(0, self.region().len())
    }

    pub fn region(&self) -> &Region {
        &self.region
    }

    pub fn prefixed(&self, offset: u64) -> &[u8] {
        let start = self.region.start() + offset;
        &self.mmap[start as usize..]
    }
}