Module reader 

Structs

PgCursor

PgCursorAcker

Source-side acker. Holds shared cursor state so an unacked message is re-emitted on the next stream poll instead of being dropped.

PgReader

PgReaderConfig

PgSubscription

Type Aliases

PgCoordinatedAcker

Standalone PartitionLease-fenced acker over the raw PgCursor. This alias matches the simple shape used by code paths that wire a coordinator outside of CoordinatedReader::read. The stream-emitted acker after the shared-fetch rewrite is PgCoordinatedStreamAcker.

PgCoordinatedCursor

PgCoordinatedReader

PgCoordinatedReaderConfig

PgCoordinatedStream

PgCoordinatedStreamAcker

Acker carried on every message emitted by PgCoordinatedReader.

PgCoordinatedSubscription

PgPartitionedCursor