Module mz_storage_client::types::sinks

Types and traits related to reporting changing collections out of dataflow.

Modules

proto_kafka_sink_connection

Nested message and enum types in ProtoKafkaSinkConnection.

proto_sink_envelope

Nested message and enum types in ProtoSinkEnvelope.

proto_storage_sink_connection

Nested message and enum types in ProtoStorageSinkConnection.

Macros

try 🔒

try 🔒

try 🔒

try 🔒

try 🔒

try 🔒

try 🔒

try 🔒

try 🔒

try 🔒

try 🔒

try 🔒

try 🔒

try 🔒

try 🔒

try 🔒

try 🔒

try 🔒

try 🔒

try 🔒

try 🔒

try 🔒

try 🔒

try 🔒

try 🔒

try 🔒

try 🔒

try 🔒

Structs

KafkaSinkConnection

KafkaSinkConnectionBuilder

KafkaSinkConnectionRetention

KafkaSinkProgressConnection

MetadataFilled

MetadataUnfilled

ProtoDurableExportMetadata

ProtoKafkaSinkConnection

ProtoKafkaSinkProgressConnection

ProtoPersistSinkConnection

ProtoPublishedSchemaInfo

ProtoSinkAsOf

ProtoSinkEnvelope

ProtoStorageSinkConnection

ProtoStorageSinkDesc

PublishedSchemaInfo

TODO(JLDLaughlin): Documentation.

ScalarWrapper 🔒

ScalarWrapper 🔒

SinkAsOf

StorageSinkDesc

A sink for updates to a relational collection.

__FieldVisitor 🔒

__FieldVisitor 🔒

__FieldVisitor 🔒

__FieldVisitor 🔒

__FieldVisitor 🔒

__FieldVisitor 🔒

__FieldVisitor 🔒

__FieldVisitor 🔒

__FieldVisitor 🔒

__FieldVisitor 🔒

__FieldVisitor 🔒

__FieldVisitor 🔒

__FieldVisitor 🔒

__FieldVisitor 🔒

__Visitor 🔒

__Visitor 🔒

__Visitor 🔒

__Visitor 🔒

__Visitor 🔒

__Visitor 🔒

__Visitor 🔒

__Visitor 🔒

__Visitor 🔒

__Visitor 🔒

__Visitor 🔒

__Visitor 🔒

__Visitor 🔒

__Visitor 🔒

__Visitor 🔒

__Visitor 🔒

Enums

KafkaConsistencyConfig

KafkaSinkFormat

SinkEnvelope

StorageSinkConnection

StorageSinkConnectionBuilder

__Field 🔒

__Field 🔒

__Field 🔒

__Field 🔒

__Field 🔒

__Field 🔒

__Field 🔒

__Field 🔒

__Field 🔒

__Field 🔒

__Field 🔒

__Field 🔒

__Field 🔒

__Field 🔒

Constants

FIELDS 🔒

FIELDS 🔒

FIELDS 🔒

FIELDS 🔒

FIELDS 🔒

FIELDS 🔒

FIELDS 🔒

FIELDS 🔒

FIELDS 🔒

STRUCT_NAME 🔒

STRUCT_NAME 🔒

STRUCT_NAME 🔒

STRUCT_NAME 🔒

STRUCT_NAME 🔒

STRUCT_NAME 🔒

STRUCT_NAME 🔒

STRUCT_NAME 🔒

STRUCT_NAME 🔒

VARIANTS 🔒

VARIANTS 🔒

VARIANTS 🔒

VARIANTS 🔒

VARIANTS 🔒

_IMPL_ARBITRARY_FOR_KafkaSinkProgressConnection 🔒

_IMPL_ARBITRARY_FOR_PublishedSchemaInfo 🔒

_IMPL_ARBITRARY_FOR_SinkEnvelope 🔒

_IMPL_ARBITRARY_FOR_StorageSinkConnection 🔒

Traits

StorageSinkDescFillState

Functions

Inner 🔒

Inner 🔒

ScalarWrapper 🔒

ScalarWrapper 🔒

ScalarWrapper 🔒

ScalarWrapper 🔒

ScalarWrapper 🔒

any_kafka_sink_connection 🔒

Opaque Types

 🔒