Module mz_storage_operators::persist_source

A source that reads from an a persist shard.

Structs

• FlowControl
  Flow control configuration.
• Subtime
  This opaque token represents progress within a timestamp, allowing finer-grained frontier progress than would otherwise be possible.

Traits

• Backpressureable
  A trait representing a type that can be used in backpressure.

Functions

• backpressure
  Apply flow control to the data input, based on the given FlowControl.
• decode_and_mfp
• persist_source
  Creates a new source that reads from a persist shard, distributing the work of reading data to all timely workers.
• persist_source_core
  Creates a new source that reads from a persist shard, distributing the work of reading data to all timely workers.