/* * Copyright 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. */ /* * Do not modify this file. This file is generated from the timestream-query-2018-11-01.normal.json service model. */ using System; using System.Collections.Generic; using System.Net; using Amazon.TimestreamQuery.Model; using Amazon.TimestreamQuery.Model.Internal.MarshallTransformations; using Amazon.TimestreamQuery.Internal; using Amazon.Runtime; using Amazon.Runtime.Internal; using Amazon.Runtime.Internal.Auth; using Amazon.Runtime.Internal.Transform; namespace Amazon.TimestreamQuery { /// /// Implementation for accessing TimestreamQuery /// /// Amazon Timestream Query /// public partial class AmazonTimestreamQueryClient : AmazonServiceClient, IAmazonTimestreamQuery { private static IServiceMetadata serviceMetadata = new AmazonTimestreamQueryMetadata(); #if BCL45 || AWS_ASYNC_ENUMERABLES_API private ITimestreamQueryPaginatorFactory _paginators; /// /// Paginators for the service /// public ITimestreamQueryPaginatorFactory Paginators { get { if (this._paginators == null) { this._paginators = new TimestreamQueryPaginatorFactory(this); } return this._paginators; } } #endif #region Constructors /// /// Constructs AmazonTimestreamQueryClient with the credentials loaded from the application's /// default configuration, and if unsuccessful from the Instance Profile service on an EC2 instance. /// /// Example App.config with credentials set. /// /// <?xml version="1.0" encoding="utf-8" ?> /// <configuration> /// <appSettings> /// <add key="AWSProfileName" value="AWS Default"/> /// </appSettings> /// </configuration> /// /// /// public AmazonTimestreamQueryClient() : base(FallbackCredentialsFactory.GetCredentials(), new AmazonTimestreamQueryConfig()) { } /// /// Constructs AmazonTimestreamQueryClient with the credentials loaded from the application's /// default configuration, and if unsuccessful from the Instance Profile service on an EC2 instance. /// /// Example App.config with credentials set. /// /// <?xml version="1.0" encoding="utf-8" ?> /// <configuration> /// <appSettings> /// <add key="AWSProfileName" value="AWS Default"/> /// </appSettings> /// </configuration> /// /// /// /// The region to connect. public AmazonTimestreamQueryClient(RegionEndpoint region) : base(FallbackCredentialsFactory.GetCredentials(), new AmazonTimestreamQueryConfig{RegionEndpoint = region}) { } /// /// Constructs AmazonTimestreamQueryClient with the credentials loaded from the application's /// default configuration, and if unsuccessful from the Instance Profile service on an EC2 instance. /// /// Example App.config with credentials set. /// /// <?xml version="1.0" encoding="utf-8" ?> /// <configuration> /// <appSettings> /// <add key="AWSProfileName" value="AWS Default"/> /// </appSettings> /// </configuration> /// /// /// /// The AmazonTimestreamQueryClient Configuration Object public AmazonTimestreamQueryClient(AmazonTimestreamQueryConfig config) : base(FallbackCredentialsFactory.GetCredentials(config), config){} /// /// Constructs AmazonTimestreamQueryClient with AWS Credentials /// /// AWS Credentials public AmazonTimestreamQueryClient(AWSCredentials credentials) : this(credentials, new AmazonTimestreamQueryConfig()) { } /// /// Constructs AmazonTimestreamQueryClient with AWS Credentials /// /// AWS Credentials /// The region to connect. public AmazonTimestreamQueryClient(AWSCredentials credentials, RegionEndpoint region) : this(credentials, new AmazonTimestreamQueryConfig{RegionEndpoint = region}) { } /// /// Constructs AmazonTimestreamQueryClient with AWS Credentials and an /// AmazonTimestreamQueryClient Configuration object. /// /// AWS Credentials /// The AmazonTimestreamQueryClient Configuration Object public AmazonTimestreamQueryClient(AWSCredentials credentials, AmazonTimestreamQueryConfig clientConfig) : base(credentials, clientConfig) { } /// /// Constructs AmazonTimestreamQueryClient with AWS Access Key ID and AWS Secret Key /// /// AWS Access Key ID /// AWS Secret Access Key public AmazonTimestreamQueryClient(string awsAccessKeyId, string awsSecretAccessKey) : this(awsAccessKeyId, awsSecretAccessKey, new AmazonTimestreamQueryConfig()) { } /// /// Constructs AmazonTimestreamQueryClient with AWS Access Key ID and AWS Secret Key /// /// AWS Access Key ID /// AWS Secret Access Key /// The region to connect. public AmazonTimestreamQueryClient(string awsAccessKeyId, string awsSecretAccessKey, RegionEndpoint region) : this(awsAccessKeyId, awsSecretAccessKey, new AmazonTimestreamQueryConfig() {RegionEndpoint=region}) { } /// /// Constructs AmazonTimestreamQueryClient with AWS Access Key ID, AWS Secret Key and an /// AmazonTimestreamQueryClient Configuration object. /// /// AWS Access Key ID /// AWS Secret Access Key /// The AmazonTimestreamQueryClient Configuration Object public AmazonTimestreamQueryClient(string awsAccessKeyId, string awsSecretAccessKey, AmazonTimestreamQueryConfig clientConfig) : base(awsAccessKeyId, awsSecretAccessKey, clientConfig) { } /// /// Constructs AmazonTimestreamQueryClient with AWS Access Key ID and AWS Secret Key /// /// AWS Access Key ID /// AWS Secret Access Key /// AWS Session Token public AmazonTimestreamQueryClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken) : this(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, new AmazonTimestreamQueryConfig()) { } /// /// Constructs AmazonTimestreamQueryClient with AWS Access Key ID and AWS Secret Key /// /// AWS Access Key ID /// AWS Secret Access Key /// AWS Session Token /// The region to connect. public AmazonTimestreamQueryClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken, RegionEndpoint region) : this(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, new AmazonTimestreamQueryConfig{RegionEndpoint = region}) { } /// /// Constructs AmazonTimestreamQueryClient with AWS Access Key ID, AWS Secret Key and an /// AmazonTimestreamQueryClient Configuration object. /// /// AWS Access Key ID /// AWS Secret Access Key /// AWS Session Token /// The AmazonTimestreamQueryClient Configuration Object public AmazonTimestreamQueryClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken, AmazonTimestreamQueryConfig clientConfig) : base(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, clientConfig) { } #endregion #region Overrides /// /// Creates the signer for the service. /// protected override AbstractAWSSigner CreateSigner() { return new AWS4Signer(); } /// /// Customize the pipeline /// /// protected override void CustomizeRuntimePipeline(RuntimePipeline pipeline) { pipeline.RemoveHandler(); pipeline.AddHandlerAfter(new AmazonTimestreamQueryEndpointResolver()); } /// /// Capture metadata for the service. /// protected override IServiceMetadata ServiceMetadata { get { return serviceMetadata; } } #endregion #region Dispose /// /// Disposes the service client. /// protected override void Dispose(bool disposing) { base.Dispose(disposing); } #endregion #region EndpointOperation Override protected override IEnumerable EndpointOperation(EndpointOperationContextBase context) { return EndpointDiscoveryResolver.ResolveEndpoints(context, () => { var request = new DescribeEndpointsRequest { }; var response = DescribeEndpoints(request); if(response.HttpStatusCode != HttpStatusCode.OK || response.Endpoints == null) { return null; } var endpoints = new List(); foreach(var endpoint in response.Endpoints) { endpoints.Add(new DiscoveryEndpoint(endpoint.Address, endpoint.CachePeriodInMinutes)); } return endpoints; }); } #endregion #region CancelQuery /// /// Cancels a query that has been issued. Cancellation is provided only if the query /// has not completed running before the cancellation request was issued. Because cancellation /// is an idempotent operation, subsequent cancellation requests will return a CancellationMessage, /// indicating that the query has already been canceled. See code /// sample for details. /// /// Container for the necessary parameters to execute the CancelQuery service method. /// /// The response from the CancelQuery service method, as returned by TimestreamQuery. /// /// You are not authorized to perform this action. /// /// /// Timestream was unable to fully process this request because of an internal server /// error. /// /// /// The requested endpoint was not valid. /// /// /// The request was denied due to request throttling. /// /// /// Invalid or malformed request. /// /// REST API Reference for CancelQuery Operation public virtual CancelQueryResponse CancelQuery(CancelQueryRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = CancelQueryRequestMarshaller.Instance; options.ResponseUnmarshaller = CancelQueryResponseUnmarshaller.Instance; options.EndpointDiscoveryMarshaller = CancelQueryEndpointDiscoveryMarshaller.Instance; options.EndpointOperation = EndpointOperation; return Invoke(request, options); } /// /// Initiates the asynchronous execution of the CancelQuery operation. /// /// /// Container for the necessary parameters to execute the CancelQuery operation on AmazonTimestreamQueryClient. /// An AsyncCallback delegate that is invoked when the operation completes. /// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback /// procedure using the AsyncState property. /// /// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndCancelQuery /// operation. /// REST API Reference for CancelQuery Operation public virtual IAsyncResult BeginCancelQuery(CancelQueryRequest request, AsyncCallback callback, object state) { var options = new InvokeOptions(); options.RequestMarshaller = CancelQueryRequestMarshaller.Instance; options.ResponseUnmarshaller = CancelQueryResponseUnmarshaller.Instance; options.EndpointDiscoveryMarshaller = CancelQueryEndpointDiscoveryMarshaller.Instance; options.EndpointOperation = EndpointOperation; return BeginInvoke(request, options, callback, state); } /// /// Finishes the asynchronous execution of the CancelQuery operation. /// /// /// The IAsyncResult returned by the call to BeginCancelQuery. /// /// Returns a CancelQueryResult from TimestreamQuery. /// REST API Reference for CancelQuery Operation public virtual CancelQueryResponse EndCancelQuery(IAsyncResult asyncResult) { return EndInvoke(asyncResult); } #endregion #region CreateScheduledQuery /// /// Create a scheduled query that will be run on your behalf at the configured schedule. /// Timestream assumes the execution role provided as part of the ScheduledQueryExecutionRoleArn /// parameter to run the query. You can use the NotificationConfiguration /// parameter to configure notification for your scheduled query operations. /// /// Container for the necessary parameters to execute the CreateScheduledQuery service method. /// /// The response from the CreateScheduledQuery service method, as returned by TimestreamQuery. /// /// You are not authorized to perform this action. /// /// /// Unable to poll results for a cancelled query. /// /// /// Timestream was unable to fully process this request because of an internal server /// error. /// /// /// The requested endpoint was not valid. /// /// /// You have exceeded the service quota. /// /// /// The request was denied due to request throttling. /// /// /// Invalid or malformed request. /// /// REST API Reference for CreateScheduledQuery Operation public virtual CreateScheduledQueryResponse CreateScheduledQuery(CreateScheduledQueryRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = CreateScheduledQueryRequestMarshaller.Instance; options.ResponseUnmarshaller = CreateScheduledQueryResponseUnmarshaller.Instance; options.EndpointDiscoveryMarshaller = CreateScheduledQueryEndpointDiscoveryMarshaller.Instance; options.EndpointOperation = EndpointOperation; return Invoke(request, options); } /// /// Initiates the asynchronous execution of the CreateScheduledQuery operation. /// /// /// Container for the necessary parameters to execute the CreateScheduledQuery operation on AmazonTimestreamQueryClient. /// An AsyncCallback delegate that is invoked when the operation completes. /// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback /// procedure using the AsyncState property. /// /// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndCreateScheduledQuery /// operation. /// REST API Reference for CreateScheduledQuery Operation public virtual IAsyncResult BeginCreateScheduledQuery(CreateScheduledQueryRequest request, AsyncCallback callback, object state) { var options = new InvokeOptions(); options.RequestMarshaller = CreateScheduledQueryRequestMarshaller.Instance; options.ResponseUnmarshaller = CreateScheduledQueryResponseUnmarshaller.Instance; options.EndpointDiscoveryMarshaller = CreateScheduledQueryEndpointDiscoveryMarshaller.Instance; options.EndpointOperation = EndpointOperation; return BeginInvoke(request, options, callback, state); } /// /// Finishes the asynchronous execution of the CreateScheduledQuery operation. /// /// /// The IAsyncResult returned by the call to BeginCreateScheduledQuery. /// /// Returns a CreateScheduledQueryResult from TimestreamQuery. /// REST API Reference for CreateScheduledQuery Operation public virtual CreateScheduledQueryResponse EndCreateScheduledQuery(IAsyncResult asyncResult) { return EndInvoke(asyncResult); } #endregion #region DeleteScheduledQuery /// /// Deletes a given scheduled query. This is an irreversible operation. /// /// Container for the necessary parameters to execute the DeleteScheduledQuery service method. /// /// The response from the DeleteScheduledQuery service method, as returned by TimestreamQuery. /// /// You are not authorized to perform this action. /// /// /// Timestream was unable to fully process this request because of an internal server /// error. /// /// /// The requested endpoint was not valid. /// /// /// The requested resource could not be found. /// /// /// The request was denied due to request throttling. /// /// /// Invalid or malformed request. /// /// REST API Reference for DeleteScheduledQuery Operation public virtual DeleteScheduledQueryResponse DeleteScheduledQuery(DeleteScheduledQueryRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = DeleteScheduledQueryRequestMarshaller.Instance; options.ResponseUnmarshaller = DeleteScheduledQueryResponseUnmarshaller.Instance; options.EndpointDiscoveryMarshaller = DeleteScheduledQueryEndpointDiscoveryMarshaller.Instance; options.EndpointOperation = EndpointOperation; return Invoke(request, options); } /// /// Initiates the asynchronous execution of the DeleteScheduledQuery operation. /// /// /// Container for the necessary parameters to execute the DeleteScheduledQuery operation on AmazonTimestreamQueryClient. /// An AsyncCallback delegate that is invoked when the operation completes. /// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback /// procedure using the AsyncState property. /// /// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndDeleteScheduledQuery /// operation. /// REST API Reference for DeleteScheduledQuery Operation public virtual IAsyncResult BeginDeleteScheduledQuery(DeleteScheduledQueryRequest request, AsyncCallback callback, object state) { var options = new InvokeOptions(); options.RequestMarshaller = DeleteScheduledQueryRequestMarshaller.Instance; options.ResponseUnmarshaller = DeleteScheduledQueryResponseUnmarshaller.Instance; options.EndpointDiscoveryMarshaller = DeleteScheduledQueryEndpointDiscoveryMarshaller.Instance; options.EndpointOperation = EndpointOperation; return BeginInvoke(request, options, callback, state); } /// /// Finishes the asynchronous execution of the DeleteScheduledQuery operation. /// /// /// The IAsyncResult returned by the call to BeginDeleteScheduledQuery. /// /// Returns a DeleteScheduledQueryResult from TimestreamQuery. /// REST API Reference for DeleteScheduledQuery Operation public virtual DeleteScheduledQueryResponse EndDeleteScheduledQuery(IAsyncResult asyncResult) { return EndInvoke(asyncResult); } #endregion #region DescribeEndpoints /// /// DescribeEndpoints returns a list of available endpoints to make Timestream API calls /// against. This API is available through both Write and Query. /// /// /// /// Because the Timestream SDKs are designed to transparently work with the service’s /// architecture, including the management and mapping of the service endpoints, it /// is not recommended that you use this API unless: /// /// /// /// For detailed information on how and when to use and implement DescribeEndpoints, see /// The /// Endpoint Discovery Pattern. /// /// /// Container for the necessary parameters to execute the DescribeEndpoints service method. /// /// The response from the DescribeEndpoints service method, as returned by TimestreamQuery. /// /// Timestream was unable to fully process this request because of an internal server /// error. /// /// /// The request was denied due to request throttling. /// /// /// Invalid or malformed request. /// /// REST API Reference for DescribeEndpoints Operation public virtual DescribeEndpointsResponse DescribeEndpoints(DescribeEndpointsRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = DescribeEndpointsRequestMarshaller.Instance; options.ResponseUnmarshaller = DescribeEndpointsResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Initiates the asynchronous execution of the DescribeEndpoints operation. /// /// /// Container for the necessary parameters to execute the DescribeEndpoints operation on AmazonTimestreamQueryClient. /// An AsyncCallback delegate that is invoked when the operation completes. /// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback /// procedure using the AsyncState property. /// /// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndDescribeEndpoints /// operation. /// REST API Reference for DescribeEndpoints Operation public virtual IAsyncResult BeginDescribeEndpoints(DescribeEndpointsRequest request, AsyncCallback callback, object state) { var options = new InvokeOptions(); options.RequestMarshaller = DescribeEndpointsRequestMarshaller.Instance; options.ResponseUnmarshaller = DescribeEndpointsResponseUnmarshaller.Instance; return BeginInvoke(request, options, callback, state); } /// /// Finishes the asynchronous execution of the DescribeEndpoints operation. /// /// /// The IAsyncResult returned by the call to BeginDescribeEndpoints. /// /// Returns a DescribeEndpointsResult from TimestreamQuery. /// REST API Reference for DescribeEndpoints Operation public virtual DescribeEndpointsResponse EndDescribeEndpoints(IAsyncResult asyncResult) { return EndInvoke(asyncResult); } #endregion #region DescribeScheduledQuery /// /// Provides detailed information about a scheduled query. /// /// Container for the necessary parameters to execute the DescribeScheduledQuery service method. /// /// The response from the DescribeScheduledQuery service method, as returned by TimestreamQuery. /// /// You are not authorized to perform this action. /// /// /// Timestream was unable to fully process this request because of an internal server /// error. /// /// /// The requested endpoint was not valid. /// /// /// The requested resource could not be found. /// /// /// The request was denied due to request throttling. /// /// /// Invalid or malformed request. /// /// REST API Reference for DescribeScheduledQuery Operation public virtual DescribeScheduledQueryResponse DescribeScheduledQuery(DescribeScheduledQueryRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = DescribeScheduledQueryRequestMarshaller.Instance; options.ResponseUnmarshaller = DescribeScheduledQueryResponseUnmarshaller.Instance; options.EndpointDiscoveryMarshaller = DescribeScheduledQueryEndpointDiscoveryMarshaller.Instance; options.EndpointOperation = EndpointOperation; return Invoke(request, options); } /// /// Initiates the asynchronous execution of the DescribeScheduledQuery operation. /// /// /// Container for the necessary parameters to execute the DescribeScheduledQuery operation on AmazonTimestreamQueryClient. /// An AsyncCallback delegate that is invoked when the operation completes. /// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback /// procedure using the AsyncState property. /// /// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndDescribeScheduledQuery /// operation. /// REST API Reference for DescribeScheduledQuery Operation public virtual IAsyncResult BeginDescribeScheduledQuery(DescribeScheduledQueryRequest request, AsyncCallback callback, object state) { var options = new InvokeOptions(); options.RequestMarshaller = DescribeScheduledQueryRequestMarshaller.Instance; options.ResponseUnmarshaller = DescribeScheduledQueryResponseUnmarshaller.Instance; options.EndpointDiscoveryMarshaller = DescribeScheduledQueryEndpointDiscoveryMarshaller.Instance; options.EndpointOperation = EndpointOperation; return BeginInvoke(request, options, callback, state); } /// /// Finishes the asynchronous execution of the DescribeScheduledQuery operation. /// /// /// The IAsyncResult returned by the call to BeginDescribeScheduledQuery. /// /// Returns a DescribeScheduledQueryResult from TimestreamQuery. /// REST API Reference for DescribeScheduledQuery Operation public virtual DescribeScheduledQueryResponse EndDescribeScheduledQuery(IAsyncResult asyncResult) { return EndInvoke(asyncResult); } #endregion #region ExecuteScheduledQuery /// /// You can use this API to run a scheduled query manually. /// /// Container for the necessary parameters to execute the ExecuteScheduledQuery service method. /// /// The response from the ExecuteScheduledQuery service method, as returned by TimestreamQuery. /// /// You are not authorized to perform this action. /// /// /// Timestream was unable to fully process this request because of an internal server /// error. /// /// /// The requested endpoint was not valid. /// /// /// The requested resource could not be found. /// /// /// The request was denied due to request throttling. /// /// /// Invalid or malformed request. /// /// REST API Reference for ExecuteScheduledQuery Operation public virtual ExecuteScheduledQueryResponse ExecuteScheduledQuery(ExecuteScheduledQueryRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = ExecuteScheduledQueryRequestMarshaller.Instance; options.ResponseUnmarshaller = ExecuteScheduledQueryResponseUnmarshaller.Instance; options.EndpointDiscoveryMarshaller = ExecuteScheduledQueryEndpointDiscoveryMarshaller.Instance; options.EndpointOperation = EndpointOperation; return Invoke(request, options); } /// /// Initiates the asynchronous execution of the ExecuteScheduledQuery operation. /// /// /// Container for the necessary parameters to execute the ExecuteScheduledQuery operation on AmazonTimestreamQueryClient. /// An AsyncCallback delegate that is invoked when the operation completes. /// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback /// procedure using the AsyncState property. /// /// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndExecuteScheduledQuery /// operation. /// REST API Reference for ExecuteScheduledQuery Operation public virtual IAsyncResult BeginExecuteScheduledQuery(ExecuteScheduledQueryRequest request, AsyncCallback callback, object state) { var options = new InvokeOptions(); options.RequestMarshaller = ExecuteScheduledQueryRequestMarshaller.Instance; options.ResponseUnmarshaller = ExecuteScheduledQueryResponseUnmarshaller.Instance; options.EndpointDiscoveryMarshaller = ExecuteScheduledQueryEndpointDiscoveryMarshaller.Instance; options.EndpointOperation = EndpointOperation; return BeginInvoke(request, options, callback, state); } /// /// Finishes the asynchronous execution of the ExecuteScheduledQuery operation. /// /// /// The IAsyncResult returned by the call to BeginExecuteScheduledQuery. /// /// Returns a ExecuteScheduledQueryResult from TimestreamQuery. /// REST API Reference for ExecuteScheduledQuery Operation public virtual ExecuteScheduledQueryResponse EndExecuteScheduledQuery(IAsyncResult asyncResult) { return EndInvoke(asyncResult); } #endregion #region ListScheduledQueries /// /// Gets a list of all scheduled queries in the caller's Amazon account and Region. ListScheduledQueries /// is eventually consistent. /// /// Container for the necessary parameters to execute the ListScheduledQueries service method. /// /// The response from the ListScheduledQueries service method, as returned by TimestreamQuery. /// /// You are not authorized to perform this action. /// /// /// Timestream was unable to fully process this request because of an internal server /// error. /// /// /// The requested endpoint was not valid. /// /// /// The request was denied due to request throttling. /// /// /// Invalid or malformed request. /// /// REST API Reference for ListScheduledQueries Operation public virtual ListScheduledQueriesResponse ListScheduledQueries(ListScheduledQueriesRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = ListScheduledQueriesRequestMarshaller.Instance; options.ResponseUnmarshaller = ListScheduledQueriesResponseUnmarshaller.Instance; options.EndpointDiscoveryMarshaller = ListScheduledQueriesEndpointDiscoveryMarshaller.Instance; options.EndpointOperation = EndpointOperation; return Invoke(request, options); } /// /// Initiates the asynchronous execution of the ListScheduledQueries operation. /// /// /// Container for the necessary parameters to execute the ListScheduledQueries operation on AmazonTimestreamQueryClient. /// An AsyncCallback delegate that is invoked when the operation completes. /// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback /// procedure using the AsyncState property. /// /// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndListScheduledQueries /// operation. /// REST API Reference for ListScheduledQueries Operation public virtual IAsyncResult BeginListScheduledQueries(ListScheduledQueriesRequest request, AsyncCallback callback, object state) { var options = new InvokeOptions(); options.RequestMarshaller = ListScheduledQueriesRequestMarshaller.Instance; options.ResponseUnmarshaller = ListScheduledQueriesResponseUnmarshaller.Instance; options.EndpointDiscoveryMarshaller = ListScheduledQueriesEndpointDiscoveryMarshaller.Instance; options.EndpointOperation = EndpointOperation; return BeginInvoke(request, options, callback, state); } /// /// Finishes the asynchronous execution of the ListScheduledQueries operation. /// /// /// The IAsyncResult returned by the call to BeginListScheduledQueries. /// /// Returns a ListScheduledQueriesResult from TimestreamQuery. /// REST API Reference for ListScheduledQueries Operation public virtual ListScheduledQueriesResponse EndListScheduledQueries(IAsyncResult asyncResult) { return EndInvoke(asyncResult); } #endregion #region ListTagsForResource /// /// List all tags on a Timestream query resource. /// /// Container for the necessary parameters to execute the ListTagsForResource service method. /// /// The response from the ListTagsForResource service method, as returned by TimestreamQuery. /// /// The requested endpoint was not valid. /// /// /// The requested resource could not be found. /// /// /// The request was denied due to request throttling. /// /// /// Invalid or malformed request. /// /// REST API Reference for ListTagsForResource Operation public virtual ListTagsForResourceResponse ListTagsForResource(ListTagsForResourceRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = ListTagsForResourceRequestMarshaller.Instance; options.ResponseUnmarshaller = ListTagsForResourceResponseUnmarshaller.Instance; options.EndpointDiscoveryMarshaller = ListTagsForResourceEndpointDiscoveryMarshaller.Instance; options.EndpointOperation = EndpointOperation; return Invoke(request, options); } /// /// Initiates the asynchronous execution of the ListTagsForResource operation. /// /// /// Container for the necessary parameters to execute the ListTagsForResource operation on AmazonTimestreamQueryClient. /// An AsyncCallback delegate that is invoked when the operation completes. /// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback /// procedure using the AsyncState property. /// /// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndListTagsForResource /// operation. /// REST API Reference for ListTagsForResource Operation public virtual IAsyncResult BeginListTagsForResource(ListTagsForResourceRequest request, AsyncCallback callback, object state) { var options = new InvokeOptions(); options.RequestMarshaller = ListTagsForResourceRequestMarshaller.Instance; options.ResponseUnmarshaller = ListTagsForResourceResponseUnmarshaller.Instance; options.EndpointDiscoveryMarshaller = ListTagsForResourceEndpointDiscoveryMarshaller.Instance; options.EndpointOperation = EndpointOperation; return BeginInvoke(request, options, callback, state); } /// /// Finishes the asynchronous execution of the ListTagsForResource operation. /// /// /// The IAsyncResult returned by the call to BeginListTagsForResource. /// /// Returns a ListTagsForResourceResult from TimestreamQuery. /// REST API Reference for ListTagsForResource Operation public virtual ListTagsForResourceResponse EndListTagsForResource(IAsyncResult asyncResult) { return EndInvoke(asyncResult); } #endregion #region PrepareQuery /// /// A synchronous operation that allows you to submit a query with parameters to be stored /// by Timestream for later running. Timestream only supports using this operation with /// the PrepareQueryRequest$ValidateOnly set to true. /// /// Container for the necessary parameters to execute the PrepareQuery service method. /// /// The response from the PrepareQuery service method, as returned by TimestreamQuery. /// /// You are not authorized to perform this action. /// /// /// Timestream was unable to fully process this request because of an internal server /// error. /// /// /// The requested endpoint was not valid. /// /// /// The request was denied due to request throttling. /// /// /// Invalid or malformed request. /// /// REST API Reference for PrepareQuery Operation public virtual PrepareQueryResponse PrepareQuery(PrepareQueryRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = PrepareQueryRequestMarshaller.Instance; options.ResponseUnmarshaller = PrepareQueryResponseUnmarshaller.Instance; options.EndpointDiscoveryMarshaller = PrepareQueryEndpointDiscoveryMarshaller.Instance; options.EndpointOperation = EndpointOperation; return Invoke(request, options); } /// /// Initiates the asynchronous execution of the PrepareQuery operation. /// /// /// Container for the necessary parameters to execute the PrepareQuery operation on AmazonTimestreamQueryClient. /// An AsyncCallback delegate that is invoked when the operation completes. /// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback /// procedure using the AsyncState property. /// /// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndPrepareQuery /// operation. /// REST API Reference for PrepareQuery Operation public virtual IAsyncResult BeginPrepareQuery(PrepareQueryRequest request, AsyncCallback callback, object state) { var options = new InvokeOptions(); options.RequestMarshaller = PrepareQueryRequestMarshaller.Instance; options.ResponseUnmarshaller = PrepareQueryResponseUnmarshaller.Instance; options.EndpointDiscoveryMarshaller = PrepareQueryEndpointDiscoveryMarshaller.Instance; options.EndpointOperation = EndpointOperation; return BeginInvoke(request, options, callback, state); } /// /// Finishes the asynchronous execution of the PrepareQuery operation. /// /// /// The IAsyncResult returned by the call to BeginPrepareQuery. /// /// Returns a PrepareQueryResult from TimestreamQuery. /// REST API Reference for PrepareQuery Operation public virtual PrepareQueryResponse EndPrepareQuery(IAsyncResult asyncResult) { return EndInvoke(asyncResult); } #endregion #region Query /// /// Query is a synchronous operation that enables you to run a query against /// your Amazon Timestream data. Query will time out after 60 seconds. You /// must update the default timeout in the SDK to support a timeout of 60 seconds. See /// the code /// sample for details. /// /// /// /// Your query request will fail in the following cases: /// ///
  • /// /// If you submit a Query request with the same client token outside of /// the 5-minute idempotency window. /// ///
  • /// /// If you submit a Query request with the same client token, but change /// other parameters, within the 5-minute idempotency window. /// ///
  • /// /// If the size of the row (including the query metadata) exceeds 1 MB, then the query /// will fail with the following error message: /// /// /// /// Query aborted as max page response size has been exceeded by the output result /// row /// ///
  • /// /// If the IAM principal of the query initiator and the result reader are not the same /// and/or the query initiator and the result reader do not have the same query string /// in the query requests, the query will fail with an Invalid pagination token /// error. /// ///
///
/// Container for the necessary parameters to execute the Query service method. /// /// The response from the Query service method, as returned by TimestreamQuery. /// /// You are not authorized to perform this action. /// /// /// Unable to poll results for a cancelled query. /// /// /// Timestream was unable to fully process this request because of an internal server /// error. /// /// /// The requested endpoint was not valid. /// /// /// Timestream was unable to run the query successfully. /// /// /// The request was denied due to request throttling. /// /// /// Invalid or malformed request. /// /// REST API Reference for Query Operation public virtual QueryResponse Query(QueryRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = QueryRequestMarshaller.Instance; options.ResponseUnmarshaller = QueryResponseUnmarshaller.Instance; options.EndpointDiscoveryMarshaller = QueryEndpointDiscoveryMarshaller.Instance; options.EndpointOperation = EndpointOperation; return Invoke(request, options); } /// /// Initiates the asynchronous execution of the Query operation. /// /// /// Container for the necessary parameters to execute the Query operation on AmazonTimestreamQueryClient. /// An AsyncCallback delegate that is invoked when the operation completes. /// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback /// procedure using the AsyncState property. /// /// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndQuery /// operation. /// REST API Reference for Query Operation public virtual IAsyncResult BeginQuery(QueryRequest request, AsyncCallback callback, object state) { var options = new InvokeOptions(); options.RequestMarshaller = QueryRequestMarshaller.Instance; options.ResponseUnmarshaller = QueryResponseUnmarshaller.Instance; options.EndpointDiscoveryMarshaller = QueryEndpointDiscoveryMarshaller.Instance; options.EndpointOperation = EndpointOperation; return BeginInvoke(request, options, callback, state); } /// /// Finishes the asynchronous execution of the Query operation. /// /// /// The IAsyncResult returned by the call to BeginQuery. /// /// Returns a QueryResult from TimestreamQuery. /// REST API Reference for Query Operation public virtual QueryResponse EndQuery(IAsyncResult asyncResult) { return EndInvoke(asyncResult); } #endregion #region TagResource /// /// Associate a set of tags with a Timestream resource. You can then activate these user-defined /// tags so that they appear on the Billing and Cost Management console for cost allocation /// tracking. /// /// Container for the necessary parameters to execute the TagResource service method. /// /// The response from the TagResource service method, as returned by TimestreamQuery. /// /// The requested endpoint was not valid. /// /// /// The requested resource could not be found. /// /// /// You have exceeded the service quota. /// /// /// The request was denied due to request throttling. /// /// /// Invalid or malformed request. /// /// REST API Reference for TagResource Operation public virtual TagResourceResponse TagResource(TagResourceRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = TagResourceRequestMarshaller.Instance; options.ResponseUnmarshaller = TagResourceResponseUnmarshaller.Instance; options.EndpointDiscoveryMarshaller = TagResourceEndpointDiscoveryMarshaller.Instance; options.EndpointOperation = EndpointOperation; return Invoke(request, options); } /// /// Initiates the asynchronous execution of the TagResource operation. /// /// /// Container for the necessary parameters to execute the TagResource operation on AmazonTimestreamQueryClient. /// An AsyncCallback delegate that is invoked when the operation completes. /// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback /// procedure using the AsyncState property. /// /// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndTagResource /// operation. /// REST API Reference for TagResource Operation public virtual IAsyncResult BeginTagResource(TagResourceRequest request, AsyncCallback callback, object state) { var options = new InvokeOptions(); options.RequestMarshaller = TagResourceRequestMarshaller.Instance; options.ResponseUnmarshaller = TagResourceResponseUnmarshaller.Instance; options.EndpointDiscoveryMarshaller = TagResourceEndpointDiscoveryMarshaller.Instance; options.EndpointOperation = EndpointOperation; return BeginInvoke(request, options, callback, state); } /// /// Finishes the asynchronous execution of the TagResource operation. /// /// /// The IAsyncResult returned by the call to BeginTagResource. /// /// Returns a TagResourceResult from TimestreamQuery. /// REST API Reference for TagResource Operation public virtual TagResourceResponse EndTagResource(IAsyncResult asyncResult) { return EndInvoke(asyncResult); } #endregion #region UntagResource /// /// Removes the association of tags from a Timestream query resource. /// /// Container for the necessary parameters to execute the UntagResource service method. /// /// The response from the UntagResource service method, as returned by TimestreamQuery. /// /// The requested endpoint was not valid. /// /// /// The requested resource could not be found. /// /// /// The request was denied due to request throttling. /// /// /// Invalid or malformed request. /// /// REST API Reference for UntagResource Operation public virtual UntagResourceResponse UntagResource(UntagResourceRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = UntagResourceRequestMarshaller.Instance; options.ResponseUnmarshaller = UntagResourceResponseUnmarshaller.Instance; options.EndpointDiscoveryMarshaller = UntagResourceEndpointDiscoveryMarshaller.Instance; options.EndpointOperation = EndpointOperation; return Invoke(request, options); } /// /// Initiates the asynchronous execution of the UntagResource operation. /// /// /// Container for the necessary parameters to execute the UntagResource operation on AmazonTimestreamQueryClient. /// An AsyncCallback delegate that is invoked when the operation completes. /// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback /// procedure using the AsyncState property. /// /// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndUntagResource /// operation. /// REST API Reference for UntagResource Operation public virtual IAsyncResult BeginUntagResource(UntagResourceRequest request, AsyncCallback callback, object state) { var options = new InvokeOptions(); options.RequestMarshaller = UntagResourceRequestMarshaller.Instance; options.ResponseUnmarshaller = UntagResourceResponseUnmarshaller.Instance; options.EndpointDiscoveryMarshaller = UntagResourceEndpointDiscoveryMarshaller.Instance; options.EndpointOperation = EndpointOperation; return BeginInvoke(request, options, callback, state); } /// /// Finishes the asynchronous execution of the UntagResource operation. /// /// /// The IAsyncResult returned by the call to BeginUntagResource. /// /// Returns a UntagResourceResult from TimestreamQuery. /// REST API Reference for UntagResource Operation public virtual UntagResourceResponse EndUntagResource(IAsyncResult asyncResult) { return EndInvoke(asyncResult); } #endregion #region UpdateScheduledQuery /// /// Update a scheduled query. /// /// Container for the necessary parameters to execute the UpdateScheduledQuery service method. /// /// The response from the UpdateScheduledQuery service method, as returned by TimestreamQuery. /// /// You are not authorized to perform this action. /// /// /// Timestream was unable to fully process this request because of an internal server /// error. /// /// /// The requested endpoint was not valid. /// /// /// The requested resource could not be found. /// /// /// The request was denied due to request throttling. /// /// /// Invalid or malformed request. /// /// REST API Reference for UpdateScheduledQuery Operation public virtual UpdateScheduledQueryResponse UpdateScheduledQuery(UpdateScheduledQueryRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = UpdateScheduledQueryRequestMarshaller.Instance; options.ResponseUnmarshaller = UpdateScheduledQueryResponseUnmarshaller.Instance; options.EndpointDiscoveryMarshaller = UpdateScheduledQueryEndpointDiscoveryMarshaller.Instance; options.EndpointOperation = EndpointOperation; return Invoke(request, options); } /// /// Initiates the asynchronous execution of the UpdateScheduledQuery operation. /// /// /// Container for the necessary parameters to execute the UpdateScheduledQuery operation on AmazonTimestreamQueryClient. /// An AsyncCallback delegate that is invoked when the operation completes. /// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback /// procedure using the AsyncState property. /// /// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndUpdateScheduledQuery /// operation. /// REST API Reference for UpdateScheduledQuery Operation public virtual IAsyncResult BeginUpdateScheduledQuery(UpdateScheduledQueryRequest request, AsyncCallback callback, object state) { var options = new InvokeOptions(); options.RequestMarshaller = UpdateScheduledQueryRequestMarshaller.Instance; options.ResponseUnmarshaller = UpdateScheduledQueryResponseUnmarshaller.Instance; options.EndpointDiscoveryMarshaller = UpdateScheduledQueryEndpointDiscoveryMarshaller.Instance; options.EndpointOperation = EndpointOperation; return BeginInvoke(request, options, callback, state); } /// /// Finishes the asynchronous execution of the UpdateScheduledQuery operation. /// /// /// The IAsyncResult returned by the call to BeginUpdateScheduledQuery. /// /// Returns a UpdateScheduledQueryResult from TimestreamQuery. /// REST API Reference for UpdateScheduledQuery Operation public virtual UpdateScheduledQueryResponse EndUpdateScheduledQuery(IAsyncResult asyncResult) { return EndInvoke(asyncResult); } #endregion } }