Struct PipelineRunsClient 

pub struct PipelineRunsClient { /* private fields */ }

Implementations

impl PipelineRunsClient

pub async fn acquire_pipeline_lock( &self, group_id: &str, pipeline_id: &str, pipeline_run_uuid: &str, req_pipeline_lock: ReqPipelineLock, ) -> Result<RespPipelineLockAcquisition, Error<AcquirePipelineLockError>>

pub async fn get_pipeline_run( &self, group_id: &str, pipeline_id: &str, pipeline_run_uuid: &str, ) -> Result<RespPipelineRun, Error<GetPipelineRunError>>

pub async fn list_pipeline_runs( &self, group_id: &str, pipeline_id: &str, ) -> Result<RespPipelineRunList, Error<ListPipelineRunsError>>

pub async fn terminate_pipeline( &self, group_id: &str, pipeline_id: &str, pipeline_run_uuid: &str, ) -> Result<RespPipelineRun, Error<TerminatePipelineError>>

pub async fn update_pipeline_run_status( &self, x_workflow_executor_token: &str, pipeline_run_uuid: &str, status: EnumRunStatus, req_patch_pipeline_run: Option<ReqPatchPipelineRun>, ) -> Result<RespString, Error<UpdatePipelineRunStatusError>>

Trait Implementations

impl Clone for PipelineRunsClient

fn clone(&self) -> PipelineRunsClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.