KafkaConnectClientProtocol

public protocol KafkaConnectClientProtocol 

Requirements

createConnector(input:completion:)

Creates a connector using the specified properties.

func createConnector(input: CreateConnectorInput, completion: @escaping (ClientRuntime.SdkResult<CreateConnectorOutputResponse, CreateConnectorOutputError>) -> Void)

createCustomPlugin(input:completion:)

Creates a custom plugin using the specified properties.

func createCustomPlugin(input: CreateCustomPluginInput, completion: @escaping (ClientRuntime.SdkResult<CreateCustomPluginOutputResponse, CreateCustomPluginOutputError>) -> Void)

createWorkerConfiguration(input:completion:)

Creates a worker configuration using the specified properties.

func createWorkerConfiguration(input: CreateWorkerConfigurationInput, completion: @escaping (ClientRuntime.SdkResult<CreateWorkerConfigurationOutputResponse, CreateWorkerConfigurationOutputError>) -> Void)

deleteConnector(input:completion:)

Deletes the specified connector.

func deleteConnector(input: DeleteConnectorInput, completion: @escaping (ClientRuntime.SdkResult<DeleteConnectorOutputResponse, DeleteConnectorOutputError>) -> Void)

describeConnector(input:completion:)

Returns summary information about the connector.

func describeConnector(input: DescribeConnectorInput, completion: @escaping (ClientRuntime.SdkResult<DescribeConnectorOutputResponse, DescribeConnectorOutputError>) -> Void)

describeCustomPlugin(input:completion:)

A summary description of the custom plugin.

func describeCustomPlugin(input: DescribeCustomPluginInput, completion: @escaping (ClientRuntime.SdkResult<DescribeCustomPluginOutputResponse, DescribeCustomPluginOutputError>) -> Void)

describeWorkerConfiguration(input:completion:)

Returns information about a worker configuration.

func describeWorkerConfiguration(input: DescribeWorkerConfigurationInput, completion: @escaping (ClientRuntime.SdkResult<DescribeWorkerConfigurationOutputResponse, DescribeWorkerConfigurationOutputError>) -> Void)

listConnectors(input:completion:)

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.

func listConnectors(input: ListConnectorsInput, completion: @escaping (ClientRuntime.SdkResult<ListConnectorsOutputResponse, ListConnectorsOutputError>) -> Void)

listCustomPlugins(input:completion:)

Returns a list of all of the custom plugins in this account and Region.

func listCustomPlugins(input: ListCustomPluginsInput, completion: @escaping (ClientRuntime.SdkResult<ListCustomPluginsOutputResponse, ListCustomPluginsOutputError>) -> Void)

listWorkerConfigurations(input:completion:)

Returns a list of all of the worker configurations in this account and Region.

func listWorkerConfigurations(input: ListWorkerConfigurationsInput, completion: @escaping (ClientRuntime.SdkResult<ListWorkerConfigurationsOutputResponse, ListWorkerConfigurationsOutputError>) -> Void)

updateConnector(input:completion:)

Updates the specified connector.

func updateConnector(input: UpdateConnectorInput, completion: @escaping (ClientRuntime.SdkResult<UpdateConnectorOutputResponse, UpdateConnectorOutputError>) -> Void)