Struct schema_registry_converter::blocking::proto_decoder::ProtoDecoder

pub struct ProtoDecoder { /* fields omitted */ }

Implementations

impl ProtoDecoder

pub fn new(sr_settings: SrSettings) -> ProtoDecoder

Creates a new decoder which will use the supplied url used in creating the sr settings to fetch the schema's since the schema needed is encoded in the binary, independent of the SubjectNameStrategy we don't need any additional data. It's possible for recoverable errors to stay in the cache, when a result comes back as an error you can use remove_errors_from_cache to clean the cache, keeping the correctly fetched schema's

pub fn remove_errors_from_cache(&mut self)

Remove al the errors from the cache, you might need to/want to run this when a recoverable error is met. Errors are also cashed to prevent trying to get schema's that either don't exist or can't be parsed.

pub fn decode(&mut self, bytes: Option<&[u8]>) -> Result<Value, SRCError>

Decodes bytes into a value. The choice to use Option<&u8> as type us made so it plays nice with the BorrowedMessage struct from rdkafka, for example if we have m: &'a BorrowedMessage and decoder: &'a mut Decoder we can use decoder.decode(m.payload()) to decode the payload or decoder.decode(m.key()) to get the decoded key.

Trait Implementations

impl Debug for ProtoDecoder

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

Formats the value using the given formatter.