Module mz_storage_types::sinks

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

Modules

• proto_kafka_id_style
  Nested message and enum types in ProtoKafkaIdStyle.
• proto_kafka_sink_connection_v2
  Nested message and enum types in ProtoKafkaSinkConnectionV2.
• proto_kafka_sink_format_type
  Nested message and enum types in ProtoKafkaSinkFormatType.
• proto_s3_sink_format
  Nested message and enum types in ProtoS3SinkFormat.
• proto_sink_envelope
  Nested message and enum types in ProtoSinkEnvelope.
• proto_sink_partition_strategy
  Nested message and enum types in ProtoSinkPartitionStrategy.
• proto_storage_sink_connection
  Nested message and enum types in ProtoStorageSinkConnection.

Structs

• KafkaSinkConnection
• KafkaSinkFormat
• MetadataFilled
• MetadataUnfilled
• ProtoKafkaIdStyle
• ProtoKafkaSinkConnectionV2
• ProtoKafkaSinkFormat
• ProtoKafkaSinkFormatType
• ProtoPersistSinkConnection
• ProtoS3SinkFormat
• ProtoS3UploadInfo
• ProtoSinkEnvelope
• ProtoSinkPartitionStrategy
• ProtoStorageSinkConnection
• ProtoStorageSinkDesc
• S3UploadInfo
  Info required to copy the data to s3.
• StorageSinkDesc
  A sink for updates to a relational collection.

Enums

• KafkaIdStyle
• KafkaSinkCompressionType
• KafkaSinkFormatType
• S3SinkFormat
• SinkEnvelope
• SinkPartitionStrategy
• StorageSinkConnection

Constants

• MAX_S3_SINK_FILE_SIZE
• MIN_S3_SINK_FILE_SIZE

Traits

• StorageSinkDescFillState

Functions

• csr_compat_level_from_proto 🔒
• csr_compat_level_to_proto 🔒