Module read

Source
Expand description

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.