Struct google_api_proto::google::cloud::aiplatform::v1beta1::job_service_client::JobServiceClient

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

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

Implementations

impl<T> JobServiceClient<T>

where T: GrpcService<BoxBody>, T::Error: Into<StdError>, T::ResponseBody: Body<Data = Bytes> + Send + 'static, <T::ResponseBody as Body>::Error: Into<StdError> + Send,

pub fn new(inner: T) -> Self

pub fn with_origin(inner: T, origin: Uri) -> Self

pub fn with_interceptor<F>( inner: T, interceptor: F, ) -> JobServiceClient<InterceptedService<T, F>>

where F: Interceptor, T::ResponseBody: Default, T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>, <T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync,

pub fn send_compressed(self, encoding: CompressionEncoding) -> Self

Compress requests with the given encoding.

This requires the server to support it otherwise it might respond with an error.

pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self

Enable decompressing responses.

pub fn max_decoding_message_size(self, limit: usize) -> Self

Limits the maximum size of a decoded message.

Default: 4MB

pub fn max_encoding_message_size(self, limit: usize) -> Self

Limits the maximum size of an encoded message.

Default: usize::MAX

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.v1beta1.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.v1beta1.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.v1beta1.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.v1beta1.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.v1beta1.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.v1beta1.HyperparameterTuningJob.state] is set to CANCELLED.

pub async fn create_nas_job( &mut self, request: impl IntoRequest<CreateNasJobRequest>, ) -> Result<Response<NasJob>, Status>

Creates a NasJob

pub async fn get_nas_job( &mut self, request: impl IntoRequest<GetNasJobRequest>, ) -> Result<Response<NasJob>, Status>

Gets a NasJob

pub async fn list_nas_jobs( &mut self, request: impl IntoRequest<ListNasJobsRequest>, ) -> Result<Response<ListNasJobsResponse>, Status>

Lists NasJobs in a Location.

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

Deletes a NasJob.

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

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

pub async fn get_nas_trial_detail( &mut self, request: impl IntoRequest<GetNasTrialDetailRequest>, ) -> Result<Response<NasTrialDetail>, Status>

Gets a NasTrialDetail.

pub async fn list_nas_trial_details( &mut self, request: impl IntoRequest<ListNasTrialDetailsRequest>, ) -> Result<Response<ListNasTrialDetailsResponse>, Status>

List top NasTrialDetails of a NasJob.

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.v1beta1.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.v1beta1.BatchPredictionJob.state] is set to CANCELLED. Any files already outputted by the job are not deleted.

pub async fn create_model_deployment_monitoring_job( &mut self, request: impl IntoRequest<CreateModelDeploymentMonitoringJobRequest>, ) -> Result<Response<ModelDeploymentMonitoringJob>, Status>

Creates a ModelDeploymentMonitoringJob. It will run periodically on a configured interval.

pub async fn search_model_deployment_monitoring_stats_anomalies( &mut self, request: impl IntoRequest<SearchModelDeploymentMonitoringStatsAnomaliesRequest>, ) -> Result<Response<SearchModelDeploymentMonitoringStatsAnomaliesResponse>, Status>

Searches Model Monitoring Statistics generated within a given time window.

pub async fn get_model_deployment_monitoring_job( &mut self, request: impl IntoRequest<GetModelDeploymentMonitoringJobRequest>, ) -> Result<Response<ModelDeploymentMonitoringJob>, Status>

Gets a ModelDeploymentMonitoringJob.

pub async fn list_model_deployment_monitoring_jobs( &mut self, request: impl IntoRequest<ListModelDeploymentMonitoringJobsRequest>, ) -> Result<Response<ListModelDeploymentMonitoringJobsResponse>, Status>

Lists ModelDeploymentMonitoringJobs in a Location.

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

Updates a ModelDeploymentMonitoringJob.

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

Deletes a ModelDeploymentMonitoringJob.

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

Pauses a ModelDeploymentMonitoringJob. If the job is running, the server makes a best effort to cancel the job. Will mark [ModelDeploymentMonitoringJob.state][google.cloud.aiplatform.v1beta1.ModelDeploymentMonitoringJob.state] to ‘PAUSED’.

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

Resumes a paused ModelDeploymentMonitoringJob. It will start to run from next scheduled time. A deleted ModelDeploymentMonitoringJob can’t be resumed.

Trait Implementations

impl<T: Clone> Clone for JobServiceClient<T>

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for JobServiceClient<T>

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

Formats the value using the given formatter.