Struct PostgresProjectionStore 

pub struct PostgresProjectionStore { /* private fields */ }

PostgreSQL destination containing a transactional projection’s read model and progress.

Implementations

impl PostgresProjectionStore

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

Connects a destination pool with the standard EventCore PostgreSQL configuration.

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

Creates a projection destination from an application-owned pool.

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

Applies the destination-owned progress migration through the separate projection ledger.

pub async fn progress( &self, projector: &ProjectorName, ) -> Result<Option<ProjectionProgress>, TransactionalProjectionError>

Reads public durable progress for one projector, if it has committed an event.

Trait Implementations

impl Clone for PostgresProjectionStore

fn clone(&self) -> PostgresProjectionStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresProjectionStore

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

Formats the value using the given formatter.