Struct CdcExportConfig 

pub struct CdcExportConfig {
    pub checkpoint: Option<String>,
    pub until_current: bool,
    pub max_events: Option<usize>,
    pub rollover: Option<usize>,
    pub rollover_memory_mb: Option<usize>,
    pub server_id: Option<u32>,
    pub slot: Option<String>,
    pub capture_instance: Option<String>,
}

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

Fields

checkpoint: Option<String>

Persist/resume the source log position to this file. Omit to tail from the current position without checkpointing.

until_current: bool

Catch up to the source’s current end and exit (a bounded run), instead of streaming indefinitely — ideal for a scheduler. For MySQL this is a non-blocking binlog dump; PostgreSQL / SQL Server already drain-and-exit.

max_events: Option<usize>

Stop after N change events (default: until end of stream / interrupted).

rollover: Option<usize>

Rows per output part file (default 10000). A part also rolls at a transaction boundary, so it never splits a transaction.

rollover_memory_mb: Option<usize>

Roll a part once its buffered changes reach this many MB, whichever comes first with rollover. Caps the in-memory buffer and the part file size by bytes instead of a fixed row count — predictable for tables with wide (large JSON / blob) rows, mirroring the batch path’s batch_size_memory_mb.

server_id: Option<u32>

MySQL replica server-id for the binlog connection (default 4271; must be distinct from the source’s and any other replica).

slot: Option<String>

PostgreSQL logical replication slot name (default rivet_slot).

capture_instance: Option<String>

SQL Server CDC capture instance, e.g. dbo_orders — required for sqlserver:// sources.

Trait Implementations

impl Clone for CdcExportConfig

fn clone(&self) -> CdcExportConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CdcExportConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for CdcExportConfig

fn default() -> CdcExportConfig

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for CdcExportConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl JsonSchema for CdcExportConfig

fn schema_name() -> Cow<'static, str>

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn inline_schema() -> bool

Whether JSON Schemas generated for this type should be included directly in parent schemas, rather than being re-used where possible using the $ref keyword.

impl Serialize for CdcExportConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.