52 releases (15 breaking)

✓ Uses Rust 2018 edition

new 0.18.0 Aug 15, 2019
0.17.0 May 12, 2019
0.16.3 May 11, 2019
0.13.1 Mar 31, 2019
0.4.2 Mar 9, 2018

#12 in Database implementations

Download history 293/week @ 2019-05-02 418/week @ 2019-05-09 627/week @ 2019-05-16 738/week @ 2019-05-23 669/week @ 2019-05-30 503/week @ 2019-06-06 281/week @ 2019-06-13 461/week @ 2019-06-20 790/week @ 2019-06-27 485/week @ 2019-07-04 328/week @ 2019-07-11 269/week @ 2019-07-18 314/week @ 2019-07-25 459/week @ 2019-08-01 506/week @ 2019-08-08

2,116 downloads per month
Used in 17 crates (2 directly)

MIT/Apache

298KB
7K SLoC

pagecache

Build Status crates.io documentation

A construction kit for databases. Provides a lock-free log store and pagecache.

References

use {
    pagecache::{pin, Materializer, Config},
    serde::{Serialize, Deserialize},
};


#[derive(
    Clone, Eq, PartialEq, Ord, PartialOrd, Debug, Serialize, Deserialize,
)]
pub struct TestState(String);

impl Materializer for TestState {
    // Used to merge chains of partial pages into a form
    // that is useful for the `PageCache` owner.
    fn merge(&mut self, other: &TestState) {
        self.0.push_str(&other.0);
    }
}

fn main() {
    let config = pagecache::ConfigBuilder::new().temporary(true).build();
    let pc: pagecache::PageCache<TestState> =
        pagecache::PageCache::start(config).unwrap();
    {
        // We begin by initiating a new transaction, which
        // will prevent any witnessable memory from being
        // reclaimed before we drop this object.
        let tx = pc.begin().unwrap();

        // The first item in a page should be set using allocate,
        // which signals that this is the beginning of a new
        // page history.
        let (id, mut key) = pc.allocate(TestState("a".to_owned()), &tx).unwrap();

        // Subsequent atomic updates should be added with link.
        key = pc.link(id, key, TestState("b".to_owned()), &tx).unwrap().unwrap();
        key = pc.link(id, key, TestState("c".to_owned()), &tx).unwrap().unwrap();

        // When getting a page, the provided `Materializer` is
        // used to merge all pages together.
        let (mut key, page, size_on_disk) = pc.get(id, &tx).unwrap().unwrap();

        assert_eq!(page.0, "abc".to_owned());

        // You can completely rewrite a page by using `replace`:
        key = pc.replace(id, key, TestState("d".into()), &tx).unwrap().unwrap();

        let (key, page, size_on_disk) = pc.get(id, &tx).unwrap().unwrap();

         assert_eq!(page.0, "d".to_owned());
    }
}

Dependencies

~4.5MB
~80K SLoC