batpak 0.8.2

Event sourcing with causal graphs and caller-defined gates. Sync API, no async runtime.
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

//! # cross_crate_payloads
//!
//! **Teaches:** validating typed payload kind allocation when an application
//! composes payload types from multiple crates.
//!
//! Run:
//! `cargo run --example cross_crate_payloads`

use batpak::prelude::*;

#[derive(Clone, Debug, serde::Serialize, serde::Deserialize, EventPayload)]
#[batpak(category = 0xF, type_id = 0x120)]
struct LocalPayload {
    value: u64,
}

fn main() -> Result<(), Box<dyn std::error::Error>> {
    // In a real application, call this once during startup after linking all
    // payload crates. `Store::open` also warns once per process by default when
    // duplicate kind registrations are linked.
    validate_event_payload_registry()?;

    let dir = tempfile::tempdir()?;
    let store = Store::open(
        StoreConfig::new(dir.path())
            .with_event_payload_validation(EventPayloadValidation::FailFast),
    )?;
    let coord = Coordinate::new("entity:example", "scope:payloads")?;
    let receipt = store.append_typed(&coord, &LocalPayload { value: 1 })?;
    let stored = store.get(receipt.event_id)?;
    assert_eq!(stored.event.event_kind(), LocalPayload::KIND);
    store.close()?;
    Ok(())
}