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
//! Document construction: *what to build?*
//!
//! A [`DocumentBuilder`] turns a changed row — named only by its table and
//! [`RowKey`](crate::RowKey) — into the target documents it affects, then
//! assembles each one. This module is self-contained: it takes neutral
//! primitives, not a [`cdc::Change`](crate::cdc::Change), so it has no
//! dependency on how changes are captured. The engine reads a change from the
//! capture stream and passes its table and key here.

mod builder;

pub use builder::*;