Module mz_persist_client::read

Read capabilities and handles

Structs

• Cursor
  An incremental cursor through a particular shard, returned from ReadHandle::snapshot_cursor.
• LazyPartStats
  Aggregate statistics about data contained in a part.
• LeasedReaderId
  An opaque identifier for a reader of a persist durable TVC (aka shard).
• Listen
  An ongoing subscription of updates to a shard.
• ReadHandle
  A “capability” granting the ability to read the state of some shard at times greater or equal to self.since().
• Since
  Wrapper for Antichain that represents a Since
• Subscribe
  Capable of generating a snapshot of all data at as_of, followed by a listen of all updates.
• UnexpiredReadHandleState 🔒
  State for a read handle that has not been explicitly expired.

Enums

• CursorConsolidator 🔒
• ListenEvent
  Data and progress events of a shard subscription.

Constants

• READER_LEASE_DURATION 🔒
  Length of time after a reader’s last operation after which the reader may be expired.