Expand description

Logic related to the creation of dataflow sources.

See render_source for more details.

Structs

KV 🔒

After handling metadata insertion, we split streams into key/value parts for convenience

Enums

SourceType 🔒

A type-level enum that holds one of two types of sources depending on their message type

Functions

Convert from streams of DecodeResult to Rows, inserting the Key according to KeyEnvelope

Handle possibly missing key or value portions of messages

Renders complete differential Collections that represent the final source and its errors as requested by the original CREATE SOURCE statement, encapsulated in the passed SourceInstanceDesc.

Convert from streams of DecodeResult to Rows, inserting the Key according to KeyEnvelope