#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Unit {
#[prost(string, optional, tag = "1")]
pub name: ::core::option::Option<::prost::alloc::string::String>,
#[prost(string, tag = "2")]
pub symbol: ::prost::alloc::string::String,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct UtcTimestamp {
#[prost(int64, tag = "1")]
pub seconds_since_epoch: i64,
#[prost(int64, optional, tag = "2")]
pub offset_nanoseconds: ::core::option::Option<i64>,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum WeakTimestampType {
Unspecified = 0,
Absolute = 1,
Relative = 2,
Pending = 3,
}
impl WeakTimestampType {
pub fn as_str_name(&self) -> &'static str {
match self {
Self::Unspecified => "WEAK_TIMESTAMP_TYPE_UNSPECIFIED",
Self::Absolute => "ABSOLUTE",
Self::Relative => "RELATIVE",
Self::Pending => "PENDING",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"WEAK_TIMESTAMP_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
"ABSOLUTE" => Some(Self::Absolute),
"RELATIVE" => Some(Self::Relative),
"PENDING" => Some(Self::Pending),
_ => None,
}
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DataSource {
#[prost(oneof = "data_source::DataSource", tags = "1, 2, 3, 4, 5")]
pub data_source: ::core::option::Option<data_source::DataSource>,
}
pub mod data_source {
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum DataSource {
#[prost(string, tag = "1")]
Dataset(::prost::alloc::string::String),
#[prost(string, tag = "2")]
Connection(::prost::alloc::string::String),
#[prost(string, tag = "3")]
LogSet(::prost::alloc::string::String),
#[prost(string, tag = "4")]
Video(::prost::alloc::string::String),
#[prost(string, tag = "5")]
Spatial(::prost::alloc::string::String),
}
}
#[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 Link {
#[prost(string, optional, tag = "1")]
pub title: ::core::option::Option<::prost::alloc::string::String>,
#[prost(string, tag = "2")]
pub url: ::prost::alloc::string::String,
}
#[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 CheckAlertState {
#[prost(oneof = "check_alert_state::CheckAlertState", tags = "1, 2, 3")]
pub check_alert_state: ::core::option::Option<check_alert_state::CheckAlertState>,
}
pub mod check_alert_state {
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum CheckAlertState {
#[prost(message, tag = "1")]
PendingReview(super::PendingReviewAlertState),
#[prost(message, tag = "2")]
ClosedWithFurtherAction(super::ClosedWithFurtherActionAlertState),
#[prost(message, tag = "3")]
ClosedWithIgnore(super::ClosedWithIgnoreAlertState),
}
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct PendingReviewAlertState {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ClosedWithFurtherActionAlertState {
#[prost(string, tag = "1")]
pub comment: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub closed_by: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ClosedWithIgnoreAlertState {
#[prost(string, tag = "1")]
pub comment: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub closed_by: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DataScope {
#[prost(string, tag = "1")]
pub data_scope_name: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub data_source: ::core::option::Option<DataSource>,
#[prost(message, optional, tag = "3")]
pub offset: ::core::option::Option<Duration>,
#[prost(enumeration = "WeakTimestampType", tag = "4")]
pub timestamp_type: i32,
#[prost(map = "string, string", tag = "5")]
pub series_tags: ::std::collections::HashMap<
::prost::alloc::string::String,
::prost::alloc::string::String,
>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MetadataChange {
#[prost(oneof = "metadata_change::MetadataChange", tags = "1, 2, 3")]
pub metadata_change: ::core::option::Option<metadata_change::MetadataChange>,
}
pub mod metadata_change {
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum MetadataChange {
#[prost(message, tag = "1")]
RenameLabel(super::RenameLabel),
#[prost(message, tag = "2")]
RenamePropertyKey(super::RenamePropertyKey),
#[prost(message, tag = "3")]
MergePropertyValuesForKey(super::MergePropertyValuesForKey),
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RenameLabel {
#[prost(string, repeated, tag = "1")]
pub source: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(string, tag = "2")]
pub target: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RenamePropertyKey {
#[prost(string, repeated, tag = "1")]
pub source: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(string, tag = "2")]
pub target: ::prost::alloc::string::String,
#[prost(message, optional, tag = "3")]
pub on_conflict: ::core::option::Option<ConflictBehavior>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MergePropertyValuesForKey {
#[prost(string, tag = "1")]
pub key: ::prost::alloc::string::String,
#[prost(string, repeated, tag = "2")]
pub source: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(string, tag = "3")]
pub target: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConflictBehavior {
#[prost(oneof = "conflict_behavior::ConflictBehavior", tags = "1, 2")]
pub conflict_behavior: ::core::option::Option<conflict_behavior::ConflictBehavior>,
}
pub mod conflict_behavior {
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum ConflictBehavior {
#[prost(message, tag = "1")]
Skip(super::SkipOnConflict),
#[prost(message, tag = "2")]
Overwrite(super::OverwriteOnConflict),
}
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct SkipOnConflict {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct OverwriteOnConflict {
#[prost(string, repeated, tag = "1")]
pub priority: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Run {
#[prost(string, tag = "1")]
pub rid: ::prost::alloc::string::String,
#[prost(int64, tag = "2")]
pub run_number: i64,
#[prost(string, optional, tag = "3")]
pub run_prefix: ::core::option::Option<::prost::alloc::string::String>,
#[prost(string, tag = "4")]
pub title: ::prost::alloc::string::String,
#[prost(string, tag = "5")]
pub description: ::prost::alloc::string::String,
#[prost(string, optional, tag = "6")]
pub author_rid: ::core::option::Option<::prost::alloc::string::String>,
#[prost(message, optional, tag = "7")]
pub start_time: ::core::option::Option<UtcTimestamp>,
#[prost(message, optional, tag = "8")]
pub end_time: ::core::option::Option<UtcTimestamp>,
#[prost(map = "string, string", tag = "9")]
pub properties: ::std::collections::HashMap<
::prost::alloc::string::String,
::prost::alloc::string::String,
>,
#[prost(string, repeated, tag = "10")]
pub labels: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(message, repeated, tag = "11")]
pub links: ::prost::alloc::vec::Vec<Link>,
#[prost(message, optional, tag = "12")]
pub created_at: ::core::option::Option<
super::super::super::google::protobuf::Timestamp,
>,
#[prost(message, optional, tag = "13")]
pub updated_at: ::core::option::Option<
super::super::super::google::protobuf::Timestamp,
>,
#[prost(map = "string, message", tag = "14")]
pub asset_data_scopes_map: ::std::collections::HashMap<
::prost::alloc::string::String,
DataScopes,
>,
#[prost(message, repeated, tag = "15")]
pub asset_data_scopes: ::prost::alloc::vec::Vec<DataScope>,
#[prost(map = "string, message", tag = "16")]
pub data_sources: ::std::collections::HashMap<
::prost::alloc::string::String,
RunDataSource,
>,
#[prost(string, repeated, tag = "17")]
pub attachments: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(string, optional, tag = "18")]
pub asset: ::core::option::Option<::prost::alloc::string::String>,
#[prost(string, repeated, tag = "19")]
pub assets: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(bool, tag = "20")]
pub is_archived: bool,
#[prost(map = "string, message", tag = "21")]
pub typed_properties: ::std::collections::HashMap<
::prost::alloc::string::String,
super::super::types::TypedPropertyValue,
>,
#[prost(enumeration = "LockStatus", tag = "22")]
pub lock_status: i32,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DataScopes {
#[prost(map = "string, message", tag = "1")]
pub data_scopes: ::std::collections::HashMap<
::prost::alloc::string::String,
DataScope,
>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RunDataSource {
#[prost(message, optional, tag = "1")]
pub data_source: ::core::option::Option<DataSource>,
#[prost(message, optional, tag = "2")]
pub offset: ::core::option::Option<Duration>,
#[prost(string, tag = "3")]
pub ref_name: ::prost::alloc::string::String,
#[prost(enumeration = "WeakTimestampType", tag = "4")]
pub timestamp_type: i32,
#[prost(map = "string, string", tag = "5")]
pub series_tags: ::std::collections::HashMap<
::prost::alloc::string::String,
::prost::alloc::string::String,
>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateRunDataSource {
#[prost(message, optional, tag = "1")]
pub data_source: ::core::option::Option<DataSource>,
#[prost(string, optional, tag = "2")]
pub data_source_rid: ::core::option::Option<::prost::alloc::string::String>,
#[prost(message, optional, tag = "3")]
pub offset: ::core::option::Option<Duration>,
#[prost(map = "string, string", tag = "4")]
pub series_tags: ::std::collections::HashMap<
::prost::alloc::string::String,
::prost::alloc::string::String,
>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RefNameAndType {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(enumeration = "DataSourceType", tag = "2")]
pub r#type: i32,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DataSourceSeriesTag {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub value: ::prost::alloc::string::String,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct DataReviewAlertMetrics {
#[prost(int32, tag = "1")]
pub pending_review: i32,
#[prost(int32, tag = "2")]
pub closed_with_ignore: i32,
#[prost(int32, tag = "3")]
pub closed_with_further_action: i32,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct DataReviewCheckMetrics {
#[prost(int32, tag = "1")]
pub pending_execution: i32,
#[prost(int32, tag = "2")]
pub executing: i32,
#[prost(int32, tag = "3")]
pub passing_automatic: i32,
#[prost(int32, tag = "4")]
pub pending_review: i32,
#[prost(int32, tag = "5")]
pub closed_with_ignore: i32,
#[prost(int32, tag = "6")]
pub closed_with_further_action: i32,
#[prost(int32, tag = "7")]
pub failed_to_execute_pending_review: i32,
#[prost(int32, tag = "8")]
pub failed_to_execute_closed_with_ignore: i32,
#[prost(int32, tag = "9")]
pub failed_to_execute_closed_with_further_action: i32,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct DataReviewMetrics {
#[prost(message, optional, tag = "1")]
pub checks: ::core::option::Option<DataReviewCheckMetrics>,
#[prost(message, optional, tag = "2")]
pub alerts: ::core::option::Option<DataReviewAlertMetrics>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct RunDataReviewSummary {
#[prost(enumeration = "RunDataReviewEvaluationStatus", tag = "1")]
pub evaluation_status: i32,
#[prost(int32, tag = "2")]
pub total_issue_count: i32,
#[prost(int32, tag = "3")]
pub reviewed_issue_count: i32,
#[prost(int32, tag = "4")]
pub issues_with_further_action_count: i32,
#[prost(int32, tag = "5")]
pub execution_error_count: i32,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RunWithDataReviewMetrics {
#[prost(message, optional, tag = "1")]
pub run: ::core::option::Option<Run>,
#[prost(message, optional, tag = "2")]
pub data_review_metrics: ::core::option::Option<DataReviewMetrics>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RunWithDataReviewSummary {
#[prost(message, optional, tag = "1")]
pub run: ::core::option::Option<Run>,
#[prost(message, optional, tag = "2")]
pub data_review_summary: ::core::option::Option<RunDataReviewSummary>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AssetsFilter {
#[prost(string, repeated, tag = "1")]
pub assets: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DatasetRidsFilter {
#[prost(string, repeated, tag = "1")]
pub dataset_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CheckAlertStatesFilter {
#[prost(message, optional, tag = "1")]
pub check_alert_state: ::core::option::Option<CheckAlertState>,
#[prost(enumeration = "Operator", tag = "2")]
pub operator: i32,
#[prost(int64, tag = "3")]
pub threshold: i64,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct CustomTimeframeFilter {
#[prost(message, optional, tag = "1")]
pub start_time: ::core::option::Option<UtcTimestamp>,
#[prost(message, optional, tag = "2")]
pub end_time: ::core::option::Option<UtcTimestamp>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct PresetTimeframeFilter {
#[prost(enumeration = "PresetTimeframeDuration", tag = "1")]
pub duration: i32,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct TimeframeFilter {
#[prost(oneof = "timeframe_filter::TimeframeFilter", tags = "1, 2")]
pub timeframe_filter: ::core::option::Option<timeframe_filter::TimeframeFilter>,
}
pub mod timeframe_filter {
#[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
pub enum TimeframeFilter {
#[prost(message, tag = "1")]
Custom(super::CustomTimeframeFilter),
#[prost(message, tag = "2")]
Preset(super::PresetTimeframeFilter),
}
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct TimeRangeFilter {
#[prost(message, optional, tag = "1")]
pub start: ::core::option::Option<UtcTimestamp>,
#[prost(message, optional, tag = "2")]
pub end: ::core::option::Option<UtcTimestamp>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SearchQuery {
#[prost(
oneof = "search_query::Query",
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"
)]
pub query: ::core::option::Option<search_query::Query>,
}
pub mod search_query {
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Query {
#[prost(message, tag = "1")]
StartTimeInclusive(super::UtcTimestamp),
#[prost(message, tag = "2")]
StartTime(super::TimeframeFilter),
#[prost(message, tag = "3")]
EndTimeInclusive(super::UtcTimestamp),
#[prost(message, tag = "4")]
EndTime(super::TimeframeFilter),
#[prost(message, tag = "5")]
TimeRange(super::TimeRangeFilter),
#[prost(message, tag = "6")]
CreatedAt(super::TimeframeFilter),
#[prost(string, tag = "7")]
ExactMatch(::prost::alloc::string::String),
#[prost(string, tag = "8")]
SearchText(::prost::alloc::string::String),
#[prost(string, tag = "9")]
Asset(::prost::alloc::string::String),
#[prost(message, tag = "10")]
Assets(super::AssetsFilter),
#[prost(bool, tag = "11")]
IsSingleAsset(bool),
#[prost(string, tag = "12")]
Label(::prost::alloc::string::String),
#[prost(message, tag = "13")]
Labels(super::LabelsFilter),
#[prost(message, tag = "14")]
Property(super::super::super::types::Property),
#[prost(string, tag = "15")]
PropertyKey(::prost::alloc::string::String),
#[prost(message, tag = "16")]
Properties(super::PropertiesFilter),
#[prost(message, tag = "17")]
DataSourceSeriesTag(super::DataSourceSeriesTag),
#[prost(string, tag = "18")]
DataSourceRefName(::prost::alloc::string::String),
#[prost(message, tag = "19")]
DataSource(super::DataSource),
#[prost(int64, tag = "20")]
RunNumber(i64),
#[prost(string, tag = "21")]
RunPrefix(::prost::alloc::string::String),
#[prost(message, tag = "22")]
CheckAlertStatesFilter(super::CheckAlertStatesFilter),
#[prost(bool, tag = "23")]
Archived(bool),
#[prost(message, tag = "24")]
AllOf(super::SearchQueryList),
#[prost(message, tag = "25")]
AnyOf(super::SearchQueryList),
#[prost(message, tag = "26")]
Negated(::prost::alloc::boxed::Box<super::SearchQuery>),
#[prost(string, tag = "27")]
Workspace(::prost::alloc::string::String),
#[prost(message, tag = "28")]
NumericProperty(super::super::super::types::NumericPropertyPredicate),
#[prost(enumeration = "super::LockStatus", tag = "29")]
LockStatus(i32),
#[prost(message, tag = "30")]
DatasetRids(super::DatasetRidsFilter),
#[prost(message, tag = "31")]
NumericPropertyRange(super::super::super::types::NumericPropertyRangePredicate),
}
}
#[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 SortProperty {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SortKey {
#[prost(oneof = "sort_key::SortKey", tags = "1, 2, 3")]
pub sort_key: ::core::option::Option<sort_key::SortKey>,
}
pub mod sort_key {
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum SortKey {
#[prost(enumeration = "super::SortField", tag = "1")]
Field(i32),
#[prost(message, tag = "2")]
Property(super::SortProperty),
#[prost(message, tag = "3")]
NumericProperty(super::SortProperty),
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SortKeyWithDirection {
#[prost(message, optional, tag = "1")]
pub sort_key: ::core::option::Option<SortKey>,
#[prost(bool, tag = "2")]
pub is_descending: bool,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SortOptions {
#[prost(bool, tag = "1")]
pub is_descending: bool,
#[deprecated]
#[prost(enumeration = "SortField", optional, tag = "2")]
pub field: ::core::option::Option<i32>,
#[prost(message, optional, tag = "3")]
pub sort_key: ::core::option::Option<SortKey>,
#[prost(message, repeated, tag = "4")]
pub additional_sort_keys: ::prost::alloc::vec::Vec<SortKeyWithDirection>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ArchivedStatusSet {
#[prost(enumeration = "super::super::types::ArchivedStatus", repeated, tag = "1")]
pub archived_statuses: ::prost::alloc::vec::Vec<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PropertyMap {
#[prost(map = "string, string", tag = "1")]
pub properties: ::std::collections::HashMap<
::prost::alloc::string::String,
::prost::alloc::string::String,
>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct LabelSet {
#[prost(string, repeated, tag = "1")]
pub labels: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct LinkList {
#[prost(message, repeated, tag = "1")]
pub links: ::prost::alloc::vec::Vec<Link>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateRunDataSourceMap {
#[prost(map = "string, message", tag = "1")]
pub data_sources: ::std::collections::HashMap<
::prost::alloc::string::String,
CreateRunDataSource,
>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AttachmentRidSet {
#[prost(string, repeated, tag = "1")]
pub attachments: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateRunRequest {
#[prost(string, tag = "1")]
pub title: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub description: ::prost::alloc::string::String,
#[prost(message, optional, tag = "3")]
pub start_time: ::core::option::Option<UtcTimestamp>,
#[prost(message, optional, tag = "4")]
pub end_time: ::core::option::Option<UtcTimestamp>,
#[prost(map = "string, string", tag = "5")]
pub properties: ::std::collections::HashMap<
::prost::alloc::string::String,
::prost::alloc::string::String,
>,
#[prost(string, repeated, tag = "6")]
pub labels: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(message, repeated, tag = "7")]
pub links: ::prost::alloc::vec::Vec<Link>,
#[prost(string, optional, tag = "8")]
pub run_prefix: ::core::option::Option<::prost::alloc::string::String>,
#[prost(map = "string, message", tag = "9")]
pub data_sources: ::std::collections::HashMap<
::prost::alloc::string::String,
CreateRunDataSource,
>,
#[prost(string, repeated, tag = "10")]
pub attachments: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(string, optional, tag = "11")]
pub asset: ::core::option::Option<::prost::alloc::string::String>,
#[prost(string, repeated, tag = "12")]
pub assets: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(string, optional, tag = "13")]
pub workspace: ::core::option::Option<::prost::alloc::string::String>,
#[prost(map = "string, message", tag = "14")]
pub typed_properties: ::std::collections::HashMap<
::prost::alloc::string::String,
super::super::types::TypedPropertyValue,
>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateRunResponse {
#[prost(message, optional, tag = "1")]
pub run: ::core::option::Option<Run>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateRunRequest {
#[prost(string, tag = "1")]
pub rid: ::prost::alloc::string::String,
#[prost(string, optional, tag = "2")]
pub title: ::core::option::Option<::prost::alloc::string::String>,
#[prost(string, optional, tag = "3")]
pub description: ::core::option::Option<::prost::alloc::string::String>,
#[prost(message, optional, tag = "4")]
pub start_time: ::core::option::Option<UtcTimestamp>,
#[prost(message, optional, tag = "5")]
pub end_time: ::core::option::Option<UtcTimestamp>,
#[prost(message, optional, tag = "6")]
pub properties: ::core::option::Option<PropertyMap>,
#[prost(message, optional, tag = "7")]
pub labels: ::core::option::Option<LabelSet>,
#[prost(message, optional, tag = "8")]
pub links: ::core::option::Option<LinkList>,
#[prost(string, optional, tag = "9")]
pub run_prefix: ::core::option::Option<::prost::alloc::string::String>,
#[prost(message, optional, tag = "10")]
pub data_sources: ::core::option::Option<CreateRunDataSourceMap>,
#[prost(message, optional, tag = "11")]
pub attachments: ::core::option::Option<AttachmentRidSet>,
#[prost(string, optional, tag = "12")]
pub asset: ::core::option::Option<::prost::alloc::string::String>,
#[prost(string, repeated, tag = "13")]
pub assets: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(bool, optional, tag = "14")]
pub strict_overwrite: ::core::option::Option<bool>,
#[prost(message, optional, tag = "15")]
pub typed_properties: ::core::option::Option<
super::super::types::TypedPropertyUpdateWrapper,
>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateRunResponse {
#[prost(message, optional, tag = "1")]
pub run: ::core::option::Option<Run>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateOrUpdateRunRequest {
#[prost(string, optional, tag = "1")]
pub run_rid: ::core::option::Option<::prost::alloc::string::String>,
#[prost(message, optional, tag = "2")]
pub create_run_request: ::core::option::Option<CreateRunRequest>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateOrUpdateRunResponse {
#[prost(message, optional, tag = "1")]
pub run: ::core::option::Option<Run>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AddDataSourcesToRunRequest {
#[prost(string, tag = "1")]
pub run_rid: ::prost::alloc::string::String,
#[prost(map = "string, message", tag = "2")]
pub data_sources: ::std::collections::HashMap<
::prost::alloc::string::String,
CreateRunDataSource,
>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AddDataSourcesToRunResponse {
#[prost(message, optional, tag = "1")]
pub run: ::core::option::Option<Run>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchEditRunMetadataRequest {
#[prost(message, optional, tag = "1")]
pub run_search_query: ::core::option::Option<SearchQuery>,
#[prost(message, optional, tag = "2")]
pub operation: ::core::option::Option<MetadataChange>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchEditRunMetadataResponse {
#[prost(string, repeated, tag = "1")]
pub modified_run_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(string, repeated, tag = "2")]
pub conflicting_run_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetRunRequest {
#[prost(string, tag = "1")]
pub rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetRunResponse {
#[prost(message, optional, tag = "1")]
pub run: ::core::option::Option<Run>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetRunWithDataReviewMetricsRequest {
#[prost(string, tag = "1")]
pub rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetRunWithDataReviewMetricsResponse {
#[prost(message, optional, tag = "1")]
pub run_with_data_review_metrics: ::core::option::Option<RunWithDataReviewMetrics>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetRunWithDataReviewSummaryRequest {
#[prost(string, tag = "1")]
pub rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetRunWithDataReviewSummaryResponse {
#[prost(message, optional, tag = "1")]
pub run_with_data_review_summary: ::core::option::Option<RunWithDataReviewSummary>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetRunByIdRequest {
#[prost(int64, tag = "1")]
pub run_number: i64,
#[prost(string, optional, tag = "2")]
pub run_prefix: ::core::option::Option<::prost::alloc::string::String>,
#[prost(string, optional, tag = "3")]
pub workspace: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetRunByIdResponse {
#[prost(message, optional, tag = "1")]
pub run: ::core::option::Option<Run>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetRunsRequest {
#[prost(string, repeated, tag = "1")]
pub rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetRunsResponse {
#[prost(map = "string, message", tag = "1")]
pub runs: ::std::collections::HashMap<::prost::alloc::string::String, Run>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetRunsByAssetRequest {
#[prost(string, tag = "1")]
pub asset: ::prost::alloc::string::String,
#[prost(string, optional, tag = "2")]
pub next_page_token: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetRunsByAssetResponse {
#[prost(message, repeated, tag = "1")]
pub results: ::prost::alloc::vec::Vec<Run>,
#[prost(string, optional, tag = "2")]
pub next_page_token: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetLatestRunForAssetsRequest {
#[prost(string, repeated, tag = "1")]
pub asset_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetLatestRunForAssetsResponse {
#[prost(map = "string, message", tag = "1")]
pub runs: ::std::collections::HashMap<::prost::alloc::string::String, Run>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetAllRunsPropertiesAndLabelsRequest {
#[prost(string, repeated, tag = "1")]
pub workspaces: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetAllRunsPropertiesAndLabelsResponse {
#[prost(map = "string, message", tag = "1")]
pub properties: ::std::collections::HashMap<
::prost::alloc::string::String,
PropertyValueList,
>,
#[prost(string, repeated, tag = "2")]
pub labels: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PropertyValueList {
#[prost(string, repeated, tag = "1")]
pub values: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SearchRunsRequest {
#[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>,
#[deprecated]
#[prost(message, optional, tag = "5")]
pub archived_statuses: ::core::option::Option<ArchivedStatusSet>,
#[prost(bool, optional, tag = "6")]
pub include_match_count: ::core::option::Option<bool>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SearchRunsResponse {
#[prost(message, repeated, tag = "1")]
pub results: ::prost::alloc::vec::Vec<Run>,
#[prost(string, optional, tag = "2")]
pub next_page_token: ::core::option::Option<::prost::alloc::string::String>,
#[prost(int32, optional, tag = "3")]
pub total_count: ::core::option::Option<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SearchRunsWithDataReviewMetricsRequest {
#[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>,
#[deprecated]
#[prost(message, optional, tag = "5")]
pub archived_statuses: ::core::option::Option<ArchivedStatusSet>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SearchRunsWithDataReviewMetricsResponse {
#[prost(message, repeated, tag = "1")]
pub results: ::prost::alloc::vec::Vec<RunWithDataReviewMetrics>,
#[prost(string, optional, tag = "2")]
pub next_page_token: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SearchRunsWithDataReviewSummaryRequest {
#[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>,
#[deprecated]
#[prost(message, optional, tag = "5")]
pub archived_statuses: ::core::option::Option<ArchivedStatusSet>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SearchRunsWithDataReviewSummaryResponse {
#[prost(message, repeated, tag = "1")]
pub results: ::prost::alloc::vec::Vec<RunWithDataReviewSummary>,
#[prost(string, optional, tag = "2")]
pub next_page_token: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ArchiveRunRequest {
#[prost(string, tag = "1")]
pub rid: ::prost::alloc::string::String,
#[prost(bool, optional, tag = "2")]
pub include_linked_workbooks: ::core::option::Option<bool>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct ArchiveRunResponse {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UnarchiveRunRequest {
#[prost(string, tag = "1")]
pub rid: ::prost::alloc::string::String,
#[prost(bool, optional, tag = "2")]
pub include_linked_workbooks: ::core::option::Option<bool>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct UnarchiveRunResponse {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ArchiveRunsRequest {
#[prost(string, repeated, tag = "1")]
pub rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(bool, optional, tag = "2")]
pub include_linked_workbooks: ::core::option::Option<bool>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct ArchiveRunsResponse {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UnarchiveRunsRequest {
#[prost(string, repeated, tag = "1")]
pub rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(bool, optional, tag = "2")]
pub include_linked_workbooks: ::core::option::Option<bool>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct UnarchiveRunsResponse {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetDataSourceRefNameAndTypeListRequest {
#[prost(string, repeated, tag = "1")]
pub workspaces: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetDataSourceRefNameAndTypeListResponse {
#[prost(message, repeated, tag = "1")]
pub ref_name_and_types: ::prost::alloc::vec::Vec<RefNameAndType>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateRunAttachmentRequest {
#[prost(string, tag = "1")]
pub rid: ::prost::alloc::string::String,
#[prost(string, repeated, tag = "2")]
pub attachments_to_add: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(string, repeated, tag = "3")]
pub attachments_to_remove: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct UpdateRunAttachmentResponse {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateLockStatusRequest {
#[prost(string, tag = "1")]
pub rid: ::prost::alloc::string::String,
#[prost(enumeration = "LockStatus", tag = "2")]
pub lock_status: i32,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct UpdateLockStatusResponse {}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum DataSourceType {
Unspecified = 0,
Dataset = 1,
Connection = 2,
Logset = 3,
Video = 4,
Spatial = 5,
}
impl DataSourceType {
pub fn as_str_name(&self) -> &'static str {
match self {
Self::Unspecified => "DATA_SOURCE_TYPE_UNSPECIFIED",
Self::Dataset => "DATASET",
Self::Connection => "CONNECTION",
Self::Logset => "LOGSET",
Self::Video => "VIDEO",
Self::Spatial => "SPATIAL",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"DATA_SOURCE_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
"DATASET" => Some(Self::Dataset),
"CONNECTION" => Some(Self::Connection),
"LOGSET" => Some(Self::Logset),
"VIDEO" => Some(Self::Video),
"SPATIAL" => Some(Self::Spatial),
_ => 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 {
pub fn as_str_name(&self) -> &'static str {
match self {
Self::Unspecified => "SET_OPERATOR_UNSPECIFIED",
Self::And => "AND",
Self::Or => "OR",
}
}
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 Operator {
Unspecified = 0,
Leq = 1,
Lt = 2,
Geq = 3,
Gt = 4,
Eq = 5,
}
impl Operator {
pub fn as_str_name(&self) -> &'static str {
match self {
Self::Unspecified => "OPERATOR_UNSPECIFIED",
Self::Leq => "LEQ",
Self::Lt => "LT",
Self::Geq => "GEQ",
Self::Gt => "GT",
Self::Eq => "EQ",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"OPERATOR_UNSPECIFIED" => Some(Self::Unspecified),
"LEQ" => Some(Self::Leq),
"LT" => Some(Self::Lt),
"GEQ" => Some(Self::Geq),
"GT" => Some(Self::Gt),
"EQ" => Some(Self::Eq),
_ => None,
}
}
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum LockStatus {
Unspecified = 0,
Locked = 1,
Unlocked = 2,
}
impl LockStatus {
pub fn as_str_name(&self) -> &'static str {
match self {
Self::Unspecified => "LOCK_STATUS_UNSPECIFIED",
Self::Locked => "LOCK_STATUS_LOCKED",
Self::Unlocked => "LOCK_STATUS_UNLOCKED",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"LOCK_STATUS_UNSPECIFIED" => Some(Self::Unspecified),
"LOCK_STATUS_LOCKED" => Some(Self::Locked),
"LOCK_STATUS_UNLOCKED" => Some(Self::Unlocked),
_ => None,
}
}
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum RunDataReviewEvaluationStatus {
Unspecified = 0,
NoChecksApplied = 1,
FailedToExecute = 2,
Executing = 3,
PendingExecution = 4,
ClosedWithFurtherAction = 5,
GeneratedAlerts = 6,
ClosedWithIgnore = 7,
Passing = 8,
}
impl RunDataReviewEvaluationStatus {
pub fn as_str_name(&self) -> &'static str {
match self {
Self::Unspecified => "RUN_DATA_REVIEW_EVALUATION_STATUS_UNSPECIFIED",
Self::NoChecksApplied => "NO_CHECKS_APPLIED",
Self::FailedToExecute => "FAILED_TO_EXECUTE",
Self::Executing => "EXECUTING",
Self::PendingExecution => "PENDING_EXECUTION",
Self::ClosedWithFurtherAction => "CLOSED_WITH_FURTHER_ACTION",
Self::GeneratedAlerts => "GENERATED_ALERTS",
Self::ClosedWithIgnore => "CLOSED_WITH_IGNORE",
Self::Passing => "PASSING",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"RUN_DATA_REVIEW_EVALUATION_STATUS_UNSPECIFIED" => Some(Self::Unspecified),
"NO_CHECKS_APPLIED" => Some(Self::NoChecksApplied),
"FAILED_TO_EXECUTE" => Some(Self::FailedToExecute),
"EXECUTING" => Some(Self::Executing),
"PENDING_EXECUTION" => Some(Self::PendingExecution),
"CLOSED_WITH_FURTHER_ACTION" => Some(Self::ClosedWithFurtherAction),
"GENERATED_ALERTS" => Some(Self::GeneratedAlerts),
"CLOSED_WITH_IGNORE" => Some(Self::ClosedWithIgnore),
"PASSING" => Some(Self::Passing),
_ => None,
}
}
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum PresetTimeframeDuration {
Unspecified = 0,
AllTime = 1,
LastDay = 2,
LastWeek = 3,
LastMonth = 4,
LastYear = 5,
}
impl PresetTimeframeDuration {
pub fn as_str_name(&self) -> &'static str {
match self {
Self::Unspecified => "PRESET_TIMEFRAME_DURATION_UNSPECIFIED",
Self::AllTime => "ALL_TIME",
Self::LastDay => "LAST_DAY",
Self::LastWeek => "LAST_WEEK",
Self::LastMonth => "LAST_MONTH",
Self::LastYear => "LAST_YEAR",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"PRESET_TIMEFRAME_DURATION_UNSPECIFIED" => Some(Self::Unspecified),
"ALL_TIME" => Some(Self::AllTime),
"LAST_DAY" => Some(Self::LastDay),
"LAST_WEEK" => Some(Self::LastWeek),
"LAST_MONTH" => Some(Self::LastMonth),
"LAST_YEAR" => Some(Self::LastYear),
_ => None,
}
}
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SortField {
Unspecified = 0,
Name = 1,
Id = 2,
CreatedAt = 3,
StartTime = 4,
EndTime = 5,
PendingCheckAlerts = 6,
}
impl SortField {
pub fn as_str_name(&self) -> &'static str {
match self {
Self::Unspecified => "SORT_FIELD_UNSPECIFIED",
Self::Name => "NAME",
Self::Id => "ID",
Self::CreatedAt => "CREATED_AT",
Self::StartTime => "START_TIME",
Self::EndTime => "END_TIME",
Self::PendingCheckAlerts => "PENDING_CHECK_ALERTS",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"SORT_FIELD_UNSPECIFIED" => Some(Self::Unspecified),
"NAME" => Some(Self::Name),
"ID" => Some(Self::Id),
"CREATED_AT" => Some(Self::CreatedAt),
"START_TIME" => Some(Self::StartTime),
"END_TIME" => Some(Self::EndTime),
"PENDING_CHECK_ALERTS" => Some(Self::PendingCheckAlerts),
_ => None,
}
}
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum RunError {
InvalidRequest = 0,
}
impl RunError {
pub fn as_str_name(&self) -> &'static str {
match self {
Self::InvalidRequest => "RUN_ERROR_INVALID_REQUEST",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"RUN_ERROR_INVALID_REQUEST" => Some(Self::InvalidRequest),
_ => None,
}
}
}
pub mod run_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 RunServiceClient<T> {
inner: tonic::client::Grpc<T>,
}
impl RunServiceClient<tonic::transport::Channel> {
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> RunServiceClient<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,
) -> RunServiceClient<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,
{
RunServiceClient::new(InterceptedService::new(inner, interceptor))
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.send_compressed(encoding);
self
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.accept_compressed(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_decoding_message_size(limit);
self
}
#[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_run(
&mut self,
request: impl tonic::IntoRequest<super::CreateRunRequest>,
) -> std::result::Result<
tonic::Response<super::CreateRunResponse>,
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.run.v1.RunService/CreateRun",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("nominal.run.v1.RunService", "CreateRun"));
self.inner.unary(req, path, codec).await
}
pub async fn update_run(
&mut self,
request: impl tonic::IntoRequest<super::UpdateRunRequest>,
) -> std::result::Result<
tonic::Response<super::UpdateRunResponse>,
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.run.v1.RunService/UpdateRun",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("nominal.run.v1.RunService", "UpdateRun"));
self.inner.unary(req, path, codec).await
}
pub async fn create_or_update_run(
&mut self,
request: impl tonic::IntoRequest<super::CreateOrUpdateRunRequest>,
) -> std::result::Result<
tonic::Response<super::CreateOrUpdateRunResponse>,
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.run.v1.RunService/CreateOrUpdateRun",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("nominal.run.v1.RunService", "CreateOrUpdateRun"),
);
self.inner.unary(req, path, codec).await
}
pub async fn add_data_sources_to_run(
&mut self,
request: impl tonic::IntoRequest<super::AddDataSourcesToRunRequest>,
) -> std::result::Result<
tonic::Response<super::AddDataSourcesToRunResponse>,
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.run.v1.RunService/AddDataSourcesToRun",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("nominal.run.v1.RunService", "AddDataSourcesToRun"),
);
self.inner.unary(req, path, codec).await
}
pub async fn batch_edit_run_metadata(
&mut self,
request: impl tonic::IntoRequest<super::BatchEditRunMetadataRequest>,
) -> std::result::Result<
tonic::Response<super::BatchEditRunMetadataResponse>,
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.run.v1.RunService/BatchEditRunMetadata",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("nominal.run.v1.RunService", "BatchEditRunMetadata"),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_run(
&mut self,
request: impl tonic::IntoRequest<super::GetRunRequest>,
) -> std::result::Result<tonic::Response<super::GetRunResponse>, 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.run.v1.RunService/GetRun",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("nominal.run.v1.RunService", "GetRun"));
self.inner.unary(req, path, codec).await
}
pub async fn get_run_with_data_review_metrics(
&mut self,
request: impl tonic::IntoRequest<super::GetRunWithDataReviewMetricsRequest>,
) -> std::result::Result<
tonic::Response<super::GetRunWithDataReviewMetricsResponse>,
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.run.v1.RunService/GetRunWithDataReviewMetrics",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"nominal.run.v1.RunService",
"GetRunWithDataReviewMetrics",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_run_with_data_review_summary(
&mut self,
request: impl tonic::IntoRequest<super::GetRunWithDataReviewSummaryRequest>,
) -> std::result::Result<
tonic::Response<super::GetRunWithDataReviewSummaryResponse>,
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.run.v1.RunService/GetRunWithDataReviewSummary",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"nominal.run.v1.RunService",
"GetRunWithDataReviewSummary",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_run_by_id(
&mut self,
request: impl tonic::IntoRequest<super::GetRunByIdRequest>,
) -> std::result::Result<
tonic::Response<super::GetRunByIdResponse>,
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.run.v1.RunService/GetRunById",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("nominal.run.v1.RunService", "GetRunById"));
self.inner.unary(req, path, codec).await
}
pub async fn get_runs(
&mut self,
request: impl tonic::IntoRequest<super::GetRunsRequest>,
) -> std::result::Result<
tonic::Response<super::GetRunsResponse>,
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.run.v1.RunService/GetRuns",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("nominal.run.v1.RunService", "GetRuns"));
self.inner.unary(req, path, codec).await
}
pub async fn get_runs_by_asset(
&mut self,
request: impl tonic::IntoRequest<super::GetRunsByAssetRequest>,
) -> std::result::Result<
tonic::Response<super::GetRunsByAssetResponse>,
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.run.v1.RunService/GetRunsByAsset",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("nominal.run.v1.RunService", "GetRunsByAsset"));
self.inner.unary(req, path, codec).await
}
pub async fn get_latest_run_for_assets(
&mut self,
request: impl tonic::IntoRequest<super::GetLatestRunForAssetsRequest>,
) -> std::result::Result<
tonic::Response<super::GetLatestRunForAssetsResponse>,
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.run.v1.RunService/GetLatestRunForAssets",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("nominal.run.v1.RunService", "GetLatestRunForAssets"),
);
self.inner.unary(req, path, codec).await
}
#[deprecated]
pub async fn get_all_runs_properties_and_labels(
&mut self,
request: impl tonic::IntoRequest<super::GetAllRunsPropertiesAndLabelsRequest>,
) -> std::result::Result<
tonic::Response<super::GetAllRunsPropertiesAndLabelsResponse>,
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.run.v1.RunService/GetAllRunsPropertiesAndLabels",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"nominal.run.v1.RunService",
"GetAllRunsPropertiesAndLabels",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn search_runs(
&mut self,
request: impl tonic::IntoRequest<super::SearchRunsRequest>,
) -> std::result::Result<
tonic::Response<super::SearchRunsResponse>,
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.run.v1.RunService/SearchRuns",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("nominal.run.v1.RunService", "SearchRuns"));
self.inner.unary(req, path, codec).await
}
pub async fn search_runs_with_data_review_metrics(
&mut self,
request: impl tonic::IntoRequest<
super::SearchRunsWithDataReviewMetricsRequest,
>,
) -> std::result::Result<
tonic::Response<super::SearchRunsWithDataReviewMetricsResponse>,
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.run.v1.RunService/SearchRunsWithDataReviewMetrics",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"nominal.run.v1.RunService",
"SearchRunsWithDataReviewMetrics",
),
);
self.inner.unary(req, path, codec).await
}
#[deprecated]
pub async fn search_runs_with_data_review_summary(
&mut self,
request: impl tonic::IntoRequest<
super::SearchRunsWithDataReviewSummaryRequest,
>,
) -> std::result::Result<
tonic::Response<super::SearchRunsWithDataReviewSummaryResponse>,
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.run.v1.RunService/SearchRunsWithDataReviewSummary",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"nominal.run.v1.RunService",
"SearchRunsWithDataReviewSummary",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn archive_run(
&mut self,
request: impl tonic::IntoRequest<super::ArchiveRunRequest>,
) -> std::result::Result<
tonic::Response<super::ArchiveRunResponse>,
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.run.v1.RunService/ArchiveRun",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("nominal.run.v1.RunService", "ArchiveRun"));
self.inner.unary(req, path, codec).await
}
pub async fn unarchive_run(
&mut self,
request: impl tonic::IntoRequest<super::UnarchiveRunRequest>,
) -> std::result::Result<
tonic::Response<super::UnarchiveRunResponse>,
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.run.v1.RunService/UnarchiveRun",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("nominal.run.v1.RunService", "UnarchiveRun"));
self.inner.unary(req, path, codec).await
}
pub async fn archive_runs(
&mut self,
request: impl tonic::IntoRequest<super::ArchiveRunsRequest>,
) -> std::result::Result<
tonic::Response<super::ArchiveRunsResponse>,
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.run.v1.RunService/ArchiveRuns",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("nominal.run.v1.RunService", "ArchiveRuns"));
self.inner.unary(req, path, codec).await
}
pub async fn unarchive_runs(
&mut self,
request: impl tonic::IntoRequest<super::UnarchiveRunsRequest>,
) -> std::result::Result<
tonic::Response<super::UnarchiveRunsResponse>,
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.run.v1.RunService/UnarchiveRuns",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("nominal.run.v1.RunService", "UnarchiveRuns"));
self.inner.unary(req, path, codec).await
}
pub async fn get_data_source_ref_name_and_type_list(
&mut self,
request: impl tonic::IntoRequest<
super::GetDataSourceRefNameAndTypeListRequest,
>,
) -> std::result::Result<
tonic::Response<super::GetDataSourceRefNameAndTypeListResponse>,
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.run.v1.RunService/GetDataSourceRefNameAndTypeList",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"nominal.run.v1.RunService",
"GetDataSourceRefNameAndTypeList",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn update_run_attachment(
&mut self,
request: impl tonic::IntoRequest<super::UpdateRunAttachmentRequest>,
) -> std::result::Result<
tonic::Response<super::UpdateRunAttachmentResponse>,
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.run.v1.RunService/UpdateRunAttachment",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("nominal.run.v1.RunService", "UpdateRunAttachment"),
);
self.inner.unary(req, path, codec).await
}
pub async fn update_lock_status(
&mut self,
request: impl tonic::IntoRequest<super::UpdateLockStatusRequest>,
) -> std::result::Result<
tonic::Response<super::UpdateLockStatusResponse>,
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.run.v1.RunService/UpdateLockStatus",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("nominal.run.v1.RunService", "UpdateLockStatus"),
);
self.inner.unary(req, path, codec).await
}
}
}