Struct HttpSource 

pub struct HttpSource { /* private fields */ }

Implementations

impl HttpSource

pub fn new(cfg: HttpSourceConfig) -> Self

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

Trait Implementations

impl IncrementalSource for HttpSource

type Cursor = BTreeMap<String, HttpUrlCursor>

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.