Struct SchemaCache 

pub struct SchemaCache { /* private fields */ }

In-memory cache for OCI-backed CloudEvent schemas.

Implementations

impl SchemaCache

pub fn new() -> Self

Create a new empty schema cache.

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

Get a schema by its ID or Version.

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

Insert or update a schema in the cache.

pub fn start_background_sync(&self, _oci_registry_url: String)

Start a background sync process to fetch schemas from an OCI registry. This is a permissive sync; it runs asynchronously and updates the cache.

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 Default for SchemaCache

fn default() -> Self

Returns the “default value” for a type.