Module shard_source

A source that reads from a persist shard.

Structs

LeaseManager 🔒

Enums

ErrorHandler

Many dataflows, including the Persist source, encounter errors that are neither data-plane errors (a la SourceData) nor bugs. This includes:

FilterResult

The result of applying an MFP to a part, if we know it.

SnapshotMode

An enum describing whether a snapshot should be emitted

Functions

shard_source

Creates a new source that reads from a persist shard, distributing the work of reading data to all timely workers.

shard_source_descs 🔒

shard_source_fetch 🔒