Struct mz_interchange::avro::ConfluentAvroResolver

pub struct ConfluentAvroResolver {
    reader_schema: Schema,
    writer_schemas: Option<SchemaCache>,
    confluent_wire_format: bool,
}

Fields

reader_schema: Schema

writer_schemas: Option<SchemaCache>

confluent_wire_format: bool

Implementations

impl ConfluentAvroResolver

pub fn new( reader_schema: &str, ccsr_client: Option<Client>, confluent_wire_format: bool, ) -> Result<Self>

pub async fn resolve<'a, 'b>( &'a mut self, bytes: &'b [u8], ) -> Result<Result<(&'b [u8], &'a Schema, Option<i32>)>>

Trait Implementations

impl Debug for ConfluentAvroResolver

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.