novakv 1.0.1

An embedded, ordered key-value store for Rust.
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

use crate::status::Result;

#[derive(Debug, Clone, Default, PartialEq, Eq)]
pub struct WriteBatch {
    pub header: crate::write_batch::WriteBatchHeader,
    pub records: Vec<crate::write_batch::WriteBatchRecord>,
}

impl WriteBatch {
    pub fn encode(&self, dst: &mut Vec<u8>) {
        self.header.encode(dst);
        for item in &self.records {
            item.encode(dst);
        }
    }

    pub fn decode_from(input: &mut &[u8]) -> Result<Self> {
        let header = crate::write_batch::WriteBatchHeader::decode_from(input)?;
        let records = {
            let n = (header.count) as usize;
            let mut items = Vec::with_capacity(n);
            for _ in 0..n {
                items.push(crate::write_batch::WriteBatchRecord::decode_from(input)?);
            }
            items
        };
        Ok(Self { header, records })
    }
}