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

nominal_api_proto/proto/
nominal.event.v2.rs
