Expand description
PostgreSQL producer and consumer for the cell-based server.
Architecture:
- Producer persists
MEventrows into a durable table. - Consumer replays table rows (catch-up), then follows new inserts via LISTEN/NOTIFY.
Structs§
- Catch
UpStatus - Shared status for startup catch-up.
- Cell
Postgres Consumer - PostgreSQL consumer that replays + tails events.
- Cell
Postgres Producer - PostgreSQL producer — background thread with fail-fast error propagation.
- Persisted
Event - Persisted event row fetched from Postgres.
- Postgres
Config - PostgreSQL configuration.
- Postgres
History Replay Provider - HistoryReplayProvider backed by PostgresHistoryStore.
- Postgres
History Store - Read API for durable event history (windback/replay providers).
- Postgres
Producer Handle - Handle to the PostgreSQL producer.