Module envelope 

Types related to source envelopes

Structs

NoneEnvelope

UpsertEnvelope

Enums

KeyEnvelope

Whether and how to include the decoded key of a stream in dataflows

SourceEnvelope

SourceEnvelopes describe how to turn a stream of messages from SourceDescs into a differential stream, that is, a stream of (data, time, diff) triples.

UnplannedSourceEnvelope

UnplannedSourceEnvelope is a SourceEnvelope missing some information. This information is obtained in UnplannedSourceEnvelope::desc, where UnplannedSourceEnvelope::into_source_envelope creates a full SourceEnvelope

UpsertStyle

Functions

compute_envelope_value_desc 🔒

Compute the resulting value relation given the decoded value relation and the envelope style. If the ValueErrInline upsert style is used this will add an error column to the beginning of the relation and make all value fields nullable.

match_key_indices 🔒

Computes the indices of the value’s relation description that appear in the key.