Struct gapi_grpc::google::cloud::aiplatform::v1::job_service_client::JobServiceClient

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

A service for creating and managing Vertex AI’s jobs.

Implementations

impl JobServiceClient<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> JobServiceClient<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_custom_job(
    &mut self,
    request: impl IntoRequest<CreateCustomJobRequest>
) -> Result<Response<CustomJob>, Status>

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

pub async fn get_custom_job(
    &mut self,
    request: impl IntoRequest<GetCustomJobRequest>
) -> Result<Response<CustomJob>, Status>

Gets a CustomJob.

pub async fn list_custom_jobs(
    &mut self,
    request: impl IntoRequest<ListCustomJobsRequest>
) -> Result<Response<ListCustomJobsResponse>, Status>

Lists CustomJobs in a Location.

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

Deletes a CustomJob.

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

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

pub async fn create_data_labeling_job(
    &mut self,
    request: impl IntoRequest<CreateDataLabelingJobRequest>
) -> Result<Response<DataLabelingJob>, Status>

Creates a DataLabelingJob.

pub async fn get_data_labeling_job(
    &mut self,
    request: impl IntoRequest<GetDataLabelingJobRequest>
) -> Result<Response<DataLabelingJob>, Status>

Gets a DataLabelingJob.

pub async fn list_data_labeling_jobs(
    &mut self,
    request: impl IntoRequest<ListDataLabelingJobsRequest>
) -> Result<Response<ListDataLabelingJobsResponse>, Status>

Lists DataLabelingJobs in a Location.

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

Deletes a DataLabelingJob.

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

Cancels a DataLabelingJob. Success of cancellation is not guaranteed.

pub async fn create_hyperparameter_tuning_job(
    &mut self,
    request: impl IntoRequest<CreateHyperparameterTuningJobRequest>
) -> Result<Response<HyperparameterTuningJob>, Status>

Creates a HyperparameterTuningJob

pub async fn get_hyperparameter_tuning_job(
    &mut self,
    request: impl IntoRequest<GetHyperparameterTuningJobRequest>
) -> Result<Response<HyperparameterTuningJob>, Status>

Gets a HyperparameterTuningJob

pub async fn list_hyperparameter_tuning_jobs(
    &mut self,
    request: impl IntoRequest<ListHyperparameterTuningJobsRequest>
) -> Result<Response<ListHyperparameterTuningJobsResponse>, Status>

Lists HyperparameterTuningJobs in a Location.

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

Deletes a HyperparameterTuningJob.

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

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

pub async fn create_batch_prediction_job(
    &mut self,
    request: impl IntoRequest<CreateBatchPredictionJobRequest>
) -> Result<Response<BatchPredictionJob>, Status>

Creates a BatchPredictionJob. A BatchPredictionJob once created will right away be attempted to start.

pub async fn get_batch_prediction_job(
    &mut self,
    request: impl IntoRequest<GetBatchPredictionJobRequest>
) -> Result<Response<BatchPredictionJob>, Status>

Gets a BatchPredictionJob

pub async fn list_batch_prediction_jobs(
    &mut self,
    request: impl IntoRequest<ListBatchPredictionJobsRequest>
) -> Result<Response<ListBatchPredictionJobsResponse>, Status>

Lists BatchPredictionJobs in a Location.

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

Deletes a BatchPredictionJob. Can only be called on jobs that already finished.

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

Cancels a BatchPredictionJob.

Starts asynchronous cancellation on the BatchPredictionJob. The server makes the best effort to cancel the job, but success is not guaranteed. Clients can use [JobService.GetBatchPredictionJob][google.cloud.aiplatform.v1.JobService.GetBatchPredictionJob] or other methods to check whether the cancellation succeeded or whether the job completed despite cancellation. On a successful cancellation, the BatchPredictionJob is not deleted;instead its [BatchPredictionJob.state][google.cloud.aiplatform.v1.BatchPredictionJob.state] is set to CANCELLED. Any files already outputted by the job are not deleted.

Trait Implementations

impl<T: Clone> Clone for JobServiceClient<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 JobServiceClient<T>

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

Formats the value using the given formatter.