Struct schema_registry_converter::blocking::json::JsonEncoder

pub struct JsonEncoder { /* fields omitted */ }

Encoder that works by prepending the correct bytes in order to make it valid schema registry bytes. Ideally you want to make sure the bytes are based on the exact schema used for encoding but you need a protobuf struct that has introspection to make that work, and both protobuf and prost don't support that at the moment.

Implementations

impl JsonEncoder

pub fn new(sr_settings: SrSettings) -> JsonEncoder

Creates a new json encoder

pub fn remove_errors_from_cache(&mut self)

Removes errors from the cache, can be useful to retry failed encodings.

pub fn encode(
    &mut self,
    value: &Value,
    subject_name_strategy: &SubjectNameStrategy
) -> Result<Vec<u8>, SRCError>

Encodes the bytes by adding a few bytes to the message with additional information. The full names is the optional package followed with the message name, and optionally inner messages.

Trait Implementations

impl Debug for JsonEncoder

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

Formats the value using the given formatter.