Module config 

Re-exports

pub use cursor::IncrementalCursorMode;

pub use resolve::parse_file_size;

pub use resolve::resolve_vars;

pub use schema::generate_config_schema_pretty;

Modules

cursor

Incremental cursor configuration (Epic D — cursor policy).

resolve

schema

Layer: Config support (JSON Schema generation, v0.7.3 P0.1/P0.2)

Structs

CdcExportConfig

Per-export CDC settings, required when mode: cdc. The output table, destination, and format come from the export itself; this carries only the CDC-specific knobs (resume + per-engine stream params).

Config

Top-level Rivet configuration root.

DestinationConfig

ExportConfig

MetaColumns

NotificationsConfig

ParquetConfig

Parquet-specific tuning for row group sizing.

QualityConfig

SlackConfig

SourceConfig

TlsConfig

Transport security for the source database connection.

Enums

CdcInitialMode

What the FIRST CDC run does before draining changes.

CompressionProfile

High-level compression preset. Maps to a (CompressionType, level) pair.

CompressionType

DestinationType

ExportMode

FormatType

NotifyEvent

PartitionGranularity

Calendar bucket width for date/timestamp output partitioning (ExportConfig::partition_by). The partition column must be a DATE or TIMESTAMP column; this picks how its range is split into contiguous Hive buckets. It is not a knob for partitioning by arbitrary column values.

RowGroupStrategy

Parquet row group tuning strategy.

SchemaDriftPolicy

SourceEnvironment

Operational environment of the source database — drives the default tuning profile when none is explicitly set. Opt-in: existing configs without environment: continue to use balanced as today.

SourceType

TimeColumnType

TlsMode

TLS enforcement mode, mirroring libpq’s sslmode semantics where possible.

VerifyMode

What to do when structural schema drift is detected (column added, removed, or retyped).

Constants

DEFAULT_MYSQL_SERVER_ID

Default MySQL replica server_id when cdc.server_id is omitted (see DEFAULT_PG_SLOT for why this is a shared const).

DEFAULT_PG_SLOT

Default PostgreSQL logical slot when cdc.slot is omitted — shared by the runner (crate::pipeline’s cdc job) and config validation, so the same-slot conflict check sees the value that will actually be used.

Functions

compression_profile_override_warning

L24: when a compression_profile is set and the user also wrote an explicit codec the profile silently discards, return a one-line warning naming both — otherwise None.

compression_supported

Whether format actually encodes compression on write.