Module errors

Modules

boxed_str 🔒

columnation 🔒

proto_dataflow_error

Nested message and enum types in ProtoDataflowError.

proto_decode_error_kind

Nested message and enum types in ProtoDecodeErrorKind.

proto_envelope_error_v1

Nested message and enum types in ProtoEnvelopeErrorV1.

proto_source_error_details

Nested message and enum types in ProtoSourceErrorDetails.

proto_upsert_error

Nested message and enum types in ProtoUpsertError.

Structs

DecodeError

The underlying data was not decodable in the format we expected: eg. invalid JSON or Avro data that doesn’t match a schema.

ProtoDataflowError

ProtoDecodeError

ProtoDecodeErrorKind

ProtoEnvelopeErrorV1

The “V1” suffix was requested by the storage team, since they might want to repurpose/modify this field in the future.

ProtoSourceError

ProtoSourceErrorDetails

ProtoUpsertError

ProtoUpsertNullKeyError

ProtoUpsertValueError

SourceError

Source-wide durable errors; for example, a replication log being meaningless or corrupted. This should not include transient source errors, like connection issues or misconfigurations.

UpsertNullKeyError

A source contained a record with a NULL key, which we don’t support.

UpsertValueError

An error from a value in an upsert source. The corresponding key is included, allowing us to reconstruct their entry in the upsert map upon restart.

Enums

ContextCreationError

An error returned by KafkaConnection::create_with_context.

CsrConnectError

An error returned by CsrConnection::connect.

DataflowError

An error that’s destined to be presented to the user in a differential dataflow collection. For example, a divide by zero will be visible in the error collection for a particular row.

DecodeErrorKind

EnvelopeError

Errors arising during envelope processing.

SourceErrorDetails

UpsertError

An error that can be retracted by a future message using upsert logic.

Traits

ContextCreationErrorExt

An extension trait for Result<T, E> that makes producing ContextCreationErrors easier.