Struct mz_txn_wal::txns::DataHandles

pub(crate) struct DataHandles<K: Codec, V: Codec, T, D> {
    pub(crate) dyncfgs: ConfigSet,
    pub(crate) client: Arc<PersistClient>,
    data_write_for_apply: BTreeMap<ShardId, DataWriteApply<K, V, T, D>>,
    data_write_for_commit: BTreeMap<ShardId, DataWriteCommit<K, V, T, D>>,
}

A helper to make a more targeted mutable borrow of self.

Fields

dyncfgs: ConfigSet

client: Arc<PersistClient>

data_write_for_apply: BTreeMap<ShardId, DataWriteApply<K, V, T, D>>

See DataWriteApply.

This is lazily populated with the set of shards touched by apply_le.

data_write_for_commit: BTreeMap<ShardId, DataWriteCommit<K, V, T, D>>

See DataWriteCommit.

This contains the set of data shards registered but not yet forgotten with this particular write handle.

NB: In the common case, this and _for_apply will contain the same set of shards, but this is not required. A shard can be in either and not the other.

Implementations

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

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

async fn open_data_write_for_apply( &self, data_id: ShardId, ) -> DataWriteApply<K, V, T, D>

pub(crate) async fn take_write_for_apply( &mut self, data_id: &ShardId, ) -> DataWriteApply<K, V, T, D>

pub(crate) fn put_write_for_apply( &mut self, data_write: DataWriteApply<K, V, T, D>, )

pub(crate) fn take_write_for_commit( &mut self, data_id: &ShardId, ) -> Option<DataWriteCommit<K, V, T, D>>

pub(crate) fn put_write_for_commit( &mut self, data_write: DataWriteCommit<K, V, T, D>, )

Trait Implementations

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

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

Formats the value using the given formatter.