Trait AsyncChecklistExecutionService

pub trait AsyncChecklistExecutionService {
    // Required methods
    fn checklist_live_status(
        &self,
        auth_: BearerToken,
        request: BatchChecklistLiveStatusRequest,
    ) -> impl Future<Output = Result<BatchChecklistLiveStatusResponse, Error>> + Send;
    fn execute_streaming_checklist(
        &self,
        auth_: BearerToken,
        request: ExecuteChecklistForAssetsRequest,
    ) -> impl Future<Output = Result<(), Error>> + Send;
    fn list_streaming_checklist(
        &self,
        auth_: BearerToken,
        request: ListStreamingChecklistRequest,
    ) -> impl Future<Output = Result<ListStreamingChecklistResponse, Error>> + Send;
    fn list_streaming_checklist_for_asset(
        &self,
        auth_: BearerToken,
        request: ListStreamingChecklistForAssetRequest,
    ) -> impl Future<Output = Result<ListStreamingChecklistForAssetResponse, Error>> + Send;
    fn get_streaming_checklist(
        &self,
        auth_: BearerToken,
        checklist_rid: ChecklistRid,
    ) -> impl Future<Output = Result<StreamingChecklistInfo, Error>> + Send;
    fn batch_get_streaming_checklist(
        &self,
        auth_: BearerToken,
        request: BatchGetStreamingChecklistRequest,
    ) -> impl Future<Output = Result<BatchGetStreamingChecklistResponse, Error>> + Send;
    fn stop_streaming_checklist(
        &self,
        auth_: BearerToken,
        checklist_rid: ChecklistRid,
    ) -> impl Future<Output = Result<(), Error>> + Send;
    fn stop_streaming_checklist_for_assets(
        &self,
        auth_: BearerToken,
        request: StopStreamingChecklistForAssetsRequest,
    ) -> impl Future<Output = Result<(), Error>> + Send;
    fn reload_streaming_checklist(
        &self,
        auth_: BearerToken,
        checklist_rid: ChecklistRid,
    ) -> impl Future<Output = Result<(), Error>> + Send;
    fn validate_checklist_resolution(
        &self,
        auth_: BearerToken,
        request: BatchValidateChecklistResolutionRequest,
    ) -> impl Future<Output = Result<BatchValidateChecklistResolutionResponse, Error>> + Send;
}

The Checklist Execution Service checks the status of checklist executions.

Required Methods

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

For each request, get the latest status for each check in a streaming checklist against the given asset.

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

Triggers a checklist to run continuously against assets. If the checklist is already running for the given asset, replace the existing configuration with the one specified by the request.

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

Lists all running streaming checklists.

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

Retrieves all streaming checklists for a given asset.

fn get_streaming_checklist( &self, auth_: BearerToken, checklist_rid: ChecklistRid, ) -> impl Future<Output = Result<StreamingChecklistInfo, Error>> + Send

Retrieves the set of assets and their execution configurations for a streaming checklist specified by the checklistRid.

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

Retrieves the set of assets and their execution configurations for all streaming checklists specified by the request. If a streaming checklist is not found, it will not be included in the response.

fn stop_streaming_checklist( &self, auth_: BearerToken, checklist_rid: ChecklistRid, ) -> impl Future<Output = Result<(), Error>> + Send

Stops the execution of a streaming checklist on all assets.

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

Stops the execution of a streaming checklist for a given set of assets.

fn reload_streaming_checklist( &self, auth_: BearerToken, checklist_rid: ChecklistRid, ) -> impl Future<Output = Result<(), Error>> + Send

Reloads the state of the streaming checklist for the given checklistRid.

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

Validates that the channels referenced by the checklist can be resolved against the data sources.

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