/* * 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.prometheus; import javax.annotation.Generated; import com.amazonaws.services.prometheus.model.*; import com.amazonaws.client.AwsAsyncClientParams; import com.amazonaws.annotation.ThreadSafe; import java.util.concurrent.ExecutorService; /** * Client for accessing Amazon Prometheus Service 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 Managed Service for Prometheus *

*/ @ThreadSafe @Generated("com.amazonaws:aws-java-sdk-code-generator") public class AmazonPrometheusAsyncClient extends AmazonPrometheusClient implements AmazonPrometheusAsync { private static final int DEFAULT_THREAD_POOL_SIZE = 50; private final java.util.concurrent.ExecutorService executorService; public static AmazonPrometheusAsyncClientBuilder asyncBuilder() { return AmazonPrometheusAsyncClientBuilder.standard(); } /** * Constructs a new asynchronous client to invoke service methods on Amazon Prometheus Service using the specified * parameters. * * @param asyncClientParams * Object providing client parameters. */ AmazonPrometheusAsyncClient(AwsAsyncClientParams asyncClientParams) { this(asyncClientParams, false); } /** * Constructs a new asynchronous client to invoke service methods on Amazon Prometheus Service using the specified * parameters. * * @param asyncClientParams * Object providing client parameters. * @param endpointDiscoveryEnabled * true will enable endpoint discovery if the service supports it. */ AmazonPrometheusAsyncClient(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 createAlertManagerDefinitionAsync(CreateAlertManagerDefinitionRequest request) { return createAlertManagerDefinitionAsync(request, null); } @Override public java.util.concurrent.Future createAlertManagerDefinitionAsync(final CreateAlertManagerDefinitionRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final CreateAlertManagerDefinitionRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public CreateAlertManagerDefinitionResult call() throws Exception { CreateAlertManagerDefinitionResult result = null; try { result = executeCreateAlertManagerDefinition(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 createLoggingConfigurationAsync(CreateLoggingConfigurationRequest request) { return createLoggingConfigurationAsync(request, null); } @Override public java.util.concurrent.Future createLoggingConfigurationAsync(final CreateLoggingConfigurationRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final CreateLoggingConfigurationRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public CreateLoggingConfigurationResult call() throws Exception { CreateLoggingConfigurationResult result = null; try { result = executeCreateLoggingConfiguration(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 createRuleGroupsNamespaceAsync(CreateRuleGroupsNamespaceRequest request) { return createRuleGroupsNamespaceAsync(request, null); } @Override public java.util.concurrent.Future createRuleGroupsNamespaceAsync(final CreateRuleGroupsNamespaceRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final CreateRuleGroupsNamespaceRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public CreateRuleGroupsNamespaceResult call() throws Exception { CreateRuleGroupsNamespaceResult result = null; try { result = executeCreateRuleGroupsNamespace(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 createWorkspaceAsync(CreateWorkspaceRequest request) { return createWorkspaceAsync(request, null); } @Override public java.util.concurrent.Future createWorkspaceAsync(final CreateWorkspaceRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final CreateWorkspaceRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public CreateWorkspaceResult call() throws Exception { CreateWorkspaceResult result = null; try { result = executeCreateWorkspace(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 deleteAlertManagerDefinitionAsync(DeleteAlertManagerDefinitionRequest request) { return deleteAlertManagerDefinitionAsync(request, null); } @Override public java.util.concurrent.Future deleteAlertManagerDefinitionAsync(final DeleteAlertManagerDefinitionRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DeleteAlertManagerDefinitionRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DeleteAlertManagerDefinitionResult call() throws Exception { DeleteAlertManagerDefinitionResult result = null; try { result = executeDeleteAlertManagerDefinition(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 deleteLoggingConfigurationAsync(DeleteLoggingConfigurationRequest request) { return deleteLoggingConfigurationAsync(request, null); } @Override public java.util.concurrent.Future deleteLoggingConfigurationAsync(final DeleteLoggingConfigurationRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DeleteLoggingConfigurationRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DeleteLoggingConfigurationResult call() throws Exception { DeleteLoggingConfigurationResult result = null; try { result = executeDeleteLoggingConfiguration(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 deleteRuleGroupsNamespaceAsync(DeleteRuleGroupsNamespaceRequest request) { return deleteRuleGroupsNamespaceAsync(request, null); } @Override public java.util.concurrent.Future deleteRuleGroupsNamespaceAsync(final DeleteRuleGroupsNamespaceRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DeleteRuleGroupsNamespaceRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DeleteRuleGroupsNamespaceResult call() throws Exception { DeleteRuleGroupsNamespaceResult result = null; try { result = executeDeleteRuleGroupsNamespace(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 deleteWorkspaceAsync(DeleteWorkspaceRequest request) { return deleteWorkspaceAsync(request, null); } @Override public java.util.concurrent.Future deleteWorkspaceAsync(final DeleteWorkspaceRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DeleteWorkspaceRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DeleteWorkspaceResult call() throws Exception { DeleteWorkspaceResult result = null; try { result = executeDeleteWorkspace(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 describeAlertManagerDefinitionAsync(DescribeAlertManagerDefinitionRequest request) { return describeAlertManagerDefinitionAsync(request, null); } @Override public java.util.concurrent.Future describeAlertManagerDefinitionAsync( final DescribeAlertManagerDefinitionRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DescribeAlertManagerDefinitionRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DescribeAlertManagerDefinitionResult call() throws Exception { DescribeAlertManagerDefinitionResult result = null; try { result = executeDescribeAlertManagerDefinition(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 describeLoggingConfigurationAsync(DescribeLoggingConfigurationRequest request) { return describeLoggingConfigurationAsync(request, null); } @Override public java.util.concurrent.Future describeLoggingConfigurationAsync(final DescribeLoggingConfigurationRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DescribeLoggingConfigurationRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DescribeLoggingConfigurationResult call() throws Exception { DescribeLoggingConfigurationResult result = null; try { result = executeDescribeLoggingConfiguration(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 describeRuleGroupsNamespaceAsync(DescribeRuleGroupsNamespaceRequest request) { return describeRuleGroupsNamespaceAsync(request, null); } @Override public java.util.concurrent.Future describeRuleGroupsNamespaceAsync(final DescribeRuleGroupsNamespaceRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DescribeRuleGroupsNamespaceRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DescribeRuleGroupsNamespaceResult call() throws Exception { DescribeRuleGroupsNamespaceResult result = null; try { result = executeDescribeRuleGroupsNamespace(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 describeWorkspaceAsync(DescribeWorkspaceRequest request) { return describeWorkspaceAsync(request, null); } @Override public java.util.concurrent.Future describeWorkspaceAsync(final DescribeWorkspaceRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final DescribeWorkspaceRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public DescribeWorkspaceResult call() throws Exception { DescribeWorkspaceResult result = null; try { result = executeDescribeWorkspace(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 listRuleGroupsNamespacesAsync(ListRuleGroupsNamespacesRequest request) { return listRuleGroupsNamespacesAsync(request, null); } @Override public java.util.concurrent.Future listRuleGroupsNamespacesAsync(final ListRuleGroupsNamespacesRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListRuleGroupsNamespacesRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListRuleGroupsNamespacesResult call() throws Exception { ListRuleGroupsNamespacesResult result = null; try { result = executeListRuleGroupsNamespaces(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 listWorkspacesAsync(ListWorkspacesRequest request) { return listWorkspacesAsync(request, null); } @Override public java.util.concurrent.Future listWorkspacesAsync(final ListWorkspacesRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final ListWorkspacesRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public ListWorkspacesResult call() throws Exception { ListWorkspacesResult result = null; try { result = executeListWorkspaces(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 putAlertManagerDefinitionAsync(PutAlertManagerDefinitionRequest request) { return putAlertManagerDefinitionAsync(request, null); } @Override public java.util.concurrent.Future putAlertManagerDefinitionAsync(final PutAlertManagerDefinitionRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final PutAlertManagerDefinitionRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public PutAlertManagerDefinitionResult call() throws Exception { PutAlertManagerDefinitionResult result = null; try { result = executePutAlertManagerDefinition(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 putRuleGroupsNamespaceAsync(PutRuleGroupsNamespaceRequest request) { return putRuleGroupsNamespaceAsync(request, null); } @Override public java.util.concurrent.Future putRuleGroupsNamespaceAsync(final PutRuleGroupsNamespaceRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final PutRuleGroupsNamespaceRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public PutRuleGroupsNamespaceResult call() throws Exception { PutRuleGroupsNamespaceResult result = null; try { result = executePutRuleGroupsNamespace(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 updateLoggingConfigurationAsync(UpdateLoggingConfigurationRequest request) { return updateLoggingConfigurationAsync(request, null); } @Override public java.util.concurrent.Future updateLoggingConfigurationAsync(final UpdateLoggingConfigurationRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateLoggingConfigurationRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateLoggingConfigurationResult call() throws Exception { UpdateLoggingConfigurationResult result = null; try { result = executeUpdateLoggingConfiguration(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 updateWorkspaceAliasAsync(UpdateWorkspaceAliasRequest request) { return updateWorkspaceAliasAsync(request, null); } @Override public java.util.concurrent.Future updateWorkspaceAliasAsync(final UpdateWorkspaceAliasRequest request, final com.amazonaws.handlers.AsyncHandler asyncHandler) { final UpdateWorkspaceAliasRequest finalRequest = beforeClientExecution(request); return executorService.submit(new java.util.concurrent.Callable() { @Override public UpdateWorkspaceAliasResult call() throws Exception { UpdateWorkspaceAliasResult result = null; try { result = executeUpdateWorkspaceAlias(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(); } }