Struct PostgresEventStore 

pub struct PostgresEventStore { /* private fields */ }

PostgreSQL-backed event store implementing EventCore’s storage traits.

Provides atomic multi-stream event writes with optimistic concurrency control, advisory locks for projector coordination, and connection pooling.

Use PostgresEventStore::new (or PostgresEventStore::with_config) with a PostgreSQL connection URL to create an instance.

Implementations

impl PostgresEventStore

pub async fn new<S: Into<String>>( connection_string: S, ) -> Result<Self, PostgresEventStoreError>

Create a new PostgresEventStore with default configuration.

pub async fn with_config<S: Into<String>>( connection_string: S, config: PostgresConfig, ) -> Result<Self, PostgresEventStoreError>

Create a new PostgresEventStore with custom configuration.

pub fn from_pool(pool: Pool<Postgres>) -> Self

Create a PostgresEventStore from an existing connection pool.

Use this when you need full control over pool configuration or want to share a pool across multiple components.

pub async fn ping(&self)

Verify connectivity by issuing a trivial SELECT 1 query.

Panics

Panics if the database is unreachable or the query fails.

pub async fn migrate(&self)

Apply the bundled schema migrations via sqlx::migrate!("./migrations").

This creates the tables EventCore requires, including the eventcore_subscription_versions table used by PostgresCheckpointStore.

Panics

Panics if applying the migrations fails.

Trait Implementations

impl CheckpointStore for PostgresEventStore

type Error = PostgresCheckpointError

Error type returned by checkpoint operations.

async fn load(&self, name: &str) -> Result<Option<StreamPosition>, Self::Error>

Load the last saved checkpoint position for a subscription.

async fn save( &self, name: &str, position: StreamPosition, ) -> Result<(), Self::Error>

Save a checkpoint position for a subscription.

impl Clone for PostgresEventStore

fn clone(&self) -> PostgresEventStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresEventStore

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

Formats the value using the given formatter.

impl EventReader for PostgresEventStore

type Error = EventStoreError

Error type returned by read operations.

async fn read_events<E: Event>( &self, filter: EventFilter, page: EventPage, ) -> Result<Vec<(E, StreamPosition)>, Self::Error>

Read events matching filter criteria with pagination.

impl EventStore for PostgresEventStore

async fn read_stream<E: Event>( &self, stream_id: StreamId, ) -> Result<EventStream<E>, EventStoreError>

Read all events from a stream.

async fn append_events( &self, writes: StreamWrites, ) -> Result<EventStreamSlice, EventStoreError>

Atomically append events to multiple streams with optimistic concurrency control.

impl ProjectorCoordinator for PostgresEventStore

type Error = CoordinationError

Error type returned when leadership acquisition fails.

type Guard = CoordinationGuard

Guard type that releases leadership when dropped.

async fn try_acquire( &self, subscription_name: &str, ) -> Result<Self::Guard, Self::Error>

Attempt to acquire leadership for a subscription.