1#[derive(prost_helpers::AnyPB)]
4#[derive(Clone, PartialEq, ::prost::Message)]
5pub struct ColIndexMapping {
6 #[prost(uint64, tag = "1")]
8 pub target_size: u64,
9 #[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 #[prost(uint32, tag = "1")]
20 pub watermark_idx: u32,
21 #[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 #[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 #[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 #[prost(bool, tag = "13")]
69 pub cdc_source_job: bool,
70 #[prost(bool, tag = "15")]
76 pub is_distributed: bool,
77 #[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 #[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 #[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 #[prost(bool, tag = "3")]
104 pub wait_for_persistence: bool,
105 #[prost(bool, tag = "4")]
107 pub is_batched: bool,
108}
109#[derive(prost_helpers::AnyPB)]
110#[derive(Clone, PartialEq, ::prost::Message)]
111pub struct Source {
112 #[prost(uint32, tag = "1")]
115 pub id: u32,
116 #[prost(uint32, tag = "2")]
117 pub schema_id: u32,
118 #[prost(uint32, tag = "3")]
119 pub database_id: u32,
120 #[prost(string, tag = "4")]
121 pub name: ::prost::alloc::string::String,
122 #[prost(uint32, optional, tag = "5")]
125 pub row_id_index: ::core::option::Option<u32>,
126 #[prost(message, repeated, tag = "6")]
128 pub columns: ::prost::alloc::vec::Vec<super::plan_common::ColumnCatalog>,
129 #[prost(int32, repeated, tag = "7")]
132 pub pk_column_ids: ::prost::alloc::vec::Vec<i32>,
133 #[prost(btree_map = "string, string", tag = "8")]
135 pub with_properties: ::prost::alloc::collections::BTreeMap<
136 ::prost::alloc::string::String,
137 ::prost::alloc::string::String,
138 >,
139 #[prost(uint32, tag = "9")]
140 pub owner: u32,
141 #[prost(message, optional, tag = "10")]
142 pub info: ::core::option::Option<StreamSourceInfo>,
143 #[prost(message, repeated, tag = "11")]
146 pub watermark_descs: ::prost::alloc::vec::Vec<WatermarkDesc>,
147 #[prost(string, tag = "13")]
148 pub definition: ::prost::alloc::string::String,
149 #[prost(uint32, optional, tag = "14")]
151 pub connection_id: ::core::option::Option<u32>,
152 #[prost(uint64, optional, tag = "15")]
153 pub initialized_at_epoch: ::core::option::Option<u64>,
154 #[prost(uint64, optional, tag = "16")]
155 pub created_at_epoch: ::core::option::Option<u64>,
156 #[prost(string, optional, tag = "17")]
158 pub initialized_at_cluster_version: ::core::option::Option<
159 ::prost::alloc::string::String,
160 >,
161 #[prost(string, optional, tag = "18")]
162 pub created_at_cluster_version: ::core::option::Option<
163 ::prost::alloc::string::String,
164 >,
165 #[prost(btree_map = "string, message", tag = "19")]
168 pub secret_refs: ::prost::alloc::collections::BTreeMap<
169 ::prost::alloc::string::String,
170 super::secret::SecretRef,
171 >,
172 #[prost(uint64, tag = "100")]
174 pub version: u64,
175 #[prost(uint32, optional, tag = "101")]
176 pub rate_limit: ::core::option::Option<u32>,
177 #[prost(oneof = "source::OptionalAssociatedTableId", tags = "12")]
179 pub optional_associated_table_id: ::core::option::Option<
180 source::OptionalAssociatedTableId,
181 >,
182}
183pub mod source {
185 #[derive(prost_helpers::AnyPB)]
187 #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
188 pub enum OptionalAssociatedTableId {
189 #[prost(uint32, tag = "12")]
190 AssociatedTableId(u32),
191 }
192}
193#[derive(prost_helpers::AnyPB)]
195#[derive(Clone, PartialEq, ::prost::Message)]
196pub struct SinkFormatDesc {
197 #[prost(enumeration = "super::plan_common::FormatType", tag = "1")]
198 pub format: i32,
199 #[prost(enumeration = "super::plan_common::EncodeType", tag = "2")]
200 pub encode: i32,
201 #[prost(btree_map = "string, string", tag = "3")]
202 pub options: ::prost::alloc::collections::BTreeMap<
203 ::prost::alloc::string::String,
204 ::prost::alloc::string::String,
205 >,
206 #[prost(enumeration = "super::plan_common::EncodeType", optional, tag = "4")]
207 pub key_encode: ::core::option::Option<i32>,
208 #[prost(btree_map = "string, message", tag = "5")]
210 pub secret_refs: ::prost::alloc::collections::BTreeMap<
211 ::prost::alloc::string::String,
212 super::secret::SecretRef,
213 >,
214 #[prost(uint32, optional, tag = "6")]
216 pub connection_id: ::core::option::Option<u32>,
217}
218#[derive(prost_helpers::AnyPB)]
223#[derive(Clone, PartialEq, ::prost::Message)]
224pub struct Sink {
225 #[prost(uint32, tag = "1")]
226 pub id: u32,
227 #[prost(uint32, tag = "2")]
228 pub schema_id: u32,
229 #[prost(uint32, tag = "3")]
230 pub database_id: u32,
231 #[prost(string, tag = "4")]
232 pub name: ::prost::alloc::string::String,
233 #[prost(message, repeated, tag = "5")]
234 pub columns: ::prost::alloc::vec::Vec<super::plan_common::ColumnCatalog>,
235 #[prost(message, repeated, tag = "6")]
237 pub plan_pk: ::prost::alloc::vec::Vec<super::common::ColumnOrder>,
238 #[prost(int32, repeated, tag = "8")]
239 pub distribution_key: ::prost::alloc::vec::Vec<i32>,
240 #[prost(int32, repeated, tag = "9")]
242 pub downstream_pk: ::prost::alloc::vec::Vec<i32>,
243 #[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 #[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 #[prost(uint32, optional, tag = "21")]
272 pub target_table: ::core::option::Option<u32>,
273 #[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 #[prost(enumeration = "CreateType", tag = "24")]
284 pub create_type: i32,
285 #[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 #[prost(message, repeated, tag = "26")]
294 pub original_target_columns: ::prost::alloc::vec::Vec<
295 super::plan_common::ColumnCatalog,
296 >,
297 #[prost(uint32, optional, tag = "27")]
298 pub auto_refresh_schema_from_table: ::core::option::Option<u32>,
299}
300#[derive(prost_helpers::AnyPB)]
301#[derive(Clone, PartialEq, ::prost::Message)]
302pub struct Subscription {
303 #[prost(uint32, tag = "1")]
304 pub id: u32,
305 #[prost(string, tag = "2")]
306 pub name: ::prost::alloc::string::String,
307 #[prost(string, tag = "3")]
308 pub definition: ::prost::alloc::string::String,
309 #[prost(uint64, tag = "6")]
310 pub retention_seconds: u64,
311 #[prost(uint32, tag = "8")]
312 pub database_id: u32,
313 #[prost(uint32, tag = "9")]
314 pub schema_id: u32,
315 #[prost(uint32, tag = "10")]
316 pub dependent_table_id: u32,
317 #[prost(uint64, optional, tag = "11")]
318 pub initialized_at_epoch: ::core::option::Option<u64>,
319 #[prost(uint64, optional, tag = "12")]
320 pub created_at_epoch: ::core::option::Option<u64>,
321 #[prost(uint32, tag = "13")]
322 pub owner: u32,
323 #[prost(string, optional, tag = "15")]
324 pub initialized_at_cluster_version: ::core::option::Option<
325 ::prost::alloc::string::String,
326 >,
327 #[prost(string, optional, tag = "16")]
328 pub created_at_cluster_version: ::core::option::Option<
329 ::prost::alloc::string::String,
330 >,
331 #[prost(enumeration = "subscription::SubscriptionState", tag = "19")]
332 pub subscription_state: i32,
333}
334pub mod subscription {
336 #[derive(prost_helpers::AnyPB)]
337 #[derive(
338 Clone,
339 Copy,
340 Debug,
341 PartialEq,
342 Eq,
343 Hash,
344 PartialOrd,
345 Ord,
346 ::prost::Enumeration
347 )]
348 #[repr(i32)]
349 pub enum SubscriptionState {
350 Unspecified = 0,
351 Init = 1,
352 Created = 2,
353 }
354 impl SubscriptionState {
355 pub fn as_str_name(&self) -> &'static str {
360 match self {
361 Self::Unspecified => "UNSPECIFIED",
362 Self::Init => "INIT",
363 Self::Created => "CREATED",
364 }
365 }
366 pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
368 match value {
369 "UNSPECIFIED" => Some(Self::Unspecified),
370 "INIT" => Some(Self::Init),
371 "CREATED" => Some(Self::Created),
372 _ => None,
373 }
374 }
375 }
376}
377#[derive(prost_helpers::AnyPB)]
378#[derive(Clone, PartialEq, ::prost::Message)]
379pub struct ConnectionParams {
380 #[prost(enumeration = "connection_params::ConnectionType", tag = "1")]
381 pub connection_type: i32,
382 #[prost(map = "string, string", tag = "2")]
383 pub properties: ::std::collections::HashMap<
384 ::prost::alloc::string::String,
385 ::prost::alloc::string::String,
386 >,
387 #[prost(map = "string, message", tag = "3")]
388 pub secret_refs: ::std::collections::HashMap<
389 ::prost::alloc::string::String,
390 super::secret::SecretRef,
391 >,
392}
393pub mod connection_params {
395 #[derive(prost_helpers::AnyPB)]
396 #[derive(
397 Clone,
398 Copy,
399 Debug,
400 PartialEq,
401 Eq,
402 Hash,
403 PartialOrd,
404 Ord,
405 ::prost::Enumeration
406 )]
407 #[repr(i32)]
408 pub enum ConnectionType {
409 Unspecified = 0,
410 Kafka = 1,
411 Iceberg = 2,
412 SchemaRegistry = 3,
413 Elasticsearch = 4,
414 }
415 impl ConnectionType {
416 pub fn as_str_name(&self) -> &'static str {
421 match self {
422 Self::Unspecified => "CONNECTION_TYPE_UNSPECIFIED",
423 Self::Kafka => "CONNECTION_TYPE_KAFKA",
424 Self::Iceberg => "CONNECTION_TYPE_ICEBERG",
425 Self::SchemaRegistry => "CONNECTION_TYPE_SCHEMA_REGISTRY",
426 Self::Elasticsearch => "CONNECTION_TYPE_ELASTICSEARCH",
427 }
428 }
429 pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
431 match value {
432 "CONNECTION_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
433 "CONNECTION_TYPE_KAFKA" => Some(Self::Kafka),
434 "CONNECTION_TYPE_ICEBERG" => Some(Self::Iceberg),
435 "CONNECTION_TYPE_SCHEMA_REGISTRY" => Some(Self::SchemaRegistry),
436 "CONNECTION_TYPE_ELASTICSEARCH" => Some(Self::Elasticsearch),
437 _ => None,
438 }
439 }
440 }
441}
442#[derive(prost_helpers::AnyPB)]
443#[derive(Clone, PartialEq, ::prost::Message)]
444pub struct Connection {
445 #[prost(uint32, tag = "1")]
446 pub id: u32,
447 #[prost(uint32, tag = "2")]
448 pub schema_id: u32,
449 #[prost(uint32, tag = "3")]
450 pub database_id: u32,
451 #[prost(string, tag = "4")]
452 pub name: ::prost::alloc::string::String,
453 #[prost(uint32, tag = "6")]
454 pub owner: u32,
455 #[prost(oneof = "connection::Info", tags = "5, 7")]
456 pub info: ::core::option::Option<connection::Info>,
457}
458pub mod connection {
460 #[derive(prost_helpers::AnyPB)]
461 #[derive(Clone, PartialEq, ::prost::Message)]
462 pub struct PrivateLinkService {
463 #[prost(enumeration = "private_link_service::PrivateLinkProvider", tag = "1")]
464 pub provider: i32,
465 #[prost(string, tag = "2")]
466 pub service_name: ::prost::alloc::string::String,
467 #[prost(string, tag = "3")]
468 pub endpoint_id: ::prost::alloc::string::String,
469 #[prost(map = "string, string", tag = "4")]
470 pub dns_entries: ::std::collections::HashMap<
471 ::prost::alloc::string::String,
472 ::prost::alloc::string::String,
473 >,
474 #[prost(string, tag = "5")]
475 pub endpoint_dns_name: ::prost::alloc::string::String,
476 }
477 pub mod private_link_service {
479 #[derive(prost_helpers::AnyPB)]
480 #[derive(
481 Clone,
482 Copy,
483 Debug,
484 PartialEq,
485 Eq,
486 Hash,
487 PartialOrd,
488 Ord,
489 ::prost::Enumeration
490 )]
491 #[repr(i32)]
492 pub enum PrivateLinkProvider {
493 Unspecified = 0,
494 Mock = 1,
495 Aws = 2,
496 }
497 impl PrivateLinkProvider {
498 pub fn as_str_name(&self) -> &'static str {
503 match self {
504 Self::Unspecified => "UNSPECIFIED",
505 Self::Mock => "MOCK",
506 Self::Aws => "AWS",
507 }
508 }
509 pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
511 match value {
512 "UNSPECIFIED" => Some(Self::Unspecified),
513 "MOCK" => Some(Self::Mock),
514 "AWS" => Some(Self::Aws),
515 _ => None,
516 }
517 }
518 }
519 }
520 #[derive(prost_helpers::AnyPB)]
521 #[derive(Clone, PartialEq, ::prost::Oneof)]
522 pub enum Info {
523 #[prost(message, tag = "5")]
524 PrivateLinkService(PrivateLinkService),
525 #[prost(message, tag = "7")]
526 ConnectionParams(super::ConnectionParams),
527 }
528}
529#[derive(prost_helpers::AnyPB)]
530#[derive(Clone, PartialEq, ::prost::Message)]
531pub struct Index {
532 #[prost(uint32, tag = "1")]
533 pub id: u32,
534 #[prost(uint32, tag = "2")]
535 pub schema_id: u32,
536 #[prost(uint32, tag = "3")]
537 pub database_id: u32,
538 #[prost(string, tag = "4")]
539 pub name: ::prost::alloc::string::String,
540 #[prost(uint32, tag = "5")]
541 pub owner: u32,
542 #[prost(uint32, tag = "6")]
543 pub index_table_id: u32,
544 #[prost(uint32, tag = "7")]
545 pub primary_table_id: u32,
546 #[prost(message, repeated, tag = "8")]
549 pub index_item: ::prost::alloc::vec::Vec<super::expr::ExprNode>,
550 #[prost(message, repeated, tag = "16")]
551 pub index_column_properties: ::prost::alloc::vec::Vec<IndexColumnProperties>,
552 #[prost(uint64, optional, tag = "10")]
553 pub initialized_at_epoch: ::core::option::Option<u64>,
554 #[prost(uint64, optional, tag = "11")]
555 pub created_at_epoch: ::core::option::Option<u64>,
556 #[prost(enumeration = "StreamJobStatus", tag = "12")]
557 pub stream_job_status: i32,
558 #[prost(uint32, tag = "13")]
561 pub index_columns_len: u32,
562 #[prost(string, optional, tag = "14")]
564 pub initialized_at_cluster_version: ::core::option::Option<
565 ::prost::alloc::string::String,
566 >,
567 #[prost(string, optional, tag = "15")]
568 pub created_at_cluster_version: ::core::option::Option<
569 ::prost::alloc::string::String,
570 >,
571}
572#[derive(prost_helpers::AnyPB)]
574#[derive(Eq, Hash)]
575#[derive(Clone, Copy, PartialEq, ::prost::Message)]
576pub struct IndexColumnProperties {
577 #[prost(bool, tag = "1")]
579 pub is_desc: bool,
580 #[prost(bool, tag = "2")]
582 pub nulls_first: bool,
583}
584#[derive(prost_helpers::AnyPB)]
585#[derive(Clone, PartialEq, ::prost::Message)]
586pub struct Function {
587 #[prost(uint32, tag = "1")]
588 pub id: u32,
589 #[prost(uint32, tag = "2")]
590 pub schema_id: u32,
591 #[prost(uint32, tag = "3")]
592 pub database_id: u32,
593 #[prost(string, tag = "4")]
594 pub name: ::prost::alloc::string::String,
595 #[prost(uint32, tag = "9")]
596 pub owner: u32,
597 #[prost(string, repeated, tag = "15")]
598 pub arg_names: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
599 #[prost(message, repeated, tag = "5")]
600 pub arg_types: ::prost::alloc::vec::Vec<super::data::DataType>,
601 #[prost(message, optional, tag = "6")]
602 pub return_type: ::core::option::Option<super::data::DataType>,
603 #[prost(string, tag = "7")]
604 pub language: ::prost::alloc::string::String,
605 #[prost(string, optional, tag = "8")]
606 pub link: ::core::option::Option<::prost::alloc::string::String>,
607 #[prost(string, optional, tag = "10")]
609 pub name_in_runtime: ::core::option::Option<::prost::alloc::string::String>,
610 #[prost(string, optional, tag = "14")]
612 pub body: ::core::option::Option<::prost::alloc::string::String>,
613 #[prost(bytes = "vec", optional, tag = "17")]
615 pub compressed_binary: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
616 #[prost(bool, tag = "16")]
617 pub always_retry_on_network_error: bool,
618 #[prost(string, optional, tag = "18")]
620 pub runtime: ::core::option::Option<::prost::alloc::string::String>,
621 #[prost(bool, optional, tag = "20")]
623 pub is_async: ::core::option::Option<bool>,
624 #[prost(bool, optional, tag = "21")]
625 pub is_batched: ::core::option::Option<bool>,
626 #[prost(oneof = "function::Kind", tags = "11, 12, 13")]
627 pub kind: ::core::option::Option<function::Kind>,
628}
629pub mod function {
631 #[derive(prost_helpers::AnyPB)]
632 #[derive(Clone, Copy, PartialEq, ::prost::Message)]
633 pub struct ScalarFunction {}
634 #[derive(prost_helpers::AnyPB)]
635 #[derive(Clone, Copy, PartialEq, ::prost::Message)]
636 pub struct TableFunction {}
637 #[derive(prost_helpers::AnyPB)]
638 #[derive(Clone, Copy, PartialEq, ::prost::Message)]
639 pub struct AggregateFunction {}
640 #[derive(prost_helpers::AnyPB)]
641 #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
642 pub enum Kind {
643 #[prost(message, tag = "11")]
644 Scalar(ScalarFunction),
645 #[prost(message, tag = "12")]
646 Table(TableFunction),
647 #[prost(message, tag = "13")]
648 Aggregate(AggregateFunction),
649 }
650}
651#[derive(prost_helpers::AnyPB)]
658#[derive(Clone, PartialEq, ::prost::Message)]
659pub struct Table {
660 #[prost(uint32, tag = "1")]
661 pub id: u32,
662 #[prost(uint32, tag = "2")]
663 pub schema_id: u32,
664 #[prost(uint32, tag = "3")]
665 pub database_id: u32,
666 #[prost(string, tag = "4")]
667 pub name: ::prost::alloc::string::String,
668 #[prost(message, repeated, tag = "5")]
669 pub columns: ::prost::alloc::vec::Vec<super::plan_common::ColumnCatalog>,
670 #[prost(message, repeated, tag = "6")]
671 pub pk: ::prost::alloc::vec::Vec<super::common::ColumnOrder>,
672 #[prost(enumeration = "table::TableType", tag = "10")]
673 pub table_type: i32,
674 #[prost(int32, repeated, tag = "12")]
675 pub distribution_key: ::prost::alloc::vec::Vec<i32>,
676 #[prost(int32, repeated, tag = "13")]
678 pub stream_key: ::prost::alloc::vec::Vec<i32>,
679 #[prost(bool, tag = "14")]
680 pub append_only: bool,
681 #[prost(uint32, tag = "15")]
682 pub owner: u32,
683 #[prost(uint32, tag = "17")]
684 pub fragment_id: u32,
685 #[prost(uint32, optional, tag = "18")]
688 pub vnode_col_index: ::core::option::Option<u32>,
689 #[prost(uint32, optional, tag = "19")]
692 pub row_id_index: ::core::option::Option<u32>,
693 #[prost(int32, repeated, tag = "20")]
697 pub value_indices: ::prost::alloc::vec::Vec<i32>,
698 #[prost(string, tag = "21")]
699 pub definition: ::prost::alloc::string::String,
700 #[prost(enumeration = "HandleConflictBehavior", tag = "22")]
702 pub handle_pk_conflict_behavior: i32,
703 #[prost(uint32, tag = "23")]
707 pub read_prefix_len_hint: u32,
708 #[prost(int32, repeated, tag = "24")]
709 pub watermark_indices: ::prost::alloc::vec::Vec<i32>,
710 #[prost(int32, repeated, tag = "25")]
711 pub dist_key_in_pk: ::prost::alloc::vec::Vec<i32>,
712 #[prost(uint32, optional, tag = "26")]
715 pub dml_fragment_id: ::core::option::Option<u32>,
716 #[prost(message, optional, tag = "27")]
720 pub cardinality: ::core::option::Option<super::plan_common::Cardinality>,
721 #[prost(uint64, optional, tag = "28")]
722 pub initialized_at_epoch: ::core::option::Option<u64>,
723 #[prost(uint64, optional, tag = "29")]
724 pub created_at_epoch: ::core::option::Option<u64>,
725 #[prost(bool, tag = "30")]
729 pub cleaned_by_watermark: bool,
730 #[prost(enumeration = "StreamJobStatus", tag = "31")]
732 pub stream_job_status: i32,
733 #[prost(enumeration = "CreateType", tag = "32")]
734 pub create_type: i32,
735 #[prost(string, optional, tag = "33")]
737 pub description: ::core::option::Option<::prost::alloc::string::String>,
738 #[prost(uint32, repeated, tag = "34")]
740 pub incoming_sinks: ::prost::alloc::vec::Vec<u32>,
741 #[prost(string, optional, tag = "35")]
743 pub initialized_at_cluster_version: ::core::option::Option<
744 ::prost::alloc::string::String,
745 >,
746 #[prost(string, optional, tag = "36")]
747 pub created_at_cluster_version: ::core::option::Option<
748 ::prost::alloc::string::String,
749 >,
750 #[prost(uint32, optional, tag = "37")]
753 pub retention_seconds: ::core::option::Option<u32>,
754 #[prost(uint32, optional, tag = "38")]
758 pub version_column_index: ::core::option::Option<u32>,
759 #[prost(string, optional, tag = "39")]
763 pub cdc_table_id: ::core::option::Option<::prost::alloc::string::String>,
764 #[prost(uint32, optional, tag = "40")]
777 pub maybe_vnode_count: ::core::option::Option<u32>,
778 #[prost(message, optional, tag = "41")]
780 pub webhook_info: ::core::option::Option<WebhookSourceInfo>,
781 #[prost(uint32, optional, tag = "42")]
783 pub job_id: ::core::option::Option<u32>,
784 #[prost(enumeration = "table::Engine", optional, tag = "43")]
786 pub engine: ::core::option::Option<i32>,
787 #[prost(int32, optional, tag = "44")]
790 pub clean_watermark_index_in_pk: ::core::option::Option<i32>,
791 #[prost(message, optional, tag = "100")]
795 pub version: ::core::option::Option<table::TableVersion>,
796 #[prost(oneof = "table::OptionalAssociatedSourceId", tags = "9")]
797 pub optional_associated_source_id: ::core::option::Option<
798 table::OptionalAssociatedSourceId,
799 >,
800}
801pub mod table {
803 #[derive(prost_helpers::AnyPB)]
804 #[derive(Clone, Copy, PartialEq, ::prost::Message)]
805 pub struct TableVersion {
806 #[prost(uint64, tag = "1")]
809 pub version: u64,
810 #[prost(int32, tag = "2")]
813 pub next_column_id: i32,
814 }
815 #[derive(prost_helpers::AnyPB)]
816 #[derive(
817 Clone,
818 Copy,
819 Debug,
820 PartialEq,
821 Eq,
822 Hash,
823 PartialOrd,
824 Ord,
825 ::prost::Enumeration
826 )]
827 #[repr(i32)]
828 pub enum TableType {
829 Unspecified = 0,
830 Table = 1,
831 MaterializedView = 2,
832 Index = 3,
833 Internal = 4,
834 }
835 impl TableType {
836 pub fn as_str_name(&self) -> &'static str {
841 match self {
842 Self::Unspecified => "UNSPECIFIED",
843 Self::Table => "TABLE",
844 Self::MaterializedView => "MATERIALIZED_VIEW",
845 Self::Index => "INDEX",
846 Self::Internal => "INTERNAL",
847 }
848 }
849 pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
851 match value {
852 "UNSPECIFIED" => Some(Self::Unspecified),
853 "TABLE" => Some(Self::Table),
854 "MATERIALIZED_VIEW" => Some(Self::MaterializedView),
855 "INDEX" => Some(Self::Index),
856 "INTERNAL" => Some(Self::Internal),
857 _ => None,
858 }
859 }
860 }
861 #[derive(prost_helpers::AnyPB)]
862 #[derive(
863 Clone,
864 Copy,
865 Debug,
866 PartialEq,
867 Eq,
868 Hash,
869 PartialOrd,
870 Ord,
871 ::prost::Enumeration
872 )]
873 #[repr(i32)]
874 pub enum Engine {
875 Unspecified = 0,
876 Hummock = 1,
877 Iceberg = 2,
878 }
879 impl Engine {
880 pub fn as_str_name(&self) -> &'static str {
885 match self {
886 Self::Unspecified => "ENGINE_UNSPECIFIED",
887 Self::Hummock => "HUMMOCK",
888 Self::Iceberg => "ICEBERG",
889 }
890 }
891 pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
893 match value {
894 "ENGINE_UNSPECIFIED" => Some(Self::Unspecified),
895 "HUMMOCK" => Some(Self::Hummock),
896 "ICEBERG" => Some(Self::Iceberg),
897 _ => None,
898 }
899 }
900 }
901 #[derive(prost_helpers::AnyPB)]
902 #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
903 pub enum OptionalAssociatedSourceId {
904 #[prost(uint32, tag = "9")]
905 AssociatedSourceId(u32),
906 }
907}
908#[derive(prost_helpers::AnyPB)]
909#[derive(Clone, PartialEq, ::prost::Message)]
910pub struct View {
911 #[prost(uint32, tag = "1")]
912 pub id: u32,
913 #[prost(uint32, tag = "2")]
914 pub schema_id: u32,
915 #[prost(uint32, tag = "3")]
916 pub database_id: u32,
917 #[prost(string, tag = "4")]
918 pub name: ::prost::alloc::string::String,
919 #[prost(uint32, tag = "5")]
920 pub owner: u32,
921 #[prost(btree_map = "string, string", tag = "6")]
922 pub properties: ::prost::alloc::collections::BTreeMap<
923 ::prost::alloc::string::String,
924 ::prost::alloc::string::String,
925 >,
926 #[prost(string, tag = "7")]
927 pub sql: ::prost::alloc::string::String,
928 #[prost(message, repeated, tag = "9")]
930 pub columns: ::prost::alloc::vec::Vec<super::plan_common::Field>,
931}
932#[derive(prost_helpers::AnyPB)]
933#[derive(Clone, PartialEq, ::prost::Message)]
934pub struct Schema {
935 #[prost(uint32, tag = "1")]
936 pub id: u32,
937 #[prost(uint32, tag = "2")]
938 pub database_id: u32,
939 #[prost(string, tag = "3")]
940 pub name: ::prost::alloc::string::String,
941 #[prost(uint32, tag = "4")]
942 pub owner: u32,
943}
944#[derive(prost_helpers::AnyPB)]
945#[derive(Clone, PartialEq, ::prost::Message)]
946pub struct Database {
947 #[prost(uint32, tag = "1")]
948 pub id: u32,
949 #[prost(string, tag = "2")]
950 pub name: ::prost::alloc::string::String,
951 #[prost(uint32, tag = "3")]
952 pub owner: u32,
953 #[prost(string, tag = "4")]
954 pub resource_group: ::prost::alloc::string::String,
955 #[prost(uint32, optional, tag = "5")]
956 pub barrier_interval_ms: ::core::option::Option<u32>,
957 #[prost(uint64, optional, tag = "6")]
958 pub checkpoint_frequency: ::core::option::Option<u64>,
959}
960#[derive(prost_helpers::AnyPB)]
961#[derive(Clone, PartialEq, ::prost::Message)]
962pub struct Comment {
963 #[prost(uint32, tag = "1")]
964 pub table_id: u32,
965 #[prost(uint32, tag = "2")]
966 pub schema_id: u32,
967 #[prost(uint32, tag = "3")]
968 pub database_id: u32,
969 #[prost(uint32, optional, tag = "4")]
970 pub column_index: ::core::option::Option<u32>,
971 #[prost(string, optional, tag = "5")]
972 pub description: ::core::option::Option<::prost::alloc::string::String>,
973}
974#[derive(prost_helpers::AnyPB)]
975#[derive(Clone, PartialEq, ::prost::Message)]
976pub struct Secret {
977 #[prost(uint32, tag = "1")]
978 pub id: u32,
979 #[prost(string, tag = "2")]
980 pub name: ::prost::alloc::string::String,
981 #[prost(uint32, tag = "3")]
982 pub database_id: u32,
983 #[prost(bytes = "vec", tag = "4")]
985 pub value: ::prost::alloc::vec::Vec<u8>,
986 #[prost(uint32, tag = "5")]
987 pub owner: u32,
988 #[prost(uint32, tag = "6")]
989 pub schema_id: u32,
990}
991#[derive(prost_helpers::AnyPB)]
992#[derive(Clone, PartialEq, ::prost::Message)]
993pub struct OptionsWithSecret {
994 #[prost(map = "string, string", tag = "1")]
995 pub options: ::std::collections::HashMap<
996 ::prost::alloc::string::String,
997 ::prost::alloc::string::String,
998 >,
999 #[prost(map = "string, message", tag = "2")]
1000 pub secret_refs: ::std::collections::HashMap<
1001 ::prost::alloc::string::String,
1002 super::secret::SecretRef,
1003 >,
1004}
1005#[derive(prost_helpers::AnyPB)]
1006#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1007#[repr(i32)]
1008pub enum SchemaRegistryNameStrategy {
1009 Unspecified = 0,
1010 RecordNameStrategy = 1,
1011 TopicRecordNameStrategy = 2,
1012}
1013impl SchemaRegistryNameStrategy {
1014 pub fn as_str_name(&self) -> &'static str {
1019 match self {
1020 Self::Unspecified => "SCHEMA_REGISTRY_NAME_STRATEGY_UNSPECIFIED",
1021 Self::RecordNameStrategy => {
1022 "SCHEMA_REGISTRY_NAME_STRATEGY_RECORD_NAME_STRATEGY"
1023 }
1024 Self::TopicRecordNameStrategy => {
1025 "SCHEMA_REGISTRY_NAME_STRATEGY_TOPIC_RECORD_NAME_STRATEGY"
1026 }
1027 }
1028 }
1029 pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1031 match value {
1032 "SCHEMA_REGISTRY_NAME_STRATEGY_UNSPECIFIED" => Some(Self::Unspecified),
1033 "SCHEMA_REGISTRY_NAME_STRATEGY_RECORD_NAME_STRATEGY" => {
1034 Some(Self::RecordNameStrategy)
1035 }
1036 "SCHEMA_REGISTRY_NAME_STRATEGY_TOPIC_RECORD_NAME_STRATEGY" => {
1037 Some(Self::TopicRecordNameStrategy)
1038 }
1039 _ => None,
1040 }
1041 }
1042}
1043#[derive(prost_helpers::AnyPB)]
1044#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1045#[repr(i32)]
1046pub enum StreamJobStatus {
1047 Unspecified = 0,
1049 Creating = 1,
1050 Created = 2,
1051}
1052impl StreamJobStatus {
1053 pub fn as_str_name(&self) -> &'static str {
1058 match self {
1059 Self::Unspecified => "STREAM_JOB_STATUS_UNSPECIFIED",
1060 Self::Creating => "STREAM_JOB_STATUS_CREATING",
1061 Self::Created => "STREAM_JOB_STATUS_CREATED",
1062 }
1063 }
1064 pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1066 match value {
1067 "STREAM_JOB_STATUS_UNSPECIFIED" => Some(Self::Unspecified),
1068 "STREAM_JOB_STATUS_CREATING" => Some(Self::Creating),
1069 "STREAM_JOB_STATUS_CREATED" => Some(Self::Created),
1070 _ => None,
1071 }
1072 }
1073}
1074#[derive(prost_helpers::AnyPB)]
1077#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1078#[repr(i32)]
1079pub enum CreateType {
1080 Unspecified = 0,
1081 Background = 1,
1082 Foreground = 2,
1083}
1084impl CreateType {
1085 pub fn as_str_name(&self) -> &'static str {
1090 match self {
1091 Self::Unspecified => "CREATE_TYPE_UNSPECIFIED",
1092 Self::Background => "CREATE_TYPE_BACKGROUND",
1093 Self::Foreground => "CREATE_TYPE_FOREGROUND",
1094 }
1095 }
1096 pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1098 match value {
1099 "CREATE_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
1100 "CREATE_TYPE_BACKGROUND" => Some(Self::Background),
1101 "CREATE_TYPE_FOREGROUND" => Some(Self::Foreground),
1102 _ => None,
1103 }
1104 }
1105}
1106#[derive(prost_helpers::AnyPB)]
1107#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1108#[repr(i32)]
1109pub enum SinkType {
1110 Unspecified = 0,
1111 AppendOnly = 1,
1112 ForceAppendOnly = 2,
1113 Upsert = 3,
1114}
1115impl SinkType {
1116 pub fn as_str_name(&self) -> &'static str {
1121 match self {
1122 Self::Unspecified => "SINK_TYPE_UNSPECIFIED",
1123 Self::AppendOnly => "SINK_TYPE_APPEND_ONLY",
1124 Self::ForceAppendOnly => "SINK_TYPE_FORCE_APPEND_ONLY",
1125 Self::Upsert => "SINK_TYPE_UPSERT",
1126 }
1127 }
1128 pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1130 match value {
1131 "SINK_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
1132 "SINK_TYPE_APPEND_ONLY" => Some(Self::AppendOnly),
1133 "SINK_TYPE_FORCE_APPEND_ONLY" => Some(Self::ForceAppendOnly),
1134 "SINK_TYPE_UPSERT" => Some(Self::Upsert),
1135 _ => None,
1136 }
1137 }
1138}
1139#[derive(prost_helpers::AnyPB)]
1140#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1141#[repr(i32)]
1142pub enum HandleConflictBehavior {
1143 Unspecified = 0,
1144 Overwrite = 1,
1145 Ignore = 2,
1146 NoCheck = 3,
1147 DoUpdateIfNotNull = 4,
1148}
1149impl HandleConflictBehavior {
1150 pub fn as_str_name(&self) -> &'static str {
1155 match self {
1156 Self::Unspecified => "HANDLE_CONFLICT_BEHAVIOR_UNSPECIFIED",
1157 Self::Overwrite => "HANDLE_CONFLICT_BEHAVIOR_OVERWRITE",
1158 Self::Ignore => "HANDLE_CONFLICT_BEHAVIOR_IGNORE",
1159 Self::NoCheck => "HANDLE_CONFLICT_BEHAVIOR_NO_CHECK",
1160 Self::DoUpdateIfNotNull => "HANDLE_CONFLICT_BEHAVIOR_DO_UPDATE_IF_NOT_NULL",
1161 }
1162 }
1163 pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1165 match value {
1166 "HANDLE_CONFLICT_BEHAVIOR_UNSPECIFIED" => Some(Self::Unspecified),
1167 "HANDLE_CONFLICT_BEHAVIOR_OVERWRITE" => Some(Self::Overwrite),
1168 "HANDLE_CONFLICT_BEHAVIOR_IGNORE" => Some(Self::Ignore),
1169 "HANDLE_CONFLICT_BEHAVIOR_NO_CHECK" => Some(Self::NoCheck),
1170 "HANDLE_CONFLICT_BEHAVIOR_DO_UPDATE_IF_NOT_NULL" => {
1171 Some(Self::DoUpdateIfNotNull)
1172 }
1173 _ => None,
1174 }
1175 }
1176}