Struct mz_avro::schema::SchemaParser

struct SchemaParser {
    named: Vec<Option<NamedSchemaPiece>>,
    indices: BTreeMap<FullName, usize>,
}

Fields

named: Vec<Option<NamedSchemaPiece>>

indices: BTreeMap<FullName, usize>

Implementations

impl SchemaParser

fn parse(self, value: &Value) -> Result<Schema, AvroError>

fn parse_inner( &mut self, default_namespace: &str, value: &Value, ) -> Result<SchemaPieceOrNamed, AvroError>

fn alloc_name(&mut self, fullname: FullName) -> Result<usize, AvroError>

fn insert(&mut self, index: usize, schema: NamedSchemaPiece)

fn parse_named_type( &mut self, type_name: &str, default_namespace: &str, complex: &Map<String, Value>, ) -> Result<usize, AvroError>

fn parse_complex( &mut self, default_namespace: &str, complex: &Map<String, Value>, ) -> Result<SchemaPieceOrNamed, AvroError>

Parse a serde_json::Value representing a complex Avro type into a Schema.

Avro supports “recursive” definition of types. e.g: {“type”: {“type”: “string”}}

fn parse_record( &mut self, default_namespace: &str, complex: &Map<String, Value>, ) -> Result<SchemaPiece, AvroError>

Parse a serde_json::Value representing a Avro record type into a Schema.

fn parse_record_field( &mut self, default_namespace: &str, field: &Map<String, Value>, position: usize, ) -> Result<RecordField, AvroError>

Parse a serde_json::Value into a RecordField.

fn parse_enum( &self, complex: &Map<String, Value>, ) -> Result<SchemaPiece, AvroError>

Parse a serde_json::Value representing a Avro enum type into a Schema.

fn parse_array( &mut self, default_namespace: &str, complex: &Map<String, Value>, ) -> Result<SchemaPiece, AvroError>

Parse a serde_json::Value representing a Avro array type into a Schema.

fn parse_map( &mut self, default_namespace: &str, complex: &Map<String, Value>, ) -> Result<SchemaPiece, AvroError>

Parse a serde_json::Value representing a Avro map type into a Schema.

fn parse_union( &mut self, default_namespace: &str, items: &[Value], ) -> Result<SchemaPiece, AvroError>

Parse a serde_json::Value representing a Avro union type into a Schema.

fn parse_decimal( complex: &Map<String, Value>, ) -> Result<(usize, usize), AvroError>

Parse a serde_json::Value representing a logical decimal type into a Schema.

fn parse_bytes(complex: &Map<String, Value>) -> Result<SchemaPiece, AvroError>

Parse a serde_json::Value representing an Avro bytes type into a Schema.

fn parse_int(complex: &Map<String, Value>) -> Result<SchemaPiece, AvroError>

Parse a serde_json::Value representing an Avro Int type

If the complex type has a connect.name tag (as emitted by Debezium) that matches a Date tag, we specify that the correct schema to use is Date.

fn parse_long(complex: &Map<String, Value>) -> Result<SchemaPiece, AvroError>

Parse a serde_json::Value representing an Avro Int64/Long type

The debezium/kafka types are document at the debezium site, and the avro ones are documented at Avro.

fn from_string(complex: &Map<String, Value>) -> SchemaPiece

fn parse_fixed( &self, _default_namespace: &str, complex: &Map<String, Value>, ) -> Result<SchemaPiece, AvroError>

Parse a serde_json::Value representing a Avro fixed type into a Schema.

Trait Implementations

impl Default for SchemaParser

fn default() -> SchemaParser

Returns the “default value” for a type.