Module mz_storage::types::sinks

source · [−]
Expand description

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.

Structs

KafkaSinkConnection
KafkaSinkConnectionBuilder
KafkaSinkConnectionRetention
KafkaSinkProgressConnection
ProtoDurableExportMetadata
ProtoKafkaSinkConnection
ProtoKafkaSinkProgressConnection
ProtoPersistSinkConnection
ProtoPublishedSchemaInfo
ProtoSinkAsOf
ProtoSinkEnvelope
ProtoStorageSinkConnection
ProtoStorageSinkDesc
PublishedSchemaInfo
TODO(JLDLaughlin): Documentation.
SinkAsOf
StorageSinkDesc
A sink for updates to a relational collection.

Enums

KafkaConsistencyConfig
KafkaSinkFormat
SinkEnvelope
StorageSinkConnection
StorageSinkConnectionBuilder

Constants

_IMPL_ARBITRARY_FOR_KafkaSinkProgressConnection 🔒
_IMPL_ARBITRARY_FOR_PublishedSchemaInfo 🔒
_IMPL_ARBITRARY_FOR_SinkEnvelope 🔒
_IMPL_ARBITRARY_FOR_StorageSinkConnection 🔒

Functions

any_kafka_sink_connection 🔒