/*
* 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 mwaa-2020-07-01.normal.json service model.
*/
using System;
using System.Collections.Generic;
using System.Net;
using Amazon.MWAA.Model;
using Amazon.MWAA.Model.Internal.MarshallTransformations;
using Amazon.MWAA.Internal;
using Amazon.Runtime;
using Amazon.Runtime.Internal;
using Amazon.Runtime.Internal.Auth;
using Amazon.Runtime.Internal.Transform;
namespace Amazon.MWAA
{
///
/// Implementation for accessing MWAA
///
/// Amazon Managed Workflows for Apache Airflow
///
/// This section contains the Amazon Managed Workflows for Apache Airflow (MWAA) API reference
/// documentation. For more information, see What
/// is Amazon MWAA?.
///
///
///
/// Endpoints
///
/// -
///
///
api.airflow.{region}.amazonaws.com
- This endpoint is used for environment
/// management.
///
/// -
///
///
env.airflow.{region}.amazonaws.com
- This endpoint is used to operate
/// the Airflow environment.
///
/// -
///
///
ops.airflow.{region}.amazonaws.com
- This endpoint is used to push environment
/// metrics that track environment health.
///
///
///
/// Regions
///
///
///
/// For a list of regions that Amazon MWAA supports, see Region
/// availability in the Amazon MWAA User Guide.
///
///
///
///
public partial class AmazonMWAAClient : AmazonServiceClient, IAmazonMWAA
{
private static IServiceMetadata serviceMetadata = new AmazonMWAAMetadata();
#if BCL45 || AWS_ASYNC_ENUMERABLES_API
private IMWAAPaginatorFactory _paginators;
///
/// Paginators for the service
///
public IMWAAPaginatorFactory Paginators
{
get
{
if (this._paginators == null)
{
this._paginators = new MWAAPaginatorFactory(this);
}
return this._paginators;
}
}
#endif
#region Constructors
///
/// Constructs AmazonMWAAClient 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 AmazonMWAAClient()
: base(FallbackCredentialsFactory.GetCredentials(), new AmazonMWAAConfig()) { }
///
/// Constructs AmazonMWAAClient 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 AmazonMWAAClient(RegionEndpoint region)
: base(FallbackCredentialsFactory.GetCredentials(), new AmazonMWAAConfig{RegionEndpoint = region}) { }
///
/// Constructs AmazonMWAAClient 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 AmazonMWAAClient Configuration Object
public AmazonMWAAClient(AmazonMWAAConfig config)
: base(FallbackCredentialsFactory.GetCredentials(config), config){}
///
/// Constructs AmazonMWAAClient with AWS Credentials
///
/// AWS Credentials
public AmazonMWAAClient(AWSCredentials credentials)
: this(credentials, new AmazonMWAAConfig())
{
}
///
/// Constructs AmazonMWAAClient with AWS Credentials
///
/// AWS Credentials
/// The region to connect.
public AmazonMWAAClient(AWSCredentials credentials, RegionEndpoint region)
: this(credentials, new AmazonMWAAConfig{RegionEndpoint = region})
{
}
///
/// Constructs AmazonMWAAClient with AWS Credentials and an
/// AmazonMWAAClient Configuration object.
///
/// AWS Credentials
/// The AmazonMWAAClient Configuration Object
public AmazonMWAAClient(AWSCredentials credentials, AmazonMWAAConfig clientConfig)
: base(credentials, clientConfig)
{
}
///
/// Constructs AmazonMWAAClient with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
public AmazonMWAAClient(string awsAccessKeyId, string awsSecretAccessKey)
: this(awsAccessKeyId, awsSecretAccessKey, new AmazonMWAAConfig())
{
}
///
/// Constructs AmazonMWAAClient with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// The region to connect.
public AmazonMWAAClient(string awsAccessKeyId, string awsSecretAccessKey, RegionEndpoint region)
: this(awsAccessKeyId, awsSecretAccessKey, new AmazonMWAAConfig() {RegionEndpoint=region})
{
}
///
/// Constructs AmazonMWAAClient with AWS Access Key ID, AWS Secret Key and an
/// AmazonMWAAClient Configuration object.
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// The AmazonMWAAClient Configuration Object
public AmazonMWAAClient(string awsAccessKeyId, string awsSecretAccessKey, AmazonMWAAConfig clientConfig)
: base(awsAccessKeyId, awsSecretAccessKey, clientConfig)
{
}
///
/// Constructs AmazonMWAAClient with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// AWS Session Token
public AmazonMWAAClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken)
: this(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, new AmazonMWAAConfig())
{
}
///
/// Constructs AmazonMWAAClient 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 AmazonMWAAClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken, RegionEndpoint region)
: this(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, new AmazonMWAAConfig{RegionEndpoint = region})
{
}
///
/// Constructs AmazonMWAAClient with AWS Access Key ID, AWS Secret Key and an
/// AmazonMWAAClient Configuration object.
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// AWS Session Token
/// The AmazonMWAAClient Configuration Object
public AmazonMWAAClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken, AmazonMWAAConfig 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 AmazonMWAAEndpointResolver());
}
///
/// 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 CreateCliToken
///
/// Creates a CLI token for the Airflow CLI. To learn more, see Creating
/// an Apache Airflow CLI token.
///
/// Container for the necessary parameters to execute the CreateCliToken service method.
///
/// The response from the CreateCliToken service method, as returned by MWAA.
///
/// ResourceNotFoundException: The resource is not available.
///
/// REST API Reference for CreateCliToken Operation
public virtual CreateCliTokenResponse CreateCliToken(CreateCliTokenRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateCliTokenRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateCliTokenResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the CreateCliToken operation.
///
///
/// Container for the necessary parameters to execute the CreateCliToken operation on AmazonMWAAClient.
/// 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 EndCreateCliToken
/// operation.
/// REST API Reference for CreateCliToken Operation
public virtual IAsyncResult BeginCreateCliToken(CreateCliTokenRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateCliTokenRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateCliTokenResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the CreateCliToken operation.
///
///
/// The IAsyncResult returned by the call to BeginCreateCliToken.
///
/// Returns a CreateCliTokenResult from MWAA.
/// REST API Reference for CreateCliToken Operation
public virtual CreateCliTokenResponse EndCreateCliToken(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region CreateEnvironment
///
/// Creates an Amazon Managed Workflows for Apache Airflow (MWAA) environment.
///
/// Container for the necessary parameters to execute the CreateEnvironment service method.
///
/// The response from the CreateEnvironment service method, as returned by MWAA.
///
/// InternalServerException: An internal error has occurred.
///
///
/// ValidationException: The provided input is not valid.
///
/// REST API Reference for CreateEnvironment Operation
public virtual CreateEnvironmentResponse CreateEnvironment(CreateEnvironmentRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateEnvironmentRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateEnvironmentResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the CreateEnvironment operation.
///
///
/// Container for the necessary parameters to execute the CreateEnvironment operation on AmazonMWAAClient.
/// 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 EndCreateEnvironment
/// operation.
/// REST API Reference for CreateEnvironment Operation
public virtual IAsyncResult BeginCreateEnvironment(CreateEnvironmentRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateEnvironmentRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateEnvironmentResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the CreateEnvironment operation.
///
///
/// The IAsyncResult returned by the call to BeginCreateEnvironment.
///
/// Returns a CreateEnvironmentResult from MWAA.
/// REST API Reference for CreateEnvironment Operation
public virtual CreateEnvironmentResponse EndCreateEnvironment(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region CreateWebLoginToken
///
/// Creates a web login token for the Airflow Web UI. To learn more, see Creating
/// an Apache Airflow web login token.
///
/// Container for the necessary parameters to execute the CreateWebLoginToken service method.
///
/// The response from the CreateWebLoginToken service method, as returned by MWAA.
///
/// Access to the Apache Airflow Web UI or CLI has been denied due to insufficient permissions.
/// To learn more, see Accessing
/// an Amazon MWAA environment.
///
///
/// InternalServerException: An internal error has occurred.
///
///
/// ResourceNotFoundException: The resource is not available.
///
///
/// ValidationException: The provided input is not valid.
///
/// REST API Reference for CreateWebLoginToken Operation
public virtual CreateWebLoginTokenResponse CreateWebLoginToken(CreateWebLoginTokenRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateWebLoginTokenRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateWebLoginTokenResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the CreateWebLoginToken operation.
///
///
/// Container for the necessary parameters to execute the CreateWebLoginToken operation on AmazonMWAAClient.
/// 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 EndCreateWebLoginToken
/// operation.
/// REST API Reference for CreateWebLoginToken Operation
public virtual IAsyncResult BeginCreateWebLoginToken(CreateWebLoginTokenRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateWebLoginTokenRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateWebLoginTokenResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the CreateWebLoginToken operation.
///
///
/// The IAsyncResult returned by the call to BeginCreateWebLoginToken.
///
/// Returns a CreateWebLoginTokenResult from MWAA.
/// REST API Reference for CreateWebLoginToken Operation
public virtual CreateWebLoginTokenResponse EndCreateWebLoginToken(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region DeleteEnvironment
///
/// Deletes an Amazon Managed Workflows for Apache Airflow (MWAA) environment.
///
/// Container for the necessary parameters to execute the DeleteEnvironment service method.
///
/// The response from the DeleteEnvironment service method, as returned by MWAA.
///
/// InternalServerException: An internal error has occurred.
///
///
/// ResourceNotFoundException: The resource is not available.
///
///
/// ValidationException: The provided input is not valid.
///
/// REST API Reference for DeleteEnvironment Operation
public virtual DeleteEnvironmentResponse DeleteEnvironment(DeleteEnvironmentRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteEnvironmentRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteEnvironmentResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the DeleteEnvironment operation.
///
///
/// Container for the necessary parameters to execute the DeleteEnvironment operation on AmazonMWAAClient.
/// 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 EndDeleteEnvironment
/// operation.
/// REST API Reference for DeleteEnvironment Operation
public virtual IAsyncResult BeginDeleteEnvironment(DeleteEnvironmentRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteEnvironmentRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteEnvironmentResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the DeleteEnvironment operation.
///
///
/// The IAsyncResult returned by the call to BeginDeleteEnvironment.
///
/// Returns a DeleteEnvironmentResult from MWAA.
/// REST API Reference for DeleteEnvironment Operation
public virtual DeleteEnvironmentResponse EndDeleteEnvironment(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region GetEnvironment
///
/// Describes an Amazon Managed Workflows for Apache Airflow (MWAA) environment.
///
/// Container for the necessary parameters to execute the GetEnvironment service method.
///
/// The response from the GetEnvironment service method, as returned by MWAA.
///
/// InternalServerException: An internal error has occurred.
///
///
/// ResourceNotFoundException: The resource is not available.
///
///
/// ValidationException: The provided input is not valid.
///
/// REST API Reference for GetEnvironment Operation
public virtual GetEnvironmentResponse GetEnvironment(GetEnvironmentRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = GetEnvironmentRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetEnvironmentResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the GetEnvironment operation.
///
///
/// Container for the necessary parameters to execute the GetEnvironment operation on AmazonMWAAClient.
/// 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 EndGetEnvironment
/// operation.
/// REST API Reference for GetEnvironment Operation
public virtual IAsyncResult BeginGetEnvironment(GetEnvironmentRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = GetEnvironmentRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetEnvironmentResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the GetEnvironment operation.
///
///
/// The IAsyncResult returned by the call to BeginGetEnvironment.
///
/// Returns a GetEnvironmentResult from MWAA.
/// REST API Reference for GetEnvironment Operation
public virtual GetEnvironmentResponse EndGetEnvironment(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region ListEnvironments
///
/// Lists the Amazon Managed Workflows for Apache Airflow (MWAA) environments.
///
/// Container for the necessary parameters to execute the ListEnvironments service method.
///
/// The response from the ListEnvironments service method, as returned by MWAA.
///
/// InternalServerException: An internal error has occurred.
///
///
/// ValidationException: The provided input is not valid.
///
/// REST API Reference for ListEnvironments Operation
public virtual ListEnvironmentsResponse ListEnvironments(ListEnvironmentsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListEnvironmentsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListEnvironmentsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the ListEnvironments operation.
///
///
/// Container for the necessary parameters to execute the ListEnvironments operation on AmazonMWAAClient.
/// 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 EndListEnvironments
/// operation.
/// REST API Reference for ListEnvironments Operation
public virtual IAsyncResult BeginListEnvironments(ListEnvironmentsRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListEnvironmentsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListEnvironmentsResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the ListEnvironments operation.
///
///
/// The IAsyncResult returned by the call to BeginListEnvironments.
///
/// Returns a ListEnvironmentsResult from MWAA.
/// REST API Reference for ListEnvironments Operation
public virtual ListEnvironmentsResponse EndListEnvironments(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region ListTagsForResource
///
/// Lists the key-value tag pairs associated to the Amazon Managed Workflows for Apache
/// Airflow (MWAA) environment. For example, "Environment": "Staging"
.
///
/// Container for the necessary parameters to execute the ListTagsForResource service method.
///
/// The response from the ListTagsForResource service method, as returned by MWAA.
///
/// InternalServerException: An internal error has occurred.
///
///
/// ResourceNotFoundException: The resource is not available.
///
///
/// ValidationException: The provided input is not valid.
///
/// REST API Reference for ListTagsForResource Operation
public virtual ListTagsForResourceResponse ListTagsForResource(ListTagsForResourceRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListTagsForResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListTagsForResourceResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the ListTagsForResource operation.
///
///
/// Container for the necessary parameters to execute the ListTagsForResource operation on AmazonMWAAClient.
/// 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;
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 MWAA.
/// REST API Reference for ListTagsForResource Operation
public virtual ListTagsForResourceResponse EndListTagsForResource(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region PublishMetrics
///
/// Internal only. Publishes environment health metrics to Amazon CloudWatch.
///
/// Container for the necessary parameters to execute the PublishMetrics service method.
///
/// The response from the PublishMetrics service method, as returned by MWAA.
///
/// InternalServerException: An internal error has occurred.
///
///
/// ValidationException: The provided input is not valid.
///
/// REST API Reference for PublishMetrics Operation
public virtual PublishMetricsResponse PublishMetrics(PublishMetricsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = PublishMetricsRequestMarshaller.Instance;
options.ResponseUnmarshaller = PublishMetricsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the PublishMetrics operation.
///
///
/// Container for the necessary parameters to execute the PublishMetrics operation on AmazonMWAAClient.
/// 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 EndPublishMetrics
/// operation.
/// REST API Reference for PublishMetrics Operation
public virtual IAsyncResult BeginPublishMetrics(PublishMetricsRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = PublishMetricsRequestMarshaller.Instance;
options.ResponseUnmarshaller = PublishMetricsResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the PublishMetrics operation.
///
///
/// The IAsyncResult returned by the call to BeginPublishMetrics.
///
/// Returns a PublishMetricsResult from MWAA.
/// REST API Reference for PublishMetrics Operation
public virtual PublishMetricsResponse EndPublishMetrics(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region TagResource
///
/// Associates key-value tag pairs to your Amazon Managed Workflows for Apache Airflow
/// (MWAA) environment.
///
/// Container for the necessary parameters to execute the TagResource service method.
///
/// The response from the TagResource service method, as returned by MWAA.
///
/// InternalServerException: An internal error has occurred.
///
///
/// ResourceNotFoundException: The resource is not available.
///
///
/// ValidationException: The provided input is not valid.
///
/// REST API Reference for TagResource Operation
public virtual TagResourceResponse TagResource(TagResourceRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = TagResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = TagResourceResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the TagResource operation.
///
///
/// Container for the necessary parameters to execute the TagResource operation on AmazonMWAAClient.
/// 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;
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 MWAA.
/// REST API Reference for TagResource Operation
public virtual TagResourceResponse EndTagResource(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region UntagResource
///
/// Removes key-value tag pairs associated to your Amazon Managed Workflows for Apache
/// Airflow (MWAA) environment. For example, "Environment": "Staging"
.
///
/// Container for the necessary parameters to execute the UntagResource service method.
///
/// The response from the UntagResource service method, as returned by MWAA.
///
/// InternalServerException: An internal error has occurred.
///
///
/// ResourceNotFoundException: The resource is not available.
///
///
/// ValidationException: The provided input is not valid.
///
/// REST API Reference for UntagResource Operation
public virtual UntagResourceResponse UntagResource(UntagResourceRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UntagResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = UntagResourceResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the UntagResource operation.
///
///
/// Container for the necessary parameters to execute the UntagResource operation on AmazonMWAAClient.
/// 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;
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 MWAA.
/// REST API Reference for UntagResource Operation
public virtual UntagResourceResponse EndUntagResource(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region UpdateEnvironment
///
/// Updates an Amazon Managed Workflows for Apache Airflow (MWAA) environment.
///
/// Container for the necessary parameters to execute the UpdateEnvironment service method.
///
/// The response from the UpdateEnvironment service method, as returned by MWAA.
///
/// InternalServerException: An internal error has occurred.
///
///
/// ResourceNotFoundException: The resource is not available.
///
///
/// ValidationException: The provided input is not valid.
///
/// REST API Reference for UpdateEnvironment Operation
public virtual UpdateEnvironmentResponse UpdateEnvironment(UpdateEnvironmentRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateEnvironmentRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateEnvironmentResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the UpdateEnvironment operation.
///
///
/// Container for the necessary parameters to execute the UpdateEnvironment operation on AmazonMWAAClient.
/// 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 EndUpdateEnvironment
/// operation.
/// REST API Reference for UpdateEnvironment Operation
public virtual IAsyncResult BeginUpdateEnvironment(UpdateEnvironmentRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateEnvironmentRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateEnvironmentResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the UpdateEnvironment operation.
///
///
/// The IAsyncResult returned by the call to BeginUpdateEnvironment.
///
/// Returns a UpdateEnvironmentResult from MWAA.
/// REST API Reference for UpdateEnvironment Operation
public virtual UpdateEnvironmentResponse EndUpdateEnvironment(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
}
}