Struct mz_avro::reader::SchemaResolver
source · pub struct SchemaResolver<'a> {
pub named: Vec<Option<NamedSchemaPiece>>,
pub indices: BTreeMap<FullName, usize>,
pub human_readable_field_path: Vec<String>,
pub current_human_readable_path_start: usize,
pub writer_to_reader_names: BTreeMap<usize, usize>,
pub reader_to_writer_names: BTreeMap<usize, usize>,
pub reader_to_resolved_names: BTreeMap<usize, usize>,
pub reader_fullnames: BTreeMap<usize, &'a FullName>,
pub reader_schema: &'a Schema,
}
Fields§
§named: Vec<Option<NamedSchemaPiece>>
§indices: BTreeMap<FullName, usize>
§human_readable_field_path: Vec<String>
§current_human_readable_path_start: usize
§writer_to_reader_names: BTreeMap<usize, usize>
§reader_to_writer_names: BTreeMap<usize, usize>
§reader_to_resolved_names: BTreeMap<usize, usize>
§reader_fullnames: BTreeMap<usize, &'a FullName>
§reader_schema: &'a Schema
Implementations§
source§impl<'a> SchemaResolver<'a>
impl<'a> SchemaResolver<'a>
fn resolve_named( &mut self, writer: &Schema, reader: &Schema, writer_index: usize, reader_index: usize, ) -> Result<SchemaPiece, AvroError>
pub fn resolve( &mut self, writer: SchemaNodeOrNamed<'_>, reader: SchemaNodeOrNamed<'_>, ) -> Result<SchemaPieceOrNamed, AvroError>
fn get_current_human_readable_path(&self) -> String
Auto Trait Implementations§
impl<'a> Freeze for SchemaResolver<'a>
impl<'a> RefUnwindSafe for SchemaResolver<'a>
impl<'a> Send for SchemaResolver<'a>
impl<'a> Sync for SchemaResolver<'a>
impl<'a> Unpin for SchemaResolver<'a>
impl<'a> UnwindSafe for SchemaResolver<'a>
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> FutureExt for T
impl<T> FutureExt for T
source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request