Module txn_read

Source
Expand description

Interfaces for reading txn shards as well as data shards.

StructsΒ§

CancelWaitOnDrop πŸ”’
Cancels an in-flight wait command when dropped, unless the given tx is yanked before that.
DataRemapEntry
A mapping between the physical upper of a data shard and the largest upper which is known to logically have the same contents.
DataSnapshot
A token exchangeable for a data shard snapshot.
DataSubscribe πŸ”’
Keeps track of a DataRemapEntry for shard data_id.
DataSubscription
An active subscription of DataRemapEntrys for a data shard.
PendingWait πŸ”’
A pending β€œwait” notification that we will complete once the frontier advances far enough.
TxnsRead
A shared TxnsCache running in a task and communicated with over a channel.
TxnsReadTask πŸ”’
TxnsSubscribeTask πŸ”’
Reads txn updates from a Subscribe and forwards them to a TxnsReadTask when receiving a progress update.

EnumsΒ§

DataListenNext
The next action to take in a data shard Listen.
TxnsReadCmd πŸ”’
WaitTs πŸ”’

TraitsΒ§

UnblockRead πŸ”’