Skip to main content

Crate talea_store_log

Crate talea_store_log 

Source
Expand description

Append-log store: one CRC-framed JSON event log per book, a single writer task per book over in-memory state, strict fsync-per-batch.

Re-exports§

pub use frame::WireEvent;

Modules§

frame
Wire format: u32-LE payload_len | u32-LE crc32(payload) | JSON payload.
idem_spill
Tiered idempotency index: hot HashMap + on-disk sorted runs + Bloom front.
segment
Segment set: a book’s on-disk log as segment-<base_seq:020>.log files.
snapshot
Atomic per-book snapshots: snapshot-<last_seq:020>.snap = u32-LE crc32(payload) | payload: JSON BookState.
state
In-memory authoritative state for one book, plus batch validation.
writer
Per-book writer: single Tokio task, group commit, ack strictly after fsync.

Structs§

LogStoreOptions
Options for opening a LogTaleaStore.
LogTaleaStore
An append-log implementation of Store.