nominal_api_proto/proto/
nominal.event.v1.rs

1// This file is @generated by prost-build.
2#[derive(Clone, PartialEq, ::prost::Message)]
3pub struct AggregateEventsRequest {
4    #[prost(message, optional, tag = "1")]
5    pub query: ::core::option::Option<SearchQuery>,
6    #[prost(enumeration = "AggregateType", repeated, tag = "2")]
7    pub aggregate_types: ::prost::alloc::vec::Vec<i32>,
8}
9#[derive(Clone, PartialEq, ::prost::Message)]
10pub struct AggregateEventsResponse {
11    #[prost(map = "string, message", tag = "1")]
12    pub values: ::std::collections::HashMap<
13        ::prost::alloc::string::String,
14        AggregateValue,
15    >,
16}
17#[derive(Clone, Copy, PartialEq, ::prost::Message)]
18pub struct AggregateValue {
19    #[prost(oneof = "aggregate_value::AggregateValue", tags = "1, 2")]
20    pub aggregate_value: ::core::option::Option<aggregate_value::AggregateValue>,
21}
22/// Nested message and enum types in `AggregateValue`.
23pub mod aggregate_value {
24    #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
25    pub enum AggregateValue {
26        #[prost(message, tag = "1")]
27        Duration(super::super::super::types::Duration),
28        #[prost(int32, tag = "2")]
29        Count(i32),
30    }
31}
32#[derive(Clone, Copy, PartialEq, ::prost::Message)]
33pub struct ApiEventOrigin {}
34#[derive(Clone, PartialEq, ::prost::Message)]
35pub struct ArchiveEventRequest {
36    #[prost(string, tag = "1")]
37    pub uuid: ::prost::alloc::string::String,
38}
39#[derive(Clone, PartialEq, ::prost::Message)]
40pub struct ArchivedStatusSetWrapper {
41    #[prost(enumeration = "super::super::types::ArchivedStatus", repeated, tag = "1")]
42    pub archived_statuses: ::prost::alloc::vec::Vec<i32>,
43}
44#[derive(Clone, PartialEq, ::prost::Message)]
45pub struct AssetRidSetWrapper {
46    #[prost(string, repeated, tag = "1")]
47    pub asset_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
48}
49#[derive(Clone, PartialEq, ::prost::Message)]
50pub struct AssetsFilter {
51    #[prost(enumeration = "super::super::types::SetOperator", tag = "1")]
52    pub operator: i32,
53    #[prost(string, repeated, tag = "2")]
54    pub assets: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
55}
56#[derive(Clone, PartialEq, ::prost::Message)]
57pub struct AssigneesFilter {
58    #[prost(enumeration = "super::super::types::SetOperator", tag = "1")]
59    pub operator: i32,
60    #[prost(string, repeated, tag = "2")]
61    pub assignees: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
62}
63#[derive(Clone, PartialEq, ::prost::Message)]
64pub struct BatchAggregateEventsRequest {
65    #[prost(message, repeated, tag = "1")]
66    pub requests: ::prost::alloc::vec::Vec<AggregateEventsRequest>,
67}
68#[derive(Clone, PartialEq, ::prost::Message)]
69pub struct BatchAggregateEventsResponse {
70    #[prost(message, repeated, tag = "1")]
71    pub responses: ::prost::alloc::vec::Vec<AggregateEventsResponse>,
72}
73#[derive(Clone, PartialEq, ::prost::Message)]
74pub struct BatchFilterEventsRequest {
75    #[prost(string, repeated, tag = "1")]
76    pub event_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
77    #[prost(message, optional, tag = "2")]
78    pub filter_query: ::core::option::Option<SearchQuery>,
79}
80#[derive(Clone, PartialEq, ::prost::Message)]
81pub struct BatchUpdateDispositionRequest {
82    #[prost(message, repeated, tag = "1")]
83    pub requests: ::prost::alloc::vec::Vec<UpdateDispositionRequest>,
84}
85#[derive(Clone, PartialEq, ::prost::Message)]
86pub struct BatchUpdateDispositionResponse {
87    #[prost(message, repeated, tag = "1")]
88    pub events: ::prost::alloc::vec::Vec<Event>,
89}
90#[derive(Clone, PartialEq, ::prost::Message)]
91pub struct BatchUpdateEventRequest {
92    #[prost(message, repeated, tag = "1")]
93    pub requests: ::prost::alloc::vec::Vec<UpdateEventRequest>,
94}
95#[derive(Clone, PartialEq, ::prost::Message)]
96pub struct BatchUpdateEventResponse {
97    #[prost(message, repeated, tag = "1")]
98    pub events: ::prost::alloc::vec::Vec<Event>,
99}
100#[derive(Clone, PartialEq, ::prost::Message)]
101pub struct CheckOriginMetadata {
102    #[prost(string, tag = "1")]
103    pub check_evaluation_rid: ::prost::alloc::string::String,
104    #[prost(string, tag = "2")]
105    pub check_rid: ::prost::alloc::string::String,
106    #[prost(string, tag = "3")]
107    pub check_lineage_rid: ::prost::alloc::string::String,
108    #[prost(int32, optional, tag = "4")]
109    pub implementation_index: ::core::option::Option<i32>,
110}
111#[derive(Clone, PartialEq, ::prost::Message)]
112pub struct CreateEventRequest {
113    #[prost(string, repeated, tag = "1")]
114    pub asset_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
115    #[prost(message, repeated, tag = "2")]
116    pub origins: ::prost::alloc::vec::Vec<EventOrigin>,
117    #[prost(message, optional, tag = "3")]
118    pub timestamp: ::core::option::Option<super::super::types::time::Timestamp>,
119    #[prost(message, optional, tag = "4")]
120    pub duration: ::core::option::Option<super::super::types::Duration>,
121    #[prost(string, tag = "5")]
122    pub name: ::prost::alloc::string::String,
123    #[prost(string, optional, tag = "6")]
124    pub description: ::core::option::Option<::prost::alloc::string::String>,
125    #[prost(enumeration = "EventType", tag = "7")]
126    pub r#type: i32,
127    #[prost(string, repeated, tag = "8")]
128    pub labels: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
129    #[prost(map = "string, string", tag = "9")]
130    pub properties: ::std::collections::HashMap<
131        ::prost::alloc::string::String,
132        ::prost::alloc::string::String,
133    >,
134    #[prost(message, optional, tag = "10")]
135    pub disposition: ::core::option::Option<EventDisposition>,
136}
137#[derive(Clone, PartialEq, ::prost::Message)]
138pub struct DataReviewChecksFilter {
139    #[prost(string, repeated, tag = "1")]
140    pub data_review_checks: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
141}
142#[derive(Clone, PartialEq, ::prost::Message)]
143pub struct DataReviewEventOrigin {
144    #[prost(string, tag = "1")]
145    pub data_review_rid: ::prost::alloc::string::String,
146    #[prost(message, optional, tag = "2")]
147    pub check_metadata: ::core::option::Option<CheckOriginMetadata>,
148}
149#[derive(Clone, PartialEq, ::prost::Message)]
150pub struct DataReviewsFilter {
151    #[prost(string, repeated, tag = "1")]
152    pub data_reviews: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
153}
154#[derive(Clone, PartialEq, ::prost::Message)]
155pub struct Event {
156    #[prost(string, tag = "1")]
157    pub uuid: ::prost::alloc::string::String,
158    #[prost(string, tag = "2")]
159    pub rid: ::prost::alloc::string::String,
160    #[prost(string, repeated, tag = "3")]
161    pub asset_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
162    #[prost(message, repeated, tag = "4")]
163    pub origins: ::prost::alloc::vec::Vec<EventOrigin>,
164    #[prost(message, optional, tag = "5")]
165    pub timestamp: ::core::option::Option<super::super::types::time::Timestamp>,
166    #[prost(message, optional, tag = "6")]
167    pub duration: ::core::option::Option<super::super::types::Duration>,
168    #[prost(string, tag = "7")]
169    pub name: ::prost::alloc::string::String,
170    #[prost(string, tag = "8")]
171    pub description: ::prost::alloc::string::String,
172    #[prost(enumeration = "EventType", tag = "9")]
173    pub r#type: i32,
174    #[prost(string, repeated, tag = "10")]
175    pub labels: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
176    #[prost(map = "string, string", tag = "11")]
177    pub properties: ::std::collections::HashMap<
178        ::prost::alloc::string::String,
179        ::prost::alloc::string::String,
180    >,
181    #[prost(bool, tag = "12")]
182    pub is_archived: bool,
183    #[prost(string, optional, tag = "13")]
184    pub created_by: ::core::option::Option<::prost::alloc::string::String>,
185    #[prost(message, optional, tag = "14")]
186    pub disposition: ::core::option::Option<EventDisposition>,
187}
188#[derive(Clone, PartialEq, ::prost::Message)]
189pub struct EventDisposition {
190    #[prost(enumeration = "super::super::types::Priority", tag = "1")]
191    pub priority: i32,
192    #[prost(message, optional, tag = "2")]
193    pub state: ::core::option::Option<super::super::types::DispositionState>,
194    #[prost(string, repeated, tag = "3")]
195    pub assignees: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
196}
197#[derive(Clone, PartialEq, ::prost::Message)]
198pub struct EventOrigin {
199    #[prost(oneof = "event_origin::EventOrigin", tags = "1, 2, 3, 4, 5, 6")]
200    pub event_origin: ::core::option::Option<event_origin::EventOrigin>,
201}
202/// Nested message and enum types in `EventOrigin`.
203pub mod event_origin {
204    #[derive(Clone, PartialEq, ::prost::Oneof)]
205    pub enum EventOrigin {
206        #[prost(message, tag = "1")]
207        Workbook(super::WorkbookEventOrigin),
208        #[prost(message, tag = "2")]
209        Template(super::TemplateEventOrigin),
210        #[prost(message, tag = "3")]
211        Api(super::ApiEventOrigin),
212        #[prost(message, tag = "4")]
213        DataReview(super::DataReviewEventOrigin),
214        #[prost(message, tag = "5")]
215        Procedure(super::ProcedureEventOrigin),
216        #[prost(message, tag = "6")]
217        StreamingChecklist(super::StreamingChecklistEventOrigin),
218    }
219}
220#[derive(Clone, Copy, PartialEq, ::prost::Message)]
221pub struct EventTimeFilter {
222    #[prost(message, optional, tag = "1")]
223    pub timestamp: ::core::option::Option<super::super::types::time::Timestamp>,
224    #[prost(enumeration = "EventTimeFilterCondition", tag = "2")]
225    pub timestamp_condition: i32,
226}
227#[derive(Clone, Copy, PartialEq, ::prost::Message)]
228pub struct EventsHistogramBucket {
229    #[prost(message, optional, tag = "1")]
230    pub start_inclusive: ::core::option::Option<super::super::types::time::Timestamp>,
231    #[prost(message, optional, tag = "2")]
232    pub end_exclusive: ::core::option::Option<super::super::types::time::Timestamp>,
233    #[prost(int32, tag = "3")]
234    pub count: i32,
235}
236#[derive(Clone, PartialEq, ::prost::Message)]
237pub struct EventsHistogramRequest {
238    #[prost(message, optional, tag = "1")]
239    pub start_inclusive: ::core::option::Option<super::super::types::time::Timestamp>,
240    #[prost(message, optional, tag = "2")]
241    pub end_exclusive: ::core::option::Option<super::super::types::time::Timestamp>,
242    #[prost(message, optional, tag = "3")]
243    pub filter_query: ::core::option::Option<HistogramFilterQuery>,
244    #[prost(message, optional, tag = "4")]
245    pub archived_statuses: ::core::option::Option<ArchivedStatusSetWrapper>,
246    #[prost(int32, optional, tag = "5")]
247    pub num_bins: ::core::option::Option<i32>,
248    #[prost(int32, optional, tag = "6")]
249    pub event_limit: ::core::option::Option<i32>,
250}
251#[derive(Clone, PartialEq, ::prost::Message)]
252pub struct EventsHistogramResponse {
253    #[prost(message, repeated, tag = "1")]
254    pub buckets: ::prost::alloc::vec::Vec<EventsHistogramBucket>,
255}
256#[derive(Clone, PartialEq, ::prost::Message)]
257pub struct GetEventsRequest {
258    #[prost(string, repeated, tag = "1")]
259    pub uuids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
260}
261#[derive(Clone, PartialEq, ::prost::Message)]
262pub struct HistogramFilterQuery {
263    #[prost(string, optional, tag = "1")]
264    pub search_text: ::core::option::Option<::prost::alloc::string::String>,
265    #[prost(string, optional, tag = "2")]
266    pub asset: ::core::option::Option<::prost::alloc::string::String>,
267    #[prost(string, optional, tag = "3")]
268    pub template: ::core::option::Option<::prost::alloc::string::String>,
269    #[prost(string, optional, tag = "4")]
270    pub workbook: ::core::option::Option<::prost::alloc::string::String>,
271    #[prost(string, optional, tag = "5")]
272    pub data_review: ::core::option::Option<::prost::alloc::string::String>,
273    #[prost(enumeration = "SearchEventOriginType", optional, tag = "6")]
274    pub origin_type: ::core::option::Option<i32>,
275    #[prost(string, optional, tag = "7")]
276    pub data_review_check: ::core::option::Option<::prost::alloc::string::String>,
277    #[prost(enumeration = "EventDispositionStatus", optional, tag = "8")]
278    pub disposition_status: ::core::option::Option<i32>,
279    #[prost(enumeration = "super::super::types::Priority", optional, tag = "9")]
280    pub priority: ::core::option::Option<i32>,
281    #[prost(string, optional, tag = "10")]
282    pub assignee: ::core::option::Option<::prost::alloc::string::String>,
283    #[prost(enumeration = "EventType", optional, tag = "11")]
284    pub event_type: ::core::option::Option<i32>,
285    #[prost(string, optional, tag = "12")]
286    pub created_by: ::core::option::Option<::prost::alloc::string::String>,
287    #[prost(string, optional, tag = "13")]
288    pub label: ::core::option::Option<::prost::alloc::string::String>,
289    #[prost(message, optional, tag = "14")]
290    pub property: ::core::option::Option<super::super::types::Property>,
291    #[prost(message, optional, tag = "15")]
292    pub and: ::core::option::Option<HistogramFilterQueryListWrapper>,
293    #[prost(message, optional, tag = "16")]
294    pub or: ::core::option::Option<HistogramFilterQueryListWrapper>,
295    #[prost(message, optional, boxed, tag = "17")]
296    pub not: ::core::option::Option<::prost::alloc::boxed::Box<HistogramFilterQuery>>,
297    #[prost(string, optional, tag = "18")]
298    pub workspace: ::core::option::Option<::prost::alloc::string::String>,
299    #[prost(string, optional, tag = "19")]
300    pub procedure: ::core::option::Option<::prost::alloc::string::String>,
301    #[prost(string, optional, tag = "20")]
302    pub procedure_execution: ::core::option::Option<::prost::alloc::string::String>,
303    #[prost(string, optional, tag = "21")]
304    pub step_id: ::core::option::Option<::prost::alloc::string::String>,
305}
306#[derive(Clone, PartialEq, ::prost::Message)]
307pub struct HistogramFilterQueryListWrapper {
308    #[prost(message, repeated, tag = "1")]
309    pub queries: ::prost::alloc::vec::Vec<HistogramFilterQuery>,
310}
311#[derive(Clone, PartialEq, ::prost::Message)]
312pub struct ListPropertiesAndLabelsRequest {
313    #[prost(message, optional, tag = "1")]
314    pub workspaces: ::core::option::Option<WorkspaceRidSetWrapper>,
315}
316#[derive(Clone, PartialEq, ::prost::Message)]
317pub struct OriginTypesFilter {
318    #[prost(enumeration = "super::super::types::SetOperator", tag = "1")]
319    pub operator: i32,
320    #[prost(enumeration = "SearchEventOriginType", repeated, tag = "2")]
321    pub origin_types: ::prost::alloc::vec::Vec<i32>,
322}
323#[derive(Clone, PartialEq, ::prost::Message)]
324pub struct ProcedureEventOrigin {
325    #[prost(string, tag = "1")]
326    pub procedure_execution_rid: ::prost::alloc::string::String,
327    #[prost(string, tag = "2")]
328    pub procedure_rid: ::prost::alloc::string::String,
329    #[prost(string, tag = "3")]
330    pub step_id: ::prost::alloc::string::String,
331}
332#[derive(Clone, PartialEq, ::prost::Message)]
333pub struct SearchEventsRequest {
334    #[prost(message, optional, tag = "1")]
335    pub sort: ::core::option::Option<SortOptions>,
336    #[prost(int32, tag = "2")]
337    pub page_size: i32,
338    #[prost(string, optional, tag = "3")]
339    pub next_page_token: ::core::option::Option<::prost::alloc::string::String>,
340    #[prost(message, optional, tag = "4")]
341    pub query: ::core::option::Option<SearchQuery>,
342    #[prost(message, optional, tag = "5")]
343    pub archived_statuses: ::core::option::Option<ArchivedStatusSetWrapper>,
344}
345#[derive(Clone, PartialEq, ::prost::Message)]
346pub struct SearchEventsResponse {
347    #[prost(message, repeated, tag = "1")]
348    pub results: ::prost::alloc::vec::Vec<Event>,
349    #[prost(string, optional, tag = "2")]
350    pub next_page_token: ::core::option::Option<::prost::alloc::string::String>,
351}
352#[derive(Clone, PartialEq, ::prost::Message)]
353pub struct SearchQuery {
354    #[prost(bool, optional, tag = "1")]
355    pub archived: ::core::option::Option<bool>,
356    #[prost(string, optional, tag = "2")]
357    pub search_text: ::core::option::Option<::prost::alloc::string::String>,
358    #[prost(string, optional, tag = "3")]
359    pub exact_match: ::core::option::Option<::prost::alloc::string::String>,
360    #[prost(message, optional, tag = "4")]
361    pub after: ::core::option::Option<super::super::types::time::Timestamp>,
362    #[prost(message, optional, tag = "5")]
363    pub before: ::core::option::Option<super::super::types::time::Timestamp>,
364    #[prost(message, optional, tag = "6")]
365    pub advanced_time_filter: ::core::option::Option<EventTimeFilter>,
366    #[prost(string, optional, tag = "7")]
367    pub asset: ::core::option::Option<::prost::alloc::string::String>,
368    #[prost(message, optional, tag = "8")]
369    pub assets: ::core::option::Option<AssetsFilter>,
370    #[prost(string, optional, tag = "9")]
371    pub template: ::core::option::Option<::prost::alloc::string::String>,
372    #[prost(string, optional, tag = "10")]
373    pub workbook: ::core::option::Option<::prost::alloc::string::String>,
374    #[prost(string, optional, tag = "11")]
375    pub data_review: ::core::option::Option<::prost::alloc::string::String>,
376    #[prost(message, optional, tag = "12")]
377    pub data_reviews: ::core::option::Option<DataReviewsFilter>,
378    #[prost(enumeration = "SearchEventOriginType", optional, tag = "13")]
379    pub origin_type: ::core::option::Option<i32>,
380    #[prost(message, optional, tag = "14")]
381    pub origin_types: ::core::option::Option<OriginTypesFilter>,
382    #[prost(string, optional, tag = "15")]
383    pub data_review_check: ::core::option::Option<::prost::alloc::string::String>,
384    #[prost(message, optional, tag = "16")]
385    pub data_review_checks: ::core::option::Option<DataReviewChecksFilter>,
386    #[prost(enumeration = "EventDispositionStatus", optional, tag = "17")]
387    pub disposition_status: ::core::option::Option<i32>,
388    #[prost(message, optional, tag = "18")]
389    pub disposition_statuses: ::core::option::Option<EventDispositionStatusListWrapper>,
390    #[prost(enumeration = "super::super::types::Priority", optional, tag = "19")]
391    pub priority: ::core::option::Option<i32>,
392    #[prost(message, optional, tag = "20")]
393    pub priorities: ::core::option::Option<PriorityListWrapper>,
394    #[prost(string, optional, tag = "21")]
395    pub assignee: ::core::option::Option<::prost::alloc::string::String>,
396    #[prost(message, optional, tag = "22")]
397    pub assignees: ::core::option::Option<AssigneesFilter>,
398    #[prost(enumeration = "EventType", optional, tag = "23")]
399    pub event_type: ::core::option::Option<i32>,
400    #[prost(message, optional, tag = "24")]
401    pub event_types: ::core::option::Option<EventTypeListWrapper>,
402    #[prost(string, optional, tag = "25")]
403    pub created_by: ::core::option::Option<::prost::alloc::string::String>,
404    #[prost(message, optional, tag = "26")]
405    pub created_by_any_of: ::core::option::Option<UserRidListWrapper>,
406    #[prost(string, optional, tag = "27")]
407    pub label: ::core::option::Option<::prost::alloc::string::String>,
408    #[prost(message, optional, tag = "28")]
409    pub labels: ::core::option::Option<super::super::types::LabelsFilter>,
410    #[prost(message, optional, tag = "29")]
411    pub property: ::core::option::Option<super::super::types::Property>,
412    #[prost(message, optional, tag = "30")]
413    pub properties: ::core::option::Option<super::super::types::PropertiesFilter>,
414    #[prost(message, optional, tag = "31")]
415    pub and: ::core::option::Option<SearchQueryListWrapper>,
416    #[prost(message, optional, tag = "32")]
417    pub or: ::core::option::Option<SearchQueryListWrapper>,
418    #[prost(message, optional, boxed, tag = "33")]
419    pub not: ::core::option::Option<::prost::alloc::boxed::Box<SearchQuery>>,
420    #[prost(string, optional, tag = "34")]
421    pub workspace: ::core::option::Option<::prost::alloc::string::String>,
422    #[prost(string, optional, tag = "35")]
423    pub procedure: ::core::option::Option<::prost::alloc::string::String>,
424    #[prost(string, optional, tag = "36")]
425    pub procedure_execution: ::core::option::Option<::prost::alloc::string::String>,
426    #[prost(string, optional, tag = "37")]
427    pub step_id: ::core::option::Option<::prost::alloc::string::String>,
428    #[prost(string, optional, tag = "38")]
429    pub streaming_checklist: ::core::option::Option<::prost::alloc::string::String>,
430    #[prost(string, optional, tag = "39")]
431    pub streaming_check: ::core::option::Option<::prost::alloc::string::String>,
432}
433#[derive(Clone, PartialEq, ::prost::Message)]
434pub struct SearchQueryListWrapper {
435    #[prost(message, repeated, tag = "1")]
436    pub queries: ::prost::alloc::vec::Vec<SearchQuery>,
437}
438#[derive(Clone, PartialEq, ::prost::Message)]
439pub struct EventDispositionStatusListWrapper {
440    #[prost(enumeration = "EventDispositionStatus", repeated, tag = "1")]
441    pub values: ::prost::alloc::vec::Vec<i32>,
442}
443#[derive(Clone, PartialEq, ::prost::Message)]
444pub struct PriorityListWrapper {
445    #[prost(enumeration = "super::super::types::Priority", repeated, tag = "1")]
446    pub values: ::prost::alloc::vec::Vec<i32>,
447}
448#[derive(Clone, PartialEq, ::prost::Message)]
449pub struct EventTypeListWrapper {
450    #[prost(enumeration = "EventType", repeated, tag = "1")]
451    pub values: ::prost::alloc::vec::Vec<i32>,
452}
453#[derive(Clone, PartialEq, ::prost::Message)]
454pub struct UserRidListWrapper {
455    #[prost(string, repeated, tag = "1")]
456    pub values: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
457}
458#[derive(Clone, Copy, PartialEq, ::prost::Message)]
459pub struct SortOptions {
460    #[prost(bool, tag = "1")]
461    pub is_descending: bool,
462    #[prost(enumeration = "SortField", tag = "2")]
463    pub field: i32,
464}
465#[derive(Clone, PartialEq, ::prost::Message)]
466pub struct StreamingCheckOriginMetadata {
467    #[prost(string, tag = "1")]
468    pub check_rid: ::prost::alloc::string::String,
469    #[prost(string, tag = "2")]
470    pub check_lineage_rid: ::prost::alloc::string::String,
471    #[prost(int32, optional, tag = "3")]
472    pub implementation_index: ::core::option::Option<i32>,
473}
474#[derive(Clone, PartialEq, ::prost::Message)]
475pub struct StreamingChecklistEventOrigin {
476    #[prost(string, tag = "1")]
477    pub checklist_rid: ::prost::alloc::string::String,
478    #[prost(message, optional, tag = "2")]
479    pub check_metadata: ::core::option::Option<StreamingCheckOriginMetadata>,
480}
481#[derive(Clone, PartialEq, ::prost::Message)]
482pub struct TemplateEventOrigin {
483    #[prost(string, tag = "1")]
484    pub rid: ::prost::alloc::string::String,
485}
486#[derive(Clone, PartialEq, ::prost::Message)]
487pub struct TimeSeriesChannelAssociation {
488    #[prost(string, tag = "1")]
489    pub variable_name: ::prost::alloc::string::String,
490    #[prost(message, optional, tag = "2")]
491    pub tags: ::core::option::Option<TimeSeriesChannelTagsWrapper>,
492}
493#[derive(Clone, PartialEq, ::prost::Message)]
494pub struct TimeSeriesChannelTagsWrapper {
495    #[prost(map = "string, string", tag = "1")]
496    pub tags: ::std::collections::HashMap<
497        ::prost::alloc::string::String,
498        ::prost::alloc::string::String,
499    >,
500}
501#[derive(Clone, PartialEq, ::prost::Message)]
502pub struct UpdateDispositionRequest {
503    #[prost(string, tag = "1")]
504    pub rid: ::prost::alloc::string::String,
505    #[prost(message, optional, tag = "2")]
506    pub disposition: ::core::option::Option<EventDisposition>,
507}
508#[derive(Clone, PartialEq, ::prost::Message)]
509pub struct UpdateEventLegacyRequest {
510    #[prost(string, tag = "1")]
511    pub uuid: ::prost::alloc::string::String,
512    #[prost(string, optional, tag = "2")]
513    pub rid: ::core::option::Option<::prost::alloc::string::String>,
514    #[prost(message, optional, tag = "3")]
515    pub asset_rids: ::core::option::Option<AssetRidSetWrapper>,
516    #[prost(message, optional, tag = "4")]
517    pub timestamp: ::core::option::Option<super::super::types::time::Timestamp>,
518    #[prost(message, optional, tag = "5")]
519    pub duration: ::core::option::Option<super::super::types::Duration>,
520    #[prost(string, optional, tag = "6")]
521    pub name: ::core::option::Option<::prost::alloc::string::String>,
522    #[prost(string, optional, tag = "7")]
523    pub description: ::core::option::Option<::prost::alloc::string::String>,
524    #[prost(enumeration = "EventType", optional, tag = "8")]
525    pub r#type: ::core::option::Option<i32>,
526    #[prost(message, optional, tag = "9")]
527    pub labels: ::core::option::Option<super::super::types::LabelUpdateWrapper>,
528    #[prost(message, optional, tag = "10")]
529    pub properties: ::core::option::Option<super::super::types::PropertyUpdateWrapper>,
530}
531#[derive(Clone, PartialEq, ::prost::Message)]
532pub struct UpdateEventRequest {
533    #[prost(string, tag = "1")]
534    pub rid: ::prost::alloc::string::String,
535    #[prost(message, optional, tag = "2")]
536    pub asset_rids: ::core::option::Option<AssetRidSetWrapper>,
537    #[prost(message, optional, tag = "3")]
538    pub timestamp: ::core::option::Option<super::super::types::time::Timestamp>,
539    #[prost(message, optional, tag = "4")]
540    pub duration: ::core::option::Option<super::super::types::Duration>,
541    #[prost(string, optional, tag = "5")]
542    pub name: ::core::option::Option<::prost::alloc::string::String>,
543    #[prost(string, optional, tag = "6")]
544    pub description: ::core::option::Option<::prost::alloc::string::String>,
545    #[prost(enumeration = "EventType", optional, tag = "7")]
546    pub r#type: ::core::option::Option<i32>,
547    #[prost(message, optional, tag = "8")]
548    pub labels: ::core::option::Option<super::super::types::LabelUpdateWrapper>,
549    #[prost(message, optional, tag = "9")]
550    pub properties: ::core::option::Option<super::super::types::PropertyUpdateWrapper>,
551}
552#[derive(Clone, PartialEq, ::prost::Message)]
553pub struct WorkbookDataAssociation {
554    #[prost(oneof = "workbook_data_association::WorkbookDataAssociation", tags = "1")]
555    pub workbook_data_association: ::core::option::Option<
556        workbook_data_association::WorkbookDataAssociation,
557    >,
558}
559/// Nested message and enum types in `WorkbookDataAssociation`.
560pub mod workbook_data_association {
561    #[derive(Clone, PartialEq, ::prost::Oneof)]
562    pub enum WorkbookDataAssociation {
563        #[prost(message, tag = "1")]
564        TimeSeriesChannel(super::TimeSeriesChannelAssociation),
565    }
566}
567#[derive(Clone, PartialEq, ::prost::Message)]
568pub struct WorkbookDataAssociationListWrapper {
569    #[prost(message, repeated, tag = "1")]
570    pub data: ::prost::alloc::vec::Vec<WorkbookDataAssociation>,
571}
572#[derive(Clone, PartialEq, ::prost::Message)]
573pub struct WorkbookEventOrigin {
574    #[prost(string, tag = "1")]
575    pub rid: ::prost::alloc::string::String,
576    #[prost(message, optional, tag = "2")]
577    pub data: ::core::option::Option<WorkbookDataAssociationListWrapper>,
578}
579#[derive(Clone, PartialEq, ::prost::Message)]
580pub struct WorkspaceRidSetWrapper {
581    #[prost(string, repeated, tag = "1")]
582    pub workspaces: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
583}
584#[derive(Clone, PartialEq, ::prost::Message)]
585pub struct CreateEventResponse {
586    #[prost(message, optional, tag = "1")]
587    pub event: ::core::option::Option<Event>,
588}
589#[derive(Clone, PartialEq, ::prost::Message)]
590pub struct GetEventsResponse {
591    #[prost(message, repeated, tag = "1")]
592    pub events: ::prost::alloc::vec::Vec<Event>,
593}
594#[derive(Clone, PartialEq, ::prost::Message)]
595pub struct BatchGetEventsRequest {
596    #[prost(string, repeated, tag = "1")]
597    pub request: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
598}
599#[derive(Clone, PartialEq, ::prost::Message)]
600pub struct BatchGetEventsResponse {
601    #[prost(message, repeated, tag = "1")]
602    pub events: ::prost::alloc::vec::Vec<Event>,
603}
604#[derive(Clone, PartialEq, ::prost::Message)]
605pub struct BatchFilterEventsResponse {
606    #[prost(message, repeated, tag = "1")]
607    pub events: ::prost::alloc::vec::Vec<Event>,
608}
609#[derive(Clone, PartialEq, ::prost::Message)]
610pub struct UpdateEventResponse {
611    #[prost(message, optional, tag = "1")]
612    pub event: ::core::option::Option<Event>,
613}
614#[derive(Clone, Copy, PartialEq, ::prost::Message)]
615pub struct ArchiveEventResponse {}
616#[derive(Clone, PartialEq, ::prost::Message)]
617pub struct BatchArchiveEventRequest {
618    #[prost(string, repeated, tag = "1")]
619    pub request: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
620}
621#[derive(Clone, Copy, PartialEq, ::prost::Message)]
622pub struct BatchArchiveEventResponse {}
623#[derive(Clone, PartialEq, ::prost::Message)]
624pub struct BatchUnarchiveEventRequest {
625    #[prost(string, repeated, tag = "1")]
626    pub request: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
627}
628#[derive(Clone, Copy, PartialEq, ::prost::Message)]
629pub struct BatchUnarchiveEventResponse {}
630#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
631#[repr(i32)]
632pub enum EventError {
633    InvalidEventRequest = 0,
634}
635impl EventError {
636    /// String value of the enum field names used in the ProtoBuf definition.
637    ///
638    /// The values are not transformed in any way and thus are considered stable
639    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
640    pub fn as_str_name(&self) -> &'static str {
641        match self {
642            Self::InvalidEventRequest => "EVENT_ERROR_INVALID_EVENT_REQUEST",
643        }
644    }
645    /// Creates an enum from field names used in the ProtoBuf definition.
646    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
647        match value {
648            "EVENT_ERROR_INVALID_EVENT_REQUEST" => Some(Self::InvalidEventRequest),
649            _ => None,
650        }
651    }
652}
653#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
654#[repr(i32)]
655pub enum AggregateType {
656    Unspecified = 0,
657    TotalDuration = 1,
658    TotalCount = 2,
659}
660impl AggregateType {
661    /// String value of the enum field names used in the ProtoBuf definition.
662    ///
663    /// The values are not transformed in any way and thus are considered stable
664    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
665    pub fn as_str_name(&self) -> &'static str {
666        match self {
667            Self::Unspecified => "AGGREGATE_TYPE_UNSPECIFIED",
668            Self::TotalDuration => "TOTAL_DURATION",
669            Self::TotalCount => "TOTAL_COUNT",
670        }
671    }
672    /// Creates an enum from field names used in the ProtoBuf definition.
673    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
674        match value {
675            "AGGREGATE_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
676            "TOTAL_DURATION" => Some(Self::TotalDuration),
677            "TOTAL_COUNT" => Some(Self::TotalCount),
678            _ => None,
679        }
680    }
681}
682#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
683#[repr(i32)]
684pub enum EventDispositionStatus {
685    Unspecified = 0,
686    PendingReview = 1,
687    ClosedIgnored = 2,
688    ClosedRequiresFurtherAction = 3,
689    NoDisposition = 4,
690}
691impl EventDispositionStatus {
692    /// String value of the enum field names used in the ProtoBuf definition.
693    ///
694    /// The values are not transformed in any way and thus are considered stable
695    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
696    pub fn as_str_name(&self) -> &'static str {
697        match self {
698            Self::Unspecified => "EVENT_DISPOSITION_STATUS_UNSPECIFIED",
699            Self::PendingReview => "PENDING_REVIEW",
700            Self::ClosedIgnored => "CLOSED_IGNORED",
701            Self::ClosedRequiresFurtherAction => "CLOSED_REQUIRES_FURTHER_ACTION",
702            Self::NoDisposition => "NO_DISPOSITION",
703        }
704    }
705    /// Creates an enum from field names used in the ProtoBuf definition.
706    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
707        match value {
708            "EVENT_DISPOSITION_STATUS_UNSPECIFIED" => Some(Self::Unspecified),
709            "PENDING_REVIEW" => Some(Self::PendingReview),
710            "CLOSED_IGNORED" => Some(Self::ClosedIgnored),
711            "CLOSED_REQUIRES_FURTHER_ACTION" => Some(Self::ClosedRequiresFurtherAction),
712            "NO_DISPOSITION" => Some(Self::NoDisposition),
713            _ => None,
714        }
715    }
716}
717#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
718#[repr(i32)]
719pub enum EventTimeFilterCondition {
720    Unspecified = 0,
721    StartTimeBeforeInclusive = 1,
722    StartTimeBeforeExclusive = 2,
723    StartTimeAfterInclusive = 3,
724    StartTimeAfterExclusive = 4,
725    EndTimeBeforeInclusive = 5,
726    EndTimeBeforeExclusive = 6,
727    EndTimeAfterInclusive = 7,
728    EndTimeAfterExclusive = 8,
729}
730impl EventTimeFilterCondition {
731    /// String value of the enum field names used in the ProtoBuf definition.
732    ///
733    /// The values are not transformed in any way and thus are considered stable
734    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
735    pub fn as_str_name(&self) -> &'static str {
736        match self {
737            Self::Unspecified => "EVENT_TIME_FILTER_CONDITION_UNSPECIFIED",
738            Self::StartTimeBeforeInclusive => "START_TIME_BEFORE_INCLUSIVE",
739            Self::StartTimeBeforeExclusive => "START_TIME_BEFORE_EXCLUSIVE",
740            Self::StartTimeAfterInclusive => "START_TIME_AFTER_INCLUSIVE",
741            Self::StartTimeAfterExclusive => "START_TIME_AFTER_EXCLUSIVE",
742            Self::EndTimeBeforeInclusive => "END_TIME_BEFORE_INCLUSIVE",
743            Self::EndTimeBeforeExclusive => "END_TIME_BEFORE_EXCLUSIVE",
744            Self::EndTimeAfterInclusive => "END_TIME_AFTER_INCLUSIVE",
745            Self::EndTimeAfterExclusive => "END_TIME_AFTER_EXCLUSIVE",
746        }
747    }
748    /// Creates an enum from field names used in the ProtoBuf definition.
749    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
750        match value {
751            "EVENT_TIME_FILTER_CONDITION_UNSPECIFIED" => Some(Self::Unspecified),
752            "START_TIME_BEFORE_INCLUSIVE" => Some(Self::StartTimeBeforeInclusive),
753            "START_TIME_BEFORE_EXCLUSIVE" => Some(Self::StartTimeBeforeExclusive),
754            "START_TIME_AFTER_INCLUSIVE" => Some(Self::StartTimeAfterInclusive),
755            "START_TIME_AFTER_EXCLUSIVE" => Some(Self::StartTimeAfterExclusive),
756            "END_TIME_BEFORE_INCLUSIVE" => Some(Self::EndTimeBeforeInclusive),
757            "END_TIME_BEFORE_EXCLUSIVE" => Some(Self::EndTimeBeforeExclusive),
758            "END_TIME_AFTER_INCLUSIVE" => Some(Self::EndTimeAfterInclusive),
759            "END_TIME_AFTER_EXCLUSIVE" => Some(Self::EndTimeAfterExclusive),
760            _ => None,
761        }
762    }
763}
764#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
765#[repr(i32)]
766pub enum EventType {
767    Unspecified = 0,
768    Info = 1,
769    Flag = 2,
770    Error = 3,
771    Success = 4,
772}
773impl EventType {
774    /// String value of the enum field names used in the ProtoBuf definition.
775    ///
776    /// The values are not transformed in any way and thus are considered stable
777    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
778    pub fn as_str_name(&self) -> &'static str {
779        match self {
780            Self::Unspecified => "EVENT_TYPE_UNSPECIFIED",
781            Self::Info => "INFO",
782            Self::Flag => "FLAG",
783            Self::Error => "ERROR",
784            Self::Success => "SUCCESS",
785        }
786    }
787    /// Creates an enum from field names used in the ProtoBuf definition.
788    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
789        match value {
790            "EVENT_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
791            "INFO" => Some(Self::Info),
792            "FLAG" => Some(Self::Flag),
793            "ERROR" => Some(Self::Error),
794            "SUCCESS" => Some(Self::Success),
795            _ => None,
796        }
797    }
798}
799#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
800#[repr(i32)]
801pub enum SearchEventOriginType {
802    Unspecified = 0,
803    Workbook = 1,
804    Template = 2,
805    Api = 3,
806    DataReview = 4,
807    Procedure = 5,
808    StreamingChecklist = 6,
809}
810impl SearchEventOriginType {
811    /// String value of the enum field names used in the ProtoBuf definition.
812    ///
813    /// The values are not transformed in any way and thus are considered stable
814    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
815    pub fn as_str_name(&self) -> &'static str {
816        match self {
817            Self::Unspecified => "SEARCH_EVENT_ORIGIN_TYPE_UNSPECIFIED",
818            Self::Workbook => "WORKBOOK",
819            Self::Template => "TEMPLATE",
820            Self::Api => "API",
821            Self::DataReview => "DATA_REVIEW",
822            Self::Procedure => "PROCEDURE",
823            Self::StreamingChecklist => "STREAMING_CHECKLIST",
824        }
825    }
826    /// Creates an enum from field names used in the ProtoBuf definition.
827    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
828        match value {
829            "SEARCH_EVENT_ORIGIN_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
830            "WORKBOOK" => Some(Self::Workbook),
831            "TEMPLATE" => Some(Self::Template),
832            "API" => Some(Self::Api),
833            "DATA_REVIEW" => Some(Self::DataReview),
834            "PROCEDURE" => Some(Self::Procedure),
835            "STREAMING_CHECKLIST" => Some(Self::StreamingChecklist),
836            _ => None,
837        }
838    }
839}
840#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
841#[repr(i32)]
842pub enum SortField {
843    Unspecified = 0,
844    StartTime = 1,
845    EndTime = 2,
846    Duration = 3,
847    DispositionStatus = 4,
848    Priority = 5,
849    EventName = 6,
850}
851impl SortField {
852    /// String value of the enum field names used in the ProtoBuf definition.
853    ///
854    /// The values are not transformed in any way and thus are considered stable
855    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
856    pub fn as_str_name(&self) -> &'static str {
857        match self {
858            Self::Unspecified => "SORT_FIELD_UNSPECIFIED",
859            Self::StartTime => "START_TIME",
860            Self::EndTime => "END_TIME",
861            Self::Duration => "DURATION",
862            Self::DispositionStatus => "DISPOSITION_STATUS",
863            Self::Priority => "PRIORITY",
864            Self::EventName => "EVENT_NAME",
865        }
866    }
867    /// Creates an enum from field names used in the ProtoBuf definition.
868    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
869        match value {
870            "SORT_FIELD_UNSPECIFIED" => Some(Self::Unspecified),
871            "START_TIME" => Some(Self::StartTime),
872            "END_TIME" => Some(Self::EndTime),
873            "DURATION" => Some(Self::Duration),
874            "DISPOSITION_STATUS" => Some(Self::DispositionStatus),
875            "PRIORITY" => Some(Self::Priority),
876            "EVENT_NAME" => Some(Self::EventName),
877            _ => None,
878        }
879    }
880}
881/// Generated client implementations.
882pub mod event_service_client {
883    #![allow(
884        unused_variables,
885        dead_code,
886        missing_docs,
887        clippy::wildcard_imports,
888        clippy::let_unit_value,
889    )]
890    use tonic::codegen::*;
891    use tonic::codegen::http::Uri;
892    #[derive(Debug, Clone)]
893    pub struct EventServiceClient<T> {
894        inner: tonic::client::Grpc<T>,
895    }
896    impl EventServiceClient<tonic::transport::Channel> {
897        /// Attempt to create a new client by connecting to a given endpoint.
898        pub async fn connect<D>(dst: D) -> Result<Self, tonic::transport::Error>
899        where
900            D: TryInto<tonic::transport::Endpoint>,
901            D::Error: Into<StdError>,
902        {
903            let conn = tonic::transport::Endpoint::new(dst)?.connect().await?;
904            Ok(Self::new(conn))
905        }
906    }
907    impl<T> EventServiceClient<T>
908    where
909        T: tonic::client::GrpcService<tonic::body::Body>,
910        T::Error: Into<StdError>,
911        T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
912        <T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
913    {
914        pub fn new(inner: T) -> Self {
915            let inner = tonic::client::Grpc::new(inner);
916            Self { inner }
917        }
918        pub fn with_origin(inner: T, origin: Uri) -> Self {
919            let inner = tonic::client::Grpc::with_origin(inner, origin);
920            Self { inner }
921        }
922        pub fn with_interceptor<F>(
923            inner: T,
924            interceptor: F,
925        ) -> EventServiceClient<InterceptedService<T, F>>
926        where
927            F: tonic::service::Interceptor,
928            T::ResponseBody: Default,
929            T: tonic::codegen::Service<
930                http::Request<tonic::body::Body>,
931                Response = http::Response<
932                    <T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
933                >,
934            >,
935            <T as tonic::codegen::Service<
936                http::Request<tonic::body::Body>,
937            >>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
938        {
939            EventServiceClient::new(InterceptedService::new(inner, interceptor))
940        }
941        /// Compress requests with the given encoding.
942        ///
943        /// This requires the server to support it otherwise it might respond with an
944        /// error.
945        #[must_use]
946        pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
947            self.inner = self.inner.send_compressed(encoding);
948            self
949        }
950        /// Enable decompressing responses.
951        #[must_use]
952        pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
953            self.inner = self.inner.accept_compressed(encoding);
954            self
955        }
956        /// Limits the maximum size of a decoded message.
957        ///
958        /// Default: `4MB`
959        #[must_use]
960        pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
961            self.inner = self.inner.max_decoding_message_size(limit);
962            self
963        }
964        /// Limits the maximum size of an encoded message.
965        ///
966        /// Default: `usize::MAX`
967        #[must_use]
968        pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
969            self.inner = self.inner.max_encoding_message_size(limit);
970            self
971        }
972        pub async fn create_event(
973            &mut self,
974            request: impl tonic::IntoRequest<super::CreateEventRequest>,
975        ) -> std::result::Result<
976            tonic::Response<super::CreateEventResponse>,
977            tonic::Status,
978        > {
979            self.inner
980                .ready()
981                .await
982                .map_err(|e| {
983                    tonic::Status::unknown(
984                        format!("Service was not ready: {}", e.into()),
985                    )
986                })?;
987            let codec = tonic::codec::ProstCodec::default();
988            let path = http::uri::PathAndQuery::from_static(
989                "/nominal.event.v1.EventService/CreateEvent",
990            );
991            let mut req = request.into_request();
992            req.extensions_mut()
993                .insert(GrpcMethod::new("nominal.event.v1.EventService", "CreateEvent"));
994            self.inner.unary(req, path, codec).await
995        }
996        pub async fn get_events(
997            &mut self,
998            request: impl tonic::IntoRequest<super::GetEventsRequest>,
999        ) -> std::result::Result<
1000            tonic::Response<super::GetEventsResponse>,
1001            tonic::Status,
1002        > {
1003            self.inner
1004                .ready()
1005                .await
1006                .map_err(|e| {
1007                    tonic::Status::unknown(
1008                        format!("Service was not ready: {}", e.into()),
1009                    )
1010                })?;
1011            let codec = tonic::codec::ProstCodec::default();
1012            let path = http::uri::PathAndQuery::from_static(
1013                "/nominal.event.v1.EventService/GetEvents",
1014            );
1015            let mut req = request.into_request();
1016            req.extensions_mut()
1017                .insert(GrpcMethod::new("nominal.event.v1.EventService", "GetEvents"));
1018            self.inner.unary(req, path, codec).await
1019        }
1020        pub async fn batch_get_events(
1021            &mut self,
1022            request: impl tonic::IntoRequest<super::BatchGetEventsRequest>,
1023        ) -> std::result::Result<
1024            tonic::Response<super::BatchGetEventsResponse>,
1025            tonic::Status,
1026        > {
1027            self.inner
1028                .ready()
1029                .await
1030                .map_err(|e| {
1031                    tonic::Status::unknown(
1032                        format!("Service was not ready: {}", e.into()),
1033                    )
1034                })?;
1035            let codec = tonic::codec::ProstCodec::default();
1036            let path = http::uri::PathAndQuery::from_static(
1037                "/nominal.event.v1.EventService/BatchGetEvents",
1038            );
1039            let mut req = request.into_request();
1040            req.extensions_mut()
1041                .insert(
1042                    GrpcMethod::new("nominal.event.v1.EventService", "BatchGetEvents"),
1043                );
1044            self.inner.unary(req, path, codec).await
1045        }
1046        pub async fn batch_filter_events(
1047            &mut self,
1048            request: impl tonic::IntoRequest<super::BatchFilterEventsRequest>,
1049        ) -> std::result::Result<
1050            tonic::Response<super::BatchFilterEventsResponse>,
1051            tonic::Status,
1052        > {
1053            self.inner
1054                .ready()
1055                .await
1056                .map_err(|e| {
1057                    tonic::Status::unknown(
1058                        format!("Service was not ready: {}", e.into()),
1059                    )
1060                })?;
1061            let codec = tonic::codec::ProstCodec::default();
1062            let path = http::uri::PathAndQuery::from_static(
1063                "/nominal.event.v1.EventService/BatchFilterEvents",
1064            );
1065            let mut req = request.into_request();
1066            req.extensions_mut()
1067                .insert(
1068                    GrpcMethod::new("nominal.event.v1.EventService", "BatchFilterEvents"),
1069                );
1070            self.inner.unary(req, path, codec).await
1071        }
1072        pub async fn update_event(
1073            &mut self,
1074            request: impl tonic::IntoRequest<super::UpdateEventLegacyRequest>,
1075        ) -> std::result::Result<
1076            tonic::Response<super::UpdateEventResponse>,
1077            tonic::Status,
1078        > {
1079            self.inner
1080                .ready()
1081                .await
1082                .map_err(|e| {
1083                    tonic::Status::unknown(
1084                        format!("Service was not ready: {}", e.into()),
1085                    )
1086                })?;
1087            let codec = tonic::codec::ProstCodec::default();
1088            let path = http::uri::PathAndQuery::from_static(
1089                "/nominal.event.v1.EventService/UpdateEvent",
1090            );
1091            let mut req = request.into_request();
1092            req.extensions_mut()
1093                .insert(GrpcMethod::new("nominal.event.v1.EventService", "UpdateEvent"));
1094            self.inner.unary(req, path, codec).await
1095        }
1096        pub async fn batch_update_event(
1097            &mut self,
1098            request: impl tonic::IntoRequest<super::BatchUpdateEventRequest>,
1099        ) -> std::result::Result<
1100            tonic::Response<super::BatchUpdateEventResponse>,
1101            tonic::Status,
1102        > {
1103            self.inner
1104                .ready()
1105                .await
1106                .map_err(|e| {
1107                    tonic::Status::unknown(
1108                        format!("Service was not ready: {}", e.into()),
1109                    )
1110                })?;
1111            let codec = tonic::codec::ProstCodec::default();
1112            let path = http::uri::PathAndQuery::from_static(
1113                "/nominal.event.v1.EventService/BatchUpdateEvent",
1114            );
1115            let mut req = request.into_request();
1116            req.extensions_mut()
1117                .insert(
1118                    GrpcMethod::new("nominal.event.v1.EventService", "BatchUpdateEvent"),
1119                );
1120            self.inner.unary(req, path, codec).await
1121        }
1122        pub async fn batch_update_disposition(
1123            &mut self,
1124            request: impl tonic::IntoRequest<super::BatchUpdateDispositionRequest>,
1125        ) -> std::result::Result<
1126            tonic::Response<super::BatchUpdateDispositionResponse>,
1127            tonic::Status,
1128        > {
1129            self.inner
1130                .ready()
1131                .await
1132                .map_err(|e| {
1133                    tonic::Status::unknown(
1134                        format!("Service was not ready: {}", e.into()),
1135                    )
1136                })?;
1137            let codec = tonic::codec::ProstCodec::default();
1138            let path = http::uri::PathAndQuery::from_static(
1139                "/nominal.event.v1.EventService/BatchUpdateDisposition",
1140            );
1141            let mut req = request.into_request();
1142            req.extensions_mut()
1143                .insert(
1144                    GrpcMethod::new(
1145                        "nominal.event.v1.EventService",
1146                        "BatchUpdateDisposition",
1147                    ),
1148                );
1149            self.inner.unary(req, path, codec).await
1150        }
1151        pub async fn archive_event(
1152            &mut self,
1153            request: impl tonic::IntoRequest<super::ArchiveEventRequest>,
1154        ) -> std::result::Result<
1155            tonic::Response<super::ArchiveEventResponse>,
1156            tonic::Status,
1157        > {
1158            self.inner
1159                .ready()
1160                .await
1161                .map_err(|e| {
1162                    tonic::Status::unknown(
1163                        format!("Service was not ready: {}", e.into()),
1164                    )
1165                })?;
1166            let codec = tonic::codec::ProstCodec::default();
1167            let path = http::uri::PathAndQuery::from_static(
1168                "/nominal.event.v1.EventService/ArchiveEvent",
1169            );
1170            let mut req = request.into_request();
1171            req.extensions_mut()
1172                .insert(
1173                    GrpcMethod::new("nominal.event.v1.EventService", "ArchiveEvent"),
1174                );
1175            self.inner.unary(req, path, codec).await
1176        }
1177        pub async fn batch_archive_event(
1178            &mut self,
1179            request: impl tonic::IntoRequest<super::BatchArchiveEventRequest>,
1180        ) -> std::result::Result<
1181            tonic::Response<super::BatchArchiveEventResponse>,
1182            tonic::Status,
1183        > {
1184            self.inner
1185                .ready()
1186                .await
1187                .map_err(|e| {
1188                    tonic::Status::unknown(
1189                        format!("Service was not ready: {}", e.into()),
1190                    )
1191                })?;
1192            let codec = tonic::codec::ProstCodec::default();
1193            let path = http::uri::PathAndQuery::from_static(
1194                "/nominal.event.v1.EventService/BatchArchiveEvent",
1195            );
1196            let mut req = request.into_request();
1197            req.extensions_mut()
1198                .insert(
1199                    GrpcMethod::new("nominal.event.v1.EventService", "BatchArchiveEvent"),
1200                );
1201            self.inner.unary(req, path, codec).await
1202        }
1203        pub async fn batch_unarchive_event(
1204            &mut self,
1205            request: impl tonic::IntoRequest<super::BatchUnarchiveEventRequest>,
1206        ) -> std::result::Result<
1207            tonic::Response<super::BatchUnarchiveEventResponse>,
1208            tonic::Status,
1209        > {
1210            self.inner
1211                .ready()
1212                .await
1213                .map_err(|e| {
1214                    tonic::Status::unknown(
1215                        format!("Service was not ready: {}", e.into()),
1216                    )
1217                })?;
1218            let codec = tonic::codec::ProstCodec::default();
1219            let path = http::uri::PathAndQuery::from_static(
1220                "/nominal.event.v1.EventService/BatchUnarchiveEvent",
1221            );
1222            let mut req = request.into_request();
1223            req.extensions_mut()
1224                .insert(
1225                    GrpcMethod::new(
1226                        "nominal.event.v1.EventService",
1227                        "BatchUnarchiveEvent",
1228                    ),
1229                );
1230            self.inner.unary(req, path, codec).await
1231        }
1232        pub async fn search_events(
1233            &mut self,
1234            request: impl tonic::IntoRequest<super::SearchEventsRequest>,
1235        ) -> std::result::Result<
1236            tonic::Response<super::SearchEventsResponse>,
1237            tonic::Status,
1238        > {
1239            self.inner
1240                .ready()
1241                .await
1242                .map_err(|e| {
1243                    tonic::Status::unknown(
1244                        format!("Service was not ready: {}", e.into()),
1245                    )
1246                })?;
1247            let codec = tonic::codec::ProstCodec::default();
1248            let path = http::uri::PathAndQuery::from_static(
1249                "/nominal.event.v1.EventService/SearchEvents",
1250            );
1251            let mut req = request.into_request();
1252            req.extensions_mut()
1253                .insert(
1254                    GrpcMethod::new("nominal.event.v1.EventService", "SearchEvents"),
1255                );
1256            self.inner.unary(req, path, codec).await
1257        }
1258        pub async fn aggregate_events(
1259            &mut self,
1260            request: impl tonic::IntoRequest<super::AggregateEventsRequest>,
1261        ) -> std::result::Result<
1262            tonic::Response<super::AggregateEventsResponse>,
1263            tonic::Status,
1264        > {
1265            self.inner
1266                .ready()
1267                .await
1268                .map_err(|e| {
1269                    tonic::Status::unknown(
1270                        format!("Service was not ready: {}", e.into()),
1271                    )
1272                })?;
1273            let codec = tonic::codec::ProstCodec::default();
1274            let path = http::uri::PathAndQuery::from_static(
1275                "/nominal.event.v1.EventService/AggregateEvents",
1276            );
1277            let mut req = request.into_request();
1278            req.extensions_mut()
1279                .insert(
1280                    GrpcMethod::new("nominal.event.v1.EventService", "AggregateEvents"),
1281                );
1282            self.inner.unary(req, path, codec).await
1283        }
1284        pub async fn batch_aggregate_events(
1285            &mut self,
1286            request: impl tonic::IntoRequest<super::BatchAggregateEventsRequest>,
1287        ) -> std::result::Result<
1288            tonic::Response<super::BatchAggregateEventsResponse>,
1289            tonic::Status,
1290        > {
1291            self.inner
1292                .ready()
1293                .await
1294                .map_err(|e| {
1295                    tonic::Status::unknown(
1296                        format!("Service was not ready: {}", e.into()),
1297                    )
1298                })?;
1299            let codec = tonic::codec::ProstCodec::default();
1300            let path = http::uri::PathAndQuery::from_static(
1301                "/nominal.event.v1.EventService/BatchAggregateEvents",
1302            );
1303            let mut req = request.into_request();
1304            req.extensions_mut()
1305                .insert(
1306                    GrpcMethod::new(
1307                        "nominal.event.v1.EventService",
1308                        "BatchAggregateEvents",
1309                    ),
1310                );
1311            self.inner.unary(req, path, codec).await
1312        }
1313        pub async fn get_events_histogram(
1314            &mut self,
1315            request: impl tonic::IntoRequest<super::EventsHistogramRequest>,
1316        ) -> std::result::Result<
1317            tonic::Response<super::EventsHistogramResponse>,
1318            tonic::Status,
1319        > {
1320            self.inner
1321                .ready()
1322                .await
1323                .map_err(|e| {
1324                    tonic::Status::unknown(
1325                        format!("Service was not ready: {}", e.into()),
1326                    )
1327                })?;
1328            let codec = tonic::codec::ProstCodec::default();
1329            let path = http::uri::PathAndQuery::from_static(
1330                "/nominal.event.v1.EventService/GetEventsHistogram",
1331            );
1332            let mut req = request.into_request();
1333            req.extensions_mut()
1334                .insert(
1335                    GrpcMethod::new(
1336                        "nominal.event.v1.EventService",
1337                        "GetEventsHistogram",
1338                    ),
1339                );
1340            self.inner.unary(req, path, codec).await
1341        }
1342        pub async fn list_properties_and_labels(
1343            &mut self,
1344            request: impl tonic::IntoRequest<super::ListPropertiesAndLabelsRequest>,
1345        ) -> std::result::Result<
1346            tonic::Response<
1347                super::super::super::metadata::v1::ListPropertiesAndLabelsResponse,
1348            >,
1349            tonic::Status,
1350        > {
1351            self.inner
1352                .ready()
1353                .await
1354                .map_err(|e| {
1355                    tonic::Status::unknown(
1356                        format!("Service was not ready: {}", e.into()),
1357                    )
1358                })?;
1359            let codec = tonic::codec::ProstCodec::default();
1360            let path = http::uri::PathAndQuery::from_static(
1361                "/nominal.event.v1.EventService/ListPropertiesAndLabels",
1362            );
1363            let mut req = request.into_request();
1364            req.extensions_mut()
1365                .insert(
1366                    GrpcMethod::new(
1367                        "nominal.event.v1.EventService",
1368                        "ListPropertiesAndLabels",
1369                    ),
1370                );
1371            self.inner.unary(req, path, codec).await
1372        }
1373    }
1374}
nominal_api_proto/proto/nominal.event.v1.rs

nominal_api_proto/proto/
nominal.event.v1.rs
