flusso-sources-core 0.3.0

Change-capture and document-builder abstractions for flusso sources.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

//! Change data capture: *what changed?*
//!
//! A [`ChangeCapture`] mechanism yields a stream of thin [`Change`]s — each a
//! [`ChangeEvent`] (table and key, never row contents) paired with an [`Ack`].
//! This module is self-contained: it knows nothing about how documents are
//! built from a change.
//!
//! The design rests on three decisions:
//!
//! 1. **Resume is internal.** No position or cursor crosses this API. Each
//!    mechanism owns its resume state — trivially so for WAL, where the
//!    replication slot is durable on the server.
//! 2. **Live and snapshot are separate capabilities.**
//!    [`ChangeCapture::live`] streams ongoing changes;
//!    [`ChangeCapture::snapshot`] reads current rows for a backfill. The engine
//!    decides whether a backfill is needed (by asking the sink) and orchestrates
//!    the two — the mechanism just exposes the capabilities.
//! 3. **Events are thin.** A change names a row; it does not carry its data, so
//!    every mechanism looks identical and nothing depends on `REPLICA IDENTITY`.

mod ack;
mod capture;
mod change;

pub use ack::*;
pub use capture::*;
pub use change::*;