/*
* 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 kafkaconnect-2021-09-14.normal.json service model.
*/
using System;
using System.Threading;
using System.Threading.Tasks;
using System.Collections.Generic;
using Amazon.Runtime;
using Amazon.KafkaConnect.Model;
namespace Amazon.KafkaConnect
{
///
/// Interface for accessing KafkaConnect
///
///
///
public partial interface IAmazonKafkaConnect : IAmazonService, IDisposable
{
#if AWS_ASYNC_ENUMERABLES_API
///
/// Paginators for the service
///
IKafkaConnectPaginatorFactory Paginators { get; }
#endif
#region CreateConnector
///
/// Creates a connector using the specified properties.
///
/// Container for the necessary parameters to execute the CreateConnector service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CreateConnector service method, as returned by KafkaConnect.
///
/// HTTP Status Code 400: Bad request due to incorrect input. Correct your request and
/// then retry it.
///
///
/// HTTP Status Code 409: Conflict. A resource with this name already exists. Retry your
/// request with another name.
///
///
/// HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your
/// request.
///
///
/// HTTP Status Code 500: Unexpected internal server error. Retrying your request might
/// resolve the issue.
///
///
/// HTTP Status Code 404: Resource not found due to incorrect input. Correct your request
/// and then retry it.
///
///
/// HTTP Status Code 503: Service Unavailable. Retrying your request in some time might
/// resolve the issue.
///
///
/// HTTP Status Code 429: Limit exceeded. Resource limit reached.
///
///
/// HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
///
/// REST API Reference for CreateConnector Operation
Task CreateConnectorAsync(CreateConnectorRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region CreateCustomPlugin
///
/// Creates a custom plugin using the specified properties.
///
/// Container for the necessary parameters to execute the CreateCustomPlugin service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CreateCustomPlugin service method, as returned by KafkaConnect.
///
/// HTTP Status Code 400: Bad request due to incorrect input. Correct your request and
/// then retry it.
///
///
/// HTTP Status Code 409: Conflict. A resource with this name already exists. Retry your
/// request with another name.
///
///
/// HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your
/// request.
///
///
/// HTTP Status Code 500: Unexpected internal server error. Retrying your request might
/// resolve the issue.
///
///
/// HTTP Status Code 404: Resource not found due to incorrect input. Correct your request
/// and then retry it.
///
///
/// HTTP Status Code 503: Service Unavailable. Retrying your request in some time might
/// resolve the issue.
///
///
/// HTTP Status Code 429: Limit exceeded. Resource limit reached.
///
///
/// HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
///
/// REST API Reference for CreateCustomPlugin Operation
Task CreateCustomPluginAsync(CreateCustomPluginRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region CreateWorkerConfiguration
///
/// Creates a worker configuration using the specified properties.
///
/// Container for the necessary parameters to execute the CreateWorkerConfiguration service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CreateWorkerConfiguration service method, as returned by KafkaConnect.
///
/// HTTP Status Code 400: Bad request due to incorrect input. Correct your request and
/// then retry it.
///
///
/// HTTP Status Code 409: Conflict. A resource with this name already exists. Retry your
/// request with another name.
///
///
/// HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your
/// request.
///
///
/// HTTP Status Code 500: Unexpected internal server error. Retrying your request might
/// resolve the issue.
///
///
/// HTTP Status Code 404: Resource not found due to incorrect input. Correct your request
/// and then retry it.
///
///
/// HTTP Status Code 503: Service Unavailable. Retrying your request in some time might
/// resolve the issue.
///
///
/// HTTP Status Code 429: Limit exceeded. Resource limit reached.
///
///
/// HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
///
/// REST API Reference for CreateWorkerConfiguration Operation
Task CreateWorkerConfigurationAsync(CreateWorkerConfigurationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region DeleteConnector
///
/// Deletes the specified connector.
///
/// Container for the necessary parameters to execute the DeleteConnector service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteConnector service method, as returned by KafkaConnect.
///
/// HTTP Status Code 400: Bad request due to incorrect input. Correct your request and
/// then retry it.
///
///
/// HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your
/// request.
///
///
/// HTTP Status Code 500: Unexpected internal server error. Retrying your request might
/// resolve the issue.
///
///
/// HTTP Status Code 404: Resource not found due to incorrect input. Correct your request
/// and then retry it.
///
///
/// HTTP Status Code 503: Service Unavailable. Retrying your request in some time might
/// resolve the issue.
///
///
/// HTTP Status Code 429: Limit exceeded. Resource limit reached.
///
///
/// HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
///
/// REST API Reference for DeleteConnector Operation
Task DeleteConnectorAsync(DeleteConnectorRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region DeleteCustomPlugin
///
/// Deletes a custom plugin.
///
/// Container for the necessary parameters to execute the DeleteCustomPlugin service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteCustomPlugin service method, as returned by KafkaConnect.
///
/// HTTP Status Code 400: Bad request due to incorrect input. Correct your request and
/// then retry it.
///
///
/// HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your
/// request.
///
///
/// HTTP Status Code 500: Unexpected internal server error. Retrying your request might
/// resolve the issue.
///
///
/// HTTP Status Code 404: Resource not found due to incorrect input. Correct your request
/// and then retry it.
///
///
/// HTTP Status Code 503: Service Unavailable. Retrying your request in some time might
/// resolve the issue.
///
///
/// HTTP Status Code 429: Limit exceeded. Resource limit reached.
///
///
/// HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
///
/// REST API Reference for DeleteCustomPlugin Operation
Task DeleteCustomPluginAsync(DeleteCustomPluginRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region DescribeConnector
///
/// Returns summary information about the connector.
///
/// Container for the necessary parameters to execute the DescribeConnector service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeConnector service method, as returned by KafkaConnect.
///
/// HTTP Status Code 400: Bad request due to incorrect input. Correct your request and
/// then retry it.
///
///
/// HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your
/// request.
///
///
/// HTTP Status Code 500: Unexpected internal server error. Retrying your request might
/// resolve the issue.
///
///
/// HTTP Status Code 404: Resource not found due to incorrect input. Correct your request
/// and then retry it.
///
///
/// HTTP Status Code 503: Service Unavailable. Retrying your request in some time might
/// resolve the issue.
///
///
/// HTTP Status Code 429: Limit exceeded. Resource limit reached.
///
///
/// HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
///
/// REST API Reference for DescribeConnector Operation
Task DescribeConnectorAsync(DescribeConnectorRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region DescribeCustomPlugin
///
/// A summary description of the custom plugin.
///
/// Container for the necessary parameters to execute the DescribeCustomPlugin service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeCustomPlugin service method, as returned by KafkaConnect.
///
/// HTTP Status Code 400: Bad request due to incorrect input. Correct your request and
/// then retry it.
///
///
/// HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your
/// request.
///
///
/// HTTP Status Code 500: Unexpected internal server error. Retrying your request might
/// resolve the issue.
///
///
/// HTTP Status Code 404: Resource not found due to incorrect input. Correct your request
/// and then retry it.
///
///
/// HTTP Status Code 503: Service Unavailable. Retrying your request in some time might
/// resolve the issue.
///
///
/// HTTP Status Code 429: Limit exceeded. Resource limit reached.
///
///
/// HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
///
/// REST API Reference for DescribeCustomPlugin Operation
Task DescribeCustomPluginAsync(DescribeCustomPluginRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region DescribeWorkerConfiguration
///
/// Returns information about a worker configuration.
///
/// Container for the necessary parameters to execute the DescribeWorkerConfiguration service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeWorkerConfiguration service method, as returned by KafkaConnect.
///
/// HTTP Status Code 400: Bad request due to incorrect input. Correct your request and
/// then retry it.
///
///
/// HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your
/// request.
///
///
/// HTTP Status Code 500: Unexpected internal server error. Retrying your request might
/// resolve the issue.
///
///
/// HTTP Status Code 404: Resource not found due to incorrect input. Correct your request
/// and then retry it.
///
///
/// HTTP Status Code 503: Service Unavailable. Retrying your request in some time might
/// resolve the issue.
///
///
/// HTTP Status Code 429: Limit exceeded. Resource limit reached.
///
///
/// HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
///
/// REST API Reference for DescribeWorkerConfiguration Operation
Task DescribeWorkerConfigurationAsync(DescribeWorkerConfigurationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region ListConnectors
///
/// Returns a list of all the connectors in this account and Region. The list is limited
/// to connectors whose name starts with the specified prefix. The response also includes
/// a description of each of the listed connectors.
///
/// Container for the necessary parameters to execute the ListConnectors service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListConnectors service method, as returned by KafkaConnect.
///
/// HTTP Status Code 400: Bad request due to incorrect input. Correct your request and
/// then retry it.
///
///
/// HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your
/// request.
///
///
/// HTTP Status Code 500: Unexpected internal server error. Retrying your request might
/// resolve the issue.
///
///
/// HTTP Status Code 404: Resource not found due to incorrect input. Correct your request
/// and then retry it.
///
///
/// HTTP Status Code 503: Service Unavailable. Retrying your request in some time might
/// resolve the issue.
///
///
/// HTTP Status Code 429: Limit exceeded. Resource limit reached.
///
///
/// HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
///
/// REST API Reference for ListConnectors Operation
Task ListConnectorsAsync(ListConnectorsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region ListCustomPlugins
///
/// Returns a list of all of the custom plugins in this account and Region.
///
/// Container for the necessary parameters to execute the ListCustomPlugins service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListCustomPlugins service method, as returned by KafkaConnect.
///
/// HTTP Status Code 400: Bad request due to incorrect input. Correct your request and
/// then retry it.
///
///
/// HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your
/// request.
///
///
/// HTTP Status Code 500: Unexpected internal server error. Retrying your request might
/// resolve the issue.
///
///
/// HTTP Status Code 404: Resource not found due to incorrect input. Correct your request
/// and then retry it.
///
///
/// HTTP Status Code 503: Service Unavailable. Retrying your request in some time might
/// resolve the issue.
///
///
/// HTTP Status Code 429: Limit exceeded. Resource limit reached.
///
///
/// HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
///
/// REST API Reference for ListCustomPlugins Operation
Task ListCustomPluginsAsync(ListCustomPluginsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region ListWorkerConfigurations
///
/// Returns a list of all of the worker configurations in this account and Region.
///
/// Container for the necessary parameters to execute the ListWorkerConfigurations service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListWorkerConfigurations service method, as returned by KafkaConnect.
///
/// HTTP Status Code 400: Bad request due to incorrect input. Correct your request and
/// then retry it.
///
///
/// HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your
/// request.
///
///
/// HTTP Status Code 500: Unexpected internal server error. Retrying your request might
/// resolve the issue.
///
///
/// HTTP Status Code 404: Resource not found due to incorrect input. Correct your request
/// and then retry it.
///
///
/// HTTP Status Code 503: Service Unavailable. Retrying your request in some time might
/// resolve the issue.
///
///
/// HTTP Status Code 429: Limit exceeded. Resource limit reached.
///
///
/// HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
///
/// REST API Reference for ListWorkerConfigurations Operation
Task ListWorkerConfigurationsAsync(ListWorkerConfigurationsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken));
#endregion
#region UpdateConnector
///
/// Updates the specified connector.
///
/// Container for the necessary parameters to execute the UpdateConnector service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UpdateConnector service method, as returned by KafkaConnect.
///
/// HTTP Status Code 400: Bad request due to incorrect input. Correct your request and
/// then retry it.
///
///
/// HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your
/// request.
///
///
/// HTTP Status Code 500: Unexpected internal server error. Retrying your request might
/// resolve the issue.
///
///
/// HTTP Status Code 404: Resource not found due to incorrect input. Correct your request
/// and then retry it.
///
///
/// HTTP Status Code 503: Service Unavailable. Retrying your request in some time might
/// resolve the issue.
///
///
/// HTTP Status Code 429: Limit exceeded. Resource limit reached.
///
///
/// HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
///
/// REST API Reference for UpdateConnector Operation
Task UpdateConnectorAsync(UpdateConnectorRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken));
#endregion
}
}