Struct Store 

pub struct Store<M> { /* private fields */ }

A PostgreSQL-backed EventStore.

Defaults are intentionally conservative:

• Positions are global and monotonic (i64, backed by BIGSERIAL).
• Metadata is stored as jsonb (M: Serialize + DeserializeOwned).
• Event data is stored as jsonb.

Implementations

impl<M> Store<M>

pub const fn new(pool: PgPool) -> Self

impl<M> Store<M>

where M: Sync,

pub async fn migrate(&self) -> Result<(), Error>

Apply the initial schema (idempotent).

This uses CREATE TABLE IF NOT EXISTS style DDL so it can be run on startup.

Errors

Returns a sqlx::Error if any of the schema creation queries fail.

Trait Implementations

impl<M: Clone> Clone for Store<M>

fn clone(&self) -> Store<M>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<M> EventStore for Store<M>

where M: Serialize + DeserializeOwned + Clone + Send + Sync + 'static,

type Data = Value

Serialised event payload type.

type Error = Error

Store-specific error type.

type Id = Uuid

Aggregate identifier type.

type Metadata = M

Metadata type for infrastructure concerns.

type Position = i64

Position type used for ordering events and version checking.

fn decode_event<E>( &self, stored: &StoredEvent<Self::Id, Self::Position, Self::Data, Self::Metadata>, ) -> Result<E, Self::Error>

where E: DomainEvent + DeserializeOwned,

Decode a stored event into a concrete event type.

async fn stream_version<'a>( &'a self, aggregate_kind: &'a str, aggregate_id: &'a Self::Id, ) -> Result<Option<Self::Position>, Self::Error>

Get the current version (latest position) for an aggregate stream.

async fn commit_events<'a, E>( &'a self, aggregate_kind: &'a str, aggregate_id: &'a Self::Id, events: NonEmpty<E>, metadata: &'a Self::Metadata, ) -> Result<Committed<i64>, CommitError<Self::Error>>

where E: EventKind + Serialize + Send + Sync + 'a, Self::Metadata: Clone,

Commit events to an aggregate stream without version checking.

async fn commit_events_optimistic<'a, E>( &'a self, aggregate_kind: &'a str, aggregate_id: &'a Self::Id, expected_version: Option<Self::Position>, events: NonEmpty<E>, metadata: &'a Self::Metadata, ) -> Result<Committed<i64>, OptimisticCommitError<i64, Self::Error>>

where E: EventKind + Serialize + Send + Sync + 'a, Self::Metadata: Clone,

Commit events to an aggregate stream with optimistic concurrency control.

async fn load_events<'a>( &'a self, filters: &'a [EventFilter<Self::Id, Self::Position>], ) -> LoadEventsResult<Self::Id, Self::Position, Self::Data, Self::Metadata, Self::Error>

Load events matching the specified filters.

impl<M> GloballyOrderedStore for Store<M>

where M: Serialize + DeserializeOwned + Clone + Send + Sync + 'static,