Struct gapi_grpc::google::cloud::aiplatform::v1beta1::pipeline_service_client::PipelineServiceClient

pub struct PipelineServiceClient<T> { /* fields omitted */ }

A service for creating and managing Vertex AI’s pipelines. This includes both TrainingPipeline resources (used for AutoML and custom training) and PipelineJob resources (used for Vertex Pipelines).

Implementations

impl PipelineServiceClient<Channel>

pub async fn connect<D>(dst: D) -> Result<Self, Error> where
    D: TryInto<Endpoint>,
    D::Error: Into<StdError>, 

Attempt to create a new client by connecting to a given endpoint.

impl<T> PipelineServiceClient<T> where
    T: GrpcService<BoxBody>,
    T::ResponseBody: Body + HttpBody + Send + 'static,
    T::Error: Into<StdError>,
    <T::ResponseBody as HttpBody>::Error: Into<StdError> + Send, 

pub fn new(inner: T) -> Self

pub fn with_interceptor(inner: T, interceptor: impl Into<Interceptor>) -> Self

pub async fn create_training_pipeline(
    &mut self,
    request: impl IntoRequest<CreateTrainingPipelineRequest>
) -> Result<Response<TrainingPipeline>, Status>

Creates a TrainingPipeline. A created TrainingPipeline right away will be attempted to be run.

pub async fn get_training_pipeline(
    &mut self,
    request: impl IntoRequest<GetTrainingPipelineRequest>
) -> Result<Response<TrainingPipeline>, Status>

Gets a TrainingPipeline.

pub async fn list_training_pipelines(
    &mut self,
    request: impl IntoRequest<ListTrainingPipelinesRequest>
) -> Result<Response<ListTrainingPipelinesResponse>, Status>

Lists TrainingPipelines in a Location.

pub async fn delete_training_pipeline(
    &mut self,
    request: impl IntoRequest<DeleteTrainingPipelineRequest>
) -> Result<Response<Operation>, Status>

Deletes a TrainingPipeline.

pub async fn cancel_training_pipeline(
    &mut self,
    request: impl IntoRequest<CancelTrainingPipelineRequest>
) -> Result<Response<()>, Status>

Cancels a TrainingPipeline. Starts asynchronous cancellation on the TrainingPipeline. The server makes a best effort to cancel the pipeline, but success is not guaranteed. Clients can use [PipelineService.GetTrainingPipeline][google.cloud.aiplatform.v1beta1.PipelineService.GetTrainingPipeline] or other methods to check whether the cancellation succeeded or whether the pipeline completed despite cancellation. On successful cancellation, the TrainingPipeline is not deleted; instead it becomes a pipeline with a [TrainingPipeline.error][google.cloud.aiplatform.v1beta1.TrainingPipeline.error] value with a [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to Code.CANCELLED, and [TrainingPipeline.state][google.cloud.aiplatform.v1beta1.TrainingPipeline.state] is set to CANCELLED.

pub async fn create_pipeline_job(
    &mut self,
    request: impl IntoRequest<CreatePipelineJobRequest>
) -> Result<Response<PipelineJob>, Status>

Creates a PipelineJob. A PipelineJob will run immediately when created.

pub async fn get_pipeline_job(
    &mut self,
    request: impl IntoRequest<GetPipelineJobRequest>
) -> Result<Response<PipelineJob>, Status>

Gets a PipelineJob.

pub async fn list_pipeline_jobs(
    &mut self,
    request: impl IntoRequest<ListPipelineJobsRequest>
) -> Result<Response<ListPipelineJobsResponse>, Status>

Lists PipelineJobs in a Location.

pub async fn delete_pipeline_job(
    &mut self,
    request: impl IntoRequest<DeletePipelineJobRequest>
) -> Result<Response<Operation>, Status>

Deletes a PipelineJob.

pub async fn cancel_pipeline_job(
    &mut self,
    request: impl IntoRequest<CancelPipelineJobRequest>
) -> Result<Response<()>, Status>

Cancels a PipelineJob. Starts asynchronous cancellation on the PipelineJob. The server makes a best effort to cancel the pipeline, but success is not guaranteed. Clients can use [PipelineService.GetPipelineJob][google.cloud.aiplatform.v1beta1.PipelineService.GetPipelineJob] or other methods to check whether the cancellation succeeded or whether the pipeline completed despite cancellation. On successful cancellation, the PipelineJob is not deleted; instead it becomes a pipeline with a [PipelineJob.error][google.cloud.aiplatform.v1beta1.PipelineJob.error] value with a [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to Code.CANCELLED, and [PipelineJob.state][google.cloud.aiplatform.v1beta1.PipelineJob.state] is set to CANCELLED.

Trait Implementations

impl<T: Clone> Clone for PipelineServiceClient<T>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T> Debug for PipelineServiceClient<T>

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

Formats the value using the given formatter.