Module mz_storage_client::source::persist_source

A source that reads from an a persist shard.

Structs

• FlowControl
  Flow control configuration. TODO(guswynn): move to persist_source

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.