Module projections 

Transactional projection delivery support for PostgreSQL.

Structs

DeliveryIdentityError

Error returned when a delivery identity contains no non-whitespace text.

DeliveryPosition

A positive, source-scoped position in the global delivery sequence.

DeliverySourceId

Stable identity for the event source that owns a delivery sequence.

EventTypeName

Persisted discriminator for an event type selected for projection.

NoopAfterCommit

An after-commit action that has no work to perform.

PersistedEventEnvelope

Opaque persisted event data delivered by a ProjectionSource.

PersistedEventId

Stable persisted event identity, distinct from the delivery position.

Postgres

PostgreSQL database driver.

PostgresProjectionConfig

Settings for a transactional PostgreSQL projection run.

PostgresProjectionSource

PostgreSQL implementation of the strict, lossless projection delivery source.

PostgresProjectionStore

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

ProjectionFailureContext

Public failure information passed to PostgresProjector::on_error.

ProjectionProgress

Durable progress committed beside a projection’s read-model effects.

ProjectionRetryPolicy

Controls retry behavior after an application requests a retry.

ProjectionSelection

Stable selection contract used to read persisted events for a projection.

ProjectionSelectionId

Stable application-supplied identity for a projection selection contract.

ProjectorName

Stable application-supplied identity for a transactional projector.

TokioProjectionPollSleeper

Default continuous polling sleeper backed by tokio::time::sleep.

TokioProjectionRetrySleeper

Default retry sleeper backed by tokio::time::sleep.

Transaction

An in-progress database transaction or savepoint.

Enums

DeliveryUpperBound

Optional inclusive upper bound for a delivery page.

PostgresProjectionMode

Selects whether a runner stops at its initial catch-up frontier or keeps polling.

PostgresProjectionSourceError

Errors returned by PostgresProjectionSource.

ProjectionConfigurationError

Configuration rejected before a runner is started.

ProjectionFailureDecision

Decision made by an application after its event effect failed.

ProjectionResetAndReplayError

Failures from the reset-and-replay convenience operation.

ProjectionResetError

Failures from a coordinated basic reset.

ProjectionRunOutcome

Observable result of a transactional projection run.

ProjectionSelectionError

Error returned when a projection selection is structurally invalid.

ProjectionStreamFilter

Stream selector applied to a projection source read.

TransactionalProjectionError

Terminal failures from a transactional projection run.

Traits

AfterCommit

Work that is safe to perform only after the read-model transaction commits.

PostgresProjectionReset

Application-owned read-model reinitialization performed in the leader transaction.

PostgresProjector

Applies decoded events through the transaction owned by the PostgreSQL runner.

ProjectionPollSleeper

Asynchronous delay used while a continuous projection is caught up.

ProjectionRetrySleeper

Asynchronous delay used between transactional projection retry attempts.

ProjectionSource

Backend-independent source of lossless, globally ordered persisted events.

Functions

reset_and_replay_transactional_projection

Reinitializes a projection and replays it while retaining named leadership.

reset_transactional_projection

Reinitializes a projection and deletes matching progress under named leadership.

run_transactional_projection

Starts a PostgreSQL transactional projection.

Type Aliases

BoxedProjectionError

Type-erased failure source retained by the stable runner error boundary.