Versions in this module Expand all Collapse all v0 v0.1.0 Dec 26, 2023 v0.0.1 Dec 26, 2023 Changes in this version + type KafkaConnectAPI interface + CreateConnector func(*kafkaconnect.CreateConnectorInput) (*kafkaconnect.CreateConnectorOutput, error) + CreateConnectorRequest func(*kafkaconnect.CreateConnectorInput) (*request.Request, *kafkaconnect.CreateConnectorOutput) + CreateConnectorWithContext func(aws.Context, *kafkaconnect.CreateConnectorInput, ...request.Option) (*kafkaconnect.CreateConnectorOutput, error) + CreateCustomPlugin func(*kafkaconnect.CreateCustomPluginInput) (*kafkaconnect.CreateCustomPluginOutput, error) + CreateCustomPluginRequest func(*kafkaconnect.CreateCustomPluginInput) (*request.Request, *kafkaconnect.CreateCustomPluginOutput) + CreateCustomPluginWithContext func(aws.Context, *kafkaconnect.CreateCustomPluginInput, ...request.Option) (*kafkaconnect.CreateCustomPluginOutput, error) + CreateWorkerConfiguration func(*kafkaconnect.CreateWorkerConfigurationInput) (*kafkaconnect.CreateWorkerConfigurationOutput, error) + CreateWorkerConfigurationRequest func(*kafkaconnect.CreateWorkerConfigurationInput) (*request.Request, *kafkaconnect.CreateWorkerConfigurationOutput) + CreateWorkerConfigurationWithContext func(aws.Context, *kafkaconnect.CreateWorkerConfigurationInput, ...request.Option) (*kafkaconnect.CreateWorkerConfigurationOutput, error) + DeleteConnector func(*kafkaconnect.DeleteConnectorInput) (*kafkaconnect.DeleteConnectorOutput, error) + DeleteConnectorRequest func(*kafkaconnect.DeleteConnectorInput) (*request.Request, *kafkaconnect.DeleteConnectorOutput) + DeleteConnectorWithContext func(aws.Context, *kafkaconnect.DeleteConnectorInput, ...request.Option) (*kafkaconnect.DeleteConnectorOutput, error) + DeleteCustomPlugin func(*kafkaconnect.DeleteCustomPluginInput) (*kafkaconnect.DeleteCustomPluginOutput, error) + DeleteCustomPluginRequest func(*kafkaconnect.DeleteCustomPluginInput) (*request.Request, *kafkaconnect.DeleteCustomPluginOutput) + DeleteCustomPluginWithContext func(aws.Context, *kafkaconnect.DeleteCustomPluginInput, ...request.Option) (*kafkaconnect.DeleteCustomPluginOutput, error) + DescribeConnector func(*kafkaconnect.DescribeConnectorInput) (*kafkaconnect.DescribeConnectorOutput, error) + DescribeConnectorRequest func(*kafkaconnect.DescribeConnectorInput) (*request.Request, *kafkaconnect.DescribeConnectorOutput) + DescribeConnectorWithContext func(aws.Context, *kafkaconnect.DescribeConnectorInput, ...request.Option) (*kafkaconnect.DescribeConnectorOutput, error) + DescribeCustomPlugin func(*kafkaconnect.DescribeCustomPluginInput) (*kafkaconnect.DescribeCustomPluginOutput, error) + DescribeCustomPluginRequest func(*kafkaconnect.DescribeCustomPluginInput) (*request.Request, *kafkaconnect.DescribeCustomPluginOutput) + DescribeCustomPluginWithContext func(aws.Context, *kafkaconnect.DescribeCustomPluginInput, ...request.Option) (*kafkaconnect.DescribeCustomPluginOutput, error) + DescribeWorkerConfiguration func(*kafkaconnect.DescribeWorkerConfigurationInput) (*kafkaconnect.DescribeWorkerConfigurationOutput, error) + DescribeWorkerConfigurationRequest func(*kafkaconnect.DescribeWorkerConfigurationInput) (*request.Request, *kafkaconnect.DescribeWorkerConfigurationOutput) + DescribeWorkerConfigurationWithContext func(aws.Context, *kafkaconnect.DescribeWorkerConfigurationInput, ...request.Option) (*kafkaconnect.DescribeWorkerConfigurationOutput, error) + ListConnectors func(*kafkaconnect.ListConnectorsInput) (*kafkaconnect.ListConnectorsOutput, error) + ListConnectorsPages func(*kafkaconnect.ListConnectorsInput, ...) error + ListConnectorsPagesWithContext func(aws.Context, *kafkaconnect.ListConnectorsInput, ...) error + ListConnectorsRequest func(*kafkaconnect.ListConnectorsInput) (*request.Request, *kafkaconnect.ListConnectorsOutput) + ListConnectorsWithContext func(aws.Context, *kafkaconnect.ListConnectorsInput, ...request.Option) (*kafkaconnect.ListConnectorsOutput, error) + ListCustomPlugins func(*kafkaconnect.ListCustomPluginsInput) (*kafkaconnect.ListCustomPluginsOutput, error) + ListCustomPluginsPages func(*kafkaconnect.ListCustomPluginsInput, ...) error + ListCustomPluginsPagesWithContext func(aws.Context, *kafkaconnect.ListCustomPluginsInput, ...) error + ListCustomPluginsRequest func(*kafkaconnect.ListCustomPluginsInput) (*request.Request, *kafkaconnect.ListCustomPluginsOutput) + ListCustomPluginsWithContext func(aws.Context, *kafkaconnect.ListCustomPluginsInput, ...request.Option) (*kafkaconnect.ListCustomPluginsOutput, error) + ListWorkerConfigurations func(*kafkaconnect.ListWorkerConfigurationsInput) (*kafkaconnect.ListWorkerConfigurationsOutput, error) + ListWorkerConfigurationsPages func(*kafkaconnect.ListWorkerConfigurationsInput, ...) error + ListWorkerConfigurationsPagesWithContext func(aws.Context, *kafkaconnect.ListWorkerConfigurationsInput, ...) error + ListWorkerConfigurationsRequest func(*kafkaconnect.ListWorkerConfigurationsInput) (*request.Request, *kafkaconnect.ListWorkerConfigurationsOutput) + ListWorkerConfigurationsWithContext func(aws.Context, *kafkaconnect.ListWorkerConfigurationsInput, ...request.Option) (*kafkaconnect.ListWorkerConfigurationsOutput, error) + UpdateConnector func(*kafkaconnect.UpdateConnectorInput) (*kafkaconnect.UpdateConnectorOutput, error) + UpdateConnectorRequest func(*kafkaconnect.UpdateConnectorInput) (*request.Request, *kafkaconnect.UpdateConnectorOutput) + UpdateConnectorWithContext func(aws.Context, *kafkaconnect.UpdateConnectorInput, ...request.Option) (*kafkaconnect.UpdateConnectorOutput, error)
Go to main page