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 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 current status and last failing time (if possible) for every automatic check against the given run.

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

Triggers a checklist to run continuously against assets. Returns a ChecklistAlreadyRunning error if the checklist is already running for the given asset.

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 information about a streaming checklist using the provided checklistRid.

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