block-db 0.2.0

Local, multi-threaded, durable byte DB.
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

// Authors: Robert Lopez

use super::{data_block::DataBlock, DataFile};
use crate::error::Error;

impl DataFile {
    pub async fn read(&mut self, id: &str) -> Result<Option<Vec<u8>>, Error> {
        if let Some(data_block) = self.data_blocks.get(id).cloned() {
            let DataBlock {
                padding,
                chunk_offsets,
            } = data_block;

            let mut bytes = Vec::with_capacity(
                (chunk_offsets.len() * self.options_store.chunk_size()) - padding,
            );

            for (index, chunk_offset) in chunk_offsets.iter().enumerate() {
                bytes.append(
                    &mut self
                        .read_chunk(
                            *chunk_offset,
                            if index == chunk_offsets.len() - 1 {
                                padding
                            } else {
                                0
                            },
                        )
                        .await?,
                );
            }

            return Ok(Some(bytes));
        }

        Ok(None)
    }
}