batpak 0.10.0

Embedded, sync-first event store: append-only hash-chained journal, typed events, verifiable receipts, deterministic replay, projections. 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

//! Event delivery surfaces.
//!
//! Two canals ship under this module:
//!
//! * [`cursor`](crate::store::delivery::cursor) — pull-based, ordered delivery with optional durable
//!   checkpoints (per FREEZE-5). Without a checkpoint id the guarantee is
//!   process-local; with one it becomes durable at-least-once across
//!   restarts.
//! * [`subscription`](crate::store::delivery::subscription) — push-based, lossy fanout with a region filter
//!   applied at the writer push point (F8). Use
//!   [`Subscription::filtered_receiver`](crate::store::delivery::subscription::Subscription::filtered_receiver) for async /
//!   deadline-driven consumers — every notification is pre-filtered to the
//!   subscription's region at the writer push point, so the channel never
//!   carries an out-of-region item.

/// Shared delivery selector for typed reactor runners.
pub mod canal;
/// Pull-based cursor for ordered delivery with optional durable checkpoints.
pub mod cursor;
/// Delivery observation witnesses for composing at-least-once with
/// consumer-side idempotency.
pub mod observation;
/// Push-based (lossy) event subscription via broadcast channel.
pub mod subscription;