Module shard_source

A source that reads from a persist shard.

Structs

• LeaseManager 🔒

Enums

• 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 🔒