Struct interchange::avro::envelope_cdc_v2::Decoder [−][src]
pub struct Decoder;
Expand description
Collected state to decode update batches and progress statements.
Trait Implementations
fn union_branch<'a, R: AvroRead, D: AvroDeserializer>(
self,
idx: usize,
_n_variants: usize,
_null_variant: Option<usize>,
deserializer: D,
r: &'a mut R
) -> Result<Self::Out, AvroError>
fn decimal<'avro_macro_lifetime, R: AvroRead>(
self,
_precision: usize,
_scale: usize,
_r: ValueOrReader<'avro_macro_lifetime, &'avro_macro_lifetime [u8], R>
) -> Result<Self::Out, Error>
fn bytes<'avro_macro_lifetime, R: AvroRead>(
self,
_r: ValueOrReader<'avro_macro_lifetime, &'avro_macro_lifetime [u8], R>
) -> Result<Self::Out, Error>
fn string<'avro_macro_lifetime, R: AvroRead>(
self,
_r: ValueOrReader<'avro_macro_lifetime, &'avro_macro_lifetime str, R>
) -> Result<Self::Out, Error>
fn json<'avro_macro_lifetime, R: AvroRead>(
self,
_r: ValueOrReader<'avro_macro_lifetime, &'avro_macro_lifetime Value, R>
) -> Result<Self::Out, Error>
fn uuid<'avro_macro_lifetime, R: AvroRead>(
self,
_r: ValueOrReader<'avro_macro_lifetime, &'avro_macro_lifetime [u8], R>
) -> Result<Self::Out, Error>
fn fixed<'avro_macro_lifetime, R: AvroRead>(
self,
_r: ValueOrReader<'avro_macro_lifetime, &'avro_macro_lifetime [u8], R>
) -> Result<Self::Out, Error>
fn map_decoder<T, F>(self, f: F) -> MappingDecoder<T, Self::Out, Self, F> where
F: FnMut(Self::Out) -> Result<T, Error>,
Auto Trait Implementations
impl RefUnwindSafe for Decoder
impl UnwindSafe for Decoder
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more