atomr-patterns 0.9.2

DDD/CQRS pattern library for atomr — aggregates, readers, projections, sagas, outbox, ACL.
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

//! CQRS + Event Sourcing pattern.
//!
//! `CqrsPattern` wires up the four moving parts of a typical
//! command-query stack:
//!
//! 1. A **command gateway** actor that owns one
//!    [`crate::AggregateRoot`] instance per aggregate id and persists
//!    events through the configured [`atomr_persistence::Journal`].
//! 2. A **repository** handle that callers use to dispatch commands.
//! 3. Zero or more **readers** — async tasks that follow the
//!    [`atomr_persistence_query::ReadJournal`], decode events with the
//!    user-supplied codec, and fold them into projection state.
//! 4. **Extension hooks** — pre-handler interceptors (validation,
//!    authorization), post-persist event listeners, and async event
//!    taps that bridge to [`atomr_streams`] / external systems.
//!
//! See [`CqrsPattern::builder`] for the entry point.

pub mod audit;
mod builder;
mod command_gateway;
mod event_codec;
mod projection;
mod reader;
mod scheduled;

pub use audit::{AuditLog, AuditProjection};
pub use builder::{CqrsBuilder, CqrsHandles, CqrsPattern, CqrsTopology};
pub use event_codec::EventCodecRegistry;
pub use projection::ProjectionHandle;
pub use reader::{Reader, ReaderFilter};
pub use scheduled::schedule_command;