Struct MemorySchemaCache 

pub struct MemorySchemaCache { /* private fields */ }

The default SchemaCache: in-process maps governed by a SchemaCachePolicy.

Implementations

impl MemorySchemaCache

pub fn new(policy: SchemaCachePolicy) -> Self

A cache under policy.

pub fn policy(&self) -> SchemaCachePolicy

The policy this cache runs under.

Trait Implementations

impl Debug for MemorySchemaCache

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

Formats the value using the given formatter.

impl SchemaCache for MemorySchemaCache

fn schema(&self, id: u32) -> Option<Arc<RegisteredSchema>>

The schema remembered under id, if any.

fn subject(&self, subject: &str) -> Option<Arc<RegisteredSchema>>

The schema remembered as subject’s current version, if any and still current.

fn store(&self, subject: Option<&str>, schema: &Arc<RegisteredSchema>)

Takes a freshly resolved schema, and the subject it was resolved through when it was one.

fn evicted_ids(&self) -> Vec<u32>

The ids this cache has dropped since the last call, so forms derived from them (a parsed Avro schema, a compiled descriptor pool) can be dropped with them.