Module cqrs_es::persist

source ·
Expand description

Common persistence mechanisms.

This module is used alongside one of the available repository crates:

Structs§

  • EventStoreAggregateContext
    Holds context for the pure event store implementation PostgresStore. This is only used internally within the EventStore.
  • GenericQuery
    A simple query and view repository. This is used both to act as a Query for processing events and to return materialized views.
  • PersistedEventStore
    Storage engine using a database backing. This defaults to an event-sourced store (i.e., events are the single source of truth), but can be configured to be aggregate-sourced or use snapshots when a large number of events are associated with a single aggregate instance.
  • QueryReplay
    A utility for replaying committed events to a Query.
  • ReplayFeed
    Used to send events to a ReplayStream for replaying events.
  • ReplayStream
    Accesses a domain event stream for a particular aggregate.
  • SemanticVersion
    A representation of a semantic version used in a SemanticVersionEventUpcaster.
  • SemanticVersionError
    Type can not be converted to a Semantic Version.
  • SemanticVersionEventUpcaster
    This upcasts any event that has the same event_type and an event_version that is less than the version configured on the upcaster.
  • SerializedEvent
    A serialized version of an event with metadata. Used by repositories to store and load events from a database.
  • SerializedSnapshot
    A serialized version of a snapshot. Used by repositories to store and load snapshots from a database.
  • ViewContext
    A data structure maintaining context when updating views.

Enums§

Traits§

  • EventUpcaster
    Used to upcast and event from an older type or version to the current form. This is needed to modify the structure of events older versions are already persisted.
  • PersistedEventRepository
    Handles the database access needed for operation of a PersistedSnapshotStore.
  • ViewRepository
    Handles the database access needed for a GenericQuery.

Type Aliases§