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.speech.v1p1beta1.stub; 18 19 import static com.google.cloud.speech.v1p1beta1.AdaptationClient.ListCustomClassesPagedResponse; 20 import static com.google.cloud.speech.v1p1beta1.AdaptationClient.ListPhraseSetPagedResponse; 21 22 import com.google.api.core.BetaApi; 23 import com.google.api.gax.core.BackgroundResource; 24 import com.google.api.gax.core.BackgroundResourceAggregation; 25 import com.google.api.gax.grpc.GrpcCallSettings; 26 import com.google.api.gax.grpc.GrpcStubCallableFactory; 27 import com.google.api.gax.rpc.ClientContext; 28 import com.google.api.gax.rpc.UnaryCallable; 29 import com.google.cloud.speech.v1p1beta1.CreateCustomClassRequest; 30 import com.google.cloud.speech.v1p1beta1.CreatePhraseSetRequest; 31 import com.google.cloud.speech.v1p1beta1.CustomClass; 32 import com.google.cloud.speech.v1p1beta1.DeleteCustomClassRequest; 33 import com.google.cloud.speech.v1p1beta1.DeletePhraseSetRequest; 34 import com.google.cloud.speech.v1p1beta1.GetCustomClassRequest; 35 import com.google.cloud.speech.v1p1beta1.GetPhraseSetRequest; 36 import com.google.cloud.speech.v1p1beta1.ListCustomClassesRequest; 37 import com.google.cloud.speech.v1p1beta1.ListCustomClassesResponse; 38 import com.google.cloud.speech.v1p1beta1.ListPhraseSetRequest; 39 import com.google.cloud.speech.v1p1beta1.ListPhraseSetResponse; 40 import com.google.cloud.speech.v1p1beta1.PhraseSet; 41 import com.google.cloud.speech.v1p1beta1.UpdateCustomClassRequest; 42 import com.google.cloud.speech.v1p1beta1.UpdatePhraseSetRequest; 43 import com.google.common.collect.ImmutableMap; 44 import com.google.longrunning.stub.GrpcOperationsStub; 45 import com.google.protobuf.Empty; 46 import io.grpc.MethodDescriptor; 47 import io.grpc.protobuf.ProtoUtils; 48 import java.io.IOException; 49 import java.util.concurrent.TimeUnit; 50 import javax.annotation.Generated; 51 52 // AUTO-GENERATED DOCUMENTATION AND CLASS. 53 /** 54 * gRPC stub implementation for the Adaptation service API. 55 * 56 * <p>This class is for advanced usage and reflects the underlying API directly. 57 */ 58 @BetaApi 59 @Generated("by gapic-generator-java") 60 public class GrpcAdaptationStub extends AdaptationStub { 61 private static final MethodDescriptor<CreatePhraseSetRequest, PhraseSet> 62 createPhraseSetMethodDescriptor = 63 MethodDescriptor.<CreatePhraseSetRequest, PhraseSet>newBuilder() 64 .setType(MethodDescriptor.MethodType.UNARY) 65 .setFullMethodName("google.cloud.speech.v1p1beta1.Adaptation/CreatePhraseSet") 66 .setRequestMarshaller( 67 ProtoUtils.marshaller(CreatePhraseSetRequest.getDefaultInstance())) 68 .setResponseMarshaller(ProtoUtils.marshaller(PhraseSet.getDefaultInstance())) 69 .build(); 70 71 private static final MethodDescriptor<GetPhraseSetRequest, PhraseSet> 72 getPhraseSetMethodDescriptor = 73 MethodDescriptor.<GetPhraseSetRequest, PhraseSet>newBuilder() 74 .setType(MethodDescriptor.MethodType.UNARY) 75 .setFullMethodName("google.cloud.speech.v1p1beta1.Adaptation/GetPhraseSet") 76 .setRequestMarshaller(ProtoUtils.marshaller(GetPhraseSetRequest.getDefaultInstance())) 77 .setResponseMarshaller(ProtoUtils.marshaller(PhraseSet.getDefaultInstance())) 78 .build(); 79 80 private static final MethodDescriptor<ListPhraseSetRequest, ListPhraseSetResponse> 81 listPhraseSetMethodDescriptor = 82 MethodDescriptor.<ListPhraseSetRequest, ListPhraseSetResponse>newBuilder() 83 .setType(MethodDescriptor.MethodType.UNARY) 84 .setFullMethodName("google.cloud.speech.v1p1beta1.Adaptation/ListPhraseSet") 85 .setRequestMarshaller( 86 ProtoUtils.marshaller(ListPhraseSetRequest.getDefaultInstance())) 87 .setResponseMarshaller( 88 ProtoUtils.marshaller(ListPhraseSetResponse.getDefaultInstance())) 89 .build(); 90 91 private static final MethodDescriptor<UpdatePhraseSetRequest, PhraseSet> 92 updatePhraseSetMethodDescriptor = 93 MethodDescriptor.<UpdatePhraseSetRequest, PhraseSet>newBuilder() 94 .setType(MethodDescriptor.MethodType.UNARY) 95 .setFullMethodName("google.cloud.speech.v1p1beta1.Adaptation/UpdatePhraseSet") 96 .setRequestMarshaller( 97 ProtoUtils.marshaller(UpdatePhraseSetRequest.getDefaultInstance())) 98 .setResponseMarshaller(ProtoUtils.marshaller(PhraseSet.getDefaultInstance())) 99 .build(); 100 101 private static final MethodDescriptor<DeletePhraseSetRequest, Empty> 102 deletePhraseSetMethodDescriptor = 103 MethodDescriptor.<DeletePhraseSetRequest, Empty>newBuilder() 104 .setType(MethodDescriptor.MethodType.UNARY) 105 .setFullMethodName("google.cloud.speech.v1p1beta1.Adaptation/DeletePhraseSet") 106 .setRequestMarshaller( 107 ProtoUtils.marshaller(DeletePhraseSetRequest.getDefaultInstance())) 108 .setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance())) 109 .build(); 110 111 private static final MethodDescriptor<CreateCustomClassRequest, CustomClass> 112 createCustomClassMethodDescriptor = 113 MethodDescriptor.<CreateCustomClassRequest, CustomClass>newBuilder() 114 .setType(MethodDescriptor.MethodType.UNARY) 115 .setFullMethodName("google.cloud.speech.v1p1beta1.Adaptation/CreateCustomClass") 116 .setRequestMarshaller( 117 ProtoUtils.marshaller(CreateCustomClassRequest.getDefaultInstance())) 118 .setResponseMarshaller(ProtoUtils.marshaller(CustomClass.getDefaultInstance())) 119 .build(); 120 121 private static final MethodDescriptor<GetCustomClassRequest, CustomClass> 122 getCustomClassMethodDescriptor = 123 MethodDescriptor.<GetCustomClassRequest, CustomClass>newBuilder() 124 .setType(MethodDescriptor.MethodType.UNARY) 125 .setFullMethodName("google.cloud.speech.v1p1beta1.Adaptation/GetCustomClass") 126 .setRequestMarshaller( 127 ProtoUtils.marshaller(GetCustomClassRequest.getDefaultInstance())) 128 .setResponseMarshaller(ProtoUtils.marshaller(CustomClass.getDefaultInstance())) 129 .build(); 130 131 private static final MethodDescriptor<ListCustomClassesRequest, ListCustomClassesResponse> 132 listCustomClassesMethodDescriptor = 133 MethodDescriptor.<ListCustomClassesRequest, ListCustomClassesResponse>newBuilder() 134 .setType(MethodDescriptor.MethodType.UNARY) 135 .setFullMethodName("google.cloud.speech.v1p1beta1.Adaptation/ListCustomClasses") 136 .setRequestMarshaller( 137 ProtoUtils.marshaller(ListCustomClassesRequest.getDefaultInstance())) 138 .setResponseMarshaller( 139 ProtoUtils.marshaller(ListCustomClassesResponse.getDefaultInstance())) 140 .build(); 141 142 private static final MethodDescriptor<UpdateCustomClassRequest, CustomClass> 143 updateCustomClassMethodDescriptor = 144 MethodDescriptor.<UpdateCustomClassRequest, CustomClass>newBuilder() 145 .setType(MethodDescriptor.MethodType.UNARY) 146 .setFullMethodName("google.cloud.speech.v1p1beta1.Adaptation/UpdateCustomClass") 147 .setRequestMarshaller( 148 ProtoUtils.marshaller(UpdateCustomClassRequest.getDefaultInstance())) 149 .setResponseMarshaller(ProtoUtils.marshaller(CustomClass.getDefaultInstance())) 150 .build(); 151 152 private static final MethodDescriptor<DeleteCustomClassRequest, Empty> 153 deleteCustomClassMethodDescriptor = 154 MethodDescriptor.<DeleteCustomClassRequest, Empty>newBuilder() 155 .setType(MethodDescriptor.MethodType.UNARY) 156 .setFullMethodName("google.cloud.speech.v1p1beta1.Adaptation/DeleteCustomClass") 157 .setRequestMarshaller( 158 ProtoUtils.marshaller(DeleteCustomClassRequest.getDefaultInstance())) 159 .setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance())) 160 .build(); 161 162 private final UnaryCallable<CreatePhraseSetRequest, PhraseSet> createPhraseSetCallable; 163 private final UnaryCallable<GetPhraseSetRequest, PhraseSet> getPhraseSetCallable; 164 private final UnaryCallable<ListPhraseSetRequest, ListPhraseSetResponse> listPhraseSetCallable; 165 private final UnaryCallable<ListPhraseSetRequest, ListPhraseSetPagedResponse> 166 listPhraseSetPagedCallable; 167 private final UnaryCallable<UpdatePhraseSetRequest, PhraseSet> updatePhraseSetCallable; 168 private final UnaryCallable<DeletePhraseSetRequest, Empty> deletePhraseSetCallable; 169 private final UnaryCallable<CreateCustomClassRequest, CustomClass> createCustomClassCallable; 170 private final UnaryCallable<GetCustomClassRequest, CustomClass> getCustomClassCallable; 171 private final UnaryCallable<ListCustomClassesRequest, ListCustomClassesResponse> 172 listCustomClassesCallable; 173 private final UnaryCallable<ListCustomClassesRequest, ListCustomClassesPagedResponse> 174 listCustomClassesPagedCallable; 175 private final UnaryCallable<UpdateCustomClassRequest, CustomClass> updateCustomClassCallable; 176 private final UnaryCallable<DeleteCustomClassRequest, Empty> deleteCustomClassCallable; 177 178 private final BackgroundResource backgroundResources; 179 private final GrpcOperationsStub operationsStub; 180 private final GrpcStubCallableFactory callableFactory; 181 create(AdaptationStubSettings settings)182 public static final GrpcAdaptationStub create(AdaptationStubSettings settings) 183 throws IOException { 184 return new GrpcAdaptationStub(settings, ClientContext.create(settings)); 185 } 186 create(ClientContext clientContext)187 public static final GrpcAdaptationStub create(ClientContext clientContext) throws IOException { 188 return new GrpcAdaptationStub(AdaptationStubSettings.newBuilder().build(), clientContext); 189 } 190 create( ClientContext clientContext, GrpcStubCallableFactory callableFactory)191 public static final GrpcAdaptationStub create( 192 ClientContext clientContext, GrpcStubCallableFactory callableFactory) throws IOException { 193 return new GrpcAdaptationStub( 194 AdaptationStubSettings.newBuilder().build(), clientContext, callableFactory); 195 } 196 197 /** 198 * Constructs an instance of GrpcAdaptationStub, using the given settings. This is protected so 199 * that it is easy to make a subclass, but otherwise, the static factory methods should be 200 * preferred. 201 */ GrpcAdaptationStub(AdaptationStubSettings settings, ClientContext clientContext)202 protected GrpcAdaptationStub(AdaptationStubSettings settings, ClientContext clientContext) 203 throws IOException { 204 this(settings, clientContext, new GrpcAdaptationCallableFactory()); 205 } 206 207 /** 208 * Constructs an instance of GrpcAdaptationStub, using the given settings. This is protected so 209 * that it is easy to make a subclass, but otherwise, the static factory methods should be 210 * preferred. 211 */ GrpcAdaptationStub( AdaptationStubSettings settings, ClientContext clientContext, GrpcStubCallableFactory callableFactory)212 protected GrpcAdaptationStub( 213 AdaptationStubSettings settings, 214 ClientContext clientContext, 215 GrpcStubCallableFactory callableFactory) 216 throws IOException { 217 this.callableFactory = callableFactory; 218 this.operationsStub = GrpcOperationsStub.create(clientContext, callableFactory); 219 220 GrpcCallSettings<CreatePhraseSetRequest, PhraseSet> createPhraseSetTransportSettings = 221 GrpcCallSettings.<CreatePhraseSetRequest, PhraseSet>newBuilder() 222 .setMethodDescriptor(createPhraseSetMethodDescriptor) 223 .setParamsExtractor( 224 request -> { 225 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 226 params.put("parent", String.valueOf(request.getParent())); 227 return params.build(); 228 }) 229 .build(); 230 GrpcCallSettings<GetPhraseSetRequest, PhraseSet> getPhraseSetTransportSettings = 231 GrpcCallSettings.<GetPhraseSetRequest, PhraseSet>newBuilder() 232 .setMethodDescriptor(getPhraseSetMethodDescriptor) 233 .setParamsExtractor( 234 request -> { 235 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 236 params.put("name", String.valueOf(request.getName())); 237 return params.build(); 238 }) 239 .build(); 240 GrpcCallSettings<ListPhraseSetRequest, ListPhraseSetResponse> listPhraseSetTransportSettings = 241 GrpcCallSettings.<ListPhraseSetRequest, ListPhraseSetResponse>newBuilder() 242 .setMethodDescriptor(listPhraseSetMethodDescriptor) 243 .setParamsExtractor( 244 request -> { 245 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 246 params.put("parent", String.valueOf(request.getParent())); 247 return params.build(); 248 }) 249 .build(); 250 GrpcCallSettings<UpdatePhraseSetRequest, PhraseSet> updatePhraseSetTransportSettings = 251 GrpcCallSettings.<UpdatePhraseSetRequest, PhraseSet>newBuilder() 252 .setMethodDescriptor(updatePhraseSetMethodDescriptor) 253 .setParamsExtractor( 254 request -> { 255 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 256 params.put("phrase_set.name", String.valueOf(request.getPhraseSet().getName())); 257 return params.build(); 258 }) 259 .build(); 260 GrpcCallSettings<DeletePhraseSetRequest, Empty> deletePhraseSetTransportSettings = 261 GrpcCallSettings.<DeletePhraseSetRequest, Empty>newBuilder() 262 .setMethodDescriptor(deletePhraseSetMethodDescriptor) 263 .setParamsExtractor( 264 request -> { 265 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 266 params.put("name", String.valueOf(request.getName())); 267 return params.build(); 268 }) 269 .build(); 270 GrpcCallSettings<CreateCustomClassRequest, CustomClass> createCustomClassTransportSettings = 271 GrpcCallSettings.<CreateCustomClassRequest, CustomClass>newBuilder() 272 .setMethodDescriptor(createCustomClassMethodDescriptor) 273 .setParamsExtractor( 274 request -> { 275 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 276 params.put("parent", String.valueOf(request.getParent())); 277 return params.build(); 278 }) 279 .build(); 280 GrpcCallSettings<GetCustomClassRequest, CustomClass> getCustomClassTransportSettings = 281 GrpcCallSettings.<GetCustomClassRequest, CustomClass>newBuilder() 282 .setMethodDescriptor(getCustomClassMethodDescriptor) 283 .setParamsExtractor( 284 request -> { 285 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 286 params.put("name", String.valueOf(request.getName())); 287 return params.build(); 288 }) 289 .build(); 290 GrpcCallSettings<ListCustomClassesRequest, ListCustomClassesResponse> 291 listCustomClassesTransportSettings = 292 GrpcCallSettings.<ListCustomClassesRequest, ListCustomClassesResponse>newBuilder() 293 .setMethodDescriptor(listCustomClassesMethodDescriptor) 294 .setParamsExtractor( 295 request -> { 296 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 297 params.put("parent", String.valueOf(request.getParent())); 298 return params.build(); 299 }) 300 .build(); 301 GrpcCallSettings<UpdateCustomClassRequest, CustomClass> updateCustomClassTransportSettings = 302 GrpcCallSettings.<UpdateCustomClassRequest, CustomClass>newBuilder() 303 .setMethodDescriptor(updateCustomClassMethodDescriptor) 304 .setParamsExtractor( 305 request -> { 306 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 307 params.put( 308 "custom_class.name", String.valueOf(request.getCustomClass().getName())); 309 return params.build(); 310 }) 311 .build(); 312 GrpcCallSettings<DeleteCustomClassRequest, Empty> deleteCustomClassTransportSettings = 313 GrpcCallSettings.<DeleteCustomClassRequest, Empty>newBuilder() 314 .setMethodDescriptor(deleteCustomClassMethodDescriptor) 315 .setParamsExtractor( 316 request -> { 317 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 318 params.put("name", String.valueOf(request.getName())); 319 return params.build(); 320 }) 321 .build(); 322 323 this.createPhraseSetCallable = 324 callableFactory.createUnaryCallable( 325 createPhraseSetTransportSettings, settings.createPhraseSetSettings(), clientContext); 326 this.getPhraseSetCallable = 327 callableFactory.createUnaryCallable( 328 getPhraseSetTransportSettings, settings.getPhraseSetSettings(), clientContext); 329 this.listPhraseSetCallable = 330 callableFactory.createUnaryCallable( 331 listPhraseSetTransportSettings, settings.listPhraseSetSettings(), clientContext); 332 this.listPhraseSetPagedCallable = 333 callableFactory.createPagedCallable( 334 listPhraseSetTransportSettings, settings.listPhraseSetSettings(), clientContext); 335 this.updatePhraseSetCallable = 336 callableFactory.createUnaryCallable( 337 updatePhraseSetTransportSettings, settings.updatePhraseSetSettings(), clientContext); 338 this.deletePhraseSetCallable = 339 callableFactory.createUnaryCallable( 340 deletePhraseSetTransportSettings, settings.deletePhraseSetSettings(), clientContext); 341 this.createCustomClassCallable = 342 callableFactory.createUnaryCallable( 343 createCustomClassTransportSettings, 344 settings.createCustomClassSettings(), 345 clientContext); 346 this.getCustomClassCallable = 347 callableFactory.createUnaryCallable( 348 getCustomClassTransportSettings, settings.getCustomClassSettings(), clientContext); 349 this.listCustomClassesCallable = 350 callableFactory.createUnaryCallable( 351 listCustomClassesTransportSettings, 352 settings.listCustomClassesSettings(), 353 clientContext); 354 this.listCustomClassesPagedCallable = 355 callableFactory.createPagedCallable( 356 listCustomClassesTransportSettings, 357 settings.listCustomClassesSettings(), 358 clientContext); 359 this.updateCustomClassCallable = 360 callableFactory.createUnaryCallable( 361 updateCustomClassTransportSettings, 362 settings.updateCustomClassSettings(), 363 clientContext); 364 this.deleteCustomClassCallable = 365 callableFactory.createUnaryCallable( 366 deleteCustomClassTransportSettings, 367 settings.deleteCustomClassSettings(), 368 clientContext); 369 370 this.backgroundResources = 371 new BackgroundResourceAggregation(clientContext.getBackgroundResources()); 372 } 373 getOperationsStub()374 public GrpcOperationsStub getOperationsStub() { 375 return operationsStub; 376 } 377 378 @Override createPhraseSetCallable()379 public UnaryCallable<CreatePhraseSetRequest, PhraseSet> createPhraseSetCallable() { 380 return createPhraseSetCallable; 381 } 382 383 @Override getPhraseSetCallable()384 public UnaryCallable<GetPhraseSetRequest, PhraseSet> getPhraseSetCallable() { 385 return getPhraseSetCallable; 386 } 387 388 @Override listPhraseSetCallable()389 public UnaryCallable<ListPhraseSetRequest, ListPhraseSetResponse> listPhraseSetCallable() { 390 return listPhraseSetCallable; 391 } 392 393 @Override 394 public UnaryCallable<ListPhraseSetRequest, ListPhraseSetPagedResponse> listPhraseSetPagedCallable()395 listPhraseSetPagedCallable() { 396 return listPhraseSetPagedCallable; 397 } 398 399 @Override updatePhraseSetCallable()400 public UnaryCallable<UpdatePhraseSetRequest, PhraseSet> updatePhraseSetCallable() { 401 return updatePhraseSetCallable; 402 } 403 404 @Override deletePhraseSetCallable()405 public UnaryCallable<DeletePhraseSetRequest, Empty> deletePhraseSetCallable() { 406 return deletePhraseSetCallable; 407 } 408 409 @Override createCustomClassCallable()410 public UnaryCallable<CreateCustomClassRequest, CustomClass> createCustomClassCallable() { 411 return createCustomClassCallable; 412 } 413 414 @Override getCustomClassCallable()415 public UnaryCallable<GetCustomClassRequest, CustomClass> getCustomClassCallable() { 416 return getCustomClassCallable; 417 } 418 419 @Override 420 public UnaryCallable<ListCustomClassesRequest, ListCustomClassesResponse> listCustomClassesCallable()421 listCustomClassesCallable() { 422 return listCustomClassesCallable; 423 } 424 425 @Override 426 public UnaryCallable<ListCustomClassesRequest, ListCustomClassesPagedResponse> listCustomClassesPagedCallable()427 listCustomClassesPagedCallable() { 428 return listCustomClassesPagedCallable; 429 } 430 431 @Override updateCustomClassCallable()432 public UnaryCallable<UpdateCustomClassRequest, CustomClass> updateCustomClassCallable() { 433 return updateCustomClassCallable; 434 } 435 436 @Override deleteCustomClassCallable()437 public UnaryCallable<DeleteCustomClassRequest, Empty> deleteCustomClassCallable() { 438 return deleteCustomClassCallable; 439 } 440 441 @Override close()442 public final void close() { 443 try { 444 backgroundResources.close(); 445 } catch (RuntimeException e) { 446 throw e; 447 } catch (Exception e) { 448 throw new IllegalStateException("Failed to close resource", e); 449 } 450 } 451 452 @Override shutdown()453 public void shutdown() { 454 backgroundResources.shutdown(); 455 } 456 457 @Override isShutdown()458 public boolean isShutdown() { 459 return backgroundResources.isShutdown(); 460 } 461 462 @Override isTerminated()463 public boolean isTerminated() { 464 return backgroundResources.isTerminated(); 465 } 466 467 @Override shutdownNow()468 public void shutdownNow() { 469 backgroundResources.shutdownNow(); 470 } 471 472 @Override awaitTermination(long duration, TimeUnit unit)473 public boolean awaitTermination(long duration, TimeUnit unit) throws InterruptedException { 474 return backgroundResources.awaitTermination(duration, unit); 475 } 476 } 477