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"
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    }
56}
57#[derive(Clone, PartialEq, ::prost::Message)]
58pub struct McapTransformPayload {
59    #[prost(message, optional, tag = "1")]
60    pub source: ::core::option::Option<super::super::ingest::v2::IngestSource>,
61    #[prost(map = "string, string", tag = "2")]
62    pub tags: ::std::collections::HashMap<
63        ::prost::alloc::string::String,
64        ::prost::alloc::string::String,
65    >,
66    #[prost(message, optional, tag = "3")]
67    pub channels: ::core::option::Option<McapChannelFilter>,
68    #[prost(bool, tag = "4")]
69    pub ignore_invalid_topics: bool,
70}
71#[derive(Clone, PartialEq, ::prost::Message)]
72pub struct McapChannelFilter {
73    #[prost(oneof = "mcap_channel_filter::Filter", tags = "1, 2")]
74    pub filter: ::core::option::Option<mcap_channel_filter::Filter>,
75}
76/// Nested message and enum types in `McapChannelFilter`.
77pub mod mcap_channel_filter {
78    #[derive(Clone, PartialEq, ::prost::Oneof)]
79    pub enum Filter {
80        #[prost(message, tag = "1")]
81        IncludeTopics(super::McapTopics),
82        #[prost(message, tag = "2")]
83        ExcludeTopics(super::McapTopics),
84    }
85}
86#[derive(Clone, PartialEq, ::prost::Message)]
87pub struct McapTopics {
88    #[prost(string, repeated, tag = "1")]
89    pub topics: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
90}
91#[derive(Clone, PartialEq, ::prost::Message)]
92pub struct DataflashTransformPayload {
93    #[prost(message, optional, tag = "1")]
94    pub source: ::core::option::Option<super::super::ingest::v2::IngestSource>,
95    #[prost(map = "string, string", tag = "2")]
96    pub tags: ::std::collections::HashMap<
97        ::prost::alloc::string::String,
98        ::prost::alloc::string::String,
99    >,
100}
101#[derive(Clone, PartialEq, ::prost::Message)]
102pub struct ParquetArchiveTransformPayload {
103    #[prost(message, optional, tag = "1")]
104    pub source: ::core::option::Option<super::super::ingest::v2::IngestSource>,
105    #[prost(message, optional, tag = "2")]
106    pub timestamp_metadata: ::core::option::Option<
107        super::super::ingest::v2::TimestampMetadata,
108    >,
109    #[prost(message, optional, tag = "3")]
110    pub format: ::core::option::Option<super::super::ingest::v2::ParquetFormat>,
111    #[prost(map = "string, string", tag = "4")]
112    pub units: ::std::collections::HashMap<
113        ::prost::alloc::string::String,
114        ::prost::alloc::string::String,
115    >,
116    #[prost(map = "string, string", tag = "5")]
117    pub tags: ::std::collections::HashMap<
118        ::prost::alloc::string::String,
119        ::prost::alloc::string::String,
120    >,
121    #[prost(string, optional, tag = "6")]
122    pub channel_prefix: ::core::option::Option<::prost::alloc::string::String>,
123    #[prost(map = "string, string", tag = "7")]
124    pub channel_name_overrides: ::std::collections::HashMap<
125        ::prost::alloc::string::String,
126        ::prost::alloc::string::String,
127    >,
128}
129#[derive(Clone, PartialEq, ::prost::Message)]
130pub struct ContainerizedTransformPayload {
131    #[prost(map = "string, message", tag = "1")]
132    pub sources: ::std::collections::HashMap<
133        ::prost::alloc::string::String,
134        super::super::ingest::v2::IngestSource,
135    >,
136    #[prost(map = "string, string", tag = "2")]
137    pub tags: ::std::collections::HashMap<
138        ::prost::alloc::string::String,
139        ::prost::alloc::string::String,
140    >,
141    #[prost(string, repeated, tag = "3")]
142    pub runs_to_expand: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
143}
144#[derive(Clone, PartialEq, ::prost::Message)]
145pub struct MarkTransformSucceededRequest {
146    #[prost(string, tag = "1")]
147    pub transform_uuid: ::prost::alloc::string::String,
148}
149#[derive(Clone, PartialEq, ::prost::Message)]
150pub struct MarkTransformFailedRequest {
151    #[prost(string, tag = "1")]
152    pub transform_uuid: ::prost::alloc::string::String,
153    #[prost(string, tag = "2")]
154    pub safe_error_message: ::prost::alloc::string::String,
155}
156#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
157#[repr(i32)]
158pub enum IngestTransformType {
159    Unspecified = 0,
160    Containerized = 1,
161    Mcap = 2,
162    Dataflash = 3,
163    ParquetArchive = 4,
164}
165impl IngestTransformType {
166    /// String value of the enum field names used in the ProtoBuf definition.
167    ///
168    /// The values are not transformed in any way and thus are considered stable
169    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
170    pub fn as_str_name(&self) -> &'static str {
171        match self {
172            Self::Unspecified => "INGEST_TRANSFORM_TYPE_UNSPECIFIED",
173            Self::Containerized => "INGEST_TRANSFORM_TYPE_CONTAINERIZED",
174            Self::Mcap => "INGEST_TRANSFORM_TYPE_MCAP",
175            Self::Dataflash => "INGEST_TRANSFORM_TYPE_DATAFLASH",
176            Self::ParquetArchive => "INGEST_TRANSFORM_TYPE_PARQUET_ARCHIVE",
177        }
178    }
179    /// Creates an enum from field names used in the ProtoBuf definition.
180    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
181        match value {
182            "INGEST_TRANSFORM_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
183            "INGEST_TRANSFORM_TYPE_CONTAINERIZED" => Some(Self::Containerized),
184            "INGEST_TRANSFORM_TYPE_MCAP" => Some(Self::Mcap),
185            "INGEST_TRANSFORM_TYPE_DATAFLASH" => Some(Self::Dataflash),
186            "INGEST_TRANSFORM_TYPE_PARQUET_ARCHIVE" => Some(Self::ParquetArchive),
187            _ => None,
188        }
189    }
190}
nominal_api_proto/proto/nominal.ingest_transform.v1.rs

nominal_api_proto/proto/
nominal.ingest_transform.v1.rs
