nominal-api-proto 0.1356.0

// This file is @generated by prost-build.
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct Duration {
    #[prost(int64, tag = "1")]
    pub seconds: i64,
    #[prost(int64, tag = "2")]
    pub nanos: i64,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PendingReviewDispositionState {
    #[prost(string, tag = "1")]
    pub opened_by: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ClosedWithFurtherActionDispositionState {
    #[prost(string, tag = "1")]
    pub closed_by: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ClosedWithIgnoreDispositionState {
    #[prost(string, tag = "1")]
    pub closed_by: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DispositionState {
    #[prost(oneof = "disposition_state::DispositionState", tags = "1, 2, 3")]
    pub disposition_state: ::core::option::Option<disposition_state::DispositionState>,
}
/// Nested message and enum types in `DispositionState`.
pub mod disposition_state {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum DispositionState {
        #[prost(message, tag = "1")]
        PendingReview(super::PendingReviewDispositionState),
        #[prost(message, tag = "2")]
        ClosedWithFurtherAction(super::ClosedWithFurtherActionDispositionState),
        #[prost(message, tag = "3")]
        ClosedWithIgnore(super::ClosedWithIgnoreDispositionState),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PropertiesFilter {
    #[prost(string, tag = "1")]
    pub name: ::prost::alloc::string::String,
    #[prost(string, repeated, tag = "2")]
    pub values: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct LabelsFilter {
    #[prost(enumeration = "SetOperator", tag = "1")]
    pub operator: i32,
    #[prost(string, repeated, tag = "2")]
    pub labels: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct EventDisposition {
    #[prost(enumeration = "Priority", tag = "1")]
    pub priority: i32,
    #[prost(message, optional, tag = "2")]
    pub state: ::core::option::Option<DispositionState>,
    #[prost(string, repeated, tag = "3")]
    pub assignees: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct ApiEventOrigin {}
#[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 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 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 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 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 TimeSeriesChannelAssociation {
    #[prost(string, tag = "1")]
    pub variable_name: ::prost::alloc::string::String,
    #[prost(map = "string, string", tag = "2")]
    pub tags: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
}
#[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 WorkbookEventOrigin {
    #[prost(string, tag = "1")]
    pub rid: ::prost::alloc::string::String,
    #[prost(message, repeated, tag = "2")]
    pub data: ::prost::alloc::vec::Vec<WorkbookDataAssociation>,
}
#[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, 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<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 AssetsFilter {
    #[prost(enumeration = "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 = "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 OriginTypesFilter {
    #[prost(enumeration = "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 DataReviewsFilter {
    #[prost(string, repeated, tag = "1")]
    pub data_reviews: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[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, 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, PartialEq, ::prost::Message)]
pub struct SearchQueryList {
    #[prost(message, repeated, tag = "1")]
    pub queries: ::prost::alloc::vec::Vec<SearchQuery>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct HistogramFilterQueryList {
    #[prost(message, repeated, tag = "1")]
    pub queries: ::prost::alloc::vec::Vec<HistogramFilterQuery>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct EventDispositionStatusList {
    #[prost(enumeration = "EventDispositionStatus", repeated, tag = "1")]
    pub values: ::prost::alloc::vec::Vec<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PriorityList {
    #[prost(enumeration = "Priority", repeated, tag = "1")]
    pub values: ::prost::alloc::vec::Vec<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct EventTypeList {
    #[prost(enumeration = "EventType", repeated, tag = "1")]
    pub values: ::prost::alloc::vec::Vec<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UserRidList {
    #[prost(string, repeated, tag = "1")]
    pub values: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SearchQuery {
    #[prost(
        oneof = "search_query::SearchQuery",
        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"
    )]
    pub search_query: ::core::option::Option<search_query::SearchQuery>,
}
/// Nested message and enum types in `SearchQuery`.
pub mod search_query {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum SearchQuery {
        #[prost(bool, tag = "1")]
        Archived(bool),
        #[prost(string, tag = "2")]
        SearchText(::prost::alloc::string::String),
        #[prost(string, tag = "3")]
        ExactMatch(::prost::alloc::string::String),
        #[prost(message, tag = "4")]
        After(super::super::super::types::time::Timestamp),
        #[prost(message, tag = "5")]
        Before(super::super::super::types::time::Timestamp),
        #[prost(message, tag = "6")]
        AdvancedTimeFilter(super::EventTimeFilter),
        #[prost(string, tag = "7")]
        Asset(::prost::alloc::string::String),
        #[prost(message, tag = "8")]
        Assets(super::AssetsFilter),
        #[prost(string, tag = "9")]
        Template(::prost::alloc::string::String),
        #[prost(string, tag = "10")]
        Workbook(::prost::alloc::string::String),
        #[prost(string, tag = "11")]
        DataReview(::prost::alloc::string::String),
        #[prost(message, tag = "12")]
        DataReviews(super::DataReviewsFilter),
        #[prost(enumeration = "super::SearchEventOriginType", tag = "13")]
        OriginType(i32),
        #[prost(message, tag = "14")]
        OriginTypes(super::OriginTypesFilter),
        #[prost(string, tag = "15")]
        DataReviewCheck(::prost::alloc::string::String),
        #[prost(message, tag = "16")]
        DataReviewChecks(super::DataReviewChecksFilter),
        #[prost(enumeration = "super::EventDispositionStatus", tag = "17")]
        DispositionStatus(i32),
        #[prost(message, tag = "18")]
        DispositionStatuses(super::EventDispositionStatusList),
        #[prost(enumeration = "super::Priority", tag = "19")]
        Priority(i32),
        #[prost(message, tag = "20")]
        Priorities(super::PriorityList),
        #[prost(string, tag = "21")]
        Assignee(::prost::alloc::string::String),
        #[prost(message, tag = "22")]
        Assignees(super::AssigneesFilter),
        #[prost(enumeration = "super::EventType", tag = "23")]
        EventType(i32),
        #[prost(message, tag = "24")]
        EventTypes(super::EventTypeList),
        #[prost(string, tag = "25")]
        CreatedBy(::prost::alloc::string::String),
        #[prost(message, tag = "26")]
        CreatedByAnyOf(super::UserRidList),
        #[prost(string, tag = "27")]
        Label(::prost::alloc::string::String),
        #[prost(message, tag = "28")]
        Labels(super::LabelsFilter),
        #[prost(message, tag = "29")]
        Property(super::super::super::types::Property),
        #[prost(message, tag = "30")]
        Properties(super::PropertiesFilter),
        #[prost(message, tag = "31")]
        And(super::SearchQueryList),
        #[prost(message, tag = "32")]
        Or(super::SearchQueryList),
        #[prost(message, tag = "33")]
        Not(::prost::alloc::boxed::Box<super::SearchQuery>),
        #[prost(string, tag = "34")]
        Workspace(::prost::alloc::string::String),
        #[prost(string, tag = "35")]
        Procedure(::prost::alloc::string::String),
        #[prost(string, tag = "36")]
        ProcedureExecution(::prost::alloc::string::String),
        #[prost(string, tag = "37")]
        StepId(::prost::alloc::string::String),
        #[prost(string, tag = "38")]
        StreamingChecklist(::prost::alloc::string::String),
        #[prost(string, tag = "39")]
        StreamingCheck(::prost::alloc::string::String),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct HistogramFilterQuery {
    #[prost(
        oneof = "histogram_filter_query::HistogramFilterQuery",
        tags = "1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21"
    )]
    pub histogram_filter_query: ::core::option::Option<
        histogram_filter_query::HistogramFilterQuery,
    >,
}
/// Nested message and enum types in `HistogramFilterQuery`.
pub mod histogram_filter_query {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum HistogramFilterQuery {
        #[prost(string, tag = "1")]
        SearchText(::prost::alloc::string::String),
        #[prost(string, tag = "2")]
        Asset(::prost::alloc::string::String),
        #[prost(string, tag = "3")]
        Template(::prost::alloc::string::String),
        #[prost(string, tag = "4")]
        Workbook(::prost::alloc::string::String),
        #[prost(string, tag = "5")]
        DataReview(::prost::alloc::string::String),
        #[prost(enumeration = "super::SearchEventOriginType", tag = "6")]
        OriginType(i32),
        #[prost(string, tag = "7")]
        DataReviewCheck(::prost::alloc::string::String),
        #[prost(enumeration = "super::EventDispositionStatus", tag = "8")]
        DispositionStatus(i32),
        #[prost(enumeration = "super::Priority", tag = "9")]
        Priority(i32),
        #[prost(string, tag = "10")]
        Assignee(::prost::alloc::string::String),
        #[prost(enumeration = "super::EventType", tag = "11")]
        EventType(i32),
        #[prost(string, tag = "12")]
        CreatedBy(::prost::alloc::string::String),
        #[prost(string, tag = "13")]
        Label(::prost::alloc::string::String),
        #[prost(message, tag = "14")]
        Property(super::super::super::types::Property),
        #[prost(message, tag = "15")]
        And(super::HistogramFilterQueryList),
        #[prost(message, tag = "16")]
        Or(super::HistogramFilterQueryList),
        #[prost(message, tag = "17")]
        Not(::prost::alloc::boxed::Box<super::HistogramFilterQuery>),
        #[prost(string, tag = "18")]
        Workspace(::prost::alloc::string::String),
        #[prost(string, tag = "19")]
        Procedure(::prost::alloc::string::String),
        #[prost(string, tag = "20")]
        ProcedureExecution(::prost::alloc::string::String),
        #[prost(string, tag = "21")]
        StepId(::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, 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::Duration),
        #[prost(int32, tag = "2")]
        Count(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 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<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 CreateEventResponse {
    #[prost(message, optional, tag = "1")]
    pub event: ::core::option::Option<Event>,
}
#[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 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 event_rids: ::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 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 BatchFilterEventsResponse {
    #[prost(message, repeated, tag = "1")]
    pub events: ::prost::alloc::vec::Vec<Event>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AssetRidSet {
    #[prost(string, repeated, tag = "1")]
    pub asset_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateEventRequest {
    #[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<AssetRidSet>,
    #[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<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 UpdateEventResponse {
    #[prost(message, optional, tag = "1")]
    pub event: ::core::option::Option<Event>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct EventUpdate {
    #[prost(string, tag = "1")]
    pub rid: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "2")]
    pub asset_rids: ::core::option::Option<AssetRidSet>,
    #[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<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 BatchUpdateEventRequest {
    #[prost(message, repeated, tag = "1")]
    pub updates: ::prost::alloc::vec::Vec<EventUpdate>,
}
#[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 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 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 ArchiveEventRequest {
    #[prost(string, tag = "1")]
    pub uuid: ::prost::alloc::string::String,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct ArchiveEventResponse {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchArchiveEventRequest {
    #[prost(string, repeated, tag = "1")]
    pub event_rids: ::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 event_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct BatchUnarchiveEventResponse {}
#[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(enumeration = "super::super::types::ArchivedStatus", repeated, tag = "5")]
    pub archived_statuses: ::prost::alloc::vec::Vec<i32>,
}
#[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 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, 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 GetEventsHistogramRequest {
    #[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(enumeration = "super::super::types::ArchivedStatus", repeated, tag = "4")]
    pub archived_statuses: ::prost::alloc::vec::Vec<i32>,
    #[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 GetEventsHistogramResponse {
    #[prost(message, repeated, tag = "1")]
    pub buckets: ::prost::alloc::vec::Vec<EventsHistogramBucket>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListPropertiesAndLabelsRequest {
    #[prost(string, repeated, tag = "1")]
    pub workspace_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[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 Priority {
    Unspecified = 0,
    P0 = 1,
    P1 = 2,
    P2 = 3,
    P3 = 4,
    P4 = 5,
}
impl Priority {
    /// 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 => "PRIORITY_UNSPECIFIED",
            Self::P0 => "P0",
            Self::P1 => "P1",
            Self::P2 => "P2",
            Self::P3 => "P3",
            Self::P4 => "P4",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "PRIORITY_UNSPECIFIED" => Some(Self::Unspecified),
            "P0" => Some(Self::P0),
            "P1" => Some(Self::P1),
            "P2" => Some(Self::P2),
            "P3" => Some(Self::P3),
            "P4" => Some(Self::P4),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SetOperator {
    Unspecified = 0,
    And = 1,
    Or = 2,
}
impl SetOperator {
    /// 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 => "SET_OPERATOR_UNSPECIFIED",
            Self::And => "AND",
            Self::Or => "OR",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "SET_OPERATOR_UNSPECIFIED" => Some(Self::Unspecified),
            "AND" => Some(Self::And),
            "OR" => Some(Self::Or),
            _ => 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 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 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 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 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.v2.EventService/CreateEvent",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("nominal.event.v2.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.v2.EventService/GetEvents",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("nominal.event.v2.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.v2.EventService/BatchGetEvents",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("nominal.event.v2.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.v2.EventService/BatchFilterEvents",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("nominal.event.v2.EventService", "BatchFilterEvents"),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn update_event(
            &mut self,
            request: impl tonic::IntoRequest<super::UpdateEventRequest>,
        ) -> 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.v2.EventService/UpdateEvent",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("nominal.event.v2.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.v2.EventService/BatchUpdateEvent",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("nominal.event.v2.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.v2.EventService/BatchUpdateDisposition",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.event.v2.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.v2.EventService/ArchiveEvent",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("nominal.event.v2.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.v2.EventService/BatchArchiveEvent",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("nominal.event.v2.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.v2.EventService/BatchUnarchiveEvent",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.event.v2.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.v2.EventService/SearchEvents",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("nominal.event.v2.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.v2.EventService/AggregateEvents",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("nominal.event.v2.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.v2.EventService/BatchAggregateEvents",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.event.v2.EventService",
                        "BatchAggregateEvents",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn get_events_histogram(
            &mut self,
            request: impl tonic::IntoRequest<super::GetEventsHistogramRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetEventsHistogramResponse>,
            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.v2.EventService/GetEventsHistogram",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.event.v2.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::v2::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.v2.EventService/ListPropertiesAndLabels",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.event.v2.EventService",
                        "ListPropertiesAndLabels",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
    }
}