Struct PostgresStore 

pub struct PostgresStore { /* private fields */ }

A persistence store backed by PostgreSQL, implementing both EventStore and SnapshotStore over a shared connection pool; cheap to clone.

Implementations

impl PostgresStore

pub fn new(pool: PgPool) -> Self

Create a store over the given connection pool. The schema is not touched; apply it via PostgresStore::migrate or manage it externally.

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

Apply the embedded schema migrations, idempotently.

Trait Implementations

impl Clone for PostgresStore

fn clone(&self) -> PostgresStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl EventStore for PostgresStore

type Error = Error

The type of the store’s failures. Send, Sync and 'static are required by the Send variant of this trait anyway; stating them here reports a non-conforming error type at its definition instead of at an opaque future, and lets callers box or propagate store failures across tasks.

async fn append( &self, id: &PersistenceId, next_seq_no: SeqNo, events: Vec<EncodedEvent>, ) -> Result<(), AppendError<Self::Error>>

Append the given events at sequence number next_seq_no, the first one taking that number, atomically: after a crash the stream contains all of them or none. The append is conditional: if the stream’s actual next sequence number differs from next_seq_no, another writer has extended the stream and the append must fail with AppendError::Conflict, leaving the stream untouched; this fences concurrent incarnations. next_seq_no is SeqNo::ZERO for an empty stream. An empty events appends nothing but is still conditional.

async fn read( &self, id: &PersistenceId, from_seq_no: SeqNo, limit: NonZeroUsize, ) -> Result<Vec<StoredEvent>, Self::Error>

Read up to limit events from the given sequence number on, inclusive, in ascending order. Replay pages through this until a page is short.

impl SnapshotStore for PostgresStore

type Error = Error

The type of the store’s failures. Send, Sync and 'static are required by the Send variant of this trait anyway; stating them here reports a non-conforming error type at its definition instead of at an opaque future, and lets callers box or propagate store failures across tasks.

async fn save( &self, id: &PersistenceId, next_seq_no: SeqNo, snapshot: EncodedSnapshot, ) -> Result<(), Self::Error>

Save the given snapshot together with next_seq_no, the sequence number at which replay resumes, replacing any earlier snapshot: only the latest one is ever loaded.

async fn load( &self, id: &PersistenceId, ) -> Result<Option<StoredSnapshot>, Self::Error>

Load the latest snapshot, if any.