Struct PostgresCheckpointStore 

pub struct PostgresCheckpointStore { /* private fields */ }

Postgres-backed checkpoint store for tracking projection progress.

PostgresCheckpointStore stores checkpoint positions in a PostgreSQL table, providing durability across process restarts. It implements the CheckpointStore trait from eventcore-types.

Schema

The store uses the eventcore_subscription_versions table with:

• subscription_name: Unique identifier for each projector/subscription
• last_position: UUID7 representing the global stream position
• updated_at: Timestamp of the last checkpoint update

Implementations

impl PostgresCheckpointStore

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

Create a new PostgresCheckpointStore with default configuration.

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

Create a new PostgresCheckpointStore with custom configuration.

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

Create a PostgresCheckpointStore from an existing connection pool.

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

Trait Implementations

impl CheckpointStore for PostgresCheckpointStore

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 PostgresCheckpointStore

fn clone(&self) -> PostgresCheckpointStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresCheckpointStore

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

Formats the value using the given formatter.