nominal-api-proto 0.1346.1

// This file is @generated by prost-build.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AggregateEventsRequest {
    #[prost(message, optional, tag = "1")]
    pub query: ::core::option::Option<SearchQuery>,
    #[prost(enumeration = "AggregateType", repeated, tag = "2")]
    pub aggregate_types: ::prost::alloc::vec::Vec<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AggregateEventsResponse {
    #[prost(map = "string, message", tag = "1")]
    pub values: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        AggregateValue,
    >,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct AggregateValue {
    #[prost(oneof = "aggregate_value::AggregateValue", tags = "1, 2")]
    pub aggregate_value: ::core::option::Option<aggregate_value::AggregateValue>,
}
/// Nested message and enum types in `AggregateValue`.
pub mod aggregate_value {
    #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
    pub enum AggregateValue {
        #[prost(message, tag = "1")]
        Duration(super::super::super::types::Duration),
        #[prost(int32, tag = "2")]
        Count(i32),
    }
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct ApiEventOrigin {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ArchiveEventRequest {
    #[prost(string, tag = "1")]
    pub uuid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ArchivedStatusSetWrapper {
    #[prost(enumeration = "super::super::types::ArchivedStatus", repeated, tag = "1")]
    pub archived_statuses: ::prost::alloc::vec::Vec<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AssetRidSetWrapper {
    #[prost(string, repeated, tag = "1")]
    pub asset_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AssetsFilter {
    #[prost(enumeration = "super::super::types::SetOperator", tag = "1")]
    pub operator: i32,
    #[prost(string, repeated, tag = "2")]
    pub assets: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AssigneesFilter {
    #[prost(enumeration = "super::super::types::SetOperator", tag = "1")]
    pub operator: i32,
    #[prost(string, repeated, tag = "2")]
    pub assignees: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchAggregateEventsRequest {
    #[prost(message, repeated, tag = "1")]
    pub requests: ::prost::alloc::vec::Vec<AggregateEventsRequest>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchAggregateEventsResponse {
    #[prost(message, repeated, tag = "1")]
    pub responses: ::prost::alloc::vec::Vec<AggregateEventsResponse>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchFilterEventsRequest {
    #[prost(string, repeated, tag = "1")]
    pub event_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub filter_query: ::core::option::Option<SearchQuery>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchUpdateDispositionRequest {
    #[prost(message, repeated, tag = "1")]
    pub requests: ::prost::alloc::vec::Vec<UpdateDispositionRequest>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchUpdateDispositionResponse {
    #[prost(message, repeated, tag = "1")]
    pub events: ::prost::alloc::vec::Vec<Event>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchUpdateEventRequest {
    #[prost(message, repeated, tag = "1")]
    pub requests: ::prost::alloc::vec::Vec<UpdateEventRequest>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchUpdateEventResponse {
    #[prost(message, repeated, tag = "1")]
    pub events: ::prost::alloc::vec::Vec<Event>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CheckOriginMetadata {
    #[prost(string, tag = "1")]
    pub check_evaluation_rid: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub check_rid: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub check_lineage_rid: ::prost::alloc::string::String,
    #[prost(int32, optional, tag = "4")]
    pub implementation_index: ::core::option::Option<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateEventRequest {
    #[prost(string, repeated, tag = "1")]
    pub asset_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "2")]
    pub origins: ::prost::alloc::vec::Vec<EventOrigin>,
    #[prost(message, optional, tag = "3")]
    pub timestamp: ::core::option::Option<super::super::types::time::Timestamp>,
    #[prost(message, optional, tag = "4")]
    pub duration: ::core::option::Option<super::super::types::Duration>,
    #[prost(string, tag = "5")]
    pub name: ::prost::alloc::string::String,
    #[prost(string, optional, tag = "6")]
    pub description: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(enumeration = "EventType", tag = "7")]
    pub r#type: i32,
    #[prost(string, repeated, tag = "8")]
    pub labels: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(map = "string, string", tag = "9")]
    pub properties: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(message, optional, tag = "10")]
    pub disposition: ::core::option::Option<EventDisposition>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DataReviewChecksFilter {
    #[prost(string, repeated, tag = "1")]
    pub data_review_checks: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DataReviewEventOrigin {
    #[prost(string, tag = "1")]
    pub data_review_rid: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "2")]
    pub check_metadata: ::core::option::Option<CheckOriginMetadata>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DataReviewsFilter {
    #[prost(string, repeated, tag = "1")]
    pub data_reviews: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Event {
    #[prost(string, tag = "1")]
    pub uuid: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub rid: ::prost::alloc::string::String,
    #[prost(string, repeated, tag = "3")]
    pub asset_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "4")]
    pub origins: ::prost::alloc::vec::Vec<EventOrigin>,
    #[prost(message, optional, tag = "5")]
    pub timestamp: ::core::option::Option<super::super::types::time::Timestamp>,
    #[prost(message, optional, tag = "6")]
    pub duration: ::core::option::Option<super::super::types::Duration>,
    #[prost(string, tag = "7")]
    pub name: ::prost::alloc::string::String,
    #[prost(string, tag = "8")]
    pub description: ::prost::alloc::string::String,
    #[prost(enumeration = "EventType", tag = "9")]
    pub r#type: i32,
    #[prost(string, repeated, tag = "10")]
    pub labels: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(map = "string, string", tag = "11")]
    pub properties: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(bool, tag = "12")]
    pub is_archived: bool,
    #[prost(string, optional, tag = "13")]
    pub created_by: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "14")]
    pub disposition: ::core::option::Option<EventDisposition>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct EventDisposition {
    #[prost(enumeration = "super::super::types::Priority", tag = "1")]
    pub priority: i32,
    #[prost(message, optional, tag = "2")]
    pub state: ::core::option::Option<super::super::types::DispositionState>,
    #[prost(string, repeated, tag = "3")]
    pub assignees: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct EventOrigin {
    #[prost(oneof = "event_origin::EventOrigin", tags = "1, 2, 3, 4, 5, 6")]
    pub event_origin: ::core::option::Option<event_origin::EventOrigin>,
}
/// Nested message and enum types in `EventOrigin`.
pub mod event_origin {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum EventOrigin {
        #[prost(message, tag = "1")]
        Workbook(super::WorkbookEventOrigin),
        #[prost(message, tag = "2")]
        Template(super::TemplateEventOrigin),
        #[prost(message, tag = "3")]
        Api(super::ApiEventOrigin),
        #[prost(message, tag = "4")]
        DataReview(super::DataReviewEventOrigin),
        #[prost(message, tag = "5")]
        Procedure(super::ProcedureEventOrigin),
        #[prost(message, tag = "6")]
        StreamingChecklist(super::StreamingChecklistEventOrigin),
    }
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct EventTimeFilter {
    #[prost(message, optional, tag = "1")]
    pub timestamp: ::core::option::Option<super::super::types::time::Timestamp>,
    #[prost(enumeration = "EventTimeFilterCondition", tag = "2")]
    pub timestamp_condition: i32,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct EventsHistogramBucket {
    #[prost(message, optional, tag = "1")]
    pub start_inclusive: ::core::option::Option<super::super::types::time::Timestamp>,
    #[prost(message, optional, tag = "2")]
    pub end_exclusive: ::core::option::Option<super::super::types::time::Timestamp>,
    #[prost(int32, tag = "3")]
    pub count: i32,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct EventsHistogramRequest {
    #[prost(message, optional, tag = "1")]
    pub start_inclusive: ::core::option::Option<super::super::types::time::Timestamp>,
    #[prost(message, optional, tag = "2")]
    pub end_exclusive: ::core::option::Option<super::super::types::time::Timestamp>,
    #[prost(message, optional, tag = "3")]
    pub filter_query: ::core::option::Option<HistogramFilterQuery>,
    #[prost(message, optional, tag = "4")]
    pub archived_statuses: ::core::option::Option<ArchivedStatusSetWrapper>,
    #[prost(int32, optional, tag = "5")]
    pub num_bins: ::core::option::Option<i32>,
    #[prost(int32, optional, tag = "6")]
    pub event_limit: ::core::option::Option<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct EventsHistogramResponse {
    #[prost(message, repeated, tag = "1")]
    pub buckets: ::prost::alloc::vec::Vec<EventsHistogramBucket>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetEventsRequest {
    #[prost(string, repeated, tag = "1")]
    pub uuids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct HistogramFilterQuery {
    #[prost(string, optional, tag = "1")]
    pub search_text: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "2")]
    pub asset: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "3")]
    pub template: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "4")]
    pub workbook: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "5")]
    pub data_review: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(enumeration = "SearchEventOriginType", optional, tag = "6")]
    pub origin_type: ::core::option::Option<i32>,
    #[prost(string, optional, tag = "7")]
    pub data_review_check: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(enumeration = "EventDispositionStatus", optional, tag = "8")]
    pub disposition_status: ::core::option::Option<i32>,
    #[prost(enumeration = "super::super::types::Priority", optional, tag = "9")]
    pub priority: ::core::option::Option<i32>,
    #[prost(string, optional, tag = "10")]
    pub assignee: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(enumeration = "EventType", optional, tag = "11")]
    pub event_type: ::core::option::Option<i32>,
    #[prost(string, optional, tag = "12")]
    pub created_by: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "13")]
    pub label: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "14")]
    pub property: ::core::option::Option<super::super::types::Property>,
    #[prost(message, optional, tag = "15")]
    pub and: ::core::option::Option<HistogramFilterQueryListWrapper>,
    #[prost(message, optional, tag = "16")]
    pub or: ::core::option::Option<HistogramFilterQueryListWrapper>,
    #[prost(message, optional, boxed, tag = "17")]
    pub not: ::core::option::Option<::prost::alloc::boxed::Box<HistogramFilterQuery>>,
    #[prost(string, optional, tag = "18")]
    pub workspace: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "19")]
    pub procedure: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "20")]
    pub procedure_execution: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "21")]
    pub step_id: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct HistogramFilterQueryListWrapper {
    #[prost(message, repeated, tag = "1")]
    pub queries: ::prost::alloc::vec::Vec<HistogramFilterQuery>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListPropertiesAndLabelsRequest {
    #[prost(message, optional, tag = "1")]
    pub workspaces: ::core::option::Option<WorkspaceRidSetWrapper>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct OriginTypesFilter {
    #[prost(enumeration = "super::super::types::SetOperator", tag = "1")]
    pub operator: i32,
    #[prost(enumeration = "SearchEventOriginType", repeated, tag = "2")]
    pub origin_types: ::prost::alloc::vec::Vec<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProcedureEventOrigin {
    #[prost(string, tag = "1")]
    pub procedure_execution_rid: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub procedure_rid: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub step_id: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SearchEventsRequest {
    #[prost(message, optional, tag = "1")]
    pub sort: ::core::option::Option<SortOptions>,
    #[prost(int32, tag = "2")]
    pub page_size: i32,
    #[prost(string, optional, tag = "3")]
    pub next_page_token: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "4")]
    pub query: ::core::option::Option<SearchQuery>,
    #[prost(message, optional, tag = "5")]
    pub archived_statuses: ::core::option::Option<ArchivedStatusSetWrapper>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SearchEventsResponse {
    #[prost(message, repeated, tag = "1")]
    pub results: ::prost::alloc::vec::Vec<Event>,
    #[prost(string, optional, tag = "2")]
    pub next_page_token: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SearchQuery {
    #[prost(bool, optional, tag = "1")]
    pub archived: ::core::option::Option<bool>,
    #[prost(string, optional, tag = "2")]
    pub search_text: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "3")]
    pub exact_match: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "4")]
    pub after: ::core::option::Option<super::super::types::time::Timestamp>,
    #[prost(message, optional, tag = "5")]
    pub before: ::core::option::Option<super::super::types::time::Timestamp>,
    #[prost(message, optional, tag = "6")]
    pub advanced_time_filter: ::core::option::Option<EventTimeFilter>,
    #[prost(string, optional, tag = "7")]
    pub asset: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "8")]
    pub assets: ::core::option::Option<AssetsFilter>,
    #[prost(string, optional, tag = "9")]
    pub template: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "10")]
    pub workbook: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "11")]
    pub data_review: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "12")]
    pub data_reviews: ::core::option::Option<DataReviewsFilter>,
    #[prost(enumeration = "SearchEventOriginType", optional, tag = "13")]
    pub origin_type: ::core::option::Option<i32>,
    #[prost(message, optional, tag = "14")]
    pub origin_types: ::core::option::Option<OriginTypesFilter>,
    #[prost(string, optional, tag = "15")]
    pub data_review_check: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "16")]
    pub data_review_checks: ::core::option::Option<DataReviewChecksFilter>,
    #[prost(enumeration = "EventDispositionStatus", optional, tag = "17")]
    pub disposition_status: ::core::option::Option<i32>,
    #[prost(message, optional, tag = "18")]
    pub disposition_statuses: ::core::option::Option<EventDispositionStatusListWrapper>,
    #[prost(enumeration = "super::super::types::Priority", optional, tag = "19")]
    pub priority: ::core::option::Option<i32>,
    #[prost(message, optional, tag = "20")]
    pub priorities: ::core::option::Option<PriorityListWrapper>,
    #[prost(string, optional, tag = "21")]
    pub assignee: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "22")]
    pub assignees: ::core::option::Option<AssigneesFilter>,
    #[prost(enumeration = "EventType", optional, tag = "23")]
    pub event_type: ::core::option::Option<i32>,
    #[prost(message, optional, tag = "24")]
    pub event_types: ::core::option::Option<EventTypeListWrapper>,
    #[prost(string, optional, tag = "25")]
    pub created_by: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "26")]
    pub created_by_any_of: ::core::option::Option<UserRidListWrapper>,
    #[prost(string, optional, tag = "27")]
    pub label: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "28")]
    pub labels: ::core::option::Option<super::super::types::LabelsFilter>,
    #[prost(message, optional, tag = "29")]
    pub property: ::core::option::Option<super::super::types::Property>,
    #[prost(message, optional, tag = "30")]
    pub properties: ::core::option::Option<super::super::types::PropertiesFilter>,
    #[prost(message, optional, tag = "31")]
    pub and: ::core::option::Option<SearchQueryListWrapper>,
    #[prost(message, optional, tag = "32")]
    pub or: ::core::option::Option<SearchQueryListWrapper>,
    #[prost(message, optional, boxed, tag = "33")]
    pub not: ::core::option::Option<::prost::alloc::boxed::Box<SearchQuery>>,
    #[prost(string, optional, tag = "34")]
    pub workspace: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "35")]
    pub procedure: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "36")]
    pub procedure_execution: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "37")]
    pub step_id: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "38")]
    pub streaming_checklist: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "39")]
    pub streaming_check: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SearchQueryListWrapper {
    #[prost(message, repeated, tag = "1")]
    pub queries: ::prost::alloc::vec::Vec<SearchQuery>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct EventDispositionStatusListWrapper {
    #[prost(enumeration = "EventDispositionStatus", repeated, tag = "1")]
    pub values: ::prost::alloc::vec::Vec<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PriorityListWrapper {
    #[prost(enumeration = "super::super::types::Priority", repeated, tag = "1")]
    pub values: ::prost::alloc::vec::Vec<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct EventTypeListWrapper {
    #[prost(enumeration = "EventType", repeated, tag = "1")]
    pub values: ::prost::alloc::vec::Vec<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UserRidListWrapper {
    #[prost(string, repeated, tag = "1")]
    pub values: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct SortOptions {
    #[prost(bool, tag = "1")]
    pub is_descending: bool,
    #[prost(enumeration = "SortField", tag = "2")]
    pub field: i32,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct StreamingCheckOriginMetadata {
    #[prost(string, tag = "1")]
    pub check_rid: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub check_lineage_rid: ::prost::alloc::string::String,
    #[prost(int32, optional, tag = "3")]
    pub implementation_index: ::core::option::Option<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct StreamingChecklistEventOrigin {
    #[prost(string, tag = "1")]
    pub checklist_rid: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "2")]
    pub check_metadata: ::core::option::Option<StreamingCheckOriginMetadata>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TemplateEventOrigin {
    #[prost(string, tag = "1")]
    pub rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TimeSeriesChannelAssociation {
    #[prost(string, tag = "1")]
    pub variable_name: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "2")]
    pub tags: ::core::option::Option<TimeSeriesChannelTagsWrapper>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TimeSeriesChannelTagsWrapper {
    #[prost(map = "string, string", tag = "1")]
    pub tags: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateDispositionRequest {
    #[prost(string, tag = "1")]
    pub rid: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "2")]
    pub disposition: ::core::option::Option<EventDisposition>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateEventLegacyRequest {
    #[prost(string, tag = "1")]
    pub uuid: ::prost::alloc::string::String,
    #[prost(string, optional, tag = "2")]
    pub rid: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub asset_rids: ::core::option::Option<AssetRidSetWrapper>,
    #[prost(message, optional, tag = "4")]
    pub timestamp: ::core::option::Option<super::super::types::time::Timestamp>,
    #[prost(message, optional, tag = "5")]
    pub duration: ::core::option::Option<super::super::types::Duration>,
    #[prost(string, optional, tag = "6")]
    pub name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "7")]
    pub description: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(enumeration = "EventType", optional, tag = "8")]
    pub r#type: ::core::option::Option<i32>,
    #[prost(message, optional, tag = "9")]
    pub labels: ::core::option::Option<super::super::types::LabelUpdateWrapper>,
    #[prost(message, optional, tag = "10")]
    pub properties: ::core::option::Option<super::super::types::PropertyUpdateWrapper>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateEventRequest {
    #[prost(string, tag = "1")]
    pub rid: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "2")]
    pub asset_rids: ::core::option::Option<AssetRidSetWrapper>,
    #[prost(message, optional, tag = "3")]
    pub timestamp: ::core::option::Option<super::super::types::time::Timestamp>,
    #[prost(message, optional, tag = "4")]
    pub duration: ::core::option::Option<super::super::types::Duration>,
    #[prost(string, optional, tag = "5")]
    pub name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "6")]
    pub description: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(enumeration = "EventType", optional, tag = "7")]
    pub r#type: ::core::option::Option<i32>,
    #[prost(message, optional, tag = "8")]
    pub labels: ::core::option::Option<super::super::types::LabelUpdateWrapper>,
    #[prost(message, optional, tag = "9")]
    pub properties: ::core::option::Option<super::super::types::PropertyUpdateWrapper>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct WorkbookDataAssociation {
    #[prost(oneof = "workbook_data_association::WorkbookDataAssociation", tags = "1")]
    pub workbook_data_association: ::core::option::Option<
        workbook_data_association::WorkbookDataAssociation,
    >,
}
/// Nested message and enum types in `WorkbookDataAssociation`.
pub mod workbook_data_association {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum WorkbookDataAssociation {
        #[prost(message, tag = "1")]
        TimeSeriesChannel(super::TimeSeriesChannelAssociation),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct WorkbookDataAssociationListWrapper {
    #[prost(message, repeated, tag = "1")]
    pub data: ::prost::alloc::vec::Vec<WorkbookDataAssociation>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct WorkbookEventOrigin {
    #[prost(string, tag = "1")]
    pub rid: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "2")]
    pub data: ::core::option::Option<WorkbookDataAssociationListWrapper>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct WorkspaceRidSetWrapper {
    #[prost(string, repeated, tag = "1")]
    pub workspaces: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateEventResponse {
    #[prost(message, optional, tag = "1")]
    pub event: ::core::option::Option<Event>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetEventsResponse {
    #[prost(message, repeated, tag = "1")]
    pub events: ::prost::alloc::vec::Vec<Event>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchGetEventsRequest {
    #[prost(string, repeated, tag = "1")]
    pub request: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchGetEventsResponse {
    #[prost(message, repeated, tag = "1")]
    pub events: ::prost::alloc::vec::Vec<Event>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchFilterEventsResponse {
    #[prost(message, repeated, tag = "1")]
    pub events: ::prost::alloc::vec::Vec<Event>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateEventResponse {
    #[prost(message, optional, tag = "1")]
    pub event: ::core::option::Option<Event>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct ArchiveEventResponse {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchArchiveEventRequest {
    #[prost(string, repeated, tag = "1")]
    pub request: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct BatchArchiveEventResponse {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchUnarchiveEventRequest {
    #[prost(string, repeated, tag = "1")]
    pub request: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct BatchUnarchiveEventResponse {}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EventError {
    InvalidEventRequest = 0,
}
impl EventError {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::InvalidEventRequest => "EVENT_ERROR_INVALID_EVENT_REQUEST",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "EVENT_ERROR_INVALID_EVENT_REQUEST" => Some(Self::InvalidEventRequest),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum AggregateType {
    Unspecified = 0,
    TotalDuration = 1,
    TotalCount = 2,
}
impl AggregateType {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::Unspecified => "AGGREGATE_TYPE_UNSPECIFIED",
            Self::TotalDuration => "TOTAL_DURATION",
            Self::TotalCount => "TOTAL_COUNT",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "AGGREGATE_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
            "TOTAL_DURATION" => Some(Self::TotalDuration),
            "TOTAL_COUNT" => Some(Self::TotalCount),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EventDispositionStatus {
    Unspecified = 0,
    PendingReview = 1,
    ClosedIgnored = 2,
    ClosedRequiresFurtherAction = 3,
    NoDisposition = 4,
}
impl EventDispositionStatus {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::Unspecified => "EVENT_DISPOSITION_STATUS_UNSPECIFIED",
            Self::PendingReview => "PENDING_REVIEW",
            Self::ClosedIgnored => "CLOSED_IGNORED",
            Self::ClosedRequiresFurtherAction => "CLOSED_REQUIRES_FURTHER_ACTION",
            Self::NoDisposition => "NO_DISPOSITION",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "EVENT_DISPOSITION_STATUS_UNSPECIFIED" => Some(Self::Unspecified),
            "PENDING_REVIEW" => Some(Self::PendingReview),
            "CLOSED_IGNORED" => Some(Self::ClosedIgnored),
            "CLOSED_REQUIRES_FURTHER_ACTION" => Some(Self::ClosedRequiresFurtherAction),
            "NO_DISPOSITION" => Some(Self::NoDisposition),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EventTimeFilterCondition {
    Unspecified = 0,
    StartTimeBeforeInclusive = 1,
    StartTimeBeforeExclusive = 2,
    StartTimeAfterInclusive = 3,
    StartTimeAfterExclusive = 4,
    EndTimeBeforeInclusive = 5,
    EndTimeBeforeExclusive = 6,
    EndTimeAfterInclusive = 7,
    EndTimeAfterExclusive = 8,
}
impl EventTimeFilterCondition {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::Unspecified => "EVENT_TIME_FILTER_CONDITION_UNSPECIFIED",
            Self::StartTimeBeforeInclusive => "START_TIME_BEFORE_INCLUSIVE",
            Self::StartTimeBeforeExclusive => "START_TIME_BEFORE_EXCLUSIVE",
            Self::StartTimeAfterInclusive => "START_TIME_AFTER_INCLUSIVE",
            Self::StartTimeAfterExclusive => "START_TIME_AFTER_EXCLUSIVE",
            Self::EndTimeBeforeInclusive => "END_TIME_BEFORE_INCLUSIVE",
            Self::EndTimeBeforeExclusive => "END_TIME_BEFORE_EXCLUSIVE",
            Self::EndTimeAfterInclusive => "END_TIME_AFTER_INCLUSIVE",
            Self::EndTimeAfterExclusive => "END_TIME_AFTER_EXCLUSIVE",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "EVENT_TIME_FILTER_CONDITION_UNSPECIFIED" => Some(Self::Unspecified),
            "START_TIME_BEFORE_INCLUSIVE" => Some(Self::StartTimeBeforeInclusive),
            "START_TIME_BEFORE_EXCLUSIVE" => Some(Self::StartTimeBeforeExclusive),
            "START_TIME_AFTER_INCLUSIVE" => Some(Self::StartTimeAfterInclusive),
            "START_TIME_AFTER_EXCLUSIVE" => Some(Self::StartTimeAfterExclusive),
            "END_TIME_BEFORE_INCLUSIVE" => Some(Self::EndTimeBeforeInclusive),
            "END_TIME_BEFORE_EXCLUSIVE" => Some(Self::EndTimeBeforeExclusive),
            "END_TIME_AFTER_INCLUSIVE" => Some(Self::EndTimeAfterInclusive),
            "END_TIME_AFTER_EXCLUSIVE" => Some(Self::EndTimeAfterExclusive),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EventType {
    Unspecified = 0,
    Info = 1,
    Flag = 2,
    Error = 3,
    Success = 4,
}
impl EventType {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::Unspecified => "EVENT_TYPE_UNSPECIFIED",
            Self::Info => "INFO",
            Self::Flag => "FLAG",
            Self::Error => "ERROR",
            Self::Success => "SUCCESS",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "EVENT_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
            "INFO" => Some(Self::Info),
            "FLAG" => Some(Self::Flag),
            "ERROR" => Some(Self::Error),
            "SUCCESS" => Some(Self::Success),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SearchEventOriginType {
    Unspecified = 0,
    Workbook = 1,
    Template = 2,
    Api = 3,
    DataReview = 4,
    Procedure = 5,
    StreamingChecklist = 6,
}
impl SearchEventOriginType {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::Unspecified => "SEARCH_EVENT_ORIGIN_TYPE_UNSPECIFIED",
            Self::Workbook => "WORKBOOK",
            Self::Template => "TEMPLATE",
            Self::Api => "API",
            Self::DataReview => "DATA_REVIEW",
            Self::Procedure => "PROCEDURE",
            Self::StreamingChecklist => "STREAMING_CHECKLIST",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "SEARCH_EVENT_ORIGIN_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
            "WORKBOOK" => Some(Self::Workbook),
            "TEMPLATE" => Some(Self::Template),
            "API" => Some(Self::Api),
            "DATA_REVIEW" => Some(Self::DataReview),
            "PROCEDURE" => Some(Self::Procedure),
            "STREAMING_CHECKLIST" => Some(Self::StreamingChecklist),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SortField {
    Unspecified = 0,
    StartTime = 1,
    EndTime = 2,
    Duration = 3,
    DispositionStatus = 4,
    Priority = 5,
    EventName = 6,
}
impl SortField {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::Unspecified => "SORT_FIELD_UNSPECIFIED",
            Self::StartTime => "START_TIME",
            Self::EndTime => "END_TIME",
            Self::Duration => "DURATION",
            Self::DispositionStatus => "DISPOSITION_STATUS",
            Self::Priority => "PRIORITY",
            Self::EventName => "EVENT_NAME",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "SORT_FIELD_UNSPECIFIED" => Some(Self::Unspecified),
            "START_TIME" => Some(Self::StartTime),
            "END_TIME" => Some(Self::EndTime),
            "DURATION" => Some(Self::Duration),
            "DISPOSITION_STATUS" => Some(Self::DispositionStatus),
            "PRIORITY" => Some(Self::Priority),
            "EVENT_NAME" => Some(Self::EventName),
            _ => None,
        }
    }
}
/// Generated client implementations.
pub mod event_service_client {
    #![allow(
        unused_variables,
        dead_code,
        missing_docs,
        clippy::wildcard_imports,
        clippy::let_unit_value,
    )]
    use tonic::codegen::*;
    use tonic::codegen::http::Uri;
    #[derive(Debug, Clone)]
    pub struct EventServiceClient<T> {
        inner: tonic::client::Grpc<T>,
    }
    impl EventServiceClient<tonic::transport::Channel> {
        /// Attempt to create a new client by connecting to a given endpoint.
        pub async fn connect<D>(dst: D) -> Result<Self, tonic::transport::Error>
        where
            D: TryInto<tonic::transport::Endpoint>,
            D::Error: Into<StdError>,
        {
            let conn = tonic::transport::Endpoint::new(dst)?.connect().await?;
            Ok(Self::new(conn))
        }
    }
    impl<T> EventServiceClient<T>
    where
        T: tonic::client::GrpcService<tonic::body::Body>,
        T::Error: Into<StdError>,
        T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
        <T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
    {
        pub fn new(inner: T) -> Self {
            let inner = tonic::client::Grpc::new(inner);
            Self { inner }
        }
        pub fn with_origin(inner: T, origin: Uri) -> Self {
            let inner = tonic::client::Grpc::with_origin(inner, origin);
            Self { inner }
        }
        pub fn with_interceptor<F>(
            inner: T,
            interceptor: F,
        ) -> EventServiceClient<InterceptedService<T, F>>
        where
            F: tonic::service::Interceptor,
            T::ResponseBody: Default,
            T: tonic::codegen::Service<
                http::Request<tonic::body::Body>,
                Response = http::Response<
                    <T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
                >,
            >,
            <T as tonic::codegen::Service<
                http::Request<tonic::body::Body>,
            >>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
        {
            EventServiceClient::new(InterceptedService::new(inner, interceptor))
        }
        /// Compress requests with the given encoding.
        ///
        /// This requires the server to support it otherwise it might respond with an
        /// error.
        #[must_use]
        pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
            self.inner = self.inner.send_compressed(encoding);
            self
        }
        /// Enable decompressing responses.
        #[must_use]
        pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
            self.inner = self.inner.accept_compressed(encoding);
            self
        }
        /// Limits the maximum size of a decoded message.
        ///
        /// Default: `4MB`
        #[must_use]
        pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
            self.inner = self.inner.max_decoding_message_size(limit);
            self
        }
        /// Limits the maximum size of an encoded message.
        ///
        /// Default: `usize::MAX`
        #[must_use]
        pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
            self.inner = self.inner.max_encoding_message_size(limit);
            self
        }
        pub async fn create_event(
            &mut self,
            request: impl tonic::IntoRequest<super::CreateEventRequest>,
        ) -> std::result::Result<
            tonic::Response<super::CreateEventResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.event.v1.EventService/CreateEvent",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("nominal.event.v1.EventService", "CreateEvent"));
            self.inner.unary(req, path, codec).await
        }
        pub async fn get_events(
            &mut self,
            request: impl tonic::IntoRequest<super::GetEventsRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetEventsResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.event.v1.EventService/GetEvents",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("nominal.event.v1.EventService", "GetEvents"));
            self.inner.unary(req, path, codec).await
        }
        pub async fn batch_get_events(
            &mut self,
            request: impl tonic::IntoRequest<super::BatchGetEventsRequest>,
        ) -> std::result::Result<
            tonic::Response<super::BatchGetEventsResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.event.v1.EventService/BatchGetEvents",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("nominal.event.v1.EventService", "BatchGetEvents"),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn batch_filter_events(
            &mut self,
            request: impl tonic::IntoRequest<super::BatchFilterEventsRequest>,
        ) -> std::result::Result<
            tonic::Response<super::BatchFilterEventsResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.event.v1.EventService/BatchFilterEvents",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("nominal.event.v1.EventService", "BatchFilterEvents"),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn update_event(
            &mut self,
            request: impl tonic::IntoRequest<super::UpdateEventLegacyRequest>,
        ) -> std::result::Result<
            tonic::Response<super::UpdateEventResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.event.v1.EventService/UpdateEvent",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("nominal.event.v1.EventService", "UpdateEvent"));
            self.inner.unary(req, path, codec).await
        }
        pub async fn batch_update_event(
            &mut self,
            request: impl tonic::IntoRequest<super::BatchUpdateEventRequest>,
        ) -> std::result::Result<
            tonic::Response<super::BatchUpdateEventResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.event.v1.EventService/BatchUpdateEvent",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("nominal.event.v1.EventService", "BatchUpdateEvent"),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn batch_update_disposition(
            &mut self,
            request: impl tonic::IntoRequest<super::BatchUpdateDispositionRequest>,
        ) -> std::result::Result<
            tonic::Response<super::BatchUpdateDispositionResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.event.v1.EventService/BatchUpdateDisposition",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.event.v1.EventService",
                        "BatchUpdateDisposition",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn archive_event(
            &mut self,
            request: impl tonic::IntoRequest<super::ArchiveEventRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ArchiveEventResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.event.v1.EventService/ArchiveEvent",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("nominal.event.v1.EventService", "ArchiveEvent"),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn batch_archive_event(
            &mut self,
            request: impl tonic::IntoRequest<super::BatchArchiveEventRequest>,
        ) -> std::result::Result<
            tonic::Response<super::BatchArchiveEventResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.event.v1.EventService/BatchArchiveEvent",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("nominal.event.v1.EventService", "BatchArchiveEvent"),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn batch_unarchive_event(
            &mut self,
            request: impl tonic::IntoRequest<super::BatchUnarchiveEventRequest>,
        ) -> std::result::Result<
            tonic::Response<super::BatchUnarchiveEventResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.event.v1.EventService/BatchUnarchiveEvent",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.event.v1.EventService",
                        "BatchUnarchiveEvent",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn search_events(
            &mut self,
            request: impl tonic::IntoRequest<super::SearchEventsRequest>,
        ) -> std::result::Result<
            tonic::Response<super::SearchEventsResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.event.v1.EventService/SearchEvents",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("nominal.event.v1.EventService", "SearchEvents"),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn aggregate_events(
            &mut self,
            request: impl tonic::IntoRequest<super::AggregateEventsRequest>,
        ) -> std::result::Result<
            tonic::Response<super::AggregateEventsResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.event.v1.EventService/AggregateEvents",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("nominal.event.v1.EventService", "AggregateEvents"),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn batch_aggregate_events(
            &mut self,
            request: impl tonic::IntoRequest<super::BatchAggregateEventsRequest>,
        ) -> std::result::Result<
            tonic::Response<super::BatchAggregateEventsResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.event.v1.EventService/BatchAggregateEvents",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.event.v1.EventService",
                        "BatchAggregateEvents",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn get_events_histogram(
            &mut self,
            request: impl tonic::IntoRequest<super::EventsHistogramRequest>,
        ) -> std::result::Result<
            tonic::Response<super::EventsHistogramResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.event.v1.EventService/GetEventsHistogram",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.event.v1.EventService",
                        "GetEventsHistogram",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn list_properties_and_labels(
            &mut self,
            request: impl tonic::IntoRequest<super::ListPropertiesAndLabelsRequest>,
        ) -> std::result::Result<
            tonic::Response<
                super::super::super::metadata::v1::ListPropertiesAndLabelsResponse,
            >,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/nominal.event.v1.EventService/ListPropertiesAndLabels",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.event.v1.EventService",
                        "ListPropertiesAndLabels",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
    }
}