hiqlite-wal 0.7.1

WAL file implementation for Hiqlite
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
44
45
46
47
48
49
50
51

use crate::error::Error;
use byteorder::{BigEndian, ReadBytesExt, WriteBytesExt};
use serde::{Deserialize, Serialize};

pub const CHKSUM: crc::Crc<u32> = crc::Crc::<u32>::new(&crc::CRC_32_CKSUM);

macro_rules! crc {
    ($input:expr) => {{
        crate::utils::CHKSUM.checksum($input).to_le_bytes()
    }};
}
pub(crate) use crc;

#[inline]
pub fn u64_to_bin(id: u64, buf: &mut Vec<u8>) -> Result<(), Error> {
    buf.write_u64::<BigEndian>(id)?;
    Ok(())
}

#[inline]
pub fn bin_to_u64(buf: &[u8]) -> Result<u64, Error> {
    Ok((&buf[0..8]).read_u64::<BigEndian>()?)
}

#[inline]
pub fn u32_to_bin(id: u32, buf: &mut Vec<u8>) -> Result<(), Error> {
    buf.write_u32::<BigEndian>(id)?;
    Ok(())
}

#[inline]
pub fn bin_to_u32(buf: &[u8]) -> Result<u32, Error> {
    Ok((&buf[0..4]).read_u32::<BigEndian>()?)
}

#[inline(always)]
pub fn serialize<T: Serialize>(value: &T) -> Result<Vec<u8>, Error> {
    Ok(bincode::serde::encode_to_vec(
        value,
        bincode::config::standard(),
    )?)
}

#[inline]
pub fn deserialize<T>(bytes: &[u8]) -> Result<T, Error>
where
    T: for<'a> Deserialize<'a>,
{
    let (res, _) = bincode::serde::decode_from_slice::<T, _>(bytes, bincode::config::standard())?;
    Ok(res)
}