distributed 3.1.0

CQRS/ES framework for Rust using Plain Old Rust Structs — append-only events, replay, snapshots, outbox, service bus, and pluggable infrastructure
Documentation
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
mod error;
mod identity;
mod inbox;
mod traits;
mod validation;

pub use error::RepositoryError;
pub use identity::StreamIdentity;
pub use inbox::{InboxOutcome, InboxReceipt};
pub use traits::{
    CommitBatch, GetStream, InboxStore, PreparedEventAppend, ReadModelWritePlanStore,
    RelationalReadModelQueryStore, Repository, SnapshotStore, SnapshotWrite, StreamWrite,
    TransactionalCommit,
};
#[cfg(any(feature = "postgres", feature = "sqlite"))]
pub(crate) use validation::validate_supported_event_codec;
pub(crate) use validation::{validate_commit_batch, validate_snapshot_identity};