mz_storage::source

Module types

Expand description

Types related to the source ingestion pipeline/framework.

Modules§

columnation 🔒

Structs§

DecodeResult: The output of the decoding operator
Probe: The result of probing an upstream system for its write frontier.
SignaledFuture
SourceMessage: Source-agnostic wrapper for messages. Each source must implement a conversion to Message.
SourceOutput: A record produced by a source

Enums§

ProgressStatisticsUpdate: An update produced by implementors of SourceRender that presents an aggregated description of the number of offset_committed and offset_known for the given source.

Traits§

SourceRender: Describes a source that can render itself in a timely scope.

Type Aliases§

StackedCollection