Struct LocalAsyncDataReviewServiceClient 

pub struct LocalAsyncDataReviewServiceClient<C> { /* private fields */ }

Trait Implementations

impl<C> AsyncService<C> for LocalAsyncDataReviewServiceClient<C>

fn new(client: C, runtime: &Arc<ConjureRuntime>) -> Self

Creates a new service wrapping an async HTTP client.

impl<C: Clone> Clone for LocalAsyncDataReviewServiceClient<C>

fn clone(&self) -> LocalAsyncDataReviewServiceClient<C>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<C: Debug> Debug for LocalAsyncDataReviewServiceClient<C>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<I: Stream<Item = Result<Bytes, Error>>, __C> LocalAsyncDataReviewService<I> for LocalAsyncDataReviewServiceClient<__C>

where __C: LocalAsyncClient<ResponseBody = I>,

async fn batch_initiate( &self, auth_: &BearerToken, request: &BatchInitiateDataReviewRequest, ) -> Result<BatchInitiateDataReviewResponse, Error>

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

async fn rerun_failed_automatic_checks( &self, auth_: &BearerToken, request: &RerunFailedAutomaticChecksRequest, ) -> Result<(), Error>

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

async fn find_data_reviews( &self, auth_: &BearerToken, request: &FindDataReviewsRequest, ) -> Result<DataReviewPage, Error>

Returns the data reviews under the provided search parameters.

async fn get( &self, auth_: &BearerToken, data_review_rid: &DataReviewRid, ) -> Result<DataReview, Error>

Throws if not found.

async fn get_check_alert( &self, auth_: &BearerToken, check_alert_rid: &CheckAlertRid, ) -> Result<CheckAlert, Error>

Throws if not found.

async fn get_check_alerts_for_data_review( &self, auth_: &BearerToken, data_review_rid: &DataReviewRid, ) -> Result<BTreeSet<CheckAlert>, Error>

Gets all check alerts from the provided data review.

async fn get_check_alerts_histogram( &self, auth_: &BearerToken, request: &CheckAlertsHistogramRequest, ) -> Result<CheckAlertsHistogramResponse, Error>

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

async fn search_check_alerts( &self, auth_: &BearerToken, request: &SearchCheckAlertsRequest, ) -> Result<SearchCheckAlertsResponse, Error>

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

async fn get_check_alert_action_log( &self, auth_: &BearerToken, check_alert_rid: &CheckAlertRid, ) -> Result<CheckAlertActionLog, Error>

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

async fn get_check_alert_counts_for_notebooks( &self, auth_: &BearerToken, rids: &BTreeSet<NotebookRid>, ) -> Result<BTreeMap<NotebookRid, i32>, Error>

Returns the number of alerts attached to each provided notebook.

async fn get_check_alert_status_for_notebooks( &self, auth_: &BearerToken, rids: &BTreeSet<NotebookRid>, ) -> Result<BTreeMap<NotebookRid, Option<CheckAlertStatus>>, Error>

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

async fn perform_check_alert_action( &self, auth_: &BearerToken, check_alert_rid: &CheckAlertRid, request: &CheckAlertAction, ) -> Result<CheckAlert, Error>

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

async fn batch_perform_check_alert_action( &self, auth_: &BearerToken, request: &BatchCheckAlertActionRequest, ) -> Result<BatchCheckAlertActionResponse, Error>

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.

async fn batch_perform_automatic_check_evaluation_review_action( &self, auth_: &BearerToken, request: &BatchAutomaticCheckEvaluationActionRequest, ) -> Result<BatchAutomaticCheckEvaluationActionResponse, Error>

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

async fn get_automatic_check_evaluation_action_log( &self, auth_: &BearerToken, rid: &AutomaticCheckEvaluationRid, ) -> Result<AutomaticCheckEvaluationActionLog, Error>

async fn batch_perform_manual_check_alert_action( &self, auth_: &BearerToken, request: &BatchManualCheckEvaluationActionRequest, ) -> Result<(), Error>

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

async fn get_manual_check_evaluation_action_log( &self, auth_: &BearerToken, rid: &ManualCheckEvaluationRid, ) -> Result<ManualCheckEvaluationActionLog, Error>

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

async fn archive_data_review( &self, auth_: &BearerToken, data_review_rid: &DataReviewRid, ) -> Result<bool, Error>

Archives the data review with the given rid.

async fn batch_archive_data_review( &self, auth_: &BearerToken, rids: &BTreeSet<DataReviewRid>, ) -> Result<(), Error>

Batch archives the data reviews with the given rids.

async fn unarchive_data_review( &self, auth_: &BearerToken, data_review_rid: &DataReviewRid, ) -> Result<(), Error>

Unarchives the data review with the given rid.

async fn get_data_review_check_metrics( &self, auth_: &BearerToken, request: &GetDataReviewCheckMetricsRequest, ) -> Result<GetDataReviewCheckMetricsResponse, Error>