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

nominal_api_proto/proto/
nominal.ingest_transform.v1.rs
