nominal_api_proto/proto/
nominal.event.v2.rs

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

nominal_api_proto/proto/
nominal.event.v2.rs
