Struct LocalAsyncRunServiceClient 

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

Trait Implementations

impl<C> AsyncService<C> for LocalAsyncRunServiceClient<C>

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

Creates a new service wrapping an async HTTP client.

impl<C: Clone> Clone for LocalAsyncRunServiceClient<C>

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C: Debug> Debug for LocalAsyncRunServiceClient<C>

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

Formats the value using the given formatter.

impl<I: Stream<Item = Result<Bytes, Error>>, __C> LocalAsyncRunService<I> for LocalAsyncRunServiceClient<__C>

where __C: LocalAsyncClient<ResponseBody = I>,

async fn create_run( &self, auth_: &BearerToken, details: &CreateRunRequest, ) -> Result<Run, Error>

Create a new run in Nominal.

async fn update_run( &self, auth_: &BearerToken, rid: &RunRid, details: &UpdateRunRequest, ) -> Result<Run, Error>

Updates an existing run based on its RID.

async fn batch_edit_run_metadata( &self, auth_: &BearerToken, request: &BatchEditRunMetadataRequest, ) -> Result<BatchEditRunMetadataResponse, Error>

Batch edits metadata across multiple runs. Supports rename/merge for labels and properties. If more than 1000 runs are targeted, this endpoint will throw a 400.

async fn add_data_sources_to_run( &self, auth_: &BearerToken, run_rid: &RunRid, request: &BTreeMap<DataSourceRefName, CreateRunDataSource>, ) -> Result<Run, Error>

Adds datasources to the run in question.

async fn create_or_update_run( &self, auth_: &BearerToken, details: &CreateOrUpdateRunRequest, ) -> Result<Run, Error>

Updates a run if it exists, otherwise it’s created from scratch. Will throw if the workspace of an existing run is different from the workspace of the request.

async fn get_run(&self, auth_: &BearerToken, rid: &RunRid) -> Result<Run, Error>

Fetches details about the run in question based on its RID.

async fn get_run_with_data_review_metrics( &self, auth_: &BearerToken, rid: &RunRid, ) -> Result<RunWithDataReviewMetrics, Error>

Fetches details about the run in question based on its RID, including metrics for check and violation review status.

async fn get_run_with_data_review_summary( &self, auth_: &BearerToken, rid: &RunRid, ) -> Result<RunWithDataReviewSummary, Error>

Fetches details about the run in question based on its RID, including a summary of the data review status.

async fn get_run_by_id( &self, auth_: &BearerToken, get_run_by_id_request: &GetRunByIdRequest, ) -> Result<Run, Error>

Fetches a run based on the run number, rather than RID.

async fn get_runs( &self, auth_: &BearerToken, rids: &BTreeSet<RunRid>, ) -> Result<BTreeMap<RunRid, Run>, Error>

Fetches a list of run details based on a list of RIDs.

async fn get_runs_by_asset( &self, auth_: &BearerToken, request: &GetRunsByAssetRequest, ) -> Result<GetRunsByAssetResponse, Error>

Fetches the runs with the given asset.

async fn get_latest_run_for_assets( &self, auth_: &BearerToken, request: &BTreeSet<AssetRid>, ) -> Result<BTreeMap<AssetRid, Run>, Error>

Fetches the latest run for each requested asset. Assets without associated runs will not be included in response.

async fn get_all_runs_properties_and_labels( &self, auth_: &BearerToken, workspaces: &BTreeSet<WorkspaceRid>, ) -> Result<AllRunsPropertiesAndLabelsResponse, Error>

async fn search_runs( &self, auth_: &BearerToken, request: &SearchRunsRequest, ) -> Result<SearchRunsResponse, Error>

Searches for runs that match the given filters. Defaults to returning un-archived runs, absent an archive filter.

async fn search_runs_with_data_review_metrics( &self, auth_: &BearerToken, request: &SearchRunsRequest, ) -> Result<SearchRunsWithDataReviewMetricsResponse, Error>

Searches for runs that match the given filters and includes metrics for check and violation review status. Defaults to returning un-archived runs, absent an archive filter.

async fn search_runs_with_data_review_summary( &self, auth_: &BearerToken, request: &SearchRunsRequest, ) -> Result<SearchRunsWithDataReviewSummaryResponse, Error>

Searches for runs that match the given filters and includes a summary of the data review status. Defaults to returning un-archived runs, absent an archive filter.

async fn archive_run( &self, auth_: &BearerToken, rid: &RunRid, include_linked_workbooks: Option<bool>, ) -> Result<bool, Error>

Soft-deletes a run. Runs still exist in the database but are no longer visible.

async fn unarchive_run( &self, auth_: &BearerToken, rid: &RunRid, include_linked_workbooks: Option<bool>, ) -> Result<bool, Error>

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

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

async fn get_data_source_ref_name_and_type_list( &self, auth_: &BearerToken, workspaces: &BTreeSet<WorkspaceRid>, ) -> Result<Vec<RefNameAndType>, Error>

Returns the list of ref names that are in use across specified and authorized workspaces.

async fn update_run_attachment( &self, auth_: &BearerToken, rid: &RunRid, request: &UpdateAttachmentsRequest, ) -> Result<(), Error>

Updates the attachments associated with a run.