risingwave_pb/
catalog.rs

1// This file is @generated by prost-build.
2/// A mapping of column indices.
3#[derive(prost_helpers::AnyPB)]
4#[derive(Clone, PartialEq, ::prost::Message)]
5pub struct ColIndexMapping {
6    /// The size of the target space.
7    #[prost(uint64, tag = "1")]
8    pub target_size: u64,
9    /// Each subscript is mapped to the corresponding element.
10    /// For those not mapped, the value will be negative.
11    #[prost(int64, repeated, tag = "2")]
12    pub map: ::prost::alloc::vec::Vec<i64>,
13}
14#[derive(prost_helpers::AnyPB)]
15#[derive(Eq, Hash)]
16#[derive(Clone, PartialEq, ::prost::Message)]
17pub struct WatermarkDesc {
18    /// The column idx the watermark is on
19    #[prost(uint32, tag = "1")]
20    pub watermark_idx: u32,
21    /// The expression to calculate the watermark value.
22    #[prost(message, optional, tag = "2")]
23    pub expr: ::core::option::Option<super::expr::ExprNode>,
24}
25#[derive(prost_helpers::AnyPB)]
26#[derive(Eq, Hash)]
27#[derive(Clone, PartialEq, ::prost::Message)]
28pub struct StreamSourceInfo {
29    /// deprecated
30    #[prost(enumeration = "super::plan_common::RowFormatType", tag = "1")]
31    pub row_format: i32,
32    #[prost(string, tag = "2")]
33    pub row_schema_location: ::prost::alloc::string::String,
34    /// This means *use **confluent** schema registry* and is `false` for **aws glue** schema registry.
35    /// Eventually we will deprecate it and rely on `enum SchemaLocation` derived from `format_encode_options` below.
36    /// * schema.location     false
37    /// * schema.registry     true
38    /// * aws.glue.schema_arn false
39    #[prost(bool, tag = "3")]
40    pub use_schema_registry: bool,
41    #[prost(string, tag = "4")]
42    pub proto_message_name: ::prost::alloc::string::String,
43    #[prost(int32, tag = "5")]
44    pub csv_delimiter: i32,
45    #[prost(bool, tag = "6")]
46    pub csv_has_header: bool,
47    #[prost(enumeration = "super::plan_common::FormatType", tag = "8")]
48    pub format: i32,
49    #[prost(enumeration = "super::plan_common::EncodeType", tag = "9")]
50    pub row_encode: i32,
51    #[prost(enumeration = "SchemaRegistryNameStrategy", tag = "10")]
52    pub name_strategy: i32,
53    #[prost(string, optional, tag = "11")]
54    pub key_message_name: ::core::option::Option<::prost::alloc::string::String>,
55    #[prost(message, optional, tag = "12")]
56    pub external_table: ::core::option::Option<super::plan_common::ExternalTableDesc>,
57    /// **This field should now be called `is_shared`.** Not renamed for backwards
58    /// compatibility.
59    ///
60    /// Whether the stream source is a shared source (it has a streaming job).
61    /// This is related with [RFC: Reusable Source
62    /// Executor](<https://github.com/risingwavelabs/rfcs/pull/72>).
63    ///
64    /// Currently, the following sources can be shared:
65    ///
66    /// - Direct CDC sources (mysql & postgresql & sqlserver)
67    /// - MQ sources (Kafka)
68    #[prost(bool, tag = "13")]
69    pub cdc_source_job: bool,
70    /// Only used when `cdc_source_job` is `true`.
71    /// If `false`, `requires_singleton` will be set in the stream plan.
72    ///
73    /// - Direct CDC sources: `false`
74    /// - MQ sources (Kafka): `true`
75    #[prost(bool, tag = "15")]
76    pub is_distributed: bool,
77    /// Options specified by user in the FORMAT ENCODE clause.
78    #[prost(btree_map = "string, string", tag = "14")]
79    pub format_encode_options: ::prost::alloc::collections::BTreeMap<
80        ::prost::alloc::string::String,
81        ::prost::alloc::string::String,
82    >,
83    /// Handle the source relies on any sceret. The key is the propertity name and the value is the secret id and type.
84    /// For format and encode options.
85    #[prost(btree_map = "string, message", tag = "16")]
86    pub format_encode_secret_refs: ::prost::alloc::collections::BTreeMap<
87        ::prost::alloc::string::String,
88        super::secret::SecretRef,
89    >,
90    /// ref connection for schema registry
91    #[prost(uint32, optional, tag = "17")]
92    pub connection_id: ::core::option::Option<u32>,
93}
94#[derive(prost_helpers::AnyPB)]
95#[derive(Eq, Hash)]
96#[derive(Clone, PartialEq, ::prost::Message)]
97pub struct WebhookSourceInfo {
98    #[prost(message, optional, tag = "1")]
99    pub secret_ref: ::core::option::Option<super::secret::SecretRef>,
100    #[prost(message, optional, tag = "2")]
101    pub signature_expr: ::core::option::Option<super::expr::ExprNode>,
102    /// Return until the data is persisted in the storage layer or not. Default is true.
103    #[prost(bool, tag = "3")]
104    pub wait_for_persistence: bool,
105}
106#[derive(prost_helpers::AnyPB)]
107#[derive(Clone, PartialEq, ::prost::Message)]
108pub struct Source {
109    /// For shared source, this is the same as the job id.
110    /// For non-shared source and table with connector, this is a different oid.
111    #[prost(uint32, tag = "1")]
112    pub id: u32,
113    #[prost(uint32, tag = "2")]
114    pub schema_id: u32,
115    #[prost(uint32, tag = "3")]
116    pub database_id: u32,
117    #[prost(string, tag = "4")]
118    pub name: ::prost::alloc::string::String,
119    /// The column index of row ID. If the primary key is specified by the user,
120    /// this will be `None`.
121    #[prost(uint32, optional, tag = "5")]
122    pub row_id_index: ::core::option::Option<u32>,
123    /// Columns of the source.
124    #[prost(message, repeated, tag = "6")]
125    pub columns: ::prost::alloc::vec::Vec<super::plan_common::ColumnCatalog>,
126    /// Column id of the primary key specified by the user. If the user does not
127    /// specify a primary key, the vector will be empty.
128    #[prost(int32, repeated, tag = "7")]
129    pub pk_column_ids: ::prost::alloc::vec::Vec<i32>,
130    /// Properties specified by the user in WITH clause.
131    #[prost(btree_map = "string, string", tag = "8")]
132    pub with_properties: ::prost::alloc::collections::BTreeMap<
133        ::prost::alloc::string::String,
134        ::prost::alloc::string::String,
135    >,
136    #[prost(uint32, tag = "9")]
137    pub owner: u32,
138    #[prost(message, optional, tag = "10")]
139    pub info: ::core::option::Option<StreamSourceInfo>,
140    /// Define watermarks on the source. The `repeated` is just for forward
141    /// compatibility, currently, only one watermark on the source
142    #[prost(message, repeated, tag = "11")]
143    pub watermark_descs: ::prost::alloc::vec::Vec<WatermarkDesc>,
144    #[prost(string, tag = "13")]
145    pub definition: ::prost::alloc::string::String,
146    /// ref connection for connector
147    #[prost(uint32, optional, tag = "14")]
148    pub connection_id: ::core::option::Option<u32>,
149    #[prost(uint64, optional, tag = "15")]
150    pub initialized_at_epoch: ::core::option::Option<u64>,
151    #[prost(uint64, optional, tag = "16")]
152    pub created_at_epoch: ::core::option::Option<u64>,
153    /// Cluster version (tracked by git commit) when initialized/created
154    #[prost(string, optional, tag = "17")]
155    pub initialized_at_cluster_version: ::core::option::Option<
156        ::prost::alloc::string::String,
157    >,
158    #[prost(string, optional, tag = "18")]
159    pub created_at_cluster_version: ::core::option::Option<
160        ::prost::alloc::string::String,
161    >,
162    /// Handle the source relies on any sceret. The key is the propertity name and the value is the secret id.
163    /// Used for secret connect options.
164    #[prost(btree_map = "string, message", tag = "19")]
165    pub secret_refs: ::prost::alloc::collections::BTreeMap<
166        ::prost::alloc::string::String,
167        super::secret::SecretRef,
168    >,
169    /// Per-source catalog version, used by schema change.
170    #[prost(uint64, tag = "100")]
171    pub version: u64,
172    #[prost(uint32, optional, tag = "101")]
173    pub rate_limit: ::core::option::Option<u32>,
174    /// Indicate whether this source is created by table.
175    #[prost(oneof = "source::OptionalAssociatedTableId", tags = "12")]
176    pub optional_associated_table_id: ::core::option::Option<
177        source::OptionalAssociatedTableId,
178    >,
179}
180/// Nested message and enum types in `Source`.
181pub mod source {
182    /// Indicate whether this source is created by table.
183    #[derive(prost_helpers::AnyPB)]
184    #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
185    pub enum OptionalAssociatedTableId {
186        #[prost(uint32, tag = "12")]
187        AssociatedTableId(u32),
188    }
189}
190/// Similar to `StreamSourceInfo`, and may replace `SinkType` later.
191#[derive(prost_helpers::AnyPB)]
192#[derive(Clone, PartialEq, ::prost::Message)]
193pub struct SinkFormatDesc {
194    #[prost(enumeration = "super::plan_common::FormatType", tag = "1")]
195    pub format: i32,
196    #[prost(enumeration = "super::plan_common::EncodeType", tag = "2")]
197    pub encode: i32,
198    #[prost(btree_map = "string, string", tag = "3")]
199    pub options: ::prost::alloc::collections::BTreeMap<
200        ::prost::alloc::string::String,
201        ::prost::alloc::string::String,
202    >,
203    #[prost(enumeration = "super::plan_common::EncodeType", optional, tag = "4")]
204    pub key_encode: ::core::option::Option<i32>,
205    /// Secret used for format encode options.
206    #[prost(btree_map = "string, message", tag = "5")]
207    pub secret_refs: ::prost::alloc::collections::BTreeMap<
208        ::prost::alloc::string::String,
209        super::secret::SecretRef,
210    >,
211    /// ref connection for schema registry
212    #[prost(uint32, optional, tag = "6")]
213    pub connection_id: ::core::option::Option<u32>,
214}
215/// the catalog of the sink. There are two kind of schema here. The full schema is all columns
216/// stored in the `column` which is the sink executor/fragment's output schema. The visible
217/// schema contains the columns whose `is_hidden` is false, which is the columns sink out to the
218/// external system. The distribution key and all other keys are indexed in the full schema.
219#[derive(prost_helpers::AnyPB)]
220#[derive(Clone, PartialEq, ::prost::Message)]
221pub struct Sink {
222    #[prost(uint32, tag = "1")]
223    pub id: u32,
224    #[prost(uint32, tag = "2")]
225    pub schema_id: u32,
226    #[prost(uint32, tag = "3")]
227    pub database_id: u32,
228    #[prost(string, tag = "4")]
229    pub name: ::prost::alloc::string::String,
230    #[prost(message, repeated, tag = "5")]
231    pub columns: ::prost::alloc::vec::Vec<super::plan_common::ColumnCatalog>,
232    /// Primary key derived from the SQL by the frontend.
233    #[prost(message, repeated, tag = "6")]
234    pub plan_pk: ::prost::alloc::vec::Vec<super::common::ColumnOrder>,
235    #[deprecated]
236    #[prost(uint32, repeated, packed = "false", tag = "7")]
237    pub dependent_relations: ::prost::alloc::vec::Vec<u32>,
238    #[prost(int32, repeated, tag = "8")]
239    pub distribution_key: ::prost::alloc::vec::Vec<i32>,
240    /// User-defined primary key indices for the upsert sink.
241    #[prost(int32, repeated, tag = "9")]
242    pub downstream_pk: ::prost::alloc::vec::Vec<i32>,
243    /// to be deprecated
244    #[prost(enumeration = "SinkType", tag = "10")]
245    pub sink_type: i32,
246    #[prost(uint32, tag = "11")]
247    pub owner: u32,
248    #[prost(btree_map = "string, string", tag = "12")]
249    pub properties: ::prost::alloc::collections::BTreeMap<
250        ::prost::alloc::string::String,
251        ::prost::alloc::string::String,
252    >,
253    #[prost(string, tag = "13")]
254    pub definition: ::prost::alloc::string::String,
255    /// ref connection for connector
256    #[prost(uint32, optional, tag = "14")]
257    pub connection_id: ::core::option::Option<u32>,
258    #[prost(uint64, optional, tag = "15")]
259    pub initialized_at_epoch: ::core::option::Option<u64>,
260    #[prost(uint64, optional, tag = "16")]
261    pub created_at_epoch: ::core::option::Option<u64>,
262    #[prost(string, tag = "17")]
263    pub db_name: ::prost::alloc::string::String,
264    #[prost(string, tag = "18")]
265    pub sink_from_name: ::prost::alloc::string::String,
266    #[prost(enumeration = "StreamJobStatus", tag = "19")]
267    pub stream_job_status: i32,
268    #[prost(message, optional, tag = "20")]
269    pub format_desc: ::core::option::Option<SinkFormatDesc>,
270    /// Target table id (only applicable for table sink)
271    #[prost(uint32, optional, tag = "21")]
272    pub target_table: ::core::option::Option<u32>,
273    /// Cluster version (tracked by git commit) when initialized/created
274    #[prost(string, optional, tag = "22")]
275    pub initialized_at_cluster_version: ::core::option::Option<
276        ::prost::alloc::string::String,
277    >,
278    #[prost(string, optional, tag = "23")]
279    pub created_at_cluster_version: ::core::option::Option<
280        ::prost::alloc::string::String,
281    >,
282    /// Whether it should use background ddl or block until backfill finishes.
283    #[prost(enumeration = "CreateType", tag = "24")]
284    pub create_type: i32,
285    /// Handle the sink relies on any sceret. The key is the propertity name and the value is the secret id and type.
286    /// Used for connect options.
287    #[prost(btree_map = "string, message", tag = "25")]
288    pub secret_refs: ::prost::alloc::collections::BTreeMap<
289        ::prost::alloc::string::String,
290        super::secret::SecretRef,
291    >,
292    /// 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.
293    #[prost(message, repeated, tag = "26")]
294    pub original_target_columns: ::prost::alloc::vec::Vec<
295        super::plan_common::ColumnCatalog,
296    >,
297}
298#[derive(prost_helpers::AnyPB)]
299#[derive(Clone, PartialEq, ::prost::Message)]
300pub struct Subscription {
301    #[prost(uint32, tag = "1")]
302    pub id: u32,
303    #[prost(string, tag = "2")]
304    pub name: ::prost::alloc::string::String,
305    #[prost(string, tag = "3")]
306    pub definition: ::prost::alloc::string::String,
307    #[prost(uint64, tag = "6")]
308    pub retention_seconds: u64,
309    #[prost(uint32, tag = "8")]
310    pub database_id: u32,
311    #[prost(uint32, tag = "9")]
312    pub schema_id: u32,
313    #[prost(uint32, tag = "10")]
314    pub dependent_table_id: u32,
315    #[prost(uint64, optional, tag = "11")]
316    pub initialized_at_epoch: ::core::option::Option<u64>,
317    #[prost(uint64, optional, tag = "12")]
318    pub created_at_epoch: ::core::option::Option<u64>,
319    #[prost(uint32, tag = "13")]
320    pub owner: u32,
321    #[prost(string, optional, tag = "15")]
322    pub initialized_at_cluster_version: ::core::option::Option<
323        ::prost::alloc::string::String,
324    >,
325    #[prost(string, optional, tag = "16")]
326    pub created_at_cluster_version: ::core::option::Option<
327        ::prost::alloc::string::String,
328    >,
329    #[prost(enumeration = "subscription::SubscriptionState", tag = "19")]
330    pub subscription_state: i32,
331}
332/// Nested message and enum types in `Subscription`.
333pub mod subscription {
334    #[derive(prost_helpers::AnyPB)]
335    #[derive(
336        Clone,
337        Copy,
338        Debug,
339        PartialEq,
340        Eq,
341        Hash,
342        PartialOrd,
343        Ord,
344        ::prost::Enumeration
345    )]
346    #[repr(i32)]
347    pub enum SubscriptionState {
348        Unspecified = 0,
349        Init = 1,
350        Created = 2,
351    }
352    impl SubscriptionState {
353        /// String value of the enum field names used in the ProtoBuf definition.
354        ///
355        /// The values are not transformed in any way and thus are considered stable
356        /// (if the ProtoBuf definition does not change) and safe for programmatic use.
357        pub fn as_str_name(&self) -> &'static str {
358            match self {
359                Self::Unspecified => "UNSPECIFIED",
360                Self::Init => "INIT",
361                Self::Created => "CREATED",
362            }
363        }
364        /// Creates an enum from field names used in the ProtoBuf definition.
365        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
366            match value {
367                "UNSPECIFIED" => Some(Self::Unspecified),
368                "INIT" => Some(Self::Init),
369                "CREATED" => Some(Self::Created),
370                _ => None,
371            }
372        }
373    }
374}
375#[derive(prost_helpers::AnyPB)]
376#[derive(Clone, PartialEq, ::prost::Message)]
377pub struct ConnectionParams {
378    #[prost(enumeration = "connection_params::ConnectionType", tag = "1")]
379    pub connection_type: i32,
380    #[prost(map = "string, string", tag = "2")]
381    pub properties: ::std::collections::HashMap<
382        ::prost::alloc::string::String,
383        ::prost::alloc::string::String,
384    >,
385    #[prost(map = "string, message", tag = "3")]
386    pub secret_refs: ::std::collections::HashMap<
387        ::prost::alloc::string::String,
388        super::secret::SecretRef,
389    >,
390}
391/// Nested message and enum types in `ConnectionParams`.
392pub mod connection_params {
393    #[derive(prost_helpers::AnyPB)]
394    #[derive(
395        Clone,
396        Copy,
397        Debug,
398        PartialEq,
399        Eq,
400        Hash,
401        PartialOrd,
402        Ord,
403        ::prost::Enumeration
404    )]
405    #[repr(i32)]
406    pub enum ConnectionType {
407        Unspecified = 0,
408        Kafka = 1,
409        Iceberg = 2,
410        SchemaRegistry = 3,
411        Elasticsearch = 4,
412    }
413    impl ConnectionType {
414        /// String value of the enum field names used in the ProtoBuf definition.
415        ///
416        /// The values are not transformed in any way and thus are considered stable
417        /// (if the ProtoBuf definition does not change) and safe for programmatic use.
418        pub fn as_str_name(&self) -> &'static str {
419            match self {
420                Self::Unspecified => "CONNECTION_TYPE_UNSPECIFIED",
421                Self::Kafka => "CONNECTION_TYPE_KAFKA",
422                Self::Iceberg => "CONNECTION_TYPE_ICEBERG",
423                Self::SchemaRegistry => "CONNECTION_TYPE_SCHEMA_REGISTRY",
424                Self::Elasticsearch => "CONNECTION_TYPE_ELASTICSEARCH",
425            }
426        }
427        /// Creates an enum from field names used in the ProtoBuf definition.
428        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
429            match value {
430                "CONNECTION_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
431                "CONNECTION_TYPE_KAFKA" => Some(Self::Kafka),
432                "CONNECTION_TYPE_ICEBERG" => Some(Self::Iceberg),
433                "CONNECTION_TYPE_SCHEMA_REGISTRY" => Some(Self::SchemaRegistry),
434                "CONNECTION_TYPE_ELASTICSEARCH" => Some(Self::Elasticsearch),
435                _ => None,
436            }
437        }
438    }
439}
440#[derive(prost_helpers::AnyPB)]
441#[derive(Clone, PartialEq, ::prost::Message)]
442pub struct Connection {
443    #[prost(uint32, tag = "1")]
444    pub id: u32,
445    #[prost(uint32, tag = "2")]
446    pub schema_id: u32,
447    #[prost(uint32, tag = "3")]
448    pub database_id: u32,
449    #[prost(string, tag = "4")]
450    pub name: ::prost::alloc::string::String,
451    #[prost(uint32, tag = "6")]
452    pub owner: u32,
453    #[prost(oneof = "connection::Info", tags = "5, 7")]
454    pub info: ::core::option::Option<connection::Info>,
455}
456/// Nested message and enum types in `Connection`.
457pub mod connection {
458    #[derive(prost_helpers::AnyPB)]
459    #[derive(Clone, PartialEq, ::prost::Message)]
460    pub struct PrivateLinkService {
461        #[prost(enumeration = "private_link_service::PrivateLinkProvider", tag = "1")]
462        pub provider: i32,
463        #[prost(string, tag = "2")]
464        pub service_name: ::prost::alloc::string::String,
465        #[prost(string, tag = "3")]
466        pub endpoint_id: ::prost::alloc::string::String,
467        #[prost(map = "string, string", tag = "4")]
468        pub dns_entries: ::std::collections::HashMap<
469            ::prost::alloc::string::String,
470            ::prost::alloc::string::String,
471        >,
472        #[prost(string, tag = "5")]
473        pub endpoint_dns_name: ::prost::alloc::string::String,
474    }
475    /// Nested message and enum types in `PrivateLinkService`.
476    pub mod private_link_service {
477        #[derive(prost_helpers::AnyPB)]
478        #[derive(
479            Clone,
480            Copy,
481            Debug,
482            PartialEq,
483            Eq,
484            Hash,
485            PartialOrd,
486            Ord,
487            ::prost::Enumeration
488        )]
489        #[repr(i32)]
490        pub enum PrivateLinkProvider {
491            Unspecified = 0,
492            Mock = 1,
493            Aws = 2,
494        }
495        impl PrivateLinkProvider {
496            /// String value of the enum field names used in the ProtoBuf definition.
497            ///
498            /// The values are not transformed in any way and thus are considered stable
499            /// (if the ProtoBuf definition does not change) and safe for programmatic use.
500            pub fn as_str_name(&self) -> &'static str {
501                match self {
502                    Self::Unspecified => "UNSPECIFIED",
503                    Self::Mock => "MOCK",
504                    Self::Aws => "AWS",
505                }
506            }
507            /// Creates an enum from field names used in the ProtoBuf definition.
508            pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
509                match value {
510                    "UNSPECIFIED" => Some(Self::Unspecified),
511                    "MOCK" => Some(Self::Mock),
512                    "AWS" => Some(Self::Aws),
513                    _ => None,
514                }
515            }
516        }
517    }
518    #[derive(prost_helpers::AnyPB)]
519    #[derive(Clone, PartialEq, ::prost::Oneof)]
520    pub enum Info {
521        #[prost(message, tag = "5")]
522        PrivateLinkService(PrivateLinkService),
523        #[prost(message, tag = "7")]
524        ConnectionParams(super::ConnectionParams),
525    }
526}
527#[derive(prost_helpers::AnyPB)]
528#[derive(Clone, PartialEq, ::prost::Message)]
529pub struct Index {
530    #[prost(uint32, tag = "1")]
531    pub id: u32,
532    #[prost(uint32, tag = "2")]
533    pub schema_id: u32,
534    #[prost(uint32, tag = "3")]
535    pub database_id: u32,
536    #[prost(string, tag = "4")]
537    pub name: ::prost::alloc::string::String,
538    #[prost(uint32, tag = "5")]
539    pub owner: u32,
540    #[prost(uint32, tag = "6")]
541    pub index_table_id: u32,
542    #[prost(uint32, tag = "7")]
543    pub primary_table_id: u32,
544    /// Only `InputRef` type index is supported Now.
545    /// The index of `InputRef` is the column index of the primary table.
546    #[prost(message, repeated, tag = "8")]
547    pub index_item: ::prost::alloc::vec::Vec<super::expr::ExprNode>,
548    #[prost(message, repeated, tag = "16")]
549    pub index_column_properties: ::prost::alloc::vec::Vec<IndexColumnProperties>,
550    #[prost(uint64, optional, tag = "10")]
551    pub initialized_at_epoch: ::core::option::Option<u64>,
552    #[prost(uint64, optional, tag = "11")]
553    pub created_at_epoch: ::core::option::Option<u64>,
554    #[prost(enumeration = "StreamJobStatus", tag = "12")]
555    pub stream_job_status: i32,
556    /// Use to record the prefix len of the index_item to reconstruct index columns
557    /// provided by users.
558    #[prost(uint32, tag = "13")]
559    pub index_columns_len: u32,
560    /// Cluster version (tracked by git commit) when initialized/created
561    #[prost(string, optional, tag = "14")]
562    pub initialized_at_cluster_version: ::core::option::Option<
563        ::prost::alloc::string::String,
564    >,
565    #[prost(string, optional, tag = "15")]
566    pub created_at_cluster_version: ::core::option::Option<
567        ::prost::alloc::string::String,
568    >,
569}
570/// <https://www.postgresql.org/docs/current/functions-info.html#FUNCTIONS-INFO-INDEX-COLUMN-PROPS>
571#[derive(prost_helpers::AnyPB)]
572#[derive(Eq, Hash)]
573#[derive(Clone, Copy, PartialEq, ::prost::Message)]
574pub struct IndexColumnProperties {
575    /// Whether the column sort in ascending(false) or descending(true) order on a forward scan.
576    #[prost(bool, tag = "1")]
577    pub is_desc: bool,
578    /// Does the column sort with nulls first on a forward scan?
579    #[prost(bool, tag = "2")]
580    pub nulls_first: bool,
581}
582#[derive(prost_helpers::AnyPB)]
583#[derive(Clone, PartialEq, ::prost::Message)]
584pub struct Function {
585    #[prost(uint32, tag = "1")]
586    pub id: u32,
587    #[prost(uint32, tag = "2")]
588    pub schema_id: u32,
589    #[prost(uint32, tag = "3")]
590    pub database_id: u32,
591    #[prost(string, tag = "4")]
592    pub name: ::prost::alloc::string::String,
593    #[prost(uint32, tag = "9")]
594    pub owner: u32,
595    #[prost(string, repeated, tag = "15")]
596    pub arg_names: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
597    #[prost(message, repeated, tag = "5")]
598    pub arg_types: ::prost::alloc::vec::Vec<super::data::DataType>,
599    #[prost(message, optional, tag = "6")]
600    pub return_type: ::core::option::Option<super::data::DataType>,
601    #[prost(string, tag = "7")]
602    pub language: ::prost::alloc::string::String,
603    #[prost(string, optional, tag = "8")]
604    pub link: ::core::option::Option<::prost::alloc::string::String>,
605    /// The function name in the runtime / on the remote side that is bound to the UDF created in RisingWave.
606    #[prost(string, optional, tag = "10")]
607    pub name_in_runtime: ::core::option::Option<::prost::alloc::string::String>,
608    /// The source code of the function.
609    #[prost(string, optional, tag = "14")]
610    pub body: ::core::option::Option<::prost::alloc::string::String>,
611    /// The zstd-compressed binary of the function.
612    #[prost(bytes = "vec", optional, tag = "17")]
613    pub compressed_binary: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
614    #[prost(bool, tag = "16")]
615    pub always_retry_on_network_error: bool,
616    /// The runtime selected when multiple runtimes are available for the language. Now is not used.
617    #[prost(string, optional, tag = "18")]
618    pub runtime: ::core::option::Option<::prost::alloc::string::String>,
619    /// additional options for javascript functions
620    #[prost(bool, optional, tag = "20")]
621    pub is_async: ::core::option::Option<bool>,
622    #[prost(bool, optional, tag = "21")]
623    pub is_batched: ::core::option::Option<bool>,
624    #[prost(oneof = "function::Kind", tags = "11, 12, 13")]
625    pub kind: ::core::option::Option<function::Kind>,
626}
627/// Nested message and enum types in `Function`.
628pub mod function {
629    #[derive(prost_helpers::AnyPB)]
630    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
631    pub struct ScalarFunction {}
632    #[derive(prost_helpers::AnyPB)]
633    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
634    pub struct TableFunction {}
635    #[derive(prost_helpers::AnyPB)]
636    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
637    pub struct AggregateFunction {}
638    #[derive(prost_helpers::AnyPB)]
639    #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
640    pub enum Kind {
641        #[prost(message, tag = "11")]
642        Scalar(ScalarFunction),
643        #[prost(message, tag = "12")]
644        Table(TableFunction),
645        #[prost(message, tag = "13")]
646        Aggregate(AggregateFunction),
647    }
648}
649/// Includes full information about a table.
650///
651/// Here `Table` is an internal concept, corresponding to _a table in storage_, all of which can be `SELECT`ed.
652/// It is not the same as a user-side table created by `CREATE TABLE`.
653///
654/// See `TableCatalog` struct in frontend crate for more information.
655#[derive(prost_helpers::AnyPB)]
656#[derive(Clone, PartialEq, ::prost::Message)]
657pub struct Table {
658    #[prost(uint32, tag = "1")]
659    pub id: u32,
660    #[prost(uint32, tag = "2")]
661    pub schema_id: u32,
662    #[prost(uint32, tag = "3")]
663    pub database_id: u32,
664    #[prost(string, tag = "4")]
665    pub name: ::prost::alloc::string::String,
666    #[prost(message, repeated, tag = "5")]
667    pub columns: ::prost::alloc::vec::Vec<super::plan_common::ColumnCatalog>,
668    #[prost(message, repeated, tag = "6")]
669    pub pk: ::prost::alloc::vec::Vec<super::common::ColumnOrder>,
670    /// For cdc table created from a cdc source, here records the source id.
671    ///
672    /// TODO(rc): deprecate this by passing dependencies via `Request` message
673    #[prost(uint32, repeated, tag = "8")]
674    pub dependent_relations: ::prost::alloc::vec::Vec<u32>,
675    #[prost(enumeration = "table::TableType", tag = "10")]
676    pub table_type: i32,
677    #[prost(int32, repeated, tag = "12")]
678    pub distribution_key: ::prost::alloc::vec::Vec<i32>,
679    /// pk_indices of the corresponding materialize operator's output.
680    #[prost(int32, repeated, tag = "13")]
681    pub stream_key: ::prost::alloc::vec::Vec<i32>,
682    #[prost(bool, tag = "14")]
683    pub append_only: bool,
684    #[prost(uint32, tag = "15")]
685    pub owner: u32,
686    #[prost(uint32, tag = "17")]
687    pub fragment_id: u32,
688    /// an optional column index which is the vnode of each row computed by the
689    /// table's consistent hash distribution
690    #[prost(uint32, optional, tag = "18")]
691    pub vnode_col_index: ::core::option::Option<u32>,
692    /// An optional column index of row id. If the primary key is specified by
693    /// users, this will be `None`.
694    #[prost(uint32, optional, tag = "19")]
695    pub row_id_index: ::core::option::Option<u32>,
696    /// The column indices which are stored in the state store's value with
697    /// row-encoding. Currently is not supported yet and expected to be
698    /// `\[0..columns.len()\]`.
699    #[prost(int32, repeated, tag = "20")]
700    pub value_indices: ::prost::alloc::vec::Vec<i32>,
701    #[prost(string, tag = "21")]
702    pub definition: ::prost::alloc::string::String,
703    /// Used to control whether handling pk conflict for incoming data.
704    #[prost(enumeration = "HandleConflictBehavior", tag = "22")]
705    pub handle_pk_conflict_behavior: i32,
706    /// Anticipated read prefix pattern (number of fields) for the table, which can
707    /// be utilized for implementing the table's bloom filter or other storage
708    /// optimization techniques.
709    #[prost(uint32, tag = "23")]
710    pub read_prefix_len_hint: u32,
711    #[prost(int32, repeated, tag = "24")]
712    pub watermark_indices: ::prost::alloc::vec::Vec<i32>,
713    #[prost(int32, repeated, tag = "25")]
714    pub dist_key_in_pk: ::prost::alloc::vec::Vec<i32>,
715    /// A dml fragment id corresponds to the table, used to decide where the dml
716    /// statement is executed.
717    #[prost(uint32, optional, tag = "26")]
718    pub dml_fragment_id: ::core::option::Option<u32>,
719    /// The range of row count of the table.
720    /// This field is not always present due to backward compatibility. Use
721    /// `Cardinality::unknown` in this case.
722    #[prost(message, optional, tag = "27")]
723    pub cardinality: ::core::option::Option<super::plan_common::Cardinality>,
724    #[prost(uint64, optional, tag = "28")]
725    pub initialized_at_epoch: ::core::option::Option<u64>,
726    #[prost(uint64, optional, tag = "29")]
727    pub created_at_epoch: ::core::option::Option<u64>,
728    /// This field is introduced in v1.2.0. It is used to indicate whether the
729    /// table should use watermark_cache to avoid state cleaning as a performance
730    /// optimization. In older versions we can just initialize without it.
731    #[prost(bool, tag = "30")]
732    pub cleaned_by_watermark: bool,
733    /// Used to filter created / creating tables in meta.
734    #[prost(enumeration = "StreamJobStatus", tag = "31")]
735    pub stream_job_status: i32,
736    #[prost(enumeration = "CreateType", tag = "32")]
737    pub create_type: i32,
738    /// This field is used to store the description set by the `comment on` clause.
739    #[prost(string, optional, tag = "33")]
740    pub description: ::core::option::Option<::prost::alloc::string::String>,
741    /// This field is used to mark the the sink into this table.
742    #[prost(uint32, repeated, tag = "34")]
743    pub incoming_sinks: ::prost::alloc::vec::Vec<u32>,
744    /// Cluster version (tracked by git commit) when initialized/created
745    #[prost(string, optional, tag = "35")]
746    pub initialized_at_cluster_version: ::core::option::Option<
747        ::prost::alloc::string::String,
748    >,
749    #[prost(string, optional, tag = "36")]
750    pub created_at_cluster_version: ::core::option::Option<
751        ::prost::alloc::string::String,
752    >,
753    /// TTL of the record in the table, to ensure the consistency with other tables
754    /// in the streaming plan, it only applies to append-only tables.
755    #[prost(uint32, optional, tag = "37")]
756    pub retention_seconds: ::core::option::Option<u32>,
757    /// This field specifies the index of the column set in the "with version
758    /// column" within all the columns. It is used for filtering during "on
759    /// conflict" operations.
760    #[prost(uint32, optional, tag = "38")]
761    pub version_column_index: ::core::option::Option<u32>,
762    /// The unique identifier of the upstream table if it is a CDC table.
763    /// It will be used in auto schema change to get the Table which mapped to the
764    /// upstream table.
765    #[prost(string, optional, tag = "39")]
766    pub cdc_table_id: ::core::option::Option<::prost::alloc::string::String>,
767    /// Total vnode count of the table.
768    ///
769    /// Use `VnodeCountCompat::vnode_count` to access it.
770    ///
771    /// - Can be unset if the table is created in older versions where variable vnode count is not
772    ///    supported, in which case a default value of 256 (or 1 for singleton) should be used.
773    /// - Can be placeholder value `Some(0)` if the catalog is generated by the frontend and the
774    ///    corresponding job is still in `Creating` status, in which case calling `vnode_count`
775    ///    will panic.
776    ///
777    /// Please note that this field is not intended to describe the expected vnode count
778    /// for a streaming job. Instead, refer to `stream_plan.StreamFragmentGraph.max_parallelism`.
779    #[prost(uint32, optional, tag = "40")]
780    pub maybe_vnode_count: ::core::option::Option<u32>,
781    /// The information used by webhook source to validate the incoming data.
782    #[prost(message, optional, tag = "41")]
783    pub webhook_info: ::core::option::Option<WebhookSourceInfo>,
784    /// This field stores the job ID for internal tables.
785    #[prost(uint32, optional, tag = "42")]
786    pub job_id: ::core::option::Option<u32>,
787    /// Table Engine, currently only support hummock and iceberg
788    #[prost(enumeration = "table::Engine", optional, tag = "43")]
789    pub engine: ::core::option::Option<i32>,
790    /// Indicate the index of the watermark column in the primary key that should be cleaned.
791    /// NOTICE: when it is "None", the watermark column should be the first column in the pk
792    #[prost(int32, optional, tag = "44")]
793    pub clean_watermark_index_in_pk: ::core::option::Option<i32>,
794    /// Per-table catalog version, used by schema change. `None` for internal
795    /// tables and tests. Not to be confused with the global catalog version for
796    /// notification service.
797    #[prost(message, optional, tag = "100")]
798    pub version: ::core::option::Option<table::TableVersion>,
799    #[prost(oneof = "table::OptionalAssociatedSourceId", tags = "9")]
800    pub optional_associated_source_id: ::core::option::Option<
801        table::OptionalAssociatedSourceId,
802    >,
803}
804/// Nested message and enum types in `Table`.
805pub mod table {
806    #[derive(prost_helpers::AnyPB)]
807    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
808    pub struct TableVersion {
809        /// The version number, which will be 0 by default and be increased by 1 for
810        /// each schema change in the frontend.
811        #[prost(uint64, tag = "1")]
812        pub version: u64,
813        /// The ID of the next column to be added, which is used to make all columns
814        /// in the table have unique IDs, even if some columns have been dropped.
815        #[prost(int32, tag = "2")]
816        pub next_column_id: i32,
817    }
818    #[derive(prost_helpers::AnyPB)]
819    #[derive(
820        Clone,
821        Copy,
822        Debug,
823        PartialEq,
824        Eq,
825        Hash,
826        PartialOrd,
827        Ord,
828        ::prost::Enumeration
829    )]
830    #[repr(i32)]
831    pub enum TableType {
832        Unspecified = 0,
833        Table = 1,
834        MaterializedView = 2,
835        Index = 3,
836        Internal = 4,
837    }
838    impl TableType {
839        /// String value of the enum field names used in the ProtoBuf definition.
840        ///
841        /// The values are not transformed in any way and thus are considered stable
842        /// (if the ProtoBuf definition does not change) and safe for programmatic use.
843        pub fn as_str_name(&self) -> &'static str {
844            match self {
845                Self::Unspecified => "UNSPECIFIED",
846                Self::Table => "TABLE",
847                Self::MaterializedView => "MATERIALIZED_VIEW",
848                Self::Index => "INDEX",
849                Self::Internal => "INTERNAL",
850            }
851        }
852        /// Creates an enum from field names used in the ProtoBuf definition.
853        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
854            match value {
855                "UNSPECIFIED" => Some(Self::Unspecified),
856                "TABLE" => Some(Self::Table),
857                "MATERIALIZED_VIEW" => Some(Self::MaterializedView),
858                "INDEX" => Some(Self::Index),
859                "INTERNAL" => Some(Self::Internal),
860                _ => None,
861            }
862        }
863    }
864    #[derive(prost_helpers::AnyPB)]
865    #[derive(
866        Clone,
867        Copy,
868        Debug,
869        PartialEq,
870        Eq,
871        Hash,
872        PartialOrd,
873        Ord,
874        ::prost::Enumeration
875    )]
876    #[repr(i32)]
877    pub enum Engine {
878        Unspecified = 0,
879        Hummock = 1,
880        Iceberg = 2,
881    }
882    impl Engine {
883        /// String value of the enum field names used in the ProtoBuf definition.
884        ///
885        /// The values are not transformed in any way and thus are considered stable
886        /// (if the ProtoBuf definition does not change) and safe for programmatic use.
887        pub fn as_str_name(&self) -> &'static str {
888            match self {
889                Self::Unspecified => "ENGINE_UNSPECIFIED",
890                Self::Hummock => "HUMMOCK",
891                Self::Iceberg => "ICEBERG",
892            }
893        }
894        /// Creates an enum from field names used in the ProtoBuf definition.
895        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
896            match value {
897                "ENGINE_UNSPECIFIED" => Some(Self::Unspecified),
898                "HUMMOCK" => Some(Self::Hummock),
899                "ICEBERG" => Some(Self::Iceberg),
900                _ => None,
901            }
902        }
903    }
904    #[derive(prost_helpers::AnyPB)]
905    #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
906    pub enum OptionalAssociatedSourceId {
907        #[prost(uint32, tag = "9")]
908        AssociatedSourceId(u32),
909    }
910}
911#[derive(prost_helpers::AnyPB)]
912#[derive(Clone, PartialEq, ::prost::Message)]
913pub struct View {
914    #[prost(uint32, tag = "1")]
915    pub id: u32,
916    #[prost(uint32, tag = "2")]
917    pub schema_id: u32,
918    #[prost(uint32, tag = "3")]
919    pub database_id: u32,
920    #[prost(string, tag = "4")]
921    pub name: ::prost::alloc::string::String,
922    #[prost(uint32, tag = "5")]
923    pub owner: u32,
924    #[prost(btree_map = "string, string", tag = "6")]
925    pub properties: ::prost::alloc::collections::BTreeMap<
926        ::prost::alloc::string::String,
927        ::prost::alloc::string::String,
928    >,
929    #[prost(string, tag = "7")]
930    pub sql: ::prost::alloc::string::String,
931    #[prost(uint32, repeated, tag = "8")]
932    pub dependent_relations: ::prost::alloc::vec::Vec<u32>,
933    /// User-specified column names.
934    #[prost(message, repeated, tag = "9")]
935    pub columns: ::prost::alloc::vec::Vec<super::plan_common::Field>,
936}
937#[derive(prost_helpers::AnyPB)]
938#[derive(Clone, PartialEq, ::prost::Message)]
939pub struct Schema {
940    #[prost(uint32, tag = "1")]
941    pub id: u32,
942    #[prost(uint32, tag = "2")]
943    pub database_id: u32,
944    #[prost(string, tag = "3")]
945    pub name: ::prost::alloc::string::String,
946    #[prost(uint32, tag = "4")]
947    pub owner: u32,
948}
949#[derive(prost_helpers::AnyPB)]
950#[derive(Clone, PartialEq, ::prost::Message)]
951pub struct Database {
952    #[prost(uint32, tag = "1")]
953    pub id: u32,
954    #[prost(string, tag = "2")]
955    pub name: ::prost::alloc::string::String,
956    #[prost(uint32, tag = "3")]
957    pub owner: u32,
958    #[prost(string, tag = "4")]
959    pub resource_group: ::prost::alloc::string::String,
960}
961#[derive(prost_helpers::AnyPB)]
962#[derive(Clone, PartialEq, ::prost::Message)]
963pub struct Comment {
964    #[prost(uint32, tag = "1")]
965    pub table_id: u32,
966    #[prost(uint32, tag = "2")]
967    pub schema_id: u32,
968    #[prost(uint32, tag = "3")]
969    pub database_id: u32,
970    #[prost(uint32, optional, tag = "4")]
971    pub column_index: ::core::option::Option<u32>,
972    #[prost(string, optional, tag = "5")]
973    pub description: ::core::option::Option<::prost::alloc::string::String>,
974}
975#[derive(prost_helpers::AnyPB)]
976#[derive(Clone, PartialEq, ::prost::Message)]
977pub struct Secret {
978    #[prost(uint32, tag = "1")]
979    pub id: u32,
980    #[prost(string, tag = "2")]
981    pub name: ::prost::alloc::string::String,
982    #[prost(uint32, tag = "3")]
983    pub database_id: u32,
984    /// The secret here is encrypted to bytes.
985    #[prost(bytes = "vec", tag = "4")]
986    pub value: ::prost::alloc::vec::Vec<u8>,
987    #[prost(uint32, tag = "5")]
988    pub owner: u32,
989    #[prost(uint32, tag = "6")]
990    pub schema_id: u32,
991}
992#[derive(prost_helpers::AnyPB)]
993#[derive(Clone, PartialEq, ::prost::Message)]
994pub struct OptionsWithSecret {
995    #[prost(map = "string, string", tag = "1")]
996    pub options: ::std::collections::HashMap<
997        ::prost::alloc::string::String,
998        ::prost::alloc::string::String,
999    >,
1000    #[prost(map = "string, message", tag = "2")]
1001    pub secret_refs: ::std::collections::HashMap<
1002        ::prost::alloc::string::String,
1003        super::secret::SecretRef,
1004    >,
1005}
1006#[derive(prost_helpers::AnyPB)]
1007#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1008#[repr(i32)]
1009pub enum SchemaRegistryNameStrategy {
1010    Unspecified = 0,
1011    RecordNameStrategy = 1,
1012    TopicRecordNameStrategy = 2,
1013}
1014impl SchemaRegistryNameStrategy {
1015    /// String value of the enum field names used in the ProtoBuf definition.
1016    ///
1017    /// The values are not transformed in any way and thus are considered stable
1018    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
1019    pub fn as_str_name(&self) -> &'static str {
1020        match self {
1021            Self::Unspecified => "SCHEMA_REGISTRY_NAME_STRATEGY_UNSPECIFIED",
1022            Self::RecordNameStrategy => {
1023                "SCHEMA_REGISTRY_NAME_STRATEGY_RECORD_NAME_STRATEGY"
1024            }
1025            Self::TopicRecordNameStrategy => {
1026                "SCHEMA_REGISTRY_NAME_STRATEGY_TOPIC_RECORD_NAME_STRATEGY"
1027            }
1028        }
1029    }
1030    /// Creates an enum from field names used in the ProtoBuf definition.
1031    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1032        match value {
1033            "SCHEMA_REGISTRY_NAME_STRATEGY_UNSPECIFIED" => Some(Self::Unspecified),
1034            "SCHEMA_REGISTRY_NAME_STRATEGY_RECORD_NAME_STRATEGY" => {
1035                Some(Self::RecordNameStrategy)
1036            }
1037            "SCHEMA_REGISTRY_NAME_STRATEGY_TOPIC_RECORD_NAME_STRATEGY" => {
1038                Some(Self::TopicRecordNameStrategy)
1039            }
1040            _ => None,
1041        }
1042    }
1043}
1044#[derive(prost_helpers::AnyPB)]
1045#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1046#[repr(i32)]
1047pub enum StreamJobStatus {
1048    /// Prefixed by `STREAM_JOB_STATUS` due to protobuf namespacing rules.
1049    Unspecified = 0,
1050    Creating = 1,
1051    Created = 2,
1052}
1053impl StreamJobStatus {
1054    /// String value of the enum field names used in the ProtoBuf definition.
1055    ///
1056    /// The values are not transformed in any way and thus are considered stable
1057    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
1058    pub fn as_str_name(&self) -> &'static str {
1059        match self {
1060            Self::Unspecified => "STREAM_JOB_STATUS_UNSPECIFIED",
1061            Self::Creating => "STREAM_JOB_STATUS_CREATING",
1062            Self::Created => "STREAM_JOB_STATUS_CREATED",
1063        }
1064    }
1065    /// Creates an enum from field names used in the ProtoBuf definition.
1066    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1067        match value {
1068            "STREAM_JOB_STATUS_UNSPECIFIED" => Some(Self::Unspecified),
1069            "STREAM_JOB_STATUS_CREATING" => Some(Self::Creating),
1070            "STREAM_JOB_STATUS_CREATED" => Some(Self::Created),
1071            _ => None,
1072        }
1073    }
1074}
1075/// How the stream job was created will determine
1076/// whether they are persisted.
1077#[derive(prost_helpers::AnyPB)]
1078#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1079#[repr(i32)]
1080pub enum CreateType {
1081    Unspecified = 0,
1082    Background = 1,
1083    Foreground = 2,
1084}
1085impl CreateType {
1086    /// String value of the enum field names used in the ProtoBuf definition.
1087    ///
1088    /// The values are not transformed in any way and thus are considered stable
1089    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
1090    pub fn as_str_name(&self) -> &'static str {
1091        match self {
1092            Self::Unspecified => "CREATE_TYPE_UNSPECIFIED",
1093            Self::Background => "CREATE_TYPE_BACKGROUND",
1094            Self::Foreground => "CREATE_TYPE_FOREGROUND",
1095        }
1096    }
1097    /// Creates an enum from field names used in the ProtoBuf definition.
1098    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1099        match value {
1100            "CREATE_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
1101            "CREATE_TYPE_BACKGROUND" => Some(Self::Background),
1102            "CREATE_TYPE_FOREGROUND" => Some(Self::Foreground),
1103            _ => None,
1104        }
1105    }
1106}
1107#[derive(prost_helpers::AnyPB)]
1108#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1109#[repr(i32)]
1110pub enum SinkType {
1111    Unspecified = 0,
1112    AppendOnly = 1,
1113    ForceAppendOnly = 2,
1114    Upsert = 3,
1115}
1116impl SinkType {
1117    /// String value of the enum field names used in the ProtoBuf definition.
1118    ///
1119    /// The values are not transformed in any way and thus are considered stable
1120    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
1121    pub fn as_str_name(&self) -> &'static str {
1122        match self {
1123            Self::Unspecified => "SINK_TYPE_UNSPECIFIED",
1124            Self::AppendOnly => "SINK_TYPE_APPEND_ONLY",
1125            Self::ForceAppendOnly => "SINK_TYPE_FORCE_APPEND_ONLY",
1126            Self::Upsert => "SINK_TYPE_UPSERT",
1127        }
1128    }
1129    /// Creates an enum from field names used in the ProtoBuf definition.
1130    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1131        match value {
1132            "SINK_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
1133            "SINK_TYPE_APPEND_ONLY" => Some(Self::AppendOnly),
1134            "SINK_TYPE_FORCE_APPEND_ONLY" => Some(Self::ForceAppendOnly),
1135            "SINK_TYPE_UPSERT" => Some(Self::Upsert),
1136            _ => None,
1137        }
1138    }
1139}
1140#[derive(prost_helpers::AnyPB)]
1141#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1142#[repr(i32)]
1143pub enum HandleConflictBehavior {
1144    Unspecified = 0,
1145    Overwrite = 1,
1146    Ignore = 2,
1147    NoCheck = 3,
1148    DoUpdateIfNotNull = 4,
1149}
1150impl HandleConflictBehavior {
1151    /// String value of the enum field names used in the ProtoBuf definition.
1152    ///
1153    /// The values are not transformed in any way and thus are considered stable
1154    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
1155    pub fn as_str_name(&self) -> &'static str {
1156        match self {
1157            Self::Unspecified => "HANDLE_CONFLICT_BEHAVIOR_UNSPECIFIED",
1158            Self::Overwrite => "HANDLE_CONFLICT_BEHAVIOR_OVERWRITE",
1159            Self::Ignore => "HANDLE_CONFLICT_BEHAVIOR_IGNORE",
1160            Self::NoCheck => "HANDLE_CONFLICT_BEHAVIOR_NO_CHECK",
1161            Self::DoUpdateIfNotNull => "HANDLE_CONFLICT_BEHAVIOR_DO_UPDATE_IF_NOT_NULL",
1162        }
1163    }
1164    /// Creates an enum from field names used in the ProtoBuf definition.
1165    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1166        match value {
1167            "HANDLE_CONFLICT_BEHAVIOR_UNSPECIFIED" => Some(Self::Unspecified),
1168            "HANDLE_CONFLICT_BEHAVIOR_OVERWRITE" => Some(Self::Overwrite),
1169            "HANDLE_CONFLICT_BEHAVIOR_IGNORE" => Some(Self::Ignore),
1170            "HANDLE_CONFLICT_BEHAVIOR_NO_CHECK" => Some(Self::NoCheck),
1171            "HANDLE_CONFLICT_BEHAVIOR_DO_UPDATE_IF_NOT_NULL" => {
1172                Some(Self::DoUpdateIfNotNull)
1173            }
1174            _ => None,
1175        }
1176    }
1177}
risingwave_pb/catalog.rs

risingwave_pb/
catalog.rs
