Crate atomr_persistence 

atomr-persistence.

Event-sourced persistent actor model with pluggable journal and snapshot stores.

Structs

AsyncSnapshotter

Helper that wraps a SnapshotStore with a retention policy.

AtLeastOnceDelivery

InMemoryJournal

InMemorySnapshotStore

PersistentFSM

PersistentRepr

ReceivePersistent

Closure-style persistent actor.

Recovery

RecoveryPermitter

Bounded in-flight recovery counter.

ReplayHarness

Drives an Eventsourced aggregate through a recorded entry stream, restoring RNG state first so derived computation is bit-identical to the original run.

ReplayReport

Outcome of a ReplayHarness::replay run.

RngState

Serializable snapshot of a SeededRng’s position in its stream.

RunPin

Governance record pinning the model/provider/version/seed a run was produced under. Recorded alongside a snapshot so a replay can prove it is reproducing the same configuration.

SeededRng

A deterministic, snapshot/restore-able RNG for record-and-replay.

SnapshotMetadata

UnconfirmedDelivery

Enums

EntryKind

Provenance of a journal entry for replay purposes.

EventsourcedError

Recovery / handler errors that propagate out of Eventsourced.

JournalError

RecoveryState

SnapshotPolicy

Snapshot retention / cadence policy.

Traits

Eventsourced

Modern event-sourced actor.

Journal

PersistentActor

SnapshotStore

Functions

with_kind

Push the provenance tag for kind onto repr without changing the struct shape. Returns the repr by value for chaining.