Trait AsyncDataReviewService 

pub trait AsyncDataReviewService<I: Stream<Item = Result<Bytes, Error>>> {
    // Required methods
    fn batch_initiate(
        &self,
        auth_: &BearerToken,
        request: &BatchInitiateDataReviewRequest,
    ) -> impl Future<Output = Result<BatchInitiateDataReviewResponse, Error>> + Send;
    fn rerun_failed_automatic_checks(
        &self,
        auth_: &BearerToken,
        request: &RerunFailedAutomaticChecksRequest,
    ) -> impl Future<Output = Result<(), Error>> + Send;
    fn find_data_reviews(
        &self,
        auth_: &BearerToken,
        request: &FindDataReviewsRequest,
    ) -> impl Future<Output = Result<DataReviewPage, Error>> + Send;
    fn get(
        &self,
        auth_: &BearerToken,
        data_review_rid: &DataReviewRid,
    ) -> impl Future<Output = Result<DataReview, Error>> + Send;
    fn get_check_alert(
        &self,
        auth_: &BearerToken,
        check_alert_rid: &CheckAlertRid,
    ) -> impl Future<Output = Result<CheckAlert, Error>> + Send;
    fn get_check_alerts_for_data_review(
        &self,
        auth_: &BearerToken,
        data_review_rid: &DataReviewRid,
    ) -> impl Future<Output = Result<BTreeSet<CheckAlert>, Error>> + Send;
    fn get_check_alerts_histogram(
        &self,
        auth_: &BearerToken,
        request: &CheckAlertsHistogramRequest,
    ) -> impl Future<Output = Result<CheckAlertsHistogramResponse, Error>> + Send;
    fn search_check_alerts(
        &self,
        auth_: &BearerToken,
        request: &SearchCheckAlertsRequest,
    ) -> impl Future<Output = Result<SearchCheckAlertsResponse, Error>> + Send;
    fn get_check_alert_action_log(
        &self,
        auth_: &BearerToken,
        check_alert_rid: &CheckAlertRid,
    ) -> impl Future<Output = Result<CheckAlertActionLog, Error>> + Send;
    fn get_check_alert_counts_for_notebooks(
        &self,
        auth_: &BearerToken,
        rids: &BTreeSet<NotebookRid>,
    ) -> impl Future<Output = Result<BTreeMap<NotebookRid, i32>, Error>> + Send;
    fn get_check_alert_status_for_notebooks(
        &self,
        auth_: &BearerToken,
        rids: &BTreeSet<NotebookRid>,
    ) -> impl Future<Output = Result<BTreeMap<NotebookRid, Option<CheckAlertStatus>>, Error>> + Send;
    fn perform_check_alert_action(
        &self,
        auth_: &BearerToken,
        check_alert_rid: &CheckAlertRid,
        request: &CheckAlertAction,
    ) -> impl Future<Output = Result<CheckAlert, Error>> + Send;
    fn batch_perform_check_alert_action(
        &self,
        auth_: &BearerToken,
        request: &BatchCheckAlertActionRequest,
    ) -> impl Future<Output = Result<BatchCheckAlertActionResponse, Error>> + Send;
    fn batch_perform_automatic_check_evaluation_review_action(
        &self,
        auth_: &BearerToken,
        request: &BatchAutomaticCheckEvaluationActionRequest,
    ) -> impl Future<Output = Result<BatchAutomaticCheckEvaluationActionResponse, Error>> + Send;
    fn get_automatic_check_evaluation_action_log(
        &self,
        auth_: &BearerToken,
        rid: &AutomaticCheckEvaluationRid,
    ) -> impl Future<Output = Result<AutomaticCheckEvaluationActionLog, Error>> + Send;
    fn batch_perform_manual_check_alert_action(
        &self,
        auth_: &BearerToken,
        request: &BatchManualCheckEvaluationActionRequest,
    ) -> impl Future<Output = Result<(), Error>> + Send;
    fn get_manual_check_evaluation_action_log(
        &self,
        auth_: &BearerToken,
        rid: &ManualCheckEvaluationRid,
    ) -> impl Future<Output = Result<ManualCheckEvaluationActionLog, Error>> + Send;
    fn archive_data_review(
        &self,
        auth_: &BearerToken,
        data_review_rid: &DataReviewRid,
    ) -> impl Future<Output = Result<bool, Error>> + Send;
    fn batch_archive_data_review(
        &self,
        auth_: &BearerToken,
        rids: &BTreeSet<DataReviewRid>,
    ) -> impl Future<Output = Result<(), Error>> + Send;
    fn unarchive_data_review(
        &self,
        auth_: &BearerToken,
        data_review_rid: &DataReviewRid,
    ) -> impl Future<Output = Result<(), Error>> + Send;
    fn get_data_review_check_metrics(
        &self,
        auth_: &BearerToken,
        request: &GetDataReviewCheckMetricsRequest,
    ) -> impl Future<Output = Result<GetDataReviewCheckMetricsResponse, Error>> + Send;
}

The data review service manages the evaluation, disposition, and historical record of checks alerts.

Required Methods

fn batch_initiate( &self, auth_: &BearerToken, request: &BatchInitiateDataReviewRequest, ) -> impl Future<Output = Result<BatchInitiateDataReviewResponse, Error>> + Send

For each request, initiates data review for the requested run and checklist and executes the automatic checks against the run.

fn rerun_failed_automatic_checks( &self, auth_: &BearerToken, request: &RerunFailedAutomaticChecksRequest, ) -> impl Future<Output = Result<(), Error>> + Send

Re-executes the most recent failed automatic checks for the data review.

fn find_data_reviews( &self, auth_: &BearerToken, request: &FindDataReviewsRequest, ) -> impl Future<Output = Result<DataReviewPage, Error>> + Send

Returns the data reviews under the provided search parameters.

fn get( &self, auth_: &BearerToken, data_review_rid: &DataReviewRid, ) -> impl Future<Output = Result<DataReview, Error>> + Send

Throws if not found.

fn get_check_alert( &self, auth_: &BearerToken, check_alert_rid: &CheckAlertRid, ) -> impl Future<Output = Result<CheckAlert, Error>> + Send

Throws if not found.

fn get_check_alerts_for_data_review( &self, auth_: &BearerToken, data_review_rid: &DataReviewRid, ) -> impl Future<Output = Result<BTreeSet<CheckAlert>, Error>> + Send

Gets all check alerts from the provided data review.

fn get_check_alerts_histogram( &self, auth_: &BearerToken, request: &CheckAlertsHistogramRequest, ) -> impl Future<Output = Result<CheckAlertsHistogramResponse, Error>> + Send

Returns a histogram of alerts that occur across the provided runs or assets. At least one run or asset must be specified.

fn search_check_alerts( &self, auth_: &BearerToken, request: &SearchCheckAlertsRequest, ) -> impl Future<Output = Result<SearchCheckAlertsResponse, Error>> + Send

Returns the check alerts under the provided search parameters. At least one run or asset must be specified.

fn get_check_alert_action_log( &self, auth_: &BearerToken, check_alert_rid: &CheckAlertRid, ) -> impl Future<Output = Result<CheckAlertActionLog, Error>> + Send

Returns a record of the historical actions taken on the provided check alert.

fn get_check_alert_counts_for_notebooks( &self, auth_: &BearerToken, rids: &BTreeSet<NotebookRid>, ) -> impl Future<Output = Result<BTreeMap<NotebookRid, i32>, Error>> + Send

Returns the number of alerts attached to each provided notebook.

fn get_check_alert_status_for_notebooks( &self, auth_: &BearerToken, rids: &BTreeSet<NotebookRid>, ) -> impl Future<Output = Result<BTreeMap<NotebookRid, Option<CheckAlertStatus>>, Error>> + Send

Returns the check alert status of any linked violations for the provided notebooks. If none exist, an empty optional is returned.

fn perform_check_alert_action( &self, auth_: &BearerToken, check_alert_rid: &CheckAlertRid, request: &CheckAlertAction, ) -> impl Future<Output = Result<CheckAlert, Error>> + Send

Applies a check alert action to the specified check alert RID.

fn batch_perform_check_alert_action( &self, auth_: &BearerToken, request: &BatchCheckAlertActionRequest, ) -> impl Future<Output = Result<BatchCheckAlertActionResponse, Error>> + Send

Applies a check alert action to the specified check alert RIDs. If any of the check actions fail, then none of the check actions will be applied.

fn batch_perform_automatic_check_evaluation_review_action( &self, auth_: &BearerToken, request: &BatchAutomaticCheckEvaluationActionRequest, ) -> impl Future<Output = Result<BatchAutomaticCheckEvaluationActionResponse, Error>> + Send

Applies an action to the specified check evaluation RIDs. If any of the check actions fail, then none of the actions will be applied.

fn get_automatic_check_evaluation_action_log( &self, auth_: &BearerToken, rid: &AutomaticCheckEvaluationRid, ) -> impl Future<Output = Result<AutomaticCheckEvaluationActionLog, Error>> + Send

fn batch_perform_manual_check_alert_action( &self, auth_: &BearerToken, request: &BatchManualCheckEvaluationActionRequest, ) -> impl Future<Output = Result<(), Error>> + Send

Applies an action to the specified check evaluation RIDs. If any of the check actions fail, then none of the actions will be applied.

fn get_manual_check_evaluation_action_log( &self, auth_: &BearerToken, rid: &ManualCheckEvaluationRid, ) -> impl Future<Output = Result<ManualCheckEvaluationActionLog, Error>> + Send

Returns a record of the historical manual actions taken on the provided check evaluation.

fn archive_data_review( &self, auth_: &BearerToken, data_review_rid: &DataReviewRid, ) -> impl Future<Output = Result<bool, Error>> + Send

Archives the data review with the given rid.

fn batch_archive_data_review( &self, auth_: &BearerToken, rids: &BTreeSet<DataReviewRid>, ) -> impl Future<Output = Result<(), Error>> + Send

Batch archives the data reviews with the given rids.

fn unarchive_data_review( &self, auth_: &BearerToken, data_review_rid: &DataReviewRid, ) -> impl Future<Output = Result<(), Error>> + Send

Unarchives the data review with the given rid.

fn get_data_review_check_metrics( &self, auth_: &BearerToken, request: &GetDataReviewCheckMetricsRequest, ) -> impl Future<Output = Result<GetDataReviewCheckMetricsResponse, Error>> + Send

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl<I: Stream<Item = Result<Bytes, Error>>, __C> AsyncDataReviewService<I> for AsyncDataReviewServiceClient<__C>

where __C: AsyncClient<ResponseBody = I> + Sync + Send, __C::ResponseBody: 'static + Send,