Module replication 

Available on crate feature source-rest only.

Incremental replication support.

Enums

ReplicationMethod

Determines how records are replicated from the source.

Functions

filter_incremental

Filter records to only those where record[key] > start.

json_gt

Total-order “greater than” over JSON values, using the same comparison filter_incremental applies to replication keys (numbers numerically, strings lexicographically — so RFC3339 timestamps order correctly). Public so callers bounding a replay window (e.g. faucet backfill --to-bookmark) compare exactly like the incremental filter does.

max_replication_value

Return the maximum value of record[key] across all records, if any.

max_value

Return the larger of two replication values using the same ordering as max_replication_value (string lexicographic, numeric for numbers, falling back to a on type mismatch).