#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct Timestamp {
#[prost(int64, tag = "1")]
pub seconds: i64,
#[prost(int64, tag = "2")]
pub nanos: i64,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct VersionedVizId {
#[prost(string, tag = "1")]
pub rid: ::prost::alloc::string::String,
#[prost(int32, tag = "2")]
pub version: i32,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PinnedChecklistRef {
#[prost(string, tag = "1")]
pub rid: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub commit: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ChecklistRef {
#[prost(string, tag = "1")]
pub rid: ::prost::alloc::string::String,
#[prost(string, optional, tag = "2")]
pub commit: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct NotificationConfiguration {
#[prost(string, tag = "1")]
pub integration_rid: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub notification_filters: ::core::option::Option<NotificationFilterSetWrapper>,
#[prost(string, optional, tag = "3")]
pub appended_workbook_rid: ::core::option::Option<::prost::alloc::string::String>,
#[prost(string, repeated, tag = "4")]
pub tags: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(message, optional, tag = "5")]
pub mute_until: ::core::option::Option<
super::super::super::google::protobuf::Timestamp,
>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct NotificationFilterSetWrapper {
#[prost(enumeration = "NotificationFilter", repeated, tag = "1")]
pub notification_filters: ::prost::alloc::vec::Vec<i32>,
}
#[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, Copy, PartialEq, ::prost::Message)]
pub struct ArchiveDataReview {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AutomaticCheckEvaluation {
#[prost(string, tag = "1")]
pub rid: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub check_rid: ::prost::alloc::string::String,
#[prost(int32, optional, tag = "3")]
pub check_implementation_index: ::core::option::Option<i32>,
#[prost(string, tag = "4")]
pub data_review_rid: ::prost::alloc::string::String,
#[prost(message, optional, tag = "5")]
pub state: ::core::option::Option<AutomaticCheckEvaluationState>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AutomaticCheckEvaluationAction {
#[prost(
oneof = "automatic_check_evaluation_action::AutomaticCheckEvaluationAction",
tags = "1, 2, 3, 4"
)]
pub automatic_check_evaluation_action: ::core::option::Option<
automatic_check_evaluation_action::AutomaticCheckEvaluationAction,
>,
}
pub mod automatic_check_evaluation_action {
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum AutomaticCheckEvaluationAction {
#[prost(message, tag = "1")]
ExecutionFinished(super::AutomaticCheckExecutionFinished),
#[prost(message, tag = "2")]
ExecutionFailedToRun(super::AutomaticCheckExecutionFailedToRun),
#[prost(message, tag = "3")]
ExecutionRetriggered(super::ExecutionRetriggered),
#[prost(message, tag = "4")]
ExecutionStarted(super::AutomaticCheckExecutionStarted),
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AutomaticCheckEvaluationActionLog {
#[prost(message, repeated, tag = "1")]
pub entries: ::prost::alloc::vec::Vec<AutomaticCheckEvaluationActionLogEntry>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AutomaticCheckEvaluationActionLogEntry {
#[prost(message, optional, tag = "1")]
pub action: ::core::option::Option<AutomaticCheckEvaluationAction>,
#[prost(message, optional, tag = "2")]
pub timestamp: ::core::option::Option<
super::super::super::google::protobuf::Timestamp,
>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AutomaticCheckEvaluationReviewAction {
#[prost(
oneof = "automatic_check_evaluation_review_action::AutomaticCheckEvaluationReviewAction",
tags = "1, 2, 3, 4, 5"
)]
pub automatic_check_evaluation_review_action: ::core::option::Option<
automatic_check_evaluation_review_action::AutomaticCheckEvaluationReviewAction,
>,
}
pub mod automatic_check_evaluation_review_action {
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum AutomaticCheckEvaluationReviewAction {
#[prost(message, tag = "1")]
CloseWithIgnore(super::CloseWithIgnoreAlert),
#[prost(message, tag = "2")]
CloseWithFurtherAction(super::CloseWithFurtherAction),
#[prost(message, tag = "3")]
Reopen(super::Reopen),
#[prost(message, tag = "4")]
Reassign(super::Reassign),
#[prost(message, tag = "5")]
UpdateNotes(super::UpdateNotes),
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AutomaticCheckEvaluationReviewActionLog {
#[prost(message, repeated, tag = "1")]
pub entries: ::prost::alloc::vec::Vec<AutomaticCheckEvaluationReviewActionLogEntry>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AutomaticCheckEvaluationReviewActionLogEntry {
#[prost(string, tag = "1")]
pub performed_by: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub action: ::core::option::Option<AutomaticCheckEvaluationReviewAction>,
#[prost(message, optional, tag = "3")]
pub timestamp: ::core::option::Option<
super::super::super::google::protobuf::Timestamp,
>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AutomaticCheckEvaluationState {
#[prost(
oneof = "automatic_check_evaluation_state::AutomaticCheckEvaluationState",
tags = "1, 2, 3, 4, 5, 6"
)]
pub automatic_check_evaluation_state: ::core::option::Option<
automatic_check_evaluation_state::AutomaticCheckEvaluationState,
>,
}
pub mod automatic_check_evaluation_state {
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum AutomaticCheckEvaluationState {
#[prost(message, tag = "1")]
PendingExecution(super::PendingExecutionState),
#[prost(message, tag = "2")]
FailedToExecute(super::FailedToExecuteState),
#[prost(message, tag = "3")]
Passing(super::PassingExecutionState),
#[prost(message, tag = "4")]
GeneratedAlerts(super::GeneratedAlertsState),
#[prost(message, tag = "5")]
TooManyAlerts(super::TooManyAlertsState),
#[prost(message, tag = "6")]
Executing(super::ExecutingState),
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AutomaticCheckExecutionFailedToRun {
#[prost(string, tag = "1")]
pub job_rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AutomaticCheckExecutionFinished {
#[prost(string, tag = "1")]
pub job_rid: ::prost::alloc::string::String,
#[prost(enumeration = "Status", tag = "2")]
pub status: i32,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AutomaticCheckExecutionStarted {
#[prost(string, tag = "1")]
pub job_rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchAutomaticCheckEvaluationActionRequest {
#[prost(message, optional, tag = "1")]
pub check_evaluation_action: ::core::option::Option<
AutomaticCheckEvaluationReviewAction,
>,
#[prost(string, repeated, tag = "2")]
pub check_evaluation_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchAutomaticCheckEvaluationActionResponse {
#[prost(message, repeated, tag = "1")]
pub check_evaluations: ::prost::alloc::vec::Vec<AutomaticCheckEvaluation>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchCheckAlertActionRequest {
#[prost(message, optional, tag = "1")]
pub check_alert_action: ::core::option::Option<CheckAlertAction>,
#[prost(string, repeated, tag = "2")]
pub check_alert_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchCheckAlertActionResponse {
#[prost(message, repeated, tag = "1")]
pub check_alerts: ::prost::alloc::vec::Vec<CheckAlert>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchInitiateDataReviewRequest {
#[prost(message, repeated, tag = "1")]
pub requests: ::prost::alloc::vec::Vec<CreateDataReviewRequest>,
#[prost(message, repeated, tag = "2")]
pub notification_configurations: ::prost::alloc::vec::Vec<NotificationConfiguration>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchInitiateDataReviewResponse {
#[prost(string, repeated, tag = "1")]
pub rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchManualCheckEvaluationActionRequest {
#[prost(message, optional, tag = "1")]
pub check_alert_action: ::core::option::Option<ManualCheckAlertAction>,
#[prost(string, repeated, tag = "2")]
pub check_evaluation_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CheckAlert {
#[prost(string, tag = "1")]
pub rid: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub check_rid: ::prost::alloc::string::String,
#[prost(int32, optional, tag = "3")]
pub implementation_index: ::core::option::Option<i32>,
#[prost(string, tag = "4")]
pub data_review_rid: ::prost::alloc::string::String,
#[prost(string, tag = "5")]
pub check_evaluation_rid: ::prost::alloc::string::String,
#[prost(string, tag = "6")]
pub name: ::prost::alloc::string::String,
#[prost(string, optional, tag = "7")]
pub autogenerated_check_title: ::core::option::Option<
::prost::alloc::string::String,
>,
#[prost(string, optional, tag = "8")]
pub autogenerated_check_description: ::core::option::Option<
::prost::alloc::string::String,
>,
#[prost(string, repeated, tag = "9")]
pub assignee_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(message, optional, tag = "10")]
pub start: ::core::option::Option<Timestamp>,
#[prost(message, optional, tag = "11")]
pub end: ::core::option::Option<Timestamp>,
#[prost(message, optional, tag = "12")]
pub state: ::core::option::Option<CheckAlertState>,
#[prost(enumeration = "super::super::types::Priority", tag = "13")]
pub priority: i32,
#[prost(message, optional, tag = "14")]
pub chart: ::core::option::Option<VersionedVizId>,
#[prost(string, optional, tag = "15")]
pub notes: ::core::option::Option<::prost::alloc::string::String>,
#[prost(string, optional, tag = "16")]
pub notebook: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CheckAlertAction {
#[prost(
oneof = "check_alert_action::CheckAlertAction",
tags = "1, 2, 3, 4, 5, 6, 7, 8, 9"
)]
pub check_alert_action: ::core::option::Option<check_alert_action::CheckAlertAction>,
}
pub mod check_alert_action {
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum CheckAlertAction {
#[prost(message, tag = "1")]
CloseWithIgnore(super::CloseWithIgnoreAlert),
#[prost(message, tag = "2")]
CloseWithFurtherAction(super::CloseWithFurtherAction),
#[prost(message, tag = "3")]
Reopen(super::Reopen),
#[prost(message, tag = "4")]
Reassign(super::Reassign),
#[prost(message, tag = "5")]
UpdateNotes(super::UpdateNotes),
#[prost(message, tag = "6")]
LinkNotebook(super::LinkNotebook),
#[prost(message, tag = "7")]
UnlinkNotebook(super::UnlinkNotebook),
#[prost(message, tag = "8")]
ArchiveDataReview(super::ArchiveDataReview),
#[prost(message, tag = "9")]
UnarchiveDataReview(super::UnarchiveDataReview),
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CheckAlertActionLog {
#[prost(message, repeated, tag = "1")]
pub entries: ::prost::alloc::vec::Vec<CheckAlertActionLogEntry>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CheckAlertActionLogEntry {
#[prost(string, tag = "1")]
pub performed_by: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub action: ::core::option::Option<CheckAlertAction>,
#[prost(message, optional, tag = "3")]
pub timestamp: ::core::option::Option<
super::super::super::google::protobuf::Timestamp,
>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CheckAlertsHistogramBuckets {
#[prost(
oneof = "check_alerts_histogram_buckets::CheckAlertsHistogramBuckets",
tags = "1, 2, 3"
)]
pub check_alerts_histogram_buckets: ::core::option::Option<
check_alerts_histogram_buckets::CheckAlertsHistogramBuckets,
>,
}
pub mod check_alerts_histogram_buckets {
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum CheckAlertsHistogramBuckets {
#[prost(message, tag = "1")]
Unstacked(super::CheckAlertsUnstackedHistogram),
#[prost(message, tag = "2")]
Priority(super::CheckAlertsPriorityHistogram),
#[prost(message, tag = "3")]
Status(super::CheckAlertsStatusHistogram),
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CheckAlertsHistogramRequest {
#[prost(int32, optional, tag = "1")]
pub num_bins: ::core::option::Option<i32>,
#[prost(string, optional, tag = "2")]
pub search_text: ::core::option::Option<::prost::alloc::string::String>,
#[prost(message, optional, tag = "3")]
pub distribution_variable: ::core::option::Option<HistogramDistributionVariable>,
#[prost(message, optional, tag = "4")]
pub sub_group_variable: ::core::option::Option<HistogramSubGroupVariable>,
#[prost(message, optional, tag = "5")]
pub start_time_after: ::core::option::Option<Timestamp>,
#[prost(message, optional, tag = "6")]
pub start_time_before: ::core::option::Option<Timestamp>,
#[prost(message, optional, tag = "7")]
pub status: ::core::option::Option<CheckAlertStatusSetWrapper>,
#[prost(message, optional, tag = "8")]
pub check_rids: ::core::option::Option<CheckRidSetWrapper>,
#[prost(message, optional, tag = "9")]
pub data_review_rids: ::core::option::Option<DataReviewRidSetWrapper>,
#[prost(message, optional, tag = "10")]
pub assignee_rids: ::core::option::Option<UserRidSetWrapper>,
#[prost(message, optional, tag = "11")]
pub priorities: ::core::option::Option<PrioritySetWrapper>,
#[prost(string, repeated, tag = "12")]
pub run_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(string, repeated, tag = "13")]
pub asset_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(message, optional, tag = "14")]
pub pinned_checklist_refs: ::core::option::Option<PinnedChecklistRefSetWrapper>,
#[prost(message, optional, tag = "15")]
pub chart_rids: ::core::option::Option<VersionedVizIdSetWrapper>,
#[prost(message, optional, tag = "16")]
pub notebook_rids: ::core::option::Option<NotebookRidSetWrapper>,
#[prost(bool, optional, tag = "17")]
pub show_archived: ::core::option::Option<bool>,
#[prost(message, optional, tag = "18")]
pub archived_statuses: ::core::option::Option<ArchivedStatusSetWrapper>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CheckAlertsHistogramResponse {
#[prost(message, optional, tag = "1")]
pub buckets: ::core::option::Option<CheckAlertsHistogramBuckets>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CheckAlertsPriorityHistogram {
#[prost(message, repeated, tag = "1")]
pub buckets: ::prost::alloc::vec::Vec<HistogramPriorityBucket>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CheckAlertsStatusHistogram {
#[prost(message, repeated, tag = "1")]
pub buckets: ::prost::alloc::vec::Vec<HistogramStatusBucket>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CheckAlertsUnstackedHistogram {
#[prost(message, repeated, tag = "1")]
pub buckets: ::prost::alloc::vec::Vec<HistogramBucket>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CheckEvaluation {
#[prost(oneof = "check_evaluation::CheckEvaluation", tags = "1, 2")]
pub check_evaluation: ::core::option::Option<check_evaluation::CheckEvaluation>,
}
pub mod check_evaluation {
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum CheckEvaluation {
#[prost(message, tag = "1")]
AutomaticCheck(super::AutomaticCheckEvaluation),
#[prost(message, tag = "2")]
ManualCheck(super::ManualCheckEvaluation),
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ChecklistEvaluation {
#[prost(message, optional, tag = "1")]
pub checklist: ::core::option::Option<PinnedChecklistRef>,
#[prost(string, tag = "2")]
pub data_review_rid: ::prost::alloc::string::String,
#[prost(message, repeated, tag = "3")]
pub checks: ::prost::alloc::vec::Vec<CheckEvaluation>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CloseAction {
#[prost(oneof = "close_action::CloseAction", tags = "1, 2")]
pub close_action: ::core::option::Option<close_action::CloseAction>,
}
pub mod close_action {
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum CloseAction {
#[prost(message, tag = "1")]
CloseWithIgnore(super::CloseWithIgnoreAlert),
#[prost(message, tag = "2")]
CloseWithFurtherAction(super::CloseWithFurtherAction),
}
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct CloseAllLinkedAlerts {}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct CloseAndDetachFromNotebook {}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct CloseAndDuplicatePreviouslyLinkedNotebook {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CloseAndLinkToNotebook {
#[prost(message, optional, tag = "1")]
pub close_action: ::core::option::Option<CloseAction>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct CloseStrategy {
#[prost(oneof = "close_strategy::CloseStrategy", tags = "1, 2, 3")]
pub close_strategy: ::core::option::Option<close_strategy::CloseStrategy>,
}
pub mod close_strategy {
#[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
pub enum CloseStrategy {
#[prost(message, tag = "1")]
CloseAllLinkedAlerts(super::CloseAllLinkedAlerts),
#[prost(message, tag = "2")]
CloseAndDetachFromNotebook(super::CloseAndDetachFromNotebook),
#[prost(message, tag = "3")]
CloseAndDuplicatePreviouslyLinkedNotebook(
super::CloseAndDuplicatePreviouslyLinkedNotebook,
),
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CloseWithFurtherAction {
#[prost(string, tag = "1")]
pub comment: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub strategy: ::core::option::Option<CloseStrategy>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CloseWithIgnoreAlert {
#[prost(string, tag = "1")]
pub comment: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub strategy: ::core::option::Option<CloseStrategy>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ClosedWithFurtherActionState {
#[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 CreateDataReviewRequest {
#[prost(string, tag = "1")]
pub run_rid: ::prost::alloc::string::String,
#[prost(string, optional, tag = "2")]
pub asset_rid: ::core::option::Option<::prost::alloc::string::String>,
#[prost(string, tag = "3")]
pub checklist_rid: ::prost::alloc::string::String,
#[prost(string, optional, tag = "4")]
pub commit: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DataReview {
#[prost(string, tag = "1")]
pub rid: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub run_rid: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub asset_rid: ::prost::alloc::string::String,
#[prost(message, optional, tag = "4")]
pub created_at: ::core::option::Option<
super::super::super::google::protobuf::Timestamp,
>,
#[prost(string, tag = "5")]
pub created_by: ::prost::alloc::string::String,
#[prost(message, optional, tag = "6")]
pub checklist: ::core::option::Option<ChecklistEvaluation>,
#[prost(message, optional, tag = "7")]
pub checklist_ref: ::core::option::Option<PinnedChecklistRef>,
#[prost(message, repeated, tag = "8")]
pub check_evaluations: ::prost::alloc::vec::Vec<AutomaticCheckEvaluation>,
#[prost(bool, tag = "9")]
pub archived: bool,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DataReviewCheckMetricsScope {
#[prost(
oneof = "data_review_check_metrics_scope::DataReviewCheckMetricsScope",
tags = "1, 2, 3"
)]
pub data_review_check_metrics_scope: ::core::option::Option<
data_review_check_metrics_scope::DataReviewCheckMetricsScope,
>,
}
pub mod data_review_check_metrics_scope {
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum DataReviewCheckMetricsScope {
#[prost(string, tag = "1")]
RunRid(::prost::alloc::string::String),
#[prost(string, tag = "2")]
AssetRid(::prost::alloc::string::String),
#[prost(string, tag = "3")]
DataReviewRid(::prost::alloc::string::String),
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DataReviewPage {
#[prost(message, repeated, tag = "1")]
pub data_reviews: ::prost::alloc::vec::Vec<DataReview>,
#[prost(string, optional, tag = "2")]
pub next_page_token: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct DuplicateAndLinkNotebook {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ExecutingState {
#[prost(string, tag = "1")]
pub job_rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ExecutionRetriggered {
#[prost(string, tag = "1")]
pub job_rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FailedToExecuteState {
#[prost(string, tag = "1")]
pub job_rid: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub review_state: ::core::option::Option<CheckAlertState>,
#[prost(string, optional, tag = "3")]
pub review_notes: ::core::option::Option<::prost::alloc::string::String>,
#[prost(string, repeated, tag = "4")]
pub assignee_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FindDataReviewsRequest {
#[prost(string, repeated, tag = "1")]
pub run_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(string, repeated, tag = "2")]
pub asset_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(bool, optional, tag = "3")]
pub filter_by_both_runs_and_assets: ::core::option::Option<bool>,
#[prost(message, repeated, tag = "4")]
pub checklist_refs: ::prost::alloc::vec::Vec<ChecklistRef>,
#[prost(string, optional, tag = "5")]
pub next_page_token: ::core::option::Option<::prost::alloc::string::String>,
#[prost(int32, optional, tag = "6")]
pub page_size: ::core::option::Option<i32>,
#[prost(bool, optional, tag = "7")]
pub show_archived: ::core::option::Option<bool>,
#[prost(message, optional, tag = "8")]
pub archived_statuses: ::core::option::Option<ArchivedStatusSetWrapper>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GeneratedAlertsState {
#[prost(message, optional, tag = "1")]
pub rids: ::core::option::Option<CheckAlertRidSetWrapper>,
#[prost(string, repeated, tag = "2")]
pub event_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetDataReviewCheckMetricsRequest {
#[prost(message, optional, tag = "1")]
pub scope: ::core::option::Option<DataReviewCheckMetricsScope>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct GetDataReviewCheckMetricsResponse {
#[prost(int32, tag = "1")]
pub checks_pending_execution: i32,
#[prost(int32, tag = "2")]
pub checks_executing: i32,
#[prost(int32, tag = "3")]
pub checks_passed: i32,
#[prost(int32, tag = "4")]
pub checks_with_events_pending_review: i32,
#[prost(int32, tag = "5")]
pub checks_with_events_closed_with_ignore: i32,
#[prost(int32, tag = "6")]
pub checks_with_events_closed_with_further_action: i32,
#[prost(int32, tag = "7")]
pub checks_with_events: i32,
#[prost(int32, tag = "8")]
pub checks_with_too_many_events: i32,
#[prost(int32, tag = "9")]
pub checks_failed_to_execute_pending_review: i32,
#[prost(int32, tag = "10")]
pub checks_failed_to_execute_closed_with_ignore: i32,
#[prost(int32, tag = "11")]
pub checks_failed_to_execute_closed_with_further_action: i32,
#[prost(int32, tag = "12")]
pub checks_failed_to_execute: i32,
#[prost(int32, tag = "13")]
pub checks_executed: i32,
#[prost(int32, tag = "14")]
pub checks_total: i32,
#[prost(int32, tag = "15")]
pub events_pending_review: i32,
#[prost(int32, tag = "16")]
pub events_closed_with_ignore: i32,
#[prost(int32, tag = "17")]
pub events_closed_with_further_action: i32,
#[prost(int32, tag = "18")]
pub events_total: i32,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct HistogramBucket {
#[prost(message, optional, tag = "1")]
pub start_inclusive: ::core::option::Option<Timestamp>,
#[prost(message, optional, tag = "2")]
pub end_exclusive: ::core::option::Option<Timestamp>,
#[prost(int32, tag = "3")]
pub count: i32,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct HistogramDistributionVariable {
#[prost(
oneof = "histogram_distribution_variable::HistogramDistributionVariable",
tags = "1"
)]
pub histogram_distribution_variable: ::core::option::Option<
histogram_distribution_variable::HistogramDistributionVariable,
>,
}
pub mod histogram_distribution_variable {
#[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
pub enum HistogramDistributionVariable {
#[prost(message, tag = "1")]
StartTime(super::HistogramStartTimeVariable),
}
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct HistogramEndTimeVariable {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct HistogramPriorityBucket {
#[prost(message, optional, tag = "1")]
pub start_inclusive: ::core::option::Option<Timestamp>,
#[prost(message, optional, tag = "2")]
pub end_exclusive: ::core::option::Option<Timestamp>,
#[prost(map = "string, int32", tag = "3")]
pub counts: ::std::collections::HashMap<::prost::alloc::string::String, i32>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct HistogramPriorityVariable {}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct HistogramStartTimeVariable {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct HistogramStatusBucket {
#[prost(message, optional, tag = "1")]
pub start_inclusive: ::core::option::Option<Timestamp>,
#[prost(message, optional, tag = "2")]
pub end_exclusive: ::core::option::Option<Timestamp>,
#[prost(map = "string, int32", tag = "3")]
pub counts: ::std::collections::HashMap<::prost::alloc::string::String, i32>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct HistogramStatusVariable {}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct HistogramSubGroupVariable {
#[prost(
oneof = "histogram_sub_group_variable::HistogramSubGroupVariable",
tags = "1, 2"
)]
pub histogram_sub_group_variable: ::core::option::Option<
histogram_sub_group_variable::HistogramSubGroupVariable,
>,
}
pub mod histogram_sub_group_variable {
#[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
pub enum HistogramSubGroupVariable {
#[prost(message, tag = "1")]
Priority(super::HistogramPriorityVariable),
#[prost(message, tag = "2")]
Status(super::HistogramStatusVariable),
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct LinkNotebook {
#[prost(string, tag = "1")]
pub rid: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub strategy: ::core::option::Option<LinkNotebookStrategy>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct LinkNotebookStrategy {
#[prost(oneof = "link_notebook_strategy::LinkNotebookStrategy", tags = "1, 2, 3")]
pub link_notebook_strategy: ::core::option::Option<
link_notebook_strategy::LinkNotebookStrategy,
>,
}
pub mod link_notebook_strategy {
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum LinkNotebookStrategy {
#[prost(message, tag = "1")]
DuplicateAndLinkToNewNotebook(super::DuplicateAndLinkNotebook),
#[prost(message, tag = "2")]
CloseAndLink(super::CloseAndLinkToNotebook),
#[prost(message, tag = "3")]
ReopenAndLink(super::ReopenAndLinkToNotebook),
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ManualCheckAlertAction {
#[prost(
oneof = "manual_check_alert_action::ManualCheckAlertAction",
tags = "1, 2, 3, 4, 5, 6"
)]
pub manual_check_alert_action: ::core::option::Option<
manual_check_alert_action::ManualCheckAlertAction,
>,
}
pub mod manual_check_alert_action {
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum ManualCheckAlertAction {
#[prost(message, tag = "1")]
Pass(super::Pass),
#[prost(message, tag = "2")]
CloseWithFurtherAction(super::CloseWithFurtherAction),
#[prost(message, tag = "3")]
Reopen(super::Reopen),
#[prost(message, tag = "4")]
Reassign(super::Reassign),
#[prost(message, tag = "5")]
UpdateNotes(super::UpdateNotes),
#[prost(message, tag = "6")]
LinkNotebook(super::LinkNotebook),
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ManualCheckEvaluation {
#[prost(string, tag = "1")]
pub rid: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub check_rid: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub data_review_rid: ::prost::alloc::string::String,
#[prost(message, optional, tag = "4")]
pub state: ::core::option::Option<ManualCheckEvaluationState>,
#[prost(string, repeated, tag = "5")]
pub assignee_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(message, optional, tag = "6")]
pub chart: ::core::option::Option<VersionedVizId>,
#[prost(string, optional, tag = "7")]
pub notes: ::core::option::Option<::prost::alloc::string::String>,
#[prost(string, optional, tag = "8")]
pub notebook: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ManualCheckEvaluationActionLog {
#[prost(message, repeated, tag = "1")]
pub entries: ::prost::alloc::vec::Vec<ManualCheckEvaluationActionLogEntry>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ManualCheckEvaluationActionLogEntry {
#[prost(string, tag = "1")]
pub performed_by: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub action: ::core::option::Option<ManualCheckAlertAction>,
#[prost(message, optional, tag = "3")]
pub timestamp: ::core::option::Option<
super::super::super::google::protobuf::Timestamp,
>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ManualCheckEvaluationState {
#[prost(
oneof = "manual_check_evaluation_state::ManualCheckEvaluationState",
tags = "1, 2, 3"
)]
pub manual_check_evaluation_state: ::core::option::Option<
manual_check_evaluation_state::ManualCheckEvaluationState,
>,
}
pub mod manual_check_evaluation_state {
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum ManualCheckEvaluationState {
#[prost(message, tag = "1")]
PendingReview(super::PendingReviewState),
#[prost(message, tag = "2")]
ClosedWithFurtherAction(super::ClosedWithFurtherActionState),
#[prost(message, tag = "3")]
Passing(super::PassState),
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Pass {
#[prost(string, tag = "1")]
pub comment: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PassState {
#[prost(string, tag = "1")]
pub comment: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub closed_by: ::prost::alloc::string::String,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct PassingExecutionState {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PendingExecutionState {
#[prost(string, tag = "1")]
pub job_rid: ::prost::alloc::string::String,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct PendingReviewState {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Reassign {
#[prost(string, repeated, tag = "1")]
pub assignee_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Reopen {
#[prost(string, tag = "1")]
pub comment: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub strategy: ::core::option::Option<ReopenStrategy>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct ReopenAllLinkedAlerts {}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct ReopenAndDetachFromNotebook {}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct ReopenAndDuplicatePreviouslyLinkedNotebook {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ReopenAndLinkToNotebook {
#[prost(string, tag = "1")]
pub comment: ::prost::alloc::string::String,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct ReopenStrategy {
#[prost(oneof = "reopen_strategy::ReopenStrategy", tags = "1, 2, 3")]
pub reopen_strategy: ::core::option::Option<reopen_strategy::ReopenStrategy>,
}
pub mod reopen_strategy {
#[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
pub enum ReopenStrategy {
#[prost(message, tag = "1")]
ReopenAllLinkedAlerts(super::ReopenAllLinkedAlerts),
#[prost(message, tag = "2")]
ReopenAndDetachFromNotebook(super::ReopenAndDetachFromNotebook),
#[prost(message, tag = "3")]
ReopenAndDuplicatePreviouslyLinkedNotebook(
super::ReopenAndDuplicatePreviouslyLinkedNotebook,
),
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RerunFailedAutomaticChecksRequest {
#[prost(string, tag = "1")]
pub data_review_rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SearchCheckAlertsRequest {
#[prost(string, optional, tag = "1")]
pub next_page_token: ::core::option::Option<::prost::alloc::string::String>,
#[prost(int32, optional, tag = "2")]
pub page_size: ::core::option::Option<i32>,
#[prost(message, optional, tag = "3")]
pub sort_by: ::core::option::Option<SearchCheckAlertsSortOptions>,
#[prost(string, optional, tag = "4")]
pub search_text: ::core::option::Option<::prost::alloc::string::String>,
#[prost(message, optional, tag = "5")]
pub after: ::core::option::Option<Timestamp>,
#[prost(message, optional, tag = "6")]
pub before: ::core::option::Option<Timestamp>,
#[prost(message, optional, tag = "7")]
pub status: ::core::option::Option<CheckAlertStatusSetWrapper>,
#[prost(message, optional, tag = "8")]
pub check_rids: ::core::option::Option<CheckRidSetWrapper>,
#[prost(message, optional, tag = "9")]
pub data_review_rids: ::core::option::Option<DataReviewRidSetWrapper>,
#[prost(message, optional, tag = "10")]
pub assignee_rids: ::core::option::Option<UserRidSetWrapper>,
#[prost(message, optional, tag = "11")]
pub priorities: ::core::option::Option<PrioritySetWrapper>,
#[prost(string, repeated, tag = "12")]
pub run_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(string, repeated, tag = "13")]
pub asset_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(message, optional, tag = "14")]
pub pinned_checklist_refs: ::core::option::Option<PinnedChecklistRefSetWrapper>,
#[prost(message, optional, tag = "15")]
pub chart_rids: ::core::option::Option<VersionedVizIdSetWrapper>,
#[prost(message, optional, tag = "16")]
pub notebook_rids: ::core::option::Option<NotebookRidSetWrapper>,
#[prost(bool, optional, tag = "17")]
pub show_archived: ::core::option::Option<bool>,
#[prost(message, optional, tag = "18")]
pub archived_statuses: ::core::option::Option<ArchivedStatusSetWrapper>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SearchCheckAlertsResponse {
#[prost(string, optional, tag = "1")]
pub next_page_token: ::core::option::Option<::prost::alloc::string::String>,
#[prost(message, repeated, tag = "2")]
pub check_alerts: ::prost::alloc::vec::Vec<CheckAlert>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct SearchCheckAlertsSortOptions {
#[prost(bool, tag = "1")]
pub is_descending: bool,
#[prost(enumeration = "SearchCheckAlertsSortField", tag = "2")]
pub field: i32,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct TooManyAlertsState {}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct UnarchiveDataReview {}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct UnlinkNotebook {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateNotes {
#[prost(string, tag = "1")]
pub notes: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ArchivedStatusSetWrapper {
#[prost(enumeration = "super::super::types::ArchivedStatus", repeated, tag = "1")]
pub archived_statuses: ::prost::alloc::vec::Vec<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CheckAlertStatusSetWrapper {
#[prost(enumeration = "CheckAlertStatus", repeated, tag = "1")]
pub status: ::prost::alloc::vec::Vec<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CheckRidSetWrapper {
#[prost(string, repeated, tag = "1")]
pub check_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CheckAlertRidSetWrapper {
#[prost(string, repeated, tag = "1")]
pub rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DataReviewRidSetWrapper {
#[prost(string, repeated, tag = "1")]
pub data_review_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UserRidSetWrapper {
#[prost(string, repeated, tag = "1")]
pub assignee_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PrioritySetWrapper {
#[prost(enumeration = "super::super::types::Priority", repeated, tag = "1")]
pub priorities: ::prost::alloc::vec::Vec<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PinnedChecklistRefSetWrapper {
#[prost(message, repeated, tag = "1")]
pub pinned_checklist_refs: ::prost::alloc::vec::Vec<PinnedChecklistRef>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct VersionedVizIdSetWrapper {
#[prost(message, repeated, tag = "1")]
pub chart_rids: ::prost::alloc::vec::Vec<VersionedVizId>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct NotebookRidSetWrapper {
#[prost(string, repeated, tag = "1")]
pub notebook_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct RerunFailedAutomaticChecksResponse {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FindDataReviewsResponse {
#[prost(message, optional, tag = "1")]
pub data_review_page: ::core::option::Option<DataReviewPage>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetRequest {
#[prost(string, tag = "1")]
pub data_review_rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetResponse {
#[prost(message, optional, tag = "1")]
pub data_review: ::core::option::Option<DataReview>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetCheckAlertRequest {
#[prost(string, tag = "1")]
pub check_alert_rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetCheckAlertResponse {
#[prost(message, optional, tag = "1")]
pub check_alert: ::core::option::Option<CheckAlert>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetCheckAlertsForDataReviewRequest {
#[prost(string, tag = "1")]
pub data_review_rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetCheckAlertsForDataReviewResponse {
#[prost(message, repeated, tag = "1")]
pub check_alerts: ::prost::alloc::vec::Vec<CheckAlert>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetCheckAlertActionLogRequest {
#[prost(string, tag = "1")]
pub check_alert_rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetCheckAlertActionLogResponse {
#[prost(message, optional, tag = "1")]
pub check_alert_action_log: ::core::option::Option<CheckAlertActionLog>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetCheckAlertCountsForNotebooksRequest {
#[prost(string, repeated, tag = "1")]
pub rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetCheckAlertCountsForNotebooksResponse {
#[prost(map = "string, int32", tag = "1")]
pub responses: ::std::collections::HashMap<::prost::alloc::string::String, i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetCheckAlertStatusForNotebooksRequest {
#[prost(string, repeated, tag = "1")]
pub rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetCheckAlertStatusForNotebooksResponse {
#[prost(map = "string, message", tag = "1")]
pub responses: ::std::collections::HashMap<
::prost::alloc::string::String,
CheckAlertStatusWrapper,
>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct CheckAlertStatusWrapper {
#[prost(enumeration = "CheckAlertStatus", optional, tag = "1")]
pub value: ::core::option::Option<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PerformCheckAlertActionRequest {
#[prost(string, tag = "1")]
pub check_alert_rid: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub request: ::core::option::Option<CheckAlertAction>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PerformCheckAlertActionResponse {
#[prost(message, optional, tag = "1")]
pub check_alert: ::core::option::Option<CheckAlert>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetAutomaticCheckEvaluationActionLogRequest {
#[prost(string, tag = "1")]
pub rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetAutomaticCheckEvaluationActionLogResponse {
#[prost(message, optional, tag = "1")]
pub automatic_check_evaluation_action_log: ::core::option::Option<
AutomaticCheckEvaluationActionLog,
>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct BatchPerformManualCheckAlertActionResponse {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetManualCheckEvaluationActionLogRequest {
#[prost(string, tag = "1")]
pub rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetManualCheckEvaluationActionLogResponse {
#[prost(message, optional, tag = "1")]
pub manual_check_evaluation_action_log: ::core::option::Option<
ManualCheckEvaluationActionLog,
>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ArchiveDataReviewRequest {
#[prost(string, tag = "1")]
pub data_review_rid: ::prost::alloc::string::String,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct ArchiveDataReviewResponse {
#[prost(bool, tag = "1")]
pub archived: bool,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchArchiveDataReviewRequest {
#[prost(string, repeated, tag = "1")]
pub rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct BatchArchiveDataReviewResponse {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UnarchiveDataReviewRequest {
#[prost(string, tag = "1")]
pub data_review_rid: ::prost::alloc::string::String,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct UnarchiveDataReviewResponse {}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum NotificationFilter {
Unspecified = 0,
ExecutionError = 1,
}
impl NotificationFilter {
pub fn as_str_name(&self) -> &'static str {
match self {
Self::Unspecified => "NOTIFICATION_FILTER_UNSPECIFIED",
Self::ExecutionError => "EXECUTION_ERROR",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"NOTIFICATION_FILTER_UNSPECIFIED" => Some(Self::Unspecified),
"EXECUTION_ERROR" => Some(Self::ExecutionError),
_ => None,
}
}
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum CheckAlertStatus {
Unspecified = 0,
PendingReview = 1,
ClosedIgnored = 2,
ClosedRequiresFurtherAction = 3,
}
impl CheckAlertStatus {
pub fn as_str_name(&self) -> &'static str {
match self {
Self::Unspecified => "CHECK_ALERT_STATUS_UNSPECIFIED",
Self::PendingReview => "PENDING_REVIEW",
Self::ClosedIgnored => "CLOSED_IGNORED",
Self::ClosedRequiresFurtherAction => "CLOSED_REQUIRES_FURTHER_ACTION",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"CHECK_ALERT_STATUS_UNSPECIFIED" => Some(Self::Unspecified),
"PENDING_REVIEW" => Some(Self::PendingReview),
"CLOSED_IGNORED" => Some(Self::ClosedIgnored),
"CLOSED_REQUIRES_FURTHER_ACTION" => Some(Self::ClosedRequiresFurtherAction),
_ => None,
}
}
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SearchCheckAlertsSortField {
Unspecified = 0,
CheckName = 1,
Start = 2,
End = 3,
Status = 4,
Priority = 5,
Duration = 6,
}
impl SearchCheckAlertsSortField {
pub fn as_str_name(&self) -> &'static str {
match self {
Self::Unspecified => "SEARCH_CHECK_ALERTS_SORT_FIELD_UNSPECIFIED",
Self::CheckName => "CHECK_NAME",
Self::Start => "START",
Self::End => "END",
Self::Status => "STATUS",
Self::Priority => "PRIORITY",
Self::Duration => "DURATION",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"SEARCH_CHECK_ALERTS_SORT_FIELD_UNSPECIFIED" => Some(Self::Unspecified),
"CHECK_NAME" => Some(Self::CheckName),
"START" => Some(Self::Start),
"END" => Some(Self::End),
"STATUS" => Some(Self::Status),
"PRIORITY" => Some(Self::Priority),
"DURATION" => Some(Self::Duration),
_ => None,
}
}
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum Status {
Unspecified = 0,
Pass = 1,
Fail = 2,
}
impl Status {
pub fn as_str_name(&self) -> &'static str {
match self {
Self::Unspecified => "STATUS_UNSPECIFIED",
Self::Pass => "PASS",
Self::Fail => "FAIL",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"STATUS_UNSPECIFIED" => Some(Self::Unspecified),
"PASS" => Some(Self::Pass),
"FAIL" => Some(Self::Fail),
_ => None,
}
}
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum DataReviewError {
InvalidDataReviewRequest = 0,
}
impl DataReviewError {
pub fn as_str_name(&self) -> &'static str {
match self {
Self::InvalidDataReviewRequest => {
"DATA_REVIEW_ERROR_INVALID_DATA_REVIEW_REQUEST"
}
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"DATA_REVIEW_ERROR_INVALID_DATA_REVIEW_REQUEST" => {
Some(Self::InvalidDataReviewRequest)
}
_ => None,
}
}
}
pub mod data_review_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 DataReviewServiceClient<T> {
inner: tonic::client::Grpc<T>,
}
impl DataReviewServiceClient<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> DataReviewServiceClient<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,
) -> DataReviewServiceClient<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,
{
DataReviewServiceClient::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 batch_initiate(
&mut self,
request: impl tonic::IntoRequest<super::BatchInitiateDataReviewRequest>,
) -> std::result::Result<
tonic::Response<super::BatchInitiateDataReviewResponse>,
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.datareview.v1.DataReviewService/BatchInitiate",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"nominal.datareview.v1.DataReviewService",
"BatchInitiate",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn rerun_failed_automatic_checks(
&mut self,
request: impl tonic::IntoRequest<super::RerunFailedAutomaticChecksRequest>,
) -> std::result::Result<
tonic::Response<super::RerunFailedAutomaticChecksResponse>,
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.datareview.v1.DataReviewService/RerunFailedAutomaticChecks",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"nominal.datareview.v1.DataReviewService",
"RerunFailedAutomaticChecks",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn find_data_reviews(
&mut self,
request: impl tonic::IntoRequest<super::FindDataReviewsRequest>,
) -> std::result::Result<
tonic::Response<super::FindDataReviewsResponse>,
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.datareview.v1.DataReviewService/FindDataReviews",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"nominal.datareview.v1.DataReviewService",
"FindDataReviews",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get(
&mut self,
request: impl tonic::IntoRequest<super::GetRequest>,
) -> std::result::Result<tonic::Response<super::GetResponse>, 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.datareview.v1.DataReviewService/Get",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("nominal.datareview.v1.DataReviewService", "Get"),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_check_alert(
&mut self,
request: impl tonic::IntoRequest<super::GetCheckAlertRequest>,
) -> std::result::Result<
tonic::Response<super::GetCheckAlertResponse>,
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.datareview.v1.DataReviewService/GetCheckAlert",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"nominal.datareview.v1.DataReviewService",
"GetCheckAlert",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_check_alerts_for_data_review(
&mut self,
request: impl tonic::IntoRequest<super::GetCheckAlertsForDataReviewRequest>,
) -> std::result::Result<
tonic::Response<super::GetCheckAlertsForDataReviewResponse>,
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.datareview.v1.DataReviewService/GetCheckAlertsForDataReview",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"nominal.datareview.v1.DataReviewService",
"GetCheckAlertsForDataReview",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_check_alerts_histogram(
&mut self,
request: impl tonic::IntoRequest<super::CheckAlertsHistogramRequest>,
) -> std::result::Result<
tonic::Response<super::CheckAlertsHistogramResponse>,
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.datareview.v1.DataReviewService/GetCheckAlertsHistogram",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"nominal.datareview.v1.DataReviewService",
"GetCheckAlertsHistogram",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn search_check_alerts(
&mut self,
request: impl tonic::IntoRequest<super::SearchCheckAlertsRequest>,
) -> std::result::Result<
tonic::Response<super::SearchCheckAlertsResponse>,
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.datareview.v1.DataReviewService/SearchCheckAlerts",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"nominal.datareview.v1.DataReviewService",
"SearchCheckAlerts",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_check_alert_action_log(
&mut self,
request: impl tonic::IntoRequest<super::GetCheckAlertActionLogRequest>,
) -> std::result::Result<
tonic::Response<super::GetCheckAlertActionLogResponse>,
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.datareview.v1.DataReviewService/GetCheckAlertActionLog",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"nominal.datareview.v1.DataReviewService",
"GetCheckAlertActionLog",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_check_alert_counts_for_notebooks(
&mut self,
request: impl tonic::IntoRequest<
super::GetCheckAlertCountsForNotebooksRequest,
>,
) -> std::result::Result<
tonic::Response<super::GetCheckAlertCountsForNotebooksResponse>,
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.datareview.v1.DataReviewService/GetCheckAlertCountsForNotebooks",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"nominal.datareview.v1.DataReviewService",
"GetCheckAlertCountsForNotebooks",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_check_alert_status_for_notebooks(
&mut self,
request: impl tonic::IntoRequest<
super::GetCheckAlertStatusForNotebooksRequest,
>,
) -> std::result::Result<
tonic::Response<super::GetCheckAlertStatusForNotebooksResponse>,
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.datareview.v1.DataReviewService/GetCheckAlertStatusForNotebooks",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"nominal.datareview.v1.DataReviewService",
"GetCheckAlertStatusForNotebooks",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn perform_check_alert_action(
&mut self,
request: impl tonic::IntoRequest<super::PerformCheckAlertActionRequest>,
) -> std::result::Result<
tonic::Response<super::PerformCheckAlertActionResponse>,
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.datareview.v1.DataReviewService/PerformCheckAlertAction",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"nominal.datareview.v1.DataReviewService",
"PerformCheckAlertAction",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn batch_perform_check_alert_action(
&mut self,
request: impl tonic::IntoRequest<super::BatchCheckAlertActionRequest>,
) -> std::result::Result<
tonic::Response<super::BatchCheckAlertActionResponse>,
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.datareview.v1.DataReviewService/BatchPerformCheckAlertAction",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"nominal.datareview.v1.DataReviewService",
"BatchPerformCheckAlertAction",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn batch_perform_automatic_check_evaluation_review_action(
&mut self,
request: impl tonic::IntoRequest<
super::BatchAutomaticCheckEvaluationActionRequest,
>,
) -> std::result::Result<
tonic::Response<super::BatchAutomaticCheckEvaluationActionResponse>,
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.datareview.v1.DataReviewService/BatchPerformAutomaticCheckEvaluationReviewAction",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"nominal.datareview.v1.DataReviewService",
"BatchPerformAutomaticCheckEvaluationReviewAction",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_automatic_check_evaluation_action_log(
&mut self,
request: impl tonic::IntoRequest<
super::GetAutomaticCheckEvaluationActionLogRequest,
>,
) -> std::result::Result<
tonic::Response<super::GetAutomaticCheckEvaluationActionLogResponse>,
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.datareview.v1.DataReviewService/GetAutomaticCheckEvaluationActionLog",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"nominal.datareview.v1.DataReviewService",
"GetAutomaticCheckEvaluationActionLog",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn batch_perform_manual_check_alert_action(
&mut self,
request: impl tonic::IntoRequest<
super::BatchManualCheckEvaluationActionRequest,
>,
) -> std::result::Result<
tonic::Response<super::BatchPerformManualCheckAlertActionResponse>,
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.datareview.v1.DataReviewService/BatchPerformManualCheckAlertAction",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"nominal.datareview.v1.DataReviewService",
"BatchPerformManualCheckAlertAction",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_manual_check_evaluation_action_log(
&mut self,
request: impl tonic::IntoRequest<
super::GetManualCheckEvaluationActionLogRequest,
>,
) -> std::result::Result<
tonic::Response<super::GetManualCheckEvaluationActionLogResponse>,
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.datareview.v1.DataReviewService/GetManualCheckEvaluationActionLog",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"nominal.datareview.v1.DataReviewService",
"GetManualCheckEvaluationActionLog",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn archive_data_review(
&mut self,
request: impl tonic::IntoRequest<super::ArchiveDataReviewRequest>,
) -> std::result::Result<
tonic::Response<super::ArchiveDataReviewResponse>,
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.datareview.v1.DataReviewService/ArchiveDataReview",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"nominal.datareview.v1.DataReviewService",
"ArchiveDataReview",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn batch_archive_data_review(
&mut self,
request: impl tonic::IntoRequest<super::BatchArchiveDataReviewRequest>,
) -> std::result::Result<
tonic::Response<super::BatchArchiveDataReviewResponse>,
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.datareview.v1.DataReviewService/BatchArchiveDataReview",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"nominal.datareview.v1.DataReviewService",
"BatchArchiveDataReview",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn unarchive_data_review(
&mut self,
request: impl tonic::IntoRequest<super::UnarchiveDataReviewRequest>,
) -> std::result::Result<
tonic::Response<super::UnarchiveDataReviewResponse>,
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.datareview.v1.DataReviewService/UnarchiveDataReview",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"nominal.datareview.v1.DataReviewService",
"UnarchiveDataReview",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_data_review_check_metrics(
&mut self,
request: impl tonic::IntoRequest<super::GetDataReviewCheckMetricsRequest>,
) -> std::result::Result<
tonic::Response<super::GetDataReviewCheckMetricsResponse>,
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.datareview.v1.DataReviewService/GetDataReviewCheckMetrics",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"nominal.datareview.v1.DataReviewService",
"GetDataReviewCheckMetrics",
),
);
self.inner.unary(req, path, codec).await
}
}
}