Trait ChecklistExecutionService

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

The Checklist Execution Service checks the status of checklist executions.

Required Methods

fn checklist_live_status( &self, auth_: BearerToken, request: BatchChecklistLiveStatusRequest, ) -> Result<BatchChecklistLiveStatusResponse, Error>

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, ) -> Result<(), Error>

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, ) -> Result<ListStreamingChecklistResponse, Error>

Lists all running streaming checklists.

fn list_streaming_checklist_for_asset( &self, auth_: BearerToken, request: ListStreamingChecklistForAssetRequest, ) -> Result<ListStreamingChecklistForAssetResponse, Error>

Retrieves all streaming checklists for a given asset.

fn get_streaming_checklist( &self, auth_: BearerToken, checklist_rid: ChecklistRid, ) -> Result<StreamingChecklistInfo, Error>

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, ) -> Result<BatchGetStreamingChecklistResponse, Error>

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, ) -> Result<(), Error>

Stops the execution of a streaming checklist on all assets.

fn stop_streaming_checklist_for_assets( &self, auth_: BearerToken, request: StopStreamingChecklistForAssetsRequest, ) -> Result<(), Error>

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

fn reload_streaming_checklist( &self, auth_: BearerToken, checklist_rid: ChecklistRid, ) -> Result<(), Error>

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

fn validate_checklist_resolution( &self, auth_: BearerToken, request: BatchValidateChecklistResolutionRequest, ) -> Result<BatchValidateChecklistResolutionResponse, Error>

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

Implementors