#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoStorageSinkDesc {
#[prost(message, optional, tag = "1")]
pub from: ::core::option::Option<::mz_repr::global_id::ProtoGlobalId>,
#[prost(message, optional, tag = "2")]
pub from_desc: ::core::option::Option<::mz_repr::ProtoRelationDesc>,
#[prost(message, optional, tag = "3")]
pub connection: ::core::option::Option<ProtoStorageSinkConnection>,
#[prost(message, optional, tag = "4")]
pub envelope: ::core::option::Option<ProtoSinkEnvelope>,
#[prost(message, optional, tag = "6")]
pub from_storage_metadata: ::core::option::Option<
super::controller::ProtoCollectionMetadata,
>,
#[prost(string, optional, tag = "7")]
pub status_id: ::core::option::Option<::prost::alloc::string::String>,
#[prost(message, optional, tag = "11")]
pub as_of: ::core::option::Option<::mz_repr::antichain::ProtoU64Antichain>,
#[prost(bool, tag = "12")]
pub with_snapshot: bool,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoSinkEnvelope {
#[prost(oneof = "proto_sink_envelope::Kind", tags = "1, 2")]
pub kind: ::core::option::Option<proto_sink_envelope::Kind>,
}
pub mod proto_sink_envelope {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Kind {
#[prost(message, tag = "1")]
Debezium(()),
#[prost(message, tag = "2")]
Upsert(()),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoStorageSinkConnection {
#[prost(oneof = "proto_storage_sink_connection::Kind", tags = "2")]
pub kind: ::core::option::Option<proto_storage_sink_connection::Kind>,
}
pub mod proto_storage_sink_connection {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Kind {
#[prost(message, tag = "2")]
KafkaV2(super::ProtoKafkaSinkConnectionV2),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoKafkaSinkFormat {
#[prost(oneof = "proto_kafka_sink_format::Kind", tags = "2, 4")]
pub kind: ::core::option::Option<proto_kafka_sink_format::Kind>,
}
pub mod proto_kafka_sink_format {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoKafkaSinkAvroFormat {
#[prost(string, optional, tag = "1")]
pub key_schema: ::core::option::Option<::prost::alloc::string::String>,
#[prost(string, tag = "2")]
pub value_schema: ::prost::alloc::string::String,
#[prost(message, optional, tag = "3")]
pub csr_connection: ::core::option::Option<
super::super::connections::ProtoCsrConnection,
>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Kind {
#[prost(message, tag = "2")]
Json(()),
#[prost(message, tag = "4")]
Avro(ProtoKafkaSinkAvroFormat),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoKafkaSinkConnectionV2 {
#[prost(message, optional, tag = "1")]
pub connection_id: ::core::option::Option<::mz_repr::global_id::ProtoGlobalId>,
#[prost(message, optional, tag = "2")]
pub connection: ::core::option::Option<super::connections::ProtoKafkaConnection>,
#[prost(string, tag = "3")]
pub topic: ::prost::alloc::string::String,
#[prost(message, optional, tag = "4")]
pub key_desc_and_indices: ::core::option::Option<
proto_kafka_sink_connection_v2::ProtoKeyDescAndIndices,
>,
#[prost(message, optional, tag = "5")]
pub relation_key_indices: ::core::option::Option<
proto_kafka_sink_connection_v2::ProtoRelationKeyIndicesVec,
>,
#[prost(message, optional, tag = "6")]
pub value_desc: ::core::option::Option<::mz_repr::ProtoRelationDesc>,
#[prost(message, optional, tag = "11")]
pub format: ::core::option::Option<ProtoKafkaSinkFormat>,
#[prost(message, optional, tag = "19")]
pub progress_group_id: ::core::option::Option<ProtoKafkaIdStyle>,
#[prost(message, optional, tag = "20")]
pub transactional_id: ::core::option::Option<ProtoKafkaIdStyle>,
#[prost(
oneof = "proto_kafka_sink_connection_v2::CompressionType",
tags = "14, 15, 16, 17, 18"
)]
pub compression_type: ::core::option::Option<
proto_kafka_sink_connection_v2::CompressionType,
>,
}
pub mod proto_kafka_sink_connection_v2 {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoKeyDescAndIndices {
#[prost(message, optional, tag = "1")]
pub desc: ::core::option::Option<::mz_repr::ProtoRelationDesc>,
#[prost(uint64, repeated, tag = "2")]
pub indices: ::prost::alloc::vec::Vec<u64>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoRelationKeyIndicesVec {
#[prost(uint64, repeated, tag = "1")]
pub relation_key_indices: ::prost::alloc::vec::Vec<u64>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum CompressionType {
#[prost(message, tag = "14")]
None(()),
#[prost(message, tag = "15")]
Gzip(()),
#[prost(message, tag = "16")]
Snappy(()),
#[prost(message, tag = "17")]
Lz4(()),
#[prost(message, tag = "18")]
Zstd(()),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoKafkaIdStyle {
#[prost(oneof = "proto_kafka_id_style::Kind", tags = "1, 2")]
pub kind: ::core::option::Option<proto_kafka_id_style::Kind>,
}
pub mod proto_kafka_id_style {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoKafkaIdStylePrefix {
#[prost(string, optional, tag = "1")]
pub prefix: ::core::option::Option<::prost::alloc::string::String>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Kind {
#[prost(message, tag = "1")]
Prefix(ProtoKafkaIdStylePrefix),
#[prost(message, tag = "2")]
Legacy(()),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoPersistSinkConnection {
#[prost(message, optional, tag = "1")]
pub value_desc: ::core::option::Option<::mz_repr::ProtoRelationDesc>,
#[prost(message, optional, tag = "2")]
pub storage_metadata: ::core::option::Option<
super::controller::ProtoCollectionMetadata,
>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoS3UploadInfo {
#[prost(string, tag = "1")]
pub prefix: ::prost::alloc::string::String,
#[prost(uint64, tag = "2")]
pub max_file_size: u64,
#[prost(message, optional, tag = "3")]
pub desc: ::core::option::Option<::mz_repr::ProtoRelationDesc>,
#[prost(message, optional, tag = "4")]
pub format: ::core::option::Option<::mz_pgcopy::ProtoCopyFormatParams>,
}