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

pub async fn execute_streaming_checklist( &self, auth_: &BearerToken, request: &ExecuteChecklistForAssetsRequest, ) -> Result<(), Error>

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

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

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 copy 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.