Module mz_storage::source::types
source · Expand description
Types related to the source ingestion pipeline/framework.
Structs§
- The output of the decoding operator
- Source-agnostic wrapper for messages. Each source must implement a conversion to Message.
- A record produced by a source
- A structured error for
SourceReader::get_next_message
implementors.
Enums§
- 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§
- Describes a source that can render itself in a timely scope.