nominal_api_proto/proto/
nominal.event.v2.rs

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

nominal_api_proto/proto/
nominal.event.v2.rs
