Enum PartMigration

pub(crate) enum PartMigration<K: Codec, V: Codec> {
    SameSchema {
        both: Schemas<K, V>,
    },
    Codec {
        read: Schemas<K, V>,
    },
    Either {
        write: Schemas<K, V>,
        read: Schemas<K, V>,
        key_migration: Arc<Migration>,
        val_migration: Arc<Migration>,
    },
}

Variants

SameSchema

No-op!

Fields

both: Schemas<K, V>

Codec

This part predates writing down schema ids, so we have to decode and potentially migrate it to the target schema via the legacy Codec path.

Fields

read: Schemas<K, V>

Either

We have both write and read schemas, and they don’t match.

Fields

write: Schemas<K, V>

read: Schemas<K, V>

key_migration: Arc<Migration>

val_migration: Arc<Migration>

Implementations

impl<K, V> PartMigration<K, V>

where K: Debug + Codec, V: Debug + Codec,

pub(crate) async fn new<T, D>( write: Option<SchemaId>, read: Schemas<K, V>, schema_cache: &mut SchemaCache<K, V, T, D>, ) -> Result<Self, Schemas<K, V>>

where T: Timestamp + Lattice + Codec64 + Sync, D: Semigroup + Codec64,

impl<K: Codec, V: Codec> PartMigration<K, V>

pub(crate) fn codec_read(&self) -> &Schemas<K, V>

Trait Implementations

impl<K: Codec, V: Codec> Clone for PartMigration<K, V>

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> Debug for PartMigration<K, V>

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

Formats the value using the given formatter.