batpak 0.4.1

Event sourcing with causal graphs and policy gates. Sync API, zero async.
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

//! Shared test helpers used across integration test files.
//!
//! Each test file that needs these helpers includes:
//! ```ignore
//! mod common;
//! ```
//!
//! Use `common::small_segment_store()` for tests that need to force segment
//! rotation, or `common::default_store()` for tests that just need a working
//! Store.

#![allow(dead_code)] // helpers are used by some test files but not all

pub mod proptest;

use batpak::prelude::*;
use tempfile::TempDir;

/// Open a Store with small segments (4 KB) and per-event fsync.
/// Use this for tests that need to force rapid segment rotation.
pub fn small_segment_store() -> (Store, TempDir) {
    let dir = TempDir::new().expect("create temp dir");
    let config = StoreConfig {
        data_dir: dir.path().to_path_buf(),
        segment_max_bytes: 4096,
        sync: SyncConfig {
            every_n_events: 1,
            ..SyncConfig::default()
        },
        ..StoreConfig::new("")
    };
    let store = Store::open(config).expect("open store");
    (store, dir)
}

/// Open a Store with 64 KB segments using a caller-supplied TempDir.
/// Use this when the test needs to keep the TempDir alive across reopens.
pub fn medium_segment_store(dir: &TempDir) -> Store {
    let mut config = StoreConfig::new(dir.path());
    config.segment_max_bytes = 64 * 1024;
    Store::open(config).expect("open store")
}

/// Standard test coordinate: `entity:test` / `scope:test`.
pub fn test_coord() -> Coordinate {
    Coordinate::new("entity:test", "scope:test").expect("coord")
}

/// Standard test event kind in the user category.
pub fn test_kind() -> EventKind {
    EventKind::custom(0xF, 1)
}