rotbl 0.3.0

Read Only Table
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

use std::sync::Arc;

use libtest_mimic::Trial;
use rotbl::storage::Storage;
use rotbl::v001::CacheStat;

use crate::async_trials;
use crate::context::TestContext;
use crate::temp_table;
use crate::utils::NewContext;

pub fn tests<S: Storage>(new_ctx: impl NewContext<S>, trials: &mut Vec<Trial>) {
    trials.extend(async_trials!(new_ctx, test_rotbl_cache_cap_limit));
}

async fn test_rotbl_cache_cap_limit<S: Storage>(mut ctx: TestContext<S>) -> anyhow::Result<()> {
    let config = ctx.config_mut();
    config.block_config.max_items = Some(1);
    config.block_cache.capacity = Some(40);

    let (t, _index_data) =
        temp_table::create_tmp_table(ctx.storage(), ctx.new_db()?.as_ref(), "foo.rot")?;

    let t = Arc::new(t);

    let stat = t.stat();
    let _ = stat;
    // println!("{}", stat);

    let cache_stat = t.cache_stat();
    let _ = cache_stat;
    // println!("{:?}", cache_stat);

    // Cache weights are encoded block sizes, tracking the pinned libzstd (zstd-sys, Cargo.toml).
    t.get("a").await?;
    assert_eq!(t.cache_stat(), CacheStat::new(1, 16));
    t.get("b").await?;
    assert_eq!(t.cache_stat(), CacheStat::new(2, 34));
    t.get("c").await?;
    assert_eq!(t.cache_stat(), CacheStat::new(1, 18));
    t.get("d").await?;
    assert_eq!(t.cache_stat(), CacheStat::new(2, 36));
    t.get("a").await?;
    assert_eq!(t.cache_stat(), CacheStat::new(2, 36));
    t.get("b").await?;
    assert_eq!(t.cache_stat(), CacheStat::new(2, 36));

    Ok(())
}