1 /* 2 * Copyright 2022 Google LLC 3 * 4 * Licensed under the Apache License, Version 2.0 (the "License"); 5 * you may not use this file except in compliance with the License. 6 * You may obtain a copy of the License at 7 * 8 * https://www.apache.org/licenses/LICENSE-2.0 9 * 10 * Unless required by applicable law or agreed to in writing, software 11 * distributed under the License is distributed on an "AS IS" BASIS, 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13 * See the License for the specific language governing permissions and 14 * limitations under the License. 15 */ 16 17 package com.google.cloud.aiplatform.v1.stub; 18 19 import static com.google.cloud.aiplatform.v1.JobServiceClient.ListBatchPredictionJobsPagedResponse; 20 import static com.google.cloud.aiplatform.v1.JobServiceClient.ListCustomJobsPagedResponse; 21 import static com.google.cloud.aiplatform.v1.JobServiceClient.ListDataLabelingJobsPagedResponse; 22 import static com.google.cloud.aiplatform.v1.JobServiceClient.ListHyperparameterTuningJobsPagedResponse; 23 import static com.google.cloud.aiplatform.v1.JobServiceClient.ListLocationsPagedResponse; 24 import static com.google.cloud.aiplatform.v1.JobServiceClient.ListModelDeploymentMonitoringJobsPagedResponse; 25 import static com.google.cloud.aiplatform.v1.JobServiceClient.ListNasJobsPagedResponse; 26 import static com.google.cloud.aiplatform.v1.JobServiceClient.ListNasTrialDetailsPagedResponse; 27 import static com.google.cloud.aiplatform.v1.JobServiceClient.SearchModelDeploymentMonitoringStatsAnomaliesPagedResponse; 28 29 import com.google.api.gax.core.BackgroundResource; 30 import com.google.api.gax.core.BackgroundResourceAggregation; 31 import com.google.api.gax.grpc.GrpcCallSettings; 32 import com.google.api.gax.grpc.GrpcStubCallableFactory; 33 import com.google.api.gax.rpc.ClientContext; 34 import com.google.api.gax.rpc.OperationCallable; 35 import com.google.api.gax.rpc.UnaryCallable; 36 import com.google.cloud.aiplatform.v1.BatchPredictionJob; 37 import com.google.cloud.aiplatform.v1.CancelBatchPredictionJobRequest; 38 import com.google.cloud.aiplatform.v1.CancelCustomJobRequest; 39 import com.google.cloud.aiplatform.v1.CancelDataLabelingJobRequest; 40 import com.google.cloud.aiplatform.v1.CancelHyperparameterTuningJobRequest; 41 import com.google.cloud.aiplatform.v1.CancelNasJobRequest; 42 import com.google.cloud.aiplatform.v1.CreateBatchPredictionJobRequest; 43 import com.google.cloud.aiplatform.v1.CreateCustomJobRequest; 44 import com.google.cloud.aiplatform.v1.CreateDataLabelingJobRequest; 45 import com.google.cloud.aiplatform.v1.CreateHyperparameterTuningJobRequest; 46 import com.google.cloud.aiplatform.v1.CreateModelDeploymentMonitoringJobRequest; 47 import com.google.cloud.aiplatform.v1.CreateNasJobRequest; 48 import com.google.cloud.aiplatform.v1.CustomJob; 49 import com.google.cloud.aiplatform.v1.DataLabelingJob; 50 import com.google.cloud.aiplatform.v1.DeleteBatchPredictionJobRequest; 51 import com.google.cloud.aiplatform.v1.DeleteCustomJobRequest; 52 import com.google.cloud.aiplatform.v1.DeleteDataLabelingJobRequest; 53 import com.google.cloud.aiplatform.v1.DeleteHyperparameterTuningJobRequest; 54 import com.google.cloud.aiplatform.v1.DeleteModelDeploymentMonitoringJobRequest; 55 import com.google.cloud.aiplatform.v1.DeleteNasJobRequest; 56 import com.google.cloud.aiplatform.v1.DeleteOperationMetadata; 57 import com.google.cloud.aiplatform.v1.GetBatchPredictionJobRequest; 58 import com.google.cloud.aiplatform.v1.GetCustomJobRequest; 59 import com.google.cloud.aiplatform.v1.GetDataLabelingJobRequest; 60 import com.google.cloud.aiplatform.v1.GetHyperparameterTuningJobRequest; 61 import com.google.cloud.aiplatform.v1.GetModelDeploymentMonitoringJobRequest; 62 import com.google.cloud.aiplatform.v1.GetNasJobRequest; 63 import com.google.cloud.aiplatform.v1.GetNasTrialDetailRequest; 64 import com.google.cloud.aiplatform.v1.HyperparameterTuningJob; 65 import com.google.cloud.aiplatform.v1.ListBatchPredictionJobsRequest; 66 import com.google.cloud.aiplatform.v1.ListBatchPredictionJobsResponse; 67 import com.google.cloud.aiplatform.v1.ListCustomJobsRequest; 68 import com.google.cloud.aiplatform.v1.ListCustomJobsResponse; 69 import com.google.cloud.aiplatform.v1.ListDataLabelingJobsRequest; 70 import com.google.cloud.aiplatform.v1.ListDataLabelingJobsResponse; 71 import com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsRequest; 72 import com.google.cloud.aiplatform.v1.ListHyperparameterTuningJobsResponse; 73 import com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsRequest; 74 import com.google.cloud.aiplatform.v1.ListModelDeploymentMonitoringJobsResponse; 75 import com.google.cloud.aiplatform.v1.ListNasJobsRequest; 76 import com.google.cloud.aiplatform.v1.ListNasJobsResponse; 77 import com.google.cloud.aiplatform.v1.ListNasTrialDetailsRequest; 78 import com.google.cloud.aiplatform.v1.ListNasTrialDetailsResponse; 79 import com.google.cloud.aiplatform.v1.ModelDeploymentMonitoringJob; 80 import com.google.cloud.aiplatform.v1.NasJob; 81 import com.google.cloud.aiplatform.v1.NasTrialDetail; 82 import com.google.cloud.aiplatform.v1.PauseModelDeploymentMonitoringJobRequest; 83 import com.google.cloud.aiplatform.v1.ResumeModelDeploymentMonitoringJobRequest; 84 import com.google.cloud.aiplatform.v1.SearchModelDeploymentMonitoringStatsAnomaliesRequest; 85 import com.google.cloud.aiplatform.v1.SearchModelDeploymentMonitoringStatsAnomaliesResponse; 86 import com.google.cloud.aiplatform.v1.UpdateModelDeploymentMonitoringJobOperationMetadata; 87 import com.google.cloud.aiplatform.v1.UpdateModelDeploymentMonitoringJobRequest; 88 import com.google.cloud.location.GetLocationRequest; 89 import com.google.cloud.location.ListLocationsRequest; 90 import com.google.cloud.location.ListLocationsResponse; 91 import com.google.cloud.location.Location; 92 import com.google.common.collect.ImmutableMap; 93 import com.google.iam.v1.GetIamPolicyRequest; 94 import com.google.iam.v1.Policy; 95 import com.google.iam.v1.SetIamPolicyRequest; 96 import com.google.iam.v1.TestIamPermissionsRequest; 97 import com.google.iam.v1.TestIamPermissionsResponse; 98 import com.google.longrunning.Operation; 99 import com.google.longrunning.stub.GrpcOperationsStub; 100 import com.google.protobuf.Empty; 101 import io.grpc.MethodDescriptor; 102 import io.grpc.protobuf.ProtoUtils; 103 import java.io.IOException; 104 import java.util.concurrent.TimeUnit; 105 import javax.annotation.Generated; 106 107 // AUTO-GENERATED DOCUMENTATION AND CLASS. 108 /** 109 * gRPC stub implementation for the JobService service API. 110 * 111 * <p>This class is for advanced usage and reflects the underlying API directly. 112 */ 113 @Generated("by gapic-generator-java") 114 public class GrpcJobServiceStub extends JobServiceStub { 115 private static final MethodDescriptor<CreateCustomJobRequest, CustomJob> 116 createCustomJobMethodDescriptor = 117 MethodDescriptor.<CreateCustomJobRequest, CustomJob>newBuilder() 118 .setType(MethodDescriptor.MethodType.UNARY) 119 .setFullMethodName("google.cloud.aiplatform.v1.JobService/CreateCustomJob") 120 .setRequestMarshaller( 121 ProtoUtils.marshaller(CreateCustomJobRequest.getDefaultInstance())) 122 .setResponseMarshaller(ProtoUtils.marshaller(CustomJob.getDefaultInstance())) 123 .build(); 124 125 private static final MethodDescriptor<GetCustomJobRequest, CustomJob> 126 getCustomJobMethodDescriptor = 127 MethodDescriptor.<GetCustomJobRequest, CustomJob>newBuilder() 128 .setType(MethodDescriptor.MethodType.UNARY) 129 .setFullMethodName("google.cloud.aiplatform.v1.JobService/GetCustomJob") 130 .setRequestMarshaller(ProtoUtils.marshaller(GetCustomJobRequest.getDefaultInstance())) 131 .setResponseMarshaller(ProtoUtils.marshaller(CustomJob.getDefaultInstance())) 132 .build(); 133 134 private static final MethodDescriptor<ListCustomJobsRequest, ListCustomJobsResponse> 135 listCustomJobsMethodDescriptor = 136 MethodDescriptor.<ListCustomJobsRequest, ListCustomJobsResponse>newBuilder() 137 .setType(MethodDescriptor.MethodType.UNARY) 138 .setFullMethodName("google.cloud.aiplatform.v1.JobService/ListCustomJobs") 139 .setRequestMarshaller( 140 ProtoUtils.marshaller(ListCustomJobsRequest.getDefaultInstance())) 141 .setResponseMarshaller( 142 ProtoUtils.marshaller(ListCustomJobsResponse.getDefaultInstance())) 143 .build(); 144 145 private static final MethodDescriptor<DeleteCustomJobRequest, Operation> 146 deleteCustomJobMethodDescriptor = 147 MethodDescriptor.<DeleteCustomJobRequest, Operation>newBuilder() 148 .setType(MethodDescriptor.MethodType.UNARY) 149 .setFullMethodName("google.cloud.aiplatform.v1.JobService/DeleteCustomJob") 150 .setRequestMarshaller( 151 ProtoUtils.marshaller(DeleteCustomJobRequest.getDefaultInstance())) 152 .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance())) 153 .build(); 154 155 private static final MethodDescriptor<CancelCustomJobRequest, Empty> 156 cancelCustomJobMethodDescriptor = 157 MethodDescriptor.<CancelCustomJobRequest, Empty>newBuilder() 158 .setType(MethodDescriptor.MethodType.UNARY) 159 .setFullMethodName("google.cloud.aiplatform.v1.JobService/CancelCustomJob") 160 .setRequestMarshaller( 161 ProtoUtils.marshaller(CancelCustomJobRequest.getDefaultInstance())) 162 .setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance())) 163 .build(); 164 165 private static final MethodDescriptor<CreateDataLabelingJobRequest, DataLabelingJob> 166 createDataLabelingJobMethodDescriptor = 167 MethodDescriptor.<CreateDataLabelingJobRequest, DataLabelingJob>newBuilder() 168 .setType(MethodDescriptor.MethodType.UNARY) 169 .setFullMethodName("google.cloud.aiplatform.v1.JobService/CreateDataLabelingJob") 170 .setRequestMarshaller( 171 ProtoUtils.marshaller(CreateDataLabelingJobRequest.getDefaultInstance())) 172 .setResponseMarshaller(ProtoUtils.marshaller(DataLabelingJob.getDefaultInstance())) 173 .build(); 174 175 private static final MethodDescriptor<GetDataLabelingJobRequest, DataLabelingJob> 176 getDataLabelingJobMethodDescriptor = 177 MethodDescriptor.<GetDataLabelingJobRequest, DataLabelingJob>newBuilder() 178 .setType(MethodDescriptor.MethodType.UNARY) 179 .setFullMethodName("google.cloud.aiplatform.v1.JobService/GetDataLabelingJob") 180 .setRequestMarshaller( 181 ProtoUtils.marshaller(GetDataLabelingJobRequest.getDefaultInstance())) 182 .setResponseMarshaller(ProtoUtils.marshaller(DataLabelingJob.getDefaultInstance())) 183 .build(); 184 185 private static final MethodDescriptor<ListDataLabelingJobsRequest, ListDataLabelingJobsResponse> 186 listDataLabelingJobsMethodDescriptor = 187 MethodDescriptor.<ListDataLabelingJobsRequest, ListDataLabelingJobsResponse>newBuilder() 188 .setType(MethodDescriptor.MethodType.UNARY) 189 .setFullMethodName("google.cloud.aiplatform.v1.JobService/ListDataLabelingJobs") 190 .setRequestMarshaller( 191 ProtoUtils.marshaller(ListDataLabelingJobsRequest.getDefaultInstance())) 192 .setResponseMarshaller( 193 ProtoUtils.marshaller(ListDataLabelingJobsResponse.getDefaultInstance())) 194 .build(); 195 196 private static final MethodDescriptor<DeleteDataLabelingJobRequest, Operation> 197 deleteDataLabelingJobMethodDescriptor = 198 MethodDescriptor.<DeleteDataLabelingJobRequest, Operation>newBuilder() 199 .setType(MethodDescriptor.MethodType.UNARY) 200 .setFullMethodName("google.cloud.aiplatform.v1.JobService/DeleteDataLabelingJob") 201 .setRequestMarshaller( 202 ProtoUtils.marshaller(DeleteDataLabelingJobRequest.getDefaultInstance())) 203 .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance())) 204 .build(); 205 206 private static final MethodDescriptor<CancelDataLabelingJobRequest, Empty> 207 cancelDataLabelingJobMethodDescriptor = 208 MethodDescriptor.<CancelDataLabelingJobRequest, Empty>newBuilder() 209 .setType(MethodDescriptor.MethodType.UNARY) 210 .setFullMethodName("google.cloud.aiplatform.v1.JobService/CancelDataLabelingJob") 211 .setRequestMarshaller( 212 ProtoUtils.marshaller(CancelDataLabelingJobRequest.getDefaultInstance())) 213 .setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance())) 214 .build(); 215 216 private static final MethodDescriptor< 217 CreateHyperparameterTuningJobRequest, HyperparameterTuningJob> 218 createHyperparameterTuningJobMethodDescriptor = 219 MethodDescriptor 220 .<CreateHyperparameterTuningJobRequest, HyperparameterTuningJob>newBuilder() 221 .setType(MethodDescriptor.MethodType.UNARY) 222 .setFullMethodName( 223 "google.cloud.aiplatform.v1.JobService/CreateHyperparameterTuningJob") 224 .setRequestMarshaller( 225 ProtoUtils.marshaller(CreateHyperparameterTuningJobRequest.getDefaultInstance())) 226 .setResponseMarshaller( 227 ProtoUtils.marshaller(HyperparameterTuningJob.getDefaultInstance())) 228 .build(); 229 230 private static final MethodDescriptor<GetHyperparameterTuningJobRequest, HyperparameterTuningJob> 231 getHyperparameterTuningJobMethodDescriptor = 232 MethodDescriptor.<GetHyperparameterTuningJobRequest, HyperparameterTuningJob>newBuilder() 233 .setType(MethodDescriptor.MethodType.UNARY) 234 .setFullMethodName("google.cloud.aiplatform.v1.JobService/GetHyperparameterTuningJob") 235 .setRequestMarshaller( 236 ProtoUtils.marshaller(GetHyperparameterTuningJobRequest.getDefaultInstance())) 237 .setResponseMarshaller( 238 ProtoUtils.marshaller(HyperparameterTuningJob.getDefaultInstance())) 239 .build(); 240 241 private static final MethodDescriptor< 242 ListHyperparameterTuningJobsRequest, ListHyperparameterTuningJobsResponse> 243 listHyperparameterTuningJobsMethodDescriptor = 244 MethodDescriptor 245 .<ListHyperparameterTuningJobsRequest, ListHyperparameterTuningJobsResponse> 246 newBuilder() 247 .setType(MethodDescriptor.MethodType.UNARY) 248 .setFullMethodName( 249 "google.cloud.aiplatform.v1.JobService/ListHyperparameterTuningJobs") 250 .setRequestMarshaller( 251 ProtoUtils.marshaller(ListHyperparameterTuningJobsRequest.getDefaultInstance())) 252 .setResponseMarshaller( 253 ProtoUtils.marshaller(ListHyperparameterTuningJobsResponse.getDefaultInstance())) 254 .build(); 255 256 private static final MethodDescriptor<DeleteHyperparameterTuningJobRequest, Operation> 257 deleteHyperparameterTuningJobMethodDescriptor = 258 MethodDescriptor.<DeleteHyperparameterTuningJobRequest, Operation>newBuilder() 259 .setType(MethodDescriptor.MethodType.UNARY) 260 .setFullMethodName( 261 "google.cloud.aiplatform.v1.JobService/DeleteHyperparameterTuningJob") 262 .setRequestMarshaller( 263 ProtoUtils.marshaller(DeleteHyperparameterTuningJobRequest.getDefaultInstance())) 264 .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance())) 265 .build(); 266 267 private static final MethodDescriptor<CancelHyperparameterTuningJobRequest, Empty> 268 cancelHyperparameterTuningJobMethodDescriptor = 269 MethodDescriptor.<CancelHyperparameterTuningJobRequest, Empty>newBuilder() 270 .setType(MethodDescriptor.MethodType.UNARY) 271 .setFullMethodName( 272 "google.cloud.aiplatform.v1.JobService/CancelHyperparameterTuningJob") 273 .setRequestMarshaller( 274 ProtoUtils.marshaller(CancelHyperparameterTuningJobRequest.getDefaultInstance())) 275 .setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance())) 276 .build(); 277 278 private static final MethodDescriptor<CreateNasJobRequest, NasJob> createNasJobMethodDescriptor = 279 MethodDescriptor.<CreateNasJobRequest, NasJob>newBuilder() 280 .setType(MethodDescriptor.MethodType.UNARY) 281 .setFullMethodName("google.cloud.aiplatform.v1.JobService/CreateNasJob") 282 .setRequestMarshaller(ProtoUtils.marshaller(CreateNasJobRequest.getDefaultInstance())) 283 .setResponseMarshaller(ProtoUtils.marshaller(NasJob.getDefaultInstance())) 284 .build(); 285 286 private static final MethodDescriptor<GetNasJobRequest, NasJob> getNasJobMethodDescriptor = 287 MethodDescriptor.<GetNasJobRequest, NasJob>newBuilder() 288 .setType(MethodDescriptor.MethodType.UNARY) 289 .setFullMethodName("google.cloud.aiplatform.v1.JobService/GetNasJob") 290 .setRequestMarshaller(ProtoUtils.marshaller(GetNasJobRequest.getDefaultInstance())) 291 .setResponseMarshaller(ProtoUtils.marshaller(NasJob.getDefaultInstance())) 292 .build(); 293 294 private static final MethodDescriptor<ListNasJobsRequest, ListNasJobsResponse> 295 listNasJobsMethodDescriptor = 296 MethodDescriptor.<ListNasJobsRequest, ListNasJobsResponse>newBuilder() 297 .setType(MethodDescriptor.MethodType.UNARY) 298 .setFullMethodName("google.cloud.aiplatform.v1.JobService/ListNasJobs") 299 .setRequestMarshaller(ProtoUtils.marshaller(ListNasJobsRequest.getDefaultInstance())) 300 .setResponseMarshaller( 301 ProtoUtils.marshaller(ListNasJobsResponse.getDefaultInstance())) 302 .build(); 303 304 private static final MethodDescriptor<DeleteNasJobRequest, Operation> 305 deleteNasJobMethodDescriptor = 306 MethodDescriptor.<DeleteNasJobRequest, Operation>newBuilder() 307 .setType(MethodDescriptor.MethodType.UNARY) 308 .setFullMethodName("google.cloud.aiplatform.v1.JobService/DeleteNasJob") 309 .setRequestMarshaller(ProtoUtils.marshaller(DeleteNasJobRequest.getDefaultInstance())) 310 .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance())) 311 .build(); 312 313 private static final MethodDescriptor<CancelNasJobRequest, Empty> cancelNasJobMethodDescriptor = 314 MethodDescriptor.<CancelNasJobRequest, Empty>newBuilder() 315 .setType(MethodDescriptor.MethodType.UNARY) 316 .setFullMethodName("google.cloud.aiplatform.v1.JobService/CancelNasJob") 317 .setRequestMarshaller(ProtoUtils.marshaller(CancelNasJobRequest.getDefaultInstance())) 318 .setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance())) 319 .build(); 320 321 private static final MethodDescriptor<GetNasTrialDetailRequest, NasTrialDetail> 322 getNasTrialDetailMethodDescriptor = 323 MethodDescriptor.<GetNasTrialDetailRequest, NasTrialDetail>newBuilder() 324 .setType(MethodDescriptor.MethodType.UNARY) 325 .setFullMethodName("google.cloud.aiplatform.v1.JobService/GetNasTrialDetail") 326 .setRequestMarshaller( 327 ProtoUtils.marshaller(GetNasTrialDetailRequest.getDefaultInstance())) 328 .setResponseMarshaller(ProtoUtils.marshaller(NasTrialDetail.getDefaultInstance())) 329 .build(); 330 331 private static final MethodDescriptor<ListNasTrialDetailsRequest, ListNasTrialDetailsResponse> 332 listNasTrialDetailsMethodDescriptor = 333 MethodDescriptor.<ListNasTrialDetailsRequest, ListNasTrialDetailsResponse>newBuilder() 334 .setType(MethodDescriptor.MethodType.UNARY) 335 .setFullMethodName("google.cloud.aiplatform.v1.JobService/ListNasTrialDetails") 336 .setRequestMarshaller( 337 ProtoUtils.marshaller(ListNasTrialDetailsRequest.getDefaultInstance())) 338 .setResponseMarshaller( 339 ProtoUtils.marshaller(ListNasTrialDetailsResponse.getDefaultInstance())) 340 .build(); 341 342 private static final MethodDescriptor<CreateBatchPredictionJobRequest, BatchPredictionJob> 343 createBatchPredictionJobMethodDescriptor = 344 MethodDescriptor.<CreateBatchPredictionJobRequest, BatchPredictionJob>newBuilder() 345 .setType(MethodDescriptor.MethodType.UNARY) 346 .setFullMethodName("google.cloud.aiplatform.v1.JobService/CreateBatchPredictionJob") 347 .setRequestMarshaller( 348 ProtoUtils.marshaller(CreateBatchPredictionJobRequest.getDefaultInstance())) 349 .setResponseMarshaller(ProtoUtils.marshaller(BatchPredictionJob.getDefaultInstance())) 350 .build(); 351 352 private static final MethodDescriptor<GetBatchPredictionJobRequest, BatchPredictionJob> 353 getBatchPredictionJobMethodDescriptor = 354 MethodDescriptor.<GetBatchPredictionJobRequest, BatchPredictionJob>newBuilder() 355 .setType(MethodDescriptor.MethodType.UNARY) 356 .setFullMethodName("google.cloud.aiplatform.v1.JobService/GetBatchPredictionJob") 357 .setRequestMarshaller( 358 ProtoUtils.marshaller(GetBatchPredictionJobRequest.getDefaultInstance())) 359 .setResponseMarshaller(ProtoUtils.marshaller(BatchPredictionJob.getDefaultInstance())) 360 .build(); 361 362 private static final MethodDescriptor< 363 ListBatchPredictionJobsRequest, ListBatchPredictionJobsResponse> 364 listBatchPredictionJobsMethodDescriptor = 365 MethodDescriptor 366 .<ListBatchPredictionJobsRequest, ListBatchPredictionJobsResponse>newBuilder() 367 .setType(MethodDescriptor.MethodType.UNARY) 368 .setFullMethodName("google.cloud.aiplatform.v1.JobService/ListBatchPredictionJobs") 369 .setRequestMarshaller( 370 ProtoUtils.marshaller(ListBatchPredictionJobsRequest.getDefaultInstance())) 371 .setResponseMarshaller( 372 ProtoUtils.marshaller(ListBatchPredictionJobsResponse.getDefaultInstance())) 373 .build(); 374 375 private static final MethodDescriptor<DeleteBatchPredictionJobRequest, Operation> 376 deleteBatchPredictionJobMethodDescriptor = 377 MethodDescriptor.<DeleteBatchPredictionJobRequest, Operation>newBuilder() 378 .setType(MethodDescriptor.MethodType.UNARY) 379 .setFullMethodName("google.cloud.aiplatform.v1.JobService/DeleteBatchPredictionJob") 380 .setRequestMarshaller( 381 ProtoUtils.marshaller(DeleteBatchPredictionJobRequest.getDefaultInstance())) 382 .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance())) 383 .build(); 384 385 private static final MethodDescriptor<CancelBatchPredictionJobRequest, Empty> 386 cancelBatchPredictionJobMethodDescriptor = 387 MethodDescriptor.<CancelBatchPredictionJobRequest, Empty>newBuilder() 388 .setType(MethodDescriptor.MethodType.UNARY) 389 .setFullMethodName("google.cloud.aiplatform.v1.JobService/CancelBatchPredictionJob") 390 .setRequestMarshaller( 391 ProtoUtils.marshaller(CancelBatchPredictionJobRequest.getDefaultInstance())) 392 .setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance())) 393 .build(); 394 395 private static final MethodDescriptor< 396 CreateModelDeploymentMonitoringJobRequest, ModelDeploymentMonitoringJob> 397 createModelDeploymentMonitoringJobMethodDescriptor = 398 MethodDescriptor 399 .<CreateModelDeploymentMonitoringJobRequest, ModelDeploymentMonitoringJob>newBuilder() 400 .setType(MethodDescriptor.MethodType.UNARY) 401 .setFullMethodName( 402 "google.cloud.aiplatform.v1.JobService/CreateModelDeploymentMonitoringJob") 403 .setRequestMarshaller( 404 ProtoUtils.marshaller( 405 CreateModelDeploymentMonitoringJobRequest.getDefaultInstance())) 406 .setResponseMarshaller( 407 ProtoUtils.marshaller(ModelDeploymentMonitoringJob.getDefaultInstance())) 408 .build(); 409 410 private static final MethodDescriptor< 411 SearchModelDeploymentMonitoringStatsAnomaliesRequest, 412 SearchModelDeploymentMonitoringStatsAnomaliesResponse> 413 searchModelDeploymentMonitoringStatsAnomaliesMethodDescriptor = 414 MethodDescriptor 415 .<SearchModelDeploymentMonitoringStatsAnomaliesRequest, 416 SearchModelDeploymentMonitoringStatsAnomaliesResponse> 417 newBuilder() 418 .setType(MethodDescriptor.MethodType.UNARY) 419 .setFullMethodName( 420 "google.cloud.aiplatform.v1.JobService/SearchModelDeploymentMonitoringStatsAnomalies") 421 .setRequestMarshaller( 422 ProtoUtils.marshaller( 423 SearchModelDeploymentMonitoringStatsAnomaliesRequest.getDefaultInstance())) 424 .setResponseMarshaller( 425 ProtoUtils.marshaller( 426 SearchModelDeploymentMonitoringStatsAnomaliesResponse.getDefaultInstance())) 427 .build(); 428 429 private static final MethodDescriptor< 430 GetModelDeploymentMonitoringJobRequest, ModelDeploymentMonitoringJob> 431 getModelDeploymentMonitoringJobMethodDescriptor = 432 MethodDescriptor 433 .<GetModelDeploymentMonitoringJobRequest, ModelDeploymentMonitoringJob>newBuilder() 434 .setType(MethodDescriptor.MethodType.UNARY) 435 .setFullMethodName( 436 "google.cloud.aiplatform.v1.JobService/GetModelDeploymentMonitoringJob") 437 .setRequestMarshaller( 438 ProtoUtils.marshaller( 439 GetModelDeploymentMonitoringJobRequest.getDefaultInstance())) 440 .setResponseMarshaller( 441 ProtoUtils.marshaller(ModelDeploymentMonitoringJob.getDefaultInstance())) 442 .build(); 443 444 private static final MethodDescriptor< 445 ListModelDeploymentMonitoringJobsRequest, ListModelDeploymentMonitoringJobsResponse> 446 listModelDeploymentMonitoringJobsMethodDescriptor = 447 MethodDescriptor 448 .<ListModelDeploymentMonitoringJobsRequest, ListModelDeploymentMonitoringJobsResponse> 449 newBuilder() 450 .setType(MethodDescriptor.MethodType.UNARY) 451 .setFullMethodName( 452 "google.cloud.aiplatform.v1.JobService/ListModelDeploymentMonitoringJobs") 453 .setRequestMarshaller( 454 ProtoUtils.marshaller( 455 ListModelDeploymentMonitoringJobsRequest.getDefaultInstance())) 456 .setResponseMarshaller( 457 ProtoUtils.marshaller( 458 ListModelDeploymentMonitoringJobsResponse.getDefaultInstance())) 459 .build(); 460 461 private static final MethodDescriptor<UpdateModelDeploymentMonitoringJobRequest, Operation> 462 updateModelDeploymentMonitoringJobMethodDescriptor = 463 MethodDescriptor.<UpdateModelDeploymentMonitoringJobRequest, Operation>newBuilder() 464 .setType(MethodDescriptor.MethodType.UNARY) 465 .setFullMethodName( 466 "google.cloud.aiplatform.v1.JobService/UpdateModelDeploymentMonitoringJob") 467 .setRequestMarshaller( 468 ProtoUtils.marshaller( 469 UpdateModelDeploymentMonitoringJobRequest.getDefaultInstance())) 470 .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance())) 471 .build(); 472 473 private static final MethodDescriptor<DeleteModelDeploymentMonitoringJobRequest, Operation> 474 deleteModelDeploymentMonitoringJobMethodDescriptor = 475 MethodDescriptor.<DeleteModelDeploymentMonitoringJobRequest, Operation>newBuilder() 476 .setType(MethodDescriptor.MethodType.UNARY) 477 .setFullMethodName( 478 "google.cloud.aiplatform.v1.JobService/DeleteModelDeploymentMonitoringJob") 479 .setRequestMarshaller( 480 ProtoUtils.marshaller( 481 DeleteModelDeploymentMonitoringJobRequest.getDefaultInstance())) 482 .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance())) 483 .build(); 484 485 private static final MethodDescriptor<PauseModelDeploymentMonitoringJobRequest, Empty> 486 pauseModelDeploymentMonitoringJobMethodDescriptor = 487 MethodDescriptor.<PauseModelDeploymentMonitoringJobRequest, Empty>newBuilder() 488 .setType(MethodDescriptor.MethodType.UNARY) 489 .setFullMethodName( 490 "google.cloud.aiplatform.v1.JobService/PauseModelDeploymentMonitoringJob") 491 .setRequestMarshaller( 492 ProtoUtils.marshaller( 493 PauseModelDeploymentMonitoringJobRequest.getDefaultInstance())) 494 .setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance())) 495 .build(); 496 497 private static final MethodDescriptor<ResumeModelDeploymentMonitoringJobRequest, Empty> 498 resumeModelDeploymentMonitoringJobMethodDescriptor = 499 MethodDescriptor.<ResumeModelDeploymentMonitoringJobRequest, Empty>newBuilder() 500 .setType(MethodDescriptor.MethodType.UNARY) 501 .setFullMethodName( 502 "google.cloud.aiplatform.v1.JobService/ResumeModelDeploymentMonitoringJob") 503 .setRequestMarshaller( 504 ProtoUtils.marshaller( 505 ResumeModelDeploymentMonitoringJobRequest.getDefaultInstance())) 506 .setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance())) 507 .build(); 508 509 private static final MethodDescriptor<ListLocationsRequest, ListLocationsResponse> 510 listLocationsMethodDescriptor = 511 MethodDescriptor.<ListLocationsRequest, ListLocationsResponse>newBuilder() 512 .setType(MethodDescriptor.MethodType.UNARY) 513 .setFullMethodName("google.cloud.location.Locations/ListLocations") 514 .setRequestMarshaller( 515 ProtoUtils.marshaller(ListLocationsRequest.getDefaultInstance())) 516 .setResponseMarshaller( 517 ProtoUtils.marshaller(ListLocationsResponse.getDefaultInstance())) 518 .build(); 519 520 private static final MethodDescriptor<GetLocationRequest, Location> getLocationMethodDescriptor = 521 MethodDescriptor.<GetLocationRequest, Location>newBuilder() 522 .setType(MethodDescriptor.MethodType.UNARY) 523 .setFullMethodName("google.cloud.location.Locations/GetLocation") 524 .setRequestMarshaller(ProtoUtils.marshaller(GetLocationRequest.getDefaultInstance())) 525 .setResponseMarshaller(ProtoUtils.marshaller(Location.getDefaultInstance())) 526 .build(); 527 528 private static final MethodDescriptor<SetIamPolicyRequest, Policy> setIamPolicyMethodDescriptor = 529 MethodDescriptor.<SetIamPolicyRequest, Policy>newBuilder() 530 .setType(MethodDescriptor.MethodType.UNARY) 531 .setFullMethodName("google.iam.v1.IAMPolicy/SetIamPolicy") 532 .setRequestMarshaller(ProtoUtils.marshaller(SetIamPolicyRequest.getDefaultInstance())) 533 .setResponseMarshaller(ProtoUtils.marshaller(Policy.getDefaultInstance())) 534 .build(); 535 536 private static final MethodDescriptor<GetIamPolicyRequest, Policy> getIamPolicyMethodDescriptor = 537 MethodDescriptor.<GetIamPolicyRequest, Policy>newBuilder() 538 .setType(MethodDescriptor.MethodType.UNARY) 539 .setFullMethodName("google.iam.v1.IAMPolicy/GetIamPolicy") 540 .setRequestMarshaller(ProtoUtils.marshaller(GetIamPolicyRequest.getDefaultInstance())) 541 .setResponseMarshaller(ProtoUtils.marshaller(Policy.getDefaultInstance())) 542 .build(); 543 544 private static final MethodDescriptor<TestIamPermissionsRequest, TestIamPermissionsResponse> 545 testIamPermissionsMethodDescriptor = 546 MethodDescriptor.<TestIamPermissionsRequest, TestIamPermissionsResponse>newBuilder() 547 .setType(MethodDescriptor.MethodType.UNARY) 548 .setFullMethodName("google.iam.v1.IAMPolicy/TestIamPermissions") 549 .setRequestMarshaller( 550 ProtoUtils.marshaller(TestIamPermissionsRequest.getDefaultInstance())) 551 .setResponseMarshaller( 552 ProtoUtils.marshaller(TestIamPermissionsResponse.getDefaultInstance())) 553 .build(); 554 555 private final UnaryCallable<CreateCustomJobRequest, CustomJob> createCustomJobCallable; 556 private final UnaryCallable<GetCustomJobRequest, CustomJob> getCustomJobCallable; 557 private final UnaryCallable<ListCustomJobsRequest, ListCustomJobsResponse> listCustomJobsCallable; 558 private final UnaryCallable<ListCustomJobsRequest, ListCustomJobsPagedResponse> 559 listCustomJobsPagedCallable; 560 private final UnaryCallable<DeleteCustomJobRequest, Operation> deleteCustomJobCallable; 561 private final OperationCallable<DeleteCustomJobRequest, Empty, DeleteOperationMetadata> 562 deleteCustomJobOperationCallable; 563 private final UnaryCallable<CancelCustomJobRequest, Empty> cancelCustomJobCallable; 564 private final UnaryCallable<CreateDataLabelingJobRequest, DataLabelingJob> 565 createDataLabelingJobCallable; 566 private final UnaryCallable<GetDataLabelingJobRequest, DataLabelingJob> 567 getDataLabelingJobCallable; 568 private final UnaryCallable<ListDataLabelingJobsRequest, ListDataLabelingJobsResponse> 569 listDataLabelingJobsCallable; 570 private final UnaryCallable<ListDataLabelingJobsRequest, ListDataLabelingJobsPagedResponse> 571 listDataLabelingJobsPagedCallable; 572 private final UnaryCallable<DeleteDataLabelingJobRequest, Operation> 573 deleteDataLabelingJobCallable; 574 private final OperationCallable<DeleteDataLabelingJobRequest, Empty, DeleteOperationMetadata> 575 deleteDataLabelingJobOperationCallable; 576 private final UnaryCallable<CancelDataLabelingJobRequest, Empty> cancelDataLabelingJobCallable; 577 private final UnaryCallable<CreateHyperparameterTuningJobRequest, HyperparameterTuningJob> 578 createHyperparameterTuningJobCallable; 579 private final UnaryCallable<GetHyperparameterTuningJobRequest, HyperparameterTuningJob> 580 getHyperparameterTuningJobCallable; 581 private final UnaryCallable< 582 ListHyperparameterTuningJobsRequest, ListHyperparameterTuningJobsResponse> 583 listHyperparameterTuningJobsCallable; 584 private final UnaryCallable< 585 ListHyperparameterTuningJobsRequest, ListHyperparameterTuningJobsPagedResponse> 586 listHyperparameterTuningJobsPagedCallable; 587 private final UnaryCallable<DeleteHyperparameterTuningJobRequest, Operation> 588 deleteHyperparameterTuningJobCallable; 589 private final OperationCallable< 590 DeleteHyperparameterTuningJobRequest, Empty, DeleteOperationMetadata> 591 deleteHyperparameterTuningJobOperationCallable; 592 private final UnaryCallable<CancelHyperparameterTuningJobRequest, Empty> 593 cancelHyperparameterTuningJobCallable; 594 private final UnaryCallable<CreateNasJobRequest, NasJob> createNasJobCallable; 595 private final UnaryCallable<GetNasJobRequest, NasJob> getNasJobCallable; 596 private final UnaryCallable<ListNasJobsRequest, ListNasJobsResponse> listNasJobsCallable; 597 private final UnaryCallable<ListNasJobsRequest, ListNasJobsPagedResponse> 598 listNasJobsPagedCallable; 599 private final UnaryCallable<DeleteNasJobRequest, Operation> deleteNasJobCallable; 600 private final OperationCallable<DeleteNasJobRequest, Empty, DeleteOperationMetadata> 601 deleteNasJobOperationCallable; 602 private final UnaryCallable<CancelNasJobRequest, Empty> cancelNasJobCallable; 603 private final UnaryCallable<GetNasTrialDetailRequest, NasTrialDetail> getNasTrialDetailCallable; 604 private final UnaryCallable<ListNasTrialDetailsRequest, ListNasTrialDetailsResponse> 605 listNasTrialDetailsCallable; 606 private final UnaryCallable<ListNasTrialDetailsRequest, ListNasTrialDetailsPagedResponse> 607 listNasTrialDetailsPagedCallable; 608 private final UnaryCallable<CreateBatchPredictionJobRequest, BatchPredictionJob> 609 createBatchPredictionJobCallable; 610 private final UnaryCallable<GetBatchPredictionJobRequest, BatchPredictionJob> 611 getBatchPredictionJobCallable; 612 private final UnaryCallable<ListBatchPredictionJobsRequest, ListBatchPredictionJobsResponse> 613 listBatchPredictionJobsCallable; 614 private final UnaryCallable<ListBatchPredictionJobsRequest, ListBatchPredictionJobsPagedResponse> 615 listBatchPredictionJobsPagedCallable; 616 private final UnaryCallable<DeleteBatchPredictionJobRequest, Operation> 617 deleteBatchPredictionJobCallable; 618 private final OperationCallable<DeleteBatchPredictionJobRequest, Empty, DeleteOperationMetadata> 619 deleteBatchPredictionJobOperationCallable; 620 private final UnaryCallable<CancelBatchPredictionJobRequest, Empty> 621 cancelBatchPredictionJobCallable; 622 private final UnaryCallable< 623 CreateModelDeploymentMonitoringJobRequest, ModelDeploymentMonitoringJob> 624 createModelDeploymentMonitoringJobCallable; 625 private final UnaryCallable< 626 SearchModelDeploymentMonitoringStatsAnomaliesRequest, 627 SearchModelDeploymentMonitoringStatsAnomaliesResponse> 628 searchModelDeploymentMonitoringStatsAnomaliesCallable; 629 private final UnaryCallable< 630 SearchModelDeploymentMonitoringStatsAnomaliesRequest, 631 SearchModelDeploymentMonitoringStatsAnomaliesPagedResponse> 632 searchModelDeploymentMonitoringStatsAnomaliesPagedCallable; 633 private final UnaryCallable<GetModelDeploymentMonitoringJobRequest, ModelDeploymentMonitoringJob> 634 getModelDeploymentMonitoringJobCallable; 635 private final UnaryCallable< 636 ListModelDeploymentMonitoringJobsRequest, ListModelDeploymentMonitoringJobsResponse> 637 listModelDeploymentMonitoringJobsCallable; 638 private final UnaryCallable< 639 ListModelDeploymentMonitoringJobsRequest, ListModelDeploymentMonitoringJobsPagedResponse> 640 listModelDeploymentMonitoringJobsPagedCallable; 641 private final UnaryCallable<UpdateModelDeploymentMonitoringJobRequest, Operation> 642 updateModelDeploymentMonitoringJobCallable; 643 private final OperationCallable< 644 UpdateModelDeploymentMonitoringJobRequest, 645 ModelDeploymentMonitoringJob, 646 UpdateModelDeploymentMonitoringJobOperationMetadata> 647 updateModelDeploymentMonitoringJobOperationCallable; 648 private final UnaryCallable<DeleteModelDeploymentMonitoringJobRequest, Operation> 649 deleteModelDeploymentMonitoringJobCallable; 650 private final OperationCallable< 651 DeleteModelDeploymentMonitoringJobRequest, Empty, DeleteOperationMetadata> 652 deleteModelDeploymentMonitoringJobOperationCallable; 653 private final UnaryCallable<PauseModelDeploymentMonitoringJobRequest, Empty> 654 pauseModelDeploymentMonitoringJobCallable; 655 private final UnaryCallable<ResumeModelDeploymentMonitoringJobRequest, Empty> 656 resumeModelDeploymentMonitoringJobCallable; 657 private final UnaryCallable<ListLocationsRequest, ListLocationsResponse> listLocationsCallable; 658 private final UnaryCallable<ListLocationsRequest, ListLocationsPagedResponse> 659 listLocationsPagedCallable; 660 private final UnaryCallable<GetLocationRequest, Location> getLocationCallable; 661 private final UnaryCallable<SetIamPolicyRequest, Policy> setIamPolicyCallable; 662 private final UnaryCallable<GetIamPolicyRequest, Policy> getIamPolicyCallable; 663 private final UnaryCallable<TestIamPermissionsRequest, TestIamPermissionsResponse> 664 testIamPermissionsCallable; 665 666 private final BackgroundResource backgroundResources; 667 private final GrpcOperationsStub operationsStub; 668 private final GrpcStubCallableFactory callableFactory; 669 create(JobServiceStubSettings settings)670 public static final GrpcJobServiceStub create(JobServiceStubSettings settings) 671 throws IOException { 672 return new GrpcJobServiceStub(settings, ClientContext.create(settings)); 673 } 674 create(ClientContext clientContext)675 public static final GrpcJobServiceStub create(ClientContext clientContext) throws IOException { 676 return new GrpcJobServiceStub(JobServiceStubSettings.newBuilder().build(), clientContext); 677 } 678 create( ClientContext clientContext, GrpcStubCallableFactory callableFactory)679 public static final GrpcJobServiceStub create( 680 ClientContext clientContext, GrpcStubCallableFactory callableFactory) throws IOException { 681 return new GrpcJobServiceStub( 682 JobServiceStubSettings.newBuilder().build(), clientContext, callableFactory); 683 } 684 685 /** 686 * Constructs an instance of GrpcJobServiceStub, using the given settings. This is protected so 687 * that it is easy to make a subclass, but otherwise, the static factory methods should be 688 * preferred. 689 */ GrpcJobServiceStub(JobServiceStubSettings settings, ClientContext clientContext)690 protected GrpcJobServiceStub(JobServiceStubSettings settings, ClientContext clientContext) 691 throws IOException { 692 this(settings, clientContext, new GrpcJobServiceCallableFactory()); 693 } 694 695 /** 696 * Constructs an instance of GrpcJobServiceStub, using the given settings. This is protected so 697 * that it is easy to make a subclass, but otherwise, the static factory methods should be 698 * preferred. 699 */ GrpcJobServiceStub( JobServiceStubSettings settings, ClientContext clientContext, GrpcStubCallableFactory callableFactory)700 protected GrpcJobServiceStub( 701 JobServiceStubSettings settings, 702 ClientContext clientContext, 703 GrpcStubCallableFactory callableFactory) 704 throws IOException { 705 this.callableFactory = callableFactory; 706 this.operationsStub = GrpcOperationsStub.create(clientContext, callableFactory); 707 708 GrpcCallSettings<CreateCustomJobRequest, CustomJob> createCustomJobTransportSettings = 709 GrpcCallSettings.<CreateCustomJobRequest, CustomJob>newBuilder() 710 .setMethodDescriptor(createCustomJobMethodDescriptor) 711 .setParamsExtractor( 712 request -> { 713 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 714 params.put("parent", String.valueOf(request.getParent())); 715 return params.build(); 716 }) 717 .build(); 718 GrpcCallSettings<GetCustomJobRequest, CustomJob> getCustomJobTransportSettings = 719 GrpcCallSettings.<GetCustomJobRequest, CustomJob>newBuilder() 720 .setMethodDescriptor(getCustomJobMethodDescriptor) 721 .setParamsExtractor( 722 request -> { 723 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 724 params.put("name", String.valueOf(request.getName())); 725 return params.build(); 726 }) 727 .build(); 728 GrpcCallSettings<ListCustomJobsRequest, ListCustomJobsResponse> 729 listCustomJobsTransportSettings = 730 GrpcCallSettings.<ListCustomJobsRequest, ListCustomJobsResponse>newBuilder() 731 .setMethodDescriptor(listCustomJobsMethodDescriptor) 732 .setParamsExtractor( 733 request -> { 734 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 735 params.put("parent", String.valueOf(request.getParent())); 736 return params.build(); 737 }) 738 .build(); 739 GrpcCallSettings<DeleteCustomJobRequest, Operation> deleteCustomJobTransportSettings = 740 GrpcCallSettings.<DeleteCustomJobRequest, Operation>newBuilder() 741 .setMethodDescriptor(deleteCustomJobMethodDescriptor) 742 .setParamsExtractor( 743 request -> { 744 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 745 params.put("name", String.valueOf(request.getName())); 746 return params.build(); 747 }) 748 .build(); 749 GrpcCallSettings<CancelCustomJobRequest, Empty> cancelCustomJobTransportSettings = 750 GrpcCallSettings.<CancelCustomJobRequest, Empty>newBuilder() 751 .setMethodDescriptor(cancelCustomJobMethodDescriptor) 752 .setParamsExtractor( 753 request -> { 754 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 755 params.put("name", String.valueOf(request.getName())); 756 return params.build(); 757 }) 758 .build(); 759 GrpcCallSettings<CreateDataLabelingJobRequest, DataLabelingJob> 760 createDataLabelingJobTransportSettings = 761 GrpcCallSettings.<CreateDataLabelingJobRequest, DataLabelingJob>newBuilder() 762 .setMethodDescriptor(createDataLabelingJobMethodDescriptor) 763 .setParamsExtractor( 764 request -> { 765 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 766 params.put("parent", String.valueOf(request.getParent())); 767 return params.build(); 768 }) 769 .build(); 770 GrpcCallSettings<GetDataLabelingJobRequest, DataLabelingJob> 771 getDataLabelingJobTransportSettings = 772 GrpcCallSettings.<GetDataLabelingJobRequest, DataLabelingJob>newBuilder() 773 .setMethodDescriptor(getDataLabelingJobMethodDescriptor) 774 .setParamsExtractor( 775 request -> { 776 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 777 params.put("name", String.valueOf(request.getName())); 778 return params.build(); 779 }) 780 .build(); 781 GrpcCallSettings<ListDataLabelingJobsRequest, ListDataLabelingJobsResponse> 782 listDataLabelingJobsTransportSettings = 783 GrpcCallSettings.<ListDataLabelingJobsRequest, ListDataLabelingJobsResponse>newBuilder() 784 .setMethodDescriptor(listDataLabelingJobsMethodDescriptor) 785 .setParamsExtractor( 786 request -> { 787 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 788 params.put("parent", String.valueOf(request.getParent())); 789 return params.build(); 790 }) 791 .build(); 792 GrpcCallSettings<DeleteDataLabelingJobRequest, Operation> 793 deleteDataLabelingJobTransportSettings = 794 GrpcCallSettings.<DeleteDataLabelingJobRequest, Operation>newBuilder() 795 .setMethodDescriptor(deleteDataLabelingJobMethodDescriptor) 796 .setParamsExtractor( 797 request -> { 798 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 799 params.put("name", String.valueOf(request.getName())); 800 return params.build(); 801 }) 802 .build(); 803 GrpcCallSettings<CancelDataLabelingJobRequest, Empty> cancelDataLabelingJobTransportSettings = 804 GrpcCallSettings.<CancelDataLabelingJobRequest, Empty>newBuilder() 805 .setMethodDescriptor(cancelDataLabelingJobMethodDescriptor) 806 .setParamsExtractor( 807 request -> { 808 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 809 params.put("name", String.valueOf(request.getName())); 810 return params.build(); 811 }) 812 .build(); 813 GrpcCallSettings<CreateHyperparameterTuningJobRequest, HyperparameterTuningJob> 814 createHyperparameterTuningJobTransportSettings = 815 GrpcCallSettings 816 .<CreateHyperparameterTuningJobRequest, HyperparameterTuningJob>newBuilder() 817 .setMethodDescriptor(createHyperparameterTuningJobMethodDescriptor) 818 .setParamsExtractor( 819 request -> { 820 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 821 params.put("parent", String.valueOf(request.getParent())); 822 return params.build(); 823 }) 824 .build(); 825 GrpcCallSettings<GetHyperparameterTuningJobRequest, HyperparameterTuningJob> 826 getHyperparameterTuningJobTransportSettings = 827 GrpcCallSettings 828 .<GetHyperparameterTuningJobRequest, HyperparameterTuningJob>newBuilder() 829 .setMethodDescriptor(getHyperparameterTuningJobMethodDescriptor) 830 .setParamsExtractor( 831 request -> { 832 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 833 params.put("name", String.valueOf(request.getName())); 834 return params.build(); 835 }) 836 .build(); 837 GrpcCallSettings<ListHyperparameterTuningJobsRequest, ListHyperparameterTuningJobsResponse> 838 listHyperparameterTuningJobsTransportSettings = 839 GrpcCallSettings 840 .<ListHyperparameterTuningJobsRequest, ListHyperparameterTuningJobsResponse> 841 newBuilder() 842 .setMethodDescriptor(listHyperparameterTuningJobsMethodDescriptor) 843 .setParamsExtractor( 844 request -> { 845 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 846 params.put("parent", String.valueOf(request.getParent())); 847 return params.build(); 848 }) 849 .build(); 850 GrpcCallSettings<DeleteHyperparameterTuningJobRequest, Operation> 851 deleteHyperparameterTuningJobTransportSettings = 852 GrpcCallSettings.<DeleteHyperparameterTuningJobRequest, Operation>newBuilder() 853 .setMethodDescriptor(deleteHyperparameterTuningJobMethodDescriptor) 854 .setParamsExtractor( 855 request -> { 856 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 857 params.put("name", String.valueOf(request.getName())); 858 return params.build(); 859 }) 860 .build(); 861 GrpcCallSettings<CancelHyperparameterTuningJobRequest, Empty> 862 cancelHyperparameterTuningJobTransportSettings = 863 GrpcCallSettings.<CancelHyperparameterTuningJobRequest, Empty>newBuilder() 864 .setMethodDescriptor(cancelHyperparameterTuningJobMethodDescriptor) 865 .setParamsExtractor( 866 request -> { 867 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 868 params.put("name", String.valueOf(request.getName())); 869 return params.build(); 870 }) 871 .build(); 872 GrpcCallSettings<CreateNasJobRequest, NasJob> createNasJobTransportSettings = 873 GrpcCallSettings.<CreateNasJobRequest, NasJob>newBuilder() 874 .setMethodDescriptor(createNasJobMethodDescriptor) 875 .setParamsExtractor( 876 request -> { 877 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 878 params.put("parent", String.valueOf(request.getParent())); 879 return params.build(); 880 }) 881 .build(); 882 GrpcCallSettings<GetNasJobRequest, NasJob> getNasJobTransportSettings = 883 GrpcCallSettings.<GetNasJobRequest, NasJob>newBuilder() 884 .setMethodDescriptor(getNasJobMethodDescriptor) 885 .setParamsExtractor( 886 request -> { 887 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 888 params.put("name", String.valueOf(request.getName())); 889 return params.build(); 890 }) 891 .build(); 892 GrpcCallSettings<ListNasJobsRequest, ListNasJobsResponse> listNasJobsTransportSettings = 893 GrpcCallSettings.<ListNasJobsRequest, ListNasJobsResponse>newBuilder() 894 .setMethodDescriptor(listNasJobsMethodDescriptor) 895 .setParamsExtractor( 896 request -> { 897 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 898 params.put("parent", String.valueOf(request.getParent())); 899 return params.build(); 900 }) 901 .build(); 902 GrpcCallSettings<DeleteNasJobRequest, Operation> deleteNasJobTransportSettings = 903 GrpcCallSettings.<DeleteNasJobRequest, Operation>newBuilder() 904 .setMethodDescriptor(deleteNasJobMethodDescriptor) 905 .setParamsExtractor( 906 request -> { 907 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 908 params.put("name", String.valueOf(request.getName())); 909 return params.build(); 910 }) 911 .build(); 912 GrpcCallSettings<CancelNasJobRequest, Empty> cancelNasJobTransportSettings = 913 GrpcCallSettings.<CancelNasJobRequest, Empty>newBuilder() 914 .setMethodDescriptor(cancelNasJobMethodDescriptor) 915 .setParamsExtractor( 916 request -> { 917 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 918 params.put("name", String.valueOf(request.getName())); 919 return params.build(); 920 }) 921 .build(); 922 GrpcCallSettings<GetNasTrialDetailRequest, NasTrialDetail> getNasTrialDetailTransportSettings = 923 GrpcCallSettings.<GetNasTrialDetailRequest, NasTrialDetail>newBuilder() 924 .setMethodDescriptor(getNasTrialDetailMethodDescriptor) 925 .setParamsExtractor( 926 request -> { 927 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 928 params.put("name", String.valueOf(request.getName())); 929 return params.build(); 930 }) 931 .build(); 932 GrpcCallSettings<ListNasTrialDetailsRequest, ListNasTrialDetailsResponse> 933 listNasTrialDetailsTransportSettings = 934 GrpcCallSettings.<ListNasTrialDetailsRequest, ListNasTrialDetailsResponse>newBuilder() 935 .setMethodDescriptor(listNasTrialDetailsMethodDescriptor) 936 .setParamsExtractor( 937 request -> { 938 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 939 params.put("parent", String.valueOf(request.getParent())); 940 return params.build(); 941 }) 942 .build(); 943 GrpcCallSettings<CreateBatchPredictionJobRequest, BatchPredictionJob> 944 createBatchPredictionJobTransportSettings = 945 GrpcCallSettings.<CreateBatchPredictionJobRequest, BatchPredictionJob>newBuilder() 946 .setMethodDescriptor(createBatchPredictionJobMethodDescriptor) 947 .setParamsExtractor( 948 request -> { 949 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 950 params.put("parent", String.valueOf(request.getParent())); 951 return params.build(); 952 }) 953 .build(); 954 GrpcCallSettings<GetBatchPredictionJobRequest, BatchPredictionJob> 955 getBatchPredictionJobTransportSettings = 956 GrpcCallSettings.<GetBatchPredictionJobRequest, BatchPredictionJob>newBuilder() 957 .setMethodDescriptor(getBatchPredictionJobMethodDescriptor) 958 .setParamsExtractor( 959 request -> { 960 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 961 params.put("name", String.valueOf(request.getName())); 962 return params.build(); 963 }) 964 .build(); 965 GrpcCallSettings<ListBatchPredictionJobsRequest, ListBatchPredictionJobsResponse> 966 listBatchPredictionJobsTransportSettings = 967 GrpcCallSettings 968 .<ListBatchPredictionJobsRequest, ListBatchPredictionJobsResponse>newBuilder() 969 .setMethodDescriptor(listBatchPredictionJobsMethodDescriptor) 970 .setParamsExtractor( 971 request -> { 972 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 973 params.put("parent", String.valueOf(request.getParent())); 974 return params.build(); 975 }) 976 .build(); 977 GrpcCallSettings<DeleteBatchPredictionJobRequest, Operation> 978 deleteBatchPredictionJobTransportSettings = 979 GrpcCallSettings.<DeleteBatchPredictionJobRequest, Operation>newBuilder() 980 .setMethodDescriptor(deleteBatchPredictionJobMethodDescriptor) 981 .setParamsExtractor( 982 request -> { 983 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 984 params.put("name", String.valueOf(request.getName())); 985 return params.build(); 986 }) 987 .build(); 988 GrpcCallSettings<CancelBatchPredictionJobRequest, Empty> 989 cancelBatchPredictionJobTransportSettings = 990 GrpcCallSettings.<CancelBatchPredictionJobRequest, Empty>newBuilder() 991 .setMethodDescriptor(cancelBatchPredictionJobMethodDescriptor) 992 .setParamsExtractor( 993 request -> { 994 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 995 params.put("name", String.valueOf(request.getName())); 996 return params.build(); 997 }) 998 .build(); 999 GrpcCallSettings<CreateModelDeploymentMonitoringJobRequest, ModelDeploymentMonitoringJob> 1000 createModelDeploymentMonitoringJobTransportSettings = 1001 GrpcCallSettings 1002 .<CreateModelDeploymentMonitoringJobRequest, ModelDeploymentMonitoringJob> 1003 newBuilder() 1004 .setMethodDescriptor(createModelDeploymentMonitoringJobMethodDescriptor) 1005 .setParamsExtractor( 1006 request -> { 1007 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 1008 params.put("parent", String.valueOf(request.getParent())); 1009 return params.build(); 1010 }) 1011 .build(); 1012 GrpcCallSettings< 1013 SearchModelDeploymentMonitoringStatsAnomaliesRequest, 1014 SearchModelDeploymentMonitoringStatsAnomaliesResponse> 1015 searchModelDeploymentMonitoringStatsAnomaliesTransportSettings = 1016 GrpcCallSettings 1017 .<SearchModelDeploymentMonitoringStatsAnomaliesRequest, 1018 SearchModelDeploymentMonitoringStatsAnomaliesResponse> 1019 newBuilder() 1020 .setMethodDescriptor(searchModelDeploymentMonitoringStatsAnomaliesMethodDescriptor) 1021 .setParamsExtractor( 1022 request -> { 1023 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 1024 params.put( 1025 "model_deployment_monitoring_job", 1026 String.valueOf(request.getModelDeploymentMonitoringJob())); 1027 return params.build(); 1028 }) 1029 .build(); 1030 GrpcCallSettings<GetModelDeploymentMonitoringJobRequest, ModelDeploymentMonitoringJob> 1031 getModelDeploymentMonitoringJobTransportSettings = 1032 GrpcCallSettings 1033 .<GetModelDeploymentMonitoringJobRequest, ModelDeploymentMonitoringJob>newBuilder() 1034 .setMethodDescriptor(getModelDeploymentMonitoringJobMethodDescriptor) 1035 .setParamsExtractor( 1036 request -> { 1037 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 1038 params.put("name", String.valueOf(request.getName())); 1039 return params.build(); 1040 }) 1041 .build(); 1042 GrpcCallSettings< 1043 ListModelDeploymentMonitoringJobsRequest, ListModelDeploymentMonitoringJobsResponse> 1044 listModelDeploymentMonitoringJobsTransportSettings = 1045 GrpcCallSettings 1046 .<ListModelDeploymentMonitoringJobsRequest, 1047 ListModelDeploymentMonitoringJobsResponse> 1048 newBuilder() 1049 .setMethodDescriptor(listModelDeploymentMonitoringJobsMethodDescriptor) 1050 .setParamsExtractor( 1051 request -> { 1052 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 1053 params.put("parent", String.valueOf(request.getParent())); 1054 return params.build(); 1055 }) 1056 .build(); 1057 GrpcCallSettings<UpdateModelDeploymentMonitoringJobRequest, Operation> 1058 updateModelDeploymentMonitoringJobTransportSettings = 1059 GrpcCallSettings.<UpdateModelDeploymentMonitoringJobRequest, Operation>newBuilder() 1060 .setMethodDescriptor(updateModelDeploymentMonitoringJobMethodDescriptor) 1061 .setParamsExtractor( 1062 request -> { 1063 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 1064 params.put( 1065 "model_deployment_monitoring_job.name", 1066 String.valueOf(request.getModelDeploymentMonitoringJob().getName())); 1067 return params.build(); 1068 }) 1069 .build(); 1070 GrpcCallSettings<DeleteModelDeploymentMonitoringJobRequest, Operation> 1071 deleteModelDeploymentMonitoringJobTransportSettings = 1072 GrpcCallSettings.<DeleteModelDeploymentMonitoringJobRequest, Operation>newBuilder() 1073 .setMethodDescriptor(deleteModelDeploymentMonitoringJobMethodDescriptor) 1074 .setParamsExtractor( 1075 request -> { 1076 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 1077 params.put("name", String.valueOf(request.getName())); 1078 return params.build(); 1079 }) 1080 .build(); 1081 GrpcCallSettings<PauseModelDeploymentMonitoringJobRequest, Empty> 1082 pauseModelDeploymentMonitoringJobTransportSettings = 1083 GrpcCallSettings.<PauseModelDeploymentMonitoringJobRequest, Empty>newBuilder() 1084 .setMethodDescriptor(pauseModelDeploymentMonitoringJobMethodDescriptor) 1085 .setParamsExtractor( 1086 request -> { 1087 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 1088 params.put("name", String.valueOf(request.getName())); 1089 return params.build(); 1090 }) 1091 .build(); 1092 GrpcCallSettings<ResumeModelDeploymentMonitoringJobRequest, Empty> 1093 resumeModelDeploymentMonitoringJobTransportSettings = 1094 GrpcCallSettings.<ResumeModelDeploymentMonitoringJobRequest, Empty>newBuilder() 1095 .setMethodDescriptor(resumeModelDeploymentMonitoringJobMethodDescriptor) 1096 .setParamsExtractor( 1097 request -> { 1098 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 1099 params.put("name", String.valueOf(request.getName())); 1100 return params.build(); 1101 }) 1102 .build(); 1103 GrpcCallSettings<ListLocationsRequest, ListLocationsResponse> listLocationsTransportSettings = 1104 GrpcCallSettings.<ListLocationsRequest, ListLocationsResponse>newBuilder() 1105 .setMethodDescriptor(listLocationsMethodDescriptor) 1106 .setParamsExtractor( 1107 request -> { 1108 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 1109 params.put("name", String.valueOf(request.getName())); 1110 return params.build(); 1111 }) 1112 .build(); 1113 GrpcCallSettings<GetLocationRequest, Location> getLocationTransportSettings = 1114 GrpcCallSettings.<GetLocationRequest, Location>newBuilder() 1115 .setMethodDescriptor(getLocationMethodDescriptor) 1116 .setParamsExtractor( 1117 request -> { 1118 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 1119 params.put("name", String.valueOf(request.getName())); 1120 return params.build(); 1121 }) 1122 .build(); 1123 GrpcCallSettings<SetIamPolicyRequest, Policy> setIamPolicyTransportSettings = 1124 GrpcCallSettings.<SetIamPolicyRequest, Policy>newBuilder() 1125 .setMethodDescriptor(setIamPolicyMethodDescriptor) 1126 .setParamsExtractor( 1127 request -> { 1128 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 1129 params.put("resource", String.valueOf(request.getResource())); 1130 return params.build(); 1131 }) 1132 .build(); 1133 GrpcCallSettings<GetIamPolicyRequest, Policy> getIamPolicyTransportSettings = 1134 GrpcCallSettings.<GetIamPolicyRequest, Policy>newBuilder() 1135 .setMethodDescriptor(getIamPolicyMethodDescriptor) 1136 .setParamsExtractor( 1137 request -> { 1138 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 1139 params.put("resource", String.valueOf(request.getResource())); 1140 return params.build(); 1141 }) 1142 .build(); 1143 GrpcCallSettings<TestIamPermissionsRequest, TestIamPermissionsResponse> 1144 testIamPermissionsTransportSettings = 1145 GrpcCallSettings.<TestIamPermissionsRequest, TestIamPermissionsResponse>newBuilder() 1146 .setMethodDescriptor(testIamPermissionsMethodDescriptor) 1147 .setParamsExtractor( 1148 request -> { 1149 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 1150 params.put("resource", String.valueOf(request.getResource())); 1151 return params.build(); 1152 }) 1153 .build(); 1154 1155 this.createCustomJobCallable = 1156 callableFactory.createUnaryCallable( 1157 createCustomJobTransportSettings, settings.createCustomJobSettings(), clientContext); 1158 this.getCustomJobCallable = 1159 callableFactory.createUnaryCallable( 1160 getCustomJobTransportSettings, settings.getCustomJobSettings(), clientContext); 1161 this.listCustomJobsCallable = 1162 callableFactory.createUnaryCallable( 1163 listCustomJobsTransportSettings, settings.listCustomJobsSettings(), clientContext); 1164 this.listCustomJobsPagedCallable = 1165 callableFactory.createPagedCallable( 1166 listCustomJobsTransportSettings, settings.listCustomJobsSettings(), clientContext); 1167 this.deleteCustomJobCallable = 1168 callableFactory.createUnaryCallable( 1169 deleteCustomJobTransportSettings, settings.deleteCustomJobSettings(), clientContext); 1170 this.deleteCustomJobOperationCallable = 1171 callableFactory.createOperationCallable( 1172 deleteCustomJobTransportSettings, 1173 settings.deleteCustomJobOperationSettings(), 1174 clientContext, 1175 operationsStub); 1176 this.cancelCustomJobCallable = 1177 callableFactory.createUnaryCallable( 1178 cancelCustomJobTransportSettings, settings.cancelCustomJobSettings(), clientContext); 1179 this.createDataLabelingJobCallable = 1180 callableFactory.createUnaryCallable( 1181 createDataLabelingJobTransportSettings, 1182 settings.createDataLabelingJobSettings(), 1183 clientContext); 1184 this.getDataLabelingJobCallable = 1185 callableFactory.createUnaryCallable( 1186 getDataLabelingJobTransportSettings, 1187 settings.getDataLabelingJobSettings(), 1188 clientContext); 1189 this.listDataLabelingJobsCallable = 1190 callableFactory.createUnaryCallable( 1191 listDataLabelingJobsTransportSettings, 1192 settings.listDataLabelingJobsSettings(), 1193 clientContext); 1194 this.listDataLabelingJobsPagedCallable = 1195 callableFactory.createPagedCallable( 1196 listDataLabelingJobsTransportSettings, 1197 settings.listDataLabelingJobsSettings(), 1198 clientContext); 1199 this.deleteDataLabelingJobCallable = 1200 callableFactory.createUnaryCallable( 1201 deleteDataLabelingJobTransportSettings, 1202 settings.deleteDataLabelingJobSettings(), 1203 clientContext); 1204 this.deleteDataLabelingJobOperationCallable = 1205 callableFactory.createOperationCallable( 1206 deleteDataLabelingJobTransportSettings, 1207 settings.deleteDataLabelingJobOperationSettings(), 1208 clientContext, 1209 operationsStub); 1210 this.cancelDataLabelingJobCallable = 1211 callableFactory.createUnaryCallable( 1212 cancelDataLabelingJobTransportSettings, 1213 settings.cancelDataLabelingJobSettings(), 1214 clientContext); 1215 this.createHyperparameterTuningJobCallable = 1216 callableFactory.createUnaryCallable( 1217 createHyperparameterTuningJobTransportSettings, 1218 settings.createHyperparameterTuningJobSettings(), 1219 clientContext); 1220 this.getHyperparameterTuningJobCallable = 1221 callableFactory.createUnaryCallable( 1222 getHyperparameterTuningJobTransportSettings, 1223 settings.getHyperparameterTuningJobSettings(), 1224 clientContext); 1225 this.listHyperparameterTuningJobsCallable = 1226 callableFactory.createUnaryCallable( 1227 listHyperparameterTuningJobsTransportSettings, 1228 settings.listHyperparameterTuningJobsSettings(), 1229 clientContext); 1230 this.listHyperparameterTuningJobsPagedCallable = 1231 callableFactory.createPagedCallable( 1232 listHyperparameterTuningJobsTransportSettings, 1233 settings.listHyperparameterTuningJobsSettings(), 1234 clientContext); 1235 this.deleteHyperparameterTuningJobCallable = 1236 callableFactory.createUnaryCallable( 1237 deleteHyperparameterTuningJobTransportSettings, 1238 settings.deleteHyperparameterTuningJobSettings(), 1239 clientContext); 1240 this.deleteHyperparameterTuningJobOperationCallable = 1241 callableFactory.createOperationCallable( 1242 deleteHyperparameterTuningJobTransportSettings, 1243 settings.deleteHyperparameterTuningJobOperationSettings(), 1244 clientContext, 1245 operationsStub); 1246 this.cancelHyperparameterTuningJobCallable = 1247 callableFactory.createUnaryCallable( 1248 cancelHyperparameterTuningJobTransportSettings, 1249 settings.cancelHyperparameterTuningJobSettings(), 1250 clientContext); 1251 this.createNasJobCallable = 1252 callableFactory.createUnaryCallable( 1253 createNasJobTransportSettings, settings.createNasJobSettings(), clientContext); 1254 this.getNasJobCallable = 1255 callableFactory.createUnaryCallable( 1256 getNasJobTransportSettings, settings.getNasJobSettings(), clientContext); 1257 this.listNasJobsCallable = 1258 callableFactory.createUnaryCallable( 1259 listNasJobsTransportSettings, settings.listNasJobsSettings(), clientContext); 1260 this.listNasJobsPagedCallable = 1261 callableFactory.createPagedCallable( 1262 listNasJobsTransportSettings, settings.listNasJobsSettings(), clientContext); 1263 this.deleteNasJobCallable = 1264 callableFactory.createUnaryCallable( 1265 deleteNasJobTransportSettings, settings.deleteNasJobSettings(), clientContext); 1266 this.deleteNasJobOperationCallable = 1267 callableFactory.createOperationCallable( 1268 deleteNasJobTransportSettings, 1269 settings.deleteNasJobOperationSettings(), 1270 clientContext, 1271 operationsStub); 1272 this.cancelNasJobCallable = 1273 callableFactory.createUnaryCallable( 1274 cancelNasJobTransportSettings, settings.cancelNasJobSettings(), clientContext); 1275 this.getNasTrialDetailCallable = 1276 callableFactory.createUnaryCallable( 1277 getNasTrialDetailTransportSettings, 1278 settings.getNasTrialDetailSettings(), 1279 clientContext); 1280 this.listNasTrialDetailsCallable = 1281 callableFactory.createUnaryCallable( 1282 listNasTrialDetailsTransportSettings, 1283 settings.listNasTrialDetailsSettings(), 1284 clientContext); 1285 this.listNasTrialDetailsPagedCallable = 1286 callableFactory.createPagedCallable( 1287 listNasTrialDetailsTransportSettings, 1288 settings.listNasTrialDetailsSettings(), 1289 clientContext); 1290 this.createBatchPredictionJobCallable = 1291 callableFactory.createUnaryCallable( 1292 createBatchPredictionJobTransportSettings, 1293 settings.createBatchPredictionJobSettings(), 1294 clientContext); 1295 this.getBatchPredictionJobCallable = 1296 callableFactory.createUnaryCallable( 1297 getBatchPredictionJobTransportSettings, 1298 settings.getBatchPredictionJobSettings(), 1299 clientContext); 1300 this.listBatchPredictionJobsCallable = 1301 callableFactory.createUnaryCallable( 1302 listBatchPredictionJobsTransportSettings, 1303 settings.listBatchPredictionJobsSettings(), 1304 clientContext); 1305 this.listBatchPredictionJobsPagedCallable = 1306 callableFactory.createPagedCallable( 1307 listBatchPredictionJobsTransportSettings, 1308 settings.listBatchPredictionJobsSettings(), 1309 clientContext); 1310 this.deleteBatchPredictionJobCallable = 1311 callableFactory.createUnaryCallable( 1312 deleteBatchPredictionJobTransportSettings, 1313 settings.deleteBatchPredictionJobSettings(), 1314 clientContext); 1315 this.deleteBatchPredictionJobOperationCallable = 1316 callableFactory.createOperationCallable( 1317 deleteBatchPredictionJobTransportSettings, 1318 settings.deleteBatchPredictionJobOperationSettings(), 1319 clientContext, 1320 operationsStub); 1321 this.cancelBatchPredictionJobCallable = 1322 callableFactory.createUnaryCallable( 1323 cancelBatchPredictionJobTransportSettings, 1324 settings.cancelBatchPredictionJobSettings(), 1325 clientContext); 1326 this.createModelDeploymentMonitoringJobCallable = 1327 callableFactory.createUnaryCallable( 1328 createModelDeploymentMonitoringJobTransportSettings, 1329 settings.createModelDeploymentMonitoringJobSettings(), 1330 clientContext); 1331 this.searchModelDeploymentMonitoringStatsAnomaliesCallable = 1332 callableFactory.createUnaryCallable( 1333 searchModelDeploymentMonitoringStatsAnomaliesTransportSettings, 1334 settings.searchModelDeploymentMonitoringStatsAnomaliesSettings(), 1335 clientContext); 1336 this.searchModelDeploymentMonitoringStatsAnomaliesPagedCallable = 1337 callableFactory.createPagedCallable( 1338 searchModelDeploymentMonitoringStatsAnomaliesTransportSettings, 1339 settings.searchModelDeploymentMonitoringStatsAnomaliesSettings(), 1340 clientContext); 1341 this.getModelDeploymentMonitoringJobCallable = 1342 callableFactory.createUnaryCallable( 1343 getModelDeploymentMonitoringJobTransportSettings, 1344 settings.getModelDeploymentMonitoringJobSettings(), 1345 clientContext); 1346 this.listModelDeploymentMonitoringJobsCallable = 1347 callableFactory.createUnaryCallable( 1348 listModelDeploymentMonitoringJobsTransportSettings, 1349 settings.listModelDeploymentMonitoringJobsSettings(), 1350 clientContext); 1351 this.listModelDeploymentMonitoringJobsPagedCallable = 1352 callableFactory.createPagedCallable( 1353 listModelDeploymentMonitoringJobsTransportSettings, 1354 settings.listModelDeploymentMonitoringJobsSettings(), 1355 clientContext); 1356 this.updateModelDeploymentMonitoringJobCallable = 1357 callableFactory.createUnaryCallable( 1358 updateModelDeploymentMonitoringJobTransportSettings, 1359 settings.updateModelDeploymentMonitoringJobSettings(), 1360 clientContext); 1361 this.updateModelDeploymentMonitoringJobOperationCallable = 1362 callableFactory.createOperationCallable( 1363 updateModelDeploymentMonitoringJobTransportSettings, 1364 settings.updateModelDeploymentMonitoringJobOperationSettings(), 1365 clientContext, 1366 operationsStub); 1367 this.deleteModelDeploymentMonitoringJobCallable = 1368 callableFactory.createUnaryCallable( 1369 deleteModelDeploymentMonitoringJobTransportSettings, 1370 settings.deleteModelDeploymentMonitoringJobSettings(), 1371 clientContext); 1372 this.deleteModelDeploymentMonitoringJobOperationCallable = 1373 callableFactory.createOperationCallable( 1374 deleteModelDeploymentMonitoringJobTransportSettings, 1375 settings.deleteModelDeploymentMonitoringJobOperationSettings(), 1376 clientContext, 1377 operationsStub); 1378 this.pauseModelDeploymentMonitoringJobCallable = 1379 callableFactory.createUnaryCallable( 1380 pauseModelDeploymentMonitoringJobTransportSettings, 1381 settings.pauseModelDeploymentMonitoringJobSettings(), 1382 clientContext); 1383 this.resumeModelDeploymentMonitoringJobCallable = 1384 callableFactory.createUnaryCallable( 1385 resumeModelDeploymentMonitoringJobTransportSettings, 1386 settings.resumeModelDeploymentMonitoringJobSettings(), 1387 clientContext); 1388 this.listLocationsCallable = 1389 callableFactory.createUnaryCallable( 1390 listLocationsTransportSettings, settings.listLocationsSettings(), clientContext); 1391 this.listLocationsPagedCallable = 1392 callableFactory.createPagedCallable( 1393 listLocationsTransportSettings, settings.listLocationsSettings(), clientContext); 1394 this.getLocationCallable = 1395 callableFactory.createUnaryCallable( 1396 getLocationTransportSettings, settings.getLocationSettings(), clientContext); 1397 this.setIamPolicyCallable = 1398 callableFactory.createUnaryCallable( 1399 setIamPolicyTransportSettings, settings.setIamPolicySettings(), clientContext); 1400 this.getIamPolicyCallable = 1401 callableFactory.createUnaryCallable( 1402 getIamPolicyTransportSettings, settings.getIamPolicySettings(), clientContext); 1403 this.testIamPermissionsCallable = 1404 callableFactory.createUnaryCallable( 1405 testIamPermissionsTransportSettings, 1406 settings.testIamPermissionsSettings(), 1407 clientContext); 1408 1409 this.backgroundResources = 1410 new BackgroundResourceAggregation(clientContext.getBackgroundResources()); 1411 } 1412 getOperationsStub()1413 public GrpcOperationsStub getOperationsStub() { 1414 return operationsStub; 1415 } 1416 1417 @Override createCustomJobCallable()1418 public UnaryCallable<CreateCustomJobRequest, CustomJob> createCustomJobCallable() { 1419 return createCustomJobCallable; 1420 } 1421 1422 @Override getCustomJobCallable()1423 public UnaryCallable<GetCustomJobRequest, CustomJob> getCustomJobCallable() { 1424 return getCustomJobCallable; 1425 } 1426 1427 @Override listCustomJobsCallable()1428 public UnaryCallable<ListCustomJobsRequest, ListCustomJobsResponse> listCustomJobsCallable() { 1429 return listCustomJobsCallable; 1430 } 1431 1432 @Override 1433 public UnaryCallable<ListCustomJobsRequest, ListCustomJobsPagedResponse> listCustomJobsPagedCallable()1434 listCustomJobsPagedCallable() { 1435 return listCustomJobsPagedCallable; 1436 } 1437 1438 @Override deleteCustomJobCallable()1439 public UnaryCallable<DeleteCustomJobRequest, Operation> deleteCustomJobCallable() { 1440 return deleteCustomJobCallable; 1441 } 1442 1443 @Override 1444 public OperationCallable<DeleteCustomJobRequest, Empty, DeleteOperationMetadata> deleteCustomJobOperationCallable()1445 deleteCustomJobOperationCallable() { 1446 return deleteCustomJobOperationCallable; 1447 } 1448 1449 @Override cancelCustomJobCallable()1450 public UnaryCallable<CancelCustomJobRequest, Empty> cancelCustomJobCallable() { 1451 return cancelCustomJobCallable; 1452 } 1453 1454 @Override 1455 public UnaryCallable<CreateDataLabelingJobRequest, DataLabelingJob> createDataLabelingJobCallable()1456 createDataLabelingJobCallable() { 1457 return createDataLabelingJobCallable; 1458 } 1459 1460 @Override getDataLabelingJobCallable()1461 public UnaryCallable<GetDataLabelingJobRequest, DataLabelingJob> getDataLabelingJobCallable() { 1462 return getDataLabelingJobCallable; 1463 } 1464 1465 @Override 1466 public UnaryCallable<ListDataLabelingJobsRequest, ListDataLabelingJobsResponse> listDataLabelingJobsCallable()1467 listDataLabelingJobsCallable() { 1468 return listDataLabelingJobsCallable; 1469 } 1470 1471 @Override 1472 public UnaryCallable<ListDataLabelingJobsRequest, ListDataLabelingJobsPagedResponse> listDataLabelingJobsPagedCallable()1473 listDataLabelingJobsPagedCallable() { 1474 return listDataLabelingJobsPagedCallable; 1475 } 1476 1477 @Override deleteDataLabelingJobCallable()1478 public UnaryCallable<DeleteDataLabelingJobRequest, Operation> deleteDataLabelingJobCallable() { 1479 return deleteDataLabelingJobCallable; 1480 } 1481 1482 @Override 1483 public OperationCallable<DeleteDataLabelingJobRequest, Empty, DeleteOperationMetadata> deleteDataLabelingJobOperationCallable()1484 deleteDataLabelingJobOperationCallable() { 1485 return deleteDataLabelingJobOperationCallable; 1486 } 1487 1488 @Override cancelDataLabelingJobCallable()1489 public UnaryCallable<CancelDataLabelingJobRequest, Empty> cancelDataLabelingJobCallable() { 1490 return cancelDataLabelingJobCallable; 1491 } 1492 1493 @Override 1494 public UnaryCallable<CreateHyperparameterTuningJobRequest, HyperparameterTuningJob> createHyperparameterTuningJobCallable()1495 createHyperparameterTuningJobCallable() { 1496 return createHyperparameterTuningJobCallable; 1497 } 1498 1499 @Override 1500 public UnaryCallable<GetHyperparameterTuningJobRequest, HyperparameterTuningJob> getHyperparameterTuningJobCallable()1501 getHyperparameterTuningJobCallable() { 1502 return getHyperparameterTuningJobCallable; 1503 } 1504 1505 @Override 1506 public UnaryCallable<ListHyperparameterTuningJobsRequest, ListHyperparameterTuningJobsResponse> listHyperparameterTuningJobsCallable()1507 listHyperparameterTuningJobsCallable() { 1508 return listHyperparameterTuningJobsCallable; 1509 } 1510 1511 @Override 1512 public UnaryCallable< 1513 ListHyperparameterTuningJobsRequest, ListHyperparameterTuningJobsPagedResponse> listHyperparameterTuningJobsPagedCallable()1514 listHyperparameterTuningJobsPagedCallable() { 1515 return listHyperparameterTuningJobsPagedCallable; 1516 } 1517 1518 @Override 1519 public UnaryCallable<DeleteHyperparameterTuningJobRequest, Operation> deleteHyperparameterTuningJobCallable()1520 deleteHyperparameterTuningJobCallable() { 1521 return deleteHyperparameterTuningJobCallable; 1522 } 1523 1524 @Override 1525 public OperationCallable<DeleteHyperparameterTuningJobRequest, Empty, DeleteOperationMetadata> deleteHyperparameterTuningJobOperationCallable()1526 deleteHyperparameterTuningJobOperationCallable() { 1527 return deleteHyperparameterTuningJobOperationCallable; 1528 } 1529 1530 @Override 1531 public UnaryCallable<CancelHyperparameterTuningJobRequest, Empty> cancelHyperparameterTuningJobCallable()1532 cancelHyperparameterTuningJobCallable() { 1533 return cancelHyperparameterTuningJobCallable; 1534 } 1535 1536 @Override createNasJobCallable()1537 public UnaryCallable<CreateNasJobRequest, NasJob> createNasJobCallable() { 1538 return createNasJobCallable; 1539 } 1540 1541 @Override getNasJobCallable()1542 public UnaryCallable<GetNasJobRequest, NasJob> getNasJobCallable() { 1543 return getNasJobCallable; 1544 } 1545 1546 @Override listNasJobsCallable()1547 public UnaryCallable<ListNasJobsRequest, ListNasJobsResponse> listNasJobsCallable() { 1548 return listNasJobsCallable; 1549 } 1550 1551 @Override listNasJobsPagedCallable()1552 public UnaryCallable<ListNasJobsRequest, ListNasJobsPagedResponse> listNasJobsPagedCallable() { 1553 return listNasJobsPagedCallable; 1554 } 1555 1556 @Override deleteNasJobCallable()1557 public UnaryCallable<DeleteNasJobRequest, Operation> deleteNasJobCallable() { 1558 return deleteNasJobCallable; 1559 } 1560 1561 @Override 1562 public OperationCallable<DeleteNasJobRequest, Empty, DeleteOperationMetadata> deleteNasJobOperationCallable()1563 deleteNasJobOperationCallable() { 1564 return deleteNasJobOperationCallable; 1565 } 1566 1567 @Override cancelNasJobCallable()1568 public UnaryCallable<CancelNasJobRequest, Empty> cancelNasJobCallable() { 1569 return cancelNasJobCallable; 1570 } 1571 1572 @Override getNasTrialDetailCallable()1573 public UnaryCallable<GetNasTrialDetailRequest, NasTrialDetail> getNasTrialDetailCallable() { 1574 return getNasTrialDetailCallable; 1575 } 1576 1577 @Override 1578 public UnaryCallable<ListNasTrialDetailsRequest, ListNasTrialDetailsResponse> listNasTrialDetailsCallable()1579 listNasTrialDetailsCallable() { 1580 return listNasTrialDetailsCallable; 1581 } 1582 1583 @Override 1584 public UnaryCallable<ListNasTrialDetailsRequest, ListNasTrialDetailsPagedResponse> listNasTrialDetailsPagedCallable()1585 listNasTrialDetailsPagedCallable() { 1586 return listNasTrialDetailsPagedCallable; 1587 } 1588 1589 @Override 1590 public UnaryCallable<CreateBatchPredictionJobRequest, BatchPredictionJob> createBatchPredictionJobCallable()1591 createBatchPredictionJobCallable() { 1592 return createBatchPredictionJobCallable; 1593 } 1594 1595 @Override 1596 public UnaryCallable<GetBatchPredictionJobRequest, BatchPredictionJob> getBatchPredictionJobCallable()1597 getBatchPredictionJobCallable() { 1598 return getBatchPredictionJobCallable; 1599 } 1600 1601 @Override 1602 public UnaryCallable<ListBatchPredictionJobsRequest, ListBatchPredictionJobsResponse> listBatchPredictionJobsCallable()1603 listBatchPredictionJobsCallable() { 1604 return listBatchPredictionJobsCallable; 1605 } 1606 1607 @Override 1608 public UnaryCallable<ListBatchPredictionJobsRequest, ListBatchPredictionJobsPagedResponse> listBatchPredictionJobsPagedCallable()1609 listBatchPredictionJobsPagedCallable() { 1610 return listBatchPredictionJobsPagedCallable; 1611 } 1612 1613 @Override 1614 public UnaryCallable<DeleteBatchPredictionJobRequest, Operation> deleteBatchPredictionJobCallable()1615 deleteBatchPredictionJobCallable() { 1616 return deleteBatchPredictionJobCallable; 1617 } 1618 1619 @Override 1620 public OperationCallable<DeleteBatchPredictionJobRequest, Empty, DeleteOperationMetadata> deleteBatchPredictionJobOperationCallable()1621 deleteBatchPredictionJobOperationCallable() { 1622 return deleteBatchPredictionJobOperationCallable; 1623 } 1624 1625 @Override cancelBatchPredictionJobCallable()1626 public UnaryCallable<CancelBatchPredictionJobRequest, Empty> cancelBatchPredictionJobCallable() { 1627 return cancelBatchPredictionJobCallable; 1628 } 1629 1630 @Override 1631 public UnaryCallable<CreateModelDeploymentMonitoringJobRequest, ModelDeploymentMonitoringJob> createModelDeploymentMonitoringJobCallable()1632 createModelDeploymentMonitoringJobCallable() { 1633 return createModelDeploymentMonitoringJobCallable; 1634 } 1635 1636 @Override 1637 public UnaryCallable< 1638 SearchModelDeploymentMonitoringStatsAnomaliesRequest, 1639 SearchModelDeploymentMonitoringStatsAnomaliesResponse> searchModelDeploymentMonitoringStatsAnomaliesCallable()1640 searchModelDeploymentMonitoringStatsAnomaliesCallable() { 1641 return searchModelDeploymentMonitoringStatsAnomaliesCallable; 1642 } 1643 1644 @Override 1645 public UnaryCallable< 1646 SearchModelDeploymentMonitoringStatsAnomaliesRequest, 1647 SearchModelDeploymentMonitoringStatsAnomaliesPagedResponse> searchModelDeploymentMonitoringStatsAnomaliesPagedCallable()1648 searchModelDeploymentMonitoringStatsAnomaliesPagedCallable() { 1649 return searchModelDeploymentMonitoringStatsAnomaliesPagedCallable; 1650 } 1651 1652 @Override 1653 public UnaryCallable<GetModelDeploymentMonitoringJobRequest, ModelDeploymentMonitoringJob> getModelDeploymentMonitoringJobCallable()1654 getModelDeploymentMonitoringJobCallable() { 1655 return getModelDeploymentMonitoringJobCallable; 1656 } 1657 1658 @Override 1659 public UnaryCallable< 1660 ListModelDeploymentMonitoringJobsRequest, ListModelDeploymentMonitoringJobsResponse> listModelDeploymentMonitoringJobsCallable()1661 listModelDeploymentMonitoringJobsCallable() { 1662 return listModelDeploymentMonitoringJobsCallable; 1663 } 1664 1665 @Override 1666 public UnaryCallable< 1667 ListModelDeploymentMonitoringJobsRequest, ListModelDeploymentMonitoringJobsPagedResponse> listModelDeploymentMonitoringJobsPagedCallable()1668 listModelDeploymentMonitoringJobsPagedCallable() { 1669 return listModelDeploymentMonitoringJobsPagedCallable; 1670 } 1671 1672 @Override 1673 public UnaryCallable<UpdateModelDeploymentMonitoringJobRequest, Operation> updateModelDeploymentMonitoringJobCallable()1674 updateModelDeploymentMonitoringJobCallable() { 1675 return updateModelDeploymentMonitoringJobCallable; 1676 } 1677 1678 @Override 1679 public OperationCallable< 1680 UpdateModelDeploymentMonitoringJobRequest, 1681 ModelDeploymentMonitoringJob, 1682 UpdateModelDeploymentMonitoringJobOperationMetadata> updateModelDeploymentMonitoringJobOperationCallable()1683 updateModelDeploymentMonitoringJobOperationCallable() { 1684 return updateModelDeploymentMonitoringJobOperationCallable; 1685 } 1686 1687 @Override 1688 public UnaryCallable<DeleteModelDeploymentMonitoringJobRequest, Operation> deleteModelDeploymentMonitoringJobCallable()1689 deleteModelDeploymentMonitoringJobCallable() { 1690 return deleteModelDeploymentMonitoringJobCallable; 1691 } 1692 1693 @Override 1694 public OperationCallable< 1695 DeleteModelDeploymentMonitoringJobRequest, Empty, DeleteOperationMetadata> deleteModelDeploymentMonitoringJobOperationCallable()1696 deleteModelDeploymentMonitoringJobOperationCallable() { 1697 return deleteModelDeploymentMonitoringJobOperationCallable; 1698 } 1699 1700 @Override 1701 public UnaryCallable<PauseModelDeploymentMonitoringJobRequest, Empty> pauseModelDeploymentMonitoringJobCallable()1702 pauseModelDeploymentMonitoringJobCallable() { 1703 return pauseModelDeploymentMonitoringJobCallable; 1704 } 1705 1706 @Override 1707 public UnaryCallable<ResumeModelDeploymentMonitoringJobRequest, Empty> resumeModelDeploymentMonitoringJobCallable()1708 resumeModelDeploymentMonitoringJobCallable() { 1709 return resumeModelDeploymentMonitoringJobCallable; 1710 } 1711 1712 @Override listLocationsCallable()1713 public UnaryCallable<ListLocationsRequest, ListLocationsResponse> listLocationsCallable() { 1714 return listLocationsCallable; 1715 } 1716 1717 @Override 1718 public UnaryCallable<ListLocationsRequest, ListLocationsPagedResponse> listLocationsPagedCallable()1719 listLocationsPagedCallable() { 1720 return listLocationsPagedCallable; 1721 } 1722 1723 @Override getLocationCallable()1724 public UnaryCallable<GetLocationRequest, Location> getLocationCallable() { 1725 return getLocationCallable; 1726 } 1727 1728 @Override setIamPolicyCallable()1729 public UnaryCallable<SetIamPolicyRequest, Policy> setIamPolicyCallable() { 1730 return setIamPolicyCallable; 1731 } 1732 1733 @Override getIamPolicyCallable()1734 public UnaryCallable<GetIamPolicyRequest, Policy> getIamPolicyCallable() { 1735 return getIamPolicyCallable; 1736 } 1737 1738 @Override 1739 public UnaryCallable<TestIamPermissionsRequest, TestIamPermissionsResponse> testIamPermissionsCallable()1740 testIamPermissionsCallable() { 1741 return testIamPermissionsCallable; 1742 } 1743 1744 @Override close()1745 public final void close() { 1746 try { 1747 backgroundResources.close(); 1748 } catch (RuntimeException e) { 1749 throw e; 1750 } catch (Exception e) { 1751 throw new IllegalStateException("Failed to close resource", e); 1752 } 1753 } 1754 1755 @Override shutdown()1756 public void shutdown() { 1757 backgroundResources.shutdown(); 1758 } 1759 1760 @Override isShutdown()1761 public boolean isShutdown() { 1762 return backgroundResources.isShutdown(); 1763 } 1764 1765 @Override isTerminated()1766 public boolean isTerminated() { 1767 return backgroundResources.isTerminated(); 1768 } 1769 1770 @Override shutdownNow()1771 public void shutdownNow() { 1772 backgroundResources.shutdownNow(); 1773 } 1774 1775 @Override awaitTermination(long duration, TimeUnit unit)1776 public boolean awaitTermination(long duration, TimeUnit unit) throws InterruptedException { 1777 return backgroundResources.awaitTermination(duration, unit); 1778 } 1779 } 1780