Struct Decoder

pub struct Decoder {
    csr_avro: ConfluentAvroResolver,
    debug_name: String,
    buf1: Vec<u8>,
    row_buf: Row,
}

Manages decoding of Avro-encoded bytes.

Fields

csr_avro: ConfluentAvroResolver

debug_name: String

buf1: Vec<u8>

row_buf: Row

Implementations

impl Decoder

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

Creates a new Decoder

The provided schema is called the “reader schema”, which is the schema that we are expecting to use to decode records. The records may indicate that they are encoded with a different schema; as long as those.

pub async fn decode( &mut self, bytes: &mut &[u8], ) -> Result<Result<Row, Error>, Error>

Decodes Avro-encoded bytes into a Row.

Trait Implementations

impl Debug for Decoder

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

Formats the value using the given formatter.