Struct SchemaCache 

pub struct SchemaCache { /* private fields */ }

Fetches and caches Avro schemas by schema ID.

The cache is lock-free for reads via DashMap. Each schema is fetched once from the Pub/Sub GetSchema RPC and cached for the lifetime of the handler.

Implementations

impl SchemaCache

pub fn new() -> Self

Creates a new empty schema cache.

pub fn insert(&self, schema_id: String, schema: Schema)

Insert a pre-parsed schema directly.

pub fn len(&self) -> usize

Returns the number of cached schemas.

pub fn is_empty(&self) -> bool

True if no schemas are cached.

pub fn get(&self, schema_id: &str) -> Option<Schema>

Get a schema by ID if it is already in cache.

pub fn parse_and_insert( &self, schema_id: String, schema_json: &str, ) -> Result<Schema>

Parse Avro schema JSON and store it in the cache.

Returns the parsed schema. Called after receiving schema_json from GetSchema.

pub async fn get_or_fetch( &self, schema_id: &str, channel: &Channel, metadata: MetadataMap, ) -> Result<Schema>

Return the schema for schema_id from cache, or fetch it via the GetSchema RPC.

On a cache miss, calls GetSchema using the provided gRPC client and authentication metadata. The fetched schema is parsed, inserted into the cache, and returned.

Errors

• PubSubError::Transport if the GetSchema RPC fails (e.g. schema not found).
• PubSubError::Avro if the returned schema JSON cannot be parsed.

Trait Implementations

impl Clone for SchemaCache

fn clone(&self) -> SchemaCache

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SchemaCache

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

Formats the value using the given formatter.

impl Default for SchemaCache

fn default() -> Self

Returns the “default value” for a type.