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.

Structs

• KafkaSinkConnection
• KafkaSinkConnectionBuilder
• KafkaSinkConnectionRetention
• KafkaSinkProgressConnection
• MetadataFilled
• MetadataUnfilled
• 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_KafkaSinkConnection 🔒
• _IMPL_ARBITRARY_FOR_KafkaSinkProgressConnection 🔒
• _IMPL_ARBITRARY_FOR_PublishedSchemaInfo 🔒
• _IMPL_ARBITRARY_FOR_SinkEnvelope 🔒
• _IMPL_ARBITRARY_FOR_StorageSinkConnection 🔒

Traits

• StorageSinkDescFillState