Struct schema_registry_converter::async_impl::proto_raw::ProtoRawDecoder

pub struct ProtoRawDecoder<'a> { /* fields omitted */ }

Implementations

impl<'a> ProtoRawDecoder<'a>

pub fn new(sr_settings: SrSettings) -> ProtoRawDecoder<'a>

Creates a new decoder which will use the supplied url 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 async fn decode(
    &mut self,
    bytes: Option<&[u8]>
) -> Result<Option<RawDecodeResult>, SRCError>

Reads the bytes to get the name, and gives back the data bytes.

Trait Implementations

impl<'a> Debug for ProtoRawDecoder<'a>

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

Formats the value using the given formatter.