/*
* 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 pipes-2015-10-07.normal.json service model.
*/
using System;
using System.Runtime.ExceptionServices;
using System.Threading;
using System.Threading.Tasks;
using System.Collections.Generic;
using System.Net;
using Amazon.Pipes.Model;
using Amazon.Pipes.Model.Internal.MarshallTransformations;
using Amazon.Pipes.Internal;
using Amazon.Runtime;
using Amazon.Runtime.Internal;
using Amazon.Runtime.Internal.Auth;
using Amazon.Runtime.Internal.Transform;
namespace Amazon.Pipes
{
///
/// Implementation for accessing Pipes
///
/// Amazon EventBridge Pipes connects event sources to targets. Pipes reduces the need
/// for specialized knowledge and integration code when developing event driven architectures.
/// This helps ensures consistency across your company’s applications. With Pipes, the
/// target can be any available EventBridge target. To set up a pipe, you select the event
/// source, add optional event filtering, define optional enrichment, and select the target
/// for the event data.
///
public partial class AmazonPipesClient : AmazonServiceClient, IAmazonPipes
{
private static IServiceMetadata serviceMetadata = new AmazonPipesMetadata();
private IPipesPaginatorFactory _paginators;
///
/// Paginators for the service
///
public IPipesPaginatorFactory Paginators
{
get
{
if (this._paginators == null)
{
this._paginators = new PipesPaginatorFactory(this);
}
return this._paginators;
}
}
#region Constructors
///
/// Constructs AmazonPipesClient 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 AmazonPipesClient()
: base(FallbackCredentialsFactory.GetCredentials(), new AmazonPipesConfig()) { }
///
/// Constructs AmazonPipesClient 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 AmazonPipesClient(RegionEndpoint region)
: base(FallbackCredentialsFactory.GetCredentials(), new AmazonPipesConfig{RegionEndpoint = region}) { }
///
/// Constructs AmazonPipesClient 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 AmazonPipesClient Configuration Object
public AmazonPipesClient(AmazonPipesConfig config)
: base(FallbackCredentialsFactory.GetCredentials(config), config){}
///
/// Constructs AmazonPipesClient with AWS Credentials
///
/// AWS Credentials
public AmazonPipesClient(AWSCredentials credentials)
: this(credentials, new AmazonPipesConfig())
{
}
///
/// Constructs AmazonPipesClient with AWS Credentials
///
/// AWS Credentials
/// The region to connect.
public AmazonPipesClient(AWSCredentials credentials, RegionEndpoint region)
: this(credentials, new AmazonPipesConfig{RegionEndpoint = region})
{
}
///
/// Constructs AmazonPipesClient with AWS Credentials and an
/// AmazonPipesClient Configuration object.
///
/// AWS Credentials
/// The AmazonPipesClient Configuration Object
public AmazonPipesClient(AWSCredentials credentials, AmazonPipesConfig clientConfig)
: base(credentials, clientConfig)
{
}
///
/// Constructs AmazonPipesClient with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
public AmazonPipesClient(string awsAccessKeyId, string awsSecretAccessKey)
: this(awsAccessKeyId, awsSecretAccessKey, new AmazonPipesConfig())
{
}
///
/// Constructs AmazonPipesClient with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// The region to connect.
public AmazonPipesClient(string awsAccessKeyId, string awsSecretAccessKey, RegionEndpoint region)
: this(awsAccessKeyId, awsSecretAccessKey, new AmazonPipesConfig() {RegionEndpoint=region})
{
}
///
/// Constructs AmazonPipesClient with AWS Access Key ID, AWS Secret Key and an
/// AmazonPipesClient Configuration object.
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// The AmazonPipesClient Configuration Object
public AmazonPipesClient(string awsAccessKeyId, string awsSecretAccessKey, AmazonPipesConfig clientConfig)
: base(awsAccessKeyId, awsSecretAccessKey, clientConfig)
{
}
///
/// Constructs AmazonPipesClient with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// AWS Session Token
public AmazonPipesClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken)
: this(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, new AmazonPipesConfig())
{
}
///
/// Constructs AmazonPipesClient 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 AmazonPipesClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken, RegionEndpoint region)
: this(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, new AmazonPipesConfig{RegionEndpoint = region})
{
}
///
/// Constructs AmazonPipesClient with AWS Access Key ID, AWS Secret Key and an
/// AmazonPipesClient Configuration object.
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// AWS Session Token
/// The AmazonPipesClient Configuration Object
public AmazonPipesClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken, AmazonPipesConfig 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 AmazonPipesEndpointResolver());
}
///
/// 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 CreatePipe
///
/// Create a pipe. Amazon EventBridge Pipes connect event sources to targets and reduces
/// the need for specialized knowledge and integration code.
///
/// Container for the necessary parameters to execute the CreatePipe service method.
///
/// The response from the CreatePipe service method, as returned by Pipes.
///
/// An action you attempted resulted in an exception.
///
///
/// This exception occurs due to unexpected causes.
///
///
/// An entity that you specified does not exist.
///
///
/// A quota has been exceeded.
///
///
/// An action was throttled.
///
///
/// Indicates that an error has occurred while performing a validate operation.
///
/// REST API Reference for CreatePipe Operation
public virtual CreatePipeResponse CreatePipe(CreatePipeRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreatePipeRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreatePipeResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Create a pipe. Amazon EventBridge Pipes connect event sources to targets and reduces
/// the need for specialized knowledge and integration code.
///
/// Container for the necessary parameters to execute the CreatePipe service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CreatePipe service method, as returned by Pipes.
///
/// An action you attempted resulted in an exception.
///
///
/// This exception occurs due to unexpected causes.
///
///
/// An entity that you specified does not exist.
///
///
/// A quota has been exceeded.
///
///
/// An action was throttled.
///
///
/// Indicates that an error has occurred while performing a validate operation.
///
/// REST API Reference for CreatePipe Operation
public virtual Task CreatePipeAsync(CreatePipeRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = CreatePipeRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreatePipeResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DeletePipe
///
/// Delete an existing pipe. For more information about pipes, see Amazon
/// EventBridge Pipes in the Amazon EventBridge User Guide.
///
/// Container for the necessary parameters to execute the DeletePipe service method.
///
/// The response from the DeletePipe service method, as returned by Pipes.
///
/// An action you attempted resulted in an exception.
///
///
/// This exception occurs due to unexpected causes.
///
///
/// An entity that you specified does not exist.
///
///
/// An action was throttled.
///
///
/// Indicates that an error has occurred while performing a validate operation.
///
/// REST API Reference for DeletePipe Operation
public virtual DeletePipeResponse DeletePipe(DeletePipeRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeletePipeRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeletePipeResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Delete an existing pipe. For more information about pipes, see Amazon
/// EventBridge Pipes in the Amazon EventBridge User Guide.
///
/// Container for the necessary parameters to execute the DeletePipe service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeletePipe service method, as returned by Pipes.
///
/// An action you attempted resulted in an exception.
///
///
/// This exception occurs due to unexpected causes.
///
///
/// An entity that you specified does not exist.
///
///
/// An action was throttled.
///
///
/// Indicates that an error has occurred while performing a validate operation.
///
/// REST API Reference for DeletePipe Operation
public virtual Task DeletePipeAsync(DeletePipeRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeletePipeRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeletePipeResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DescribePipe
///
/// Get the information about an existing pipe. For more information about pipes, see
/// Amazon
/// EventBridge Pipes in the Amazon EventBridge User Guide.
///
/// Container for the necessary parameters to execute the DescribePipe service method.
///
/// The response from the DescribePipe service method, as returned by Pipes.
///
/// This exception occurs due to unexpected causes.
///
///
/// An entity that you specified does not exist.
///
///
/// An action was throttled.
///
///
/// Indicates that an error has occurred while performing a validate operation.
///
/// REST API Reference for DescribePipe Operation
public virtual DescribePipeResponse DescribePipe(DescribePipeRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribePipeRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribePipeResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Get the information about an existing pipe. For more information about pipes, see
/// Amazon
/// EventBridge Pipes in the Amazon EventBridge User Guide.
///
/// Container for the necessary parameters to execute the DescribePipe service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribePipe service method, as returned by Pipes.
///
/// This exception occurs due to unexpected causes.
///
///
/// An entity that you specified does not exist.
///
///
/// An action was throttled.
///
///
/// Indicates that an error has occurred while performing a validate operation.
///
/// REST API Reference for DescribePipe Operation
public virtual Task DescribePipeAsync(DescribePipeRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribePipeRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribePipeResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListPipes
///
/// Get the pipes associated with this account. For more information about pipes, see
/// Amazon
/// EventBridge Pipes in the Amazon EventBridge User Guide.
///
/// Container for the necessary parameters to execute the ListPipes service method.
///
/// The response from the ListPipes service method, as returned by Pipes.
///
/// This exception occurs due to unexpected causes.
///
///
/// An action was throttled.
///
///
/// Indicates that an error has occurred while performing a validate operation.
///
/// REST API Reference for ListPipes Operation
public virtual ListPipesResponse ListPipes(ListPipesRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListPipesRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListPipesResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Get the pipes associated with this account. For more information about pipes, see
/// Amazon
/// EventBridge Pipes in the Amazon EventBridge User Guide.
///
/// Container for the necessary parameters to execute the ListPipes service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListPipes service method, as returned by Pipes.
///
/// This exception occurs due to unexpected causes.
///
///
/// An action was throttled.
///
///
/// Indicates that an error has occurred while performing a validate operation.
///
/// REST API Reference for ListPipes Operation
public virtual Task ListPipesAsync(ListPipesRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListPipesRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListPipesResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListTagsForResource
///
/// Displays the tags associated with a pipe.
///
/// Container for the necessary parameters to execute the ListTagsForResource service method.
///
/// The response from the ListTagsForResource service method, as returned by Pipes.
///
/// This exception occurs due to unexpected causes.
///
///
/// An entity that you specified does not exist.
///
///
/// Indicates that an error has occurred while performing a validate operation.
///
/// 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);
}
///
/// Displays the tags associated with a pipe.
///
/// Container for the necessary parameters to execute the ListTagsForResource service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListTagsForResource service method, as returned by Pipes.
///
/// This exception occurs due to unexpected causes.
///
///
/// An entity that you specified does not exist.
///
///
/// Indicates that an error has occurred while performing a validate operation.
///
/// REST API Reference for ListTagsForResource Operation
public virtual Task ListTagsForResourceAsync(ListTagsForResourceRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListTagsForResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListTagsForResourceResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region StartPipe
///
/// Start an existing pipe.
///
/// Container for the necessary parameters to execute the StartPipe service method.
///
/// The response from the StartPipe service method, as returned by Pipes.
///
/// An action you attempted resulted in an exception.
///
///
/// This exception occurs due to unexpected causes.
///
///
/// An entity that you specified does not exist.
///
///
/// An action was throttled.
///
///
/// Indicates that an error has occurred while performing a validate operation.
///
/// REST API Reference for StartPipe Operation
public virtual StartPipeResponse StartPipe(StartPipeRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = StartPipeRequestMarshaller.Instance;
options.ResponseUnmarshaller = StartPipeResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Start an existing pipe.
///
/// Container for the necessary parameters to execute the StartPipe service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the StartPipe service method, as returned by Pipes.
///
/// An action you attempted resulted in an exception.
///
///
/// This exception occurs due to unexpected causes.
///
///
/// An entity that you specified does not exist.
///
///
/// An action was throttled.
///
///
/// Indicates that an error has occurred while performing a validate operation.
///
/// REST API Reference for StartPipe Operation
public virtual Task StartPipeAsync(StartPipeRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = StartPipeRequestMarshaller.Instance;
options.ResponseUnmarshaller = StartPipeResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region StopPipe
///
/// Stop an existing pipe.
///
/// Container for the necessary parameters to execute the StopPipe service method.
///
/// The response from the StopPipe service method, as returned by Pipes.
///
/// An action you attempted resulted in an exception.
///
///
/// This exception occurs due to unexpected causes.
///
///
/// An entity that you specified does not exist.
///
///
/// An action was throttled.
///
///
/// Indicates that an error has occurred while performing a validate operation.
///
/// REST API Reference for StopPipe Operation
public virtual StopPipeResponse StopPipe(StopPipeRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = StopPipeRequestMarshaller.Instance;
options.ResponseUnmarshaller = StopPipeResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Stop an existing pipe.
///
/// Container for the necessary parameters to execute the StopPipe service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the StopPipe service method, as returned by Pipes.
///
/// An action you attempted resulted in an exception.
///
///
/// This exception occurs due to unexpected causes.
///
///
/// An entity that you specified does not exist.
///
///
/// An action was throttled.
///
///
/// Indicates that an error has occurred while performing a validate operation.
///
/// REST API Reference for StopPipe Operation
public virtual Task StopPipeAsync(StopPipeRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = StopPipeRequestMarshaller.Instance;
options.ResponseUnmarshaller = StopPipeResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region TagResource
///
/// Assigns one or more tags (key-value pairs) to the specified pipe. Tags can help you
/// organize and categorize your resources. You can also use them to scope user permissions
/// by granting a user permission to access or change only resources with certain tag
/// values.
///
///
///
/// Tags don't have any semantic meaning to Amazon Web Services and are interpreted strictly
/// as strings of characters.
///
///
///
/// You can use the TagResource action with a pipe that already has tags.
/// If you specify a new tag key, this tag is appended to the list of tags associated
/// with the pipe. If you specify a tag key that is already associated with the pipe,
/// the new tag value that you specify replaces the previous value for that tag.
///
///
///
/// You can associate as many as 50 tags with a pipe.
///
///
/// Container for the necessary parameters to execute the TagResource service method.
///
/// The response from the TagResource service method, as returned by Pipes.
///
/// This exception occurs due to unexpected causes.
///
///
/// An entity that you specified does not exist.
///
///
/// Indicates that an error has occurred while performing a validate operation.
///
/// 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);
}
///
/// Assigns one or more tags (key-value pairs) to the specified pipe. Tags can help you
/// organize and categorize your resources. You can also use them to scope user permissions
/// by granting a user permission to access or change only resources with certain tag
/// values.
///
///
///
/// Tags don't have any semantic meaning to Amazon Web Services and are interpreted strictly
/// as strings of characters.
///
///
///
/// You can use the TagResource action with a pipe that already has tags.
/// If you specify a new tag key, this tag is appended to the list of tags associated
/// with the pipe. If you specify a tag key that is already associated with the pipe,
/// the new tag value that you specify replaces the previous value for that tag.
///
///
///
/// You can associate as many as 50 tags with a pipe.
///
///
/// Container for the necessary parameters to execute the TagResource service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the TagResource service method, as returned by Pipes.
///
/// This exception occurs due to unexpected causes.
///
///
/// An entity that you specified does not exist.
///
///
/// Indicates that an error has occurred while performing a validate operation.
///
/// REST API Reference for TagResource Operation
public virtual Task TagResourceAsync(TagResourceRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = TagResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = TagResourceResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region UntagResource
///
/// Removes one or more tags from the specified pipes.
///
/// Container for the necessary parameters to execute the UntagResource service method.
///
/// The response from the UntagResource service method, as returned by Pipes.
///
/// This exception occurs due to unexpected causes.
///
///
/// An entity that you specified does not exist.
///
///
/// Indicates that an error has occurred while performing a validate operation.
///
/// 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);
}
///
/// Removes one or more tags from the specified pipes.
///
/// Container for the necessary parameters to execute the UntagResource service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UntagResource service method, as returned by Pipes.
///
/// This exception occurs due to unexpected causes.
///
///
/// An entity that you specified does not exist.
///
///
/// Indicates that an error has occurred while performing a validate operation.
///
/// REST API Reference for UntagResource Operation
public virtual Task UntagResourceAsync(UntagResourceRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = UntagResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = UntagResourceResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region UpdatePipe
///
/// Update an existing pipe. When you call UpdatePipe, only the fields that
/// are included in the request are changed, the rest are unchanged. The exception to
/// this is if you modify any Amazon Web Services-service specific fields in the SourceParameters,
/// EnrichmentParameters, or TargetParameters objects. The fields
/// in these objects are updated atomically as one and override existing values. This
/// is by design and means that if you don't specify an optional field in one of these
/// Parameters objects, that field will be set to its system-default value after the update.
///
///
///
/// For more information about pipes, see
/// Amazon EventBridge Pipes in the Amazon EventBridge User Guide.
///
///
/// Container for the necessary parameters to execute the UpdatePipe service method.
///
/// The response from the UpdatePipe service method, as returned by Pipes.
///
/// An action you attempted resulted in an exception.
///
///
/// This exception occurs due to unexpected causes.
///
///
/// An entity that you specified does not exist.
///
///
/// An action was throttled.
///
///
/// Indicates that an error has occurred while performing a validate operation.
///
/// REST API Reference for UpdatePipe Operation
public virtual UpdatePipeResponse UpdatePipe(UpdatePipeRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdatePipeRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdatePipeResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Update an existing pipe. When you call UpdatePipe, only the fields that
/// are included in the request are changed, the rest are unchanged. The exception to
/// this is if you modify any Amazon Web Services-service specific fields in the SourceParameters,
/// EnrichmentParameters, or TargetParameters objects. The fields
/// in these objects are updated atomically as one and override existing values. This
/// is by design and means that if you don't specify an optional field in one of these
/// Parameters objects, that field will be set to its system-default value after the update.
///
///
///
/// For more information about pipes, see
/// Amazon EventBridge Pipes in the Amazon EventBridge User Guide.
///
///
/// Container for the necessary parameters to execute the UpdatePipe service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UpdatePipe service method, as returned by Pipes.
///
/// An action you attempted resulted in an exception.
///
///
/// This exception occurs due to unexpected causes.
///
///
/// An entity that you specified does not exist.
///
///
/// An action was throttled.
///
///
/// Indicates that an error has occurred while performing a validate operation.
///
/// REST API Reference for UpdatePipe Operation
public virtual Task UpdatePipeAsync(UpdatePipeRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdatePipeRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdatePipeResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
}
}