Module replication 

Incremental replication support.

Structs

ReplicationBind

Declarative binding of the stored bookmark into the outgoing request — “server-side incremental push-down” (#513).

Enums

BindFormat

How the bookmark value is formatted before it is substituted into the ReplicationBind::template.

BindTarget

Where a rendered bookmark is injected into the outgoing request.

ReplicationMethod

Determines how records are replicated from the source.

Constants

BIND_PLACEHOLDER

The placeholder replaced by the formatted bookmark inside a ReplicationBind::template.

Functions

filter_incremental

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

format_bookmark

Format a bookmark value per BindFormat.

format_instant

Format an already-resolved UTC instant per BindFormat. Unlike format_bookmark (which takes an arbitrary scalar and, for BindFormat::Raw, echoes it verbatim), this always has a real instant, so Raw and Iso8601 both emit an RFC 3339 UTC timestamp. Used to render window boundaries (#527).

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).

parse_instant

Parse a bookmark value into a UTC instant (public wrapper over the internal parser; see BindFormat for the accepted forms). Used by datetime window slicing (#527) to resolve the sweep’s start bound from the stored bookmark.