Module envelope

Types related to source envelopes

Modules

proto_key_envelope

Nested message and enum types in ProtoKeyEnvelope.

proto_source_envelope

Nested message and enum types in ProtoSourceEnvelope.

proto_upsert_style

Nested message and enum types in ProtoUpsertStyle.

Structs

NoneEnvelope

ProtoKeyEnvelope

ProtoNoneEnvelope

ProtoSourceEnvelope

ProtoUpsertEnvelope

ProtoUpsertStyle

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.