Struct PgTableSource 

pub struct PgTableSource { /* private fields */ }

Implementations

impl PgTableSource

pub fn new(cfg: PgTableSourceConfig) -> Self

pub async fn iter_documents(&self) -> Result<Vec<Document>>

Trait Implementations

impl IncrementalSource for PgTableSource

type Cursor = PgTableCursor

Per-source cursor type. Must serde-round-trip (so the consumer can persist it as JSON / YAML / a column).

fn empty_cursor(&self) -> Self::Cursor

Initial cursor for a never-synced state. Returned by the consumer’s first call before any documents are emitted.

fn iter_changes_since( &self, cursor: &Self::Cursor, ) -> impl Future<Output = Result<Vec<Document>>> + Send

Stream documents changed since cursor. May return Err(StaleCursorError::new(...).into()) to signal the cursor is too old; consumer should retry with empty_cursor().

fn cursor_from(&self, last_document: &Document) -> Self::Cursor

Per-doc cursor DELTA. See trait docs for merge contract.