Struct PostgresProjectionSource 

pub struct PostgresProjectionSource { /* private fields */ }

PostgreSQL implementation of the strict, lossless projection delivery source.

Implementations

impl PostgresProjectionSource

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

Creates a source with the default PostgreSQL pool configuration.

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

Creates a source with an explicit PostgreSQL pool configuration.

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

Creates a source from an existing pool and a stable application-supplied source identity.

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

Applies the source-owned delivery migration without using SQLx’s shared migration ledger.

Trait Implementations

impl Clone for PostgresProjectionSource

fn clone(&self) -> PostgresProjectionSource

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresProjectionSource

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

Formats the value using the given formatter.

impl ProjectionSource for PostgresProjectionSource

type Error = PostgresProjectionSourceError

Error returned when the source cannot read its committed delivery sequence.

fn source_id(&self) -> &DeliverySourceId

Returns this source’s stable delivery identity.

async fn high_watermark(&self) -> Result<Option<DeliveryPosition>, Self::Error>

Returns the committed high-water mark for the entire delivery sequence.

async fn read_envelopes( &self, selection: &ProjectionSelection, after: Option<DeliveryPosition>, through: DeliveryUpperBound, limit: BatchSize, ) -> Result<Vec<PersistedEventEnvelope>, Self::Error>

Reads one selected page in ascending delivery order.