Module prelude 

Convenient re-exports.

Re-exports

pub use crate::cqrs::CqrsHandles;

pub use crate::cqrs::CqrsPattern;

pub use crate::cqrs::ProjectionHandle;

pub use crate::cqrs::Reader;

pub use crate::ddd::AggregateRoot;

pub use crate::ddd::Command;

pub use crate::ddd::DomainEvent;

pub use crate::ddd::Entity;

pub use crate::ddd::Repository;

pub use crate::ddd::ValueObject;

pub use crate::saga::Saga;

pub use crate::saga::SagaAction;

pub use crate::saga::SagaPattern;

pub use crate::topology::Topology;

pub use crate::PatternError;

Structs

AsyncSnapshotter

Helper that wraps a SnapshotStore with a retention policy.

EventEnvelope

InMemoryJournal

InMemorySnapshotStore

RecoveryPermitter

Bounded in-flight recovery counter.

Enums

EventsourcedError

Recovery / handler errors that propagate out of Eventsourced.

Offset

Typed read-journal offset. The in-memory backend uses Sequence numbers; a SQL backend might emit TimeBased UUIDs. NoOffset means “from the start.”

SnapshotPolicy

Snapshot retention / cadence policy.

Traits

Eventsourced

Modern event-sourced actor.

Journal

ReadJournal

Read-journal surface. current_* variants take a snapshot at call time; the non-current variants are tail-following (live) — backends that only support snapshots return the snapshot and let callers re-poll.

SnapshotStore