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
• PendingWork 🔒
  Pending work to read from fetched parts
• PersistSourceDataStats 🔒

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
• downcast_stats 🔒
• filter_may_match 🔒
• 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.

Type Definitions

• RefinedScope 🔒