Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

kafkaiface

package

Go to main page

Versions in this module

v1

v1.42.9

Aug 3, 2023

Changes in this version

type KafkaAPI

+ CreateClusterV2 func(*kafka.CreateClusterV2Input) (*kafka.CreateClusterV2Output, error)

+ CreateClusterV2Request func(*kafka.CreateClusterV2Input) (*request.Request, *kafka.CreateClusterV2Output)

+ CreateClusterV2WithContext func(aws.Context, *kafka.CreateClusterV2Input, ...request.Option) (*kafka.CreateClusterV2Output, error)

+ CreateVpcConnection func(*kafka.CreateVpcConnectionInput) (*kafka.CreateVpcConnectionOutput, error)

+ CreateVpcConnectionRequest func(*kafka.CreateVpcConnectionInput) (*request.Request, *kafka.CreateVpcConnectionOutput)

+ CreateVpcConnectionWithContext func(aws.Context, *kafka.CreateVpcConnectionInput, ...request.Option) (*kafka.CreateVpcConnectionOutput, error)

+ DeleteClusterPolicy func(*kafka.DeleteClusterPolicyInput) (*kafka.DeleteClusterPolicyOutput, error)

+ DeleteClusterPolicyRequest func(*kafka.DeleteClusterPolicyInput) (*request.Request, *kafka.DeleteClusterPolicyOutput)

+ DeleteClusterPolicyWithContext func(aws.Context, *kafka.DeleteClusterPolicyInput, ...request.Option) (*kafka.DeleteClusterPolicyOutput, error)

+ DeleteVpcConnection func(*kafka.DeleteVpcConnectionInput) (*kafka.DeleteVpcConnectionOutput, error)

+ DeleteVpcConnectionRequest func(*kafka.DeleteVpcConnectionInput) (*request.Request, *kafka.DeleteVpcConnectionOutput)

+ DeleteVpcConnectionWithContext func(aws.Context, *kafka.DeleteVpcConnectionInput, ...request.Option) (*kafka.DeleteVpcConnectionOutput, error)

+ DescribeClusterOperationV2 func(*kafka.DescribeClusterOperationV2Input) (*kafka.DescribeClusterOperationV2Output, error)

+ DescribeClusterOperationV2Request func(*kafka.DescribeClusterOperationV2Input) (*request.Request, *kafka.DescribeClusterOperationV2Output)

+ DescribeClusterOperationV2WithContext func(aws.Context, *kafka.DescribeClusterOperationV2Input, ...request.Option) (*kafka.DescribeClusterOperationV2Output, error)

+ DescribeClusterV2 func(*kafka.DescribeClusterV2Input) (*kafka.DescribeClusterV2Output, error)

+ DescribeClusterV2Request func(*kafka.DescribeClusterV2Input) (*request.Request, *kafka.DescribeClusterV2Output)

+ DescribeClusterV2WithContext func(aws.Context, *kafka.DescribeClusterV2Input, ...request.Option) (*kafka.DescribeClusterV2Output, error)

+ DescribeVpcConnection func(*kafka.DescribeVpcConnectionInput) (*kafka.DescribeVpcConnectionOutput, error)

+ DescribeVpcConnectionRequest func(*kafka.DescribeVpcConnectionInput) (*request.Request, *kafka.DescribeVpcConnectionOutput)

+ DescribeVpcConnectionWithContext func(aws.Context, *kafka.DescribeVpcConnectionInput, ...request.Option) (*kafka.DescribeVpcConnectionOutput, error)

+ GetClusterPolicy func(*kafka.GetClusterPolicyInput) (*kafka.GetClusterPolicyOutput, error)

+ GetClusterPolicyRequest func(*kafka.GetClusterPolicyInput) (*request.Request, *kafka.GetClusterPolicyOutput)

+ GetClusterPolicyWithContext func(aws.Context, *kafka.GetClusterPolicyInput, ...request.Option) (*kafka.GetClusterPolicyOutput, error)

+ ListClientVpcConnections func(*kafka.ListClientVpcConnectionsInput) (*kafka.ListClientVpcConnectionsOutput, error)

+ ListClientVpcConnectionsPages func(*kafka.ListClientVpcConnectionsInput, ...) error

+ ListClientVpcConnectionsPagesWithContext func(aws.Context, *kafka.ListClientVpcConnectionsInput, ...) error

+ ListClientVpcConnectionsRequest func(*kafka.ListClientVpcConnectionsInput) (*request.Request, *kafka.ListClientVpcConnectionsOutput)

+ ListClientVpcConnectionsWithContext func(aws.Context, *kafka.ListClientVpcConnectionsInput, ...request.Option) (*kafka.ListClientVpcConnectionsOutput, error)

+ ListClusterOperationsV2 func(*kafka.ListClusterOperationsV2Input) (*kafka.ListClusterOperationsV2Output, error)

+ ListClusterOperationsV2Pages func(*kafka.ListClusterOperationsV2Input, ...) error

+ ListClusterOperationsV2PagesWithContext func(aws.Context, *kafka.ListClusterOperationsV2Input, ...) error

+ ListClusterOperationsV2Request func(*kafka.ListClusterOperationsV2Input) (*request.Request, *kafka.ListClusterOperationsV2Output)

+ ListClusterOperationsV2WithContext func(aws.Context, *kafka.ListClusterOperationsV2Input, ...request.Option) (*kafka.ListClusterOperationsV2Output, error)

+ ListClustersV2 func(*kafka.ListClustersV2Input) (*kafka.ListClustersV2Output, error)

+ ListClustersV2Pages func(*kafka.ListClustersV2Input, func(*kafka.ListClustersV2Output, bool) bool) error

+ ListClustersV2PagesWithContext func(aws.Context, *kafka.ListClustersV2Input, ...) error

+ ListClustersV2Request func(*kafka.ListClustersV2Input) (*request.Request, *kafka.ListClustersV2Output)

+ ListClustersV2WithContext func(aws.Context, *kafka.ListClustersV2Input, ...request.Option) (*kafka.ListClustersV2Output, error)

+ ListVpcConnections func(*kafka.ListVpcConnectionsInput) (*kafka.ListVpcConnectionsOutput, error)

+ ListVpcConnectionsPages func(*kafka.ListVpcConnectionsInput, ...) error

+ ListVpcConnectionsPagesWithContext func(aws.Context, *kafka.ListVpcConnectionsInput, ...) error

+ ListVpcConnectionsRequest func(*kafka.ListVpcConnectionsInput) (*request.Request, *kafka.ListVpcConnectionsOutput)

+ ListVpcConnectionsWithContext func(aws.Context, *kafka.ListVpcConnectionsInput, ...request.Option) (*kafka.ListVpcConnectionsOutput, error)

+ PutClusterPolicy func(*kafka.PutClusterPolicyInput) (*kafka.PutClusterPolicyOutput, error)

+ PutClusterPolicyRequest func(*kafka.PutClusterPolicyInput) (*request.Request, *kafka.PutClusterPolicyOutput)

+ PutClusterPolicyWithContext func(aws.Context, *kafka.PutClusterPolicyInput, ...request.Option) (*kafka.PutClusterPolicyOutput, error)

+ RejectClientVpcConnection func(*kafka.RejectClientVpcConnectionInput) (*kafka.RejectClientVpcConnectionOutput, error)

+ RejectClientVpcConnectionRequest func(*kafka.RejectClientVpcConnectionInput) (*request.Request, *kafka.RejectClientVpcConnectionOutput)

+ RejectClientVpcConnectionWithContext func(aws.Context, *kafka.RejectClientVpcConnectionInput, ...request.Option) (*kafka.RejectClientVpcConnectionOutput, error)

+ UpdateConnectivity func(*kafka.UpdateConnectivityInput) (*kafka.UpdateConnectivityOutput, error)

+ UpdateConnectivityRequest func(*kafka.UpdateConnectivityInput) (*request.Request, *kafka.UpdateConnectivityOutput)

+ UpdateConnectivityWithContext func(aws.Context, *kafka.UpdateConnectivityInput, ...request.Option) (*kafka.UpdateConnectivityOutput, error)

+ UpdateStorage func(*kafka.UpdateStorageInput) (*kafka.UpdateStorageOutput, error)

+ UpdateStorageRequest func(*kafka.UpdateStorageInput) (*request.Request, *kafka.UpdateStorageOutput)

+ UpdateStorageWithContext func(aws.Context, *kafka.UpdateStorageInput, ...request.Option) (*kafka.UpdateStorageOutput, error)

v1.42.6

Nov 15, 2021

Changes in this version

+ type KafkaAPI interface

+ BatchAssociateScramSecret func(*kafka.BatchAssociateScramSecretInput) (*kafka.BatchAssociateScramSecretOutput, error)

+ BatchAssociateScramSecretRequest func(*kafka.BatchAssociateScramSecretInput) (*request.Request, *kafka.BatchAssociateScramSecretOutput)

+ BatchAssociateScramSecretWithContext func(aws.Context, *kafka.BatchAssociateScramSecretInput, ...request.Option) (*kafka.BatchAssociateScramSecretOutput, error)

+ BatchDisassociateScramSecret func(*kafka.BatchDisassociateScramSecretInput) (*kafka.BatchDisassociateScramSecretOutput, error)

+ BatchDisassociateScramSecretRequest func(*kafka.BatchDisassociateScramSecretInput) (*request.Request, *kafka.BatchDisassociateScramSecretOutput)

+ BatchDisassociateScramSecretWithContext func(aws.Context, *kafka.BatchDisassociateScramSecretInput, ...request.Option) (*kafka.BatchDisassociateScramSecretOutput, error)

+ CreateCluster func(*kafka.CreateClusterInput) (*kafka.CreateClusterOutput, error)

+ CreateClusterRequest func(*kafka.CreateClusterInput) (*request.Request, *kafka.CreateClusterOutput)

+ CreateClusterWithContext func(aws.Context, *kafka.CreateClusterInput, ...request.Option) (*kafka.CreateClusterOutput, error)

+ CreateConfiguration func(*kafka.CreateConfigurationInput) (*kafka.CreateConfigurationOutput, error)

+ CreateConfigurationRequest func(*kafka.CreateConfigurationInput) (*request.Request, *kafka.CreateConfigurationOutput)

+ CreateConfigurationWithContext func(aws.Context, *kafka.CreateConfigurationInput, ...request.Option) (*kafka.CreateConfigurationOutput, error)

+ DeleteCluster func(*kafka.DeleteClusterInput) (*kafka.DeleteClusterOutput, error)

+ DeleteClusterRequest func(*kafka.DeleteClusterInput) (*request.Request, *kafka.DeleteClusterOutput)

+ DeleteClusterWithContext func(aws.Context, *kafka.DeleteClusterInput, ...request.Option) (*kafka.DeleteClusterOutput, error)

+ DeleteConfiguration func(*kafka.DeleteConfigurationInput) (*kafka.DeleteConfigurationOutput, error)

+ DeleteConfigurationRequest func(*kafka.DeleteConfigurationInput) (*request.Request, *kafka.DeleteConfigurationOutput)

+ DeleteConfigurationWithContext func(aws.Context, *kafka.DeleteConfigurationInput, ...request.Option) (*kafka.DeleteConfigurationOutput, error)

+ DescribeCluster func(*kafka.DescribeClusterInput) (*kafka.DescribeClusterOutput, error)

+ DescribeClusterOperation func(*kafka.DescribeClusterOperationInput) (*kafka.DescribeClusterOperationOutput, error)

+ DescribeClusterOperationRequest func(*kafka.DescribeClusterOperationInput) (*request.Request, *kafka.DescribeClusterOperationOutput)

+ DescribeClusterOperationWithContext func(aws.Context, *kafka.DescribeClusterOperationInput, ...request.Option) (*kafka.DescribeClusterOperationOutput, error)

+ DescribeClusterRequest func(*kafka.DescribeClusterInput) (*request.Request, *kafka.DescribeClusterOutput)

+ DescribeClusterWithContext func(aws.Context, *kafka.DescribeClusterInput, ...request.Option) (*kafka.DescribeClusterOutput, error)

+ DescribeConfiguration func(*kafka.DescribeConfigurationInput) (*kafka.DescribeConfigurationOutput, error)

+ DescribeConfigurationRequest func(*kafka.DescribeConfigurationInput) (*request.Request, *kafka.DescribeConfigurationOutput)

+ DescribeConfigurationRevision func(*kafka.DescribeConfigurationRevisionInput) (*kafka.DescribeConfigurationRevisionOutput, error)

+ DescribeConfigurationRevisionRequest func(*kafka.DescribeConfigurationRevisionInput) (*request.Request, *kafka.DescribeConfigurationRevisionOutput)

+ DescribeConfigurationRevisionWithContext func(aws.Context, *kafka.DescribeConfigurationRevisionInput, ...request.Option) (*kafka.DescribeConfigurationRevisionOutput, error)

+ DescribeConfigurationWithContext func(aws.Context, *kafka.DescribeConfigurationInput, ...request.Option) (*kafka.DescribeConfigurationOutput, error)

+ GetBootstrapBrokers func(*kafka.GetBootstrapBrokersInput) (*kafka.GetBootstrapBrokersOutput, error)

+ GetBootstrapBrokersRequest func(*kafka.GetBootstrapBrokersInput) (*request.Request, *kafka.GetBootstrapBrokersOutput)

+ GetBootstrapBrokersWithContext func(aws.Context, *kafka.GetBootstrapBrokersInput, ...request.Option) (*kafka.GetBootstrapBrokersOutput, error)

+ GetCompatibleKafkaVersions func(*kafka.GetCompatibleKafkaVersionsInput) (*kafka.GetCompatibleKafkaVersionsOutput, error)

+ GetCompatibleKafkaVersionsRequest func(*kafka.GetCompatibleKafkaVersionsInput) (*request.Request, *kafka.GetCompatibleKafkaVersionsOutput)

+ GetCompatibleKafkaVersionsWithContext func(aws.Context, *kafka.GetCompatibleKafkaVersionsInput, ...request.Option) (*kafka.GetCompatibleKafkaVersionsOutput, error)

+ ListClusterOperations func(*kafka.ListClusterOperationsInput) (*kafka.ListClusterOperationsOutput, error)

+ ListClusterOperationsPages func(*kafka.ListClusterOperationsInput, ...) error

+ ListClusterOperationsPagesWithContext func(aws.Context, *kafka.ListClusterOperationsInput, ...) error

+ ListClusterOperationsRequest func(*kafka.ListClusterOperationsInput) (*request.Request, *kafka.ListClusterOperationsOutput)

+ ListClusterOperationsWithContext func(aws.Context, *kafka.ListClusterOperationsInput, ...request.Option) (*kafka.ListClusterOperationsOutput, error)

+ ListClusters func(*kafka.ListClustersInput) (*kafka.ListClustersOutput, error)

+ ListClustersPages func(*kafka.ListClustersInput, func(*kafka.ListClustersOutput, bool) bool) error

+ ListClustersPagesWithContext func(aws.Context, *kafka.ListClustersInput, ...) error

+ ListClustersRequest func(*kafka.ListClustersInput) (*request.Request, *kafka.ListClustersOutput)

+ ListClustersWithContext func(aws.Context, *kafka.ListClustersInput, ...request.Option) (*kafka.ListClustersOutput, error)

+ ListConfigurationRevisions func(*kafka.ListConfigurationRevisionsInput) (*kafka.ListConfigurationRevisionsOutput, error)

+ ListConfigurationRevisionsPages func(*kafka.ListConfigurationRevisionsInput, ...) error

+ ListConfigurationRevisionsPagesWithContext func(aws.Context, *kafka.ListConfigurationRevisionsInput, ...) error

+ ListConfigurationRevisionsRequest func(*kafka.ListConfigurationRevisionsInput) (*request.Request, *kafka.ListConfigurationRevisionsOutput)

+ ListConfigurationRevisionsWithContext func(aws.Context, *kafka.ListConfigurationRevisionsInput, ...request.Option) (*kafka.ListConfigurationRevisionsOutput, error)

+ ListConfigurations func(*kafka.ListConfigurationsInput) (*kafka.ListConfigurationsOutput, error)

+ ListConfigurationsPages func(*kafka.ListConfigurationsInput, ...) error

+ ListConfigurationsPagesWithContext func(aws.Context, *kafka.ListConfigurationsInput, ...) error

+ ListConfigurationsRequest func(*kafka.ListConfigurationsInput) (*request.Request, *kafka.ListConfigurationsOutput)

+ ListConfigurationsWithContext func(aws.Context, *kafka.ListConfigurationsInput, ...request.Option) (*kafka.ListConfigurationsOutput, error)

+ ListKafkaVersions func(*kafka.ListKafkaVersionsInput) (*kafka.ListKafkaVersionsOutput, error)

+ ListKafkaVersionsPages func(*kafka.ListKafkaVersionsInput, func(*kafka.ListKafkaVersionsOutput, bool) bool) error

+ ListKafkaVersionsPagesWithContext func(aws.Context, *kafka.ListKafkaVersionsInput, ...) error

+ ListKafkaVersionsRequest func(*kafka.ListKafkaVersionsInput) (*request.Request, *kafka.ListKafkaVersionsOutput)

+ ListKafkaVersionsWithContext func(aws.Context, *kafka.ListKafkaVersionsInput, ...request.Option) (*kafka.ListKafkaVersionsOutput, error)

+ ListNodes func(*kafka.ListNodesInput) (*kafka.ListNodesOutput, error)

+ ListNodesPages func(*kafka.ListNodesInput, func(*kafka.ListNodesOutput, bool) bool) error

+ ListNodesPagesWithContext func(aws.Context, *kafka.ListNodesInput, func(*kafka.ListNodesOutput, bool) bool, ...) error

+ ListNodesRequest func(*kafka.ListNodesInput) (*request.Request, *kafka.ListNodesOutput)

+ ListNodesWithContext func(aws.Context, *kafka.ListNodesInput, ...request.Option) (*kafka.ListNodesOutput, error)

+ ListScramSecrets func(*kafka.ListScramSecretsInput) (*kafka.ListScramSecretsOutput, error)

+ ListScramSecretsPages func(*kafka.ListScramSecretsInput, func(*kafka.ListScramSecretsOutput, bool) bool) error

+ ListScramSecretsPagesWithContext func(aws.Context, *kafka.ListScramSecretsInput, ...) error

+ ListScramSecretsRequest func(*kafka.ListScramSecretsInput) (*request.Request, *kafka.ListScramSecretsOutput)

+ ListScramSecretsWithContext func(aws.Context, *kafka.ListScramSecretsInput, ...request.Option) (*kafka.ListScramSecretsOutput, error)

+ ListTagsForResource func(*kafka.ListTagsForResourceInput) (*kafka.ListTagsForResourceOutput, error)

+ ListTagsForResourceRequest func(*kafka.ListTagsForResourceInput) (*request.Request, *kafka.ListTagsForResourceOutput)

+ ListTagsForResourceWithContext func(aws.Context, *kafka.ListTagsForResourceInput, ...request.Option) (*kafka.ListTagsForResourceOutput, error)

+ RebootBroker func(*kafka.RebootBrokerInput) (*kafka.RebootBrokerOutput, error)

+ RebootBrokerRequest func(*kafka.RebootBrokerInput) (*request.Request, *kafka.RebootBrokerOutput)

+ RebootBrokerWithContext func(aws.Context, *kafka.RebootBrokerInput, ...request.Option) (*kafka.RebootBrokerOutput, error)

+ TagResource func(*kafka.TagResourceInput) (*kafka.TagResourceOutput, error)

+ TagResourceRequest func(*kafka.TagResourceInput) (*request.Request, *kafka.TagResourceOutput)

+ TagResourceWithContext func(aws.Context, *kafka.TagResourceInput, ...request.Option) (*kafka.TagResourceOutput, error)

+ UntagResource func(*kafka.UntagResourceInput) (*kafka.UntagResourceOutput, error)

+ UntagResourceRequest func(*kafka.UntagResourceInput) (*request.Request, *kafka.UntagResourceOutput)

+ UntagResourceWithContext func(aws.Context, *kafka.UntagResourceInput, ...request.Option) (*kafka.UntagResourceOutput, error)

+ UpdateBrokerCount func(*kafka.UpdateBrokerCountInput) (*kafka.UpdateBrokerCountOutput, error)

+ UpdateBrokerCountRequest func(*kafka.UpdateBrokerCountInput) (*request.Request, *kafka.UpdateBrokerCountOutput)

+ UpdateBrokerCountWithContext func(aws.Context, *kafka.UpdateBrokerCountInput, ...request.Option) (*kafka.UpdateBrokerCountOutput, error)

+ UpdateBrokerStorage func(*kafka.UpdateBrokerStorageInput) (*kafka.UpdateBrokerStorageOutput, error)

+ UpdateBrokerStorageRequest func(*kafka.UpdateBrokerStorageInput) (*request.Request, *kafka.UpdateBrokerStorageOutput)

+ UpdateBrokerStorageWithContext func(aws.Context, *kafka.UpdateBrokerStorageInput, ...request.Option) (*kafka.UpdateBrokerStorageOutput, error)

+ UpdateBrokerType func(*kafka.UpdateBrokerTypeInput) (*kafka.UpdateBrokerTypeOutput, error)

+ UpdateBrokerTypeRequest func(*kafka.UpdateBrokerTypeInput) (*request.Request, *kafka.UpdateBrokerTypeOutput)

+ UpdateBrokerTypeWithContext func(aws.Context, *kafka.UpdateBrokerTypeInput, ...request.Option) (*kafka.UpdateBrokerTypeOutput, error)

+ UpdateClusterConfiguration func(*kafka.UpdateClusterConfigurationInput) (*kafka.UpdateClusterConfigurationOutput, error)

+ UpdateClusterConfigurationRequest func(*kafka.UpdateClusterConfigurationInput) (*request.Request, *kafka.UpdateClusterConfigurationOutput)

+ UpdateClusterConfigurationWithContext func(aws.Context, *kafka.UpdateClusterConfigurationInput, ...request.Option) (*kafka.UpdateClusterConfigurationOutput, error)

+ UpdateClusterKafkaVersion func(*kafka.UpdateClusterKafkaVersionInput) (*kafka.UpdateClusterKafkaVersionOutput, error)

+ UpdateClusterKafkaVersionRequest func(*kafka.UpdateClusterKafkaVersionInput) (*request.Request, *kafka.UpdateClusterKafkaVersionOutput)

+ UpdateClusterKafkaVersionWithContext func(aws.Context, *kafka.UpdateClusterKafkaVersionInput, ...request.Option) (*kafka.UpdateClusterKafkaVersionOutput, error)

+ UpdateConfiguration func(*kafka.UpdateConfigurationInput) (*kafka.UpdateConfigurationOutput, error)

+ UpdateConfigurationRequest func(*kafka.UpdateConfigurationInput) (*request.Request, *kafka.UpdateConfigurationOutput)

+ UpdateConfigurationWithContext func(aws.Context, *kafka.UpdateConfigurationInput, ...request.Option) (*kafka.UpdateConfigurationOutput, error)

+ UpdateMonitoring func(*kafka.UpdateMonitoringInput) (*kafka.UpdateMonitoringOutput, error)

+ UpdateMonitoringRequest func(*kafka.UpdateMonitoringInput) (*request.Request, *kafka.UpdateMonitoringOutput)

+ UpdateMonitoringWithContext func(aws.Context, *kafka.UpdateMonitoringInput, ...request.Option) (*kafka.UpdateMonitoringOutput, error)

+ UpdateSecurity func(*kafka.UpdateSecurityInput) (*kafka.UpdateSecurityOutput, error)

+ UpdateSecurityRequest func(*kafka.UpdateSecurityInput) (*request.Request, *kafka.UpdateSecurityOutput)

+ UpdateSecurityWithContext func(aws.Context, *kafka.UpdateSecurityInput, ...request.Option) (*kafka.UpdateSecurityOutput, error)