Module types 

Types related to the source ingestion pipeline/framework.

Structs

DecodeResult

The output of the decoding operator

Probe

The result of probing an upstream system for its write frontier.

ResumeUppers

The durably committed progress of an ingestion, in the source’s timestamp type.

SharedFuel

Output handles of one operator that share a fuel budget, so that the operator yields back to timely once per MAX_OUTSTANDING_BYTES of its total emission across them.

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

FuelSize

Heap-size estimate used by source operators to drive give_fueled yielding.

SourceRender

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

Type Aliases

StackedCollection