Struct mz_interchange::avro::schema::SchemaCache

struct SchemaCache {
    cache: BTreeMap<i32, Result<Schema, Error>>,
    ccsr_client: Arc<Client>,
}

Fields

cache: BTreeMap<i32, Result<Schema, Error>>

ccsr_client: Arc<Client>

Implementations

impl SchemaCache

fn new(ccsr_client: Client) -> Result<SchemaCache, Error>

async fn get( &mut self, id: i32, reader_schema: &Schema, ) -> Result<Result<&Schema>>

Looks up the writer schema for ID. If the schema is literally identical to the reader schema, as determined by the reader schema fingerprint that this schema cache was initialized with, returns the schema directly. If not, performs schema resolution on the reader and writer and returns the result.

Trait Implementations

impl Debug for SchemaCache

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

Formats the value using the given formatter.