Struct ChecklistExecutionServiceClient

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

The Checklist Execution Service checks the status of checklist executions.

Implementations

impl<T> ChecklistExecutionServiceClient<T>

where T: Client,

pub 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 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 fn list_streaming_checklist( &self, auth_: &BearerToken, request: &ListStreamingChecklistRequest, ) -> Result<ListStreamingChecklistResponse, Error>

Lists all running streaming checklists.

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

Retrieves all streaming checklists for a given asset.

pub 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 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 fn stop_streaming_checklist( &self, auth_: &BearerToken, checklist_rid: &ChecklistRid, ) -> Result<(), Error>

Stops the execution of a streaming checklist on all assets.

pub 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 fn reload_streaming_checklist( &self, auth_: &BearerToken, checklist_rid: &ChecklistRid, ) -> Result<(), Error>

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

pub 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: Clone> Clone for ChecklistExecutionServiceClient<T>

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for ChecklistExecutionServiceClient<T>

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

Formats the value using the given formatter.

impl<T> Service<T> for ChecklistExecutionServiceClient<T>

where T: Client,

fn new(client: T) -> Self

Creates a new service wrapping an HTTP client.