1#[derive(Clone, PartialEq, ::prost::Message)]
3pub struct VersionedVizId {
4 #[prost(string, tag = "1")]
5 pub rid: ::prost::alloc::string::String,
6 #[prost(int32, tag = "2")]
7 pub version: i32,
8}
9#[derive(Clone, PartialEq, ::prost::Message)]
10pub struct PinnedChecklistRef {
11 #[prost(string, tag = "1")]
12 pub rid: ::prost::alloc::string::String,
13 #[prost(string, tag = "2")]
14 pub commit: ::prost::alloc::string::String,
15}
16#[derive(Clone, PartialEq, ::prost::Message)]
17pub struct ChecklistRef {
18 #[prost(string, tag = "1")]
19 pub rid: ::prost::alloc::string::String,
20 #[prost(string, optional, tag = "2")]
21 pub commit: ::core::option::Option<::prost::alloc::string::String>,
22}
23#[derive(Clone, PartialEq, ::prost::Message)]
24pub struct NotificationConfiguration {
25 #[prost(string, tag = "1")]
26 pub integration_rid: ::prost::alloc::string::String,
27 #[prost(enumeration = "NotificationFilter", repeated, tag = "2")]
28 pub notification_filters: ::prost::alloc::vec::Vec<i32>,
29 #[prost(string, optional, tag = "3")]
30 pub appended_workbook_rid: ::core::option::Option<::prost::alloc::string::String>,
31 #[prost(string, repeated, tag = "4")]
32 pub tags: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
33 #[prost(message, optional, tag = "5")]
34 pub mute_until: ::core::option::Option<
35 super::super::super::google::protobuf::Timestamp,
36 >,
37}
38#[derive(Clone, PartialEq, ::prost::Message)]
39pub struct CheckAlertState {
40 #[prost(oneof = "check_alert_state::CheckAlertState", tags = "1, 2, 3")]
41 pub check_alert_state: ::core::option::Option<check_alert_state::CheckAlertState>,
42}
43pub mod check_alert_state {
45 #[derive(Clone, PartialEq, ::prost::Oneof)]
46 pub enum CheckAlertState {
47 #[prost(message, tag = "1")]
48 PendingReview(super::PendingReviewAlertState),
49 #[prost(message, tag = "2")]
50 ClosedWithFurtherAction(super::ClosedWithFurtherActionAlertState),
51 #[prost(message, tag = "3")]
52 ClosedWithIgnore(super::ClosedWithIgnoreAlertState),
53 }
54}
55#[derive(Clone, Copy, PartialEq, ::prost::Message)]
56pub struct PendingReviewAlertState {}
57#[derive(Clone, PartialEq, ::prost::Message)]
58pub struct ClosedWithFurtherActionAlertState {
59 #[prost(string, tag = "1")]
60 pub comment: ::prost::alloc::string::String,
61 #[prost(string, tag = "2")]
62 pub closed_by: ::prost::alloc::string::String,
63}
64#[derive(Clone, PartialEq, ::prost::Message)]
65pub struct ClosedWithIgnoreAlertState {
66 #[prost(string, tag = "1")]
67 pub comment: ::prost::alloc::string::String,
68 #[prost(string, tag = "2")]
69 pub closed_by: ::prost::alloc::string::String,
70}
71#[derive(Clone, Copy, PartialEq, ::prost::Message)]
72pub struct ArchiveDataReview {}
73#[derive(Clone, Copy, PartialEq, ::prost::Message)]
74pub struct UnarchiveDataReview {}
75#[derive(Clone, PartialEq, ::prost::Message)]
76pub struct AutomaticCheckEvaluation {
77 #[prost(string, tag = "1")]
78 pub rid: ::prost::alloc::string::String,
79 #[prost(string, tag = "2")]
80 pub check_rid: ::prost::alloc::string::String,
81 #[prost(int32, optional, tag = "3")]
82 pub check_implementation_index: ::core::option::Option<i32>,
83 #[prost(string, tag = "4")]
84 pub data_review_rid: ::prost::alloc::string::String,
85 #[prost(message, optional, tag = "5")]
86 pub state: ::core::option::Option<AutomaticCheckEvaluationState>,
87}
88#[derive(Clone, PartialEq, ::prost::Message)]
89pub struct AutomaticCheckEvaluationAction {
90 #[prost(
91 oneof = "automatic_check_evaluation_action::AutomaticCheckEvaluationAction",
92 tags = "1, 2, 3, 4"
93 )]
94 pub automatic_check_evaluation_action: ::core::option::Option<
95 automatic_check_evaluation_action::AutomaticCheckEvaluationAction,
96 >,
97}
98pub mod automatic_check_evaluation_action {
100 #[derive(Clone, PartialEq, ::prost::Oneof)]
101 pub enum AutomaticCheckEvaluationAction {
102 #[prost(message, tag = "1")]
103 ExecutionFinished(super::AutomaticCheckExecutionFinished),
104 #[prost(message, tag = "2")]
105 ExecutionFailedToRun(super::AutomaticCheckExecutionFailedToRun),
106 #[prost(message, tag = "3")]
107 ExecutionRetriggered(super::ExecutionRetriggered),
108 #[prost(message, tag = "4")]
109 ExecutionStarted(super::AutomaticCheckExecutionStarted),
110 }
111}
112#[derive(Clone, PartialEq, ::prost::Message)]
113pub struct AutomaticCheckEvaluationActionLog {
114 #[prost(message, repeated, tag = "1")]
115 pub entries: ::prost::alloc::vec::Vec<AutomaticCheckEvaluationActionLogEntry>,
116}
117#[derive(Clone, PartialEq, ::prost::Message)]
118pub struct AutomaticCheckEvaluationActionLogEntry {
119 #[prost(message, optional, tag = "1")]
120 pub action: ::core::option::Option<AutomaticCheckEvaluationAction>,
121 #[prost(message, optional, tag = "2")]
122 pub timestamp: ::core::option::Option<
123 super::super::super::google::protobuf::Timestamp,
124 >,
125}
126#[derive(Clone, PartialEq, ::prost::Message)]
127pub struct AutomaticCheckEvaluationReviewAction {
128 #[prost(
129 oneof = "automatic_check_evaluation_review_action::AutomaticCheckEvaluationReviewAction",
130 tags = "1, 2, 3, 4, 5"
131 )]
132 pub automatic_check_evaluation_review_action: ::core::option::Option<
133 automatic_check_evaluation_review_action::AutomaticCheckEvaluationReviewAction,
134 >,
135}
136pub mod automatic_check_evaluation_review_action {
138 #[derive(Clone, PartialEq, ::prost::Oneof)]
139 pub enum AutomaticCheckEvaluationReviewAction {
140 #[prost(message, tag = "1")]
141 CloseWithIgnore(super::CloseWithIgnoreAlert),
142 #[prost(message, tag = "2")]
143 CloseWithFurtherAction(super::CloseWithFurtherAction),
144 #[prost(message, tag = "3")]
145 Reopen(super::Reopen),
146 #[prost(message, tag = "4")]
147 Reassign(super::Reassign),
148 #[prost(message, tag = "5")]
149 UpdateNotes(super::UpdateNotes),
150 }
151}
152#[derive(Clone, PartialEq, ::prost::Message)]
153pub struct AutomaticCheckEvaluationReviewActionLog {
154 #[prost(message, repeated, tag = "1")]
155 pub entries: ::prost::alloc::vec::Vec<AutomaticCheckEvaluationReviewActionLogEntry>,
156}
157#[derive(Clone, PartialEq, ::prost::Message)]
158pub struct AutomaticCheckEvaluationReviewActionLogEntry {
159 #[prost(string, tag = "1")]
160 pub performed_by: ::prost::alloc::string::String,
161 #[prost(message, optional, tag = "2")]
162 pub action: ::core::option::Option<AutomaticCheckEvaluationReviewAction>,
163 #[prost(message, optional, tag = "3")]
164 pub timestamp: ::core::option::Option<
165 super::super::super::google::protobuf::Timestamp,
166 >,
167}
168#[derive(Clone, PartialEq, ::prost::Message)]
169pub struct AutomaticCheckEvaluationState {
170 #[prost(
171 oneof = "automatic_check_evaluation_state::AutomaticCheckEvaluationState",
172 tags = "1, 2, 3, 4, 5, 6"
173 )]
174 pub automatic_check_evaluation_state: ::core::option::Option<
175 automatic_check_evaluation_state::AutomaticCheckEvaluationState,
176 >,
177}
178pub mod automatic_check_evaluation_state {
180 #[derive(Clone, PartialEq, ::prost::Oneof)]
181 pub enum AutomaticCheckEvaluationState {
182 #[prost(message, tag = "1")]
183 PendingExecution(super::PendingExecutionState),
184 #[prost(message, tag = "2")]
185 FailedToExecute(super::FailedToExecuteState),
186 #[prost(message, tag = "3")]
187 Passing(super::PassingExecutionState),
188 #[prost(message, tag = "4")]
189 GeneratedAlerts(super::GeneratedAlertsState),
190 #[prost(message, tag = "5")]
191 TooManyAlerts(super::TooManyAlertsState),
192 #[prost(message, tag = "6")]
193 Executing(super::ExecutingState),
194 }
195}
196#[derive(Clone, PartialEq, ::prost::Message)]
197pub struct AutomaticCheckExecutionFailedToRun {
198 #[prost(string, tag = "1")]
199 pub job_rid: ::prost::alloc::string::String,
200}
201#[derive(Clone, PartialEq, ::prost::Message)]
202pub struct AutomaticCheckExecutionFinished {
203 #[prost(string, tag = "1")]
204 pub job_rid: ::prost::alloc::string::String,
205 #[prost(enumeration = "Status", tag = "2")]
206 pub status: i32,
207}
208#[derive(Clone, PartialEq, ::prost::Message)]
209pub struct AutomaticCheckExecutionStarted {
210 #[prost(string, tag = "1")]
211 pub job_rid: ::prost::alloc::string::String,
212}
213#[derive(Clone, PartialEq, ::prost::Message)]
214pub struct CheckAlert {
215 #[prost(string, tag = "1")]
216 pub rid: ::prost::alloc::string::String,
217 #[prost(string, tag = "2")]
218 pub check_rid: ::prost::alloc::string::String,
219 #[prost(int32, optional, tag = "3")]
220 pub implementation_index: ::core::option::Option<i32>,
221 #[prost(string, tag = "4")]
222 pub data_review_rid: ::prost::alloc::string::String,
223 #[prost(string, tag = "5")]
224 pub check_evaluation_rid: ::prost::alloc::string::String,
225 #[prost(string, tag = "6")]
226 pub name: ::prost::alloc::string::String,
227 #[prost(string, optional, tag = "7")]
228 pub autogenerated_check_title: ::core::option::Option<
229 ::prost::alloc::string::String,
230 >,
231 #[prost(string, optional, tag = "8")]
232 pub autogenerated_check_description: ::core::option::Option<
233 ::prost::alloc::string::String,
234 >,
235 #[prost(string, repeated, tag = "9")]
236 pub assignee_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
237 #[prost(message, optional, tag = "10")]
238 pub start: ::core::option::Option<super::super::super::google::protobuf::Timestamp>,
239 #[prost(message, optional, tag = "11")]
240 pub end: ::core::option::Option<super::super::super::google::protobuf::Timestamp>,
241 #[prost(message, optional, tag = "12")]
242 pub state: ::core::option::Option<CheckAlertState>,
243 #[prost(enumeration = "super::super::types::Priority", tag = "13")]
244 pub priority: i32,
245 #[prost(message, optional, tag = "14")]
246 pub chart: ::core::option::Option<VersionedVizId>,
247 #[prost(string, optional, tag = "15")]
248 pub notes: ::core::option::Option<::prost::alloc::string::String>,
249 #[prost(string, optional, tag = "16")]
250 pub notebook: ::core::option::Option<::prost::alloc::string::String>,
251}
252#[derive(Clone, PartialEq, ::prost::Message)]
253pub struct CheckAlertAction {
254 #[prost(
255 oneof = "check_alert_action::CheckAlertAction",
256 tags = "1, 2, 3, 4, 5, 6, 7, 8, 9"
257 )]
258 pub check_alert_action: ::core::option::Option<check_alert_action::CheckAlertAction>,
259}
260pub mod check_alert_action {
262 #[derive(Clone, PartialEq, ::prost::Oneof)]
263 pub enum CheckAlertAction {
264 #[prost(message, tag = "1")]
265 CloseWithIgnore(super::CloseWithIgnoreAlert),
266 #[prost(message, tag = "2")]
267 CloseWithFurtherAction(super::CloseWithFurtherAction),
268 #[prost(message, tag = "3")]
269 Reopen(super::Reopen),
270 #[prost(message, tag = "4")]
271 Reassign(super::Reassign),
272 #[prost(message, tag = "5")]
273 UpdateNotes(super::UpdateNotes),
274 #[prost(message, tag = "6")]
275 LinkNotebook(super::LinkNotebook),
276 #[prost(message, tag = "7")]
277 UnlinkNotebook(super::UnlinkNotebook),
278 #[prost(message, tag = "8")]
279 ArchiveDataReview(super::ArchiveDataReview),
280 #[prost(message, tag = "9")]
281 UnarchiveDataReview(super::UnarchiveDataReview),
282 }
283}
284#[derive(Clone, PartialEq, ::prost::Message)]
285pub struct CheckAlertActionLog {
286 #[prost(message, repeated, tag = "1")]
287 pub entries: ::prost::alloc::vec::Vec<CheckAlertActionLogEntry>,
288}
289#[derive(Clone, PartialEq, ::prost::Message)]
290pub struct CheckAlertActionLogEntry {
291 #[prost(string, tag = "1")]
292 pub performed_by: ::prost::alloc::string::String,
293 #[prost(message, optional, tag = "2")]
294 pub action: ::core::option::Option<CheckAlertAction>,
295 #[prost(message, optional, tag = "3")]
296 pub timestamp: ::core::option::Option<
297 super::super::super::google::protobuf::Timestamp,
298 >,
299}
300#[derive(Clone, PartialEq, ::prost::Message)]
301pub struct CheckAlertsHistogramBuckets {
302 #[prost(
303 oneof = "check_alerts_histogram_buckets::CheckAlertsHistogramBuckets",
304 tags = "1, 2, 3"
305 )]
306 pub check_alerts_histogram_buckets: ::core::option::Option<
307 check_alerts_histogram_buckets::CheckAlertsHistogramBuckets,
308 >,
309}
310pub mod check_alerts_histogram_buckets {
312 #[derive(Clone, PartialEq, ::prost::Oneof)]
313 pub enum CheckAlertsHistogramBuckets {
314 #[prost(message, tag = "1")]
315 Unstacked(super::CheckAlertsUnstackedHistogram),
316 #[prost(message, tag = "2")]
317 Priority(super::CheckAlertsPriorityHistogram),
318 #[prost(message, tag = "3")]
319 Status(super::CheckAlertsStatusHistogram),
320 }
321}
322#[derive(Clone, PartialEq, ::prost::Message)]
323pub struct CheckAlertsPriorityHistogram {
324 #[prost(message, repeated, tag = "1")]
325 pub buckets: ::prost::alloc::vec::Vec<HistogramPriorityBucket>,
326}
327#[derive(Clone, PartialEq, ::prost::Message)]
328pub struct CheckAlertsStatusHistogram {
329 #[prost(message, repeated, tag = "1")]
330 pub buckets: ::prost::alloc::vec::Vec<HistogramStatusBucket>,
331}
332#[derive(Clone, PartialEq, ::prost::Message)]
333pub struct CheckAlertsUnstackedHistogram {
334 #[prost(message, repeated, tag = "1")]
335 pub buckets: ::prost::alloc::vec::Vec<HistogramBucket>,
336}
337#[derive(Clone, PartialEq, ::prost::Message)]
338pub struct CheckEvaluation {
339 #[prost(oneof = "check_evaluation::CheckEvaluation", tags = "1, 2")]
340 pub check_evaluation: ::core::option::Option<check_evaluation::CheckEvaluation>,
341}
342pub mod check_evaluation {
344 #[derive(Clone, PartialEq, ::prost::Oneof)]
345 pub enum CheckEvaluation {
346 #[prost(message, tag = "1")]
347 AutomaticCheck(super::AutomaticCheckEvaluation),
348 #[prost(message, tag = "2")]
349 ManualCheck(super::ManualCheckEvaluation),
350 }
351}
352#[derive(Clone, PartialEq, ::prost::Message)]
353pub struct ChecklistEvaluation {
354 #[prost(message, optional, tag = "1")]
355 pub checklist: ::core::option::Option<PinnedChecklistRef>,
356 #[prost(string, tag = "2")]
357 pub data_review_rid: ::prost::alloc::string::String,
358 #[prost(message, repeated, tag = "3")]
359 pub checks: ::prost::alloc::vec::Vec<CheckEvaluation>,
360}
361#[derive(Clone, PartialEq, ::prost::Message)]
362pub struct CloseAction {
363 #[prost(oneof = "close_action::CloseAction", tags = "1, 2")]
364 pub close_action: ::core::option::Option<close_action::CloseAction>,
365}
366pub mod close_action {
368 #[derive(Clone, PartialEq, ::prost::Oneof)]
369 pub enum CloseAction {
370 #[prost(message, tag = "1")]
371 CloseWithIgnore(super::CloseWithIgnoreAlert),
372 #[prost(message, tag = "2")]
373 CloseWithFurtherAction(super::CloseWithFurtherAction),
374 }
375}
376#[derive(Clone, Copy, PartialEq, ::prost::Message)]
377pub struct CloseAllLinkedAlerts {}
378#[derive(Clone, Copy, PartialEq, ::prost::Message)]
379pub struct CloseAndDetachFromNotebook {}
380#[derive(Clone, Copy, PartialEq, ::prost::Message)]
381pub struct CloseAndDuplicatePreviouslyLinkedNotebook {}
382#[derive(Clone, PartialEq, ::prost::Message)]
383pub struct CloseAndLinkToNotebook {
384 #[prost(message, optional, tag = "1")]
385 pub close_action: ::core::option::Option<CloseAction>,
386}
387#[derive(Clone, Copy, PartialEq, ::prost::Message)]
388pub struct CloseStrategy {
389 #[prost(oneof = "close_strategy::CloseStrategy", tags = "1, 2, 3")]
390 pub close_strategy: ::core::option::Option<close_strategy::CloseStrategy>,
391}
392pub mod close_strategy {
394 #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
395 pub enum CloseStrategy {
396 #[prost(message, tag = "1")]
397 CloseAllLinkedAlerts(super::CloseAllLinkedAlerts),
398 #[prost(message, tag = "2")]
399 CloseAndDetachFromNotebook(super::CloseAndDetachFromNotebook),
400 #[prost(message, tag = "3")]
401 CloseAndDuplicatePreviouslyLinkedNotebook(
402 super::CloseAndDuplicatePreviouslyLinkedNotebook,
403 ),
404 }
405}
406#[derive(Clone, PartialEq, ::prost::Message)]
407pub struct CloseWithFurtherAction {
408 #[prost(string, tag = "1")]
409 pub comment: ::prost::alloc::string::String,
410 #[prost(message, optional, tag = "2")]
411 pub strategy: ::core::option::Option<CloseStrategy>,
412}
413#[derive(Clone, PartialEq, ::prost::Message)]
414pub struct CloseWithIgnoreAlert {
415 #[prost(string, tag = "1")]
416 pub comment: ::prost::alloc::string::String,
417 #[prost(message, optional, tag = "2")]
418 pub strategy: ::core::option::Option<CloseStrategy>,
419}
420#[derive(Clone, PartialEq, ::prost::Message)]
421pub struct ClosedWithFurtherActionState {
422 #[prost(string, tag = "1")]
423 pub comment: ::prost::alloc::string::String,
424 #[prost(string, tag = "2")]
425 pub closed_by: ::prost::alloc::string::String,
426}
427#[derive(Clone, PartialEq, ::prost::Message)]
428pub struct CreateDataReviewRequest {
429 #[prost(string, tag = "1")]
430 pub run_rid: ::prost::alloc::string::String,
431 #[prost(string, optional, tag = "2")]
432 pub asset_rid: ::core::option::Option<::prost::alloc::string::String>,
433 #[prost(string, tag = "3")]
434 pub checklist_rid: ::prost::alloc::string::String,
435 #[prost(string, optional, tag = "4")]
436 pub commit: ::core::option::Option<::prost::alloc::string::String>,
437}
438#[derive(Clone, PartialEq, ::prost::Message)]
439pub struct DataReview {
440 #[prost(string, tag = "1")]
441 pub rid: ::prost::alloc::string::String,
442 #[prost(string, tag = "2")]
443 pub run_rid: ::prost::alloc::string::String,
444 #[prost(string, tag = "3")]
445 pub asset_rid: ::prost::alloc::string::String,
446 #[prost(message, optional, tag = "4")]
447 pub created_at: ::core::option::Option<
448 super::super::super::google::protobuf::Timestamp,
449 >,
450 #[prost(string, tag = "5")]
451 pub created_by: ::prost::alloc::string::String,
452 #[prost(message, optional, tag = "6")]
453 pub checklist: ::core::option::Option<ChecklistEvaluation>,
454 #[prost(message, optional, tag = "7")]
455 pub checklist_ref: ::core::option::Option<PinnedChecklistRef>,
456 #[prost(message, repeated, tag = "8")]
457 pub check_evaluations: ::prost::alloc::vec::Vec<AutomaticCheckEvaluation>,
458 #[prost(bool, tag = "9")]
459 pub archived: bool,
460}
461#[derive(Clone, PartialEq, ::prost::Message)]
462pub struct DataReviewCheckMetricsScope {
463 #[prost(
464 oneof = "data_review_check_metrics_scope::DataReviewCheckMetricsScope",
465 tags = "1, 2, 3"
466 )]
467 pub data_review_check_metrics_scope: ::core::option::Option<
468 data_review_check_metrics_scope::DataReviewCheckMetricsScope,
469 >,
470}
471pub mod data_review_check_metrics_scope {
473 #[derive(Clone, PartialEq, ::prost::Oneof)]
474 pub enum DataReviewCheckMetricsScope {
475 #[prost(string, tag = "1")]
476 RunRid(::prost::alloc::string::String),
477 #[prost(string, tag = "2")]
478 AssetRid(::prost::alloc::string::String),
479 #[prost(string, tag = "3")]
480 DataReviewRid(::prost::alloc::string::String),
481 }
482}
483#[derive(Clone, Copy, PartialEq, ::prost::Message)]
484pub struct DuplicateAndLinkNotebook {}
485#[derive(Clone, PartialEq, ::prost::Message)]
486pub struct ExecutingState {
487 #[prost(string, tag = "1")]
488 pub job_rid: ::prost::alloc::string::String,
489}
490#[derive(Clone, PartialEq, ::prost::Message)]
491pub struct ExecutionRetriggered {
492 #[prost(string, tag = "1")]
493 pub job_rid: ::prost::alloc::string::String,
494}
495#[derive(Clone, PartialEq, ::prost::Message)]
496pub struct FailedToExecuteState {
497 #[prost(string, tag = "1")]
498 pub job_rid: ::prost::alloc::string::String,
499 #[prost(message, optional, tag = "2")]
500 pub review_state: ::core::option::Option<CheckAlertState>,
501 #[prost(string, optional, tag = "3")]
502 pub review_notes: ::core::option::Option<::prost::alloc::string::String>,
503 #[prost(string, repeated, tag = "4")]
504 pub assignee_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
505}
506#[derive(Clone, PartialEq, ::prost::Message)]
507pub struct GeneratedAlertsState {
508 #[prost(string, repeated, tag = "1")]
509 pub rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
510 #[prost(string, repeated, tag = "2")]
511 pub event_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
512}
513#[derive(Clone, Copy, PartialEq, ::prost::Message)]
514pub struct HistogramBucket {
515 #[prost(message, optional, tag = "1")]
516 pub start_inclusive: ::core::option::Option<
517 super::super::super::google::protobuf::Timestamp,
518 >,
519 #[prost(message, optional, tag = "2")]
520 pub end_exclusive: ::core::option::Option<
521 super::super::super::google::protobuf::Timestamp,
522 >,
523 #[prost(int32, tag = "3")]
524 pub count: i32,
525}
526#[derive(Clone, Copy, PartialEq, ::prost::Message)]
527pub struct HistogramDistributionVariable {
528 #[prost(
529 oneof = "histogram_distribution_variable::HistogramDistributionVariable",
530 tags = "1"
531 )]
532 pub histogram_distribution_variable: ::core::option::Option<
533 histogram_distribution_variable::HistogramDistributionVariable,
534 >,
535}
536pub mod histogram_distribution_variable {
538 #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
539 pub enum HistogramDistributionVariable {
540 #[prost(message, tag = "1")]
541 StartTime(super::HistogramStartTimeVariable),
542 }
543}
544#[derive(Clone, Copy, PartialEq, ::prost::Message)]
545pub struct HistogramEndTimeVariable {}
546#[derive(Clone, PartialEq, ::prost::Message)]
547pub struct HistogramPriorityBucket {
548 #[prost(message, optional, tag = "1")]
549 pub start_inclusive: ::core::option::Option<
550 super::super::super::google::protobuf::Timestamp,
551 >,
552 #[prost(message, optional, tag = "2")]
553 pub end_exclusive: ::core::option::Option<
554 super::super::super::google::protobuf::Timestamp,
555 >,
556 #[prost(map = "string, int32", tag = "3")]
557 pub counts: ::std::collections::HashMap<::prost::alloc::string::String, i32>,
558}
559#[derive(Clone, Copy, PartialEq, ::prost::Message)]
560pub struct HistogramPriorityVariable {}
561#[derive(Clone, Copy, PartialEq, ::prost::Message)]
562pub struct HistogramStartTimeVariable {}
563#[derive(Clone, PartialEq, ::prost::Message)]
564pub struct HistogramStatusBucket {
565 #[prost(message, optional, tag = "1")]
566 pub start_inclusive: ::core::option::Option<
567 super::super::super::google::protobuf::Timestamp,
568 >,
569 #[prost(message, optional, tag = "2")]
570 pub end_exclusive: ::core::option::Option<
571 super::super::super::google::protobuf::Timestamp,
572 >,
573 #[prost(map = "string, int32", tag = "3")]
574 pub counts: ::std::collections::HashMap<::prost::alloc::string::String, i32>,
575}
576#[derive(Clone, Copy, PartialEq, ::prost::Message)]
577pub struct HistogramStatusVariable {}
578#[derive(Clone, Copy, PartialEq, ::prost::Message)]
579pub struct HistogramSubGroupVariable {
580 #[prost(
581 oneof = "histogram_sub_group_variable::HistogramSubGroupVariable",
582 tags = "1, 2"
583 )]
584 pub histogram_sub_group_variable: ::core::option::Option<
585 histogram_sub_group_variable::HistogramSubGroupVariable,
586 >,
587}
588pub mod histogram_sub_group_variable {
590 #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
591 pub enum HistogramSubGroupVariable {
592 #[prost(message, tag = "1")]
593 Priority(super::HistogramPriorityVariable),
594 #[prost(message, tag = "2")]
595 Status(super::HistogramStatusVariable),
596 }
597}
598#[derive(Clone, PartialEq, ::prost::Message)]
599pub struct LinkNotebook {
600 #[prost(string, tag = "1")]
601 pub rid: ::prost::alloc::string::String,
602 #[prost(message, optional, tag = "2")]
603 pub strategy: ::core::option::Option<LinkNotebookStrategy>,
604}
605#[derive(Clone, PartialEq, ::prost::Message)]
606pub struct LinkNotebookStrategy {
607 #[prost(oneof = "link_notebook_strategy::LinkNotebookStrategy", tags = "1, 2, 3")]
608 pub link_notebook_strategy: ::core::option::Option<
609 link_notebook_strategy::LinkNotebookStrategy,
610 >,
611}
612pub mod link_notebook_strategy {
614 #[derive(Clone, PartialEq, ::prost::Oneof)]
615 pub enum LinkNotebookStrategy {
616 #[prost(message, tag = "1")]
617 DuplicateAndLinkToNewNotebook(super::DuplicateAndLinkNotebook),
618 #[prost(message, tag = "2")]
619 CloseAndLink(super::CloseAndLinkToNotebook),
620 #[prost(message, tag = "3")]
621 ReopenAndLink(super::ReopenAndLinkToNotebook),
622 }
623}
624#[derive(Clone, PartialEq, ::prost::Message)]
625pub struct ManualCheckAlertAction {
626 #[prost(
627 oneof = "manual_check_alert_action::ManualCheckAlertAction",
628 tags = "1, 2, 3, 4, 5, 6"
629 )]
630 pub manual_check_alert_action: ::core::option::Option<
631 manual_check_alert_action::ManualCheckAlertAction,
632 >,
633}
634pub mod manual_check_alert_action {
636 #[derive(Clone, PartialEq, ::prost::Oneof)]
637 pub enum ManualCheckAlertAction {
638 #[prost(message, tag = "1")]
639 Pass(super::Pass),
640 #[prost(message, tag = "2")]
641 CloseWithFurtherAction(super::CloseWithFurtherAction),
642 #[prost(message, tag = "3")]
643 Reopen(super::Reopen),
644 #[prost(message, tag = "4")]
645 Reassign(super::Reassign),
646 #[prost(message, tag = "5")]
647 UpdateNotes(super::UpdateNotes),
648 #[prost(message, tag = "6")]
649 LinkNotebook(super::LinkNotebook),
650 }
651}
652#[derive(Clone, PartialEq, ::prost::Message)]
653pub struct ManualCheckEvaluation {
654 #[prost(string, tag = "1")]
655 pub rid: ::prost::alloc::string::String,
656 #[prost(string, tag = "2")]
657 pub check_rid: ::prost::alloc::string::String,
658 #[prost(string, tag = "3")]
659 pub data_review_rid: ::prost::alloc::string::String,
660 #[prost(message, optional, tag = "4")]
661 pub state: ::core::option::Option<ManualCheckEvaluationState>,
662 #[prost(string, repeated, tag = "5")]
663 pub assignee_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
664 #[prost(message, optional, tag = "6")]
665 pub chart: ::core::option::Option<VersionedVizId>,
666 #[prost(string, optional, tag = "7")]
667 pub notes: ::core::option::Option<::prost::alloc::string::String>,
668 #[prost(string, optional, tag = "8")]
669 pub notebook: ::core::option::Option<::prost::alloc::string::String>,
670}
671#[derive(Clone, PartialEq, ::prost::Message)]
672pub struct ManualCheckEvaluationActionLog {
673 #[prost(message, repeated, tag = "1")]
674 pub entries: ::prost::alloc::vec::Vec<ManualCheckEvaluationActionLogEntry>,
675}
676#[derive(Clone, PartialEq, ::prost::Message)]
677pub struct ManualCheckEvaluationActionLogEntry {
678 #[prost(string, tag = "1")]
679 pub performed_by: ::prost::alloc::string::String,
680 #[prost(message, optional, tag = "2")]
681 pub action: ::core::option::Option<ManualCheckAlertAction>,
682 #[prost(message, optional, tag = "3")]
683 pub timestamp: ::core::option::Option<
684 super::super::super::google::protobuf::Timestamp,
685 >,
686}
687#[derive(Clone, PartialEq, ::prost::Message)]
688pub struct ManualCheckEvaluationState {
689 #[prost(
690 oneof = "manual_check_evaluation_state::ManualCheckEvaluationState",
691 tags = "1, 2, 3"
692 )]
693 pub manual_check_evaluation_state: ::core::option::Option<
694 manual_check_evaluation_state::ManualCheckEvaluationState,
695 >,
696}
697pub mod manual_check_evaluation_state {
699 #[derive(Clone, PartialEq, ::prost::Oneof)]
700 pub enum ManualCheckEvaluationState {
701 #[prost(message, tag = "1")]
702 PendingReview(super::PendingReviewState),
703 #[prost(message, tag = "2")]
704 ClosedWithFurtherAction(super::ClosedWithFurtherActionState),
705 #[prost(message, tag = "3")]
706 Passing(super::PassState),
707 }
708}
709#[derive(Clone, PartialEq, ::prost::Message)]
710pub struct Pass {
711 #[prost(string, tag = "1")]
712 pub comment: ::prost::alloc::string::String,
713}
714#[derive(Clone, PartialEq, ::prost::Message)]
715pub struct PassState {
716 #[prost(string, tag = "1")]
717 pub comment: ::prost::alloc::string::String,
718 #[prost(string, tag = "2")]
719 pub closed_by: ::prost::alloc::string::String,
720}
721#[derive(Clone, Copy, PartialEq, ::prost::Message)]
722pub struct PassingExecutionState {}
723#[derive(Clone, PartialEq, ::prost::Message)]
724pub struct PendingExecutionState {
725 #[prost(string, tag = "1")]
726 pub job_rid: ::prost::alloc::string::String,
727}
728#[derive(Clone, Copy, PartialEq, ::prost::Message)]
729pub struct PendingReviewState {}
730#[derive(Clone, PartialEq, ::prost::Message)]
731pub struct Reassign {
732 #[prost(string, repeated, tag = "1")]
733 pub assignee_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
734}
735#[derive(Clone, PartialEq, ::prost::Message)]
736pub struct Reopen {
737 #[prost(string, tag = "1")]
738 pub comment: ::prost::alloc::string::String,
739 #[prost(message, optional, tag = "2")]
740 pub strategy: ::core::option::Option<ReopenStrategy>,
741}
742#[derive(Clone, Copy, PartialEq, ::prost::Message)]
743pub struct ReopenAllLinkedAlerts {}
744#[derive(Clone, Copy, PartialEq, ::prost::Message)]
745pub struct ReopenAndDetachFromNotebook {}
746#[derive(Clone, Copy, PartialEq, ::prost::Message)]
747pub struct ReopenAndDuplicatePreviouslyLinkedNotebook {}
748#[derive(Clone, PartialEq, ::prost::Message)]
749pub struct ReopenAndLinkToNotebook {
750 #[prost(string, tag = "1")]
751 pub comment: ::prost::alloc::string::String,
752}
753#[derive(Clone, Copy, PartialEq, ::prost::Message)]
754pub struct ReopenStrategy {
755 #[prost(oneof = "reopen_strategy::ReopenStrategy", tags = "1, 2, 3")]
756 pub reopen_strategy: ::core::option::Option<reopen_strategy::ReopenStrategy>,
757}
758pub mod reopen_strategy {
760 #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
761 pub enum ReopenStrategy {
762 #[prost(message, tag = "1")]
763 ReopenAllLinkedAlerts(super::ReopenAllLinkedAlerts),
764 #[prost(message, tag = "2")]
765 ReopenAndDetachFromNotebook(super::ReopenAndDetachFromNotebook),
766 #[prost(message, tag = "3")]
767 ReopenAndDuplicatePreviouslyLinkedNotebook(
768 super::ReopenAndDuplicatePreviouslyLinkedNotebook,
769 ),
770 }
771}
772#[derive(Clone, Copy, PartialEq, ::prost::Message)]
773pub struct SearchCheckAlertsSortOptions {
774 #[prost(bool, tag = "1")]
775 pub is_descending: bool,
776 #[prost(enumeration = "SearchCheckAlertsSortField", tag = "2")]
777 pub field: i32,
778}
779#[derive(Clone, Copy, PartialEq, ::prost::Message)]
780pub struct TooManyAlertsState {}
781#[derive(Clone, Copy, PartialEq, ::prost::Message)]
782pub struct UnlinkNotebook {}
783#[derive(Clone, PartialEq, ::prost::Message)]
784pub struct UpdateNotes {
785 #[prost(string, tag = "1")]
786 pub notes: ::prost::alloc::string::String,
787}
788#[derive(Clone, PartialEq, ::prost::Message)]
789pub struct ArchivedStatusSet {
790 #[prost(enumeration = "super::super::types::ArchivedStatus", repeated, tag = "1")]
791 pub values: ::prost::alloc::vec::Vec<i32>,
792}
793#[derive(Clone, PartialEq, ::prost::Message)]
794pub struct CheckAlertStatusSet {
795 #[prost(enumeration = "CheckAlertStatus", repeated, tag = "1")]
796 pub values: ::prost::alloc::vec::Vec<i32>,
797}
798#[derive(Clone, PartialEq, ::prost::Message)]
799pub struct PrioritySet {
800 #[prost(enumeration = "super::super::types::Priority", repeated, tag = "1")]
801 pub values: ::prost::alloc::vec::Vec<i32>,
802}
803#[derive(Clone, PartialEq, ::prost::Message)]
804pub struct CheckRidSet {
805 #[prost(string, repeated, tag = "1")]
806 pub values: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
807}
808#[derive(Clone, PartialEq, ::prost::Message)]
809pub struct DataReviewRidSet {
810 #[prost(string, repeated, tag = "1")]
811 pub values: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
812}
813#[derive(Clone, PartialEq, ::prost::Message)]
814pub struct UserRidSet {
815 #[prost(string, repeated, tag = "1")]
816 pub values: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
817}
818#[derive(Clone, PartialEq, ::prost::Message)]
819pub struct NotebookRidSet {
820 #[prost(string, repeated, tag = "1")]
821 pub values: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
822}
823#[derive(Clone, PartialEq, ::prost::Message)]
824pub struct PinnedChecklistRefSet {
825 #[prost(message, repeated, tag = "1")]
826 pub values: ::prost::alloc::vec::Vec<PinnedChecklistRef>,
827}
828#[derive(Clone, PartialEq, ::prost::Message)]
829pub struct BatchInitiateRequest {
830 #[prost(message, repeated, tag = "1")]
831 pub requests: ::prost::alloc::vec::Vec<CreateDataReviewRequest>,
832 #[prost(message, repeated, tag = "2")]
833 pub notification_configurations: ::prost::alloc::vec::Vec<NotificationConfiguration>,
834}
835#[derive(Clone, PartialEq, ::prost::Message)]
836pub struct BatchInitiateResponse {
837 #[prost(string, repeated, tag = "1")]
838 pub rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
839}
840#[derive(Clone, PartialEq, ::prost::Message)]
841pub struct RerunFailedAutomaticChecksRequest {
842 #[prost(string, tag = "1")]
843 pub data_review_rid: ::prost::alloc::string::String,
844}
845#[derive(Clone, Copy, PartialEq, ::prost::Message)]
846pub struct RerunFailedAutomaticChecksResponse {}
847#[derive(Clone, PartialEq, ::prost::Message)]
848pub struct FindDataReviewsRequest {
849 #[prost(string, repeated, tag = "1")]
850 pub run_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
851 #[prost(string, repeated, tag = "2")]
852 pub asset_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
853 #[prost(bool, optional, tag = "3")]
854 pub filter_by_both_runs_and_assets: ::core::option::Option<bool>,
855 #[prost(message, repeated, tag = "4")]
856 pub checklist_refs: ::prost::alloc::vec::Vec<ChecklistRef>,
857 #[prost(string, optional, tag = "5")]
858 pub next_page_token: ::core::option::Option<::prost::alloc::string::String>,
859 #[prost(int32, optional, tag = "6")]
860 pub page_size: ::core::option::Option<i32>,
861 #[prost(message, optional, tag = "7")]
862 pub archived_statuses: ::core::option::Option<ArchivedStatusSet>,
863}
864#[derive(Clone, PartialEq, ::prost::Message)]
865pub struct FindDataReviewsResponse {
866 #[prost(message, repeated, tag = "1")]
867 pub data_reviews: ::prost::alloc::vec::Vec<DataReview>,
868 #[prost(string, optional, tag = "2")]
869 pub next_page_token: ::core::option::Option<::prost::alloc::string::String>,
870}
871#[derive(Clone, PartialEq, ::prost::Message)]
872pub struct GetDataReviewRequest {
873 #[prost(string, tag = "1")]
874 pub data_review_rid: ::prost::alloc::string::String,
875}
876#[derive(Clone, PartialEq, ::prost::Message)]
877pub struct GetDataReviewResponse {
878 #[prost(message, optional, tag = "1")]
879 pub data_review: ::core::option::Option<DataReview>,
880}
881#[derive(Clone, PartialEq, ::prost::Message)]
882pub struct GetCheckAlertRequest {
883 #[prost(string, tag = "1")]
884 pub check_alert_rid: ::prost::alloc::string::String,
885}
886#[derive(Clone, PartialEq, ::prost::Message)]
887pub struct GetCheckAlertResponse {
888 #[prost(message, optional, tag = "1")]
889 pub check_alert: ::core::option::Option<CheckAlert>,
890}
891#[derive(Clone, PartialEq, ::prost::Message)]
892pub struct GetCheckAlertsForDataReviewRequest {
893 #[prost(string, tag = "1")]
894 pub data_review_rid: ::prost::alloc::string::String,
895}
896#[derive(Clone, PartialEq, ::prost::Message)]
897pub struct GetCheckAlertsForDataReviewResponse {
898 #[prost(message, repeated, tag = "1")]
899 pub check_alerts: ::prost::alloc::vec::Vec<CheckAlert>,
900}
901#[derive(Clone, PartialEq, ::prost::Message)]
902pub struct GetCheckAlertsHistogramRequest {
903 #[prost(int32, optional, tag = "1")]
904 pub num_bins: ::core::option::Option<i32>,
905 #[prost(string, optional, tag = "2")]
906 pub search_text: ::core::option::Option<::prost::alloc::string::String>,
907 #[prost(message, optional, tag = "3")]
908 pub distribution_variable: ::core::option::Option<HistogramDistributionVariable>,
909 #[prost(message, optional, tag = "4")]
910 pub sub_group_variable: ::core::option::Option<HistogramSubGroupVariable>,
911 #[prost(message, optional, tag = "5")]
912 pub start_time_after: ::core::option::Option<
913 super::super::super::google::protobuf::Timestamp,
914 >,
915 #[prost(message, optional, tag = "6")]
916 pub start_time_before: ::core::option::Option<
917 super::super::super::google::protobuf::Timestamp,
918 >,
919 #[prost(message, optional, tag = "7")]
920 pub status: ::core::option::Option<CheckAlertStatusSet>,
921 #[prost(message, optional, tag = "8")]
922 pub check_rids: ::core::option::Option<CheckRidSet>,
923 #[prost(message, optional, tag = "9")]
924 pub data_review_rids: ::core::option::Option<DataReviewRidSet>,
925 #[prost(message, optional, tag = "10")]
926 pub assignee_rids: ::core::option::Option<UserRidSet>,
927 #[prost(message, optional, tag = "11")]
928 pub priorities: ::core::option::Option<PrioritySet>,
929 #[prost(string, repeated, tag = "12")]
930 pub run_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
931 #[prost(string, repeated, tag = "13")]
932 pub asset_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
933 #[prost(message, optional, tag = "14")]
934 pub pinned_checklist_refs: ::core::option::Option<PinnedChecklistRefSet>,
935 #[prost(message, repeated, tag = "15")]
936 pub chart_rids: ::prost::alloc::vec::Vec<VersionedVizId>,
937 #[prost(message, optional, tag = "16")]
938 pub notebook_rids: ::core::option::Option<NotebookRidSet>,
939 #[prost(message, optional, tag = "17")]
940 pub archived_statuses: ::core::option::Option<ArchivedStatusSet>,
941}
942#[derive(Clone, PartialEq, ::prost::Message)]
943pub struct GetCheckAlertsHistogramResponse {
944 #[prost(message, optional, tag = "1")]
945 pub buckets: ::core::option::Option<CheckAlertsHistogramBuckets>,
946}
947#[derive(Clone, PartialEq, ::prost::Message)]
948pub struct SearchCheckAlertsRequest {
949 #[prost(string, optional, tag = "1")]
950 pub next_page_token: ::core::option::Option<::prost::alloc::string::String>,
951 #[prost(int32, optional, tag = "2")]
952 pub page_size: ::core::option::Option<i32>,
953 #[prost(message, optional, tag = "3")]
954 pub sort_by: ::core::option::Option<SearchCheckAlertsSortOptions>,
955 #[prost(string, optional, tag = "4")]
956 pub search_text: ::core::option::Option<::prost::alloc::string::String>,
957 #[prost(message, optional, tag = "5")]
958 pub after: ::core::option::Option<super::super::super::google::protobuf::Timestamp>,
959 #[prost(message, optional, tag = "6")]
960 pub before: ::core::option::Option<super::super::super::google::protobuf::Timestamp>,
961 #[prost(message, optional, tag = "7")]
962 pub status: ::core::option::Option<CheckAlertStatusSet>,
963 #[prost(message, optional, tag = "8")]
964 pub check_rids: ::core::option::Option<CheckRidSet>,
965 #[prost(message, optional, tag = "9")]
966 pub data_review_rids: ::core::option::Option<DataReviewRidSet>,
967 #[prost(message, optional, tag = "10")]
968 pub assignee_rids: ::core::option::Option<UserRidSet>,
969 #[prost(message, optional, tag = "11")]
970 pub priorities: ::core::option::Option<PrioritySet>,
971 #[prost(string, repeated, tag = "12")]
972 pub run_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
973 #[prost(string, repeated, tag = "13")]
974 pub asset_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
975 #[prost(message, optional, tag = "14")]
976 pub pinned_checklist_refs: ::core::option::Option<PinnedChecklistRefSet>,
977 #[prost(message, repeated, tag = "15")]
978 pub chart_rids: ::prost::alloc::vec::Vec<VersionedVizId>,
979 #[prost(message, optional, tag = "16")]
980 pub notebook_rids: ::core::option::Option<NotebookRidSet>,
981 #[prost(message, optional, tag = "17")]
982 pub archived_statuses: ::core::option::Option<ArchivedStatusSet>,
983}
984#[derive(Clone, PartialEq, ::prost::Message)]
985pub struct SearchCheckAlertsResponse {
986 #[prost(string, optional, tag = "1")]
987 pub next_page_token: ::core::option::Option<::prost::alloc::string::String>,
988 #[prost(message, repeated, tag = "2")]
989 pub check_alerts: ::prost::alloc::vec::Vec<CheckAlert>,
990}
991#[derive(Clone, PartialEq, ::prost::Message)]
992pub struct GetCheckAlertActionLogRequest {
993 #[prost(string, tag = "1")]
994 pub check_alert_rid: ::prost::alloc::string::String,
995}
996#[derive(Clone, PartialEq, ::prost::Message)]
997pub struct GetCheckAlertActionLogResponse {
998 #[prost(message, optional, tag = "1")]
999 pub check_alert_action_log: ::core::option::Option<CheckAlertActionLog>,
1000}
1001#[derive(Clone, PartialEq, ::prost::Message)]
1002pub struct GetCheckAlertCountsForNotebooksRequest {
1003 #[prost(string, repeated, tag = "1")]
1004 pub notebook_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
1005}
1006#[derive(Clone, PartialEq, ::prost::Message)]
1007pub struct GetCheckAlertCountsForNotebooksResponse {
1008 #[prost(map = "string, int32", tag = "1")]
1009 pub counts: ::std::collections::HashMap<::prost::alloc::string::String, i32>,
1010}
1011#[derive(Clone, PartialEq, ::prost::Message)]
1012pub struct GetCheckAlertStatusForNotebooksRequest {
1013 #[prost(string, repeated, tag = "1")]
1014 pub notebook_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
1015}
1016#[derive(Clone, PartialEq, ::prost::Message)]
1017pub struct GetCheckAlertStatusForNotebooksResponse {
1018 #[prost(map = "string, enumeration(CheckAlertStatus)", tag = "1")]
1019 pub statuses: ::std::collections::HashMap<::prost::alloc::string::String, i32>,
1020}
1021#[derive(Clone, PartialEq, ::prost::Message)]
1022pub struct PerformCheckAlertActionRequest {
1023 #[prost(string, tag = "1")]
1024 pub check_alert_rid: ::prost::alloc::string::String,
1025 #[prost(message, optional, tag = "2")]
1026 pub action: ::core::option::Option<CheckAlertAction>,
1027}
1028#[derive(Clone, PartialEq, ::prost::Message)]
1029pub struct PerformCheckAlertActionResponse {
1030 #[prost(message, optional, tag = "1")]
1031 pub check_alert: ::core::option::Option<CheckAlert>,
1032}
1033#[derive(Clone, PartialEq, ::prost::Message)]
1034pub struct BatchPerformCheckAlertActionRequest {
1035 #[prost(message, optional, tag = "1")]
1036 pub check_alert_action: ::core::option::Option<CheckAlertAction>,
1037 #[prost(string, repeated, tag = "2")]
1038 pub check_alert_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
1039}
1040#[derive(Clone, PartialEq, ::prost::Message)]
1041pub struct BatchPerformCheckAlertActionResponse {
1042 #[prost(message, repeated, tag = "1")]
1043 pub check_alerts: ::prost::alloc::vec::Vec<CheckAlert>,
1044}
1045#[derive(Clone, PartialEq, ::prost::Message)]
1046pub struct BatchPerformAutomaticCheckEvaluationReviewActionRequest {
1047 #[prost(message, optional, tag = "1")]
1048 pub check_evaluation_action: ::core::option::Option<
1049 AutomaticCheckEvaluationReviewAction,
1050 >,
1051 #[prost(string, repeated, tag = "2")]
1052 pub check_evaluation_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
1053}
1054#[derive(Clone, PartialEq, ::prost::Message)]
1055pub struct BatchPerformAutomaticCheckEvaluationReviewActionResponse {
1056 #[prost(message, repeated, tag = "1")]
1057 pub check_evaluations: ::prost::alloc::vec::Vec<AutomaticCheckEvaluation>,
1058}
1059#[derive(Clone, PartialEq, ::prost::Message)]
1060pub struct GetAutomaticCheckEvaluationActionLogRequest {
1061 #[prost(string, tag = "1")]
1062 pub rid: ::prost::alloc::string::String,
1063}
1064#[derive(Clone, PartialEq, ::prost::Message)]
1065pub struct GetAutomaticCheckEvaluationActionLogResponse {
1066 #[prost(message, optional, tag = "1")]
1067 pub automatic_check_evaluation_action_log: ::core::option::Option<
1068 AutomaticCheckEvaluationActionLog,
1069 >,
1070}
1071#[derive(Clone, PartialEq, ::prost::Message)]
1072pub struct BatchPerformManualCheckAlertActionRequest {
1073 #[prost(message, optional, tag = "1")]
1074 pub check_alert_action: ::core::option::Option<ManualCheckAlertAction>,
1075 #[prost(string, repeated, tag = "2")]
1076 pub check_evaluation_rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
1077}
1078#[derive(Clone, Copy, PartialEq, ::prost::Message)]
1079pub struct BatchPerformManualCheckAlertActionResponse {}
1080#[derive(Clone, PartialEq, ::prost::Message)]
1081pub struct GetManualCheckEvaluationActionLogRequest {
1082 #[prost(string, tag = "1")]
1083 pub rid: ::prost::alloc::string::String,
1084}
1085#[derive(Clone, PartialEq, ::prost::Message)]
1086pub struct GetManualCheckEvaluationActionLogResponse {
1087 #[prost(message, optional, tag = "1")]
1088 pub manual_check_evaluation_action_log: ::core::option::Option<
1089 ManualCheckEvaluationActionLog,
1090 >,
1091}
1092#[derive(Clone, PartialEq, ::prost::Message)]
1093pub struct ArchiveDataReviewRequest {
1094 #[prost(string, tag = "1")]
1095 pub data_review_rid: ::prost::alloc::string::String,
1096}
1097#[derive(Clone, Copy, PartialEq, ::prost::Message)]
1098pub struct ArchiveDataReviewResponse {
1099 #[prost(bool, tag = "1")]
1100 pub archived: bool,
1101}
1102#[derive(Clone, PartialEq, ::prost::Message)]
1103pub struct BatchArchiveDataReviewRequest {
1104 #[prost(string, repeated, tag = "1")]
1105 pub rids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
1106}
1107#[derive(Clone, Copy, PartialEq, ::prost::Message)]
1108pub struct BatchArchiveDataReviewResponse {}
1109#[derive(Clone, PartialEq, ::prost::Message)]
1110pub struct UnarchiveDataReviewRequest {
1111 #[prost(string, tag = "1")]
1112 pub data_review_rid: ::prost::alloc::string::String,
1113}
1114#[derive(Clone, Copy, PartialEq, ::prost::Message)]
1115pub struct UnarchiveDataReviewResponse {}
1116#[derive(Clone, PartialEq, ::prost::Message)]
1117pub struct GetDataReviewCheckMetricsRequest {
1118 #[prost(message, optional, tag = "1")]
1119 pub scope: ::core::option::Option<DataReviewCheckMetricsScope>,
1120}
1121#[derive(Clone, Copy, PartialEq, ::prost::Message)]
1122pub struct GetDataReviewCheckMetricsResponse {
1123 #[prost(int32, tag = "1")]
1124 pub checks_pending_execution: i32,
1125 #[prost(int32, tag = "2")]
1126 pub checks_executing: i32,
1127 #[prost(int32, tag = "3")]
1128 pub checks_passed: i32,
1129 #[prost(int32, tag = "4")]
1130 pub checks_with_events_pending_review: i32,
1131 #[prost(int32, tag = "5")]
1132 pub checks_with_events_closed_with_ignore: i32,
1133 #[prost(int32, tag = "6")]
1134 pub checks_with_events_closed_with_further_action: i32,
1135 #[prost(int32, tag = "7")]
1136 pub checks_with_events: i32,
1137 #[prost(int32, tag = "8")]
1138 pub checks_with_too_many_events: i32,
1139 #[prost(int32, tag = "9")]
1140 pub checks_failed_to_execute_pending_review: i32,
1141 #[prost(int32, tag = "10")]
1142 pub checks_failed_to_execute_closed_with_ignore: i32,
1143 #[prost(int32, tag = "11")]
1144 pub checks_failed_to_execute_closed_with_further_action: i32,
1145 #[prost(int32, tag = "12")]
1146 pub checks_failed_to_execute: i32,
1147 #[prost(int32, tag = "13")]
1148 pub checks_executed: i32,
1149 #[prost(int32, tag = "14")]
1150 pub checks_total: i32,
1151 #[prost(int32, tag = "15")]
1152 pub events_pending_review: i32,
1153 #[prost(int32, tag = "16")]
1154 pub events_closed_with_ignore: i32,
1155 #[prost(int32, tag = "17")]
1156 pub events_closed_with_further_action: i32,
1157 #[prost(int32, tag = "18")]
1158 pub events_total: i32,
1159}
1160#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1161#[repr(i32)]
1162pub enum NotificationFilter {
1163 Unspecified = 0,
1164 ExecutionError = 1,
1165}
1166impl NotificationFilter {
1167 pub fn as_str_name(&self) -> &'static str {
1172 match self {
1173 Self::Unspecified => "NOTIFICATION_FILTER_UNSPECIFIED",
1174 Self::ExecutionError => "EXECUTION_ERROR",
1175 }
1176 }
1177 pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1179 match value {
1180 "NOTIFICATION_FILTER_UNSPECIFIED" => Some(Self::Unspecified),
1181 "EXECUTION_ERROR" => Some(Self::ExecutionError),
1182 _ => None,
1183 }
1184 }
1185}
1186#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1187#[repr(i32)]
1188pub enum CheckAlertStatus {
1189 Unspecified = 0,
1190 PendingReview = 1,
1191 ClosedIgnored = 2,
1192 ClosedRequiresFurtherAction = 3,
1193}
1194impl CheckAlertStatus {
1195 pub fn as_str_name(&self) -> &'static str {
1200 match self {
1201 Self::Unspecified => "CHECK_ALERT_STATUS_UNSPECIFIED",
1202 Self::PendingReview => "PENDING_REVIEW",
1203 Self::ClosedIgnored => "CLOSED_IGNORED",
1204 Self::ClosedRequiresFurtherAction => "CLOSED_REQUIRES_FURTHER_ACTION",
1205 }
1206 }
1207 pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1209 match value {
1210 "CHECK_ALERT_STATUS_UNSPECIFIED" => Some(Self::Unspecified),
1211 "PENDING_REVIEW" => Some(Self::PendingReview),
1212 "CLOSED_IGNORED" => Some(Self::ClosedIgnored),
1213 "CLOSED_REQUIRES_FURTHER_ACTION" => Some(Self::ClosedRequiresFurtherAction),
1214 _ => None,
1215 }
1216 }
1217}
1218#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1219#[repr(i32)]
1220pub enum SearchCheckAlertsSortField {
1221 Unspecified = 0,
1222 CheckName = 1,
1223 Start = 2,
1224 End = 3,
1225 Status = 4,
1226 Priority = 5,
1227 Duration = 6,
1228}
1229impl SearchCheckAlertsSortField {
1230 pub fn as_str_name(&self) -> &'static str {
1235 match self {
1236 Self::Unspecified => "SEARCH_CHECK_ALERTS_SORT_FIELD_UNSPECIFIED",
1237 Self::CheckName => "CHECK_NAME",
1238 Self::Start => "START",
1239 Self::End => "END",
1240 Self::Status => "STATUS",
1241 Self::Priority => "PRIORITY",
1242 Self::Duration => "DURATION",
1243 }
1244 }
1245 pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1247 match value {
1248 "SEARCH_CHECK_ALERTS_SORT_FIELD_UNSPECIFIED" => Some(Self::Unspecified),
1249 "CHECK_NAME" => Some(Self::CheckName),
1250 "START" => Some(Self::Start),
1251 "END" => Some(Self::End),
1252 "STATUS" => Some(Self::Status),
1253 "PRIORITY" => Some(Self::Priority),
1254 "DURATION" => Some(Self::Duration),
1255 _ => None,
1256 }
1257 }
1258}
1259#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1260#[repr(i32)]
1261pub enum Status {
1262 Unspecified = 0,
1263 Pass = 1,
1264 Fail = 2,
1265}
1266impl Status {
1267 pub fn as_str_name(&self) -> &'static str {
1272 match self {
1273 Self::Unspecified => "STATUS_UNSPECIFIED",
1274 Self::Pass => "PASS",
1275 Self::Fail => "FAIL",
1276 }
1277 }
1278 pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1280 match value {
1281 "STATUS_UNSPECIFIED" => Some(Self::Unspecified),
1282 "PASS" => Some(Self::Pass),
1283 "FAIL" => Some(Self::Fail),
1284 _ => None,
1285 }
1286 }
1287}
1288#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1289#[repr(i32)]
1290pub enum DataReviewError {
1291 InvalidDataReviewRequest = 0,
1292}
1293impl DataReviewError {
1294 pub fn as_str_name(&self) -> &'static str {
1299 match self {
1300 Self::InvalidDataReviewRequest => {
1301 "DATA_REVIEW_ERROR_INVALID_DATA_REVIEW_REQUEST"
1302 }
1303 }
1304 }
1305 pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1307 match value {
1308 "DATA_REVIEW_ERROR_INVALID_DATA_REVIEW_REQUEST" => {
1309 Some(Self::InvalidDataReviewRequest)
1310 }
1311 _ => None,
1312 }
1313 }
1314}
1315pub mod data_review_service_client {
1317 #![allow(
1318 unused_variables,
1319 dead_code,
1320 missing_docs,
1321 clippy::wildcard_imports,
1322 clippy::let_unit_value,
1323 )]
1324 use tonic::codegen::*;
1325 use tonic::codegen::http::Uri;
1326 #[derive(Debug, Clone)]
1327 pub struct DataReviewServiceClient<T> {
1328 inner: tonic::client::Grpc<T>,
1329 }
1330 impl DataReviewServiceClient<tonic::transport::Channel> {
1331 pub async fn connect<D>(dst: D) -> Result<Self, tonic::transport::Error>
1333 where
1334 D: TryInto<tonic::transport::Endpoint>,
1335 D::Error: Into<StdError>,
1336 {
1337 let conn = tonic::transport::Endpoint::new(dst)?.connect().await?;
1338 Ok(Self::new(conn))
1339 }
1340 }
1341 impl<T> DataReviewServiceClient<T>
1342 where
1343 T: tonic::client::GrpcService<tonic::body::Body>,
1344 T::Error: Into<StdError>,
1345 T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
1346 <T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
1347 {
1348 pub fn new(inner: T) -> Self {
1349 let inner = tonic::client::Grpc::new(inner);
1350 Self { inner }
1351 }
1352 pub fn with_origin(inner: T, origin: Uri) -> Self {
1353 let inner = tonic::client::Grpc::with_origin(inner, origin);
1354 Self { inner }
1355 }
1356 pub fn with_interceptor<F>(
1357 inner: T,
1358 interceptor: F,
1359 ) -> DataReviewServiceClient<InterceptedService<T, F>>
1360 where
1361 F: tonic::service::Interceptor,
1362 T::ResponseBody: Default,
1363 T: tonic::codegen::Service<
1364 http::Request<tonic::body::Body>,
1365 Response = http::Response<
1366 <T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
1367 >,
1368 >,
1369 <T as tonic::codegen::Service<
1370 http::Request<tonic::body::Body>,
1371 >>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
1372 {
1373 DataReviewServiceClient::new(InterceptedService::new(inner, interceptor))
1374 }
1375 #[must_use]
1380 pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
1381 self.inner = self.inner.send_compressed(encoding);
1382 self
1383 }
1384 #[must_use]
1386 pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
1387 self.inner = self.inner.accept_compressed(encoding);
1388 self
1389 }
1390 #[must_use]
1394 pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
1395 self.inner = self.inner.max_decoding_message_size(limit);
1396 self
1397 }
1398 #[must_use]
1402 pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
1403 self.inner = self.inner.max_encoding_message_size(limit);
1404 self
1405 }
1406 pub async fn batch_initiate(
1407 &mut self,
1408 request: impl tonic::IntoRequest<super::BatchInitiateRequest>,
1409 ) -> std::result::Result<
1410 tonic::Response<super::BatchInitiateResponse>,
1411 tonic::Status,
1412 > {
1413 self.inner
1414 .ready()
1415 .await
1416 .map_err(|e| {
1417 tonic::Status::unknown(
1418 format!("Service was not ready: {}", e.into()),
1419 )
1420 })?;
1421 let codec = tonic::codec::ProstCodec::default();
1422 let path = http::uri::PathAndQuery::from_static(
1423 "/nominal.datareview.v2.DataReviewService/BatchInitiate",
1424 );
1425 let mut req = request.into_request();
1426 req.extensions_mut()
1427 .insert(
1428 GrpcMethod::new(
1429 "nominal.datareview.v2.DataReviewService",
1430 "BatchInitiate",
1431 ),
1432 );
1433 self.inner.unary(req, path, codec).await
1434 }
1435 pub async fn rerun_failed_automatic_checks(
1436 &mut self,
1437 request: impl tonic::IntoRequest<super::RerunFailedAutomaticChecksRequest>,
1438 ) -> std::result::Result<
1439 tonic::Response<super::RerunFailedAutomaticChecksResponse>,
1440 tonic::Status,
1441 > {
1442 self.inner
1443 .ready()
1444 .await
1445 .map_err(|e| {
1446 tonic::Status::unknown(
1447 format!("Service was not ready: {}", e.into()),
1448 )
1449 })?;
1450 let codec = tonic::codec::ProstCodec::default();
1451 let path = http::uri::PathAndQuery::from_static(
1452 "/nominal.datareview.v2.DataReviewService/RerunFailedAutomaticChecks",
1453 );
1454 let mut req = request.into_request();
1455 req.extensions_mut()
1456 .insert(
1457 GrpcMethod::new(
1458 "nominal.datareview.v2.DataReviewService",
1459 "RerunFailedAutomaticChecks",
1460 ),
1461 );
1462 self.inner.unary(req, path, codec).await
1463 }
1464 pub async fn find_data_reviews(
1465 &mut self,
1466 request: impl tonic::IntoRequest<super::FindDataReviewsRequest>,
1467 ) -> std::result::Result<
1468 tonic::Response<super::FindDataReviewsResponse>,
1469 tonic::Status,
1470 > {
1471 self.inner
1472 .ready()
1473 .await
1474 .map_err(|e| {
1475 tonic::Status::unknown(
1476 format!("Service was not ready: {}", e.into()),
1477 )
1478 })?;
1479 let codec = tonic::codec::ProstCodec::default();
1480 let path = http::uri::PathAndQuery::from_static(
1481 "/nominal.datareview.v2.DataReviewService/FindDataReviews",
1482 );
1483 let mut req = request.into_request();
1484 req.extensions_mut()
1485 .insert(
1486 GrpcMethod::new(
1487 "nominal.datareview.v2.DataReviewService",
1488 "FindDataReviews",
1489 ),
1490 );
1491 self.inner.unary(req, path, codec).await
1492 }
1493 pub async fn get_data_review(
1494 &mut self,
1495 request: impl tonic::IntoRequest<super::GetDataReviewRequest>,
1496 ) -> std::result::Result<
1497 tonic::Response<super::GetDataReviewResponse>,
1498 tonic::Status,
1499 > {
1500 self.inner
1501 .ready()
1502 .await
1503 .map_err(|e| {
1504 tonic::Status::unknown(
1505 format!("Service was not ready: {}", e.into()),
1506 )
1507 })?;
1508 let codec = tonic::codec::ProstCodec::default();
1509 let path = http::uri::PathAndQuery::from_static(
1510 "/nominal.datareview.v2.DataReviewService/GetDataReview",
1511 );
1512 let mut req = request.into_request();
1513 req.extensions_mut()
1514 .insert(
1515 GrpcMethod::new(
1516 "nominal.datareview.v2.DataReviewService",
1517 "GetDataReview",
1518 ),
1519 );
1520 self.inner.unary(req, path, codec).await
1521 }
1522 pub async fn get_check_alert(
1523 &mut self,
1524 request: impl tonic::IntoRequest<super::GetCheckAlertRequest>,
1525 ) -> std::result::Result<
1526 tonic::Response<super::GetCheckAlertResponse>,
1527 tonic::Status,
1528 > {
1529 self.inner
1530 .ready()
1531 .await
1532 .map_err(|e| {
1533 tonic::Status::unknown(
1534 format!("Service was not ready: {}", e.into()),
1535 )
1536 })?;
1537 let codec = tonic::codec::ProstCodec::default();
1538 let path = http::uri::PathAndQuery::from_static(
1539 "/nominal.datareview.v2.DataReviewService/GetCheckAlert",
1540 );
1541 let mut req = request.into_request();
1542 req.extensions_mut()
1543 .insert(
1544 GrpcMethod::new(
1545 "nominal.datareview.v2.DataReviewService",
1546 "GetCheckAlert",
1547 ),
1548 );
1549 self.inner.unary(req, path, codec).await
1550 }
1551 pub async fn get_check_alerts_for_data_review(
1552 &mut self,
1553 request: impl tonic::IntoRequest<super::GetCheckAlertsForDataReviewRequest>,
1554 ) -> std::result::Result<
1555 tonic::Response<super::GetCheckAlertsForDataReviewResponse>,
1556 tonic::Status,
1557 > {
1558 self.inner
1559 .ready()
1560 .await
1561 .map_err(|e| {
1562 tonic::Status::unknown(
1563 format!("Service was not ready: {}", e.into()),
1564 )
1565 })?;
1566 let codec = tonic::codec::ProstCodec::default();
1567 let path = http::uri::PathAndQuery::from_static(
1568 "/nominal.datareview.v2.DataReviewService/GetCheckAlertsForDataReview",
1569 );
1570 let mut req = request.into_request();
1571 req.extensions_mut()
1572 .insert(
1573 GrpcMethod::new(
1574 "nominal.datareview.v2.DataReviewService",
1575 "GetCheckAlertsForDataReview",
1576 ),
1577 );
1578 self.inner.unary(req, path, codec).await
1579 }
1580 pub async fn get_check_alerts_histogram(
1581 &mut self,
1582 request: impl tonic::IntoRequest<super::GetCheckAlertsHistogramRequest>,
1583 ) -> std::result::Result<
1584 tonic::Response<super::GetCheckAlertsHistogramResponse>,
1585 tonic::Status,
1586 > {
1587 self.inner
1588 .ready()
1589 .await
1590 .map_err(|e| {
1591 tonic::Status::unknown(
1592 format!("Service was not ready: {}", e.into()),
1593 )
1594 })?;
1595 let codec = tonic::codec::ProstCodec::default();
1596 let path = http::uri::PathAndQuery::from_static(
1597 "/nominal.datareview.v2.DataReviewService/GetCheckAlertsHistogram",
1598 );
1599 let mut req = request.into_request();
1600 req.extensions_mut()
1601 .insert(
1602 GrpcMethod::new(
1603 "nominal.datareview.v2.DataReviewService",
1604 "GetCheckAlertsHistogram",
1605 ),
1606 );
1607 self.inner.unary(req, path, codec).await
1608 }
1609 pub async fn search_check_alerts(
1610 &mut self,
1611 request: impl tonic::IntoRequest<super::SearchCheckAlertsRequest>,
1612 ) -> std::result::Result<
1613 tonic::Response<super::SearchCheckAlertsResponse>,
1614 tonic::Status,
1615 > {
1616 self.inner
1617 .ready()
1618 .await
1619 .map_err(|e| {
1620 tonic::Status::unknown(
1621 format!("Service was not ready: {}", e.into()),
1622 )
1623 })?;
1624 let codec = tonic::codec::ProstCodec::default();
1625 let path = http::uri::PathAndQuery::from_static(
1626 "/nominal.datareview.v2.DataReviewService/SearchCheckAlerts",
1627 );
1628 let mut req = request.into_request();
1629 req.extensions_mut()
1630 .insert(
1631 GrpcMethod::new(
1632 "nominal.datareview.v2.DataReviewService",
1633 "SearchCheckAlerts",
1634 ),
1635 );
1636 self.inner.unary(req, path, codec).await
1637 }
1638 pub async fn get_check_alert_action_log(
1639 &mut self,
1640 request: impl tonic::IntoRequest<super::GetCheckAlertActionLogRequest>,
1641 ) -> std::result::Result<
1642 tonic::Response<super::GetCheckAlertActionLogResponse>,
1643 tonic::Status,
1644 > {
1645 self.inner
1646 .ready()
1647 .await
1648 .map_err(|e| {
1649 tonic::Status::unknown(
1650 format!("Service was not ready: {}", e.into()),
1651 )
1652 })?;
1653 let codec = tonic::codec::ProstCodec::default();
1654 let path = http::uri::PathAndQuery::from_static(
1655 "/nominal.datareview.v2.DataReviewService/GetCheckAlertActionLog",
1656 );
1657 let mut req = request.into_request();
1658 req.extensions_mut()
1659 .insert(
1660 GrpcMethod::new(
1661 "nominal.datareview.v2.DataReviewService",
1662 "GetCheckAlertActionLog",
1663 ),
1664 );
1665 self.inner.unary(req, path, codec).await
1666 }
1667 pub async fn get_check_alert_counts_for_notebooks(
1668 &mut self,
1669 request: impl tonic::IntoRequest<
1670 super::GetCheckAlertCountsForNotebooksRequest,
1671 >,
1672 ) -> std::result::Result<
1673 tonic::Response<super::GetCheckAlertCountsForNotebooksResponse>,
1674 tonic::Status,
1675 > {
1676 self.inner
1677 .ready()
1678 .await
1679 .map_err(|e| {
1680 tonic::Status::unknown(
1681 format!("Service was not ready: {}", e.into()),
1682 )
1683 })?;
1684 let codec = tonic::codec::ProstCodec::default();
1685 let path = http::uri::PathAndQuery::from_static(
1686 "/nominal.datareview.v2.DataReviewService/GetCheckAlertCountsForNotebooks",
1687 );
1688 let mut req = request.into_request();
1689 req.extensions_mut()
1690 .insert(
1691 GrpcMethod::new(
1692 "nominal.datareview.v2.DataReviewService",
1693 "GetCheckAlertCountsForNotebooks",
1694 ),
1695 );
1696 self.inner.unary(req, path, codec).await
1697 }
1698 pub async fn get_check_alert_status_for_notebooks(
1699 &mut self,
1700 request: impl tonic::IntoRequest<
1701 super::GetCheckAlertStatusForNotebooksRequest,
1702 >,
1703 ) -> std::result::Result<
1704 tonic::Response<super::GetCheckAlertStatusForNotebooksResponse>,
1705 tonic::Status,
1706 > {
1707 self.inner
1708 .ready()
1709 .await
1710 .map_err(|e| {
1711 tonic::Status::unknown(
1712 format!("Service was not ready: {}", e.into()),
1713 )
1714 })?;
1715 let codec = tonic::codec::ProstCodec::default();
1716 let path = http::uri::PathAndQuery::from_static(
1717 "/nominal.datareview.v2.DataReviewService/GetCheckAlertStatusForNotebooks",
1718 );
1719 let mut req = request.into_request();
1720 req.extensions_mut()
1721 .insert(
1722 GrpcMethod::new(
1723 "nominal.datareview.v2.DataReviewService",
1724 "GetCheckAlertStatusForNotebooks",
1725 ),
1726 );
1727 self.inner.unary(req, path, codec).await
1728 }
1729 pub async fn perform_check_alert_action(
1730 &mut self,
1731 request: impl tonic::IntoRequest<super::PerformCheckAlertActionRequest>,
1732 ) -> std::result::Result<
1733 tonic::Response<super::PerformCheckAlertActionResponse>,
1734 tonic::Status,
1735 > {
1736 self.inner
1737 .ready()
1738 .await
1739 .map_err(|e| {
1740 tonic::Status::unknown(
1741 format!("Service was not ready: {}", e.into()),
1742 )
1743 })?;
1744 let codec = tonic::codec::ProstCodec::default();
1745 let path = http::uri::PathAndQuery::from_static(
1746 "/nominal.datareview.v2.DataReviewService/PerformCheckAlertAction",
1747 );
1748 let mut req = request.into_request();
1749 req.extensions_mut()
1750 .insert(
1751 GrpcMethod::new(
1752 "nominal.datareview.v2.DataReviewService",
1753 "PerformCheckAlertAction",
1754 ),
1755 );
1756 self.inner.unary(req, path, codec).await
1757 }
1758 pub async fn batch_perform_check_alert_action(
1759 &mut self,
1760 request: impl tonic::IntoRequest<super::BatchPerformCheckAlertActionRequest>,
1761 ) -> std::result::Result<
1762 tonic::Response<super::BatchPerformCheckAlertActionResponse>,
1763 tonic::Status,
1764 > {
1765 self.inner
1766 .ready()
1767 .await
1768 .map_err(|e| {
1769 tonic::Status::unknown(
1770 format!("Service was not ready: {}", e.into()),
1771 )
1772 })?;
1773 let codec = tonic::codec::ProstCodec::default();
1774 let path = http::uri::PathAndQuery::from_static(
1775 "/nominal.datareview.v2.DataReviewService/BatchPerformCheckAlertAction",
1776 );
1777 let mut req = request.into_request();
1778 req.extensions_mut()
1779 .insert(
1780 GrpcMethod::new(
1781 "nominal.datareview.v2.DataReviewService",
1782 "BatchPerformCheckAlertAction",
1783 ),
1784 );
1785 self.inner.unary(req, path, codec).await
1786 }
1787 pub async fn batch_perform_automatic_check_evaluation_review_action(
1788 &mut self,
1789 request: impl tonic::IntoRequest<
1790 super::BatchPerformAutomaticCheckEvaluationReviewActionRequest,
1791 >,
1792 ) -> std::result::Result<
1793 tonic::Response<
1794 super::BatchPerformAutomaticCheckEvaluationReviewActionResponse,
1795 >,
1796 tonic::Status,
1797 > {
1798 self.inner
1799 .ready()
1800 .await
1801 .map_err(|e| {
1802 tonic::Status::unknown(
1803 format!("Service was not ready: {}", e.into()),
1804 )
1805 })?;
1806 let codec = tonic::codec::ProstCodec::default();
1807 let path = http::uri::PathAndQuery::from_static(
1808 "/nominal.datareview.v2.DataReviewService/BatchPerformAutomaticCheckEvaluationReviewAction",
1809 );
1810 let mut req = request.into_request();
1811 req.extensions_mut()
1812 .insert(
1813 GrpcMethod::new(
1814 "nominal.datareview.v2.DataReviewService",
1815 "BatchPerformAutomaticCheckEvaluationReviewAction",
1816 ),
1817 );
1818 self.inner.unary(req, path, codec).await
1819 }
1820 pub async fn get_automatic_check_evaluation_action_log(
1821 &mut self,
1822 request: impl tonic::IntoRequest<
1823 super::GetAutomaticCheckEvaluationActionLogRequest,
1824 >,
1825 ) -> std::result::Result<
1826 tonic::Response<super::GetAutomaticCheckEvaluationActionLogResponse>,
1827 tonic::Status,
1828 > {
1829 self.inner
1830 .ready()
1831 .await
1832 .map_err(|e| {
1833 tonic::Status::unknown(
1834 format!("Service was not ready: {}", e.into()),
1835 )
1836 })?;
1837 let codec = tonic::codec::ProstCodec::default();
1838 let path = http::uri::PathAndQuery::from_static(
1839 "/nominal.datareview.v2.DataReviewService/GetAutomaticCheckEvaluationActionLog",
1840 );
1841 let mut req = request.into_request();
1842 req.extensions_mut()
1843 .insert(
1844 GrpcMethod::new(
1845 "nominal.datareview.v2.DataReviewService",
1846 "GetAutomaticCheckEvaluationActionLog",
1847 ),
1848 );
1849 self.inner.unary(req, path, codec).await
1850 }
1851 pub async fn batch_perform_manual_check_alert_action(
1852 &mut self,
1853 request: impl tonic::IntoRequest<
1854 super::BatchPerformManualCheckAlertActionRequest,
1855 >,
1856 ) -> std::result::Result<
1857 tonic::Response<super::BatchPerformManualCheckAlertActionResponse>,
1858 tonic::Status,
1859 > {
1860 self.inner
1861 .ready()
1862 .await
1863 .map_err(|e| {
1864 tonic::Status::unknown(
1865 format!("Service was not ready: {}", e.into()),
1866 )
1867 })?;
1868 let codec = tonic::codec::ProstCodec::default();
1869 let path = http::uri::PathAndQuery::from_static(
1870 "/nominal.datareview.v2.DataReviewService/BatchPerformManualCheckAlertAction",
1871 );
1872 let mut req = request.into_request();
1873 req.extensions_mut()
1874 .insert(
1875 GrpcMethod::new(
1876 "nominal.datareview.v2.DataReviewService",
1877 "BatchPerformManualCheckAlertAction",
1878 ),
1879 );
1880 self.inner.unary(req, path, codec).await
1881 }
1882 pub async fn get_manual_check_evaluation_action_log(
1883 &mut self,
1884 request: impl tonic::IntoRequest<
1885 super::GetManualCheckEvaluationActionLogRequest,
1886 >,
1887 ) -> std::result::Result<
1888 tonic::Response<super::GetManualCheckEvaluationActionLogResponse>,
1889 tonic::Status,
1890 > {
1891 self.inner
1892 .ready()
1893 .await
1894 .map_err(|e| {
1895 tonic::Status::unknown(
1896 format!("Service was not ready: {}", e.into()),
1897 )
1898 })?;
1899 let codec = tonic::codec::ProstCodec::default();
1900 let path = http::uri::PathAndQuery::from_static(
1901 "/nominal.datareview.v2.DataReviewService/GetManualCheckEvaluationActionLog",
1902 );
1903 let mut req = request.into_request();
1904 req.extensions_mut()
1905 .insert(
1906 GrpcMethod::new(
1907 "nominal.datareview.v2.DataReviewService",
1908 "GetManualCheckEvaluationActionLog",
1909 ),
1910 );
1911 self.inner.unary(req, path, codec).await
1912 }
1913 pub async fn archive_data_review(
1914 &mut self,
1915 request: impl tonic::IntoRequest<super::ArchiveDataReviewRequest>,
1916 ) -> std::result::Result<
1917 tonic::Response<super::ArchiveDataReviewResponse>,
1918 tonic::Status,
1919 > {
1920 self.inner
1921 .ready()
1922 .await
1923 .map_err(|e| {
1924 tonic::Status::unknown(
1925 format!("Service was not ready: {}", e.into()),
1926 )
1927 })?;
1928 let codec = tonic::codec::ProstCodec::default();
1929 let path = http::uri::PathAndQuery::from_static(
1930 "/nominal.datareview.v2.DataReviewService/ArchiveDataReview",
1931 );
1932 let mut req = request.into_request();
1933 req.extensions_mut()
1934 .insert(
1935 GrpcMethod::new(
1936 "nominal.datareview.v2.DataReviewService",
1937 "ArchiveDataReview",
1938 ),
1939 );
1940 self.inner.unary(req, path, codec).await
1941 }
1942 pub async fn batch_archive_data_review(
1943 &mut self,
1944 request: impl tonic::IntoRequest<super::BatchArchiveDataReviewRequest>,
1945 ) -> std::result::Result<
1946 tonic::Response<super::BatchArchiveDataReviewResponse>,
1947 tonic::Status,
1948 > {
1949 self.inner
1950 .ready()
1951 .await
1952 .map_err(|e| {
1953 tonic::Status::unknown(
1954 format!("Service was not ready: {}", e.into()),
1955 )
1956 })?;
1957 let codec = tonic::codec::ProstCodec::default();
1958 let path = http::uri::PathAndQuery::from_static(
1959 "/nominal.datareview.v2.DataReviewService/BatchArchiveDataReview",
1960 );
1961 let mut req = request.into_request();
1962 req.extensions_mut()
1963 .insert(
1964 GrpcMethod::new(
1965 "nominal.datareview.v2.DataReviewService",
1966 "BatchArchiveDataReview",
1967 ),
1968 );
1969 self.inner.unary(req, path, codec).await
1970 }
1971 pub async fn unarchive_data_review(
1972 &mut self,
1973 request: impl tonic::IntoRequest<super::UnarchiveDataReviewRequest>,
1974 ) -> std::result::Result<
1975 tonic::Response<super::UnarchiveDataReviewResponse>,
1976 tonic::Status,
1977 > {
1978 self.inner
1979 .ready()
1980 .await
1981 .map_err(|e| {
1982 tonic::Status::unknown(
1983 format!("Service was not ready: {}", e.into()),
1984 )
1985 })?;
1986 let codec = tonic::codec::ProstCodec::default();
1987 let path = http::uri::PathAndQuery::from_static(
1988 "/nominal.datareview.v2.DataReviewService/UnarchiveDataReview",
1989 );
1990 let mut req = request.into_request();
1991 req.extensions_mut()
1992 .insert(
1993 GrpcMethod::new(
1994 "nominal.datareview.v2.DataReviewService",
1995 "UnarchiveDataReview",
1996 ),
1997 );
1998 self.inner.unary(req, path, codec).await
1999 }
2000 pub async fn get_data_review_check_metrics(
2001 &mut self,
2002 request: impl tonic::IntoRequest<super::GetDataReviewCheckMetricsRequest>,
2003 ) -> std::result::Result<
2004 tonic::Response<super::GetDataReviewCheckMetricsResponse>,
2005 tonic::Status,
2006 > {
2007 self.inner
2008 .ready()
2009 .await
2010 .map_err(|e| {
2011 tonic::Status::unknown(
2012 format!("Service was not ready: {}", e.into()),
2013 )
2014 })?;
2015 let codec = tonic::codec::ProstCodec::default();
2016 let path = http::uri::PathAndQuery::from_static(
2017 "/nominal.datareview.v2.DataReviewService/GetDataReviewCheckMetrics",
2018 );
2019 let mut req = request.into_request();
2020 req.extensions_mut()
2021 .insert(
2022 GrpcMethod::new(
2023 "nominal.datareview.v2.DataReviewService",
2024 "GetDataReviewCheckMetrics",
2025 ),
2026 );
2027 self.inner.unary(req, path, codec).await
2028 }
2029 }
2030}