Module stream 

EventStream / StreamFactory implementations over a replication connection.

Structs

PgEventStream

PgStreamFactory

Opens replication streams for run, verifying source identity and slot continuity.

Functions

verify_slot_continuity

Fail with ResyncRequired whenever the slot cannot deliver every transaction after the checkpoint, or with Preflight when it is the wrong kind of slot.