Module mz_storage::source::types

source ·
Expand description

Types related to the source ingestion pipeline/framework.

Structs§

  • DecodeResult
    The output of the decoding operator
  • SourceMessage
    Source-agnostic wrapper for messages. Each source must implement a conversion to Message.
  • SourceOutput
    A record produced by a source
  • SourceReaderError
    A structured error for SourceReader::get_next_message implementors.

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.