Module interchange::avro[][src]

Re-exports

pub use envelope_cdc_v2 as cdc_v2;

Modules

decode
encode
envelope_cdc_v2

Logic for the Avro representation of the CDCv2 protocol.

envelope_debezium

Envelope: Debezium

schema

Structs

ConfluentAvroResolver
DebeziumDecodeState

Additional context needed for decoding Debezium-formatted data.

Decoder

Manages decoding of Avro-encoded bytes.

DiffPair
Encoder

Manages encoding of Avro-encoded bytes.

Enums

DebeziumDeduplicationStrategy

Ordered means we can trust Debezium high water marks

EnvelopeType

Functions

column_names_and_types

Extracts deduplicated column names and types from a relation description.

encode_datums_as_avro

Encodes a sequence of Datum as Avro (key and value), using supplied column names and types.

encode_debezium_transaction_unchecked
extract_row
get_debezium_transaction_schema
is_null
parse_schema
validate_key_schema

Validates an Avro key schema for use as a source.

validate_value_schema

Converts an Apache Avro schema into a list of column names and types.