Awso_kafkaconnect_asyncSourceval create_connector :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_kafkaconnect.Values.CreateConnectorRequest.t ->
(Awso_kafkaconnect.Values.CreateConnectorResponse.t,
Awso_kafkaconnect.Values.CreateConnectorResponse.error)
Result.t
Async.Deferred.tval create_custom_plugin :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_kafkaconnect.Values.CreateCustomPluginRequest.t ->
(Awso_kafkaconnect.Values.CreateCustomPluginResponse.t,
Awso_kafkaconnect.Values.CreateCustomPluginResponse.error)
Result.t
Async.Deferred.tval create_worker_configuration :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_kafkaconnect.Values.CreateWorkerConfigurationRequest.t ->
(Awso_kafkaconnect.Values.CreateWorkerConfigurationResponse.t,
Awso_kafkaconnect.Values.CreateWorkerConfigurationResponse.error)
Result.t
Async.Deferred.tval delete_connector :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_kafkaconnect.Values.DeleteConnectorRequest.t ->
(Awso_kafkaconnect.Values.DeleteConnectorResponse.t,
Awso_kafkaconnect.Values.DeleteConnectorResponse.error)
Result.t
Async.Deferred.tval delete_custom_plugin :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_kafkaconnect.Values.DeleteCustomPluginRequest.t ->
(Awso_kafkaconnect.Values.DeleteCustomPluginResponse.t,
Awso_kafkaconnect.Values.DeleteCustomPluginResponse.error)
Result.t
Async.Deferred.tval delete_worker_configuration :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_kafkaconnect.Values.DeleteWorkerConfigurationRequest.t ->
(Awso_kafkaconnect.Values.DeleteWorkerConfigurationResponse.t,
Awso_kafkaconnect.Values.DeleteWorkerConfigurationResponse.error)
Result.t
Async.Deferred.tval describe_connector :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_kafkaconnect.Values.DescribeConnectorRequest.t ->
(Awso_kafkaconnect.Values.DescribeConnectorResponse.t,
Awso_kafkaconnect.Values.DescribeConnectorResponse.error)
Result.t
Async.Deferred.tval describe_connector_operation :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_kafkaconnect.Values.DescribeConnectorOperationRequest.t ->
(Awso_kafkaconnect.Values.DescribeConnectorOperationResponse.t,
Awso_kafkaconnect.Values.DescribeConnectorOperationResponse.error)
Result.t
Async.Deferred.tval describe_custom_plugin :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_kafkaconnect.Values.DescribeCustomPluginRequest.t ->
(Awso_kafkaconnect.Values.DescribeCustomPluginResponse.t,
Awso_kafkaconnect.Values.DescribeCustomPluginResponse.error)
Result.t
Async.Deferred.tval describe_worker_configuration :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_kafkaconnect.Values.DescribeWorkerConfigurationRequest.t ->
(Awso_kafkaconnect.Values.DescribeWorkerConfigurationResponse.t,
Awso_kafkaconnect.Values.DescribeWorkerConfigurationResponse.error)
Result.t
Async.Deferred.tval list_connector_operations :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_kafkaconnect.Values.ListConnectorOperationsRequest.t ->
(Awso_kafkaconnect.Values.ListConnectorOperationsResponse.t,
Awso_kafkaconnect.Values.ListConnectorOperationsResponse.error)
Result.t
Async.Deferred.tval list_connectors :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_kafkaconnect.Values.ListConnectorsRequest.t ->
(Awso_kafkaconnect.Values.ListConnectorsResponse.t,
Awso_kafkaconnect.Values.ListConnectorsResponse.error)
Result.t
Async.Deferred.tval list_custom_plugins :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_kafkaconnect.Values.ListCustomPluginsRequest.t ->
(Awso_kafkaconnect.Values.ListCustomPluginsResponse.t,
Awso_kafkaconnect.Values.ListCustomPluginsResponse.error)
Result.t
Async.Deferred.tval list_tags_for_resource :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_kafkaconnect.Values.ListTagsForResourceRequest.t ->
(Awso_kafkaconnect.Values.ListTagsForResourceResponse.t,
Awso_kafkaconnect.Values.ListTagsForResourceResponse.error)
Result.t
Async.Deferred.tval list_worker_configurations :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_kafkaconnect.Values.ListWorkerConfigurationsRequest.t ->
(Awso_kafkaconnect.Values.ListWorkerConfigurationsResponse.t,
Awso_kafkaconnect.Values.ListWorkerConfigurationsResponse.error)
Result.t
Async.Deferred.tval tag_resource :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_kafkaconnect.Values.TagResourceRequest.t ->
(Awso_kafkaconnect.Values.TagResourceResponse.t,
Awso_kafkaconnect.Values.TagResourceResponse.error)
Result.t
Async.Deferred.tval untag_resource :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_kafkaconnect.Values.UntagResourceRequest.t ->
(Awso_kafkaconnect.Values.UntagResourceResponse.t,
Awso_kafkaconnect.Values.UntagResourceResponse.error)
Result.t
Async.Deferred.tval update_connector :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_kafkaconnect.Values.UpdateConnectorRequest.t ->
(Awso_kafkaconnect.Values.UpdateConnectorResponse.t,
Awso_kafkaconnect.Values.UpdateConnectorResponse.error)
Result.t
Async.Deferred.tinclude module type of struct include Awso_kafkaconnect.Values endval structure_to_value_aux :
('a * 'b option) list ->
f:(('a * 'b) list -> 'c) ->
[> `Structure of 'c ]val structure_to_wrapped_value :
wrapper:'a ->
response:'a ->
('b * 'c option) list ->
[> `Structure of ('a * [> `Structure of ('b * 'c) list ]) list ]The description of the location of an object in Amazon S3.
The description of the scale-in policy for the connector.
The description of the scale-out policy for the connector.
The description of the VPC in which the connector resides.
module CloudWatchLogsLogDeliveryDescription =
Awso_kafkaconnect.Values.CloudWatchLogsLogDeliveryDescriptionA description of the log delivery settings.
module FirehoseLogDeliveryDescription =
Awso_kafkaconnect.Values.FirehoseLogDeliveryDescriptionA description of the settings for delivering logs to Amazon Kinesis Data Firehose.
The description of the details about delivering logs to Amazon S3.
Details about a custom plugin.
Details about a custom plugin file.
module CustomPluginLocationDescription =
Awso_kafkaconnect.Values.CustomPluginLocationDescriptionInformation about the location of a custom plugin.
Information about the auto scaling parameters for the connector.
module ProvisionedCapacityDescription =
Awso_kafkaconnect.Values.ProvisionedCapacityDescriptionThe description of a connector's provisioned capacity.
module KafkaClusterClientAuthenticationType =
Awso_kafkaconnect.Values.KafkaClusterClientAuthenticationTypeThe description of the Apache Kafka cluster to which the connector is connected.
module KafkaClusterEncryptionInTransitType =
Awso_kafkaconnect.Values.KafkaClusterEncryptionInTransitTypeWorkers can send worker logs to different destination types. This configuration specifies the details of these destinations.
The description of the plugin.
An update to the connector's scale-in policy.
An update to the connector's scale-out policy.
module WorkerConfigurationRevisionSummary =
Awso_kafkaconnect.Values.WorkerConfigurationRevisionSummaryThe summary of a worker configuration revision.
Details about the revision of a custom plugin.
A description of the connector's capacity.
module KafkaClusterClientAuthenticationDescription =
Awso_kafkaconnect.Values.KafkaClusterClientAuthenticationDescriptionThe client authentication information used in order to authenticate with the Apache Kafka cluster.
Details of how to connect to the Apache Kafka cluster.
module KafkaClusterEncryptionInTransitDescription =
Awso_kafkaconnect.Values.KafkaClusterEncryptionInTransitDescriptionThe description of the encryption in transit to the Apache Kafka cluster.
The description of the log delivery settings.
module WorkerConfigurationDescription =
Awso_kafkaconnect.Values.WorkerConfigurationDescriptionThe description of the worker configuration.
The scale-in policy for the connector.
The scale-out policy for the connector.
Information about the VPC in which the connector resides.
The settings for delivering connector logs to Amazon CloudWatch Logs.
The settings for delivering logs to Amazon Kinesis Data Firehose.
Details about delivering logs to Amazon S3.
A plugin is an Amazon Web Services resource that contains the code that defines a connector's logic.
The updates to the auto scaling parameters for the connector.
An update to a connector's fixed capacity.
The summary of a worker configuration.
A summary of the custom plugin.
Summary of a connector.
Summary of a connector operation.
Details of a step that is involved in a connector's operation.
The location of an object in Amazon S3.
Specifies how the connector scales.
Details about a connector's provisioned capacity.
The details of the Apache Kafka cluster to which the connector is connected.
Workers can send worker logs to different destination types. This configuration specifies the details of these destinations.
A plugin is an Amazon Web Services resource that contains the code that defines your connector logic.
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.
The target capacity for the connector. The capacity can be auto scaled or provisioned.
HTTP Status Code 409: Conflict. A resource with this name already exists. Retry your request with another name.
module WorkerConfigurationRevisionDescription =
Awso_kafkaconnect.Values.WorkerConfigurationRevisionDescriptionThe description of the worker configuration revision.
Details about the state of a resource.
Details about worker setting of a connector
Information about the location of a custom plugin.
Information about the capacity of the connector, whether it is auto scaled or provisioned.
The details of the Apache Kafka cluster to which the connector is connected.
module KafkaClusterClientAuthentication =
Awso_kafkaconnect.Values.KafkaClusterClientAuthenticationThe client authentication information used in order to authenticate with the Apache Kafka cluster.
module KafkaClusterEncryptionInTransit =
Awso_kafkaconnect.Values.KafkaClusterEncryptionInTransitDetails of encryption in transit to the Apache Kafka cluster.
Details about log delivery.
The configuration of the workers, which are the processes that run the connector logic.
Updates the specified connector. For request body, specify only one parameter: either capacity or connectorConfiguration.
Updates the specified connector. For request body, specify only one parameter: either capacity or connectorConfiguration.
Removes tags from the specified resource.
Removes tags from the specified resource.
Attaches tags to the specified resource.
Attaches tags to the specified resource.
module ListWorkerConfigurationsResponse =
Awso_kafkaconnect.Values.ListWorkerConfigurationsResponseReturns a list of all of the worker configurations in this account and Region.
module ListWorkerConfigurationsRequest =
Awso_kafkaconnect.Values.ListWorkerConfigurationsRequestReturns a list of all of the worker configurations in this account and Region.
Lists all the tags attached to the specified resource.
Lists all the tags attached to the specified resource.
Returns a list of all of the custom plugins in this account and Region.
Returns a list of all of the custom plugins in this account and Region.
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.
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.
module ListConnectorOperationsResponse =
Awso_kafkaconnect.Values.ListConnectorOperationsResponseLists information about a connector's operation(s).
module ListConnectorOperationsRequest =
Awso_kafkaconnect.Values.ListConnectorOperationsRequestLists information about a connector's operation(s).
module DescribeWorkerConfigurationResponse =
Awso_kafkaconnect.Values.DescribeWorkerConfigurationResponseReturns information about a worker configuration.
module DescribeWorkerConfigurationRequest =
Awso_kafkaconnect.Values.DescribeWorkerConfigurationRequestReturns information about a worker configuration.
A summary description of the custom plugin.
A summary description of the custom plugin.
Returns summary information about the connector.
Returns summary information about the connector.
module DescribeConnectorOperationResponse =
Awso_kafkaconnect.Values.DescribeConnectorOperationResponseReturns information about the specified connector's operations.
module DescribeConnectorOperationRequest =
Awso_kafkaconnect.Values.DescribeConnectorOperationRequestReturns information about the specified connector's operations.
module DeleteWorkerConfigurationResponse =
Awso_kafkaconnect.Values.DeleteWorkerConfigurationResponseDeletes the specified worker configuration.
module DeleteWorkerConfigurationRequest =
Awso_kafkaconnect.Values.DeleteWorkerConfigurationRequestDeletes the specified worker configuration.
Deletes a custom plugin.
Deletes a custom plugin.
Deletes the specified connector.
Deletes the specified connector.
module CreateWorkerConfigurationResponse =
Awso_kafkaconnect.Values.CreateWorkerConfigurationResponseCreates a worker configuration using the specified properties.
module CreateWorkerConfigurationRequest =
Awso_kafkaconnect.Values.CreateWorkerConfigurationRequestCreates a worker configuration using the specified properties.
Creates a custom plugin using the specified properties.
Creates a custom plugin using the specified properties.
Creates a connector using the specified properties.
Creates a connector using the specified properties.