Module interchange::avro::envelope_cdc_v2[−][src]

Expand description

Logic for the Avro representation of the CDCv2 protocol.

Structs

Count
Count_DECODER
Decoder

Collected state to decode update batches and progress statements.

MyProgress
MyProgress_DECODER
MyUpdate
MyUpdate_DECODER

Functions

build_schema

Construct the schema for the CDC V2 protocol.

extract_data_columns
make_counts_decoder