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

nominal_api_proto/proto/
nominal.ingest_transform.v1.rs
