graft 0.2.1

The Graft storage engine.
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
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108

use crate::core::{checkpoints::CachedCheckpoints, commit::Commit, page::Page};
use bilrost::{Message, OwnedMessage};
use bytes::Bytes;
use culprit::ResultExt;

use crate::{
    local::fjall_storage::fjall_repr::{FjallRepr, FjallReprRef},
    volume::Volume,
};

use super::fjall_repr::DecodeErr;

impl FjallReprRef for Page {
    #[inline]
    fn as_slice(&self) -> impl AsRef<[u8]> {
        self
    }

    #[inline]
    fn into_slice(self) -> fjall::Slice {
        self.into_bytes().into()
    }
}

impl FjallRepr for Page {
    #[inline]
    fn try_from_slice(slice: fjall::Slice) -> culprit::Result<Self, DecodeErr> {
        Page::try_from(Bytes::from(slice)).or_into_ctx()
    }
}

macro_rules! impl_fjallrepr_for_bilrost {
    ($($ty:ty),+) => {
        $(
            impl FjallReprRef for $ty {
                #[inline]
                fn as_slice(&self) -> impl AsRef<[u8]> {
                    self.encode_to_bytes()
                }

                #[inline]
                fn into_slice(self) -> fjall::Slice {
                    self.encode_to_bytes().into()
                }
            }

            impl FjallRepr for $ty {
                #[inline]
                fn try_from_slice(slice: fjall::Slice) -> culprit::Result<Self, DecodeErr> {
                    <$ty>::decode(Bytes::from(slice)).or_into_ctx()
                }
            }
        )+
    };
}

impl_fjallrepr_for_bilrost!(Volume, CachedCheckpoints, Commit);

#[cfg(test)]
mod tests {
    use super::*;

    use crate::core::VolumeId;
    use crate::core::checkpoints::Checkpoints;
    use crate::core::{LogId, PageCount, page::PAGESIZE};
    use crate::lsn;

    use crate::local::fjall_storage::fjall_repr::testutil::{
        test_empty_default, test_invalid, test_roundtrip,
    };

    #[graft_test::test]
    fn test_page() {
        test_roundtrip(Page::test_filled(123));
        test_roundtrip(Page::EMPTY);
        test_invalid::<Page>(&b"a".repeat(PAGESIZE.as_usize() + 1));
    }

    #[graft_test::test]
    fn test_volume() {
        test_roundtrip(Volume::new(
            VolumeId::random(),
            LogId::random(),
            LogId::random(),
            None,
            None,
        ));
        test_empty_default::<Volume>();
        test_invalid::<Volume>(&b"abc".repeat(123));
    }

    #[graft_test::test]
    fn test_checkpoints() {
        test_roundtrip(CachedCheckpoints::new(
            Checkpoints::from([lsn!(123)].as_slice()),
            Some("asdf"),
        ));
        test_empty_default::<CachedCheckpoints>();
        test_invalid::<CachedCheckpoints>(&b"abc".repeat(123));
    }

    #[graft_test::test]
    fn test_commit() {
        test_roundtrip(Commit::new(LogId::random(), lsn!(123), PageCount::new(456)));
        test_empty_default::<Commit>();
        test_invalid::<Commit>(&b"abc".repeat(123));
    }
}