batpak 0.5.0

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

use batpak::prelude::*;

#[allow(clippy::print_stdout)]
fn main() -> Result<(), Box<dyn std::error::Error>> {
    let dir = tempfile::tempdir()?;
    let store = Store::open(StoreConfig::new(dir.path()))?;

    let coord = Coordinate::new("player:fence", "room:hidden")?;
    let kind = EventKind::custom(0xF, 4);

    let fence = store.begin_visibility_fence()?;
    let ticket = fence.submit(&coord, kind, &serde_json::json!({"hidden": true}))?;
    let receipt = ticket.wait()?;

    println!(
        "durable before commit: visible_count={}",
        store.by_fact(kind).len()
    );
    assert_eq!(store.by_fact(kind).len(), 0);

    fence.commit()?;

    println!(
        "after commit event {} is visible and query count is {}",
        receipt.event_id,
        store.by_fact(kind).len()
    );

    store.close()?;
    Ok(())
}