Module persist_source

A source that reads from an a persist shard.

Structs

FlowControl

Flow control configuration.

PendingWork 🔒

Pending work to read from fetched parts

Subtime

This opaque token represents progress within a timestamp, allowing finer-grained frontier progress than would otherwise be possible.

Enums

PendingPart 🔒

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

filter_result 🔒

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 Aliases

RefinedScope 🔒