/* * Copyright 2018-2023 Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file except in compliance with * the License. A copy of the License is located at * * http://aws.amazon.com/apache2.0 * * or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR * CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions * and limitations under the License. */ package com.amazonaws.services.eks; import javax.annotation.Generated; import com.amazonaws.services.eks.model.*; import com.amazonaws.client.AwsAsyncClientParams; import com.amazonaws.annotation.ThreadSafe; import java.util.concurrent.ExecutorService; /** * Client for accessing Amazon EKS asynchronously. Each asynchronous method will return a Java Future object * representing the asynchronous operation; overloads which accept an {@code AsyncHandler} can be used to receive * notification when an asynchronous operation completes. *

*

* Amazon Elastic Kubernetes Service (Amazon EKS) is a managed service that makes it easy for you to run Kubernetes on * Amazon Web Services without needing to stand up or maintain your own Kubernetes control plane. Kubernetes is an * open-source system for automating the deployment, scaling, and management of containerized applications. *

*

* Amazon EKS runs up-to-date versions of the open-source Kubernetes software, so you can use all the existing plugins * and tooling from the Kubernetes community. Applications running on Amazon EKS are fully compatible with applications * running on any standard Kubernetes environment, whether running in on-premises data centers or public clouds. This * means that you can easily migrate any standard Kubernetes application to Amazon EKS without any code modification * required. *

*/ @ThreadSafe @Generated("com.amazonaws:aws-java-sdk-code-generator") public class AmazonEKSAsyncClient extends AmazonEKSClient implements AmazonEKSAsync { private static final int DEFAULT_THREAD_POOL_SIZE = 50; private final java.util.concurrent.ExecutorService executorService; public static AmazonEKSAsyncClientBuilder asyncBuilder() { return AmazonEKSAsyncClientBuilder.standard(); } /** * Constructs a new asynchronous client to invoke service methods on Amazon EKS using the specified parameters. * * @param asyncClientParams * Object providing client parameters. */ AmazonEKSAsyncClient(AwsAsyncClientParams asyncClientParams) { this(asyncClientParams, false); } /** * Constructs a new asynchronous client to invoke service methods on Amazon EKS using the specified parameters. * * @param asyncClientParams * Object providing client parameters. * @param endpointDiscoveryEnabled * true will enable endpoint discovery if the service supports it. */ AmazonEKSAsyncClient(AwsAsyncClientParams asyncClientParams, boolean endpointDiscoveryEnabled) { super(asyncClientParams, endpointDiscoveryEnabled); this.executorService = asyncClientParams.getExecutor(); } /** * Returns the executor service used by this client to execute async requests. * * @return The executor service used by this client to execute async requests. */ public ExecutorService getExecutorService() { return executorService; } @Override public java.util.concurrent.Future associateEncryptionConfigAsync(AssociateEncryptionConfigRequest request) { return associateEncryptionConfigAsync(request, null); } @Override public java.util.concurrent.Future associateEncryptionConfigAsync(final AssociateEncryptionConfigRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final AssociateEncryptionConfigRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public AssociateEncryptionConfigResult call() throws Exception { AssociateEncryptionConfigResult result = null; try { result = executeAssociateEncryptionConfig(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future associateIdentityProviderConfigAsync( AssociateIdentityProviderConfigRequest request) { return associateIdentityProviderConfigAsync(request, null); } @Override public java.util.concurrent.Future associateIdentityProviderConfigAsync( final AssociateIdentityProviderConfigRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final AssociateIdentityProviderConfigRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public AssociateIdentityProviderConfigResult call() throws Exception { AssociateIdentityProviderConfigResult result = null; try { result = executeAssociateIdentityProviderConfig(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future createAddonAsync(CreateAddonRequest request) { return createAddonAsync(request, null); } @Override public java.util.concurrent.Future createAddonAsync(final CreateAddonRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final CreateAddonRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public CreateAddonResult call() throws Exception { CreateAddonResult result = null; try { result = executeCreateAddon(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future createClusterAsync(CreateClusterRequest request) { return createClusterAsync(request, null); } @Override public java.util.concurrent.Future createClusterAsync(final CreateClusterRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final CreateClusterRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public CreateClusterResult call() throws Exception { CreateClusterResult result = null; try { result = executeCreateCluster(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future createFargateProfileAsync(CreateFargateProfileRequest request) { return createFargateProfileAsync(request, null); } @Override public java.util.concurrent.Future createFargateProfileAsync(final CreateFargateProfileRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final CreateFargateProfileRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public CreateFargateProfileResult call() throws Exception { CreateFargateProfileResult result = null; try { result = executeCreateFargateProfile(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future createNodegroupAsync(CreateNodegroupRequest request) { return createNodegroupAsync(request, null); } @Override public java.util.concurrent.Future createNodegroupAsync(final CreateNodegroupRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final CreateNodegroupRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public CreateNodegroupResult call() throws Exception { CreateNodegroupResult result = null; try { result = executeCreateNodegroup(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future deleteAddonAsync(DeleteAddonRequest request) { return deleteAddonAsync(request, null); } @Override public java.util.concurrent.Future deleteAddonAsync(final DeleteAddonRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DeleteAddonRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DeleteAddonResult call() throws Exception { DeleteAddonResult result = null; try { result = executeDeleteAddon(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future deleteClusterAsync(DeleteClusterRequest request) { return deleteClusterAsync(request, null); } @Override public java.util.concurrent.Future deleteClusterAsync(final DeleteClusterRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DeleteClusterRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DeleteClusterResult call() throws Exception { DeleteClusterResult result = null; try { result = executeDeleteCluster(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future deleteFargateProfileAsync(DeleteFargateProfileRequest request) { return deleteFargateProfileAsync(request, null); } @Override public java.util.concurrent.Future deleteFargateProfileAsync(final DeleteFargateProfileRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DeleteFargateProfileRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DeleteFargateProfileResult call() throws Exception { DeleteFargateProfileResult result = null; try { result = executeDeleteFargateProfile(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future deleteNodegroupAsync(DeleteNodegroupRequest request) { return deleteNodegroupAsync(request, null); } @Override public java.util.concurrent.Future deleteNodegroupAsync(final DeleteNodegroupRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DeleteNodegroupRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DeleteNodegroupResult call() throws Exception { DeleteNodegroupResult result = null; try { result = executeDeleteNodegroup(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future deregisterClusterAsync(DeregisterClusterRequest request) { return deregisterClusterAsync(request, null); } @Override public java.util.concurrent.Future deregisterClusterAsync(final DeregisterClusterRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DeregisterClusterRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DeregisterClusterResult call() throws Exception { DeregisterClusterResult result = null; try { result = executeDeregisterCluster(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future describeAddonAsync(DescribeAddonRequest request) { return describeAddonAsync(request, null); } @Override public java.util.concurrent.Future describeAddonAsync(final DescribeAddonRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DescribeAddonRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DescribeAddonResult call() throws Exception { DescribeAddonResult result = null; try { result = executeDescribeAddon(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future describeAddonConfigurationAsync(DescribeAddonConfigurationRequest request) { return describeAddonConfigurationAsync(request, null); } @Override public java.util.concurrent.Future describeAddonConfigurationAsync(final DescribeAddonConfigurationRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DescribeAddonConfigurationRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DescribeAddonConfigurationResult call() throws Exception { DescribeAddonConfigurationResult result = null; try { result = executeDescribeAddonConfiguration(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future describeAddonVersionsAsync(DescribeAddonVersionsRequest request) { return describeAddonVersionsAsync(request, null); } @Override public java.util.concurrent.Future describeAddonVersionsAsync(final DescribeAddonVersionsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DescribeAddonVersionsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DescribeAddonVersionsResult call() throws Exception { DescribeAddonVersionsResult result = null; try { result = executeDescribeAddonVersions(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future describeClusterAsync(DescribeClusterRequest request) { return describeClusterAsync(request, null); } @Override public java.util.concurrent.Future describeClusterAsync(final DescribeClusterRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DescribeClusterRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DescribeClusterResult call() throws Exception { DescribeClusterResult result = null; try { result = executeDescribeCluster(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future describeFargateProfileAsync(DescribeFargateProfileRequest request) { return describeFargateProfileAsync(request, null); } @Override public java.util.concurrent.Future describeFargateProfileAsync(final DescribeFargateProfileRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DescribeFargateProfileRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DescribeFargateProfileResult call() throws Exception { DescribeFargateProfileResult result = null; try { result = executeDescribeFargateProfile(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future describeIdentityProviderConfigAsync(DescribeIdentityProviderConfigRequest request) { return describeIdentityProviderConfigAsync(request, null); } @Override public java.util.concurrent.Future describeIdentityProviderConfigAsync( final DescribeIdentityProviderConfigRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DescribeIdentityProviderConfigRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DescribeIdentityProviderConfigResult call() throws Exception { DescribeIdentityProviderConfigResult result = null; try { result = executeDescribeIdentityProviderConfig(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future describeNodegroupAsync(DescribeNodegroupRequest request) { return describeNodegroupAsync(request, null); } @Override public java.util.concurrent.Future describeNodegroupAsync(final DescribeNodegroupRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DescribeNodegroupRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DescribeNodegroupResult call() throws Exception { DescribeNodegroupResult result = null; try { result = executeDescribeNodegroup(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future describeUpdateAsync(DescribeUpdateRequest request) { return describeUpdateAsync(request, null); } @Override public java.util.concurrent.Future describeUpdateAsync(final DescribeUpdateRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DescribeUpdateRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DescribeUpdateResult call() throws Exception { DescribeUpdateResult result = null; try { result = executeDescribeUpdate(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future disassociateIdentityProviderConfigAsync( DisassociateIdentityProviderConfigRequest request) { return disassociateIdentityProviderConfigAsync(request, null); } @Override public java.util.concurrent.Future disassociateIdentityProviderConfigAsync( final DisassociateIdentityProviderConfigRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DisassociateIdentityProviderConfigRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DisassociateIdentityProviderConfigResult call() throws Exception { DisassociateIdentityProviderConfigResult result = null; try { result = executeDisassociateIdentityProviderConfig(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future listAddonsAsync(ListAddonsRequest request) { return listAddonsAsync(request, null); } @Override public java.util.concurrent.Future listAddonsAsync(final ListAddonsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListAddonsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListAddonsResult call() throws Exception { ListAddonsResult result = null; try { result = executeListAddons(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future listClustersAsync(ListClustersRequest request) { return listClustersAsync(request, null); } @Override public java.util.concurrent.Future listClustersAsync(final ListClustersRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListClustersRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListClustersResult call() throws Exception { ListClustersResult result = null; try { result = executeListClusters(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future listFargateProfilesAsync(ListFargateProfilesRequest request) { return listFargateProfilesAsync(request, null); } @Override public java.util.concurrent.Future listFargateProfilesAsync(final ListFargateProfilesRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListFargateProfilesRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListFargateProfilesResult call() throws Exception { ListFargateProfilesResult result = null; try { result = executeListFargateProfiles(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future listIdentityProviderConfigsAsync(ListIdentityProviderConfigsRequest request) { return listIdentityProviderConfigsAsync(request, null); } @Override public java.util.concurrent.Future listIdentityProviderConfigsAsync(final ListIdentityProviderConfigsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListIdentityProviderConfigsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListIdentityProviderConfigsResult call() throws Exception { ListIdentityProviderConfigsResult result = null; try { result = executeListIdentityProviderConfigs(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future listNodegroupsAsync(ListNodegroupsRequest request) { return listNodegroupsAsync(request, null); } @Override public java.util.concurrent.Future listNodegroupsAsync(final ListNodegroupsRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListNodegroupsRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListNodegroupsResult call() throws Exception { ListNodegroupsResult result = null; try { result = executeListNodegroups(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future listTagsForResourceAsync(ListTagsForResourceRequest request) { return listTagsForResourceAsync(request, null); } @Override public java.util.concurrent.Future listTagsForResourceAsync(final ListTagsForResourceRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListTagsForResourceRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListTagsForResourceResult call() throws Exception { ListTagsForResourceResult result = null; try { result = executeListTagsForResource(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future listUpdatesAsync(ListUpdatesRequest request) { return listUpdatesAsync(request, null); } @Override public java.util.concurrent.Future listUpdatesAsync(final ListUpdatesRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListUpdatesRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListUpdatesResult call() throws Exception { ListUpdatesResult result = null; try { result = executeListUpdates(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future registerClusterAsync(RegisterClusterRequest request) { return registerClusterAsync(request, null); } @Override public java.util.concurrent.Future registerClusterAsync(final RegisterClusterRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final RegisterClusterRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public RegisterClusterResult call() throws Exception { RegisterClusterResult result = null; try { result = executeRegisterCluster(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future tagResourceAsync(TagResourceRequest request) { return tagResourceAsync(request, null); } @Override public java.util.concurrent.Future tagResourceAsync(final TagResourceRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final TagResourceRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public TagResourceResult call() throws Exception { TagResourceResult result = null; try { result = executeTagResource(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future untagResourceAsync(UntagResourceRequest request) { return untagResourceAsync(request, null); } @Override public java.util.concurrent.Future untagResourceAsync(final UntagResourceRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UntagResourceRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UntagResourceResult call() throws Exception { UntagResourceResult result = null; try { result = executeUntagResource(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future updateAddonAsync(UpdateAddonRequest request) { return updateAddonAsync(request, null); } @Override public java.util.concurrent.Future updateAddonAsync(final UpdateAddonRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateAddonRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateAddonResult call() throws Exception { UpdateAddonResult result = null; try { result = executeUpdateAddon(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future updateClusterConfigAsync(UpdateClusterConfigRequest request) { return updateClusterConfigAsync(request, null); } @Override public java.util.concurrent.Future updateClusterConfigAsync(final UpdateClusterConfigRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateClusterConfigRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateClusterConfigResult call() throws Exception { UpdateClusterConfigResult result = null; try { result = executeUpdateClusterConfig(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future updateClusterVersionAsync(UpdateClusterVersionRequest request) { return updateClusterVersionAsync(request, null); } @Override public java.util.concurrent.Future updateClusterVersionAsync(final UpdateClusterVersionRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateClusterVersionRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateClusterVersionResult call() throws Exception { UpdateClusterVersionResult result = null; try { result = executeUpdateClusterVersion(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future updateNodegroupConfigAsync(UpdateNodegroupConfigRequest request) { return updateNodegroupConfigAsync(request, null); } @Override public java.util.concurrent.Future updateNodegroupConfigAsync(final UpdateNodegroupConfigRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateNodegroupConfigRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateNodegroupConfigResult call() throws Exception { UpdateNodegroupConfigResult result = null; try { result = executeUpdateNodegroupConfig(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } @Override public java.util.concurrent.Future updateNodegroupVersionAsync(UpdateNodegroupVersionRequest request) { return updateNodegroupVersionAsync(request, null); } @Override public java.util.concurrent.Future updateNodegroupVersionAsync(final UpdateNodegroupVersionRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateNodegroupVersionRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateNodegroupVersionResult call() throws Exception { UpdateNodegroupVersionResult result = null; try { result = executeUpdateNodegroupVersion(finalRequest); } catch (Exception ex) { if (asyncHandler != null) { asyncHandler.onError(ex); } throw ex; } if (asyncHandler != null) { asyncHandler.onSuccess(finalRequest, result); } return result; } }); } /** * Shuts down the client, releasing all managed resources. This includes forcibly terminating all pending * asynchronous service calls. Clients who wish to give pending asynchronous service calls time to complete should * call {@code getExecutorService().shutdown()} followed by {@code getExecutorService().awaitTermination()} prior to * calling this method. */ @Override public void shutdown() { super.shutdown(); executorService.shutdownNow(); } }