Trait AsyncRunService

pub trait AsyncRunService {
    // Required methods
    fn create_run(
        &self,
        auth_: BearerToken,
        details: CreateRunRequest,
    ) -> impl Future<Output = Result<Run, Error>> + Send;
    fn update_run(
        &self,
        auth_: BearerToken,
        rid: RunRid,
        details: UpdateRunRequest,
    ) -> impl Future<Output = Result<Run, Error>> + Send;
    fn add_data_sources_to_run(
        &self,
        auth_: BearerToken,
        run_rid: RunRid,
        request: BTreeMap<DataSourceRefName, CreateRunDataSource>,
    ) -> impl Future<Output = Result<Run, Error>> + Send;
    fn create_or_update_run(
        &self,
        auth_: BearerToken,
        details: CreateOrUpdateRunRequest,
    ) -> impl Future<Output = Result<Run, Error>> + Send;
    fn get_run(
        &self,
        auth_: BearerToken,
        rid: RunRid,
    ) -> impl Future<Output = Result<Run, Error>> + Send;
    fn get_run_with_data_review_metrics(
        &self,
        auth_: BearerToken,
        rid: RunRid,
    ) -> impl Future<Output = Result<RunWithDataReviewMetrics, Error>> + Send;
    fn get_run_with_data_review_summary(
        &self,
        auth_: BearerToken,
        rid: RunRid,
    ) -> impl Future<Output = Result<RunWithDataReviewSummary, Error>> + Send;
    fn get_run_by_id(
        &self,
        auth_: BearerToken,
        get_run_by_id_request: GetRunByIdRequest,
    ) -> impl Future<Output = Result<Run, Error>> + Send;
    fn get_runs(
        &self,
        auth_: BearerToken,
        rids: BTreeSet<RunRid>,
    ) -> impl Future<Output = Result<BTreeMap<RunRid, Run>, Error>> + Send;
    fn get_runs_by_asset(
        &self,
        auth_: BearerToken,
        request: GetRunsByAssetRequest,
    ) -> impl Future<Output = Result<GetRunsByAssetResponse, Error>> + Send;
    fn get_all_runs_properties_and_labels(
        &self,
        auth_: BearerToken,
        workspaces: BTreeSet<WorkspaceRid>,
    ) -> impl Future<Output = Result<AllRunsPropertiesAndLabelsResponse, Error>> + Send;
    fn search_runs(
        &self,
        auth_: BearerToken,
        request: SearchRunsRequest,
    ) -> impl Future<Output = Result<SearchRunsResponse, Error>> + Send;
    fn search_runs_with_data_review_metrics(
        &self,
        auth_: BearerToken,
        request: SearchRunsRequest,
    ) -> impl Future<Output = Result<SearchRunsWithDataReviewMetricsResponse, Error>> + Send;
    fn search_runs_with_data_review_summary(
        &self,
        auth_: BearerToken,
        request: SearchRunsRequest,
    ) -> impl Future<Output = Result<SearchRunsWithDataReviewSummaryResponse, Error>> + Send;
    fn archive_run(
        &self,
        auth_: BearerToken,
        rid: RunRid,
    ) -> impl Future<Output = Result<bool, Error>> + Send;
    fn unarchive_run(
        &self,
        auth_: BearerToken,
        rid: RunRid,
    ) -> impl Future<Output = Result<bool, Error>> + Send;
    fn get_data_source_ref_name_and_type_list(
        &self,
        auth_: BearerToken,
        workspaces: BTreeSet<WorkspaceRid>,
    ) -> impl Future<Output = Result<Vec<RefNameAndType>, Error>> + Send;
    fn search_channels(
        &self,
        auth_: BearerToken,
        rid: RunRid,
        request: SearchRunChannelsRequest,
    ) -> impl Future<Output = Result<SearchRunChannelsResponse, Error>> + Send;
    fn update_run_attachment(
        &self,
        auth_: BearerToken,
        rid: RunRid,
        request: UpdateAttachmentsRequest,
    ) -> impl Future<Output = Result<(), Error>> + Send;
}

Runs are collections of channels and metadata from one or more data sources, synchronized over a range of real time, which represents a test event or simulation. These API endpoints let you manage runs in the Nominal app.

Required Methods

fn create_run( &self, auth_: BearerToken, details: CreateRunRequest, ) -> impl Future<Output = Result<Run, Error>> + Send

Create a new run in Nominal.

Throws if start is equal to or after end.

fn update_run( &self, auth_: BearerToken, rid: RunRid, details: UpdateRunRequest, ) -> impl Future<Output = Result<Run, Error>> + Send

Updates an existing run based on its RID.

Throws if start is equal to or after end.

fn add_data_sources_to_run( &self, auth_: BearerToken, run_rid: RunRid, request: BTreeMap<DataSourceRefName, CreateRunDataSource>, ) -> impl Future<Output = Result<Run, Error>> + Send

Adds datasources to the run in question.

Throws if any of the ref names conflict with existing data sources or each other.

fn create_or_update_run( &self, auth_: BearerToken, details: CreateOrUpdateRunRequest, ) -> impl Future<Output = Result<Run, Error>> + Send

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.

fn get_run( &self, auth_: BearerToken, rid: RunRid, ) -> impl Future<Output = Result<Run, Error>> + Send

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

fn get_run_with_data_review_metrics( &self, auth_: BearerToken, rid: RunRid, ) -> impl Future<Output = Result<RunWithDataReviewMetrics, Error>> + Send

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

fn get_run_with_data_review_summary( &self, auth_: BearerToken, rid: RunRid, ) -> impl Future<Output = Result<RunWithDataReviewSummary, Error>> + Send

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

fn get_run_by_id( &self, auth_: BearerToken, get_run_by_id_request: GetRunByIdRequest, ) -> impl Future<Output = Result<Run, Error>> + Send

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

fn get_runs( &self, auth_: BearerToken, rids: BTreeSet<RunRid>, ) -> impl Future<Output = Result<BTreeMap<RunRid, Run>, Error>> + Send

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

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

Fetches the runs with the given asset.

fn get_all_runs_properties_and_labels( &self, auth_: BearerToken, workspaces: BTreeSet<WorkspaceRid>, ) -> impl Future<Output = Result<AllRunsPropertiesAndLabelsResponse, Error>> + Send

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

Searches for runs that match the given filters.

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

Searches for runs that match the given filters and includes metrics for check and violation review status.

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

Searches for runs that match the given filters and includes a summary of the data review status.

fn archive_run( &self, auth_: BearerToken, rid: RunRid, ) -> impl Future<Output = Result<bool, Error>> + Send

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

fn unarchive_run( &self, auth_: BearerToken, rid: RunRid, ) -> impl Future<Output = Result<bool, Error>> + Send

fn get_data_source_ref_name_and_type_list( &self, auth_: BearerToken, workspaces: BTreeSet<WorkspaceRid>, ) -> impl Future<Output = Result<Vec<RefNameAndType>, Error>> + Send

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

fn search_channels( &self, auth_: BearerToken, rid: RunRid, request: SearchRunChannelsRequest, ) -> impl Future<Output = Result<SearchRunChannelsResponse, Error>> + Send

fn update_run_attachment( &self, auth_: BearerToken, rid: RunRid, request: UpdateAttachmentsRequest, ) -> impl Future<Output = Result<(), Error>> + Send

Updates the attachments associated with a run.

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