Struct mz_persist_client::schema::SchemaCache

pub(crate) struct SchemaCache<K: Codec, V: Codec, T, D> {
    maps: Arc<SchemaCacheMaps<K, V>>,
    applier: Applier<K, V, T, D>,
    key_migration_by_ids: MigrationCacheMap,
    val_migration_by_ids: MigrationCacheMap,
}

A cache of decoded schemas and schema migrations.

The decoded schemas are a cache of the registry in state, and so are shared process-wide.

On the other hand, the migrations have an N^2 problem and so are per-handle. This also seems reasonable because for any given write handle, the write schema will be the same for all migration entries, and ditto for read handle and read schema.

Fields

maps: Arc<SchemaCacheMaps<K, V>>

applier: Applier<K, V, T, D>

key_migration_by_ids: MigrationCacheMap

val_migration_by_ids: MigrationCacheMap

Implementations

impl<K, V, T, D> SchemaCache<K, V, T, D>

where K: Debug + Codec, V: Debug + Codec, T: Timestamp + Lattice + Codec64 + Sync, D: Semigroup + Codec64,

pub fn new( maps: Arc<SchemaCacheMaps<K, V>>, applier: Applier<K, V, T, D>, ) -> Self

async fn schemas(&self, id: &SchemaId) -> Option<Schemas<K, V>>

fn key_migration( &mut self, write: &Schemas<K, V>, read: &Schemas<K, V>, ) -> Option<Arc<Migration>>

fn val_migration( &mut self, write: &Schemas<K, V>, read: &Schemas<K, V>, ) -> Option<Arc<Migration>>

fn migration<C: Codec>(write: &C::Schema, read: &C::Schema) -> Option<Migration>

async fn get_or_try_init<MK: Clone + Ord, MV: PartialEq + Debug>( &self, map: &SchemaCacheMap<MK, MV>, key: &MK, f: impl Fn(&BTreeMap<SchemaId, EncodedSchemas>) -> Option<MV>, ) -> Option<Arc<MV>>

Trait Implementations

impl<K: Codec, V: Codec, T: Clone, D> Clone for SchemaCache<K, V, T, D>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<K: Debug + Codec, V: Debug + Codec, T: Debug, D: Debug> Debug for SchemaCache<K, V, T, D>

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

Formats the value using the given formatter.

impl<K: Codec, V: Codec, T, D> Drop for SchemaCache<K, V, T, D>

fn drop(&mut self)

Executes the destructor for this type.