Skip to main content

cdc_envelope_schema

laminar_connectors::cdc::postgres::schema

Function cdc_envelope_schema 

Source 
pub fn cdc_envelope_schema() -> SchemaRef
Expand description

Builds the CDC envelope schema used by PostgresCdcSource.

This schema wraps change events in a uniform envelope with metadata columns, making it compatible with any table structure.