Skip to main content

Module postgres

Module postgres 

Source
Expand description

PostgreSQL producer and consumer for the cell-based server.

Architecture:

  • Producer persists MEvent rows into a durable table.
  • Consumer replays table rows (catch-up), then follows new inserts via LISTEN/NOTIFY.

Structs§

CatchUpStatus
Shared status for startup catch-up.
CellPostgresConsumer
PostgreSQL consumer that replays + tails events.
CellPostgresProducer
PostgreSQL producer — background thread with fail-fast error propagation.
PersistedEvent
Persisted event row fetched from Postgres.
PostgresConfig
PostgreSQL configuration.
PostgresHistoryReplayProvider
HistoryReplayProvider backed by PostgresHistoryStore.
PostgresHistoryStore
Read API for durable event history (windback/replay providers).
PostgresProducerHandle
Handle to the PostgreSQL producer.