mz_storage_types/mnt/build/debug/build/mz-storage-types-b98dc267080caedb/out/
mz_storage_types.sources.rs

1// This file is @generated by prost-build.
2#[derive(Clone, Copy, PartialEq, ::prost::Message)]
3pub struct ProtoMzOffset {
4    #[prost(uint64, tag = "1")]
5    pub offset: u64,
6}
7#[derive(Clone, PartialEq, ::prost::Message)]
8pub struct ProtoTimeline {
9    #[prost(oneof = "proto_timeline::Kind", tags = "1, 2, 3")]
10    pub kind: ::core::option::Option<proto_timeline::Kind>,
11}
12/// Nested message and enum types in `ProtoTimeline`.
13pub mod proto_timeline {
14    #[derive(Clone, PartialEq, ::prost::Oneof)]
15    pub enum Kind {
16        #[prost(message, tag = "1")]
17        EpochMilliseconds(()),
18        #[prost(string, tag = "2")]
19        External(::prost::alloc::string::String),
20        #[prost(string, tag = "3")]
21        User(::prost::alloc::string::String),
22    }
23}
24#[derive(Clone, PartialEq, ::prost::Message)]
25pub struct ProtoSourceExportDataConfig {
26    #[prost(message, optional, tag = "1")]
27    pub encoding: ::core::option::Option<encoding::ProtoSourceDataEncoding>,
28    #[prost(message, optional, tag = "2")]
29    pub envelope: ::core::option::Option<envelope::ProtoSourceEnvelope>,
30}
31#[derive(Clone, PartialEq, ::prost::Message)]
32pub struct ProtoSourceDesc {
33    #[prost(message, optional, tag = "1")]
34    pub connection: ::core::option::Option<ProtoSourceConnection>,
35    #[prost(message, optional, tag = "5")]
36    pub timestamp_interval: ::core::option::Option<::mz_proto::ProtoDuration>,
37    #[prost(message, optional, tag = "6")]
38    pub primary_export: ::core::option::Option<ProtoSourceExportDataConfig>,
39    #[prost(message, optional, tag = "7")]
40    pub primary_export_details: ::core::option::Option<ProtoSourceExportDetails>,
41}
42#[derive(Clone, PartialEq, ::prost::Message)]
43pub struct ProtoSourceConnection {
44    #[prost(oneof = "proto_source_connection::Kind", tags = "1, 4, 6, 8, 9")]
45    pub kind: ::core::option::Option<proto_source_connection::Kind>,
46}
47/// Nested message and enum types in `ProtoSourceConnection`.
48pub mod proto_source_connection {
49    #[derive(Clone, PartialEq, ::prost::Oneof)]
50    pub enum Kind {
51        #[prost(message, tag = "1")]
52        Kafka(super::kafka::ProtoKafkaSourceConnection),
53        #[prost(message, tag = "4")]
54        Postgres(super::postgres::ProtoPostgresSourceConnection),
55        #[prost(message, tag = "6")]
56        Loadgen(super::load_generator::ProtoLoadGeneratorSourceConnection),
57        #[prost(message, tag = "8")]
58        Mysql(super::mysql::ProtoMySqlSourceConnection),
59        #[prost(message, tag = "9")]
60        SqlServer(super::sql_server::ProtoSqlServerSource),
61    }
62}
63#[derive(Clone, PartialEq, ::prost::Message)]
64pub struct ProtoSourceData {
65    #[prost(oneof = "proto_source_data::Kind", tags = "1, 2")]
66    pub kind: ::core::option::Option<proto_source_data::Kind>,
67}
68/// Nested message and enum types in `ProtoSourceData`.
69pub mod proto_source_data {
70    #[derive(Clone, PartialEq, ::prost::Oneof)]
71    pub enum Kind {
72        #[prost(message, tag = "1")]
73        Ok(::mz_repr::ProtoRow),
74        #[prost(message, tag = "2")]
75        Err(super::super::errors::ProtoDataflowError),
76    }
77}
78#[derive(Clone, Copy, PartialEq, ::prost::Message)]
79pub struct ProtoCompression {
80    #[prost(oneof = "proto_compression::Kind", tags = "1, 2")]
81    pub kind: ::core::option::Option<proto_compression::Kind>,
82}
83/// Nested message and enum types in `ProtoCompression`.
84pub mod proto_compression {
85    #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
86    pub enum Kind {
87        #[prost(message, tag = "1")]
88        Gzip(()),
89        #[prost(message, tag = "2")]
90        None(()),
91    }
92}
93#[derive(Clone, PartialEq, ::prost::Message)]
94pub struct ProtoSourceExportDetails {
95    #[prost(oneof = "proto_source_export_details::Kind", tags = "1, 2, 3, 5, 4")]
96    pub kind: ::core::option::Option<proto_source_export_details::Kind>,
97}
98/// Nested message and enum types in `ProtoSourceExportDetails`.
99pub mod proto_source_export_details {
100    #[derive(Clone, PartialEq, ::prost::Oneof)]
101    pub enum Kind {
102        #[prost(message, tag = "1")]
103        Kafka(super::kafka::ProtoKafkaSourceExportDetails),
104        #[prost(message, tag = "2")]
105        Postgres(super::postgres::ProtoPostgresSourceExportDetails),
106        #[prost(message, tag = "3")]
107        Mysql(super::mysql::ProtoMySqlSourceExportDetails),
108        #[prost(message, tag = "5")]
109        SqlServer(super::sql_server::ProtoSqlServerSourceExportDetails),
110        #[prost(message, tag = "4")]
111        Loadgen(super::load_generator::ProtoLoadGeneratorSourceExportDetails),
112    }
113}
114/// NOTE: this message is encoded and stored as part of a source export
115/// statement option (currently only `CREATE SUBSOURCE` statements)
116/// Be extra careful about changes, ensuring that all changes are backwards compatible
117#[derive(Clone, PartialEq, ::prost::Message)]
118pub struct ProtoSourceExportStatementDetails {
119    #[prost(
120        oneof = "proto_source_export_statement_details::Kind",
121        tags = "1, 2, 5, 3, 4"
122    )]
123    pub kind: ::core::option::Option<proto_source_export_statement_details::Kind>,
124}
125/// Nested message and enum types in `ProtoSourceExportStatementDetails`.
126pub mod proto_source_export_statement_details {
127    #[derive(Clone, PartialEq, ::prost::Oneof)]
128    pub enum Kind {
129        #[prost(message, tag = "1")]
130        Postgres(super::postgres::ProtoPostgresSourceExportStatementDetails),
131        #[prost(message, tag = "2")]
132        Mysql(super::mysql::ProtoMySqlSourceExportStatementDetails),
133        #[prost(message, tag = "5")]
134        SqlServer(super::sql_server::ProtoSqlServerSourceExportStatementDetails),
135        #[prost(message, tag = "3")]
136        Loadgen(super::load_generator::ProtoLoadGeneratorSourceExportStatementDetails),
137        #[prost(message, tag = "4")]
138        Kafka(super::kafka::ProtoKafkaSourceExportStatementDetails),
139    }
140}
141#[derive(Clone, PartialEq, ::prost::Message)]
142pub struct ProtoIngestionDescription {
143    /// repeated ProtoSourceImport source_imports = 1;
144    #[prost(message, repeated, tag = "2")]
145    pub source_exports: ::prost::alloc::vec::Vec<
146        proto_ingestion_description::ProtoSourceExport,
147    >,
148    #[prost(message, optional, tag = "3")]
149    pub ingestion_metadata: ::core::option::Option<
150        super::controller::ProtoCollectionMetadata,
151    >,
152    #[prost(message, optional, tag = "4")]
153    pub desc: ::core::option::Option<ProtoSourceDesc>,
154    #[prost(message, optional, tag = "6")]
155    pub instance_id: ::core::option::Option<super::instances::ProtoStorageInstanceId>,
156    #[prost(message, optional, tag = "7")]
157    pub remap_collection_id: ::core::option::Option<::mz_repr::global_id::ProtoGlobalId>,
158}
159/// Nested message and enum types in `ProtoIngestionDescription`.
160pub mod proto_ingestion_description {
161    #[derive(Clone, PartialEq, ::prost::Message)]
162    pub struct ProtoSourceImport {
163        #[prost(message, optional, tag = "1")]
164        pub id: ::core::option::Option<::mz_repr::global_id::ProtoGlobalId>,
165        #[prost(message, optional, tag = "2")]
166        pub storage_metadata: ::core::option::Option<
167            super::super::controller::ProtoCollectionMetadata,
168        >,
169    }
170    #[derive(Clone, PartialEq, ::prost::Message)]
171    pub struct ProtoSourceExport {
172        #[prost(message, optional, tag = "1")]
173        pub id: ::core::option::Option<::mz_repr::global_id::ProtoGlobalId>,
174        #[prost(message, optional, tag = "3")]
175        pub storage_metadata: ::core::option::Option<
176            super::super::controller::ProtoCollectionMetadata,
177        >,
178        #[prost(message, optional, tag = "5")]
179        pub details: ::core::option::Option<super::ProtoSourceExportDetails>,
180        #[prost(message, optional, tag = "6")]
181        pub data_config: ::core::option::Option<super::ProtoSourceExportDataConfig>,
182    }
183}
mz_storage_types/mnt/build/debug/build/mz-storage-types-b98dc267080caedb/out/mz_storage_types.sources.rs

mz_storage_types/mnt/build/debug/build/mz-storage-types-b98dc267080caedb/out/
mz_storage_types.sources.rs
