commonware-storage 2026.4.0

Persist and retrieve data from an abstract store.
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

use super::utils::{get_random_kvs, init};
use commonware_runtime::{
    benchmarks::{context, tokio},
    tokio::Config,
    Runner,
};
use criterion::{criterion_group, Criterion};
use std::time::{Duration, Instant};

fn bench_restart(c: &mut Criterion) {
    let cfg = Config::default();
    for &num_keys in &[100, 1_000, 10_000, 100_000] {
        // Create metadata and fill it.
        let builder = commonware_runtime::tokio::Runner::new(cfg.clone());
        builder.start(|ctx| async move {
            let mut metadata = init(ctx).await;
            let kvs = get_random_kvs(num_keys);
            for (k, v) in kvs {
                metadata.put(k, v);
            }

            // Sync twice to ensure both blobs populated
            metadata.sync().await.unwrap();
            metadata.sync().await.unwrap();
        });

        // Benchmark
        let runner = tokio::Runner::new(cfg.clone());
        c.bench_function(&format!("{}/keys={}", module_path!(), num_keys), |b| {
            b.to_async(&runner).iter_custom(|iters| async move {
                let ctx = context::get::<commonware_runtime::tokio::Context>();
                let mut total = Duration::ZERO;
                for _ in 0..iters {
                    let start = Instant::now();
                    // This is the benchmarked operation
                    let _metadata = init(ctx.clone()).await;
                    total += start.elapsed();
                }
                total
            });
        });

        // Teardown
        let cleaner = commonware_runtime::tokio::Runner::new(cfg.clone());
        cleaner.start(|ctx| async move {
            let metadata = init(ctx).await;
            metadata.destroy().await.unwrap();
        });
    }
}

criterion_group! {
    name = benches;
    config = Criterion::default().sample_size(10);
    targets = bench_restart
}