batpak 0.7.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
32
33
34
35
36
37
38
39
40

//! # quickstart
//!
//! **Teaches:** basic typed append + retrieval.
//!
//! Run: `cargo run --example quickstart`

use batpak::prelude::*;

// One struct binds a Rust type to its EventKind at compile time.
// Callsites never touch EventKind::custom(...) again.
#[derive(serde::Serialize, serde::Deserialize, EventPayload)]
#[batpak(category = 0xF, type_id = 1)]
struct PlayerMoved {
    x: i32,
    y: i32,
}

// justifies: INV-EXAMPLES-OBSERVABLE-OUTPUT; quickstart example in examples/quickstart.rs prints observable success output so new users can see the end-to-end append and query flow.
#[allow(clippy::print_stdout)]
fn main() -> Result<(), Box<dyn std::error::Error>> {
    let dir = tempfile::tempdir()?;
    let config = StoreConfig::new(dir.path())
        .with_sync_every_n_events(25)
        .with_sync_mode(SyncMode::SyncData);
    let store = Store::open(config)?;

    let coord = Coordinate::new("player:alice", "room:dungeon")?;
    let receipt = store.append_typed(&coord, &PlayerMoved { x: 10, y: 20 })?;

    let fetched = store.get(receipt.event_id)?;
    println!(
        "stored {} at sequence {} in scope {}",
        fetched.event.header.event_id,
        receipt.sequence,
        fetched.coordinate.scope()
    );

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