Re-exports§
pub use parquet_parser::ParquetParser;
Modules§
- access_
builder 🔒 - additional_
columns - avro 🔒
- bytes_
parser 🔒 - canal 🔒
- chunk_
builder 🔒 - config 🔒
- csv_
parser 🔒 - debezium 🔒
- json_
parser 🔒 - maxwell 🔒
- mysql 🔒
- parquet_
parser - plain_
parser - postgres 🔒
- protobuf 🔒
- scalar_
adapter - schema_
change - simd_
json_ parser - sql_
server 🔒 - unified 🔒
- Unified parsers for both normal events or CDC events of multiple message formats
- upsert_
parser 🔒 - utils 🔒
Structs§
- Avro
Parser Config - Avro
Properties - Bytes
Properties - Canal
Json Parser - Common
Parser Config - CsvProperties
- Debezium
Avro Access Builder - Debezium
Avro Parser Config - Debezium
Mongo Json Parser - Debezium
Parser - Debezium
Props - Json
Access - Json
Access Builder - Json
Properties - Message
Meta - The meta data of the original message for a row writer.
- Mongo
Properties - Parser
Config - Note: this is created in
SourceReader::build_stream - Protobuf
Access Builder - Protobuf
Parser Config - Protobuf
Properties - Scalar
Impl Tiberius Wrapper - Source
Stream Chunk Builder - A builder for building a [
StreamChunk] fromSourceColumnDesc. - Source
Stream Chunk RowWriter SourceStreamChunkRowWriteris responsible to write one or more records to the [StreamChunk], where each contains either one row (Insert/Delete) or two rows (Update) that can be written atomically.- Specific
Parser Config
Enums§
- Access
Error - Byte
Stream Source Parser Impl - The entrypoint of parsing. It parses
SourceMessagestream (byte stream) into [StreamChunk] stream. Used bycrate::source::into_chunk_stream. - Encoding
Properties - Encoding
Type - Parse
Result - The result of parsing a message.
- Parser
Format - Protocol
Properties - Schema
Location - WIP: may cover protobuf and json schema later.
- Timestamptz
Handling - Transaction
Control - Transaction control message. Currently only used by Debezium messages.
Constants§
Traits§
- Access
- Access to a field in the data structure. Created by
AccessBuilder. - Byte
Stream Source Parser ByteStreamSourceParseris the entrypoint abstraction for parsing messages. It consumes bytes of one individual message and produces parsed records.- Source
Parser Into Stream Ext
Functions§
- fetch_
json_ schema_ and_ map_ to_ columns - from_
protobuf_ value - mysql_
datum_ to_ rw_ datum - The decoding result can be interpreted as follows: Ok(value) => The value was found and successfully decoded. Err(error) => The value was found but could not be decoded, either because it was not supported, or there was an error during conversion.
- mysql_
row_ to_ owned_ row - parse_
message_ 🔒stream - pb_
schema_ to_ fields - postgres_
row_ to_ owned_ row - sql_
server_ row_ to_ owned_ row