Module mz_txn_wal::txn_read

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 🔒