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.redis.v1beta1.stub; 18 19 import static com.google.cloud.redis.v1beta1.CloudRedisClient.ListInstancesPagedResponse; 20 21 import com.google.api.core.BetaApi; 22 import com.google.api.gax.core.BackgroundResource; 23 import com.google.api.gax.core.BackgroundResourceAggregation; 24 import com.google.api.gax.grpc.GrpcCallSettings; 25 import com.google.api.gax.grpc.GrpcStubCallableFactory; 26 import com.google.api.gax.rpc.ClientContext; 27 import com.google.api.gax.rpc.OperationCallable; 28 import com.google.api.gax.rpc.UnaryCallable; 29 import com.google.cloud.redis.v1beta1.CreateInstanceRequest; 30 import com.google.cloud.redis.v1beta1.DeleteInstanceRequest; 31 import com.google.cloud.redis.v1beta1.ExportInstanceRequest; 32 import com.google.cloud.redis.v1beta1.FailoverInstanceRequest; 33 import com.google.cloud.redis.v1beta1.GetInstanceAuthStringRequest; 34 import com.google.cloud.redis.v1beta1.GetInstanceRequest; 35 import com.google.cloud.redis.v1beta1.ImportInstanceRequest; 36 import com.google.cloud.redis.v1beta1.Instance; 37 import com.google.cloud.redis.v1beta1.InstanceAuthString; 38 import com.google.cloud.redis.v1beta1.ListInstancesRequest; 39 import com.google.cloud.redis.v1beta1.ListInstancesResponse; 40 import com.google.cloud.redis.v1beta1.RescheduleMaintenanceRequest; 41 import com.google.cloud.redis.v1beta1.UpdateInstanceRequest; 42 import com.google.cloud.redis.v1beta1.UpgradeInstanceRequest; 43 import com.google.common.collect.ImmutableMap; 44 import com.google.longrunning.Operation; 45 import com.google.longrunning.stub.GrpcOperationsStub; 46 import com.google.protobuf.Any; 47 import com.google.protobuf.Empty; 48 import io.grpc.MethodDescriptor; 49 import io.grpc.protobuf.ProtoUtils; 50 import java.io.IOException; 51 import java.util.concurrent.TimeUnit; 52 import javax.annotation.Generated; 53 54 // AUTO-GENERATED DOCUMENTATION AND CLASS. 55 /** 56 * gRPC stub implementation for the CloudRedis service API. 57 * 58 * <p>This class is for advanced usage and reflects the underlying API directly. 59 */ 60 @BetaApi 61 @Generated("by gapic-generator-java") 62 public class GrpcCloudRedisStub extends CloudRedisStub { 63 private static final MethodDescriptor<ListInstancesRequest, ListInstancesResponse> 64 listInstancesMethodDescriptor = 65 MethodDescriptor.<ListInstancesRequest, ListInstancesResponse>newBuilder() 66 .setType(MethodDescriptor.MethodType.UNARY) 67 .setFullMethodName("google.cloud.redis.v1beta1.CloudRedis/ListInstances") 68 .setRequestMarshaller( 69 ProtoUtils.marshaller(ListInstancesRequest.getDefaultInstance())) 70 .setResponseMarshaller( 71 ProtoUtils.marshaller(ListInstancesResponse.getDefaultInstance())) 72 .build(); 73 74 private static final MethodDescriptor<GetInstanceRequest, Instance> getInstanceMethodDescriptor = 75 MethodDescriptor.<GetInstanceRequest, Instance>newBuilder() 76 .setType(MethodDescriptor.MethodType.UNARY) 77 .setFullMethodName("google.cloud.redis.v1beta1.CloudRedis/GetInstance") 78 .setRequestMarshaller(ProtoUtils.marshaller(GetInstanceRequest.getDefaultInstance())) 79 .setResponseMarshaller(ProtoUtils.marshaller(Instance.getDefaultInstance())) 80 .build(); 81 82 private static final MethodDescriptor<GetInstanceAuthStringRequest, InstanceAuthString> 83 getInstanceAuthStringMethodDescriptor = 84 MethodDescriptor.<GetInstanceAuthStringRequest, InstanceAuthString>newBuilder() 85 .setType(MethodDescriptor.MethodType.UNARY) 86 .setFullMethodName("google.cloud.redis.v1beta1.CloudRedis/GetInstanceAuthString") 87 .setRequestMarshaller( 88 ProtoUtils.marshaller(GetInstanceAuthStringRequest.getDefaultInstance())) 89 .setResponseMarshaller(ProtoUtils.marshaller(InstanceAuthString.getDefaultInstance())) 90 .build(); 91 92 private static final MethodDescriptor<CreateInstanceRequest, Operation> 93 createInstanceMethodDescriptor = 94 MethodDescriptor.<CreateInstanceRequest, Operation>newBuilder() 95 .setType(MethodDescriptor.MethodType.UNARY) 96 .setFullMethodName("google.cloud.redis.v1beta1.CloudRedis/CreateInstance") 97 .setRequestMarshaller( 98 ProtoUtils.marshaller(CreateInstanceRequest.getDefaultInstance())) 99 .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance())) 100 .build(); 101 102 private static final MethodDescriptor<UpdateInstanceRequest, Operation> 103 updateInstanceMethodDescriptor = 104 MethodDescriptor.<UpdateInstanceRequest, Operation>newBuilder() 105 .setType(MethodDescriptor.MethodType.UNARY) 106 .setFullMethodName("google.cloud.redis.v1beta1.CloudRedis/UpdateInstance") 107 .setRequestMarshaller( 108 ProtoUtils.marshaller(UpdateInstanceRequest.getDefaultInstance())) 109 .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance())) 110 .build(); 111 112 private static final MethodDescriptor<UpgradeInstanceRequest, Operation> 113 upgradeInstanceMethodDescriptor = 114 MethodDescriptor.<UpgradeInstanceRequest, Operation>newBuilder() 115 .setType(MethodDescriptor.MethodType.UNARY) 116 .setFullMethodName("google.cloud.redis.v1beta1.CloudRedis/UpgradeInstance") 117 .setRequestMarshaller( 118 ProtoUtils.marshaller(UpgradeInstanceRequest.getDefaultInstance())) 119 .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance())) 120 .build(); 121 122 private static final MethodDescriptor<ImportInstanceRequest, Operation> 123 importInstanceMethodDescriptor = 124 MethodDescriptor.<ImportInstanceRequest, Operation>newBuilder() 125 .setType(MethodDescriptor.MethodType.UNARY) 126 .setFullMethodName("google.cloud.redis.v1beta1.CloudRedis/ImportInstance") 127 .setRequestMarshaller( 128 ProtoUtils.marshaller(ImportInstanceRequest.getDefaultInstance())) 129 .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance())) 130 .build(); 131 132 private static final MethodDescriptor<ExportInstanceRequest, Operation> 133 exportInstanceMethodDescriptor = 134 MethodDescriptor.<ExportInstanceRequest, Operation>newBuilder() 135 .setType(MethodDescriptor.MethodType.UNARY) 136 .setFullMethodName("google.cloud.redis.v1beta1.CloudRedis/ExportInstance") 137 .setRequestMarshaller( 138 ProtoUtils.marshaller(ExportInstanceRequest.getDefaultInstance())) 139 .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance())) 140 .build(); 141 142 private static final MethodDescriptor<FailoverInstanceRequest, Operation> 143 failoverInstanceMethodDescriptor = 144 MethodDescriptor.<FailoverInstanceRequest, Operation>newBuilder() 145 .setType(MethodDescriptor.MethodType.UNARY) 146 .setFullMethodName("google.cloud.redis.v1beta1.CloudRedis/FailoverInstance") 147 .setRequestMarshaller( 148 ProtoUtils.marshaller(FailoverInstanceRequest.getDefaultInstance())) 149 .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance())) 150 .build(); 151 152 private static final MethodDescriptor<DeleteInstanceRequest, Operation> 153 deleteInstanceMethodDescriptor = 154 MethodDescriptor.<DeleteInstanceRequest, Operation>newBuilder() 155 .setType(MethodDescriptor.MethodType.UNARY) 156 .setFullMethodName("google.cloud.redis.v1beta1.CloudRedis/DeleteInstance") 157 .setRequestMarshaller( 158 ProtoUtils.marshaller(DeleteInstanceRequest.getDefaultInstance())) 159 .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance())) 160 .build(); 161 162 private static final MethodDescriptor<RescheduleMaintenanceRequest, Operation> 163 rescheduleMaintenanceMethodDescriptor = 164 MethodDescriptor.<RescheduleMaintenanceRequest, Operation>newBuilder() 165 .setType(MethodDescriptor.MethodType.UNARY) 166 .setFullMethodName("google.cloud.redis.v1beta1.CloudRedis/RescheduleMaintenance") 167 .setRequestMarshaller( 168 ProtoUtils.marshaller(RescheduleMaintenanceRequest.getDefaultInstance())) 169 .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance())) 170 .build(); 171 172 private final UnaryCallable<ListInstancesRequest, ListInstancesResponse> listInstancesCallable; 173 private final UnaryCallable<ListInstancesRequest, ListInstancesPagedResponse> 174 listInstancesPagedCallable; 175 private final UnaryCallable<GetInstanceRequest, Instance> getInstanceCallable; 176 private final UnaryCallable<GetInstanceAuthStringRequest, InstanceAuthString> 177 getInstanceAuthStringCallable; 178 private final UnaryCallable<CreateInstanceRequest, Operation> createInstanceCallable; 179 private final OperationCallable<CreateInstanceRequest, Instance, Any> 180 createInstanceOperationCallable; 181 private final UnaryCallable<UpdateInstanceRequest, Operation> updateInstanceCallable; 182 private final OperationCallable<UpdateInstanceRequest, Instance, Any> 183 updateInstanceOperationCallable; 184 private final UnaryCallable<UpgradeInstanceRequest, Operation> upgradeInstanceCallable; 185 private final OperationCallable<UpgradeInstanceRequest, Instance, Any> 186 upgradeInstanceOperationCallable; 187 private final UnaryCallable<ImportInstanceRequest, Operation> importInstanceCallable; 188 private final OperationCallable<ImportInstanceRequest, Instance, Any> 189 importInstanceOperationCallable; 190 private final UnaryCallable<ExportInstanceRequest, Operation> exportInstanceCallable; 191 private final OperationCallable<ExportInstanceRequest, Instance, Any> 192 exportInstanceOperationCallable; 193 private final UnaryCallable<FailoverInstanceRequest, Operation> failoverInstanceCallable; 194 private final OperationCallable<FailoverInstanceRequest, Instance, Any> 195 failoverInstanceOperationCallable; 196 private final UnaryCallable<DeleteInstanceRequest, Operation> deleteInstanceCallable; 197 private final OperationCallable<DeleteInstanceRequest, Empty, Any> 198 deleteInstanceOperationCallable; 199 private final UnaryCallable<RescheduleMaintenanceRequest, Operation> 200 rescheduleMaintenanceCallable; 201 private final OperationCallable<RescheduleMaintenanceRequest, Instance, Any> 202 rescheduleMaintenanceOperationCallable; 203 204 private final BackgroundResource backgroundResources; 205 private final GrpcOperationsStub operationsStub; 206 private final GrpcStubCallableFactory callableFactory; 207 create(CloudRedisStubSettings settings)208 public static final GrpcCloudRedisStub create(CloudRedisStubSettings settings) 209 throws IOException { 210 return new GrpcCloudRedisStub(settings, ClientContext.create(settings)); 211 } 212 create(ClientContext clientContext)213 public static final GrpcCloudRedisStub create(ClientContext clientContext) throws IOException { 214 return new GrpcCloudRedisStub(CloudRedisStubSettings.newBuilder().build(), clientContext); 215 } 216 create( ClientContext clientContext, GrpcStubCallableFactory callableFactory)217 public static final GrpcCloudRedisStub create( 218 ClientContext clientContext, GrpcStubCallableFactory callableFactory) throws IOException { 219 return new GrpcCloudRedisStub( 220 CloudRedisStubSettings.newBuilder().build(), clientContext, callableFactory); 221 } 222 223 /** 224 * Constructs an instance of GrpcCloudRedisStub, using the given settings. This is protected so 225 * that it is easy to make a subclass, but otherwise, the static factory methods should be 226 * preferred. 227 */ GrpcCloudRedisStub(CloudRedisStubSettings settings, ClientContext clientContext)228 protected GrpcCloudRedisStub(CloudRedisStubSettings settings, ClientContext clientContext) 229 throws IOException { 230 this(settings, clientContext, new GrpcCloudRedisCallableFactory()); 231 } 232 233 /** 234 * Constructs an instance of GrpcCloudRedisStub, using the given settings. This is protected so 235 * that it is easy to make a subclass, but otherwise, the static factory methods should be 236 * preferred. 237 */ GrpcCloudRedisStub( CloudRedisStubSettings settings, ClientContext clientContext, GrpcStubCallableFactory callableFactory)238 protected GrpcCloudRedisStub( 239 CloudRedisStubSettings settings, 240 ClientContext clientContext, 241 GrpcStubCallableFactory callableFactory) 242 throws IOException { 243 this.callableFactory = callableFactory; 244 this.operationsStub = GrpcOperationsStub.create(clientContext, callableFactory); 245 246 GrpcCallSettings<ListInstancesRequest, ListInstancesResponse> listInstancesTransportSettings = 247 GrpcCallSettings.<ListInstancesRequest, ListInstancesResponse>newBuilder() 248 .setMethodDescriptor(listInstancesMethodDescriptor) 249 .setParamsExtractor( 250 request -> { 251 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 252 params.put("parent", String.valueOf(request.getParent())); 253 return params.build(); 254 }) 255 .build(); 256 GrpcCallSettings<GetInstanceRequest, Instance> getInstanceTransportSettings = 257 GrpcCallSettings.<GetInstanceRequest, Instance>newBuilder() 258 .setMethodDescriptor(getInstanceMethodDescriptor) 259 .setParamsExtractor( 260 request -> { 261 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 262 params.put("name", String.valueOf(request.getName())); 263 return params.build(); 264 }) 265 .build(); 266 GrpcCallSettings<GetInstanceAuthStringRequest, InstanceAuthString> 267 getInstanceAuthStringTransportSettings = 268 GrpcCallSettings.<GetInstanceAuthStringRequest, InstanceAuthString>newBuilder() 269 .setMethodDescriptor(getInstanceAuthStringMethodDescriptor) 270 .setParamsExtractor( 271 request -> { 272 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 273 params.put("name", String.valueOf(request.getName())); 274 return params.build(); 275 }) 276 .build(); 277 GrpcCallSettings<CreateInstanceRequest, Operation> createInstanceTransportSettings = 278 GrpcCallSettings.<CreateInstanceRequest, Operation>newBuilder() 279 .setMethodDescriptor(createInstanceMethodDescriptor) 280 .setParamsExtractor( 281 request -> { 282 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 283 params.put("parent", String.valueOf(request.getParent())); 284 return params.build(); 285 }) 286 .build(); 287 GrpcCallSettings<UpdateInstanceRequest, Operation> updateInstanceTransportSettings = 288 GrpcCallSettings.<UpdateInstanceRequest, Operation>newBuilder() 289 .setMethodDescriptor(updateInstanceMethodDescriptor) 290 .setParamsExtractor( 291 request -> { 292 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 293 params.put("instance.name", String.valueOf(request.getInstance().getName())); 294 return params.build(); 295 }) 296 .build(); 297 GrpcCallSettings<UpgradeInstanceRequest, Operation> upgradeInstanceTransportSettings = 298 GrpcCallSettings.<UpgradeInstanceRequest, Operation>newBuilder() 299 .setMethodDescriptor(upgradeInstanceMethodDescriptor) 300 .setParamsExtractor( 301 request -> { 302 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 303 params.put("name", String.valueOf(request.getName())); 304 return params.build(); 305 }) 306 .build(); 307 GrpcCallSettings<ImportInstanceRequest, Operation> importInstanceTransportSettings = 308 GrpcCallSettings.<ImportInstanceRequest, Operation>newBuilder() 309 .setMethodDescriptor(importInstanceMethodDescriptor) 310 .setParamsExtractor( 311 request -> { 312 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 313 params.put("name", String.valueOf(request.getName())); 314 return params.build(); 315 }) 316 .build(); 317 GrpcCallSettings<ExportInstanceRequest, Operation> exportInstanceTransportSettings = 318 GrpcCallSettings.<ExportInstanceRequest, Operation>newBuilder() 319 .setMethodDescriptor(exportInstanceMethodDescriptor) 320 .setParamsExtractor( 321 request -> { 322 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 323 params.put("name", String.valueOf(request.getName())); 324 return params.build(); 325 }) 326 .build(); 327 GrpcCallSettings<FailoverInstanceRequest, Operation> failoverInstanceTransportSettings = 328 GrpcCallSettings.<FailoverInstanceRequest, Operation>newBuilder() 329 .setMethodDescriptor(failoverInstanceMethodDescriptor) 330 .setParamsExtractor( 331 request -> { 332 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 333 params.put("name", String.valueOf(request.getName())); 334 return params.build(); 335 }) 336 .build(); 337 GrpcCallSettings<DeleteInstanceRequest, Operation> deleteInstanceTransportSettings = 338 GrpcCallSettings.<DeleteInstanceRequest, Operation>newBuilder() 339 .setMethodDescriptor(deleteInstanceMethodDescriptor) 340 .setParamsExtractor( 341 request -> { 342 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 343 params.put("name", String.valueOf(request.getName())); 344 return params.build(); 345 }) 346 .build(); 347 GrpcCallSettings<RescheduleMaintenanceRequest, Operation> 348 rescheduleMaintenanceTransportSettings = 349 GrpcCallSettings.<RescheduleMaintenanceRequest, Operation>newBuilder() 350 .setMethodDescriptor(rescheduleMaintenanceMethodDescriptor) 351 .setParamsExtractor( 352 request -> { 353 ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); 354 params.put("name", String.valueOf(request.getName())); 355 return params.build(); 356 }) 357 .build(); 358 359 this.listInstancesCallable = 360 callableFactory.createUnaryCallable( 361 listInstancesTransportSettings, settings.listInstancesSettings(), clientContext); 362 this.listInstancesPagedCallable = 363 callableFactory.createPagedCallable( 364 listInstancesTransportSettings, settings.listInstancesSettings(), clientContext); 365 this.getInstanceCallable = 366 callableFactory.createUnaryCallable( 367 getInstanceTransportSettings, settings.getInstanceSettings(), clientContext); 368 this.getInstanceAuthStringCallable = 369 callableFactory.createUnaryCallable( 370 getInstanceAuthStringTransportSettings, 371 settings.getInstanceAuthStringSettings(), 372 clientContext); 373 this.createInstanceCallable = 374 callableFactory.createUnaryCallable( 375 createInstanceTransportSettings, settings.createInstanceSettings(), clientContext); 376 this.createInstanceOperationCallable = 377 callableFactory.createOperationCallable( 378 createInstanceTransportSettings, 379 settings.createInstanceOperationSettings(), 380 clientContext, 381 operationsStub); 382 this.updateInstanceCallable = 383 callableFactory.createUnaryCallable( 384 updateInstanceTransportSettings, settings.updateInstanceSettings(), clientContext); 385 this.updateInstanceOperationCallable = 386 callableFactory.createOperationCallable( 387 updateInstanceTransportSettings, 388 settings.updateInstanceOperationSettings(), 389 clientContext, 390 operationsStub); 391 this.upgradeInstanceCallable = 392 callableFactory.createUnaryCallable( 393 upgradeInstanceTransportSettings, settings.upgradeInstanceSettings(), clientContext); 394 this.upgradeInstanceOperationCallable = 395 callableFactory.createOperationCallable( 396 upgradeInstanceTransportSettings, 397 settings.upgradeInstanceOperationSettings(), 398 clientContext, 399 operationsStub); 400 this.importInstanceCallable = 401 callableFactory.createUnaryCallable( 402 importInstanceTransportSettings, settings.importInstanceSettings(), clientContext); 403 this.importInstanceOperationCallable = 404 callableFactory.createOperationCallable( 405 importInstanceTransportSettings, 406 settings.importInstanceOperationSettings(), 407 clientContext, 408 operationsStub); 409 this.exportInstanceCallable = 410 callableFactory.createUnaryCallable( 411 exportInstanceTransportSettings, settings.exportInstanceSettings(), clientContext); 412 this.exportInstanceOperationCallable = 413 callableFactory.createOperationCallable( 414 exportInstanceTransportSettings, 415 settings.exportInstanceOperationSettings(), 416 clientContext, 417 operationsStub); 418 this.failoverInstanceCallable = 419 callableFactory.createUnaryCallable( 420 failoverInstanceTransportSettings, settings.failoverInstanceSettings(), clientContext); 421 this.failoverInstanceOperationCallable = 422 callableFactory.createOperationCallable( 423 failoverInstanceTransportSettings, 424 settings.failoverInstanceOperationSettings(), 425 clientContext, 426 operationsStub); 427 this.deleteInstanceCallable = 428 callableFactory.createUnaryCallable( 429 deleteInstanceTransportSettings, settings.deleteInstanceSettings(), clientContext); 430 this.deleteInstanceOperationCallable = 431 callableFactory.createOperationCallable( 432 deleteInstanceTransportSettings, 433 settings.deleteInstanceOperationSettings(), 434 clientContext, 435 operationsStub); 436 this.rescheduleMaintenanceCallable = 437 callableFactory.createUnaryCallable( 438 rescheduleMaintenanceTransportSettings, 439 settings.rescheduleMaintenanceSettings(), 440 clientContext); 441 this.rescheduleMaintenanceOperationCallable = 442 callableFactory.createOperationCallable( 443 rescheduleMaintenanceTransportSettings, 444 settings.rescheduleMaintenanceOperationSettings(), 445 clientContext, 446 operationsStub); 447 448 this.backgroundResources = 449 new BackgroundResourceAggregation(clientContext.getBackgroundResources()); 450 } 451 getOperationsStub()452 public GrpcOperationsStub getOperationsStub() { 453 return operationsStub; 454 } 455 456 @Override listInstancesCallable()457 public UnaryCallable<ListInstancesRequest, ListInstancesResponse> listInstancesCallable() { 458 return listInstancesCallable; 459 } 460 461 @Override 462 public UnaryCallable<ListInstancesRequest, ListInstancesPagedResponse> listInstancesPagedCallable()463 listInstancesPagedCallable() { 464 return listInstancesPagedCallable; 465 } 466 467 @Override getInstanceCallable()468 public UnaryCallable<GetInstanceRequest, Instance> getInstanceCallable() { 469 return getInstanceCallable; 470 } 471 472 @Override 473 public UnaryCallable<GetInstanceAuthStringRequest, InstanceAuthString> getInstanceAuthStringCallable()474 getInstanceAuthStringCallable() { 475 return getInstanceAuthStringCallable; 476 } 477 478 @Override createInstanceCallable()479 public UnaryCallable<CreateInstanceRequest, Operation> createInstanceCallable() { 480 return createInstanceCallable; 481 } 482 483 @Override createInstanceOperationCallable()484 public OperationCallable<CreateInstanceRequest, Instance, Any> createInstanceOperationCallable() { 485 return createInstanceOperationCallable; 486 } 487 488 @Override updateInstanceCallable()489 public UnaryCallable<UpdateInstanceRequest, Operation> updateInstanceCallable() { 490 return updateInstanceCallable; 491 } 492 493 @Override updateInstanceOperationCallable()494 public OperationCallable<UpdateInstanceRequest, Instance, Any> updateInstanceOperationCallable() { 495 return updateInstanceOperationCallable; 496 } 497 498 @Override upgradeInstanceCallable()499 public UnaryCallable<UpgradeInstanceRequest, Operation> upgradeInstanceCallable() { 500 return upgradeInstanceCallable; 501 } 502 503 @Override 504 public OperationCallable<UpgradeInstanceRequest, Instance, Any> upgradeInstanceOperationCallable()505 upgradeInstanceOperationCallable() { 506 return upgradeInstanceOperationCallable; 507 } 508 509 @Override importInstanceCallable()510 public UnaryCallable<ImportInstanceRequest, Operation> importInstanceCallable() { 511 return importInstanceCallable; 512 } 513 514 @Override importInstanceOperationCallable()515 public OperationCallable<ImportInstanceRequest, Instance, Any> importInstanceOperationCallable() { 516 return importInstanceOperationCallable; 517 } 518 519 @Override exportInstanceCallable()520 public UnaryCallable<ExportInstanceRequest, Operation> exportInstanceCallable() { 521 return exportInstanceCallable; 522 } 523 524 @Override exportInstanceOperationCallable()525 public OperationCallable<ExportInstanceRequest, Instance, Any> exportInstanceOperationCallable() { 526 return exportInstanceOperationCallable; 527 } 528 529 @Override failoverInstanceCallable()530 public UnaryCallable<FailoverInstanceRequest, Operation> failoverInstanceCallable() { 531 return failoverInstanceCallable; 532 } 533 534 @Override 535 public OperationCallable<FailoverInstanceRequest, Instance, Any> failoverInstanceOperationCallable()536 failoverInstanceOperationCallable() { 537 return failoverInstanceOperationCallable; 538 } 539 540 @Override deleteInstanceCallable()541 public UnaryCallable<DeleteInstanceRequest, Operation> deleteInstanceCallable() { 542 return deleteInstanceCallable; 543 } 544 545 @Override deleteInstanceOperationCallable()546 public OperationCallable<DeleteInstanceRequest, Empty, Any> deleteInstanceOperationCallable() { 547 return deleteInstanceOperationCallable; 548 } 549 550 @Override rescheduleMaintenanceCallable()551 public UnaryCallable<RescheduleMaintenanceRequest, Operation> rescheduleMaintenanceCallable() { 552 return rescheduleMaintenanceCallable; 553 } 554 555 @Override 556 public OperationCallable<RescheduleMaintenanceRequest, Instance, Any> rescheduleMaintenanceOperationCallable()557 rescheduleMaintenanceOperationCallable() { 558 return rescheduleMaintenanceOperationCallable; 559 } 560 561 @Override close()562 public final void close() { 563 try { 564 backgroundResources.close(); 565 } catch (RuntimeException e) { 566 throw e; 567 } catch (Exception e) { 568 throw new IllegalStateException("Failed to close resource", e); 569 } 570 } 571 572 @Override shutdown()573 public void shutdown() { 574 backgroundResources.shutdown(); 575 } 576 577 @Override isShutdown()578 public boolean isShutdown() { 579 return backgroundResources.isShutdown(); 580 } 581 582 @Override isTerminated()583 public boolean isTerminated() { 584 return backgroundResources.isTerminated(); 585 } 586 587 @Override shutdownNow()588 public void shutdownNow() { 589 backgroundResources.shutdownNow(); 590 } 591 592 @Override awaitTermination(long duration, TimeUnit unit)593 public boolean awaitTermination(long duration, TimeUnit unit) throws InterruptedException { 594 return backgroundResources.awaitTermination(duration, unit); 595 } 596 } 597