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, 40, 41"
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        #[prost(message, tag = "40")]
360        NumericProperty(super::super::super::types::NumericPropertyPredicate),
361        #[prost(message, tag = "41")]
362        NumericPropertyRange(super::super::super::types::NumericPropertyRangePredicate),
363    }
364}
365#[derive(Clone, PartialEq, ::prost::Message)]
366pub struct HistogramFilterQuery {
367    #[prost(
368        oneof = "histogram_filter_query::HistogramFilterQuery",
369        tags = "1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21"
370    )]
371    pub histogram_filter_query: ::core::option::Option<
372        histogram_filter_query::HistogramFilterQuery,
373    >,
374}
375/// Nested message and enum types in `HistogramFilterQuery`.
376pub mod histogram_filter_query {
377    #[derive(Clone, PartialEq, ::prost::Oneof)]
378    pub enum HistogramFilterQuery {
379        #[prost(string, tag = "1")]
380        SearchText(::prost::alloc::string::String),
381        #[prost(string, tag = "2")]
382        Asset(::prost::alloc::string::String),
383        #[prost(string, tag = "3")]
384        Template(::prost::alloc::string::String),
385        #[prost(string, tag = "4")]
386        Workbook(::prost::alloc::string::String),
387        #[prost(string, tag = "5")]
388        DataReview(::prost::alloc::string::String),
389        #[prost(enumeration = "super::SearchEventOriginType", tag = "6")]
390        OriginType(i32),
391        #[prost(string, tag = "7")]
392        DataReviewCheck(::prost::alloc::string::String),
393        #[prost(enumeration = "super::EventDispositionStatus", tag = "8")]
394        DispositionStatus(i32),
395        #[prost(enumeration = "super::Priority", tag = "9")]
396        Priority(i32),
397        #[prost(string, tag = "10")]
398        Assignee(::prost::alloc::string::String),
399        #[prost(enumeration = "super::EventType", tag = "11")]
400        EventType(i32),
401        #[prost(string, tag = "12")]
402        CreatedBy(::prost::alloc::string::String),
403        #[prost(string, tag = "13")]
404        Label(::prost::alloc::string::String),
405        #[prost(message, tag = "14")]
406        Property(super::super::super::types::Property),
407        #[prost(message, tag = "15")]
408        And(super::HistogramFilterQueryList),
409        #[prost(message, tag = "16")]
410        Or(super::HistogramFilterQueryList),
411        #[prost(message, tag = "17")]
412        Not(::prost::alloc::boxed::Box<super::HistogramFilterQuery>),
413        #[prost(string, tag = "18")]
414        Workspace(::prost::alloc::string::String),
415        #[prost(string, tag = "19")]
416        Procedure(::prost::alloc::string::String),
417        #[prost(string, tag = "20")]
418        ProcedureExecution(::prost::alloc::string::String),
419        #[prost(string, tag = "21")]
420        StepId(::prost::alloc::string::String),
421    }
422}
423#[derive(Clone, Copy, PartialEq, ::prost::Message)]
424pub struct SortOptions {
425    #[prost(bool, tag = "1")]
426    pub is_descending: bool,
427    #[prost(enumeration = "SortField", tag = "2")]
428    pub field: i32,
429}
430#[derive(Clone, Copy, PartialEq, ::prost::Message)]
431pub struct AggregateValue {
432    #[prost(oneof = "aggregate_value::AggregateValue", tags = "1, 2")]
433    pub aggregate_value: ::core::option::Option<aggregate_value::AggregateValue>,
434}
435/// Nested message and enum types in `AggregateValue`.
436pub mod aggregate_value {
437    #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
438    pub enum AggregateValue {
439        #[prost(message, tag = "1")]
440        Duration(super::super::super::types::Duration),
441        #[prost(int32, tag = "2")]
442        Count(i32),
443    }
444}
445#[derive(Clone, Copy, PartialEq, ::prost::Message)]
446pub struct EventsHistogramBucket {
447    #[prost(message, optional, tag = "1")]
448    pub start_inclusive: ::core::option::Option<super::super::types::time::Timestamp>,
449    #[prost(message, optional, tag = "2")]
450    pub end_exclusive: ::core::option::Option<super::super::types::time::Timestamp>,
451    #[prost(int32, tag = "3")]
452    pub count: i32,
453}
454#[derive(Clone, PartialEq, ::prost::Message)]
455pub struct CreateEventRequest {
456    #[prost(string, repeated, tag = "1")]
457    pub asset_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
458    #[prost(message, repeated, tag = "2")]
459    pub origins: ::prost::alloc::vec::Vec<EventOrigin>,
460    #[prost(message, optional, tag = "3")]
461    pub timestamp: ::core::option::Option<super::super::types::time::Timestamp>,
462    #[prost(message, optional, tag = "4")]
463    pub duration: ::core::option::Option<super::super::types::Duration>,
464    #[prost(string, tag = "5")]
465    pub name: ::prost::alloc::string::String,
466    #[prost(string, optional, tag = "6")]
467    pub description: ::core::option::Option<::prost::alloc::string::String>,
468    #[prost(enumeration = "EventType", tag = "7")]
469    pub r#type: i32,
470    #[prost(string, repeated, tag = "8")]
471    pub labels: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
472    #[prost(map = "string, string", tag = "9")]
473    pub properties: ::std::collections::HashMap<
474        ::prost::alloc::string::String,
475        ::prost::alloc::string::String,
476    >,
477    #[prost(message, optional, tag = "10")]
478    pub disposition: ::core::option::Option<EventDisposition>,
479    #[prost(map = "string, message", tag = "11")]
480    pub typed_properties: ::std::collections::HashMap<
481        ::prost::alloc::string::String,
482        super::super::types::TypedPropertyValue,
483    >,
484}
485#[derive(Clone, PartialEq, ::prost::Message)]
486pub struct CreateEventResponse {
487    #[prost(message, optional, tag = "1")]
488    pub event: ::core::option::Option<Event>,
489}
490#[derive(Clone, PartialEq, ::prost::Message)]
491pub struct GetEventsRequest {
492    #[prost(string, repeated, tag = "1")]
493    pub uuids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
494}
495#[derive(Clone, PartialEq, ::prost::Message)]
496pub struct GetEventsResponse {
497    #[prost(message, repeated, tag = "1")]
498    pub events: ::prost::alloc::vec::Vec<Event>,
499}
500#[derive(Clone, PartialEq, ::prost::Message)]
501pub struct BatchGetEventsRequest {
502    #[prost(string, repeated, tag = "1")]
503    pub event_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
504}
505#[derive(Clone, PartialEq, ::prost::Message)]
506pub struct BatchGetEventsResponse {
507    #[prost(message, repeated, tag = "1")]
508    pub events: ::prost::alloc::vec::Vec<Event>,
509}
510#[derive(Clone, PartialEq, ::prost::Message)]
511pub struct BatchFilterEventsRequest {
512    #[prost(string, repeated, tag = "1")]
513    pub event_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
514    #[prost(message, optional, tag = "2")]
515    pub filter_query: ::core::option::Option<SearchQuery>,
516}
517#[derive(Clone, PartialEq, ::prost::Message)]
518pub struct BatchFilterEventsResponse {
519    #[prost(message, repeated, tag = "1")]
520    pub events: ::prost::alloc::vec::Vec<Event>,
521}
522#[derive(Clone, PartialEq, ::prost::Message)]
523pub struct AssetRidSet {
524    #[prost(string, repeated, tag = "1")]
525    pub asset_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
526}
527#[derive(Clone, PartialEq, ::prost::Message)]
528pub struct UpdateEventRequest {
529    #[prost(string, tag = "1")]
530    pub uuid: ::prost::alloc::string::String,
531    #[prost(string, optional, tag = "2")]
532    pub rid: ::core::option::Option<::prost::alloc::string::String>,
533    #[prost(message, optional, tag = "3")]
534    pub asset_rids: ::core::option::Option<AssetRidSet>,
535    #[prost(message, optional, tag = "4")]
536    pub timestamp: ::core::option::Option<super::super::types::time::Timestamp>,
537    #[prost(message, optional, tag = "5")]
538    pub duration: ::core::option::Option<super::super::types::Duration>,
539    #[prost(string, optional, tag = "6")]
540    pub name: ::core::option::Option<::prost::alloc::string::String>,
541    #[prost(string, optional, tag = "7")]
542    pub description: ::core::option::Option<::prost::alloc::string::String>,
543    #[prost(enumeration = "EventType", optional, tag = "8")]
544    pub r#type: ::core::option::Option<i32>,
545    #[prost(message, optional, tag = "9")]
546    pub labels: ::core::option::Option<super::super::types::LabelUpdateWrapper>,
547    #[deprecated]
548    #[prost(message, optional, tag = "10")]
549    pub properties: ::core::option::Option<super::super::types::PropertyUpdateWrapper>,
550    #[prost(message, optional, tag = "11")]
551    pub typed_properties: ::core::option::Option<
552        super::super::types::TypedPropertyUpdateWrapper,
553    >,
554}
555#[derive(Clone, PartialEq, ::prost::Message)]
556pub struct UpdateEventResponse {
557    #[prost(message, optional, tag = "1")]
558    pub event: ::core::option::Option<Event>,
559}
560#[derive(Clone, PartialEq, ::prost::Message)]
561pub struct EventUpdate {
562    #[prost(string, tag = "1")]
563    pub rid: ::prost::alloc::string::String,
564    #[prost(message, optional, tag = "2")]
565    pub asset_rids: ::core::option::Option<AssetRidSet>,
566    #[prost(message, optional, tag = "3")]
567    pub timestamp: ::core::option::Option<super::super::types::time::Timestamp>,
568    #[prost(message, optional, tag = "4")]
569    pub duration: ::core::option::Option<super::super::types::Duration>,
570    #[prost(string, optional, tag = "5")]
571    pub name: ::core::option::Option<::prost::alloc::string::String>,
572    #[prost(string, optional, tag = "6")]
573    pub description: ::core::option::Option<::prost::alloc::string::String>,
574    #[prost(enumeration = "EventType", optional, tag = "7")]
575    pub r#type: ::core::option::Option<i32>,
576    #[prost(message, optional, tag = "8")]
577    pub labels: ::core::option::Option<super::super::types::LabelUpdateWrapper>,
578    #[deprecated]
579    #[prost(message, optional, tag = "9")]
580    pub properties: ::core::option::Option<super::super::types::PropertyUpdateWrapper>,
581    #[prost(message, optional, tag = "10")]
582    pub typed_properties: ::core::option::Option<
583        super::super::types::TypedPropertyUpdateWrapper,
584    >,
585}
586#[derive(Clone, PartialEq, ::prost::Message)]
587pub struct BatchUpdateEventRequest {
588    #[prost(message, repeated, tag = "1")]
589    pub updates: ::prost::alloc::vec::Vec<EventUpdate>,
590}
591#[derive(Clone, PartialEq, ::prost::Message)]
592pub struct BatchUpdateEventResponse {
593    #[prost(message, repeated, tag = "1")]
594    pub events: ::prost::alloc::vec::Vec<Event>,
595}
596#[derive(Clone, PartialEq, ::prost::Message)]
597pub struct UpdateDispositionRequest {
598    #[prost(string, tag = "1")]
599    pub rid: ::prost::alloc::string::String,
600    #[prost(message, optional, tag = "2")]
601    pub disposition: ::core::option::Option<EventDisposition>,
602}
603#[derive(Clone, PartialEq, ::prost::Message)]
604pub struct BatchUpdateDispositionRequest {
605    #[prost(message, repeated, tag = "1")]
606    pub requests: ::prost::alloc::vec::Vec<UpdateDispositionRequest>,
607}
608#[derive(Clone, PartialEq, ::prost::Message)]
609pub struct BatchUpdateDispositionResponse {
610    #[prost(message, repeated, tag = "1")]
611    pub events: ::prost::alloc::vec::Vec<Event>,
612}
613#[derive(Clone, PartialEq, ::prost::Message)]
614pub struct ArchiveEventRequest {
615    #[prost(string, tag = "1")]
616    pub uuid: ::prost::alloc::string::String,
617}
618#[derive(Clone, Copy, PartialEq, ::prost::Message)]
619pub struct ArchiveEventResponse {}
620#[derive(Clone, PartialEq, ::prost::Message)]
621pub struct BatchArchiveEventRequest {
622    #[prost(string, repeated, tag = "1")]
623    pub event_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
624}
625#[derive(Clone, Copy, PartialEq, ::prost::Message)]
626pub struct BatchArchiveEventResponse {}
627#[derive(Clone, PartialEq, ::prost::Message)]
628pub struct BatchUnarchiveEventRequest {
629    #[prost(string, repeated, tag = "1")]
630    pub event_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
631}
632#[derive(Clone, Copy, PartialEq, ::prost::Message)]
633pub struct BatchUnarchiveEventResponse {}
634#[derive(Clone, PartialEq, ::prost::Message)]
635pub struct SearchEventsRequest {
636    #[prost(message, optional, tag = "1")]
637    pub sort: ::core::option::Option<SortOptions>,
638    #[prost(int32, tag = "2")]
639    pub page_size: i32,
640    #[prost(string, optional, tag = "3")]
641    pub next_page_token: ::core::option::Option<::prost::alloc::string::String>,
642    #[prost(message, optional, tag = "4")]
643    pub query: ::core::option::Option<SearchQuery>,
644    #[prost(enumeration = "super::super::types::ArchivedStatus", repeated, tag = "5")]
645    pub archived_statuses: ::prost::alloc::vec::Vec<i32>,
646}
647#[derive(Clone, PartialEq, ::prost::Message)]
648pub struct SearchEventsResponse {
649    #[prost(message, repeated, tag = "1")]
650    pub results: ::prost::alloc::vec::Vec<Event>,
651    #[prost(string, optional, tag = "2")]
652    pub next_page_token: ::core::option::Option<::prost::alloc::string::String>,
653}
654#[derive(Clone, PartialEq, ::prost::Message)]
655pub struct FindEventsQuery {
656    #[prost(string, repeated, tag = "1")]
657    pub asset_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
658    #[prost(message, optional, tag = "2")]
659    pub start_inclusive: ::core::option::Option<super::super::types::time::Timestamp>,
660    #[prost(message, optional, tag = "3")]
661    pub end_exclusive: ::core::option::Option<super::super::types::time::Timestamp>,
662    #[prost(int32, tag = "4")]
663    pub index: i32,
664}
665#[derive(Clone, PartialEq, ::prost::Message)]
666pub struct BatchFindEventsRequest {
667    #[prost(message, optional, tag = "1")]
668    pub query: ::core::option::Option<SearchQuery>,
669    #[prost(message, optional, tag = "2")]
670    pub sort: ::core::option::Option<SortOptions>,
671    #[prost(message, repeated, tag = "3")]
672    pub queries: ::prost::alloc::vec::Vec<FindEventsQuery>,
673}
674#[derive(Clone, PartialEq, ::prost::Message)]
675pub struct FindEventsResult {
676    #[prost(message, optional, tag = "1")]
677    pub event: ::core::option::Option<Event>,
678}
679#[derive(Clone, PartialEq, ::prost::Message)]
680pub struct BatchFindEventsResponse {
681    #[prost(message, repeated, tag = "1")]
682    pub results: ::prost::alloc::vec::Vec<FindEventsResult>,
683}
684#[derive(Clone, PartialEq, ::prost::Message)]
685pub struct AggregateEventsRequest {
686    #[prost(message, optional, tag = "1")]
687    pub query: ::core::option::Option<SearchQuery>,
688    #[prost(enumeration = "AggregateType", repeated, tag = "2")]
689    pub aggregate_types: ::prost::alloc::vec::Vec<i32>,
690}
691#[derive(Clone, PartialEq, ::prost::Message)]
692pub struct AggregateEventsResponse {
693    #[prost(map = "string, message", tag = "1")]
694    pub values: ::std::collections::HashMap<
695        ::prost::alloc::string::String,
696        AggregateValue,
697    >,
698}
699#[derive(Clone, PartialEq, ::prost::Message)]
700pub struct BatchAggregateEventsRequest {
701    #[prost(message, repeated, tag = "1")]
702    pub requests: ::prost::alloc::vec::Vec<AggregateEventsRequest>,
703}
704#[derive(Clone, PartialEq, ::prost::Message)]
705pub struct BatchAggregateEventsResponse {
706    #[prost(message, repeated, tag = "1")]
707    pub responses: ::prost::alloc::vec::Vec<AggregateEventsResponse>,
708}
709#[derive(Clone, PartialEq, ::prost::Message)]
710pub struct GetEventsHistogramRequest {
711    #[prost(message, optional, tag = "1")]
712    pub start_inclusive: ::core::option::Option<super::super::types::time::Timestamp>,
713    #[prost(message, optional, tag = "2")]
714    pub end_exclusive: ::core::option::Option<super::super::types::time::Timestamp>,
715    #[prost(message, optional, tag = "3")]
716    pub filter_query: ::core::option::Option<HistogramFilterQuery>,
717    #[prost(enumeration = "super::super::types::ArchivedStatus", repeated, tag = "4")]
718    pub archived_statuses: ::prost::alloc::vec::Vec<i32>,
719    #[prost(int32, optional, tag = "5")]
720    pub num_bins: ::core::option::Option<i32>,
721    #[prost(int32, optional, tag = "6")]
722    pub event_limit: ::core::option::Option<i32>,
723}
724#[derive(Clone, PartialEq, ::prost::Message)]
725pub struct GetEventsHistogramResponse {
726    #[prost(message, repeated, tag = "1")]
727    pub buckets: ::prost::alloc::vec::Vec<EventsHistogramBucket>,
728}
729#[derive(Clone, PartialEq, ::prost::Message)]
730pub struct ListPropertiesAndLabelsRequest {
731    #[prost(string, repeated, tag = "1")]
732    pub workspace_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
733}
734#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
735#[repr(i32)]
736pub enum EventError {
737    InvalidEventRequest = 0,
738    FindEventsQueryCountTooLarge = 1,
739    FindEventsIndexInvalid = 2,
740    SearchQueryTooBroad = 3,
741}
742impl EventError {
743    /// String value of the enum field names used in the ProtoBuf definition.
744    ///
745    /// The values are not transformed in any way and thus are considered stable
746    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
747    pub fn as_str_name(&self) -> &'static str {
748        match self {
749            Self::InvalidEventRequest => "EVENT_ERROR_INVALID_EVENT_REQUEST",
750            Self::FindEventsQueryCountTooLarge => {
751                "EVENT_ERROR_FIND_EVENTS_QUERY_COUNT_TOO_LARGE"
752            }
753            Self::FindEventsIndexInvalid => "EVENT_ERROR_FIND_EVENTS_INDEX_INVALID",
754            Self::SearchQueryTooBroad => "EVENT_ERROR_SEARCH_QUERY_TOO_BROAD",
755        }
756    }
757    /// Creates an enum from field names used in the ProtoBuf definition.
758    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
759        match value {
760            "EVENT_ERROR_INVALID_EVENT_REQUEST" => Some(Self::InvalidEventRequest),
761            "EVENT_ERROR_FIND_EVENTS_QUERY_COUNT_TOO_LARGE" => {
762                Some(Self::FindEventsQueryCountTooLarge)
763            }
764            "EVENT_ERROR_FIND_EVENTS_INDEX_INVALID" => Some(Self::FindEventsIndexInvalid),
765            "EVENT_ERROR_SEARCH_QUERY_TOO_BROAD" => Some(Self::SearchQueryTooBroad),
766            _ => None,
767        }
768    }
769}
770#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
771#[repr(i32)]
772pub enum Priority {
773    Unspecified = 0,
774    P0 = 1,
775    P1 = 2,
776    P2 = 3,
777    P3 = 4,
778    P4 = 5,
779}
780impl Priority {
781    /// String value of the enum field names used in the ProtoBuf definition.
782    ///
783    /// The values are not transformed in any way and thus are considered stable
784    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
785    pub fn as_str_name(&self) -> &'static str {
786        match self {
787            Self::Unspecified => "PRIORITY_UNSPECIFIED",
788            Self::P0 => "P0",
789            Self::P1 => "P1",
790            Self::P2 => "P2",
791            Self::P3 => "P3",
792            Self::P4 => "P4",
793        }
794    }
795    /// Creates an enum from field names used in the ProtoBuf definition.
796    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
797        match value {
798            "PRIORITY_UNSPECIFIED" => Some(Self::Unspecified),
799            "P0" => Some(Self::P0),
800            "P1" => Some(Self::P1),
801            "P2" => Some(Self::P2),
802            "P3" => Some(Self::P3),
803            "P4" => Some(Self::P4),
804            _ => None,
805        }
806    }
807}
808#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
809#[repr(i32)]
810pub enum SetOperator {
811    Unspecified = 0,
812    And = 1,
813    Or = 2,
814}
815impl SetOperator {
816    /// String value of the enum field names used in the ProtoBuf definition.
817    ///
818    /// The values are not transformed in any way and thus are considered stable
819    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
820    pub fn as_str_name(&self) -> &'static str {
821        match self {
822            Self::Unspecified => "SET_OPERATOR_UNSPECIFIED",
823            Self::And => "AND",
824            Self::Or => "OR",
825        }
826    }
827    /// Creates an enum from field names used in the ProtoBuf definition.
828    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
829        match value {
830            "SET_OPERATOR_UNSPECIFIED" => Some(Self::Unspecified),
831            "AND" => Some(Self::And),
832            "OR" => Some(Self::Or),
833            _ => None,
834        }
835    }
836}
837#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
838#[repr(i32)]
839pub enum EventType {
840    Unspecified = 0,
841    Info = 1,
842    Flag = 2,
843    Error = 3,
844    Success = 4,
845}
846impl EventType {
847    /// String value of the enum field names used in the ProtoBuf definition.
848    ///
849    /// The values are not transformed in any way and thus are considered stable
850    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
851    pub fn as_str_name(&self) -> &'static str {
852        match self {
853            Self::Unspecified => "EVENT_TYPE_UNSPECIFIED",
854            Self::Info => "INFO",
855            Self::Flag => "FLAG",
856            Self::Error => "ERROR",
857            Self::Success => "SUCCESS",
858        }
859    }
860    /// Creates an enum from field names used in the ProtoBuf definition.
861    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
862        match value {
863            "EVENT_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
864            "INFO" => Some(Self::Info),
865            "FLAG" => Some(Self::Flag),
866            "ERROR" => Some(Self::Error),
867            "SUCCESS" => Some(Self::Success),
868            _ => None,
869        }
870    }
871}
872#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
873#[repr(i32)]
874pub enum EventDispositionStatus {
875    Unspecified = 0,
876    PendingReview = 1,
877    ClosedIgnored = 2,
878    ClosedRequiresFurtherAction = 3,
879    NoDisposition = 4,
880}
881impl EventDispositionStatus {
882    /// String value of the enum field names used in the ProtoBuf definition.
883    ///
884    /// The values are not transformed in any way and thus are considered stable
885    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
886    pub fn as_str_name(&self) -> &'static str {
887        match self {
888            Self::Unspecified => "EVENT_DISPOSITION_STATUS_UNSPECIFIED",
889            Self::PendingReview => "PENDING_REVIEW",
890            Self::ClosedIgnored => "CLOSED_IGNORED",
891            Self::ClosedRequiresFurtherAction => "CLOSED_REQUIRES_FURTHER_ACTION",
892            Self::NoDisposition => "NO_DISPOSITION",
893        }
894    }
895    /// Creates an enum from field names used in the ProtoBuf definition.
896    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
897        match value {
898            "EVENT_DISPOSITION_STATUS_UNSPECIFIED" => Some(Self::Unspecified),
899            "PENDING_REVIEW" => Some(Self::PendingReview),
900            "CLOSED_IGNORED" => Some(Self::ClosedIgnored),
901            "CLOSED_REQUIRES_FURTHER_ACTION" => Some(Self::ClosedRequiresFurtherAction),
902            "NO_DISPOSITION" => Some(Self::NoDisposition),
903            _ => None,
904        }
905    }
906}
907#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
908#[repr(i32)]
909pub enum EventTimeFilterCondition {
910    Unspecified = 0,
911    StartTimeBeforeInclusive = 1,
912    StartTimeBeforeExclusive = 2,
913    StartTimeAfterInclusive = 3,
914    StartTimeAfterExclusive = 4,
915    EndTimeBeforeInclusive = 5,
916    EndTimeBeforeExclusive = 6,
917    EndTimeAfterInclusive = 7,
918    EndTimeAfterExclusive = 8,
919}
920impl EventTimeFilterCondition {
921    /// String value of the enum field names used in the ProtoBuf definition.
922    ///
923    /// The values are not transformed in any way and thus are considered stable
924    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
925    pub fn as_str_name(&self) -> &'static str {
926        match self {
927            Self::Unspecified => "EVENT_TIME_FILTER_CONDITION_UNSPECIFIED",
928            Self::StartTimeBeforeInclusive => "START_TIME_BEFORE_INCLUSIVE",
929            Self::StartTimeBeforeExclusive => "START_TIME_BEFORE_EXCLUSIVE",
930            Self::StartTimeAfterInclusive => "START_TIME_AFTER_INCLUSIVE",
931            Self::StartTimeAfterExclusive => "START_TIME_AFTER_EXCLUSIVE",
932            Self::EndTimeBeforeInclusive => "END_TIME_BEFORE_INCLUSIVE",
933            Self::EndTimeBeforeExclusive => "END_TIME_BEFORE_EXCLUSIVE",
934            Self::EndTimeAfterInclusive => "END_TIME_AFTER_INCLUSIVE",
935            Self::EndTimeAfterExclusive => "END_TIME_AFTER_EXCLUSIVE",
936        }
937    }
938    /// Creates an enum from field names used in the ProtoBuf definition.
939    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
940        match value {
941            "EVENT_TIME_FILTER_CONDITION_UNSPECIFIED" => Some(Self::Unspecified),
942            "START_TIME_BEFORE_INCLUSIVE" => Some(Self::StartTimeBeforeInclusive),
943            "START_TIME_BEFORE_EXCLUSIVE" => Some(Self::StartTimeBeforeExclusive),
944            "START_TIME_AFTER_INCLUSIVE" => Some(Self::StartTimeAfterInclusive),
945            "START_TIME_AFTER_EXCLUSIVE" => Some(Self::StartTimeAfterExclusive),
946            "END_TIME_BEFORE_INCLUSIVE" => Some(Self::EndTimeBeforeInclusive),
947            "END_TIME_BEFORE_EXCLUSIVE" => Some(Self::EndTimeBeforeExclusive),
948            "END_TIME_AFTER_INCLUSIVE" => Some(Self::EndTimeAfterInclusive),
949            "END_TIME_AFTER_EXCLUSIVE" => Some(Self::EndTimeAfterExclusive),
950            _ => None,
951        }
952    }
953}
954#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
955#[repr(i32)]
956pub enum SearchEventOriginType {
957    Unspecified = 0,
958    Workbook = 1,
959    Template = 2,
960    Api = 3,
961    DataReview = 4,
962    Procedure = 5,
963    StreamingChecklist = 6,
964}
965impl SearchEventOriginType {
966    /// String value of the enum field names used in the ProtoBuf definition.
967    ///
968    /// The values are not transformed in any way and thus are considered stable
969    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
970    pub fn as_str_name(&self) -> &'static str {
971        match self {
972            Self::Unspecified => "SEARCH_EVENT_ORIGIN_TYPE_UNSPECIFIED",
973            Self::Workbook => "WORKBOOK",
974            Self::Template => "TEMPLATE",
975            Self::Api => "API",
976            Self::DataReview => "DATA_REVIEW",
977            Self::Procedure => "PROCEDURE",
978            Self::StreamingChecklist => "STREAMING_CHECKLIST",
979        }
980    }
981    /// Creates an enum from field names used in the ProtoBuf definition.
982    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
983        match value {
984            "SEARCH_EVENT_ORIGIN_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
985            "WORKBOOK" => Some(Self::Workbook),
986            "TEMPLATE" => Some(Self::Template),
987            "API" => Some(Self::Api),
988            "DATA_REVIEW" => Some(Self::DataReview),
989            "PROCEDURE" => Some(Self::Procedure),
990            "STREAMING_CHECKLIST" => Some(Self::StreamingChecklist),
991            _ => None,
992        }
993    }
994}
995#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
996#[repr(i32)]
997pub enum AggregateType {
998    Unspecified = 0,
999    TotalDuration = 1,
1000    TotalCount = 2,
1001}
1002impl AggregateType {
1003    /// String value of the enum field names used in the ProtoBuf definition.
1004    ///
1005    /// The values are not transformed in any way and thus are considered stable
1006    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
1007    pub fn as_str_name(&self) -> &'static str {
1008        match self {
1009            Self::Unspecified => "AGGREGATE_TYPE_UNSPECIFIED",
1010            Self::TotalDuration => "TOTAL_DURATION",
1011            Self::TotalCount => "TOTAL_COUNT",
1012        }
1013    }
1014    /// Creates an enum from field names used in the ProtoBuf definition.
1015    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1016        match value {
1017            "AGGREGATE_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
1018            "TOTAL_DURATION" => Some(Self::TotalDuration),
1019            "TOTAL_COUNT" => Some(Self::TotalCount),
1020            _ => None,
1021        }
1022    }
1023}
1024#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1025#[repr(i32)]
1026pub enum SortField {
1027    Unspecified = 0,
1028    StartTime = 1,
1029    EndTime = 2,
1030    Duration = 3,
1031    DispositionStatus = 4,
1032    Priority = 5,
1033    EventName = 6,
1034}
1035impl SortField {
1036    /// String value of the enum field names used in the ProtoBuf definition.
1037    ///
1038    /// The values are not transformed in any way and thus are considered stable
1039    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
1040    pub fn as_str_name(&self) -> &'static str {
1041        match self {
1042            Self::Unspecified => "SORT_FIELD_UNSPECIFIED",
1043            Self::StartTime => "START_TIME",
1044            Self::EndTime => "END_TIME",
1045            Self::Duration => "DURATION",
1046            Self::DispositionStatus => "DISPOSITION_STATUS",
1047            Self::Priority => "PRIORITY",
1048            Self::EventName => "EVENT_NAME",
1049        }
1050    }
1051    /// Creates an enum from field names used in the ProtoBuf definition.
1052    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1053        match value {
1054            "SORT_FIELD_UNSPECIFIED" => Some(Self::Unspecified),
1055            "START_TIME" => Some(Self::StartTime),
1056            "END_TIME" => Some(Self::EndTime),
1057            "DURATION" => Some(Self::Duration),
1058            "DISPOSITION_STATUS" => Some(Self::DispositionStatus),
1059            "PRIORITY" => Some(Self::Priority),
1060            "EVENT_NAME" => Some(Self::EventName),
1061            _ => None,
1062        }
1063    }
1064}
1065/// Generated client implementations.
1066pub mod event_service_client {
1067    #![allow(
1068        unused_variables,
1069        dead_code,
1070        missing_docs,
1071        clippy::wildcard_imports,
1072        clippy::let_unit_value,
1073    )]
1074    use tonic::codegen::*;
1075    use tonic::codegen::http::Uri;
1076    #[derive(Debug, Clone)]
1077    pub struct EventServiceClient<T> {
1078        inner: tonic::client::Grpc<T>,
1079    }
1080    impl EventServiceClient<tonic::transport::Channel> {
1081        /// Attempt to create a new client by connecting to a given endpoint.
1082        pub async fn connect<D>(dst: D) -> Result<Self, tonic::transport::Error>
1083        where
1084            D: TryInto<tonic::transport::Endpoint>,
1085            D::Error: Into<StdError>,
1086        {
1087            let conn = tonic::transport::Endpoint::new(dst)?.connect().await?;
1088            Ok(Self::new(conn))
1089        }
1090    }
1091    impl<T> EventServiceClient<T>
1092    where
1093        T: tonic::client::GrpcService<tonic::body::Body>,
1094        T::Error: Into<StdError>,
1095        T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
1096        <T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
1097    {
1098        pub fn new(inner: T) -> Self {
1099            let inner = tonic::client::Grpc::new(inner);
1100            Self { inner }
1101        }
1102        pub fn with_origin(inner: T, origin: Uri) -> Self {
1103            let inner = tonic::client::Grpc::with_origin(inner, origin);
1104            Self { inner }
1105        }
1106        pub fn with_interceptor<F>(
1107            inner: T,
1108            interceptor: F,
1109        ) -> EventServiceClient<InterceptedService<T, F>>
1110        where
1111            F: tonic::service::Interceptor,
1112            T::ResponseBody: Default,
1113            T: tonic::codegen::Service<
1114                http::Request<tonic::body::Body>,
1115                Response = http::Response<
1116                    <T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
1117                >,
1118            >,
1119            <T as tonic::codegen::Service<
1120                http::Request<tonic::body::Body>,
1121            >>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
1122        {
1123            EventServiceClient::new(InterceptedService::new(inner, interceptor))
1124        }
1125        /// Compress requests with the given encoding.
1126        ///
1127        /// This requires the server to support it otherwise it might respond with an
1128        /// error.
1129        #[must_use]
1130        pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
1131            self.inner = self.inner.send_compressed(encoding);
1132            self
1133        }
1134        /// Enable decompressing responses.
1135        #[must_use]
1136        pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
1137            self.inner = self.inner.accept_compressed(encoding);
1138            self
1139        }
1140        /// Limits the maximum size of a decoded message.
1141        ///
1142        /// Default: `4MB`
1143        #[must_use]
1144        pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
1145            self.inner = self.inner.max_decoding_message_size(limit);
1146            self
1147        }
1148        /// Limits the maximum size of an encoded message.
1149        ///
1150        /// Default: `usize::MAX`
1151        #[must_use]
1152        pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
1153            self.inner = self.inner.max_encoding_message_size(limit);
1154            self
1155        }
1156        pub async fn create_event(
1157            &mut self,
1158            request: impl tonic::IntoRequest<super::CreateEventRequest>,
1159        ) -> std::result::Result<
1160            tonic::Response<super::CreateEventResponse>,
1161            tonic::Status,
1162        > {
1163            self.inner
1164                .ready()
1165                .await
1166                .map_err(|e| {
1167                    tonic::Status::unknown(
1168                        format!("Service was not ready: {}", e.into()),
1169                    )
1170                })?;
1171            let codec = tonic::codec::ProstCodec::default();
1172            let path = http::uri::PathAndQuery::from_static(
1173                "/nominal.event.v2.EventService/CreateEvent",
1174            );
1175            let mut req = request.into_request();
1176            req.extensions_mut()
1177                .insert(GrpcMethod::new("nominal.event.v2.EventService", "CreateEvent"));
1178            self.inner.unary(req, path, codec).await
1179        }
1180        pub async fn get_events(
1181            &mut self,
1182            request: impl tonic::IntoRequest<super::GetEventsRequest>,
1183        ) -> std::result::Result<
1184            tonic::Response<super::GetEventsResponse>,
1185            tonic::Status,
1186        > {
1187            self.inner
1188                .ready()
1189                .await
1190                .map_err(|e| {
1191                    tonic::Status::unknown(
1192                        format!("Service was not ready: {}", e.into()),
1193                    )
1194                })?;
1195            let codec = tonic::codec::ProstCodec::default();
1196            let path = http::uri::PathAndQuery::from_static(
1197                "/nominal.event.v2.EventService/GetEvents",
1198            );
1199            let mut req = request.into_request();
1200            req.extensions_mut()
1201                .insert(GrpcMethod::new("nominal.event.v2.EventService", "GetEvents"));
1202            self.inner.unary(req, path, codec).await
1203        }
1204        pub async fn batch_get_events(
1205            &mut self,
1206            request: impl tonic::IntoRequest<super::BatchGetEventsRequest>,
1207        ) -> std::result::Result<
1208            tonic::Response<super::BatchGetEventsResponse>,
1209            tonic::Status,
1210        > {
1211            self.inner
1212                .ready()
1213                .await
1214                .map_err(|e| {
1215                    tonic::Status::unknown(
1216                        format!("Service was not ready: {}", e.into()),
1217                    )
1218                })?;
1219            let codec = tonic::codec::ProstCodec::default();
1220            let path = http::uri::PathAndQuery::from_static(
1221                "/nominal.event.v2.EventService/BatchGetEvents",
1222            );
1223            let mut req = request.into_request();
1224            req.extensions_mut()
1225                .insert(
1226                    GrpcMethod::new("nominal.event.v2.EventService", "BatchGetEvents"),
1227                );
1228            self.inner.unary(req, path, codec).await
1229        }
1230        pub async fn batch_filter_events(
1231            &mut self,
1232            request: impl tonic::IntoRequest<super::BatchFilterEventsRequest>,
1233        ) -> std::result::Result<
1234            tonic::Response<super::BatchFilterEventsResponse>,
1235            tonic::Status,
1236        > {
1237            self.inner
1238                .ready()
1239                .await
1240                .map_err(|e| {
1241                    tonic::Status::unknown(
1242                        format!("Service was not ready: {}", e.into()),
1243                    )
1244                })?;
1245            let codec = tonic::codec::ProstCodec::default();
1246            let path = http::uri::PathAndQuery::from_static(
1247                "/nominal.event.v2.EventService/BatchFilterEvents",
1248            );
1249            let mut req = request.into_request();
1250            req.extensions_mut()
1251                .insert(
1252                    GrpcMethod::new("nominal.event.v2.EventService", "BatchFilterEvents"),
1253                );
1254            self.inner.unary(req, path, codec).await
1255        }
1256        pub async fn update_event(
1257            &mut self,
1258            request: impl tonic::IntoRequest<super::UpdateEventRequest>,
1259        ) -> std::result::Result<
1260            tonic::Response<super::UpdateEventResponse>,
1261            tonic::Status,
1262        > {
1263            self.inner
1264                .ready()
1265                .await
1266                .map_err(|e| {
1267                    tonic::Status::unknown(
1268                        format!("Service was not ready: {}", e.into()),
1269                    )
1270                })?;
1271            let codec = tonic::codec::ProstCodec::default();
1272            let path = http::uri::PathAndQuery::from_static(
1273                "/nominal.event.v2.EventService/UpdateEvent",
1274            );
1275            let mut req = request.into_request();
1276            req.extensions_mut()
1277                .insert(GrpcMethod::new("nominal.event.v2.EventService", "UpdateEvent"));
1278            self.inner.unary(req, path, codec).await
1279        }
1280        pub async fn batch_update_event(
1281            &mut self,
1282            request: impl tonic::IntoRequest<super::BatchUpdateEventRequest>,
1283        ) -> std::result::Result<
1284            tonic::Response<super::BatchUpdateEventResponse>,
1285            tonic::Status,
1286        > {
1287            self.inner
1288                .ready()
1289                .await
1290                .map_err(|e| {
1291                    tonic::Status::unknown(
1292                        format!("Service was not ready: {}", e.into()),
1293                    )
1294                })?;
1295            let codec = tonic::codec::ProstCodec::default();
1296            let path = http::uri::PathAndQuery::from_static(
1297                "/nominal.event.v2.EventService/BatchUpdateEvent",
1298            );
1299            let mut req = request.into_request();
1300            req.extensions_mut()
1301                .insert(
1302                    GrpcMethod::new("nominal.event.v2.EventService", "BatchUpdateEvent"),
1303                );
1304            self.inner.unary(req, path, codec).await
1305        }
1306        pub async fn batch_update_disposition(
1307            &mut self,
1308            request: impl tonic::IntoRequest<super::BatchUpdateDispositionRequest>,
1309        ) -> std::result::Result<
1310            tonic::Response<super::BatchUpdateDispositionResponse>,
1311            tonic::Status,
1312        > {
1313            self.inner
1314                .ready()
1315                .await
1316                .map_err(|e| {
1317                    tonic::Status::unknown(
1318                        format!("Service was not ready: {}", e.into()),
1319                    )
1320                })?;
1321            let codec = tonic::codec::ProstCodec::default();
1322            let path = http::uri::PathAndQuery::from_static(
1323                "/nominal.event.v2.EventService/BatchUpdateDisposition",
1324            );
1325            let mut req = request.into_request();
1326            req.extensions_mut()
1327                .insert(
1328                    GrpcMethod::new(
1329                        "nominal.event.v2.EventService",
1330                        "BatchUpdateDisposition",
1331                    ),
1332                );
1333            self.inner.unary(req, path, codec).await
1334        }
1335        pub async fn archive_event(
1336            &mut self,
1337            request: impl tonic::IntoRequest<super::ArchiveEventRequest>,
1338        ) -> std::result::Result<
1339            tonic::Response<super::ArchiveEventResponse>,
1340            tonic::Status,
1341        > {
1342            self.inner
1343                .ready()
1344                .await
1345                .map_err(|e| {
1346                    tonic::Status::unknown(
1347                        format!("Service was not ready: {}", e.into()),
1348                    )
1349                })?;
1350            let codec = tonic::codec::ProstCodec::default();
1351            let path = http::uri::PathAndQuery::from_static(
1352                "/nominal.event.v2.EventService/ArchiveEvent",
1353            );
1354            let mut req = request.into_request();
1355            req.extensions_mut()
1356                .insert(
1357                    GrpcMethod::new("nominal.event.v2.EventService", "ArchiveEvent"),
1358                );
1359            self.inner.unary(req, path, codec).await
1360        }
1361        pub async fn batch_archive_event(
1362            &mut self,
1363            request: impl tonic::IntoRequest<super::BatchArchiveEventRequest>,
1364        ) -> std::result::Result<
1365            tonic::Response<super::BatchArchiveEventResponse>,
1366            tonic::Status,
1367        > {
1368            self.inner
1369                .ready()
1370                .await
1371                .map_err(|e| {
1372                    tonic::Status::unknown(
1373                        format!("Service was not ready: {}", e.into()),
1374                    )
1375                })?;
1376            let codec = tonic::codec::ProstCodec::default();
1377            let path = http::uri::PathAndQuery::from_static(
1378                "/nominal.event.v2.EventService/BatchArchiveEvent",
1379            );
1380            let mut req = request.into_request();
1381            req.extensions_mut()
1382                .insert(
1383                    GrpcMethod::new("nominal.event.v2.EventService", "BatchArchiveEvent"),
1384                );
1385            self.inner.unary(req, path, codec).await
1386        }
1387        pub async fn batch_unarchive_event(
1388            &mut self,
1389            request: impl tonic::IntoRequest<super::BatchUnarchiveEventRequest>,
1390        ) -> std::result::Result<
1391            tonic::Response<super::BatchUnarchiveEventResponse>,
1392            tonic::Status,
1393        > {
1394            self.inner
1395                .ready()
1396                .await
1397                .map_err(|e| {
1398                    tonic::Status::unknown(
1399                        format!("Service was not ready: {}", e.into()),
1400                    )
1401                })?;
1402            let codec = tonic::codec::ProstCodec::default();
1403            let path = http::uri::PathAndQuery::from_static(
1404                "/nominal.event.v2.EventService/BatchUnarchiveEvent",
1405            );
1406            let mut req = request.into_request();
1407            req.extensions_mut()
1408                .insert(
1409                    GrpcMethod::new(
1410                        "nominal.event.v2.EventService",
1411                        "BatchUnarchiveEvent",
1412                    ),
1413                );
1414            self.inner.unary(req, path, codec).await
1415        }
1416        pub async fn search_events(
1417            &mut self,
1418            request: impl tonic::IntoRequest<super::SearchEventsRequest>,
1419        ) -> std::result::Result<
1420            tonic::Response<super::SearchEventsResponse>,
1421            tonic::Status,
1422        > {
1423            self.inner
1424                .ready()
1425                .await
1426                .map_err(|e| {
1427                    tonic::Status::unknown(
1428                        format!("Service was not ready: {}", e.into()),
1429                    )
1430                })?;
1431            let codec = tonic::codec::ProstCodec::default();
1432            let path = http::uri::PathAndQuery::from_static(
1433                "/nominal.event.v2.EventService/SearchEvents",
1434            );
1435            let mut req = request.into_request();
1436            req.extensions_mut()
1437                .insert(
1438                    GrpcMethod::new("nominal.event.v2.EventService", "SearchEvents"),
1439                );
1440            self.inner.unary(req, path, codec).await
1441        }
1442        pub async fn batch_find_events(
1443            &mut self,
1444            request: impl tonic::IntoRequest<super::BatchFindEventsRequest>,
1445        ) -> std::result::Result<
1446            tonic::Response<super::BatchFindEventsResponse>,
1447            tonic::Status,
1448        > {
1449            self.inner
1450                .ready()
1451                .await
1452                .map_err(|e| {
1453                    tonic::Status::unknown(
1454                        format!("Service was not ready: {}", e.into()),
1455                    )
1456                })?;
1457            let codec = tonic::codec::ProstCodec::default();
1458            let path = http::uri::PathAndQuery::from_static(
1459                "/nominal.event.v2.EventService/BatchFindEvents",
1460            );
1461            let mut req = request.into_request();
1462            req.extensions_mut()
1463                .insert(
1464                    GrpcMethod::new("nominal.event.v2.EventService", "BatchFindEvents"),
1465                );
1466            self.inner.unary(req, path, codec).await
1467        }
1468        pub async fn aggregate_events(
1469            &mut self,
1470            request: impl tonic::IntoRequest<super::AggregateEventsRequest>,
1471        ) -> std::result::Result<
1472            tonic::Response<super::AggregateEventsResponse>,
1473            tonic::Status,
1474        > {
1475            self.inner
1476                .ready()
1477                .await
1478                .map_err(|e| {
1479                    tonic::Status::unknown(
1480                        format!("Service was not ready: {}", e.into()),
1481                    )
1482                })?;
1483            let codec = tonic::codec::ProstCodec::default();
1484            let path = http::uri::PathAndQuery::from_static(
1485                "/nominal.event.v2.EventService/AggregateEvents",
1486            );
1487            let mut req = request.into_request();
1488            req.extensions_mut()
1489                .insert(
1490                    GrpcMethod::new("nominal.event.v2.EventService", "AggregateEvents"),
1491                );
1492            self.inner.unary(req, path, codec).await
1493        }
1494        pub async fn batch_aggregate_events(
1495            &mut self,
1496            request: impl tonic::IntoRequest<super::BatchAggregateEventsRequest>,
1497        ) -> std::result::Result<
1498            tonic::Response<super::BatchAggregateEventsResponse>,
1499            tonic::Status,
1500        > {
1501            self.inner
1502                .ready()
1503                .await
1504                .map_err(|e| {
1505                    tonic::Status::unknown(
1506                        format!("Service was not ready: {}", e.into()),
1507                    )
1508                })?;
1509            let codec = tonic::codec::ProstCodec::default();
1510            let path = http::uri::PathAndQuery::from_static(
1511                "/nominal.event.v2.EventService/BatchAggregateEvents",
1512            );
1513            let mut req = request.into_request();
1514            req.extensions_mut()
1515                .insert(
1516                    GrpcMethod::new(
1517                        "nominal.event.v2.EventService",
1518                        "BatchAggregateEvents",
1519                    ),
1520                );
1521            self.inner.unary(req, path, codec).await
1522        }
1523        pub async fn get_events_histogram(
1524            &mut self,
1525            request: impl tonic::IntoRequest<super::GetEventsHistogramRequest>,
1526        ) -> std::result::Result<
1527            tonic::Response<super::GetEventsHistogramResponse>,
1528            tonic::Status,
1529        > {
1530            self.inner
1531                .ready()
1532                .await
1533                .map_err(|e| {
1534                    tonic::Status::unknown(
1535                        format!("Service was not ready: {}", e.into()),
1536                    )
1537                })?;
1538            let codec = tonic::codec::ProstCodec::default();
1539            let path = http::uri::PathAndQuery::from_static(
1540                "/nominal.event.v2.EventService/GetEventsHistogram",
1541            );
1542            let mut req = request.into_request();
1543            req.extensions_mut()
1544                .insert(
1545                    GrpcMethod::new(
1546                        "nominal.event.v2.EventService",
1547                        "GetEventsHistogram",
1548                    ),
1549                );
1550            self.inner.unary(req, path, codec).await
1551        }
1552        pub async fn list_properties_and_labels(
1553            &mut self,
1554            request: impl tonic::IntoRequest<super::ListPropertiesAndLabelsRequest>,
1555        ) -> std::result::Result<
1556            tonic::Response<
1557                super::super::super::metadata::v2::ListPropertiesAndLabelsResponse,
1558            >,
1559            tonic::Status,
1560        > {
1561            self.inner
1562                .ready()
1563                .await
1564                .map_err(|e| {
1565                    tonic::Status::unknown(
1566                        format!("Service was not ready: {}", e.into()),
1567                    )
1568                })?;
1569            let codec = tonic::codec::ProstCodec::default();
1570            let path = http::uri::PathAndQuery::from_static(
1571                "/nominal.event.v2.EventService/ListPropertiesAndLabels",
1572            );
1573            let mut req = request.into_request();
1574            req.extensions_mut()
1575                .insert(
1576                    GrpcMethod::new(
1577                        "nominal.event.v2.EventService",
1578                        "ListPropertiesAndLabels",
1579                    ),
1580                );
1581            self.inner.unary(req, path, codec).await
1582        }
1583    }
1584}
nominal_api_proto/proto/nominal.event.v2.rs

nominal_api_proto/proto/
nominal.event.v2.rs
