Module mz_storage::source::types

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