/*
* 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 kafka-2018-11-14.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.Kafka.Model;
using Amazon.Kafka.Model.Internal.MarshallTransformations;
using Amazon.Kafka.Internal;
using Amazon.Runtime;
using Amazon.Runtime.Internal;
using Amazon.Runtime.Internal.Auth;
using Amazon.Runtime.Internal.Transform;
namespace Amazon.Kafka
{
///
/// Implementation for accessing Kafka
///
/// The operations for managing an Amazon MSK cluster.
///
public partial class AmazonKafkaClient : AmazonServiceClient, IAmazonKafka
{
private static IServiceMetadata serviceMetadata = new AmazonKafkaMetadata();
#region Constructors
///
/// Constructs AmazonKafkaClient 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 AmazonKafkaClient()
: base(FallbackCredentialsFactory.GetCredentials(), new AmazonKafkaConfig()) { }
///
/// Constructs AmazonKafkaClient 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 AmazonKafkaClient(RegionEndpoint region)
: base(FallbackCredentialsFactory.GetCredentials(), new AmazonKafkaConfig{RegionEndpoint = region}) { }
///
/// Constructs AmazonKafkaClient 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 AmazonKafkaClient Configuration Object
public AmazonKafkaClient(AmazonKafkaConfig config)
: base(FallbackCredentialsFactory.GetCredentials(config), config){}
///
/// Constructs AmazonKafkaClient with AWS Credentials
///
/// AWS Credentials
public AmazonKafkaClient(AWSCredentials credentials)
: this(credentials, new AmazonKafkaConfig())
{
}
///
/// Constructs AmazonKafkaClient with AWS Credentials
///
/// AWS Credentials
/// The region to connect.
public AmazonKafkaClient(AWSCredentials credentials, RegionEndpoint region)
: this(credentials, new AmazonKafkaConfig{RegionEndpoint = region})
{
}
///
/// Constructs AmazonKafkaClient with AWS Credentials and an
/// AmazonKafkaClient Configuration object.
///
/// AWS Credentials
/// The AmazonKafkaClient Configuration Object
public AmazonKafkaClient(AWSCredentials credentials, AmazonKafkaConfig clientConfig)
: base(credentials, clientConfig)
{
}
///
/// Constructs AmazonKafkaClient with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
public AmazonKafkaClient(string awsAccessKeyId, string awsSecretAccessKey)
: this(awsAccessKeyId, awsSecretAccessKey, new AmazonKafkaConfig())
{
}
///
/// Constructs AmazonKafkaClient with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// The region to connect.
public AmazonKafkaClient(string awsAccessKeyId, string awsSecretAccessKey, RegionEndpoint region)
: this(awsAccessKeyId, awsSecretAccessKey, new AmazonKafkaConfig() {RegionEndpoint=region})
{
}
///
/// Constructs AmazonKafkaClient with AWS Access Key ID, AWS Secret Key and an
/// AmazonKafkaClient Configuration object.
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// The AmazonKafkaClient Configuration Object
public AmazonKafkaClient(string awsAccessKeyId, string awsSecretAccessKey, AmazonKafkaConfig clientConfig)
: base(awsAccessKeyId, awsSecretAccessKey, clientConfig)
{
}
///
/// Constructs AmazonKafkaClient with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// AWS Session Token
public AmazonKafkaClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken)
: this(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, new AmazonKafkaConfig())
{
}
///
/// Constructs AmazonKafkaClient 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 AmazonKafkaClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken, RegionEndpoint region)
: this(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, new AmazonKafkaConfig{RegionEndpoint = region})
{
}
///
/// Constructs AmazonKafkaClient with AWS Access Key ID, AWS Secret Key and an
/// AmazonKafkaClient Configuration object.
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// AWS Session Token
/// The AmazonKafkaClient Configuration Object
public AmazonKafkaClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken, AmazonKafkaConfig clientConfig)
: base(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, clientConfig)
{
}
#endregion
#if AWS_ASYNC_ENUMERABLES_API
private IKafkaPaginatorFactory _paginators;
///
/// Paginators for the service
///
public IKafkaPaginatorFactory Paginators
{
get
{
if (this._paginators == null)
{
this._paginators = new KafkaPaginatorFactory(this);
}
return this._paginators;
}
}
#endif
#region Overrides
///
/// Creates the signer for the service.
///
protected override AbstractAWSSigner CreateSigner()
{
return new AWS4Signer();
}
///
/// Customizes the runtime pipeline.
///
/// Runtime pipeline for the current client.
protected override void CustomizeRuntimePipeline(RuntimePipeline pipeline)
{
pipeline.RemoveHandler();
pipeline.AddHandlerAfter(new AmazonKafkaEndpointResolver());
}
///
/// 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 BatchAssociateScramSecret
internal virtual BatchAssociateScramSecretResponse BatchAssociateScramSecret(BatchAssociateScramSecretRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = BatchAssociateScramSecretRequestMarshaller.Instance;
options.ResponseUnmarshaller = BatchAssociateScramSecretResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Associates one or more Scram Secrets with an Amazon MSK cluster.
///
/// Container for the necessary parameters to execute the BatchAssociateScramSecret service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the BatchAssociateScramSecret service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for BatchAssociateScramSecret Operation
public virtual Task BatchAssociateScramSecretAsync(BatchAssociateScramSecretRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = BatchAssociateScramSecretRequestMarshaller.Instance;
options.ResponseUnmarshaller = BatchAssociateScramSecretResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region BatchDisassociateScramSecret
internal virtual BatchDisassociateScramSecretResponse BatchDisassociateScramSecret(BatchDisassociateScramSecretRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = BatchDisassociateScramSecretRequestMarshaller.Instance;
options.ResponseUnmarshaller = BatchDisassociateScramSecretResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Disassociates one or more Scram Secrets from an Amazon MSK cluster.
///
/// Container for the necessary parameters to execute the BatchDisassociateScramSecret service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the BatchDisassociateScramSecret service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for BatchDisassociateScramSecret Operation
public virtual Task BatchDisassociateScramSecretAsync(BatchDisassociateScramSecretRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = BatchDisassociateScramSecretRequestMarshaller.Instance;
options.ResponseUnmarshaller = BatchDisassociateScramSecretResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region CreateCluster
internal virtual CreateClusterResponse CreateCluster(CreateClusterRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateClusterRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateClusterResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Creates a new MSK cluster.
///
/// Container for the necessary parameters to execute the CreateCluster service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CreateCluster service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for CreateCluster Operation
public virtual Task CreateClusterAsync(CreateClusterRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateClusterRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateClusterResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region CreateClusterV2
internal virtual CreateClusterV2Response CreateClusterV2(CreateClusterV2Request request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateClusterV2RequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateClusterV2ResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Creates a new MSK cluster.
///
/// Container for the necessary parameters to execute the CreateClusterV2 service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CreateClusterV2 service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for CreateClusterV2 Operation
public virtual Task CreateClusterV2Async(CreateClusterV2Request request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateClusterV2RequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateClusterV2ResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region CreateConfiguration
internal virtual CreateConfigurationResponse CreateConfiguration(CreateConfigurationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateConfigurationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Creates a new MSK configuration.
///
/// Container for the necessary parameters to execute the CreateConfiguration service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CreateConfiguration service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for CreateConfiguration Operation
public virtual Task CreateConfigurationAsync(CreateConfigurationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateConfigurationResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region CreateVpcConnection
internal virtual CreateVpcConnectionResponse CreateVpcConnection(CreateVpcConnectionRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateVpcConnectionRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateVpcConnectionResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Creates a new MSK VPC connection.
///
/// Container for the necessary parameters to execute the CreateVpcConnection service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CreateVpcConnection service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for CreateVpcConnection Operation
public virtual Task CreateVpcConnectionAsync(CreateVpcConnectionRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateVpcConnectionRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateVpcConnectionResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DeleteCluster
internal virtual DeleteClusterResponse DeleteCluster(DeleteClusterRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteClusterRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteClusterResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Deletes the MSK cluster specified by the Amazon Resource Name (ARN) in the request.
///
/// Container for the necessary parameters to execute the DeleteCluster service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteCluster service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for DeleteCluster Operation
public virtual Task DeleteClusterAsync(DeleteClusterRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteClusterRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteClusterResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DeleteClusterPolicy
internal virtual DeleteClusterPolicyResponse DeleteClusterPolicy(DeleteClusterPolicyRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteClusterPolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteClusterPolicyResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Deletes the MSK cluster policy specified by the Amazon Resource Name (ARN) in the
/// request.
///
/// Container for the necessary parameters to execute the DeleteClusterPolicy service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteClusterPolicy service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for DeleteClusterPolicy Operation
public virtual Task DeleteClusterPolicyAsync(DeleteClusterPolicyRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteClusterPolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteClusterPolicyResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DeleteConfiguration
internal virtual DeleteConfigurationResponse DeleteConfiguration(DeleteConfigurationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteConfigurationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Deletes an MSK Configuration.
///
/// Container for the necessary parameters to execute the DeleteConfiguration service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteConfiguration service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for DeleteConfiguration Operation
public virtual Task DeleteConfigurationAsync(DeleteConfigurationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteConfigurationResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DeleteVpcConnection
internal virtual DeleteVpcConnectionResponse DeleteVpcConnection(DeleteVpcConnectionRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteVpcConnectionRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteVpcConnectionResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Deletes a MSK VPC connection.
///
/// Container for the necessary parameters to execute the DeleteVpcConnection service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteVpcConnection service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for DeleteVpcConnection Operation
public virtual Task DeleteVpcConnectionAsync(DeleteVpcConnectionRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteVpcConnectionRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteVpcConnectionResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DescribeCluster
internal virtual DescribeClusterResponse DescribeCluster(DescribeClusterRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeClusterRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeClusterResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified
/// in the request.
///
/// Container for the necessary parameters to execute the DescribeCluster service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeCluster service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for DescribeCluster Operation
public virtual Task DescribeClusterAsync(DescribeClusterRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeClusterRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeClusterResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DescribeClusterOperation
internal virtual DescribeClusterOperationResponse DescribeClusterOperation(DescribeClusterOperationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeClusterOperationRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeClusterOperationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns a description of the cluster operation specified by the ARN.
///
/// Container for the necessary parameters to execute the DescribeClusterOperation service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeClusterOperation service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for DescribeClusterOperation Operation
public virtual Task DescribeClusterOperationAsync(DescribeClusterOperationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeClusterOperationRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeClusterOperationResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DescribeClusterOperationV2
internal virtual DescribeClusterOperationV2Response DescribeClusterOperationV2(DescribeClusterOperationV2Request request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeClusterOperationV2RequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeClusterOperationV2ResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns a description of the cluster operation specified by the ARN.
///
/// Container for the necessary parameters to execute the DescribeClusterOperationV2 service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeClusterOperationV2 service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for DescribeClusterOperationV2 Operation
public virtual Task DescribeClusterOperationV2Async(DescribeClusterOperationV2Request request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeClusterOperationV2RequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeClusterOperationV2ResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DescribeClusterV2
internal virtual DescribeClusterV2Response DescribeClusterV2(DescribeClusterV2Request request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeClusterV2RequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeClusterV2ResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified
/// in the request.
///
/// Container for the necessary parameters to execute the DescribeClusterV2 service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeClusterV2 service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for DescribeClusterV2 Operation
public virtual Task DescribeClusterV2Async(DescribeClusterV2Request request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeClusterV2RequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeClusterV2ResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DescribeConfiguration
internal virtual DescribeConfigurationResponse DescribeConfiguration(DescribeConfigurationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeConfigurationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns a description of this MSK configuration.
///
/// Container for the necessary parameters to execute the DescribeConfiguration service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeConfiguration service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for DescribeConfiguration Operation
public virtual Task DescribeConfigurationAsync(DescribeConfigurationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeConfigurationResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DescribeConfigurationRevision
internal virtual DescribeConfigurationRevisionResponse DescribeConfigurationRevision(DescribeConfigurationRevisionRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeConfigurationRevisionRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeConfigurationRevisionResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns a description of this revision of the configuration.
///
/// Container for the necessary parameters to execute the DescribeConfigurationRevision service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeConfigurationRevision service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for DescribeConfigurationRevision Operation
public virtual Task DescribeConfigurationRevisionAsync(DescribeConfigurationRevisionRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeConfigurationRevisionRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeConfigurationRevisionResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DescribeVpcConnection
internal virtual DescribeVpcConnectionResponse DescribeVpcConnection(DescribeVpcConnectionRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeVpcConnectionRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeVpcConnectionResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns a description of this MSK VPC connection.
///
/// Container for the necessary parameters to execute the DescribeVpcConnection service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeVpcConnection service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for DescribeVpcConnection Operation
public virtual Task DescribeVpcConnectionAsync(DescribeVpcConnectionRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeVpcConnectionRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeVpcConnectionResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region GetBootstrapBrokers
internal virtual GetBootstrapBrokersResponse GetBootstrapBrokers(GetBootstrapBrokersRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = GetBootstrapBrokersRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetBootstrapBrokersResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// A list of brokers that a client application can use to bootstrap.
///
/// Container for the necessary parameters to execute the GetBootstrapBrokers service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the GetBootstrapBrokers service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for GetBootstrapBrokers Operation
public virtual Task GetBootstrapBrokersAsync(GetBootstrapBrokersRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = GetBootstrapBrokersRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetBootstrapBrokersResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region GetClusterPolicy
internal virtual GetClusterPolicyResponse GetClusterPolicy(GetClusterPolicyRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = GetClusterPolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetClusterPolicyResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Get the MSK cluster policy specified by the Amazon Resource Name (ARN) in the request.
///
/// Container for the necessary parameters to execute the GetClusterPolicy service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the GetClusterPolicy service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for GetClusterPolicy Operation
public virtual Task GetClusterPolicyAsync(GetClusterPolicyRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = GetClusterPolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetClusterPolicyResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region GetCompatibleKafkaVersions
internal virtual GetCompatibleKafkaVersionsResponse GetCompatibleKafkaVersions(GetCompatibleKafkaVersionsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = GetCompatibleKafkaVersionsRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetCompatibleKafkaVersionsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Gets the Apache Kafka versions to which you can update the MSK cluster.
///
/// Container for the necessary parameters to execute the GetCompatibleKafkaVersions service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the GetCompatibleKafkaVersions service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for GetCompatibleKafkaVersions Operation
public virtual Task GetCompatibleKafkaVersionsAsync(GetCompatibleKafkaVersionsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = GetCompatibleKafkaVersionsRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetCompatibleKafkaVersionsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListClientVpcConnections
internal virtual ListClientVpcConnectionsResponse ListClientVpcConnections(ListClientVpcConnectionsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListClientVpcConnectionsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListClientVpcConnectionsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns a list of all the VPC connections in this Region.
///
/// Container for the necessary parameters to execute the ListClientVpcConnections service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListClientVpcConnections service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for ListClientVpcConnections Operation
public virtual Task ListClientVpcConnectionsAsync(ListClientVpcConnectionsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListClientVpcConnectionsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListClientVpcConnectionsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListClusterOperations
internal virtual ListClusterOperationsResponse ListClusterOperations(ListClusterOperationsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListClusterOperationsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListClusterOperationsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns a list of all the operations that have been performed on the specified MSK
/// cluster.
///
/// Container for the necessary parameters to execute the ListClusterOperations service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListClusterOperations service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for ListClusterOperations Operation
public virtual Task ListClusterOperationsAsync(ListClusterOperationsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListClusterOperationsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListClusterOperationsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListClusterOperationsV2
internal virtual ListClusterOperationsV2Response ListClusterOperationsV2(ListClusterOperationsV2Request request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListClusterOperationsV2RequestMarshaller.Instance;
options.ResponseUnmarshaller = ListClusterOperationsV2ResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns a list of all the operations that have been performed on the specified MSK
/// cluster.
///
/// Container for the necessary parameters to execute the ListClusterOperationsV2 service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListClusterOperationsV2 service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for ListClusterOperationsV2 Operation
public virtual Task ListClusterOperationsV2Async(ListClusterOperationsV2Request request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListClusterOperationsV2RequestMarshaller.Instance;
options.ResponseUnmarshaller = ListClusterOperationsV2ResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListClusters
internal virtual ListClustersResponse ListClusters(ListClustersRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListClustersRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListClustersResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns a list of all the MSK clusters in the current Region.
///
/// Container for the necessary parameters to execute the ListClusters service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListClusters service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for ListClusters Operation
public virtual Task ListClustersAsync(ListClustersRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListClustersRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListClustersResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListClustersV2
internal virtual ListClustersV2Response ListClustersV2(ListClustersV2Request request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListClustersV2RequestMarshaller.Instance;
options.ResponseUnmarshaller = ListClustersV2ResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns a list of all the MSK clusters in the current Region.
///
/// Container for the necessary parameters to execute the ListClustersV2 service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListClustersV2 service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for ListClustersV2 Operation
public virtual Task ListClustersV2Async(ListClustersV2Request request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListClustersV2RequestMarshaller.Instance;
options.ResponseUnmarshaller = ListClustersV2ResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListConfigurationRevisions
internal virtual ListConfigurationRevisionsResponse ListConfigurationRevisions(ListConfigurationRevisionsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListConfigurationRevisionsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListConfigurationRevisionsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns a list of all the MSK configurations in this Region.
///
/// Container for the necessary parameters to execute the ListConfigurationRevisions service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListConfigurationRevisions service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for ListConfigurationRevisions Operation
public virtual Task ListConfigurationRevisionsAsync(ListConfigurationRevisionsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListConfigurationRevisionsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListConfigurationRevisionsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListConfigurations
internal virtual ListConfigurationsResponse ListConfigurations(ListConfigurationsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListConfigurationsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListConfigurationsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns a list of all the MSK configurations in this Region.
///
/// Container for the necessary parameters to execute the ListConfigurations service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListConfigurations service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for ListConfigurations Operation
public virtual Task ListConfigurationsAsync(ListConfigurationsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListConfigurationsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListConfigurationsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListKafkaVersions
internal virtual ListKafkaVersionsResponse ListKafkaVersions(ListKafkaVersionsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListKafkaVersionsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListKafkaVersionsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns a list of Apache Kafka versions.
///
/// Container for the necessary parameters to execute the ListKafkaVersions service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListKafkaVersions service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for ListKafkaVersions Operation
public virtual Task ListKafkaVersionsAsync(ListKafkaVersionsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListKafkaVersionsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListKafkaVersionsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListNodes
internal virtual ListNodesResponse ListNodes(ListNodesRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListNodesRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListNodesResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns a list of the broker nodes in the cluster.
///
/// Container for the necessary parameters to execute the ListNodes service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListNodes service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for ListNodes Operation
public virtual Task ListNodesAsync(ListNodesRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListNodesRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListNodesResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListScramSecrets
internal virtual ListScramSecretsResponse ListScramSecrets(ListScramSecretsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListScramSecretsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListScramSecretsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns a list of the Scram Secrets associated with an Amazon MSK cluster.
///
/// Container for the necessary parameters to execute the ListScramSecrets service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListScramSecrets service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for ListScramSecrets Operation
public virtual Task ListScramSecretsAsync(ListScramSecretsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListScramSecretsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListScramSecretsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListTagsForResource
internal virtual ListTagsForResourceResponse ListTagsForResource(ListTagsForResourceRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListTagsForResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListTagsForResourceResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns a list of the tags associated with the specified resource.
///
/// 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 Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// 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 ListVpcConnections
internal virtual ListVpcConnectionsResponse ListVpcConnections(ListVpcConnectionsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListVpcConnectionsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListVpcConnectionsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns a list of all the VPC connections in this Region.
///
/// Container for the necessary parameters to execute the ListVpcConnections service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListVpcConnections service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for ListVpcConnections Operation
public virtual Task ListVpcConnectionsAsync(ListVpcConnectionsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListVpcConnectionsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListVpcConnectionsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region PutClusterPolicy
internal virtual PutClusterPolicyResponse PutClusterPolicy(PutClusterPolicyRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = PutClusterPolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = PutClusterPolicyResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Creates or updates the MSK cluster policy specified by the cluster Amazon Resource
/// Name (ARN) in the request.
///
/// Container for the necessary parameters to execute the PutClusterPolicy service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the PutClusterPolicy service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for PutClusterPolicy Operation
public virtual Task PutClusterPolicyAsync(PutClusterPolicyRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = PutClusterPolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = PutClusterPolicyResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region RebootBroker
internal virtual RebootBrokerResponse RebootBroker(RebootBrokerRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = RebootBrokerRequestMarshaller.Instance;
options.ResponseUnmarshaller = RebootBrokerResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Reboots brokers.
///
/// Container for the necessary parameters to execute the RebootBroker service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the RebootBroker service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for RebootBroker Operation
public virtual Task RebootBrokerAsync(RebootBrokerRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = RebootBrokerRequestMarshaller.Instance;
options.ResponseUnmarshaller = RebootBrokerResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region RejectClientVpcConnection
internal virtual RejectClientVpcConnectionResponse RejectClientVpcConnection(RejectClientVpcConnectionRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = RejectClientVpcConnectionRequestMarshaller.Instance;
options.ResponseUnmarshaller = RejectClientVpcConnectionResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns empty response.
///
/// Container for the necessary parameters to execute the RejectClientVpcConnection service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the RejectClientVpcConnection service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for RejectClientVpcConnection Operation
public virtual Task RejectClientVpcConnectionAsync(RejectClientVpcConnectionRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = RejectClientVpcConnectionRequestMarshaller.Instance;
options.ResponseUnmarshaller = RejectClientVpcConnectionResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region TagResource
internal virtual TagResourceResponse TagResource(TagResourceRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = TagResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = TagResourceResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Adds tags to the specified MSK resource.
///
/// 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 Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// 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
internal virtual UntagResourceResponse UntagResource(UntagResourceRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UntagResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = UntagResourceResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Removes the tags associated with the keys that are provided in the query.
///
/// 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 Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// 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 UpdateBrokerCount
internal virtual UpdateBrokerCountResponse UpdateBrokerCount(UpdateBrokerCountRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateBrokerCountRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateBrokerCountResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Updates the number of broker nodes in the cluster.
///
/// Container for the necessary parameters to execute the UpdateBrokerCount service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UpdateBrokerCount service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for UpdateBrokerCount Operation
public virtual Task UpdateBrokerCountAsync(UpdateBrokerCountRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateBrokerCountRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateBrokerCountResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region UpdateBrokerStorage
internal virtual UpdateBrokerStorageResponse UpdateBrokerStorage(UpdateBrokerStorageRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateBrokerStorageRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateBrokerStorageResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Updates the EBS storage associated with MSK brokers.
///
/// Container for the necessary parameters to execute the UpdateBrokerStorage service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UpdateBrokerStorage service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for UpdateBrokerStorage Operation
public virtual Task UpdateBrokerStorageAsync(UpdateBrokerStorageRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateBrokerStorageRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateBrokerStorageResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region UpdateBrokerType
internal virtual UpdateBrokerTypeResponse UpdateBrokerType(UpdateBrokerTypeRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateBrokerTypeRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateBrokerTypeResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Updates EC2 instance type.
///
/// Container for the necessary parameters to execute the UpdateBrokerType service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UpdateBrokerType service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for UpdateBrokerType Operation
public virtual Task UpdateBrokerTypeAsync(UpdateBrokerTypeRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateBrokerTypeRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateBrokerTypeResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region UpdateClusterConfiguration
internal virtual UpdateClusterConfigurationResponse UpdateClusterConfiguration(UpdateClusterConfigurationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateClusterConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateClusterConfigurationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Updates the cluster with the configuration that is specified in the request body.
///
/// Container for the necessary parameters to execute the UpdateClusterConfiguration service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UpdateClusterConfiguration service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for UpdateClusterConfiguration Operation
public virtual Task UpdateClusterConfigurationAsync(UpdateClusterConfigurationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateClusterConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateClusterConfigurationResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region UpdateClusterKafkaVersion
internal virtual UpdateClusterKafkaVersionResponse UpdateClusterKafkaVersion(UpdateClusterKafkaVersionRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateClusterKafkaVersionRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateClusterKafkaVersionResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Updates the Apache Kafka version for the cluster.
///
/// Container for the necessary parameters to execute the UpdateClusterKafkaVersion service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UpdateClusterKafkaVersion service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for UpdateClusterKafkaVersion Operation
public virtual Task UpdateClusterKafkaVersionAsync(UpdateClusterKafkaVersionRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateClusterKafkaVersionRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateClusterKafkaVersionResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region UpdateConfiguration
internal virtual UpdateConfigurationResponse UpdateConfiguration(UpdateConfigurationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateConfigurationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Updates an MSK configuration.
///
/// Container for the necessary parameters to execute the UpdateConfiguration service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UpdateConfiguration service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for UpdateConfiguration Operation
public virtual Task UpdateConfigurationAsync(UpdateConfigurationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateConfigurationResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region UpdateConnectivity
internal virtual UpdateConnectivityResponse UpdateConnectivity(UpdateConnectivityRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateConnectivityRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateConnectivityResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Updates the cluster's connectivity configuration.
///
/// Container for the necessary parameters to execute the UpdateConnectivity service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UpdateConnectivity service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for UpdateConnectivity Operation
public virtual Task UpdateConnectivityAsync(UpdateConnectivityRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateConnectivityRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateConnectivityResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region UpdateMonitoring
internal virtual UpdateMonitoringResponse UpdateMonitoring(UpdateMonitoringRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateMonitoringRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateMonitoringResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Updates the monitoring settings for the cluster. You can use this operation to specify
/// which Apache Kafka metrics you want Amazon MSK to send to Amazon CloudWatch. You can
/// also specify settings for open monitoring with Prometheus.
///
/// Container for the necessary parameters to execute the UpdateMonitoring service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UpdateMonitoring service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for UpdateMonitoring Operation
public virtual Task UpdateMonitoringAsync(UpdateMonitoringRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateMonitoringRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateMonitoringResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region UpdateSecurity
internal virtual UpdateSecurityResponse UpdateSecurity(UpdateSecurityRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateSecurityRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateSecurityResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Updates the security settings for the cluster. You can use this operation to specify
/// encryption and authentication on existing clusters.
///
/// Container for the necessary parameters to execute the UpdateSecurity service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UpdateSecurity service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for UpdateSecurity Operation
public virtual Task UpdateSecurityAsync(UpdateSecurityRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateSecurityRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateSecurityResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region UpdateStorage
internal virtual UpdateStorageResponse UpdateStorage(UpdateStorageRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateStorageRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateStorageResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Updates cluster broker volume size (or) sets cluster storage mode to TIERED.
///
/// Container for the necessary parameters to execute the UpdateStorage service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UpdateStorage service method, as returned by Kafka.
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
///
/// Returns information about an error.
///
/// REST API Reference for UpdateStorage Operation
public virtual Task UpdateStorageAsync(UpdateStorageRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateStorageRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateStorageResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
}
}