Struct ChecklistExecutionServiceAsyncClient

pub struct ChecklistExecutionServiceAsyncClient<T>(/* private fields */);

The Checklist Execution Service checks the status of checklist executions.

Implementations

impl<T> ChecklistExecutionServiceAsyncClient<T>

where T: AsyncClient,

pub async 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.

pub async 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.

pub async fn list_streaming_checklist( &self, auth_: &BearerToken, request: &ListStreamingChecklistRequest, ) -> Result<ListStreamingChecklistResponse, Error>

Lists all running streaming checklists.

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

Retrieves all streaming checklists for a given asset.

pub async 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.

pub async 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.

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

Stops the execution of a streaming checklist on all assets.

pub async 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.

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

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

pub async 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.

Trait Implementations

impl<T> AsyncService<T> for ChecklistExecutionServiceAsyncClient<T>

where T: AsyncClient,

fn new(client: T) -> Self

Creates a new service wrapping an async HTTP client.

impl<T: Clone> Clone for ChecklistExecutionServiceAsyncClient<T>

fn clone(&self) -> ChecklistExecutionServiceAsyncClient<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for ChecklistExecutionServiceAsyncClient<T>

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

Formats the value using the given formatter.