#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoMzOffset {
    #[prost(uint64, tag = "1")]
    pub offset: u64,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoIncludedColumnSource {
    #[prost(oneof = "proto_included_column_source::Kind", tags = "1, 2, 3, 4, 5")]
    pub kind: ::core::option::Option<proto_included_column_source::Kind>,
}
/// Nested message and enum types in `ProtoIncludedColumnSource`.
pub mod proto_included_column_source {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Kind {
        #[prost(message, tag = "1")]
        Partition(()),
        #[prost(message, tag = "2")]
        Offset(()),
        #[prost(message, tag = "3")]
        Timestamp(()),
        #[prost(message, tag = "4")]
        Topic(()),
        #[prost(message, tag = "5")]
        Headers(()),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoKeyEnvelope {
    #[prost(oneof = "proto_key_envelope::Kind", tags = "1, 2, 3")]
    pub kind: ::core::option::Option<proto_key_envelope::Kind>,
}
/// Nested message and enum types in `ProtoKeyEnvelope`.
pub mod proto_key_envelope {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Kind {
        #[prost(message, tag = "1")]
        None(()),
        #[prost(message, tag = "2")]
        Flattened(()),
        #[prost(string, tag = "3")]
        Named(::prost::alloc::string::String),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoTimeline {
    #[prost(oneof = "proto_timeline::Kind", tags = "1, 2, 3")]
    pub kind: ::core::option::Option<proto_timeline::Kind>,
}
/// Nested message and enum types in `ProtoTimeline`.
pub mod proto_timeline {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Kind {
        #[prost(message, tag = "1")]
        EpochMilliseconds(()),
        #[prost(string, tag = "2")]
        External(::prost::alloc::string::String),
        #[prost(string, tag = "3")]
        User(::prost::alloc::string::String),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoSourceEnvelope {
    #[prost(oneof = "proto_source_envelope::Kind", tags = "1, 2, 3, 4")]
    pub kind: ::core::option::Option<proto_source_envelope::Kind>,
}
/// Nested message and enum types in `ProtoSourceEnvelope`.
pub mod proto_source_envelope {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Kind {
        #[prost(message, tag = "1")]
        None(super::ProtoNoneEnvelope),
        #[prost(message, tag = "2")]
        Debezium(super::ProtoDebeziumEnvelope),
        #[prost(message, tag = "3")]
        Upsert(super::ProtoUpsertEnvelope),
        #[prost(message, tag = "4")]
        CdcV2(()),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoNoneEnvelope {
    #[prost(message, optional, tag = "1")]
    pub key_envelope: ::core::option::Option<ProtoKeyEnvelope>,
    #[prost(uint64, tag = "2")]
    pub key_arity: u64,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoUpsertEnvelope {
    #[prost(message, optional, tag = "1")]
    pub style: ::core::option::Option<ProtoUpsertStyle>,
    #[prost(uint64, repeated, tag = "2")]
    pub key_indices: ::prost::alloc::vec::Vec<u64>,
    #[prost(uint64, tag = "3")]
    pub source_arity: u64,
    #[prost(bool, tag = "4")]
    pub disk: bool,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoUpsertStyle {
    #[prost(oneof = "proto_upsert_style::Kind", tags = "1, 2")]
    pub kind: ::core::option::Option<proto_upsert_style::Kind>,
}
/// Nested message and enum types in `ProtoUpsertStyle`.
pub mod proto_upsert_style {
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ProtoDebezium {
        #[prost(uint64, tag = "1")]
        pub after_idx: u64,
    }
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Kind {
        #[prost(message, tag = "1")]
        Default(super::ProtoKeyEnvelope),
        #[prost(message, tag = "2")]
        Debezium(ProtoDebezium),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoIncludedColumnPos {
    #[prost(string, tag = "1")]
    pub name: ::prost::alloc::string::String,
    #[prost(uint64, tag = "2")]
    pub pos: u64,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoDebeziumEnvelope {
    #[prost(uint64, tag = "1")]
    pub before_idx: u64,
    #[prost(uint64, tag = "2")]
    pub after_idx: u64,
    #[prost(message, optional, tag = "3")]
    pub dedup: ::core::option::Option<ProtoDebeziumDedupProjection>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoDebeziumTransactionMetadata {
    #[prost(message, optional, tag = "1")]
    pub tx_metadata_global_id: ::core::option::Option<
        ::mz_repr::global_id::ProtoGlobalId,
    >,
    #[prost(uint64, tag = "2")]
    pub tx_status_idx: u64,
    #[prost(uint64, tag = "3")]
    pub tx_transaction_id_idx: u64,
    #[prost(uint64, tag = "4")]
    pub tx_data_collections_idx: u64,
    #[prost(uint64, tag = "5")]
    pub tx_data_collections_data_collection_idx: u64,
    #[prost(uint64, tag = "6")]
    pub tx_data_collections_event_count_idx: u64,
    #[prost(string, tag = "7")]
    pub tx_data_collection_name: ::prost::alloc::string::String,
    #[prost(uint64, tag = "8")]
    pub data_transaction_idx: u64,
    #[prost(uint64, tag = "9")]
    pub data_transaction_id_idx: u64,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoDebeziumDedupProjection {
    #[prost(uint64, tag = "1")]
    pub op_idx: u64,
    #[prost(uint64, tag = "2")]
    pub source_idx: u64,
    #[prost(uint64, tag = "3")]
    pub snapshot_idx: u64,
    #[prost(message, optional, tag = "4")]
    pub source_projection: ::core::option::Option<ProtoDebeziumSourceProjection>,
    #[prost(message, optional, tag = "6")]
    pub tx_metadata: ::core::option::Option<ProtoDebeziumTransactionMetadata>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoDebeziumSourceProjection {
    #[prost(oneof = "proto_debezium_source_projection::Kind", tags = "1, 2, 3")]
    pub kind: ::core::option::Option<proto_debezium_source_projection::Kind>,
}
/// Nested message and enum types in `ProtoDebeziumSourceProjection`.
pub mod proto_debezium_source_projection {
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ProtoMySql {
        #[prost(uint64, tag = "1")]
        pub file: u64,
        #[prost(uint64, tag = "2")]
        pub pos: u64,
        #[prost(uint64, tag = "3")]
        pub row: u64,
    }
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ProtoPostgres {
        #[prost(uint64, tag = "1")]
        pub sequence: u64,
        #[prost(uint64, tag = "2")]
        pub lsn: u64,
    }
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ProtoSqlServer {
        #[prost(uint64, tag = "1")]
        pub change_lsn: u64,
        #[prost(uint64, tag = "2")]
        pub event_serial_no: u64,
    }
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Kind {
        #[prost(message, tag = "1")]
        MySql(ProtoMySql),
        #[prost(message, tag = "2")]
        Postgres(ProtoPostgres),
        #[prost(message, tag = "3")]
        SqlServer(ProtoSqlServer),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoKafkaSourceConnection {
    #[prost(message, optional, tag = "1")]
    pub connection: ::core::option::Option<super::connections::ProtoKafkaConnection>,
    #[prost(message, optional, tag = "13")]
    pub connection_id: ::core::option::Option<::mz_repr::global_id::ProtoGlobalId>,
    #[prost(string, tag = "2")]
    pub topic: ::prost::alloc::string::String,
    #[prost(btree_map = "int32, int64", tag = "3")]
    pub start_offsets: ::prost::alloc::collections::BTreeMap<i32, i64>,
    #[prost(string, optional, tag = "4")]
    pub group_id_prefix: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "5")]
    pub environment_id: ::core::option::Option<::mz_proto::ProtoU128>,
    #[prost(string, optional, tag = "12")]
    pub environment_name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "6")]
    pub include_timestamp: ::core::option::Option<ProtoIncludedColumnPos>,
    #[prost(message, optional, tag = "7")]
    pub include_partition: ::core::option::Option<ProtoIncludedColumnPos>,
    #[prost(message, optional, tag = "8")]
    pub include_topic: ::core::option::Option<ProtoIncludedColumnPos>,
    #[prost(message, optional, tag = "9")]
    pub include_offset: ::core::option::Option<ProtoIncludedColumnPos>,
    #[prost(message, optional, tag = "10")]
    pub include_headers: ::core::option::Option<ProtoIncludedColumnPos>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoSourceDesc {
    #[prost(message, optional, tag = "1")]
    pub connection: ::core::option::Option<ProtoSourceConnection>,
    #[prost(message, optional, tag = "2")]
    pub encoding: ::core::option::Option<encoding::ProtoSourceDataEncoding>,
    #[prost(message, optional, tag = "3")]
    pub envelope: ::core::option::Option<ProtoSourceEnvelope>,
    #[prost(message, repeated, tag = "4")]
    pub metadata_columns: ::prost::alloc::vec::Vec<ProtoIncludedColumnSource>,
    #[prost(message, optional, tag = "5")]
    pub timestamp_interval: ::core::option::Option<::mz_proto::ProtoDuration>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoSourceConnection {
    #[prost(oneof = "proto_source_connection::Kind", tags = "1, 4, 6, 7")]
    pub kind: ::core::option::Option<proto_source_connection::Kind>,
}
/// Nested message and enum types in `ProtoSourceConnection`.
pub mod proto_source_connection {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Kind {
        #[prost(message, tag = "1")]
        Kafka(super::ProtoKafkaSourceConnection),
        #[prost(message, tag = "4")]
        Postgres(super::ProtoPostgresSourceConnection),
        #[prost(message, tag = "6")]
        Loadgen(super::ProtoLoadGeneratorSourceConnection),
        #[prost(message, tag = "7")]
        Testscript(super::ProtoTestScriptSourceConnection),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoSourceData {
    #[prost(oneof = "proto_source_data::Kind", tags = "1, 2")]
    pub kind: ::core::option::Option<proto_source_data::Kind>,
}
/// Nested message and enum types in `ProtoSourceData`.
pub mod proto_source_data {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Kind {
        #[prost(message, tag = "1")]
        Ok(::mz_repr::ProtoRow),
        #[prost(message, tag = "2")]
        Err(super::super::errors::ProtoDataflowError),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoPostgresSourceConnection {
    #[prost(message, optional, tag = "6")]
    pub connection_id: ::core::option::Option<::mz_repr::global_id::ProtoGlobalId>,
    #[prost(message, optional, tag = "1")]
    pub connection: ::core::option::Option<super::connections::ProtoPostgresConnection>,
    #[prost(string, tag = "2")]
    pub publication: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "4")]
    pub details: ::core::option::Option<ProtoPostgresSourcePublicationDetails>,
    #[prost(message, repeated, tag = "5")]
    pub table_casts: ::prost::alloc::vec::Vec<
        proto_postgres_source_connection::ProtoPostgresTableCast,
    >,
    /// Describes the position in the source's publication that the table cast
    /// correlates to; meant to be iterated over in tandem with table_casts
    #[prost(uint64, repeated, tag = "7")]
    pub table_cast_pos: ::prost::alloc::vec::Vec<u64>,
}
/// Nested message and enum types in `ProtoPostgresSourceConnection`.
pub mod proto_postgres_source_connection {
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ProtoPostgresTableCast {
        #[prost(message, repeated, tag = "1")]
        pub column_casts: ::prost::alloc::vec::Vec<::mz_expr::ProtoMirScalarExpr>,
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoPostgresSourcePublicationDetails {
    #[prost(message, repeated, tag = "1")]
    pub tables: ::prost::alloc::vec::Vec<
        ::mz_postgres_util::desc::ProtoPostgresTableDesc,
    >,
    #[prost(string, tag = "2")]
    pub slot: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoLoadGeneratorSourceConnection {
    #[prost(uint64, optional, tag = "2")]
    pub tick_micros: ::core::option::Option<u64>,
    #[prost(
        oneof = "proto_load_generator_source_connection::Generator",
        tags = "6, 3, 4, 5"
    )]
    pub generator: ::core::option::Option<
        proto_load_generator_source_connection::Generator,
    >,
}
/// Nested message and enum types in `ProtoLoadGeneratorSourceConnection`.
pub mod proto_load_generator_source_connection {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Generator {
        #[prost(message, tag = "6")]
        Counter(super::ProtoCounterLoadGenerator),
        #[prost(message, tag = "3")]
        Auction(()),
        #[prost(message, tag = "4")]
        Tpch(super::ProtoTpchLoadGenerator),
        #[prost(message, tag = "5")]
        Datums(()),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoTestScriptSourceConnection {
    #[prost(string, tag = "1")]
    pub desc_json: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoCounterLoadGenerator {
    /// Must be non-negative,
    /// but kept as int64 to make downstream logic simpler
    #[prost(int64, optional, tag = "1")]
    pub max_cardinality: ::core::option::Option<i64>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoTpchLoadGenerator {
    #[prost(int64, tag = "1")]
    pub count_supplier: i64,
    #[prost(int64, tag = "2")]
    pub count_part: i64,
    #[prost(int64, tag = "3")]
    pub count_customer: i64,
    #[prost(int64, tag = "4")]
    pub count_orders: i64,
    #[prost(int64, tag = "5")]
    pub count_clerk: i64,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoCompression {
    #[prost(oneof = "proto_compression::Kind", tags = "1, 2")]
    pub kind: ::core::option::Option<proto_compression::Kind>,
}
/// Nested message and enum types in `ProtoCompression`.
pub mod proto_compression {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Kind {
        #[prost(message, tag = "1")]
        Gzip(()),
        #[prost(message, tag = "2")]
        None(()),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoIngestionDescription {
    #[prost(message, repeated, tag = "1")]
    pub source_imports: ::prost::alloc::vec::Vec<
        proto_ingestion_description::ProtoSourceImport,
    >,
    #[prost(message, repeated, tag = "2")]
    pub source_exports: ::prost::alloc::vec::Vec<
        proto_ingestion_description::ProtoSourceExport,
    >,
    #[prost(message, optional, tag = "3")]
    pub ingestion_metadata: ::core::option::Option<
        super::super::controller::ProtoCollectionMetadata,
    >,
    #[prost(message, optional, tag = "4")]
    pub desc: ::core::option::Option<ProtoSourceDesc>,
    #[prost(message, optional, tag = "6")]
    pub instance_id: ::core::option::Option<super::instances::ProtoStorageInstanceId>,
    #[prost(message, optional, tag = "7")]
    pub remap_collection_id: ::core::option::Option<::mz_repr::global_id::ProtoGlobalId>,
}
/// Nested message and enum types in `ProtoIngestionDescription`.
pub mod proto_ingestion_description {
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ProtoSourceImport {
        #[prost(message, optional, tag = "1")]
        pub id: ::core::option::Option<::mz_repr::global_id::ProtoGlobalId>,
        #[prost(message, optional, tag = "2")]
        pub storage_metadata: ::core::option::Option<
            super::super::super::controller::ProtoCollectionMetadata,
        >,
    }
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ProtoSourceExport {
        #[prost(message, optional, tag = "1")]
        pub id: ::core::option::Option<::mz_repr::global_id::ProtoGlobalId>,
        #[prost(uint64, tag = "2")]
        pub output_index: u64,
        #[prost(message, optional, tag = "3")]
        pub storage_metadata: ::core::option::Option<
            super::super::super::controller::ProtoCollectionMetadata,
        >,
    }
}