risingwave_pb/

catalog.rs

// This file is @generated by prost-build.
/// A mapping of column indices.
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ColIndexMapping {
    /// The size of the target space.
    #[prost(uint64, tag = "1")]
    pub target_size: u64,
    /// Each subscript is mapped to the corresponding element.
    /// For those not mapped, the value will be negative.
    #[prost(int64, repeated, tag = "2")]
    pub map: ::prost::alloc::vec::Vec<i64>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Eq, Hash)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct WatermarkDesc {
    /// The column idx the watermark is on
    #[prost(uint32, tag = "1")]
    pub watermark_idx: u32,
    /// The expression to calculate the watermark value.
    #[prost(message, optional, tag = "2")]
    pub expr: ::core::option::Option<super::expr::ExprNode>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Eq, Hash)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct StreamSourceInfo {
    /// deprecated
    #[prost(enumeration = "super::plan_common::RowFormatType", tag = "1")]
    pub row_format: i32,
    #[prost(string, tag = "2")]
    pub row_schema_location: ::prost::alloc::string::String,
    /// This means *use **confluent** schema registry* and is `false` for **aws glue** schema registry.
    /// Eventually we will deprecate it and rely on `enum SchemaLocation` derived from `format_encode_options` below.
    /// * schema.location     false
    /// * schema.registry     true
    /// * aws.glue.schema_arn false
    #[prost(bool, tag = "3")]
    pub use_schema_registry: bool,
    #[prost(string, tag = "4")]
    pub proto_message_name: ::prost::alloc::string::String,
    #[prost(int32, tag = "5")]
    pub csv_delimiter: i32,
    #[prost(bool, tag = "6")]
    pub csv_has_header: bool,
    #[prost(enumeration = "super::plan_common::FormatType", tag = "8")]
    pub format: i32,
    #[prost(enumeration = "super::plan_common::EncodeType", tag = "9")]
    pub row_encode: i32,
    #[prost(enumeration = "SchemaRegistryNameStrategy", tag = "10")]
    pub name_strategy: i32,
    #[prost(string, optional, tag = "11")]
    pub key_message_name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "12")]
    pub external_table: ::core::option::Option<super::plan_common::ExternalTableDesc>,
    /// **This field should now be called `is_shared`.** Not renamed for backwards
    /// compatibility.
    ///
    /// Whether the stream source is a shared source (it has a streaming job).
    /// This is related with [RFC: Reusable Source
    /// Executor](<https://github.com/risingwavelabs/rfcs/pull/72>).
    ///
    /// Currently, the following sources can be shared:
    ///
    /// - Direct CDC sources (mysql & postgresql & sqlserver)
    /// - MQ sources (Kafka)
    #[prost(bool, tag = "13")]
    pub cdc_source_job: bool,
    /// Only used when `cdc_source_job` is `true`.
    /// If `false`, `requires_singleton` will be set in the stream plan.
    ///
    /// - Direct CDC sources: `false`
    /// - MQ sources (Kafka): `true`
    #[prost(bool, tag = "15")]
    pub is_distributed: bool,
    /// Options specified by user in the FORMAT ENCODE clause.
    #[prost(btree_map = "string, string", tag = "14")]
    pub format_encode_options: ::prost::alloc::collections::BTreeMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    /// Handle the source relies on any sceret. The key is the propertity name and the value is the secret id and type.
    /// For format and encode options.
    #[prost(btree_map = "string, message", tag = "16")]
    pub format_encode_secret_refs: ::prost::alloc::collections::BTreeMap<
        ::prost::alloc::string::String,
        super::secret::SecretRef,
    >,
}
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Source {
    /// For shared source, this is the same as the job id.
    /// For non-shared source and table with connector, this is a different oid.
    #[prost(uint32, tag = "1")]
    pub id: u32,
    #[prost(uint32, tag = "2")]
    pub schema_id: u32,
    #[prost(uint32, tag = "3")]
    pub database_id: u32,
    #[prost(string, tag = "4")]
    pub name: ::prost::alloc::string::String,
    /// The column index of row ID. If the primary key is specified by the user,
    /// this will be `None`.
    #[prost(uint32, optional, tag = "5")]
    pub row_id_index: ::core::option::Option<u32>,
    /// Columns of the source.
    #[prost(message, repeated, tag = "6")]
    pub columns: ::prost::alloc::vec::Vec<super::plan_common::ColumnCatalog>,
    /// Column id of the primary key specified by the user. If the user does not
    /// specify a primary key, the vector will be empty.
    #[prost(int32, repeated, tag = "7")]
    pub pk_column_ids: ::prost::alloc::vec::Vec<i32>,
    /// Properties specified by the user in WITH clause.
    #[prost(btree_map = "string, string", tag = "8")]
    pub with_properties: ::prost::alloc::collections::BTreeMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(uint32, tag = "9")]
    pub owner: u32,
    #[prost(message, optional, tag = "10")]
    pub info: ::core::option::Option<StreamSourceInfo>,
    /// Define watermarks on the source. The `repeated` is just for forward
    /// compatibility, currently, only one watermark on the source
    #[prost(message, repeated, tag = "11")]
    pub watermark_descs: ::prost::alloc::vec::Vec<WatermarkDesc>,
    #[prost(string, tag = "13")]
    pub definition: ::prost::alloc::string::String,
    #[prost(uint32, optional, tag = "14")]
    pub connection_id: ::core::option::Option<u32>,
    #[prost(uint64, optional, tag = "15")]
    pub initialized_at_epoch: ::core::option::Option<u64>,
    #[prost(uint64, optional, tag = "16")]
    pub created_at_epoch: ::core::option::Option<u64>,
    /// Cluster version (tracked by git commit) when initialized/created
    #[prost(string, optional, tag = "17")]
    pub initialized_at_cluster_version: ::core::option::Option<
        ::prost::alloc::string::String,
    >,
    #[prost(string, optional, tag = "18")]
    pub created_at_cluster_version: ::core::option::Option<
        ::prost::alloc::string::String,
    >,
    /// Handle the source relies on any sceret. The key is the propertity name and the value is the secret id.
    /// Used for secret connect options.
    #[prost(btree_map = "string, message", tag = "19")]
    pub secret_refs: ::prost::alloc::collections::BTreeMap<
        ::prost::alloc::string::String,
        super::secret::SecretRef,
    >,
    /// Per-source catalog version, used by schema change.
    #[prost(uint64, tag = "100")]
    pub version: u64,
    #[prost(uint32, optional, tag = "101")]
    pub rate_limit: ::core::option::Option<u32>,
    /// Indicate whether this source is created by table.
    #[prost(oneof = "source::OptionalAssociatedTableId", tags = "12")]
    pub optional_associated_table_id: ::core::option::Option<
        source::OptionalAssociatedTableId,
    >,
}
/// Nested message and enum types in `Source`.
pub mod source {
    /// Indicate whether this source is created by table.
    #[derive(prost_helpers::AnyPB)]
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
    pub enum OptionalAssociatedTableId {
        #[prost(uint32, tag = "12")]
        AssociatedTableId(u32),
    }
}
/// Similar to `StreamSourceInfo`, and may replace `SinkType` later.
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SinkFormatDesc {
    #[prost(enumeration = "super::plan_common::FormatType", tag = "1")]
    pub format: i32,
    #[prost(enumeration = "super::plan_common::EncodeType", tag = "2")]
    pub encode: i32,
    #[prost(btree_map = "string, string", tag = "3")]
    pub options: ::prost::alloc::collections::BTreeMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(enumeration = "super::plan_common::EncodeType", optional, tag = "4")]
    pub key_encode: ::core::option::Option<i32>,
    /// Secret used for format encode options.
    #[prost(btree_map = "string, message", tag = "5")]
    pub secret_refs: ::prost::alloc::collections::BTreeMap<
        ::prost::alloc::string::String,
        super::secret::SecretRef,
    >,
}
/// the catalog of the sink. There are two kind of schema here. The full schema is all columns
/// stored in the `column` which is the sink executor/fragment's output schema. The visible
/// schema contains the columns whose `is_hidden` is false, which is the columns sink out to the
/// external system. The distribution key and all other keys are indexed in the full schema.
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Sink {
    #[prost(uint32, tag = "1")]
    pub id: u32,
    #[prost(uint32, tag = "2")]
    pub schema_id: u32,
    #[prost(uint32, tag = "3")]
    pub database_id: u32,
    #[prost(string, tag = "4")]
    pub name: ::prost::alloc::string::String,
    #[prost(message, repeated, tag = "5")]
    pub columns: ::prost::alloc::vec::Vec<super::plan_common::ColumnCatalog>,
    /// Primary key derived from the SQL by the frontend.
    #[prost(message, repeated, tag = "6")]
    pub plan_pk: ::prost::alloc::vec::Vec<super::common::ColumnOrder>,
    #[deprecated]
    #[prost(uint32, repeated, packed = "false", tag = "7")]
    pub dependent_relations: ::prost::alloc::vec::Vec<u32>,
    #[prost(int32, repeated, tag = "8")]
    pub distribution_key: ::prost::alloc::vec::Vec<i32>,
    /// User-defined primary key indices for the upsert sink.
    #[prost(int32, repeated, tag = "9")]
    pub downstream_pk: ::prost::alloc::vec::Vec<i32>,
    /// to be deprecated
    #[prost(enumeration = "SinkType", tag = "10")]
    pub sink_type: i32,
    #[prost(uint32, tag = "11")]
    pub owner: u32,
    #[prost(btree_map = "string, string", tag = "12")]
    pub properties: ::prost::alloc::collections::BTreeMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(string, tag = "13")]
    pub definition: ::prost::alloc::string::String,
    #[prost(uint32, optional, tag = "14")]
    pub connection_id: ::core::option::Option<u32>,
    #[prost(uint64, optional, tag = "15")]
    pub initialized_at_epoch: ::core::option::Option<u64>,
    #[prost(uint64, optional, tag = "16")]
    pub created_at_epoch: ::core::option::Option<u64>,
    #[prost(string, tag = "17")]
    pub db_name: ::prost::alloc::string::String,
    #[prost(string, tag = "18")]
    pub sink_from_name: ::prost::alloc::string::String,
    #[prost(enumeration = "StreamJobStatus", tag = "19")]
    pub stream_job_status: i32,
    #[prost(message, optional, tag = "20")]
    pub format_desc: ::core::option::Option<SinkFormatDesc>,
    /// Target table id (only applicable for table sink)
    #[prost(uint32, optional, tag = "21")]
    pub target_table: ::core::option::Option<u32>,
    /// Cluster version (tracked by git commit) when initialized/created
    #[prost(string, optional, tag = "22")]
    pub initialized_at_cluster_version: ::core::option::Option<
        ::prost::alloc::string::String,
    >,
    #[prost(string, optional, tag = "23")]
    pub created_at_cluster_version: ::core::option::Option<
        ::prost::alloc::string::String,
    >,
    /// Whether it should use background ddl or block until backfill finishes.
    #[prost(enumeration = "CreateType", tag = "24")]
    pub create_type: i32,
    /// Handle the sink relies on any sceret. The key is the propertity name and the value is the secret id and type.
    /// Used for connect options.
    #[prost(btree_map = "string, message", tag = "25")]
    pub secret_refs: ::prost::alloc::collections::BTreeMap<
        ::prost::alloc::string::String,
        super::secret::SecretRef,
    >,
    /// only for the sink whose target is a table. Columns of the target table when the sink is created. At this point all the default columns of the target table are all handled by the project operator in the sink plan.
    #[prost(message, repeated, tag = "26")]
    pub original_target_columns: ::prost::alloc::vec::Vec<
        super::plan_common::ColumnCatalog,
    >,
}
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Subscription {
    #[prost(uint32, tag = "1")]
    pub id: u32,
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub definition: ::prost::alloc::string::String,
    #[prost(uint64, tag = "6")]
    pub retention_seconds: u64,
    #[prost(uint32, tag = "8")]
    pub database_id: u32,
    #[prost(uint32, tag = "9")]
    pub schema_id: u32,
    #[prost(uint32, tag = "10")]
    pub dependent_table_id: u32,
    #[prost(uint64, optional, tag = "11")]
    pub initialized_at_epoch: ::core::option::Option<u64>,
    #[prost(uint64, optional, tag = "12")]
    pub created_at_epoch: ::core::option::Option<u64>,
    #[prost(uint32, tag = "13")]
    pub owner: u32,
    #[prost(string, optional, tag = "15")]
    pub initialized_at_cluster_version: ::core::option::Option<
        ::prost::alloc::string::String,
    >,
    #[prost(string, optional, tag = "16")]
    pub created_at_cluster_version: ::core::option::Option<
        ::prost::alloc::string::String,
    >,
    #[prost(enumeration = "subscription::SubscriptionState", tag = "19")]
    pub subscription_state: i32,
}
/// Nested message and enum types in `Subscription`.
pub mod subscription {
    #[derive(prost_helpers::AnyPB)]
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum SubscriptionState {
        Unspecified = 0,
        Init = 1,
        Created = 2,
    }
    impl SubscriptionState {
        /// String value of the enum field names used in the ProtoBuf definition.
        ///
        /// The values are not transformed in any way and thus are considered stable
        /// (if the ProtoBuf definition does not change) and safe for programmatic use.
        pub fn as_str_name(&self) -> &'static str {
            match self {
                SubscriptionState::Unspecified => "UNSPECIFIED",
                SubscriptionState::Init => "INIT",
                SubscriptionState::Created => "CREATED",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "UNSPECIFIED" => Some(Self::Unspecified),
                "INIT" => Some(Self::Init),
                "CREATED" => Some(Self::Created),
                _ => None,
            }
        }
    }
}
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Connection {
    #[prost(uint32, tag = "1")]
    pub id: u32,
    #[prost(uint32, tag = "2")]
    pub schema_id: u32,
    #[prost(uint32, tag = "3")]
    pub database_id: u32,
    #[prost(string, tag = "4")]
    pub name: ::prost::alloc::string::String,
    #[prost(uint32, tag = "6")]
    pub owner: u32,
    #[prost(oneof = "connection::Info", tags = "5")]
    pub info: ::core::option::Option<connection::Info>,
}
/// Nested message and enum types in `Connection`.
pub mod connection {
    #[derive(prost_helpers::AnyPB)]
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct PrivateLinkService {
        #[prost(enumeration = "private_link_service::PrivateLinkProvider", tag = "1")]
        pub provider: i32,
        #[prost(string, tag = "2")]
        pub service_name: ::prost::alloc::string::String,
        #[prost(string, tag = "3")]
        pub endpoint_id: ::prost::alloc::string::String,
        #[prost(map = "string, string", tag = "4")]
        pub dns_entries: ::std::collections::HashMap<
            ::prost::alloc::string::String,
            ::prost::alloc::string::String,
        >,
        #[prost(string, tag = "5")]
        pub endpoint_dns_name: ::prost::alloc::string::String,
    }
    /// Nested message and enum types in `PrivateLinkService`.
    pub mod private_link_service {
        #[derive(prost_helpers::AnyPB)]
        #[derive(
            Clone,
            Copy,
            Debug,
            PartialEq,
            Eq,
            Hash,
            PartialOrd,
            Ord,
            ::prost::Enumeration
        )]
        #[repr(i32)]
        pub enum PrivateLinkProvider {
            Unspecified = 0,
            Mock = 1,
            Aws = 2,
        }
        impl PrivateLinkProvider {
            /// String value of the enum field names used in the ProtoBuf definition.
            ///
            /// The values are not transformed in any way and thus are considered stable
            /// (if the ProtoBuf definition does not change) and safe for programmatic use.
            pub fn as_str_name(&self) -> &'static str {
                match self {
                    PrivateLinkProvider::Unspecified => "UNSPECIFIED",
                    PrivateLinkProvider::Mock => "MOCK",
                    PrivateLinkProvider::Aws => "AWS",
                }
            }
            /// Creates an enum from field names used in the ProtoBuf definition.
            pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
                match value {
                    "UNSPECIFIED" => Some(Self::Unspecified),
                    "MOCK" => Some(Self::Mock),
                    "AWS" => Some(Self::Aws),
                    _ => None,
                }
            }
        }
    }
    #[derive(prost_helpers::AnyPB)]
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Info {
        #[prost(message, tag = "5")]
        PrivateLinkService(PrivateLinkService),
    }
}
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Index {
    #[prost(uint32, tag = "1")]
    pub id: u32,
    #[prost(uint32, tag = "2")]
    pub schema_id: u32,
    #[prost(uint32, tag = "3")]
    pub database_id: u32,
    #[prost(string, tag = "4")]
    pub name: ::prost::alloc::string::String,
    #[prost(uint32, tag = "5")]
    pub owner: u32,
    #[prost(uint32, tag = "6")]
    pub index_table_id: u32,
    #[prost(uint32, tag = "7")]
    pub primary_table_id: u32,
    /// Only `InputRef` type index is supported Now.
    /// The index of `InputRef` is the column index of the primary table.
    #[prost(message, repeated, tag = "8")]
    pub index_item: ::prost::alloc::vec::Vec<super::expr::ExprNode>,
    #[prost(message, repeated, tag = "16")]
    pub index_column_properties: ::prost::alloc::vec::Vec<IndexColumnProperties>,
    #[prost(uint64, optional, tag = "10")]
    pub initialized_at_epoch: ::core::option::Option<u64>,
    #[prost(uint64, optional, tag = "11")]
    pub created_at_epoch: ::core::option::Option<u64>,
    #[prost(enumeration = "StreamJobStatus", tag = "12")]
    pub stream_job_status: i32,
    /// Use to record the prefix len of the index_item to reconstruct index columns
    /// provided by users.
    #[prost(uint32, tag = "13")]
    pub index_columns_len: u32,
    /// Cluster version (tracked by git commit) when initialized/created
    #[prost(string, optional, tag = "14")]
    pub initialized_at_cluster_version: ::core::option::Option<
        ::prost::alloc::string::String,
    >,
    #[prost(string, optional, tag = "15")]
    pub created_at_cluster_version: ::core::option::Option<
        ::prost::alloc::string::String,
    >,
}
/// <https://www.postgresql.org/docs/current/functions-info.html#FUNCTIONS-INFO-INDEX-COLUMN-PROPS>
#[derive(prost_helpers::AnyPB)]
#[derive(Eq, Hash)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct IndexColumnProperties {
    /// Whether the column sort in ascending(false) or descending(true) order on a forward scan.
    #[prost(bool, tag = "1")]
    pub is_desc: bool,
    /// Does the column sort with nulls first on a forward scan?
    #[prost(bool, tag = "2")]
    pub nulls_first: bool,
}
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Function {
    #[prost(uint32, tag = "1")]
    pub id: u32,
    #[prost(uint32, tag = "2")]
    pub schema_id: u32,
    #[prost(uint32, tag = "3")]
    pub database_id: u32,
    #[prost(string, tag = "4")]
    pub name: ::prost::alloc::string::String,
    #[prost(uint32, tag = "9")]
    pub owner: u32,
    #[prost(string, repeated, tag = "15")]
    pub arg_names: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "5")]
    pub arg_types: ::prost::alloc::vec::Vec<super::data::DataType>,
    #[prost(message, optional, tag = "6")]
    pub return_type: ::core::option::Option<super::data::DataType>,
    #[prost(string, tag = "7")]
    pub language: ::prost::alloc::string::String,
    #[prost(string, optional, tag = "8")]
    pub link: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "10")]
    pub identifier: ::core::option::Option<::prost::alloc::string::String>,
    /// The source code of the function.
    #[prost(string, optional, tag = "14")]
    pub body: ::core::option::Option<::prost::alloc::string::String>,
    /// The zstd-compressed binary of the function.
    #[prost(bytes = "vec", optional, tag = "17")]
    pub compressed_binary: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(bool, tag = "16")]
    pub always_retry_on_network_error: bool,
    /// The runtime selected when multiple runtimes are available for the language. Now is not used.
    #[prost(string, optional, tag = "18")]
    pub runtime: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(oneof = "function::Kind", tags = "11, 12, 13")]
    pub kind: ::core::option::Option<function::Kind>,
}
/// Nested message and enum types in `Function`.
pub mod function {
    #[derive(prost_helpers::AnyPB)]
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct ScalarFunction {}
    #[derive(prost_helpers::AnyPB)]
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct TableFunction {}
    #[derive(prost_helpers::AnyPB)]
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct AggregateFunction {}
    #[derive(prost_helpers::AnyPB)]
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
    pub enum Kind {
        #[prost(message, tag = "11")]
        Scalar(ScalarFunction),
        #[prost(message, tag = "12")]
        Table(TableFunction),
        #[prost(message, tag = "13")]
        Aggregate(AggregateFunction),
    }
}
/// See `TableCatalog` struct in frontend crate for more information.
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Table {
    #[prost(uint32, tag = "1")]
    pub id: u32,
    #[prost(uint32, tag = "2")]
    pub schema_id: u32,
    #[prost(uint32, tag = "3")]
    pub database_id: u32,
    #[prost(string, tag = "4")]
    pub name: ::prost::alloc::string::String,
    #[prost(message, repeated, tag = "5")]
    pub columns: ::prost::alloc::vec::Vec<super::plan_common::ColumnCatalog>,
    #[prost(message, repeated, tag = "6")]
    pub pk: ::prost::alloc::vec::Vec<super::common::ColumnOrder>,
    /// For cdc table created from a cdc source, here records the source id.
    ///
    /// TODO(rc): deprecate this by passing dependencies via `Request` message
    #[prost(uint32, repeated, tag = "8")]
    pub dependent_relations: ::prost::alloc::vec::Vec<u32>,
    #[prost(enumeration = "table::TableType", tag = "10")]
    pub table_type: i32,
    #[prost(int32, repeated, tag = "12")]
    pub distribution_key: ::prost::alloc::vec::Vec<i32>,
    /// pk_indices of the corresponding materialize operator's output.
    #[prost(int32, repeated, tag = "13")]
    pub stream_key: ::prost::alloc::vec::Vec<i32>,
    #[prost(bool, tag = "14")]
    pub append_only: bool,
    #[prost(uint32, tag = "15")]
    pub owner: u32,
    #[prost(uint32, tag = "17")]
    pub fragment_id: u32,
    /// an optional column index which is the vnode of each row computed by the
    /// table's consistent hash distribution
    #[prost(uint32, optional, tag = "18")]
    pub vnode_col_index: ::core::option::Option<u32>,
    /// An optional column index of row id. If the primary key is specified by
    /// users, this will be `None`.
    #[prost(uint32, optional, tag = "19")]
    pub row_id_index: ::core::option::Option<u32>,
    /// The column indices which are stored in the state store's value with
    /// row-encoding. Currently is not supported yet and expected to be
    /// `\[0..columns.len()\]`.
    #[prost(int32, repeated, tag = "20")]
    pub value_indices: ::prost::alloc::vec::Vec<i32>,
    #[prost(string, tag = "21")]
    pub definition: ::prost::alloc::string::String,
    /// Used to control whether handling pk conflict for incoming data.
    #[prost(enumeration = "HandleConflictBehavior", tag = "22")]
    pub handle_pk_conflict_behavior: i32,
    /// Anticipated read prefix pattern (number of fields) for the table, which can
    /// be utilized for implementing the table's bloom filter or other storage
    /// optimization techniques.
    #[prost(uint32, tag = "23")]
    pub read_prefix_len_hint: u32,
    #[prost(int32, repeated, tag = "24")]
    pub watermark_indices: ::prost::alloc::vec::Vec<i32>,
    #[prost(int32, repeated, tag = "25")]
    pub dist_key_in_pk: ::prost::alloc::vec::Vec<i32>,
    /// A dml fragment id corresponds to the table, used to decide where the dml
    /// statement is executed.
    #[prost(uint32, optional, tag = "26")]
    pub dml_fragment_id: ::core::option::Option<u32>,
    /// The range of row count of the table.
    /// This field is not always present due to backward compatibility. Use
    /// `Cardinality::unknown` in this case.
    #[prost(message, optional, tag = "27")]
    pub cardinality: ::core::option::Option<super::plan_common::Cardinality>,
    #[prost(uint64, optional, tag = "28")]
    pub initialized_at_epoch: ::core::option::Option<u64>,
    #[prost(uint64, optional, tag = "29")]
    pub created_at_epoch: ::core::option::Option<u64>,
    /// This field is introduced in v1.2.0. It is used to indicate whether the
    /// table should use watermark_cache to avoid state cleaning as a performance
    /// optimization. In older versions we can just initialize without it.
    #[prost(bool, tag = "30")]
    pub cleaned_by_watermark: bool,
    /// Used to filter created / creating tables in meta.
    #[prost(enumeration = "StreamJobStatus", tag = "31")]
    pub stream_job_status: i32,
    #[prost(enumeration = "CreateType", tag = "32")]
    pub create_type: i32,
    /// This field is used to store the description set by the `comment on` clause.
    #[prost(string, optional, tag = "33")]
    pub description: ::core::option::Option<::prost::alloc::string::String>,
    /// This field is used to mark the the sink into this table.
    #[prost(uint32, repeated, tag = "34")]
    pub incoming_sinks: ::prost::alloc::vec::Vec<u32>,
    /// Cluster version (tracked by git commit) when initialized/created
    #[prost(string, optional, tag = "35")]
    pub initialized_at_cluster_version: ::core::option::Option<
        ::prost::alloc::string::String,
    >,
    #[prost(string, optional, tag = "36")]
    pub created_at_cluster_version: ::core::option::Option<
        ::prost::alloc::string::String,
    >,
    /// TTL of the record in the table, to ensure the consistency with other tables
    /// in the streaming plan, it only applies to append-only tables.
    #[prost(uint32, optional, tag = "37")]
    pub retention_seconds: ::core::option::Option<u32>,
    /// This field specifies the index of the column set in the "with version
    /// column" within all the columns. It is used for filtering during "on
    /// conflict" operations.
    #[prost(uint32, optional, tag = "38")]
    pub version_column_index: ::core::option::Option<u32>,
    /// The unique identifier of the upstream table if it is a CDC table.
    /// It will be used in auto schema change to get the Table which mapped to the
    /// upstream table.
    #[prost(string, optional, tag = "39")]
    pub cdc_table_id: ::core::option::Option<::prost::alloc::string::String>,
    /// Total vnode count of the table.
    ///
    /// Use `VnodeCountCompat::vnode_count` to access it.
    ///
    /// - Can be unset if the table is created in older versions where variable vnode count is not
    ///    supported, in which case a default value of 256 (or 1 for singleton) should be used.
    /// - Can be placeholder value `Some(0)` if the catalog is generated by the frontend and the
    ///    corresponding job is still in `Creating` status, in which case calling `vnode_count`
    ///    will panic.
    ///
    /// Please note that this field is not intended to describe the expected vnode count
    /// for a streaming job. Instead, refer to `stream_plan.StreamFragmentGraph.max_parallelism`.
    #[prost(uint32, optional, tag = "40")]
    pub maybe_vnode_count: ::core::option::Option<u32>,
    /// Per-table catalog version, used by schema change. `None` for internal
    /// tables and tests. Not to be confused with the global catalog version for
    /// notification service.
    #[prost(message, optional, tag = "100")]
    pub version: ::core::option::Option<table::TableVersion>,
    #[prost(oneof = "table::OptionalAssociatedSourceId", tags = "9")]
    pub optional_associated_source_id: ::core::option::Option<
        table::OptionalAssociatedSourceId,
    >,
}
/// Nested message and enum types in `Table`.
pub mod table {
    #[derive(prost_helpers::AnyPB)]
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct TableVersion {
        /// The version number, which will be 0 by default and be increased by 1 for
        /// each schema change in the frontend.
        #[prost(uint64, tag = "1")]
        pub version: u64,
        /// The ID of the next column to be added, which is used to make all columns
        /// in the table have unique IDs, even if some columns have been dropped.
        #[prost(int32, tag = "2")]
        pub next_column_id: i32,
    }
    #[derive(prost_helpers::AnyPB)]
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum TableType {
        Unspecified = 0,
        Table = 1,
        MaterializedView = 2,
        Index = 3,
        Internal = 4,
    }
    impl TableType {
        /// String value of the enum field names used in the ProtoBuf definition.
        ///
        /// The values are not transformed in any way and thus are considered stable
        /// (if the ProtoBuf definition does not change) and safe for programmatic use.
        pub fn as_str_name(&self) -> &'static str {
            match self {
                TableType::Unspecified => "UNSPECIFIED",
                TableType::Table => "TABLE",
                TableType::MaterializedView => "MATERIALIZED_VIEW",
                TableType::Index => "INDEX",
                TableType::Internal => "INTERNAL",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "UNSPECIFIED" => Some(Self::Unspecified),
                "TABLE" => Some(Self::Table),
                "MATERIALIZED_VIEW" => Some(Self::MaterializedView),
                "INDEX" => Some(Self::Index),
                "INTERNAL" => Some(Self::Internal),
                _ => None,
            }
        }
    }
    #[derive(prost_helpers::AnyPB)]
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
    pub enum OptionalAssociatedSourceId {
        #[prost(uint32, tag = "9")]
        AssociatedSourceId(u32),
    }
}
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct View {
    #[prost(uint32, tag = "1")]
    pub id: u32,
    #[prost(uint32, tag = "2")]
    pub schema_id: u32,
    #[prost(uint32, tag = "3")]
    pub database_id: u32,
    #[prost(string, tag = "4")]
    pub name: ::prost::alloc::string::String,
    #[prost(uint32, tag = "5")]
    pub owner: u32,
    #[prost(btree_map = "string, string", tag = "6")]
    pub properties: ::prost::alloc::collections::BTreeMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(string, tag = "7")]
    pub sql: ::prost::alloc::string::String,
    #[prost(uint32, repeated, tag = "8")]
    pub dependent_relations: ::prost::alloc::vec::Vec<u32>,
    /// User-specified column names.
    #[prost(message, repeated, tag = "9")]
    pub columns: ::prost::alloc::vec::Vec<super::plan_common::Field>,
}
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Schema {
    #[prost(uint32, tag = "1")]
    pub id: u32,
    #[prost(uint32, tag = "2")]
    pub database_id: u32,
    #[prost(string, tag = "3")]
    pub name: ::prost::alloc::string::String,
    #[prost(uint32, tag = "4")]
    pub owner: u32,
}
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Database {
    #[prost(uint32, tag = "1")]
    pub id: u32,
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    #[prost(uint32, tag = "3")]
    pub owner: u32,
}
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Comment {
    #[prost(uint32, tag = "1")]
    pub table_id: u32,
    #[prost(uint32, tag = "2")]
    pub schema_id: u32,
    #[prost(uint32, tag = "3")]
    pub database_id: u32,
    #[prost(uint32, optional, tag = "4")]
    pub column_index: ::core::option::Option<u32>,
    #[prost(string, optional, tag = "5")]
    pub description: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Secret {
    #[prost(uint32, tag = "1")]
    pub id: u32,
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    #[prost(uint32, tag = "3")]
    pub database_id: u32,
    /// The secret here is encrypted to bytes.
    #[prost(bytes = "vec", tag = "4")]
    pub value: ::prost::alloc::vec::Vec<u8>,
    #[prost(uint32, tag = "5")]
    pub owner: u32,
    #[prost(uint32, tag = "6")]
    pub schema_id: u32,
}
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct OptionsWithSecret {
    #[prost(map = "string, string", tag = "1")]
    pub options: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(map = "string, message", tag = "2")]
    pub secret_refs: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        super::secret::SecretRef,
    >,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SchemaRegistryNameStrategy {
    Unspecified = 0,
    RecordNameStrategy = 1,
    TopicRecordNameStrategy = 2,
}
impl SchemaRegistryNameStrategy {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            SchemaRegistryNameStrategy::Unspecified => {
                "SCHEMA_REGISTRY_NAME_STRATEGY_UNSPECIFIED"
            }
            SchemaRegistryNameStrategy::RecordNameStrategy => {
                "SCHEMA_REGISTRY_NAME_STRATEGY_RECORD_NAME_STRATEGY"
            }
            SchemaRegistryNameStrategy::TopicRecordNameStrategy => {
                "SCHEMA_REGISTRY_NAME_STRATEGY_TOPIC_RECORD_NAME_STRATEGY"
            }
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "SCHEMA_REGISTRY_NAME_STRATEGY_UNSPECIFIED" => Some(Self::Unspecified),
            "SCHEMA_REGISTRY_NAME_STRATEGY_RECORD_NAME_STRATEGY" => {
                Some(Self::RecordNameStrategy)
            }
            "SCHEMA_REGISTRY_NAME_STRATEGY_TOPIC_RECORD_NAME_STRATEGY" => {
                Some(Self::TopicRecordNameStrategy)
            }
            _ => None,
        }
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum StreamJobStatus {
    /// Prefixed by `STREAM_JOB_STATUS` due to protobuf namespacing rules.
    Unspecified = 0,
    Creating = 1,
    Created = 2,
}
impl StreamJobStatus {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            StreamJobStatus::Unspecified => "STREAM_JOB_STATUS_UNSPECIFIED",
            StreamJobStatus::Creating => "STREAM_JOB_STATUS_CREATING",
            StreamJobStatus::Created => "STREAM_JOB_STATUS_CREATED",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "STREAM_JOB_STATUS_UNSPECIFIED" => Some(Self::Unspecified),
            "STREAM_JOB_STATUS_CREATING" => Some(Self::Creating),
            "STREAM_JOB_STATUS_CREATED" => Some(Self::Created),
            _ => None,
        }
    }
}
/// How the stream job was created will determine
/// whether they are persisted.
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum CreateType {
    Unspecified = 0,
    Background = 1,
    Foreground = 2,
}
impl CreateType {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            CreateType::Unspecified => "CREATE_TYPE_UNSPECIFIED",
            CreateType::Background => "CREATE_TYPE_BACKGROUND",
            CreateType::Foreground => "CREATE_TYPE_FOREGROUND",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "CREATE_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
            "CREATE_TYPE_BACKGROUND" => Some(Self::Background),
            "CREATE_TYPE_FOREGROUND" => Some(Self::Foreground),
            _ => None,
        }
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SinkType {
    Unspecified = 0,
    AppendOnly = 1,
    ForceAppendOnly = 2,
    Upsert = 3,
}
impl SinkType {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            SinkType::Unspecified => "SINK_TYPE_UNSPECIFIED",
            SinkType::AppendOnly => "SINK_TYPE_APPEND_ONLY",
            SinkType::ForceAppendOnly => "SINK_TYPE_FORCE_APPEND_ONLY",
            SinkType::Upsert => "SINK_TYPE_UPSERT",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "SINK_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
            "SINK_TYPE_APPEND_ONLY" => Some(Self::AppendOnly),
            "SINK_TYPE_FORCE_APPEND_ONLY" => Some(Self::ForceAppendOnly),
            "SINK_TYPE_UPSERT" => Some(Self::Upsert),
            _ => None,
        }
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum HandleConflictBehavior {
    Unspecified = 0,
    Overwrite = 1,
    Ignore = 2,
    NoCheck = 3,
    DoUpdateIfNotNull = 4,
}
impl HandleConflictBehavior {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            HandleConflictBehavior::Unspecified => "HANDLE_CONFLICT_BEHAVIOR_UNSPECIFIED",
            HandleConflictBehavior::Overwrite => "HANDLE_CONFLICT_BEHAVIOR_OVERWRITE",
            HandleConflictBehavior::Ignore => "HANDLE_CONFLICT_BEHAVIOR_IGNORE",
            HandleConflictBehavior::NoCheck => "HANDLE_CONFLICT_BEHAVIOR_NO_CHECK",
            HandleConflictBehavior::DoUpdateIfNotNull => {
                "HANDLE_CONFLICT_BEHAVIOR_DO_UPDATE_IF_NOT_NULL"
            }
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "HANDLE_CONFLICT_BEHAVIOR_UNSPECIFIED" => Some(Self::Unspecified),
            "HANDLE_CONFLICT_BEHAVIOR_OVERWRITE" => Some(Self::Overwrite),
            "HANDLE_CONFLICT_BEHAVIOR_IGNORE" => Some(Self::Ignore),
            "HANDLE_CONFLICT_BEHAVIOR_NO_CHECK" => Some(Self::NoCheck),
            "HANDLE_CONFLICT_BEHAVIOR_DO_UPDATE_IF_NOT_NULL" => {
                Some(Self::DoUpdateIfNotNull)
            }
            _ => None,
        }
    }
}