An EventSourcingDB implementation of the PersistedEventRepository trait in cqrs-es.
Add the following to your Cargo.toml:
[dependencies]
cqrs-es = "0.5.0"
eventsourcingdb-es = "0.2.0"- Persist events
- Read events by subject (aggregate type and ID)
- Read last events by subject
- Stream events for subject
- Stream all events for aggregate type
- Write snapshots
- Read snapshots