nominal_api_proto/proto/
nominal.ingest_transform.v1.rs

1// This file is @generated by prost-build.
2#[derive(Clone, PartialEq, ::prost::Message)]
3pub struct ExecuteIngestTransformRequest {
4    #[prost(string, tag = "1")]
5    pub transform_uuid: ::prost::alloc::string::String,
6    #[prost(string, optional, tag = "2")]
7    pub workspace_rid: ::core::option::Option<::prost::alloc::string::String>,
8    #[prost(bool, tag = "3")]
9    pub shadow_ingest_worker_mcap: bool,
10}
11#[derive(Clone, Copy, PartialEq, ::prost::Message)]
12pub struct ExecuteIngestTransformResponse {}
13#[derive(Clone, PartialEq, ::prost::Message)]
14pub struct LoadRunnableTransformRequest {
15    #[prost(string, tag = "1")]
16    pub transform_uuid: ::prost::alloc::string::String,
17}
18#[derive(Clone, PartialEq, ::prost::Message)]
19pub struct LoadRunnableTransformResponse {
20    #[prost(string, tag = "1")]
21    pub transform_uuid: ::prost::alloc::string::String,
22    #[prost(string, tag = "2")]
23    pub ingest_job_uuid: ::prost::alloc::string::String,
24    #[prost(string, tag = "3")]
25    pub org_uuid: ::prost::alloc::string::String,
26    #[prost(enumeration = "IngestTransformType", tag = "4")]
27    pub transform_type: i32,
28    #[prost(map = "string, string", tag = "6")]
29    pub arguments: ::std::collections::HashMap<
30        ::prost::alloc::string::String,
31        ::prost::alloc::string::String,
32    >,
33    #[prost(string, optional, tag = "7")]
34    pub extractor_rid: ::core::option::Option<::prost::alloc::string::String>,
35    #[prost(string, tag = "13")]
36    pub ingest_job_rid: ::prost::alloc::string::String,
37    #[prost(message, optional, tag = "9")]
38    pub timestamp_metadata: ::core::option::Option<
39        super::super::ingest::v2::TimestampMetadata,
40    >,
41    #[prost(
42        oneof = "load_runnable_transform_response::Payload",
43        tags = "10, 11, 12, 14, 15"
44    )]
45    pub payload: ::core::option::Option<load_runnable_transform_response::Payload>,
46}
47/// Nested message and enum types in `LoadRunnableTransformResponse`.
48pub mod load_runnable_transform_response {
49    #[derive(Clone, PartialEq, ::prost::Oneof)]
50    pub enum Payload {
51        #[prost(message, tag = "10")]
52        Containerized(super::ContainerizedTransformPayload),
53        #[prost(message, tag = "11")]
54        Mcap(super::McapTransformPayload),
55        #[prost(message, tag = "12")]
56        Dataflash(super::DataflashTransformPayload),
57        #[prost(message, tag = "14")]
58        ParquetArchive(super::ParquetArchiveTransformPayload),
59        #[prost(message, tag = "15")]
60        FileCopy(super::FileCopyTransformPayload),
61    }
62}
63#[derive(Clone, PartialEq, ::prost::Message)]
64pub struct McapTransformPayload {
65    #[prost(message, optional, tag = "1")]
66    pub source: ::core::option::Option<super::super::ingest::v2::IngestSource>,
67    #[prost(map = "string, string", tag = "2")]
68    pub tags: ::std::collections::HashMap<
69        ::prost::alloc::string::String,
70        ::prost::alloc::string::String,
71    >,
72    #[prost(message, optional, tag = "3")]
73    pub channels: ::core::option::Option<McapChannelFilter>,
74    #[prost(bool, tag = "4")]
75    pub ignore_invalid_topics: bool,
76    #[prost(int32, repeated, tag = "5")]
77    pub channel_ids: ::prost::alloc::vec::Vec<i32>,
78}
79#[derive(Clone, PartialEq, ::prost::Message)]
80pub struct McapChannelFilter {
81    #[prost(oneof = "mcap_channel_filter::Filter", tags = "1, 2")]
82    pub filter: ::core::option::Option<mcap_channel_filter::Filter>,
83}
84/// Nested message and enum types in `McapChannelFilter`.
85pub mod mcap_channel_filter {
86    #[derive(Clone, PartialEq, ::prost::Oneof)]
87    pub enum Filter {
88        #[prost(message, tag = "1")]
89        IncludeTopics(super::McapTopics),
90        #[prost(message, tag = "2")]
91        ExcludeTopics(super::McapTopics),
92    }
93}
94#[derive(Clone, PartialEq, ::prost::Message)]
95pub struct McapTopics {
96    #[prost(string, repeated, tag = "1")]
97    pub topics: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
98}
99#[derive(Clone, PartialEq, ::prost::Message)]
100pub struct DataflashTransformPayload {
101    #[prost(message, optional, tag = "1")]
102    pub source: ::core::option::Option<super::super::ingest::v2::IngestSource>,
103    #[prost(map = "string, string", tag = "2")]
104    pub tags: ::std::collections::HashMap<
105        ::prost::alloc::string::String,
106        ::prost::alloc::string::String,
107    >,
108}
109#[derive(Clone, PartialEq, ::prost::Message)]
110pub struct ParquetArchiveTransformPayload {
111    #[prost(message, optional, tag = "1")]
112    pub source: ::core::option::Option<super::super::ingest::v2::IngestSource>,
113    #[prost(message, optional, tag = "2")]
114    pub timestamp_metadata: ::core::option::Option<
115        super::super::ingest::v2::TimestampMetadata,
116    >,
117    #[prost(message, optional, tag = "3")]
118    pub format: ::core::option::Option<super::super::ingest::v2::ParquetFormat>,
119    #[prost(map = "string, string", tag = "4")]
120    pub units: ::std::collections::HashMap<
121        ::prost::alloc::string::String,
122        ::prost::alloc::string::String,
123    >,
124    #[prost(map = "string, string", tag = "5")]
125    pub tags: ::std::collections::HashMap<
126        ::prost::alloc::string::String,
127        ::prost::alloc::string::String,
128    >,
129    #[prost(string, optional, tag = "6")]
130    pub channel_prefix: ::core::option::Option<::prost::alloc::string::String>,
131    #[prost(map = "string, string", tag = "7")]
132    pub channel_name_overrides: ::std::collections::HashMap<
133        ::prost::alloc::string::String,
134        ::prost::alloc::string::String,
135    >,
136}
137#[derive(Clone, PartialEq, ::prost::Message)]
138pub struct FileCopyTransformPayload {
139    #[prost(message, optional, tag = "1")]
140    pub file: ::core::option::Option<super::super::ingest::v2::FileIngestItem>,
141    #[prost(map = "string, string", tag = "2")]
142    pub tags: ::std::collections::HashMap<
143        ::prost::alloc::string::String,
144        ::prost::alloc::string::String,
145    >,
146}
147#[derive(Clone, PartialEq, ::prost::Message)]
148pub struct ContainerizedTransformPayload {
149    #[prost(map = "string, message", tag = "1")]
150    pub sources: ::std::collections::HashMap<
151        ::prost::alloc::string::String,
152        super::super::ingest::v2::IngestSource,
153    >,
154    #[prost(map = "string, string", tag = "2")]
155    pub tags: ::std::collections::HashMap<
156        ::prost::alloc::string::String,
157        ::prost::alloc::string::String,
158    >,
159    #[prost(string, repeated, tag = "3")]
160    pub runs_to_expand: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
161    #[prost(string, optional, tag = "4")]
162    pub image_tag: ::core::option::Option<::prost::alloc::string::String>,
163    #[prost(string, optional, tag = "5")]
164    pub native_catalog_id: ::core::option::Option<::prost::alloc::string::String>,
165}
166#[derive(Clone, PartialEq, ::prost::Message)]
167pub struct MarkTransformSucceededRequest {
168    #[prost(string, tag = "1")]
169    pub transform_uuid: ::prost::alloc::string::String,
170}
171#[derive(Clone, PartialEq, ::prost::Message)]
172pub struct MarkTransformFailedRequest {
173    #[prost(string, tag = "1")]
174    pub transform_uuid: ::prost::alloc::string::String,
175    #[prost(string, tag = "2")]
176    pub safe_error_message: ::prost::alloc::string::String,
177    #[prost(enumeration = "TransformFailureKind", tag = "3")]
178    pub failure_kind: i32,
179    #[prost(message, optional, tag = "4")]
180    pub extractor_failure: ::core::option::Option<ExtractorFailure>,
181}
182#[derive(Clone, PartialEq, ::prost::Message)]
183pub struct ExtractorFailure {
184    #[prost(string, tag = "1")]
185    pub code: ::prost::alloc::string::String,
186    #[prost(string, tag = "2")]
187    pub message: ::prost::alloc::string::String,
188    #[prost(bool, tag = "3")]
189    pub retryable: bool,
190    #[prost(map = "string, string", tag = "4")]
191    pub details: ::std::collections::HashMap<
192        ::prost::alloc::string::String,
193        ::prost::alloc::string::String,
194    >,
195}
196#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
197#[repr(i32)]
198pub enum TransformFailureKind {
199    Unspecified = 0,
200    User = 1,
201    System = 2,
202}
203impl TransformFailureKind {
204    /// String value of the enum field names used in the ProtoBuf definition.
205    ///
206    /// The values are not transformed in any way and thus are considered stable
207    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
208    pub fn as_str_name(&self) -> &'static str {
209        match self {
210            Self::Unspecified => "TRANSFORM_FAILURE_KIND_UNSPECIFIED",
211            Self::User => "TRANSFORM_FAILURE_KIND_USER",
212            Self::System => "TRANSFORM_FAILURE_KIND_SYSTEM",
213        }
214    }
215    /// Creates an enum from field names used in the ProtoBuf definition.
216    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
217        match value {
218            "TRANSFORM_FAILURE_KIND_UNSPECIFIED" => Some(Self::Unspecified),
219            "TRANSFORM_FAILURE_KIND_USER" => Some(Self::User),
220            "TRANSFORM_FAILURE_KIND_SYSTEM" => Some(Self::System),
221            _ => None,
222        }
223    }
224}
225#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
226#[repr(i32)]
227pub enum IngestTransformType {
228    Unspecified = 0,
229    Containerized = 1,
230    Mcap = 2,
231    Dataflash = 3,
232    ParquetArchive = 4,
233    FileCopy = 5,
234}
235impl IngestTransformType {
236    /// String value of the enum field names used in the ProtoBuf definition.
237    ///
238    /// The values are not transformed in any way and thus are considered stable
239    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
240    pub fn as_str_name(&self) -> &'static str {
241        match self {
242            Self::Unspecified => "INGEST_TRANSFORM_TYPE_UNSPECIFIED",
243            Self::Containerized => "INGEST_TRANSFORM_TYPE_CONTAINERIZED",
244            Self::Mcap => "INGEST_TRANSFORM_TYPE_MCAP",
245            Self::Dataflash => "INGEST_TRANSFORM_TYPE_DATAFLASH",
246            Self::ParquetArchive => "INGEST_TRANSFORM_TYPE_PARQUET_ARCHIVE",
247            Self::FileCopy => "INGEST_TRANSFORM_TYPE_FILE_COPY",
248        }
249    }
250    /// Creates an enum from field names used in the ProtoBuf definition.
251    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
252        match value {
253            "INGEST_TRANSFORM_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
254            "INGEST_TRANSFORM_TYPE_CONTAINERIZED" => Some(Self::Containerized),
255            "INGEST_TRANSFORM_TYPE_MCAP" => Some(Self::Mcap),
256            "INGEST_TRANSFORM_TYPE_DATAFLASH" => Some(Self::Dataflash),
257            "INGEST_TRANSFORM_TYPE_PARQUET_ARCHIVE" => Some(Self::ParquetArchive),
258            "INGEST_TRANSFORM_TYPE_FILE_COPY" => Some(Self::FileCopy),
259            _ => None,
260        }
261    }
262}
nominal_api_proto/proto/nominal.ingest_transform.v1.rs

nominal_api_proto/proto/
nominal.ingest_transform.v1.rs
