...
AWS SDK for Go API Reference
import "github.com/aws/aws-sdk-go/service/kafka"
Overview
Constants

Overview ▾

Package kafka provides the client and types for making API requests to Managed Streaming for Kafka.

The operations for managing an Amazon MSK cluster.

See https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14 for more information on this service.

See kafka package documentation for more information. https://docs.aws.amazon.com/sdk-for-go/api/service/kafka/

Using the Client

To contact Managed Streaming for Kafka with the SDK use the New function to create a new service client. With that client you can make API requests to the service. These clients are safe to use concurrently.

See the SDK's documentation for more information on how to use the SDK. https://docs.aws.amazon.com/sdk-for-go/api/

See aws.Config documentation for more information on configuring SDK clients. https://docs.aws.amazon.com/sdk-for-go/api/aws/#Config

See the Managed Streaming for Kafka client Kafka for more information on creating client for this service. https://docs.aws.amazon.com/sdk-for-go/api/service/kafka/#New

The stub package, kafkaiface, can be used to provide alternative implementations of service clients, such as mocking the client for testing.

Operations ▾

func New(p client.ConfigProvider, cfgs ...*aws.Config) *Kafka
    CreateCluster
    CreateClusterRequest
    CreateClusterWithContext
    CreateConfiguration
    CreateConfigurationRequest
    CreateConfigurationWithContext
    DeleteCluster
    DeleteClusterRequest
    DeleteClusterWithContext
    DescribeCluster
    DescribeClusterOperation
    DescribeClusterOperationRequest
    DescribeClusterOperationWithContext
    DescribeClusterRequest
    DescribeClusterWithContext
    DescribeConfiguration
    DescribeConfigurationRequest
    DescribeConfigurationRevision
    DescribeConfigurationRevisionRequest
    DescribeConfigurationRevisionWithContext
    DescribeConfigurationWithContext
    GetBootstrapBrokers
    GetBootstrapBrokersRequest
    GetBootstrapBrokersWithContext
    ListClusterOperations
    ListClusterOperationsPagesWithContext
    ListClusterOperationsRequest
    ListClusterOperationsWithContext
    ListClusters
    ListClustersPagesWithContext
    ListClustersRequest
    ListClustersWithContext
    ListConfigurationRevisions
    ListConfigurationRevisionsPagesWithContext
    ListConfigurationRevisionsRequest
    ListConfigurationRevisionsWithContext
    ListConfigurations
    ListConfigurationsPagesWithContext
    ListConfigurationsRequest
    ListConfigurationsWithContext
    ListNodes
    ListNodesPagesWithContext
    ListNodesRequest
    ListNodesWithContext
    ListTagsForResource
    ListTagsForResourceRequest
    ListTagsForResourceWithContext
    TagResource
    TagResourceRequest
    TagResourceWithContext
    UntagResource
    UntagResourceRequest
    UntagResourceWithContext
    UpdateBrokerCount
    UpdateBrokerCountRequest
    UpdateBrokerCountWithContext
    UpdateBrokerStorage
    UpdateBrokerStorageRequest
    UpdateBrokerStorageWithContext
    UpdateClusterConfiguration
    UpdateClusterConfigurationRequest
    UpdateClusterConfigurationWithContext

Types ▾

type BrokerEBSVolumeInfo
func (s *BrokerEBSVolumeInfo) SetKafkaBrokerNodeId(v string) *BrokerEBSVolumeInfo
func (s *BrokerEBSVolumeInfo) SetVolumeSizeGB(v int64) *BrokerEBSVolumeInfo
type BrokerNodeGroupInfo
func (s *BrokerNodeGroupInfo) SetBrokerAZDistribution(v string) *BrokerNodeGroupInfo
func (s *BrokerNodeGroupInfo) SetClientSubnets(v []*string) *BrokerNodeGroupInfo
func (s *BrokerNodeGroupInfo) SetInstanceType(v string) *BrokerNodeGroupInfo
func (s *BrokerNodeGroupInfo) SetSecurityGroups(v []*string) *BrokerNodeGroupInfo
func (s *BrokerNodeGroupInfo) SetStorageInfo(v *StorageInfo) *BrokerNodeGroupInfo
type BrokerNodeInfo
func (s *BrokerNodeInfo) SetAttachedENIId(v string) *BrokerNodeInfo
func (s *BrokerNodeInfo) SetBrokerId(v float64) *BrokerNodeInfo
func (s *BrokerNodeInfo) SetClientSubnet(v string) *BrokerNodeInfo
func (s *BrokerNodeInfo) SetClientVpcIpAddress(v string) *BrokerNodeInfo
func (s *BrokerNodeInfo) SetCurrentBrokerSoftwareInfo(v *BrokerSoftwareInfo) *BrokerNodeInfo
func (s *BrokerNodeInfo) SetEndpoints(v []*string) *BrokerNodeInfo
type BrokerSoftwareInfo
func (s *BrokerSoftwareInfo) SetConfigurationArn(v string) *BrokerSoftwareInfo
func (s *BrokerSoftwareInfo) SetConfigurationRevision(v int64) *BrokerSoftwareInfo
func (s *BrokerSoftwareInfo) SetKafkaVersion(v string) *BrokerSoftwareInfo
type ClientAuthentication
func (s *ClientAuthentication) SetTls(v *Tls) *ClientAuthentication
type ClusterInfo
func (s *ClusterInfo) SetActiveOperationArn(v string) *ClusterInfo
func (s *ClusterInfo) SetBrokerNodeGroupInfo(v *BrokerNodeGroupInfo) *ClusterInfo
func (s *ClusterInfo) SetClientAuthentication(v *ClientAuthentication) *ClusterInfo
func (s *ClusterInfo) SetClusterArn(v string) *ClusterInfo
func (s *ClusterInfo) SetClusterName(v string) *ClusterInfo
func (s *ClusterInfo) SetCreationTime(v time.Time) *ClusterInfo
func (s *ClusterInfo) SetCurrentBrokerSoftwareInfo(v *BrokerSoftwareInfo) *ClusterInfo
func (s *ClusterInfo) SetCurrentVersion(v string) *ClusterInfo
func (s *ClusterInfo) SetEncryptionInfo(v *EncryptionInfo) *ClusterInfo
func (s *ClusterInfo) SetEnhancedMonitoring(v string) *ClusterInfo
func (s *ClusterInfo) SetNumberOfBrokerNodes(v int64) *ClusterInfo
func (s *ClusterInfo) SetState(v string) *ClusterInfo
func (s *ClusterInfo) SetTags(v map[string]*string) *ClusterInfo
func (s *ClusterInfo) SetZookeeperConnectString(v string) *ClusterInfo
type ClusterOperationInfo
func (s *ClusterOperationInfo) SetClientRequestId(v string) *ClusterOperationInfo
func (s *ClusterOperationInfo) SetClusterArn(v string) *ClusterOperationInfo
func (s *ClusterOperationInfo) SetCreationTime(v time.Time) *ClusterOperationInfo
func (s *ClusterOperationInfo) SetEndTime(v time.Time) *ClusterOperationInfo
func (s *ClusterOperationInfo) SetErrorInfo(v *ErrorInfo) *ClusterOperationInfo
func (s *ClusterOperationInfo) SetOperationArn(v string) *ClusterOperationInfo
func (s *ClusterOperationInfo) SetOperationState(v string) *ClusterOperationInfo
func (s *ClusterOperationInfo) SetOperationType(v string) *ClusterOperationInfo
func (s *ClusterOperationInfo) SetSourceClusterInfo(v *MutableClusterInfo) *ClusterOperationInfo
func (s *ClusterOperationInfo) SetTargetClusterInfo(v *MutableClusterInfo) *ClusterOperationInfo
type Configuration
func (s *Configuration) SetArn(v string) *Configuration
func (s *Configuration) SetCreationTime(v time.Time) *Configuration
func (s *Configuration) SetDescription(v string) *Configuration
func (s *Configuration) SetKafkaVersions(v []*string) *Configuration
func (s *Configuration) SetLatestRevision(v *ConfigurationRevision) *Configuration
func (s *Configuration) SetName(v string) *Configuration
type ConfigurationInfo
func (s *ConfigurationInfo) SetArn(v string) *ConfigurationInfo
func (s *ConfigurationInfo) SetRevision(v int64) *ConfigurationInfo
type ConfigurationRevision
func (s *ConfigurationRevision) SetCreationTime(v time.Time) *ConfigurationRevision
func (s *ConfigurationRevision) SetDescription(v string) *ConfigurationRevision
func (s *ConfigurationRevision) SetRevision(v int64) *ConfigurationRevision
type CreateClusterInput
func (s *CreateClusterInput) SetBrokerNodeGroupInfo(v *BrokerNodeGroupInfo) *CreateClusterInput
func (s *CreateClusterInput) SetClientAuthentication(v *ClientAuthentication) *CreateClusterInput
func (s *CreateClusterInput) SetClusterName(v string) *CreateClusterInput
func (s *CreateClusterInput) SetConfigurationInfo(v *ConfigurationInfo) *CreateClusterInput
func (s *CreateClusterInput) SetEncryptionInfo(v *EncryptionInfo) *CreateClusterInput
func (s *CreateClusterInput) SetEnhancedMonitoring(v string) *CreateClusterInput
func (s *CreateClusterInput) SetKafkaVersion(v string) *CreateClusterInput
func (s *CreateClusterInput) SetNumberOfBrokerNodes(v int64) *CreateClusterInput
func (s *CreateClusterInput) SetTags(v map[string]*string) *CreateClusterInput
type CreateClusterOutput
func (s *CreateClusterOutput) SetClusterArn(v string) *CreateClusterOutput
func (s *CreateClusterOutput) SetClusterName(v string) *CreateClusterOutput
func (s *CreateClusterOutput) SetState(v string) *CreateClusterOutput
type CreateConfigurationInput
func (s *CreateConfigurationInput) SetDescription(v string) *CreateConfigurationInput
func (s *CreateConfigurationInput) SetKafkaVersions(v []*string) *CreateConfigurationInput
func (s *CreateConfigurationInput) SetName(v string) *CreateConfigurationInput
func (s *CreateConfigurationInput) SetServerProperties(v []byte) *CreateConfigurationInput
type CreateConfigurationOutput
func (s *CreateConfigurationOutput) SetArn(v string) *CreateConfigurationOutput
func (s *CreateConfigurationOutput) SetCreationTime(v time.Time) *CreateConfigurationOutput
func (s *CreateConfigurationOutput) SetLatestRevision(v *ConfigurationRevision) *CreateConfigurationOutput
func (s *CreateConfigurationOutput) SetName(v string) *CreateConfigurationOutput
type DeleteClusterInput
func (s *DeleteClusterInput) SetClusterArn(v string) *DeleteClusterInput
func (s *DeleteClusterInput) SetCurrentVersion(v string) *DeleteClusterInput
type DeleteClusterOutput
func (s *DeleteClusterOutput) SetClusterArn(v string) *DeleteClusterOutput
func (s *DeleteClusterOutput) SetState(v string) *DeleteClusterOutput
type DescribeClusterInput
func (s *DescribeClusterInput) SetClusterArn(v string) *DescribeClusterInput
type DescribeClusterOperationInput
func (s *DescribeClusterOperationInput) SetClusterOperationArn(v string) *DescribeClusterOperationInput
type DescribeClusterOperationOutput
func (s *DescribeClusterOperationOutput) SetClusterOperationInfo(v *ClusterOperationInfo) *DescribeClusterOperationOutput
type DescribeClusterOutput
func (s *DescribeClusterOutput) SetClusterInfo(v *ClusterInfo) *DescribeClusterOutput
type DescribeConfigurationInput
func (s *DescribeConfigurationInput) SetArn(v string) *DescribeConfigurationInput
type DescribeConfigurationOutput
func (s *DescribeConfigurationOutput) SetArn(v string) *DescribeConfigurationOutput
func (s *DescribeConfigurationOutput) SetCreationTime(v time.Time) *DescribeConfigurationOutput
func (s *DescribeConfigurationOutput) SetDescription(v string) *DescribeConfigurationOutput
func (s *DescribeConfigurationOutput) SetKafkaVersions(v []*string) *DescribeConfigurationOutput
func (s *DescribeConfigurationOutput) SetLatestRevision(v *ConfigurationRevision) *DescribeConfigurationOutput
func (s *DescribeConfigurationOutput) SetName(v string) *DescribeConfigurationOutput
type DescribeConfigurationRevisionInput
func (s *DescribeConfigurationRevisionInput) SetArn(v string) *DescribeConfigurationRevisionInput
func (s *DescribeConfigurationRevisionInput) SetRevision(v int64) *DescribeConfigurationRevisionInput
type DescribeConfigurationRevisionOutput
func (s *DescribeConfigurationRevisionOutput) SetArn(v string) *DescribeConfigurationRevisionOutput
func (s *DescribeConfigurationRevisionOutput) SetCreationTime(v time.Time) *DescribeConfigurationRevisionOutput
func (s *DescribeConfigurationRevisionOutput) SetDescription(v string) *DescribeConfigurationRevisionOutput
func (s *DescribeConfigurationRevisionOutput) SetRevision(v int64) *DescribeConfigurationRevisionOutput
func (s *DescribeConfigurationRevisionOutput) SetServerProperties(v []byte) *DescribeConfigurationRevisionOutput
type EBSStorageInfo
func (s *EBSStorageInfo) SetVolumeSize(v int64) *EBSStorageInfo
type EncryptionAtRest
func (s *EncryptionAtRest) SetDataVolumeKMSKeyId(v string) *EncryptionAtRest
type EncryptionInTransit
func (s *EncryptionInTransit) SetClientBroker(v string) *EncryptionInTransit
func (s *EncryptionInTransit) SetInCluster(v bool) *EncryptionInTransit
type EncryptionInfo
func (s *EncryptionInfo) SetEncryptionAtRest(v *EncryptionAtRest) *EncryptionInfo
func (s *EncryptionInfo) SetEncryptionInTransit(v *EncryptionInTransit) *EncryptionInfo
type ErrorInfo
func (s *ErrorInfo) SetErrorCode(v string) *ErrorInfo
func (s *ErrorInfo) SetErrorString(v string) *ErrorInfo
type GetBootstrapBrokersInput
func (s *GetBootstrapBrokersInput) SetClusterArn(v string) *GetBootstrapBrokersInput
type GetBootstrapBrokersOutput
func (s *GetBootstrapBrokersOutput) SetBootstrapBrokerString(v string) *GetBootstrapBrokersOutput
func (s *GetBootstrapBrokersOutput) SetBootstrapBrokerStringTls(v string) *GetBootstrapBrokersOutput
type Kafka
type ListClusterOperationsInput
func (s *ListClusterOperationsInput) SetClusterArn(v string) *ListClusterOperationsInput
func (s *ListClusterOperationsInput) SetMaxResults(v int64) *ListClusterOperationsInput
func (s *ListClusterOperationsInput) SetNextToken(v string) *ListClusterOperationsInput
type ListClusterOperationsOutput
func (s *ListClusterOperationsOutput) SetClusterOperationInfoList(v []*ClusterOperationInfo) *ListClusterOperationsOutput
func (s *ListClusterOperationsOutput) SetNextToken(v string) *ListClusterOperationsOutput
type ListClustersInput
func (s *ListClustersInput) SetClusterNameFilter(v string) *ListClustersInput
func (s *ListClustersInput) SetMaxResults(v int64) *ListClustersInput
func (s *ListClustersInput) SetNextToken(v string) *ListClustersInput
type ListClustersOutput
func (s *ListClustersOutput) SetClusterInfoList(v []*ClusterInfo) *ListClustersOutput
func (s *ListClustersOutput) SetNextToken(v string) *ListClustersOutput
type ListConfigurationRevisionsInput
func (s *ListConfigurationRevisionsInput) SetArn(v string) *ListConfigurationRevisionsInput
func (s *ListConfigurationRevisionsInput) SetMaxResults(v int64) *ListConfigurationRevisionsInput
func (s *ListConfigurationRevisionsInput) SetNextToken(v string) *ListConfigurationRevisionsInput
type ListConfigurationRevisionsOutput
func (s *ListConfigurationRevisionsOutput) SetNextToken(v string) *ListConfigurationRevisionsOutput
func (s *ListConfigurationRevisionsOutput) SetRevisions(v []*ConfigurationRevision) *ListConfigurationRevisionsOutput
type ListConfigurationsInput
func (s *ListConfigurationsInput) SetMaxResults(v int64) *ListConfigurationsInput
func (s *ListConfigurationsInput) SetNextToken(v string) *ListConfigurationsInput
type ListConfigurationsOutput
func (s *ListConfigurationsOutput) SetConfigurations(v []*Configuration) *ListConfigurationsOutput
func (s *ListConfigurationsOutput) SetNextToken(v string) *ListConfigurationsOutput
type ListNodesInput
func (s *ListNodesInput) SetClusterArn(v string) *ListNodesInput
func (s *ListNodesInput) SetMaxResults(v int64) *ListNodesInput
func (s *ListNodesInput) SetNextToken(v string) *ListNodesInput
type ListNodesOutput
func (s *ListNodesOutput) SetNextToken(v string) *ListNodesOutput
func (s *ListNodesOutput) SetNodeInfoList(v []*NodeInfo) *ListNodesOutput
type ListTagsForResourceInput
func (s *ListTagsForResourceInput) SetResourceArn(v string) *ListTagsForResourceInput
type ListTagsForResourceOutput
func (s *ListTagsForResourceOutput) SetTags(v map[string]*string) *ListTagsForResourceOutput
type MutableClusterInfo
func (s *MutableClusterInfo) SetBrokerEBSVolumeInfo(v []*BrokerEBSVolumeInfo) *MutableClusterInfo
func (s *MutableClusterInfo) SetConfigurationInfo(v *ConfigurationInfo) *MutableClusterInfo
func (s *MutableClusterInfo) SetNumberOfBrokerNodes(v int64) *MutableClusterInfo
type NodeInfo
func (s *NodeInfo) SetAddedToClusterTime(v string) *NodeInfo
func (s *NodeInfo) SetBrokerNodeInfo(v *BrokerNodeInfo) *NodeInfo
func (s *NodeInfo) SetInstanceType(v string) *NodeInfo
func (s *NodeInfo) SetNodeARN(v string) *NodeInfo
func (s *NodeInfo) SetNodeType(v string) *NodeInfo
func (s *NodeInfo) SetZookeeperNodeInfo(v *ZookeeperNodeInfo) *NodeInfo
type StorageInfo
func (s *StorageInfo) SetEbsStorageInfo(v *EBSStorageInfo) *StorageInfo
type TagResourceInput
func (s *TagResourceInput) SetResourceArn(v string) *TagResourceInput
func (s *TagResourceInput) SetTags(v map[string]*string) *TagResourceInput
type TagResourceOutput
type Tls
func (s *Tls) SetCertificateAuthorityArnList(v []*string) *Tls
type UntagResourceInput
func (s *UntagResourceInput) SetResourceArn(v string) *UntagResourceInput
func (s *UntagResourceInput) SetTagKeys(v []*string) *UntagResourceInput
type UntagResourceOutput
type UpdateBrokerCountInput
func (s *UpdateBrokerCountInput) SetClusterArn(v string) *UpdateBrokerCountInput
func (s *UpdateBrokerCountInput) SetCurrentVersion(v string) *UpdateBrokerCountInput
func (s *UpdateBrokerCountInput) SetTargetNumberOfBrokerNodes(v int64) *UpdateBrokerCountInput
type UpdateBrokerCountOutput
func (s *UpdateBrokerCountOutput) SetClusterArn(v string) *UpdateBrokerCountOutput
func (s *UpdateBrokerCountOutput) SetClusterOperationArn(v string) *UpdateBrokerCountOutput
type UpdateBrokerStorageInput
func (s *UpdateBrokerStorageInput) SetClusterArn(v string) *UpdateBrokerStorageInput
func (s *UpdateBrokerStorageInput) SetCurrentVersion(v string) *UpdateBrokerStorageInput
func (s *UpdateBrokerStorageInput) SetTargetBrokerEBSVolumeInfo(v []*BrokerEBSVolumeInfo) *UpdateBrokerStorageInput
type UpdateBrokerStorageOutput
func (s *UpdateBrokerStorageOutput) SetClusterArn(v string) *UpdateBrokerStorageOutput
func (s *UpdateBrokerStorageOutput) SetClusterOperationArn(v string) *UpdateBrokerStorageOutput
type UpdateClusterConfigurationInput
func (s *UpdateClusterConfigurationInput) SetClusterArn(v string) *UpdateClusterConfigurationInput
func (s *UpdateClusterConfigurationInput) SetConfigurationInfo(v *ConfigurationInfo) *UpdateClusterConfigurationInput
func (s *UpdateClusterConfigurationInput) SetCurrentVersion(v string) *UpdateClusterConfigurationInput
type UpdateClusterConfigurationOutput
func (s *UpdateClusterConfigurationOutput) SetClusterArn(v string) *UpdateClusterConfigurationOutput
func (s *UpdateClusterConfigurationOutput) SetClusterOperationArn(v string) *UpdateClusterConfigurationOutput
type ZookeeperNodeInfo
func (s *ZookeeperNodeInfo) SetAttachedENIId(v string) *ZookeeperNodeInfo
func (s *ZookeeperNodeInfo) SetClientVpcIpAddress(v string) *ZookeeperNodeInfo
func (s *ZookeeperNodeInfo) SetEndpoints(v []*string) *ZookeeperNodeInfo
func (s *ZookeeperNodeInfo) SetZookeeperId(v float64) *ZookeeperNodeInfo
func (s *ZookeeperNodeInfo) SetZookeeperVersion(v string) *ZookeeperNodeInfo

Constants ▾

const (
    // ClientBrokerTls is a ClientBroker enum value
    ClientBrokerTls = "TLS"

    // ClientBrokerTlsPlaintext is a ClientBroker enum value
    ClientBrokerTlsPlaintext = "TLS_PLAINTEXT"

    // ClientBrokerPlaintext is a ClientBroker enum value
    ClientBrokerPlaintext = "PLAINTEXT"
)

Client-broker encryption in transit setting.

const (
    // ClusterStateActive is a ClusterState enum value
    ClusterStateActive = "ACTIVE"

    // ClusterStateCreating is a ClusterState enum value
    ClusterStateCreating = "CREATING"

    // ClusterStateUpdating is a ClusterState enum value
    ClusterStateUpdating = "UPDATING"

    // ClusterStateDeleting is a ClusterState enum value
    ClusterStateDeleting = "DELETING"

    // ClusterStateFailed is a ClusterState enum value
    ClusterStateFailed = "FAILED"
)

The state of a Kafka cluster.

const (
    // EnhancedMonitoringDefault is a EnhancedMonitoring enum value
    EnhancedMonitoringDefault = "DEFAULT"

    // EnhancedMonitoringPerBroker is a EnhancedMonitoring enum value
    EnhancedMonitoringPerBroker = "PER_BROKER"

    // EnhancedMonitoringPerTopicPerBroker is a EnhancedMonitoring enum value
    EnhancedMonitoringPerTopicPerBroker = "PER_TOPIC_PER_BROKER"
)

Specifies which metrics are gathered for the MSK cluster. This property has three possible values: DEFAULT, PER_BROKER, and PER_TOPIC_PER_BROKER. For a list of the metrics associated with each of these three levels of monitoring, see Monitoring (https://docs.aws.amazon.com/msk/latest/developerguide/monitoring.html).

const (

    // ErrCodeBadRequestException for service response error code
    // "BadRequestException".
    //
    // Returns information about an error.
    ErrCodeBadRequestException = "BadRequestException"

    // ErrCodeConflictException for service response error code
    // "ConflictException".
    //
    // Returns information about an error.
    ErrCodeConflictException = "ConflictException"

    // ErrCodeForbiddenException for service response error code
    // "ForbiddenException".
    //
    // Returns information about an error.
    ErrCodeForbiddenException = "ForbiddenException"

    // ErrCodeInternalServerErrorException for service response error code
    // "InternalServerErrorException".
    //
    // Returns information about an error.
    ErrCodeInternalServerErrorException = "InternalServerErrorException"

    // ErrCodeNotFoundException for service response error code
    // "NotFoundException".
    //
    // Returns information about an error.
    ErrCodeNotFoundException = "NotFoundException"

    // ErrCodeServiceUnavailableException for service response error code
    // "ServiceUnavailableException".
    //
    // Returns information about an error.
    ErrCodeServiceUnavailableException = "ServiceUnavailableException"

    // ErrCodeTooManyRequestsException for service response error code
    // "TooManyRequestsException".
    //
    // Returns information about an error.
    ErrCodeTooManyRequestsException = "TooManyRequestsException"

    // ErrCodeUnauthorizedException for service response error code
    // "UnauthorizedException".
    //
    // Returns information about an error.
    ErrCodeUnauthorizedException = "UnauthorizedException"
)
const (
    ServiceName = "Kafka" // Name of service.
    EndpointsID = "kafka" // ID to lookup a service endpoint with.
    ServiceID   = "Kafka" // ServiceID is a unique identifer of a specific service.
)

Service information constants

const (
    // BrokerAZDistributionDefault is a BrokerAZDistribution enum value
    BrokerAZDistributionDefault = "DEFAULT"
)

The distribution of broker nodes across Availability Zones. By default, broker nodes are distributed among the Availability Zones of your Region. Currently, the only supported value is DEFAULT. You can either specify this value explicitly or leave it out.

const (
    // NodeTypeBroker is a NodeType enum value
    NodeTypeBroker = "BROKER"
)

The broker or Zookeeper node.

type BrokerEBSVolumeInfo

type BrokerEBSVolumeInfo struct {

    // The ID of the broker to update.
    //
    // KafkaBrokerNodeId is a required field
    KafkaBrokerNodeId *string `locationName:"kafkaBrokerNodeId" type:"string" required:"true"`

    // Size of the EBS volume to update.
    //
    // VolumeSizeGB is a required field
    VolumeSizeGB *int64 `locationName:"volumeSizeGB" type:"integer" required:"true"`
    // contains filtered or unexported fields
}

Specifies the EBS volume upgrade information. The broker identifier must be set to the keyword ALL. This means the changes apply to all the brokers in the cluster.

func (BrokerEBSVolumeInfo) GoString

func (s BrokerEBSVolumeInfo) GoString() string

GoString returns the string representation

func (*BrokerEBSVolumeInfo) SetKafkaBrokerNodeId

func (s *BrokerEBSVolumeInfo) SetKafkaBrokerNodeId(v string) *BrokerEBSVolumeInfo

SetKafkaBrokerNodeId sets the KafkaBrokerNodeId field's value.

func (*BrokerEBSVolumeInfo) SetVolumeSizeGB

func (s *BrokerEBSVolumeInfo) SetVolumeSizeGB(v int64) *BrokerEBSVolumeInfo

SetVolumeSizeGB sets the VolumeSizeGB field's value.

func (BrokerEBSVolumeInfo) String

func (s BrokerEBSVolumeInfo) String() string

String returns the string representation

func (*BrokerEBSVolumeInfo) Validate

func (s *BrokerEBSVolumeInfo) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type BrokerNodeGroupInfo

type BrokerNodeGroupInfo struct {

    // The distribution of broker nodes across Availability Zones.
    BrokerAZDistribution *string `locationName:"brokerAZDistribution" type:"string" enum:"BrokerAZDistribution"`

    // The list of subnets to connect to in the client virtual private cloud (VPC).
    // AWS creates elastic network interfaces inside these subnets. Client applications
    // use elastic network interfaces to produce and consume data. Client subnets
    // can't be in Availability Zone us-east-1e.
    //
    // ClientSubnets is a required field
    ClientSubnets []*string `locationName:"clientSubnets" type:"list" required:"true"`

    // The type of Amazon EC2 instances to use for Kafka brokers. The following
    // instance types are allowed: kafka.m5.large, kafka.m5.xlarge, kafka.m5.2xlarge,
    // kafka.m5.4xlarge, kafka.m5.12xlarge, and kafka.m5.24xlarge.
    //
    // InstanceType is a required field
    InstanceType *string `locationName:"instanceType" min:"5" type:"string" required:"true"`

    // The AWS security groups to associate with the elastic network interfaces
    // in order to specify who can connect to and communicate with the Amazon MSK
    // cluster. If you don't specify a security group, Amazon MSK uses the default
    // security group associated with the VPC. If you specify security groups that
    // were shared with you, you must ensure that you have permissions to them.
    // Specifically, you need the ec2:DescribeSecurityGroups permission.
    SecurityGroups []*string `locationName:"securityGroups" type:"list"`

    // Contains information about storage volumes attached to MSK broker nodes.
    StorageInfo *StorageInfo `locationName:"storageInfo" type:"structure"`
    // contains filtered or unexported fields
}

Describes the setup to be used for Kafka broker nodes in the cluster.

func (BrokerNodeGroupInfo) GoString

func (s BrokerNodeGroupInfo) GoString() string

GoString returns the string representation

func (*BrokerNodeGroupInfo) SetBrokerAZDistribution

func (s *BrokerNodeGroupInfo) SetBrokerAZDistribution(v string) *BrokerNodeGroupInfo

SetBrokerAZDistribution sets the BrokerAZDistribution field's value.

func (*BrokerNodeGroupInfo) SetClientSubnets

func (s *BrokerNodeGroupInfo) SetClientSubnets(v []*string) *BrokerNodeGroupInfo

SetClientSubnets sets the ClientSubnets field's value.

func (*BrokerNodeGroupInfo) SetInstanceType

func (s *BrokerNodeGroupInfo) SetInstanceType(v string) *BrokerNodeGroupInfo

SetInstanceType sets the InstanceType field's value.

func (*BrokerNodeGroupInfo) SetSecurityGroups

func (s *BrokerNodeGroupInfo) SetSecurityGroups(v []*string) *BrokerNodeGroupInfo

SetSecurityGroups sets the SecurityGroups field's value.

func (*BrokerNodeGroupInfo) SetStorageInfo

func (s *BrokerNodeGroupInfo) SetStorageInfo(v *StorageInfo) *BrokerNodeGroupInfo

SetStorageInfo sets the StorageInfo field's value.

func (BrokerNodeGroupInfo) String

func (s BrokerNodeGroupInfo) String() string

String returns the string representation

func (*BrokerNodeGroupInfo) Validate

func (s *BrokerNodeGroupInfo) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type BrokerNodeInfo

type BrokerNodeInfo struct {

    // The attached elastic network interface of the broker.
    AttachedENIId *string `locationName:"attachedENIId" type:"string"`

    // The ID of the broker.
    BrokerId *float64 `locationName:"brokerId" type:"double"`

    // The client subnet to which this broker node belongs.
    ClientSubnet *string `locationName:"clientSubnet" type:"string"`

    // The virtual private cloud (VPC) of the client.
    ClientVpcIpAddress *string `locationName:"clientVpcIpAddress" type:"string"`

    // Information about the version of software currently deployed on the Kafka
    // brokers in the cluster.
    CurrentBrokerSoftwareInfo *BrokerSoftwareInfo `locationName:"currentBrokerSoftwareInfo" type:"structure"`

    // Endpoints for accessing the broker.
    Endpoints []*string `locationName:"endpoints" type:"list"`
    // contains filtered or unexported fields
}

BrokerNodeInfo

func (BrokerNodeInfo) GoString

func (s BrokerNodeInfo) GoString() string

GoString returns the string representation

func (*BrokerNodeInfo) SetAttachedENIId

func (s *BrokerNodeInfo) SetAttachedENIId(v string) *BrokerNodeInfo

SetAttachedENIId sets the AttachedENIId field's value.

func (*BrokerNodeInfo) SetBrokerId

func (s *BrokerNodeInfo) SetBrokerId(v float64) *BrokerNodeInfo

SetBrokerId sets the BrokerId field's value.

func (*BrokerNodeInfo) SetClientSubnet

func (s *BrokerNodeInfo) SetClientSubnet(v string) *BrokerNodeInfo

SetClientSubnet sets the ClientSubnet field's value.

func (*BrokerNodeInfo) SetClientVpcIpAddress

func (s *BrokerNodeInfo) SetClientVpcIpAddress(v string) *BrokerNodeInfo

SetClientVpcIpAddress sets the ClientVpcIpAddress field's value.

func (*BrokerNodeInfo) SetCurrentBrokerSoftwareInfo

func (s *BrokerNodeInfo) SetCurrentBrokerSoftwareInfo(v *BrokerSoftwareInfo) *BrokerNodeInfo

SetCurrentBrokerSoftwareInfo sets the CurrentBrokerSoftwareInfo field's value.

func (*BrokerNodeInfo) SetEndpoints

func (s *BrokerNodeInfo) SetEndpoints(v []*string) *BrokerNodeInfo

SetEndpoints sets the Endpoints field's value.

func (BrokerNodeInfo) String

func (s BrokerNodeInfo) String() string

String returns the string representation

type BrokerSoftwareInfo

type BrokerSoftwareInfo struct {

    // The Amazon Resource Name (ARN) of the configuration used for the cluster.
    // This field isn't visible in this preview release.
    ConfigurationArn *string `locationName:"configurationArn" type:"string"`

    // The revision of the configuration to use. This field isn't visible in this
    // preview release.
    ConfigurationRevision *int64 `locationName:"configurationRevision" type:"long"`

    // The version of Apache Kafka.
    KafkaVersion *string `locationName:"kafkaVersion" type:"string"`
    // contains filtered or unexported fields
}

Information about the current software installed on the cluster.

func (BrokerSoftwareInfo) GoString

func (s BrokerSoftwareInfo) GoString() string

GoString returns the string representation

func (*BrokerSoftwareInfo) SetConfigurationArn

func (s *BrokerSoftwareInfo) SetConfigurationArn(v string) *BrokerSoftwareInfo

SetConfigurationArn sets the ConfigurationArn field's value.

func (*BrokerSoftwareInfo) SetConfigurationRevision

func (s *BrokerSoftwareInfo) SetConfigurationRevision(v int64) *BrokerSoftwareInfo

SetConfigurationRevision sets the ConfigurationRevision field's value.

func (*BrokerSoftwareInfo) SetKafkaVersion

func (s *BrokerSoftwareInfo) SetKafkaVersion(v string) *BrokerSoftwareInfo

SetKafkaVersion sets the KafkaVersion field's value.

func (BrokerSoftwareInfo) String

func (s BrokerSoftwareInfo) String() string

String returns the string representation

type ClientAuthentication

type ClientAuthentication struct {

    // Details for ClientAuthentication using TLS.
    Tls *Tls `locationName:"tls" type:"structure"`
    // contains filtered or unexported fields
}

Includes all client authentication information.

func (ClientAuthentication) GoString

func (s ClientAuthentication) GoString() string

GoString returns the string representation

func (*ClientAuthentication) SetTls

func (s *ClientAuthentication) SetTls(v *Tls) *ClientAuthentication

SetTls sets the Tls field's value.

func (ClientAuthentication) String

func (s ClientAuthentication) String() string

String returns the string representation

type ClusterInfo

type ClusterInfo struct {

    // Arn of active cluster operation.
    ActiveOperationArn *string `locationName:"activeOperationArn" type:"string"`

    // Information about the broker nodes.
    BrokerNodeGroupInfo *BrokerNodeGroupInfo `locationName:"brokerNodeGroupInfo" type:"structure"`

    // Includes all client authentication information.
    ClientAuthentication *ClientAuthentication `locationName:"clientAuthentication" type:"structure"`

    // The Amazon Resource Name (ARN) that uniquely identifies the cluster.
    ClusterArn *string `locationName:"clusterArn" type:"string"`

    // The name of the cluster.
    ClusterName *string `locationName:"clusterName" type:"string"`

    // The time when the cluster was created.
    CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"iso8601"`

    // Information about the version of software currently deployed on the Kafka
    // brokers in the cluster.
    CurrentBrokerSoftwareInfo *BrokerSoftwareInfo `locationName:"currentBrokerSoftwareInfo" type:"structure"`

    // The current version of the MSK cluster. Cluster versions aren't simple integers.
    // You can obtain the current version by describing the cluster. An example
    // version is KTVPDKIKX0DER.
    CurrentVersion *string `locationName:"currentVersion" type:"string"`

    // Includes all encryption-related information.
    EncryptionInfo *EncryptionInfo `locationName:"encryptionInfo" type:"structure"`

    // Specifies which metrics are gathered for the MSK cluster. This property has
    // three possible values: DEFAULT, PER_BROKER, and PER_TOPIC_PER_BROKER. For
    // a list of the metrics associated with each of these three levels of monitoring,
    // see Monitoring (https://docs.aws.amazon.com/msk/latest/developerguide/monitoring.html).
    EnhancedMonitoring *string `locationName:"enhancedMonitoring" type:"string" enum:"EnhancedMonitoring"`

    // The number of broker nodes in the cluster.
    NumberOfBrokerNodes *int64 `locationName:"numberOfBrokerNodes" type:"integer"`

    // The state of the cluster. The possible states are CREATING, ACTIVE, and FAILED.
    State *string `locationName:"state" type:"string" enum:"ClusterState"`

    // Tags attached to the cluster.
    Tags map[string]*string `locationName:"tags" type:"map"`

    // The connection string to use to connect to the Apache ZooKeeper cluster.
    ZookeeperConnectString *string `locationName:"zookeeperConnectString" type:"string"`
    // contains filtered or unexported fields
}

Returns information about a cluster.

func (ClusterInfo) GoString

func (s ClusterInfo) GoString() string

GoString returns the string representation

func (*ClusterInfo) SetActiveOperationArn

func (s *ClusterInfo) SetActiveOperationArn(v string) *ClusterInfo

SetActiveOperationArn sets the ActiveOperationArn field's value.

func (*ClusterInfo) SetBrokerNodeGroupInfo

func (s *ClusterInfo) SetBrokerNodeGroupInfo(v *BrokerNodeGroupInfo) *ClusterInfo

SetBrokerNodeGroupInfo sets the BrokerNodeGroupInfo field's value.

func (*ClusterInfo) SetClientAuthentication

func (s *ClusterInfo) SetClientAuthentication(v *ClientAuthentication) *ClusterInfo

SetClientAuthentication sets the ClientAuthentication field's value.

func (*ClusterInfo) SetClusterArn

func (s *ClusterInfo) SetClusterArn(v string) *ClusterInfo

SetClusterArn sets the ClusterArn field's value.

func (*ClusterInfo) SetClusterName

func (s *ClusterInfo) SetClusterName(v string) *ClusterInfo

SetClusterName sets the ClusterName field's value.

func (*ClusterInfo) SetCreationTime

func (s *ClusterInfo) SetCreationTime(v time.Time) *ClusterInfo

SetCreationTime sets the CreationTime field's value.

func (*ClusterInfo) SetCurrentBrokerSoftwareInfo

func (s *ClusterInfo) SetCurrentBrokerSoftwareInfo(v *BrokerSoftwareInfo) *ClusterInfo

SetCurrentBrokerSoftwareInfo sets the CurrentBrokerSoftwareInfo field's value.

func (*ClusterInfo) SetCurrentVersion

func (s *ClusterInfo) SetCurrentVersion(v string) *ClusterInfo

SetCurrentVersion sets the CurrentVersion field's value.

func (*ClusterInfo) SetEncryptionInfo

func (s *ClusterInfo) SetEncryptionInfo(v *EncryptionInfo) *ClusterInfo

SetEncryptionInfo sets the EncryptionInfo field's value.

func (*ClusterInfo) SetEnhancedMonitoring

func (s *ClusterInfo) SetEnhancedMonitoring(v string) *ClusterInfo

SetEnhancedMonitoring sets the EnhancedMonitoring field's value.

func (*ClusterInfo) SetNumberOfBrokerNodes

func (s *ClusterInfo) SetNumberOfBrokerNodes(v int64) *ClusterInfo

SetNumberOfBrokerNodes sets the NumberOfBrokerNodes field's value.

func (*ClusterInfo) SetState

func (s *ClusterInfo) SetState(v string) *ClusterInfo

SetState sets the State field's value.

func (*ClusterInfo) SetTags

func (s *ClusterInfo) SetTags(v map[string]*string) *ClusterInfo

SetTags sets the Tags field's value.

func (*ClusterInfo) SetZookeeperConnectString

func (s *ClusterInfo) SetZookeeperConnectString(v string) *ClusterInfo

SetZookeeperConnectString sets the ZookeeperConnectString field's value.

func (ClusterInfo) String

func (s ClusterInfo) String() string

String returns the string representation

type ClusterOperationInfo

type ClusterOperationInfo struct {

    // The ID of the API request that triggered this operation.
    ClientRequestId *string `locationName:"clientRequestId" type:"string"`

    // ARN of the cluster.
    ClusterArn *string `locationName:"clusterArn" type:"string"`

    // The time at which operation was created.
    CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"iso8601"`

    // The time at which the operation finished.
    EndTime *time.Time `locationName:"endTime" type:"timestamp" timestampFormat:"iso8601"`

    // Describes the error if the operation fails.
    ErrorInfo *ErrorInfo `locationName:"errorInfo" type:"structure"`

    // ARN of the cluster operation.
    OperationArn *string `locationName:"operationArn" type:"string"`

    // State of the cluster operation.
    OperationState *string `locationName:"operationState" type:"string"`

    // Type of the cluster operation.
    OperationType *string `locationName:"operationType" type:"string"`

    // Information about cluster attributes before a cluster is updated.
    SourceClusterInfo *MutableClusterInfo `locationName:"sourceClusterInfo" type:"structure"`

    // Information about cluster attributes after a cluster is updated.
    TargetClusterInfo *MutableClusterInfo `locationName:"targetClusterInfo" type:"structure"`
    // contains filtered or unexported fields
}

Returns information about a cluster operation.

func (ClusterOperationInfo) GoString

func (s ClusterOperationInfo) GoString() string

GoString returns the string representation

func (*ClusterOperationInfo) SetClientRequestId

func (s *ClusterOperationInfo) SetClientRequestId(v string) *ClusterOperationInfo

SetClientRequestId sets the ClientRequestId field's value.

func (*ClusterOperationInfo) SetClusterArn

func (s *ClusterOperationInfo) SetClusterArn(v string) *ClusterOperationInfo

SetClusterArn sets the ClusterArn field's value.

func (*ClusterOperationInfo) SetCreationTime

func (s *ClusterOperationInfo) SetCreationTime(v time.Time) *ClusterOperationInfo

SetCreationTime sets the CreationTime field's value.

func (*ClusterOperationInfo) SetEndTime

func (s *ClusterOperationInfo) SetEndTime(v time.Time) *ClusterOperationInfo

SetEndTime sets the EndTime field's value.

func (*ClusterOperationInfo) SetErrorInfo

func (s *ClusterOperationInfo) SetErrorInfo(v *ErrorInfo) *ClusterOperationInfo

SetErrorInfo sets the ErrorInfo field's value.

func (*ClusterOperationInfo) SetOperationArn

func (s *ClusterOperationInfo) SetOperationArn(v string) *ClusterOperationInfo

SetOperationArn sets the OperationArn field's value.

func (*ClusterOperationInfo) SetOperationState

func (s *ClusterOperationInfo) SetOperationState(v string) *ClusterOperationInfo

SetOperationState sets the OperationState field's value.

func (*ClusterOperationInfo) SetOperationType

func (s *ClusterOperationInfo) SetOperationType(v string) *ClusterOperationInfo

SetOperationType sets the OperationType field's value.

func (*ClusterOperationInfo) SetSourceClusterInfo

func (s *ClusterOperationInfo) SetSourceClusterInfo(v *MutableClusterInfo) *ClusterOperationInfo

SetSourceClusterInfo sets the SourceClusterInfo field's value.

func (*ClusterOperationInfo) SetTargetClusterInfo

func (s *ClusterOperationInfo) SetTargetClusterInfo(v *MutableClusterInfo) *ClusterOperationInfo

SetTargetClusterInfo sets the TargetClusterInfo field's value.

func (ClusterOperationInfo) String

func (s ClusterOperationInfo) String() string

String returns the string representation

type Configuration

type Configuration struct {

    // The Amazon Resource Name (ARN) of the configuration.
    //
    // Arn is a required field
    Arn *string `locationName:"arn" type:"string" required:"true"`

    // CreationTime is a required field
    CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"iso8601" required:"true"`

    // The description of the configuration.
    //
    // Description is a required field
    Description *string `locationName:"description" type:"string" required:"true"`

    // An array of the versions of Apache Kafka with which you can use this MSK
    // configuration. You can use this configuration for an MSK cluster only if
    // the Apache Kafka version specified for the cluster appears in this array.
    //
    // KafkaVersions is a required field
    KafkaVersions []*string `locationName:"kafkaVersions" type:"list" required:"true"`

    // Latest revision of the configuration.
    //
    // LatestRevision is a required field
    LatestRevision *ConfigurationRevision `locationName:"latestRevision" type:"structure" required:"true"`

    // The name of the configuration. Configuration names are strings that match
    // the regex "^[0-9A-Za-z-]+$".
    //
    // Name is a required field
    Name *string `locationName:"name" type:"string" required:"true"`
    // contains filtered or unexported fields
}

Represents an MSK Configuration.

func (Configuration) GoString

func (s Configuration) GoString() string

GoString returns the string representation

func (*Configuration) SetArn

func (s *Configuration) SetArn(v string) *Configuration

SetArn sets the Arn field's value.

func (*Configuration) SetCreationTime

func (s *Configuration) SetCreationTime(v time.Time) *Configuration

SetCreationTime sets the CreationTime field's value.

func (*Configuration) SetDescription

func (s *Configuration) SetDescription(v string) *Configuration

SetDescription sets the Description field's value.

func (*Configuration) SetKafkaVersions

func (s *Configuration) SetKafkaVersions(v []*string) *Configuration

SetKafkaVersions sets the KafkaVersions field's value.

func (*Configuration) SetLatestRevision

func (s *Configuration) SetLatestRevision(v *ConfigurationRevision) *Configuration

SetLatestRevision sets the LatestRevision field's value.

func (*Configuration) SetName

func (s *Configuration) SetName(v string) *Configuration

SetName sets the Name field's value.

func (Configuration) String

func (s Configuration) String() string

String returns the string representation

type ConfigurationInfo

type ConfigurationInfo struct {

    // ARN of the configuration to use.
    //
    // Arn is a required field
    Arn *string `locationName:"arn" type:"string" required:"true"`

    // The revision of the configuration to use.
    //
    // Revision is a required field
    Revision *int64 `locationName:"revision" type:"long" required:"true"`
    // contains filtered or unexported fields
}

Specifies the configuration to use for the brokers.

func (ConfigurationInfo) GoString

func (s ConfigurationInfo) GoString() string

GoString returns the string representation

func (*ConfigurationInfo) SetArn

func (s *ConfigurationInfo) SetArn(v string) *ConfigurationInfo

SetArn sets the Arn field's value.

func (*ConfigurationInfo) SetRevision

func (s *ConfigurationInfo) SetRevision(v int64) *ConfigurationInfo

SetRevision sets the Revision field's value.

func (ConfigurationInfo) String

func (s ConfigurationInfo) String() string

String returns the string representation

func (*ConfigurationInfo) Validate

func (s *ConfigurationInfo) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ConfigurationRevision

type ConfigurationRevision struct {

    // The time when the configuration revision was created.
    //
    // CreationTime is a required field
    CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"iso8601" required:"true"`

    // The description of the configuration revision.
    Description *string `locationName:"description" type:"string"`

    // The revision number.
    //
    // Revision is a required field
    Revision *int64 `locationName:"revision" type:"long" required:"true"`
    // contains filtered or unexported fields
}

Describes a configuration revision.

func (ConfigurationRevision) GoString

func (s ConfigurationRevision) GoString() string

GoString returns the string representation

func (*ConfigurationRevision) SetCreationTime

func (s *ConfigurationRevision) SetCreationTime(v time.Time) *ConfigurationRevision

SetCreationTime sets the CreationTime field's value.

func (*ConfigurationRevision) SetDescription

func (s *ConfigurationRevision) SetDescription(v string) *ConfigurationRevision

SetDescription sets the Description field's value.

func (*ConfigurationRevision) SetRevision

func (s *ConfigurationRevision) SetRevision(v int64) *ConfigurationRevision

SetRevision sets the Revision field's value.

func (ConfigurationRevision) String

func (s ConfigurationRevision) String() string

String returns the string representation

type CreateClusterInput

type CreateClusterInput struct {

    // Information about the broker nodes in the cluster.
    //
    // BrokerNodeGroupInfo is a required field
    BrokerNodeGroupInfo *BrokerNodeGroupInfo `locationName:"brokerNodeGroupInfo" type:"structure" required:"true"`

    // Includes all client authentication related information.
    ClientAuthentication *ClientAuthentication `locationName:"clientAuthentication" type:"structure"`

    // The name of the cluster.
    //
    // ClusterName is a required field
    ClusterName *string `locationName:"clusterName" min:"1" type:"string" required:"true"`

    // Represents the configuration that you want MSK to use for the cluster.
    ConfigurationInfo *ConfigurationInfo `locationName:"configurationInfo" type:"structure"`

    // Includes all encryption-related information.
    EncryptionInfo *EncryptionInfo `locationName:"encryptionInfo" type:"structure"`

    // Specifies the level of monitoring for the MSK cluster. The possible values
    // are DEFAULT, PER_BROKER, and PER_TOPIC_PER_BROKER.
    EnhancedMonitoring *string `locationName:"enhancedMonitoring" type:"string" enum:"EnhancedMonitoring"`

    // The version of Apache Kafka.
    //
    // KafkaVersion is a required field
    KafkaVersion *string `locationName:"kafkaVersion" min:"1" type:"string" required:"true"`

    // The number of Kafka broker nodes in the Amazon MSK cluster.
    //
    // NumberOfBrokerNodes is a required field
    NumberOfBrokerNodes *int64 `locationName:"numberOfBrokerNodes" min:"1" type:"integer" required:"true"`

    // Create tags when creating the cluster.
    Tags map[string]*string `locationName:"tags" type:"map"`
    // contains filtered or unexported fields
}

Creates a cluster.

func (CreateClusterInput) GoString

func (s CreateClusterInput) GoString() string

GoString returns the string representation

func (*CreateClusterInput) SetBrokerNodeGroupInfo

func (s *CreateClusterInput) SetBrokerNodeGroupInfo(v *BrokerNodeGroupInfo) *CreateClusterInput

SetBrokerNodeGroupInfo sets the BrokerNodeGroupInfo field's value.

func (*CreateClusterInput) SetClientAuthentication

func (s *CreateClusterInput) SetClientAuthentication(v *ClientAuthentication) *CreateClusterInput

SetClientAuthentication sets the ClientAuthentication field's value.

func (*CreateClusterInput) SetClusterName

func (s *CreateClusterInput) SetClusterName(v string) *CreateClusterInput

SetClusterName sets the ClusterName field's value.

func (*CreateClusterInput) SetConfigurationInfo

func (s *CreateClusterInput) SetConfigurationInfo(v *ConfigurationInfo) *CreateClusterInput

SetConfigurationInfo sets the ConfigurationInfo field's value.

func (*CreateClusterInput) SetEncryptionInfo

func (s *CreateClusterInput) SetEncryptionInfo(v *EncryptionInfo) *CreateClusterInput

SetEncryptionInfo sets the EncryptionInfo field's value.

func (*CreateClusterInput) SetEnhancedMonitoring

func (s *CreateClusterInput) SetEnhancedMonitoring(v string) *CreateClusterInput

SetEnhancedMonitoring sets the EnhancedMonitoring field's value.

func (*CreateClusterInput) SetKafkaVersion

func (s *CreateClusterInput) SetKafkaVersion(v string) *CreateClusterInput

SetKafkaVersion sets the KafkaVersion field's value.

func (*CreateClusterInput) SetNumberOfBrokerNodes

func (s *CreateClusterInput) SetNumberOfBrokerNodes(v int64) *CreateClusterInput

SetNumberOfBrokerNodes sets the NumberOfBrokerNodes field's value.

func (*CreateClusterInput) SetTags

func (s *CreateClusterInput) SetTags(v map[string]*string) *CreateClusterInput

SetTags sets the Tags field's value.

func (CreateClusterInput) String

func (s CreateClusterInput) String() string

String returns the string representation

func (*CreateClusterInput) Validate

func (s *CreateClusterInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type CreateClusterOutput

type CreateClusterOutput struct {

    // The Amazon Resource Name (ARN) of the cluster.
    ClusterArn *string `locationName:"clusterArn" type:"string"`

    // The name of the MSK cluster.
    ClusterName *string `locationName:"clusterName" type:"string"`

    // The state of the cluster. The possible states are CREATING, ACTIVE, and FAILED.
    State *string `locationName:"state" type:"string" enum:"ClusterState"`
    // contains filtered or unexported fields
}

Returns information about the created cluster.

func (CreateClusterOutput) GoString

func (s CreateClusterOutput) GoString() string

GoString returns the string representation

func (*CreateClusterOutput) SetClusterArn

func (s *CreateClusterOutput) SetClusterArn(v string) *CreateClusterOutput

SetClusterArn sets the ClusterArn field's value.

func (*CreateClusterOutput) SetClusterName

func (s *CreateClusterOutput) SetClusterName(v string) *CreateClusterOutput

SetClusterName sets the ClusterName field's value.

func (*CreateClusterOutput) SetState

func (s *CreateClusterOutput) SetState(v string) *CreateClusterOutput

SetState sets the State field's value.

func (CreateClusterOutput) String

func (s CreateClusterOutput) String() string

String returns the string representation

type CreateConfigurationInput

type CreateConfigurationInput struct {

    // The description of the configuration.
    Description *string `locationName:"description" type:"string"`

    // The versions of Apache Kafka with which you can use this MSK configuration.
    //
    // KafkaVersions is a required field
    KafkaVersions []*string `locationName:"kafkaVersions" type:"list" required:"true"`

    // The name of the configuration. Configuration names are strings that match
    // the regex "^[0-9A-Za-z-]+$".
    //
    // Name is a required field
    Name *string `locationName:"name" type:"string" required:"true"`

    // ServerProperties is automatically base64 encoded/decoded by the SDK.
    //
    // ServerProperties is a required field
    ServerProperties []byte `locationName:"serverProperties" type:"blob" required:"true"`
    // contains filtered or unexported fields
}

Request body for CreateConfiguration.

func (CreateConfigurationInput) GoString

func (s CreateConfigurationInput) GoString() string

GoString returns the string representation

func (*CreateConfigurationInput) SetDescription

func (s *CreateConfigurationInput) SetDescription(v string) *CreateConfigurationInput

SetDescription sets the Description field's value.

func (*CreateConfigurationInput) SetKafkaVersions

func (s *CreateConfigurationInput) SetKafkaVersions(v []*string) *CreateConfigurationInput

SetKafkaVersions sets the KafkaVersions field's value.

func (*CreateConfigurationInput) SetName

func (s *CreateConfigurationInput) SetName(v string) *CreateConfigurationInput

SetName sets the Name field's value.

func (*CreateConfigurationInput) SetServerProperties

func (s *CreateConfigurationInput) SetServerProperties(v []byte) *CreateConfigurationInput

SetServerProperties sets the ServerProperties field's value.

func (CreateConfigurationInput) String

func (s CreateConfigurationInput) String() string

String returns the string representation

func (*CreateConfigurationInput) Validate

func (s *CreateConfigurationInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type CreateConfigurationOutput

type CreateConfigurationOutput struct {

    // The Amazon Resource Name (ARN) of the configuration.
    Arn *string `locationName:"arn" type:"string"`

    // The time when the configuration was created.
    CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"iso8601"`

    // Latest revision of the configuration.
    LatestRevision *ConfigurationRevision `locationName:"latestRevision" type:"structure"`

    // The name of the configuration. Configuration names are strings that match
    // the regex "^[0-9A-Za-z-]+$".
    Name *string `locationName:"name" type:"string"`
    // contains filtered or unexported fields
}

Response body for CreateConfiguration

func (CreateConfigurationOutput) GoString

func (s CreateConfigurationOutput) GoString() string

GoString returns the string representation

func (*CreateConfigurationOutput) SetArn

func (s *CreateConfigurationOutput) SetArn(v string) *CreateConfigurationOutput

SetArn sets the Arn field's value.

func (*CreateConfigurationOutput) SetCreationTime

func (s *CreateConfigurationOutput) SetCreationTime(v time.Time) *CreateConfigurationOutput

SetCreationTime sets the CreationTime field's value.

func (*CreateConfigurationOutput) SetLatestRevision

func (s *CreateConfigurationOutput) SetLatestRevision(v *ConfigurationRevision) *CreateConfigurationOutput

SetLatestRevision sets the LatestRevision field's value.

func (*CreateConfigurationOutput) SetName

func (s *CreateConfigurationOutput) SetName(v string) *CreateConfigurationOutput

SetName sets the Name field's value.

func (CreateConfigurationOutput) String

func (s CreateConfigurationOutput) String() string

String returns the string representation

type DeleteClusterInput

type DeleteClusterInput struct {

    // ClusterArn is a required field
    ClusterArn *string `location:"uri" locationName:"clusterArn" type:"string" required:"true"`

    CurrentVersion *string `location:"querystring" locationName:"currentVersion" type:"string"`
    // contains filtered or unexported fields
}

func (DeleteClusterInput) GoString

func (s DeleteClusterInput) GoString() string

GoString returns the string representation

func (*DeleteClusterInput) SetClusterArn

func (s *DeleteClusterInput) SetClusterArn(v string) *DeleteClusterInput

SetClusterArn sets the ClusterArn field's value.

func (*DeleteClusterInput) SetCurrentVersion

func (s *DeleteClusterInput) SetCurrentVersion(v string) *DeleteClusterInput

SetCurrentVersion sets the CurrentVersion field's value.

func (DeleteClusterInput) String

func (s DeleteClusterInput) String() string

String returns the string representation

func (*DeleteClusterInput) Validate

func (s *DeleteClusterInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DeleteClusterOutput

type DeleteClusterOutput struct {

    // The Amazon Resource Name (ARN) of the cluster.
    ClusterArn *string `locationName:"clusterArn" type:"string"`

    // The state of the cluster. The possible states are CREATING, ACTIVE, and FAILED.
    State *string `locationName:"state" type:"string" enum:"ClusterState"`
    // contains filtered or unexported fields
}

Returns information about the deleted cluster.

func (DeleteClusterOutput) GoString

func (s DeleteClusterOutput) GoString() string

GoString returns the string representation

func (*DeleteClusterOutput) SetClusterArn

func (s *DeleteClusterOutput) SetClusterArn(v string) *DeleteClusterOutput

SetClusterArn sets the ClusterArn field's value.

func (*DeleteClusterOutput) SetState

func (s *DeleteClusterOutput) SetState(v string) *DeleteClusterOutput

SetState sets the State field's value.

func (DeleteClusterOutput) String

func (s DeleteClusterOutput) String() string

String returns the string representation

type DescribeClusterInput

type DescribeClusterInput struct {

    // ClusterArn is a required field
    ClusterArn *string `location:"uri" locationName:"clusterArn" type:"string" required:"true"`
    // contains filtered or unexported fields
}

func (DescribeClusterInput) GoString

func (s DescribeClusterInput) GoString() string

GoString returns the string representation

func (*DescribeClusterInput) SetClusterArn

func (s *DescribeClusterInput) SetClusterArn(v string) *DescribeClusterInput

SetClusterArn sets the ClusterArn field's value.

func (DescribeClusterInput) String

func (s DescribeClusterInput) String() string

String returns the string representation

func (*DescribeClusterInput) Validate

func (s *DescribeClusterInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DescribeClusterOperationInput

type DescribeClusterOperationInput struct {

    // ClusterOperationArn is a required field
    ClusterOperationArn *string `location:"uri" locationName:"clusterOperationArn" type:"string" required:"true"`
    // contains filtered or unexported fields
}

func (DescribeClusterOperationInput) GoString

func (s DescribeClusterOperationInput) GoString() string

GoString returns the string representation

func (*DescribeClusterOperationInput) SetClusterOperationArn

func (s *DescribeClusterOperationInput) SetClusterOperationArn(v string) *DescribeClusterOperationInput

SetClusterOperationArn sets the ClusterOperationArn field's value.

func (DescribeClusterOperationInput) String

func (s DescribeClusterOperationInput) String() string

String returns the string representation

func (*DescribeClusterOperationInput) Validate

func (s *DescribeClusterOperationInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DescribeClusterOperationOutput

type DescribeClusterOperationOutput struct {

    // Cluster operation information
    ClusterOperationInfo *ClusterOperationInfo `locationName:"clusterOperationInfo" type:"structure"`
    // contains filtered or unexported fields
}

Information about a cluster operation.

func (DescribeClusterOperationOutput) GoString

func (s DescribeClusterOperationOutput) GoString() string

GoString returns the string representation

func (*DescribeClusterOperationOutput) SetClusterOperationInfo

func (s *DescribeClusterOperationOutput) SetClusterOperationInfo(v *ClusterOperationInfo) *DescribeClusterOperationOutput

SetClusterOperationInfo sets the ClusterOperationInfo field's value.

func (DescribeClusterOperationOutput) String

func (s DescribeClusterOperationOutput) String() string

String returns the string representation

type DescribeClusterOutput

type DescribeClusterOutput struct {

    // The cluster information.
    ClusterInfo *ClusterInfo `locationName:"clusterInfo" type:"structure"`
    // contains filtered or unexported fields
}

Returns information about a cluster.

func (DescribeClusterOutput) GoString

func (s DescribeClusterOutput) GoString() string

GoString returns the string representation

func (*DescribeClusterOutput) SetClusterInfo

func (s *DescribeClusterOutput) SetClusterInfo(v *ClusterInfo) *DescribeClusterOutput

SetClusterInfo sets the ClusterInfo field's value.

func (DescribeClusterOutput) String

func (s DescribeClusterOutput) String() string

String returns the string representation

type DescribeConfigurationInput

type DescribeConfigurationInput struct {

    // Arn is a required field
    Arn *string `location:"uri" locationName:"arn" type:"string" required:"true"`
    // contains filtered or unexported fields
}

func (DescribeConfigurationInput) GoString

func (s DescribeConfigurationInput) GoString() string

GoString returns the string representation

func (*DescribeConfigurationInput) SetArn

func (s *DescribeConfigurationInput) SetArn(v string) *DescribeConfigurationInput

SetArn sets the Arn field's value.

func (DescribeConfigurationInput) String

func (s DescribeConfigurationInput) String() string

String returns the string representation

func (*DescribeConfigurationInput) Validate

func (s *DescribeConfigurationInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DescribeConfigurationOutput

type DescribeConfigurationOutput struct {

    // The Amazon Resource Name (ARN) of the configuration.
    Arn *string `locationName:"arn" type:"string"`

    // The time when the configuration was created.
    CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"iso8601"`

    // The description of the configuration.
    Description *string `locationName:"description" type:"string"`

    // The versions of Apache Kafka with which you can use this MSK configuration.
    KafkaVersions []*string `locationName:"kafkaVersions" type:"list"`

    // Latest revision of the configuration.
    LatestRevision *ConfigurationRevision `locationName:"latestRevision" type:"structure"`

    // The name of the configuration. Configuration names are strings that match
    // the regex "^[0-9A-Za-z-]+$".
    Name *string `locationName:"name" type:"string"`
    // contains filtered or unexported fields
}

Response body for DescribeConfiguration.

func (DescribeConfigurationOutput) GoString

func (s DescribeConfigurationOutput) GoString() string

GoString returns the string representation

func (*DescribeConfigurationOutput) SetArn

func (s *DescribeConfigurationOutput) SetArn(v string) *DescribeConfigurationOutput

SetArn sets the Arn field's value.

func (*DescribeConfigurationOutput) SetCreationTime

func (s *DescribeConfigurationOutput) SetCreationTime(v time.Time) *DescribeConfigurationOutput

SetCreationTime sets the CreationTime field's value.

func (*DescribeConfigurationOutput) SetDescription

func (s *DescribeConfigurationOutput) SetDescription(v string) *DescribeConfigurationOutput

SetDescription sets the Description field's value.

func (*DescribeConfigurationOutput) SetKafkaVersions

func (s *DescribeConfigurationOutput) SetKafkaVersions(v []*string) *DescribeConfigurationOutput

SetKafkaVersions sets the KafkaVersions field's value.

func (*DescribeConfigurationOutput) SetLatestRevision

func (s *DescribeConfigurationOutput) SetLatestRevision(v *ConfigurationRevision) *DescribeConfigurationOutput

SetLatestRevision sets the LatestRevision field's value.

func (*DescribeConfigurationOutput) SetName

func (s *DescribeConfigurationOutput) SetName(v string) *DescribeConfigurationOutput

SetName sets the Name field's value.

func (DescribeConfigurationOutput) String

func (s DescribeConfigurationOutput) String() string

String returns the string representation

type DescribeConfigurationRevisionInput

type DescribeConfigurationRevisionInput struct {

    // Arn is a required field
    Arn *string `location:"uri" locationName:"arn" type:"string" required:"true"`

    // Revision is a required field
    Revision *int64 `location:"uri" locationName:"revision" type:"long" required:"true"`
    // contains filtered or unexported fields
}

func (DescribeConfigurationRevisionInput) GoString

func (s DescribeConfigurationRevisionInput) GoString() string

GoString returns the string representation

func (*DescribeConfigurationRevisionInput) SetArn

func (s *DescribeConfigurationRevisionInput) SetArn(v string) *DescribeConfigurationRevisionInput

SetArn sets the Arn field's value.

func (*DescribeConfigurationRevisionInput) SetRevision

func (s *DescribeConfigurationRevisionInput) SetRevision(v int64) *DescribeConfigurationRevisionInput

SetRevision sets the Revision field's value.

func (DescribeConfigurationRevisionInput) String

func (s DescribeConfigurationRevisionInput) String() string

String returns the string representation

func (*DescribeConfigurationRevisionInput) Validate

func (s *DescribeConfigurationRevisionInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DescribeConfigurationRevisionOutput

type DescribeConfigurationRevisionOutput struct {

    // The Amazon Resource Name (ARN) of the configuration.
    Arn *string `locationName:"arn" type:"string"`

    // The time when the configuration was created.
    CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"iso8601"`

    // The description of the configuration.
    Description *string `locationName:"description" type:"string"`

    // The revision number.
    Revision *int64 `locationName:"revision" type:"long"`

    // ServerProperties is automatically base64 encoded/decoded by the SDK.
    ServerProperties []byte `locationName:"serverProperties" type:"blob"`
    // contains filtered or unexported fields
}

Response body for DescribeConfigurationRevision.

func (DescribeConfigurationRevisionOutput) GoString

func (s DescribeConfigurationRevisionOutput) GoString() string

GoString returns the string representation

func (*DescribeConfigurationRevisionOutput) SetArn

func (s *DescribeConfigurationRevisionOutput) SetArn(v string) *DescribeConfigurationRevisionOutput

SetArn sets the Arn field's value.

func (*DescribeConfigurationRevisionOutput) SetCreationTime

func (s *DescribeConfigurationRevisionOutput) SetCreationTime(v time.Time) *DescribeConfigurationRevisionOutput

SetCreationTime sets the CreationTime field's value.

func (*DescribeConfigurationRevisionOutput) SetDescription

func (s *DescribeConfigurationRevisionOutput) SetDescription(v string) *DescribeConfigurationRevisionOutput

SetDescription sets the Description field's value.

func (*DescribeConfigurationRevisionOutput) SetRevision

func (s *DescribeConfigurationRevisionOutput) SetRevision(v int64) *DescribeConfigurationRevisionOutput

SetRevision sets the Revision field's value.

func (*DescribeConfigurationRevisionOutput) SetServerProperties

func (s *DescribeConfigurationRevisionOutput) SetServerProperties(v []byte) *DescribeConfigurationRevisionOutput

SetServerProperties sets the ServerProperties field's value.

func (DescribeConfigurationRevisionOutput) String

func (s DescribeConfigurationRevisionOutput) String() string

String returns the string representation

type EBSStorageInfo

type EBSStorageInfo struct {

    // The size in GiB of the EBS volume for the data drive on each broker node.
    VolumeSize *int64 `locationName:"volumeSize" min:"1" type:"integer"`
    // contains filtered or unexported fields
}

Contains information about the EBS storage volumes attached to Kafka broker nodes.

func (EBSStorageInfo) GoString

func (s EBSStorageInfo) GoString() string

GoString returns the string representation

func (*EBSStorageInfo) SetVolumeSize

func (s *EBSStorageInfo) SetVolumeSize(v int64) *EBSStorageInfo

SetVolumeSize sets the VolumeSize field's value.

func (EBSStorageInfo) String

func (s EBSStorageInfo) String() string

String returns the string representation

func (*EBSStorageInfo) Validate

func (s *EBSStorageInfo) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type EncryptionAtRest

type EncryptionAtRest struct {

    // The ARN of the AWS KMS key for encrypting data at rest. If you don't specify
    // a KMS key, MSK creates one for you and uses it.
    //
    // DataVolumeKMSKeyId is a required field
    DataVolumeKMSKeyId *string `locationName:"dataVolumeKMSKeyId" type:"string" required:"true"`
    // contains filtered or unexported fields
}

The data-volume encryption details.

func (EncryptionAtRest) GoString

func (s EncryptionAtRest) GoString() string

GoString returns the string representation

func (*EncryptionAtRest) SetDataVolumeKMSKeyId

func (s *EncryptionAtRest) SetDataVolumeKMSKeyId(v string) *EncryptionAtRest

SetDataVolumeKMSKeyId sets the DataVolumeKMSKeyId field's value.

func (EncryptionAtRest) String

func (s EncryptionAtRest) String() string

String returns the string representation

func (*EncryptionAtRest) Validate

func (s *EncryptionAtRest) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type EncryptionInTransit

type EncryptionInTransit struct {

    // Indicates the encryption setting for data in transit between clients and
    // brokers. You must set it to one of the following values.
    //
    // TLS means that client-broker communication is enabled with TLS only.
    //
    // TLS_PLAINTEXT means that client-broker communication is enabled for both
    // TLS-encrypted, as well as plaintext data.
    //
    // PLAINTEXT means that client-broker communication is enabled in plaintext
    // only.
    //
    // The default value is TLS.
    ClientBroker *string `locationName:"clientBroker" type:"string" enum:"ClientBroker"`

    // When set to true, it indicates that data communication among the broker nodes
    // of the cluster is encrypted. When set to false, the communication happens
    // in plaintext.
    //
    // The default value is true.
    InCluster *bool `locationName:"inCluster" type:"boolean"`
    // contains filtered or unexported fields
}

The settings for encrypting data in transit.

func (EncryptionInTransit) GoString

func (s EncryptionInTransit) GoString() string

GoString returns the string representation

func (*EncryptionInTransit) SetClientBroker

func (s *EncryptionInTransit) SetClientBroker(v string) *EncryptionInTransit

SetClientBroker sets the ClientBroker field's value.

func (*EncryptionInTransit) SetInCluster

func (s *EncryptionInTransit) SetInCluster(v bool) *EncryptionInTransit

SetInCluster sets the InCluster field's value.

func (EncryptionInTransit) String

func (s EncryptionInTransit) String() string

String returns the string representation

type EncryptionInfo

type EncryptionInfo struct {

    // The data-volume encryption details.
    EncryptionAtRest *EncryptionAtRest `locationName:"encryptionAtRest" type:"structure"`

    // The details for encryption in transit.
    EncryptionInTransit *EncryptionInTransit `locationName:"encryptionInTransit" type:"structure"`
    // contains filtered or unexported fields
}

Includes encryption-related information, such as the AWS KMS key used for encrypting data at rest and whether you want MSK to encrypt your data in transit.

func (EncryptionInfo) GoString

func (s EncryptionInfo) GoString() string

GoString returns the string representation

func (*EncryptionInfo) SetEncryptionAtRest

func (s *EncryptionInfo) SetEncryptionAtRest(v *EncryptionAtRest) *EncryptionInfo

SetEncryptionAtRest sets the EncryptionAtRest field's value.

func (*EncryptionInfo) SetEncryptionInTransit

func (s *EncryptionInfo) SetEncryptionInTransit(v *EncryptionInTransit) *EncryptionInfo

SetEncryptionInTransit sets the EncryptionInTransit field's value.

func (EncryptionInfo) String

func (s EncryptionInfo) String() string

String returns the string representation

func (*EncryptionInfo) Validate

func (s *EncryptionInfo) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ErrorInfo

type ErrorInfo struct {

    // A number describing the error programmatically.
    ErrorCode *string `locationName:"errorCode" type:"string"`

    // An optional field to provide more details about the error.
    ErrorString *string `locationName:"errorString" type:"string"`
    // contains filtered or unexported fields
}

Returns information about an error state of the cluster.

func (ErrorInfo) GoString

func (s ErrorInfo) GoString() string

GoString returns the string representation

func (*ErrorInfo) SetErrorCode

func (s *ErrorInfo) SetErrorCode(v string) *ErrorInfo

SetErrorCode sets the ErrorCode field's value.

func (*ErrorInfo) SetErrorString

func (s *ErrorInfo) SetErrorString(v string) *ErrorInfo

SetErrorString sets the ErrorString field's value.

func (ErrorInfo) String

func (s ErrorInfo) String() string

String returns the string representation

type GetBootstrapBrokersInput

type GetBootstrapBrokersInput struct {

    // ClusterArn is a required field
    ClusterArn *string `location:"uri" locationName:"clusterArn" type:"string" required:"true"`
    // contains filtered or unexported fields
}

func (GetBootstrapBrokersInput) GoString

func (s GetBootstrapBrokersInput) GoString() string

GoString returns the string representation

func (*GetBootstrapBrokersInput) SetClusterArn

func (s *GetBootstrapBrokersInput) SetClusterArn(v string) *GetBootstrapBrokersInput

SetClusterArn sets the ClusterArn field's value.

func (GetBootstrapBrokersInput) String

func (s GetBootstrapBrokersInput) String() string

String returns the string representation

func (*GetBootstrapBrokersInput) Validate

func (s *GetBootstrapBrokersInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type GetBootstrapBrokersOutput

type GetBootstrapBrokersOutput struct {

    // A string containing one or more hostname:port pairs.
    BootstrapBrokerString *string `locationName:"bootstrapBrokerString" type:"string"`

    // A string containing one or more DNS names (or IP) and TLS port pairs. The
    // following is an example.
    //  { "BootstrapBrokerStringTls": "b-3.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9094,b-1.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9094,b-2.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9094"}
    BootstrapBrokerStringTls *string `locationName:"bootstrapBrokerStringTls" type:"string"`
    // contains filtered or unexported fields
}

Returns a string containing one or more hostname:port pairs.

func (GetBootstrapBrokersOutput) GoString

func (s GetBootstrapBrokersOutput) GoString() string

GoString returns the string representation

func (*GetBootstrapBrokersOutput) SetBootstrapBrokerString

func (s *GetBootstrapBrokersOutput) SetBootstrapBrokerString(v string) *GetBootstrapBrokersOutput

SetBootstrapBrokerString sets the BootstrapBrokerString field's value.

func (*GetBootstrapBrokersOutput) SetBootstrapBrokerStringTls

func (s *GetBootstrapBrokersOutput) SetBootstrapBrokerStringTls(v string) *GetBootstrapBrokersOutput

SetBootstrapBrokerStringTls sets the BootstrapBrokerStringTls field's value.

func (GetBootstrapBrokersOutput) String

func (s GetBootstrapBrokersOutput) String() string

String returns the string representation

type Kafka

type Kafka struct {
    *client.Client
}

Kafka provides the API operation methods for making requests to Managed Streaming for Kafka. See this package's package overview docs for details on the service.

Kafka methods are safe to use concurrently. It is not safe to modify mutate any of the struct's properties though.

func New

func New(p client.ConfigProvider, cfgs ...*aws.Config) *Kafka

New creates a new instance of the Kafka client with a session. If additional configuration is needed for the client instance use the optional aws.Config parameter to add your extra config.

Example:

// Create a Kafka client from just a session.
svc := kafka.New(mySession)

// Create a Kafka client with additional configuration
svc := kafka.New(mySession, aws.NewConfig().WithRegion("us-west-2"))

func (*Kafka) CreateCluster

func (c *Kafka) CreateCluster(input *CreateClusterInput) (*CreateClusterOutput, error)

CreateCluster API operation for Managed Streaming for Kafka.

Creates a new MSK cluster.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Managed Streaming for Kafka's API operation CreateCluster for usage and error information.

Returned Error Codes:

* ErrCodeBadRequestException "BadRequestException"
Returns information about an error.

* ErrCodeInternalServerErrorException "InternalServerErrorException"
Returns information about an error.

* ErrCodeUnauthorizedException "UnauthorizedException"
Returns information about an error.

* ErrCodeForbiddenException "ForbiddenException"
Returns information about an error.

* ErrCodeServiceUnavailableException "ServiceUnavailableException"
Returns information about an error.

* ErrCodeTooManyRequestsException "TooManyRequestsException"
Returns information about an error.

* ErrCodeConflictException "ConflictException"
Returns information about an error.

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/CreateCluster

func (*Kafka) CreateClusterRequest

func (c *Kafka) CreateClusterRequest(input *CreateClusterInput) (req *request.Request, output *CreateClusterOutput)

CreateClusterRequest generates a "aws/request.Request" representing the client's request for the CreateCluster operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See CreateCluster for more information on using the CreateCluster API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the CreateClusterRequest method.
req, resp := client.CreateClusterRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/CreateCluster

func (*Kafka) CreateClusterWithContext

func (c *Kafka) CreateClusterWithContext(ctx aws.Context, input *CreateClusterInput, opts ...request.Option) (*CreateClusterOutput, error)

CreateClusterWithContext is the same as CreateCluster with the addition of the ability to pass a context and additional request options.

See CreateCluster for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Kafka) CreateConfiguration

func (c *Kafka) CreateConfiguration(input *CreateConfigurationInput) (*CreateConfigurationOutput, error)

CreateConfiguration API operation for Managed Streaming for Kafka.

Creates a new MSK configuration.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Managed Streaming for Kafka's API operation CreateConfiguration for usage and error information.

Returned Error Codes:

* ErrCodeBadRequestException "BadRequestException"
Returns information about an error.

* ErrCodeInternalServerErrorException "InternalServerErrorException"
Returns information about an error.

* ErrCodeUnauthorizedException "UnauthorizedException"
Returns information about an error.

* ErrCodeForbiddenException "ForbiddenException"
Returns information about an error.

* ErrCodeServiceUnavailableException "ServiceUnavailableException"
Returns information about an error.

* ErrCodeTooManyRequestsException "TooManyRequestsException"
Returns information about an error.

* ErrCodeConflictException "ConflictException"
Returns information about an error.

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/CreateConfiguration

func (*Kafka) CreateConfigurationRequest

func (c *Kafka) CreateConfigurationRequest(input *CreateConfigurationInput) (req *request.Request, output *CreateConfigurationOutput)

CreateConfigurationRequest generates a "aws/request.Request" representing the client's request for the CreateConfiguration operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See CreateConfiguration for more information on using the CreateConfiguration API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the CreateConfigurationRequest method.
req, resp := client.CreateConfigurationRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/CreateConfiguration

func (*Kafka) CreateConfigurationWithContext

func (c *Kafka) CreateConfigurationWithContext(ctx aws.Context, input *CreateConfigurationInput, opts ...request.Option) (*CreateConfigurationOutput, error)

CreateConfigurationWithContext is the same as CreateConfiguration with the addition of the ability to pass a context and additional request options.

See CreateConfiguration for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Kafka) DeleteCluster

func (c *Kafka) DeleteCluster(input *DeleteClusterInput) (*DeleteClusterOutput, error)

DeleteCluster API operation for Managed Streaming for Kafka.

Deletes the MSK cluster specified by the Amazon Resource Name (ARN) in the request.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Managed Streaming for Kafka's API operation DeleteCluster for usage and error information.

Returned Error Codes:

* ErrCodeNotFoundException "NotFoundException"
Returns information about an error.

* ErrCodeBadRequestException "BadRequestException"
Returns information about an error.

* ErrCodeInternalServerErrorException "InternalServerErrorException"
Returns information about an error.

* ErrCodeForbiddenException "ForbiddenException"
Returns information about an error.

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DeleteCluster

func (*Kafka) DeleteClusterRequest

func (c *Kafka) DeleteClusterRequest(input *DeleteClusterInput) (req *request.Request, output *DeleteClusterOutput)

DeleteClusterRequest generates a "aws/request.Request" representing the client's request for the DeleteCluster operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See DeleteCluster for more information on using the DeleteCluster API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the DeleteClusterRequest method.
req, resp := client.DeleteClusterRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DeleteCluster

func (*Kafka) DeleteClusterWithContext

func (c *Kafka) DeleteClusterWithContext(ctx aws.Context, input *DeleteClusterInput, opts ...request.Option) (*DeleteClusterOutput, error)

DeleteClusterWithContext is the same as DeleteCluster with the addition of the ability to pass a context and additional request options.

See DeleteCluster for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Kafka) DescribeCluster

func (c *Kafka) DescribeCluster(input *DescribeClusterInput) (*DescribeClusterOutput, error)

DescribeCluster API operation for Managed Streaming for Kafka.

Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Managed Streaming for Kafka's API operation DescribeCluster for usage and error information.

Returned Error Codes:

* ErrCodeNotFoundException "NotFoundException"
Returns information about an error.

* ErrCodeBadRequestException "BadRequestException"
Returns information about an error.

* ErrCodeUnauthorizedException "UnauthorizedException"
Returns information about an error.

* ErrCodeInternalServerErrorException "InternalServerErrorException"
Returns information about an error.

* ErrCodeForbiddenException "ForbiddenException"
Returns information about an error.

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeCluster

func (*Kafka) DescribeClusterOperation

func (c *Kafka) DescribeClusterOperation(input *DescribeClusterOperationInput) (*DescribeClusterOperationOutput, error)

DescribeClusterOperation API operation for Managed Streaming for Kafka.

Returns a description of the cluster operation specified by the ARN.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Managed Streaming for Kafka's API operation DescribeClusterOperation for usage and error information.

Returned Error Codes:

* ErrCodeNotFoundException "NotFoundException"
Returns information about an error.

* ErrCodeBadRequestException "BadRequestException"
Returns information about an error.

* ErrCodeUnauthorizedException "UnauthorizedException"
Returns information about an error.

* ErrCodeInternalServerErrorException "InternalServerErrorException"
Returns information about an error.

* ErrCodeForbiddenException "ForbiddenException"
Returns information about an error.

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeClusterOperation

func (*Kafka) DescribeClusterOperationRequest

func (c *Kafka) DescribeClusterOperationRequest(input *DescribeClusterOperationInput) (req *request.Request, output *DescribeClusterOperationOutput)

DescribeClusterOperationRequest generates a "aws/request.Request" representing the client's request for the DescribeClusterOperation operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See DescribeClusterOperation for more information on using the DescribeClusterOperation API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the DescribeClusterOperationRequest method.
req, resp := client.DescribeClusterOperationRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeClusterOperation

func (*Kafka) DescribeClusterOperationWithContext

func (c *Kafka) DescribeClusterOperationWithContext(ctx aws.Context, input *DescribeClusterOperationInput, opts ...request.Option) (*DescribeClusterOperationOutput, error)

DescribeClusterOperationWithContext is the same as DescribeClusterOperation with the addition of the ability to pass a context and additional request options.

See DescribeClusterOperation for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Kafka) DescribeClusterRequest

func (c *Kafka) DescribeClusterRequest(input *DescribeClusterInput) (req *request.Request, output *DescribeClusterOutput)

DescribeClusterRequest generates a "aws/request.Request" representing the client's request for the DescribeCluster operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See DescribeCluster for more information on using the DescribeCluster API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the DescribeClusterRequest method.
req, resp := client.DescribeClusterRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeCluster

func (*Kafka) DescribeClusterWithContext

func (c *Kafka) DescribeClusterWithContext(ctx aws.Context, input *DescribeClusterInput, opts ...request.Option) (*DescribeClusterOutput, error)

DescribeClusterWithContext is the same as DescribeCluster with the addition of the ability to pass a context and additional request options.

See DescribeCluster for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Kafka) DescribeConfiguration

func (c *Kafka) DescribeConfiguration(input *DescribeConfigurationInput) (*DescribeConfigurationOutput, error)

DescribeConfiguration API operation for Managed Streaming for Kafka.

Returns a description of this MSK configuration.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Managed Streaming for Kafka's API operation DescribeConfiguration for usage and error information.

Returned Error Codes:

* ErrCodeBadRequestException "BadRequestException"
Returns information about an error.

* ErrCodeUnauthorizedException "UnauthorizedException"
Returns information about an error.

* ErrCodeInternalServerErrorException "InternalServerErrorException"
Returns information about an error.

* ErrCodeForbiddenException "ForbiddenException"
Returns information about an error.

* ErrCodeNotFoundException "NotFoundException"
Returns information about an error.

* ErrCodeServiceUnavailableException "ServiceUnavailableException"
Returns information about an error.

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeConfiguration

func (*Kafka) DescribeConfigurationRequest

func (c *Kafka) DescribeConfigurationRequest(input *DescribeConfigurationInput) (req *request.Request, output *DescribeConfigurationOutput)

DescribeConfigurationRequest generates a "aws/request.Request" representing the client's request for the DescribeConfiguration operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See DescribeConfiguration for more information on using the DescribeConfiguration API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the DescribeConfigurationRequest method.
req, resp := client.DescribeConfigurationRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeConfiguration

func (*Kafka) DescribeConfigurationRevision

func (c *Kafka) DescribeConfigurationRevision(input *DescribeConfigurationRevisionInput) (*DescribeConfigurationRevisionOutput, error)

DescribeConfigurationRevision API operation for Managed Streaming for Kafka.

Returns a description of this revision of the configuration.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Managed Streaming for Kafka's API operation DescribeConfigurationRevision for usage and error information.

Returned Error Codes:

* ErrCodeBadRequestException "BadRequestException"
Returns information about an error.

* ErrCodeUnauthorizedException "UnauthorizedException"
Returns information about an error.

* ErrCodeInternalServerErrorException "InternalServerErrorException"
Returns information about an error.

* ErrCodeForbiddenException "ForbiddenException"
Returns information about an error.

* ErrCodeNotFoundException "NotFoundException"
Returns information about an error.

* ErrCodeServiceUnavailableException "ServiceUnavailableException"
Returns information about an error.

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeConfigurationRevision

func (*Kafka) DescribeConfigurationRevisionRequest

func (c *Kafka) DescribeConfigurationRevisionRequest(input *DescribeConfigurationRevisionInput) (req *request.Request, output *DescribeConfigurationRevisionOutput)

DescribeConfigurationRevisionRequest generates a "aws/request.Request" representing the client's request for the DescribeConfigurationRevision operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See DescribeConfigurationRevision for more information on using the DescribeConfigurationRevision API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the DescribeConfigurationRevisionRequest method.
req, resp := client.DescribeConfigurationRevisionRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeConfigurationRevision

func (*Kafka) DescribeConfigurationRevisionWithContext

func (c *Kafka) DescribeConfigurationRevisionWithContext(ctx aws.Context, input *DescribeConfigurationRevisionInput, opts ...request.Option) (*DescribeConfigurationRevisionOutput, error)

DescribeConfigurationRevisionWithContext is the same as DescribeConfigurationRevision with the addition of the ability to pass a context and additional request options.

See DescribeConfigurationRevision for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Kafka) DescribeConfigurationWithContext

func (c *Kafka) DescribeConfigurationWithContext(ctx aws.Context, input *DescribeConfigurationInput, opts ...request.Option) (*DescribeConfigurationOutput, error)

DescribeConfigurationWithContext is the same as DescribeConfiguration with the addition of the ability to pass a context and additional request options.

See DescribeConfiguration for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Kafka) GetBootstrapBrokers

func (c *Kafka) GetBootstrapBrokers(input *GetBootstrapBrokersInput) (*GetBootstrapBrokersOutput, error)

GetBootstrapBrokers API operation for Managed Streaming for Kafka.

A list of brokers that a client application can use to bootstrap.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Managed Streaming for Kafka's API operation GetBootstrapBrokers for usage and error information.

Returned Error Codes:

* ErrCodeBadRequestException "BadRequestException"
Returns information about an error.

* ErrCodeUnauthorizedException "UnauthorizedException"
Returns information about an error.

* ErrCodeInternalServerErrorException "InternalServerErrorException"
Returns information about an error.

* ErrCodeConflictException "ConflictException"
Returns information about an error.

* ErrCodeForbiddenException "ForbiddenException"
Returns information about an error.

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/GetBootstrapBrokers

func (*Kafka) GetBootstrapBrokersRequest

func (c *Kafka) GetBootstrapBrokersRequest(input *GetBootstrapBrokersInput) (req *request.Request, output *GetBootstrapBrokersOutput)

GetBootstrapBrokersRequest generates a "aws/request.Request" representing the client's request for the GetBootstrapBrokers operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See GetBootstrapBrokers for more information on using the GetBootstrapBrokers API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the GetBootstrapBrokersRequest method.
req, resp := client.GetBootstrapBrokersRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/GetBootstrapBrokers

func (*Kafka) GetBootstrapBrokersWithContext

func (c *Kafka) GetBootstrapBrokersWithContext(ctx aws.Context, input *GetBootstrapBrokersInput, opts ...request.Option) (*GetBootstrapBrokersOutput, error)

GetBootstrapBrokersWithContext is the same as GetBootstrapBrokers with the addition of the ability to pass a context and additional request options.

See GetBootstrapBrokers for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Kafka) ListClusterOperations

func (c *Kafka) ListClusterOperations(input *ListClusterOperationsInput) (*ListClusterOperationsOutput, error)

ListClusterOperations API operation for Managed Streaming for Kafka.

Returns a list of all the operations that have been performed on the specified MSK cluster.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Managed Streaming for Kafka's API operation ListClusterOperations for usage and error information.

Returned Error Codes:

* ErrCodeBadRequestException "BadRequestException"
Returns information about an error.

* ErrCodeInternalServerErrorException "InternalServerErrorException"
Returns information about an error.

* ErrCodeUnauthorizedException "UnauthorizedException"
Returns information about an error.

* ErrCodeForbiddenException "ForbiddenException"
Returns information about an error.

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListClusterOperations

func (*Kafka) ListClusterOperationsPages

func (c *Kafka) ListClusterOperationsPages(input *ListClusterOperationsInput, fn func(*ListClusterOperationsOutput, bool) bool) error

ListClusterOperationsPages iterates over the pages of a ListClusterOperations operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See ListClusterOperations method for more information on how to use this operation.

Note: This operation can generate multiple requests to a service.

// Example iterating over at most 3 pages of a ListClusterOperations operation.
pageNum := 0
err := client.ListClusterOperationsPages(params,
    func(page *kafka.ListClusterOperationsOutput, lastPage bool) bool {
        pageNum++
        fmt.Println(page)
        return pageNum <= 3
    })

func (*Kafka) ListClusterOperationsPagesWithContext

func (c *Kafka) ListClusterOperationsPagesWithContext(ctx aws.Context, input *ListClusterOperationsInput, fn func(*ListClusterOperationsOutput, bool) bool, opts ...request.Option) error

ListClusterOperationsPagesWithContext same as ListClusterOperationsPages except it takes a Context and allows setting request options on the pages.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Kafka) ListClusterOperationsRequest

func (c *Kafka) ListClusterOperationsRequest(input *ListClusterOperationsInput) (req *request.Request, output *ListClusterOperationsOutput)

ListClusterOperationsRequest generates a "aws/request.Request" representing the client's request for the ListClusterOperations operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See ListClusterOperations for more information on using the ListClusterOperations API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the ListClusterOperationsRequest method.
req, resp := client.ListClusterOperationsRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListClusterOperations

func (*Kafka) ListClusterOperationsWithContext

func (c *Kafka) ListClusterOperationsWithContext(ctx aws.Context, input *ListClusterOperationsInput, opts ...request.Option) (*ListClusterOperationsOutput, error)

ListClusterOperationsWithContext is the same as ListClusterOperations with the addition of the ability to pass a context and additional request options.

See ListClusterOperations for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Kafka) ListClusters

func (c *Kafka) ListClusters(input *ListClustersInput) (*ListClustersOutput, error)

ListClusters API operation for Managed Streaming for Kafka.

Returns a list of all the MSK clusters in the current Region.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Managed Streaming for Kafka's API operation ListClusters for usage and error information.

Returned Error Codes:

* ErrCodeBadRequestException "BadRequestException"
Returns information about an error.

* ErrCodeInternalServerErrorException "InternalServerErrorException"
Returns information about an error.

* ErrCodeUnauthorizedException "UnauthorizedException"
Returns information about an error.

* ErrCodeForbiddenException "ForbiddenException"
Returns information about an error.

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListClusters

func (*Kafka) ListClustersPages

func (c *Kafka) ListClustersPages(input *ListClustersInput, fn func(*ListClustersOutput, bool) bool) error

ListClustersPages iterates over the pages of a ListClusters operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See ListClusters method for more information on how to use this operation.

Note: This operation can generate multiple requests to a service.

// Example iterating over at most 3 pages of a ListClusters operation.
pageNum := 0
err := client.ListClustersPages(params,
    func(page *kafka.ListClustersOutput, lastPage bool) bool {
        pageNum++
        fmt.Println(page)
        return pageNum <= 3
    })

func (*Kafka) ListClustersPagesWithContext

func (c *Kafka) ListClustersPagesWithContext(ctx aws.Context, input *ListClustersInput, fn func(*ListClustersOutput, bool) bool, opts ...request.Option) error

ListClustersPagesWithContext same as ListClustersPages except it takes a Context and allows setting request options on the pages.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Kafka) ListClustersRequest

func (c *Kafka) ListClustersRequest(input *ListClustersInput) (req *request.Request, output *ListClustersOutput)

ListClustersRequest generates a "aws/request.Request" representing the client's request for the ListClusters operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See ListClusters for more information on using the ListClusters API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the ListClustersRequest method.
req, resp := client.ListClustersRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListClusters

func (*Kafka) ListClustersWithContext

func (c *Kafka) ListClustersWithContext(ctx aws.Context, input *ListClustersInput, opts ...request.Option) (*ListClustersOutput, error)

ListClustersWithContext is the same as ListClusters with the addition of the ability to pass a context and additional request options.

See ListClusters for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Kafka) ListConfigurationRevisions

func (c *Kafka) ListConfigurationRevisions(input *ListConfigurationRevisionsInput) (*ListConfigurationRevisionsOutput, error)

ListConfigurationRevisions API operation for Managed Streaming for Kafka.

Returns a list of all the revisions of an MSK configuration.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Managed Streaming for Kafka's API operation ListConfigurationRevisions for usage and error information.

Returned Error Codes:

* ErrCodeBadRequestException "BadRequestException"
Returns information about an error.

* ErrCodeUnauthorizedException "UnauthorizedException"
Returns information about an error.

* ErrCodeInternalServerErrorException "InternalServerErrorException"
Returns information about an error.

* ErrCodeForbiddenException "ForbiddenException"
Returns information about an error.

* ErrCodeNotFoundException "NotFoundException"
Returns information about an error.

* ErrCodeServiceUnavailableException "ServiceUnavailableException"
Returns information about an error.

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListConfigurationRevisions

func (*Kafka) ListConfigurationRevisionsPages

func (c *Kafka) ListConfigurationRevisionsPages(input *ListConfigurationRevisionsInput, fn func(*ListConfigurationRevisionsOutput, bool) bool) error

ListConfigurationRevisionsPages iterates over the pages of a ListConfigurationRevisions operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See ListConfigurationRevisions method for more information on how to use this operation.

Note: This operation can generate multiple requests to a service.

// Example iterating over at most 3 pages of a ListConfigurationRevisions operation.
pageNum := 0
err := client.ListConfigurationRevisionsPages(params,
    func(page *kafka.ListConfigurationRevisionsOutput, lastPage bool) bool {
        pageNum++
        fmt.Println(page)
        return pageNum <= 3
    })

func (*Kafka) ListConfigurationRevisionsPagesWithContext

func (c *Kafka) ListConfigurationRevisionsPagesWithContext(ctx aws.Context, input *ListConfigurationRevisionsInput, fn func(*ListConfigurationRevisionsOutput, bool) bool, opts ...request.Option) error

ListConfigurationRevisionsPagesWithContext same as ListConfigurationRevisionsPages except it takes a Context and allows setting request options on the pages.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Kafka) ListConfigurationRevisionsRequest

func (c *Kafka) ListConfigurationRevisionsRequest(input *ListConfigurationRevisionsInput) (req *request.Request, output *ListConfigurationRevisionsOutput)

ListConfigurationRevisionsRequest generates a "aws/request.Request" representing the client's request for the ListConfigurationRevisions operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See ListConfigurationRevisions for more information on using the ListConfigurationRevisions API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the ListConfigurationRevisionsRequest method.
req, resp := client.ListConfigurationRevisionsRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListConfigurationRevisions

func (*Kafka) ListConfigurationRevisionsWithContext

func (c *Kafka) ListConfigurationRevisionsWithContext(ctx aws.Context, input *ListConfigurationRevisionsInput, opts ...request.Option) (*ListConfigurationRevisionsOutput, error)

ListConfigurationRevisionsWithContext is the same as ListConfigurationRevisions with the addition of the ability to pass a context and additional request options.

See ListConfigurationRevisions for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Kafka) ListConfigurations

func (c *Kafka) ListConfigurations(input *ListConfigurationsInput) (*ListConfigurationsOutput, error)

ListConfigurations API operation for Managed Streaming for Kafka.

Returns a list of all the MSK configurations in this Region.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Managed Streaming for Kafka's API operation ListConfigurations for usage and error information.

Returned Error Codes:

* ErrCodeServiceUnavailableException "ServiceUnavailableException"
Returns information about an error.

* ErrCodeBadRequestException "BadRequestException"
Returns information about an error.

* ErrCodeUnauthorizedException "UnauthorizedException"
Returns information about an error.

* ErrCodeInternalServerErrorException "InternalServerErrorException"
Returns information about an error.

* ErrCodeForbiddenException "ForbiddenException"
Returns information about an error.

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListConfigurations

func (*Kafka) ListConfigurationsPages

func (c *Kafka) ListConfigurationsPages(input *ListConfigurationsInput, fn func(*ListConfigurationsOutput, bool) bool) error

ListConfigurationsPages iterates over the pages of a ListConfigurations operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See ListConfigurations method for more information on how to use this operation.

Note: This operation can generate multiple requests to a service.

// Example iterating over at most 3 pages of a ListConfigurations operation.
pageNum := 0
err := client.ListConfigurationsPages(params,
    func(page *kafka.ListConfigurationsOutput, lastPage bool) bool {
        pageNum++
        fmt.Println(page)
        return pageNum <= 3
    })

func (*Kafka) ListConfigurationsPagesWithContext

func (c *Kafka) ListConfigurationsPagesWithContext(ctx aws.Context, input *ListConfigurationsInput, fn func(*ListConfigurationsOutput, bool) bool, opts ...request.Option) error

ListConfigurationsPagesWithContext same as ListConfigurationsPages except it takes a Context and allows setting request options on the pages.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Kafka) ListConfigurationsRequest

func (c *Kafka) ListConfigurationsRequest(input *ListConfigurationsInput) (req *request.Request, output *ListConfigurationsOutput)

ListConfigurationsRequest generates a "aws/request.Request" representing the client's request for the ListConfigurations operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See ListConfigurations for more information on using the ListConfigurations API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the ListConfigurationsRequest method.
req, resp := client.ListConfigurationsRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListConfigurations

func (*Kafka) ListConfigurationsWithContext

func (c *Kafka) ListConfigurationsWithContext(ctx aws.Context, input *ListConfigurationsInput, opts ...request.Option) (*ListConfigurationsOutput, error)

ListConfigurationsWithContext is the same as ListConfigurations with the addition of the ability to pass a context and additional request options.

See ListConfigurations for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Kafka) ListNodes

func (c *Kafka) ListNodes(input *ListNodesInput) (*ListNodesOutput, error)

ListNodes API operation for Managed Streaming for Kafka.

Returns a list of the broker nodes in the cluster.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Managed Streaming for Kafka's API operation ListNodes for usage and error information.

Returned Error Codes:

* ErrCodeNotFoundException "NotFoundException"
Returns information about an error.

* ErrCodeBadRequestException "BadRequestException"
Returns information about an error.

* ErrCodeInternalServerErrorException "InternalServerErrorException"
Returns information about an error.

* ErrCodeForbiddenException "ForbiddenException"
Returns information about an error.

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListNodes

func (*Kafka) ListNodesPages

func (c *Kafka) ListNodesPages(input *ListNodesInput, fn func(*ListNodesOutput, bool) bool) error

ListNodesPages iterates over the pages of a ListNodes operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See ListNodes method for more information on how to use this operation.

Note: This operation can generate multiple requests to a service.

// Example iterating over at most 3 pages of a ListNodes operation.
pageNum := 0
err := client.ListNodesPages(params,
    func(page *kafka.ListNodesOutput, lastPage bool) bool {
        pageNum++
        fmt.Println(page)
        return pageNum <= 3
    })

func (*Kafka) ListNodesPagesWithContext

func (c *Kafka) ListNodesPagesWithContext(ctx aws.Context, input *ListNodesInput, fn func(*ListNodesOutput, bool) bool, opts ...request.Option) error

ListNodesPagesWithContext same as ListNodesPages except it takes a Context and allows setting request options on the pages.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Kafka) ListNodesRequest

func (c *Kafka) ListNodesRequest(input *ListNodesInput) (req *request.Request, output *ListNodesOutput)

ListNodesRequest generates a "aws/request.Request" representing the client's request for the ListNodes operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See ListNodes for more information on using the ListNodes API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the ListNodesRequest method.
req, resp := client.ListNodesRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListNodes

func (*Kafka) ListNodesWithContext

func (c *Kafka) ListNodesWithContext(ctx aws.Context, input *ListNodesInput, opts ...request.Option) (*ListNodesOutput, error)

ListNodesWithContext is the same as ListNodes with the addition of the ability to pass a context and additional request options.

See ListNodes for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Kafka) ListTagsForResource

func (c *Kafka) ListTagsForResource(input *ListTagsForResourceInput) (*ListTagsForResourceOutput, error)

ListTagsForResource API operation for Managed Streaming for Kafka.

Returns a list of the tags associated with the specified resource.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Managed Streaming for Kafka's API operation ListTagsForResource for usage and error information.

Returned Error Codes:

* ErrCodeNotFoundException "NotFoundException"
Returns information about an error.

* ErrCodeBadRequestException "BadRequestException"
Returns information about an error.

* ErrCodeInternalServerErrorException "InternalServerErrorException"
Returns information about an error.

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListTagsForResource

func (*Kafka) ListTagsForResourceRequest

func (c *Kafka) ListTagsForResourceRequest(input *ListTagsForResourceInput) (req *request.Request, output *ListTagsForResourceOutput)

ListTagsForResourceRequest generates a "aws/request.Request" representing the client's request for the ListTagsForResource operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See ListTagsForResource for more information on using the ListTagsForResource API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the ListTagsForResourceRequest method.
req, resp := client.ListTagsForResourceRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListTagsForResource

func (*Kafka) ListTagsForResourceWithContext

func (c *Kafka) ListTagsForResourceWithContext(ctx aws.Context, input *ListTagsForResourceInput, opts ...request.Option) (*ListTagsForResourceOutput, error)

ListTagsForResourceWithContext is the same as ListTagsForResource with the addition of the ability to pass a context and additional request options.

See ListTagsForResource for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Kafka) TagResource

func (c *Kafka) TagResource(input *TagResourceInput) (*TagResourceOutput, error)

TagResource API operation for Managed Streaming for Kafka.

Adds tags to the specified MSK resource.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Managed Streaming for Kafka's API operation TagResource for usage and error information.

Returned Error Codes:

* ErrCodeNotFoundException "NotFoundException"
Returns information about an error.

* ErrCodeBadRequestException "BadRequestException"
Returns information about an error.

* ErrCodeInternalServerErrorException "InternalServerErrorException"
Returns information about an error.

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/TagResource

func (*Kafka) TagResourceRequest

func (c *Kafka) TagResourceRequest(input *TagResourceInput) (req *request.Request, output *TagResourceOutput)

TagResourceRequest generates a "aws/request.Request" representing the client's request for the TagResource operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See TagResource for more information on using the TagResource API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the TagResourceRequest method.
req, resp := client.TagResourceRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/TagResource

func (*Kafka) TagResourceWithContext

func (c *Kafka) TagResourceWithContext(ctx aws.Context, input *TagResourceInput, opts ...request.Option) (*TagResourceOutput, error)

TagResourceWithContext is the same as TagResource with the addition of the ability to pass a context and additional request options.

See TagResource for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Kafka) UntagResource

func (c *Kafka) UntagResource(input *UntagResourceInput) (*UntagResourceOutput, error)

UntagResource API operation for Managed Streaming for Kafka.

Removes the tags associated with the keys that are provided in the query.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Managed Streaming for Kafka's API operation UntagResource for usage and error information.

Returned Error Codes:

* ErrCodeNotFoundException "NotFoundException"
Returns information about an error.

* ErrCodeBadRequestException "BadRequestException"
Returns information about an error.

* ErrCodeInternalServerErrorException "InternalServerErrorException"
Returns information about an error.

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UntagResource

func (*Kafka) UntagResourceRequest

func (c *Kafka) UntagResourceRequest(input *UntagResourceInput) (req *request.Request, output *UntagResourceOutput)

UntagResourceRequest generates a "aws/request.Request" representing the client's request for the UntagResource operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See UntagResource for more information on using the UntagResource API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the UntagResourceRequest method.
req, resp := client.UntagResourceRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UntagResource

func (*Kafka) UntagResourceWithContext

func (c *Kafka) UntagResourceWithContext(ctx aws.Context, input *UntagResourceInput, opts ...request.Option) (*UntagResourceOutput, error)

UntagResourceWithContext is the same as UntagResource with the addition of the ability to pass a context and additional request options.

See UntagResource for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Kafka) UpdateBrokerCount

func (c *Kafka) UpdateBrokerCount(input *UpdateBrokerCountInput) (*UpdateBrokerCountOutput, error)

UpdateBrokerCount API operation for Managed Streaming for Kafka.

Updates the number of broker nodes in the cluster. You can use this operation to increase the number of brokers in an existing cluster. You can't decrease the number of brokers.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Managed Streaming for Kafka's API operation UpdateBrokerCount for usage and error information.

Returned Error Codes:

* ErrCodeServiceUnavailableException "ServiceUnavailableException"
Returns information about an error.

* ErrCodeBadRequestException "BadRequestException"
Returns information about an error.

* ErrCodeUnauthorizedException "UnauthorizedException"
Returns information about an error.

* ErrCodeInternalServerErrorException "InternalServerErrorException"
Returns information about an error.

* ErrCodeForbiddenException "ForbiddenException"
Returns information about an error.

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateBrokerCount

func (*Kafka) UpdateBrokerCountRequest

func (c *Kafka) UpdateBrokerCountRequest(input *UpdateBrokerCountInput) (req *request.Request, output *UpdateBrokerCountOutput)

UpdateBrokerCountRequest generates a "aws/request.Request" representing the client's request for the UpdateBrokerCount operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See UpdateBrokerCount for more information on using the UpdateBrokerCount API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the UpdateBrokerCountRequest method.
req, resp := client.UpdateBrokerCountRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateBrokerCount

func (*Kafka) UpdateBrokerCountWithContext

func (c *Kafka) UpdateBrokerCountWithContext(ctx aws.Context, input *UpdateBrokerCountInput, opts ...request.Option) (*UpdateBrokerCountOutput, error)

UpdateBrokerCountWithContext is the same as UpdateBrokerCount with the addition of the ability to pass a context and additional request options.

See UpdateBrokerCount for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Kafka) UpdateBrokerStorage

func (c *Kafka) UpdateBrokerStorage(input *UpdateBrokerStorageInput) (*UpdateBrokerStorageOutput, error)

UpdateBrokerStorage API operation for Managed Streaming for Kafka.

Updates the EBS storage associated with MSK brokers.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Managed Streaming for Kafka's API operation UpdateBrokerStorage for usage and error information.

Returned Error Codes:

* ErrCodeServiceUnavailableException "ServiceUnavailableException"
Returns information about an error.

* ErrCodeBadRequestException "BadRequestException"
Returns information about an error.

* ErrCodeUnauthorizedException "UnauthorizedException"
Returns information about an error.

* ErrCodeInternalServerErrorException "InternalServerErrorException"
Returns information about an error.

* ErrCodeForbiddenException "ForbiddenException"
Returns information about an error.

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateBrokerStorage

func (*Kafka) UpdateBrokerStorageRequest

func (c *Kafka) UpdateBrokerStorageRequest(input *UpdateBrokerStorageInput) (req *request.Request, output *UpdateBrokerStorageOutput)

UpdateBrokerStorageRequest generates a "aws/request.Request" representing the client's request for the UpdateBrokerStorage operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See UpdateBrokerStorage for more information on using the UpdateBrokerStorage API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the UpdateBrokerStorageRequest method.
req, resp := client.UpdateBrokerStorageRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateBrokerStorage

func (*Kafka) UpdateBrokerStorageWithContext

func (c *Kafka) UpdateBrokerStorageWithContext(ctx aws.Context, input *UpdateBrokerStorageInput, opts ...request.Option) (*UpdateBrokerStorageOutput, error)

UpdateBrokerStorageWithContext is the same as UpdateBrokerStorage with the addition of the ability to pass a context and additional request options.

See UpdateBrokerStorage for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Kafka) UpdateClusterConfiguration

func (c *Kafka) UpdateClusterConfiguration(input *UpdateClusterConfigurationInput) (*UpdateClusterConfigurationOutput, error)

UpdateClusterConfiguration API operation for Managed Streaming for Kafka.

Updates the cluster with the configuration that is specified in the request body.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Managed Streaming for Kafka's API operation UpdateClusterConfiguration for usage and error information.

Returned Error Codes:

* ErrCodeBadRequestException "BadRequestException"
Returns information about an error.

* ErrCodeUnauthorizedException "UnauthorizedException"
Returns information about an error.

* ErrCodeInternalServerErrorException "InternalServerErrorException"
Returns information about an error.

* ErrCodeForbiddenException "ForbiddenException"
Returns information about an error.

* ErrCodeNotFoundException "NotFoundException"
Returns information about an error.

* ErrCodeServiceUnavailableException "ServiceUnavailableException"
Returns information about an error.

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateClusterConfiguration

func (*Kafka) UpdateClusterConfigurationRequest

func (c *Kafka) UpdateClusterConfigurationRequest(input *UpdateClusterConfigurationInput) (req *request.Request, output *UpdateClusterConfigurationOutput)

UpdateClusterConfigurationRequest generates a "aws/request.Request" representing the client's request for the UpdateClusterConfiguration operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See UpdateClusterConfiguration for more information on using the UpdateClusterConfiguration API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the UpdateClusterConfigurationRequest method.
req, resp := client.UpdateClusterConfigurationRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateClusterConfiguration

func (*Kafka) UpdateClusterConfigurationWithContext

func (c *Kafka) UpdateClusterConfigurationWithContext(ctx aws.Context, input *UpdateClusterConfigurationInput, opts ...request.Option) (*UpdateClusterConfigurationOutput, error)

UpdateClusterConfigurationWithContext is the same as UpdateClusterConfiguration with the addition of the ability to pass a context and additional request options.

See UpdateClusterConfiguration for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

type ListClusterOperationsInput

type ListClusterOperationsInput struct {

    // ClusterArn is a required field
    ClusterArn *string `location:"uri" locationName:"clusterArn" type:"string" required:"true"`

    MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"`

    NextToken *string `location:"querystring" locationName:"nextToken" type:"string"`
    // contains filtered or unexported fields
}

func (ListClusterOperationsInput) GoString

func (s ListClusterOperationsInput) GoString() string

GoString returns the string representation

func (*ListClusterOperationsInput) SetClusterArn

func (s *ListClusterOperationsInput) SetClusterArn(v string) *ListClusterOperationsInput

SetClusterArn sets the ClusterArn field's value.

func (*ListClusterOperationsInput) SetMaxResults

func (s *ListClusterOperationsInput) SetMaxResults(v int64) *ListClusterOperationsInput

SetMaxResults sets the MaxResults field's value.

func (*ListClusterOperationsInput) SetNextToken

func (s *ListClusterOperationsInput) SetNextToken(v string) *ListClusterOperationsInput

SetNextToken sets the NextToken field's value.

func (ListClusterOperationsInput) String

func (s ListClusterOperationsInput) String() string

String returns the string representation

func (*ListClusterOperationsInput) Validate

func (s *ListClusterOperationsInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ListClusterOperationsOutput

type ListClusterOperationsOutput struct {

    // An array of cluster operation information objects.
    ClusterOperationInfoList []*ClusterOperationInfo `locationName:"clusterOperationInfoList" type:"list"`

    // If the response of ListClusterOperations is truncated, it returns a NextToken
    // in the response. This Nexttoken should be sent in the subsequent request
    // to ListClusterOperations.
    NextToken *string `locationName:"nextToken" type:"string"`
    // contains filtered or unexported fields
}

The response contains an array containing cluster operation information and a next token if the response is truncated.

func (ListClusterOperationsOutput) GoString

func (s ListClusterOperationsOutput) GoString() string

GoString returns the string representation

func (*ListClusterOperationsOutput) SetClusterOperationInfoList

func (s *ListClusterOperationsOutput) SetClusterOperationInfoList(v []*ClusterOperationInfo) *ListClusterOperationsOutput

SetClusterOperationInfoList sets the ClusterOperationInfoList field's value.

func (*ListClusterOperationsOutput) SetNextToken

func (s *ListClusterOperationsOutput) SetNextToken(v string) *ListClusterOperationsOutput

SetNextToken sets the NextToken field's value.

func (ListClusterOperationsOutput) String

func (s ListClusterOperationsOutput) String() string

String returns the string representation

type ListClustersInput

type ListClustersInput struct {
    ClusterNameFilter *string `location:"querystring" locationName:"clusterNameFilter" type:"string"`

    MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"`

    NextToken *string `location:"querystring" locationName:"nextToken" type:"string"`
    // contains filtered or unexported fields
}

func (ListClustersInput) GoString

func (s ListClustersInput) GoString() string

GoString returns the string representation

func (*ListClustersInput) SetClusterNameFilter

func (s *ListClustersInput) SetClusterNameFilter(v string) *ListClustersInput

SetClusterNameFilter sets the ClusterNameFilter field's value.

func (*ListClustersInput) SetMaxResults

func (s *ListClustersInput) SetMaxResults(v int64) *ListClustersInput

SetMaxResults sets the MaxResults field's value.

func (*ListClustersInput) SetNextToken

func (s *ListClustersInput) SetNextToken(v string) *ListClustersInput

SetNextToken sets the NextToken field's value.

func (ListClustersInput) String

func (s ListClustersInput) String() string

String returns the string representation

func (*ListClustersInput) Validate

func (s *ListClustersInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ListClustersOutput

type ListClustersOutput struct {

    // Information on each of the MSK clusters in the response.
    ClusterInfoList []*ClusterInfo `locationName:"clusterInfoList" type:"list"`

    // The paginated results marker. When the result of a ListClusters operation
    // is truncated, the call returns NextToken in the response. To get another
    // batch of clusters, provide this token in your next request.
    NextToken *string `locationName:"nextToken" type:"string"`
    // contains filtered or unexported fields
}

The response contains an array containing cluster information and a next token if the response is truncated.

func (ListClustersOutput) GoString

func (s ListClustersOutput) GoString() string

GoString returns the string representation

func (*ListClustersOutput) SetClusterInfoList

func (s *ListClustersOutput) SetClusterInfoList(v []*ClusterInfo) *ListClustersOutput

SetClusterInfoList sets the ClusterInfoList field's value.

func (*ListClustersOutput) SetNextToken

func (s *ListClustersOutput) SetNextToken(v string) *ListClustersOutput

SetNextToken sets the NextToken field's value.

func (ListClustersOutput) String

func (s ListClustersOutput) String() string

String returns the string representation

type ListConfigurationRevisionsInput

type ListConfigurationRevisionsInput struct {

    // Arn is a required field
    Arn *string `location:"uri" locationName:"arn" type:"string" required:"true"`

    MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"`

    NextToken *string `location:"querystring" locationName:"nextToken" type:"string"`
    // contains filtered or unexported fields
}

func (ListConfigurationRevisionsInput) GoString

func (s ListConfigurationRevisionsInput) GoString() string

GoString returns the string representation

func (*ListConfigurationRevisionsInput) SetArn

func (s *ListConfigurationRevisionsInput) SetArn(v string) *ListConfigurationRevisionsInput

SetArn sets the Arn field's value.

func (*ListConfigurationRevisionsInput) SetMaxResults

func (s *ListConfigurationRevisionsInput) SetMaxResults(v int64) *ListConfigurationRevisionsInput

SetMaxResults sets the MaxResults field's value.

func (*ListConfigurationRevisionsInput) SetNextToken

func (s *ListConfigurationRevisionsInput) SetNextToken(v string) *ListConfigurationRevisionsInput

SetNextToken sets the NextToken field's value.

func (ListConfigurationRevisionsInput) String

func (s ListConfigurationRevisionsInput) String() string

String returns the string representation

func (*ListConfigurationRevisionsInput) Validate

func (s *ListConfigurationRevisionsInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ListConfigurationRevisionsOutput

type ListConfigurationRevisionsOutput struct {

    // Paginated results marker.
    NextToken *string `locationName:"nextToken" type:"string"`

    // List of ConfigurationRevision objects.
    Revisions []*ConfigurationRevision `locationName:"revisions" type:"list"`
    // contains filtered or unexported fields
}

Information about revisions of an MSK configuration.

func (ListConfigurationRevisionsOutput) GoString

func (s ListConfigurationRevisionsOutput) GoString() string

GoString returns the string representation

func (*ListConfigurationRevisionsOutput) SetNextToken

func (s *ListConfigurationRevisionsOutput) SetNextToken(v string) *ListConfigurationRevisionsOutput

SetNextToken sets the NextToken field's value.

func (*ListConfigurationRevisionsOutput) SetRevisions

func (s *ListConfigurationRevisionsOutput) SetRevisions(v []*ConfigurationRevision) *ListConfigurationRevisionsOutput

SetRevisions sets the Revisions field's value.

func (ListConfigurationRevisionsOutput) String

func (s ListConfigurationRevisionsOutput) String() string

String returns the string representation

type ListConfigurationsInput

type ListConfigurationsInput struct {
    MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"`

    NextToken *string `location:"querystring" locationName:"nextToken" type:"string"`
    // contains filtered or unexported fields
}

func (ListConfigurationsInput) GoString

func (s ListConfigurationsInput) GoString() string

GoString returns the string representation

func (*ListConfigurationsInput) SetMaxResults

func (s *ListConfigurationsInput) SetMaxResults(v int64) *ListConfigurationsInput

SetMaxResults sets the MaxResults field's value.

func (*ListConfigurationsInput) SetNextToken

func (s *ListConfigurationsInput) SetNextToken(v string) *ListConfigurationsInput

SetNextToken sets the NextToken field's value.

func (ListConfigurationsInput) String

func (s ListConfigurationsInput) String() string

String returns the string representation

func (*ListConfigurationsInput) Validate

func (s *ListConfigurationsInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ListConfigurationsOutput

type ListConfigurationsOutput struct {

    // An array of MSK configurations.
    Configurations []*Configuration `locationName:"configurations" type:"list"`

    // The paginated results marker. When the result of a ListConfigurations operation
    // is truncated, the call returns NextToken in the response. To get another
    // batch of configurations, provide this token in your next request.
    NextToken *string `locationName:"nextToken" type:"string"`
    // contains filtered or unexported fields
}

The response contains an array of Configuration and a next token if the response is truncated.

func (ListConfigurationsOutput) GoString

func (s ListConfigurationsOutput) GoString() string

GoString returns the string representation

func (*ListConfigurationsOutput) SetConfigurations

func (s *ListConfigurationsOutput) SetConfigurations(v []*Configuration) *ListConfigurationsOutput

SetConfigurations sets the Configurations field's value.

func (*ListConfigurationsOutput) SetNextToken

func (s *ListConfigurationsOutput) SetNextToken(v string) *ListConfigurationsOutput

SetNextToken sets the NextToken field's value.

func (ListConfigurationsOutput) String

func (s ListConfigurationsOutput) String() string

String returns the string representation

type ListNodesInput

type ListNodesInput struct {

    // ClusterArn is a required field
    ClusterArn *string `location:"uri" locationName:"clusterArn" type:"string" required:"true"`

    MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"`

    NextToken *string `location:"querystring" locationName:"nextToken" type:"string"`
    // contains filtered or unexported fields
}

func (ListNodesInput) GoString

func (s ListNodesInput) GoString() string

GoString returns the string representation

func (*ListNodesInput) SetClusterArn

func (s *ListNodesInput) SetClusterArn(v string) *ListNodesInput

SetClusterArn sets the ClusterArn field's value.

func (*ListNodesInput) SetMaxResults

func (s *ListNodesInput) SetMaxResults(v int64) *ListNodesInput

SetMaxResults sets the MaxResults field's value.

func (*ListNodesInput) SetNextToken

func (s *ListNodesInput) SetNextToken(v string) *ListNodesInput

SetNextToken sets the NextToken field's value.

func (ListNodesInput) String

func (s ListNodesInput) String() string

String returns the string representation

func (*ListNodesInput) Validate

func (s *ListNodesInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ListNodesOutput

type ListNodesOutput struct {

    // The paginated results marker. When the result of a ListNodes operation is
    // truncated, the call returns NextToken in the response. To get another batch
    // of nodes, provide this token in your next request.
    NextToken *string `locationName:"nextToken" type:"string"`

    // List containing a NodeInfo object.
    NodeInfoList []*NodeInfo `locationName:"nodeInfoList" type:"list"`
    // contains filtered or unexported fields
}

Information about nodes in the cluster.

func (ListNodesOutput) GoString

func (s ListNodesOutput) GoString() string

GoString returns the string representation

func (*ListNodesOutput) SetNextToken

func (s *ListNodesOutput) SetNextToken(v string) *ListNodesOutput

SetNextToken sets the NextToken field's value.

func (*ListNodesOutput) SetNodeInfoList

func (s *ListNodesOutput) SetNodeInfoList(v []*NodeInfo) *ListNodesOutput

SetNodeInfoList sets the NodeInfoList field's value.

func (ListNodesOutput) String

func (s ListNodesOutput) String() string

String returns the string representation

type ListTagsForResourceInput

type ListTagsForResourceInput struct {

    // ResourceArn is a required field
    ResourceArn *string `location:"uri" locationName:"resourceArn" type:"string" required:"true"`
    // contains filtered or unexported fields
}

func (ListTagsForResourceInput) GoString

func (s ListTagsForResourceInput) GoString() string

GoString returns the string representation

func (*ListTagsForResourceInput) SetResourceArn

func (s *ListTagsForResourceInput) SetResourceArn(v string) *ListTagsForResourceInput

SetResourceArn sets the ResourceArn field's value.

func (ListTagsForResourceInput) String

func (s ListTagsForResourceInput) String() string

String returns the string representation

func (*ListTagsForResourceInput) Validate

func (s *ListTagsForResourceInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ListTagsForResourceOutput

type ListTagsForResourceOutput struct {

    // The key-value pair for the resource tag.
    Tags map[string]*string `locationName:"tags" type:"map"`
    // contains filtered or unexported fields
}

Response of listing tags for a resource.

func (ListTagsForResourceOutput) GoString

func (s ListTagsForResourceOutput) GoString() string

GoString returns the string representation

func (*ListTagsForResourceOutput) SetTags

func (s *ListTagsForResourceOutput) SetTags(v map[string]*string) *ListTagsForResourceOutput

SetTags sets the Tags field's value.

func (ListTagsForResourceOutput) String

func (s ListTagsForResourceOutput) String() string

String returns the string representation

type MutableClusterInfo

type MutableClusterInfo struct {

    // Specifies the size of the EBS volume and the ID of the associated broker.
    BrokerEBSVolumeInfo []*BrokerEBSVolumeInfo `locationName:"brokerEBSVolumeInfo" type:"list"`

    // Information about the changes in the configuration of the brokers.
    ConfigurationInfo *ConfigurationInfo `locationName:"configurationInfo" type:"structure"`

    // The number of broker nodes in the cluster.
    NumberOfBrokerNodes *int64 `locationName:"numberOfBrokerNodes" type:"integer"`
    // contains filtered or unexported fields
}

Information about cluster attributes that can be updated via update APIs.

func (MutableClusterInfo) GoString

func (s MutableClusterInfo) GoString() string

GoString returns the string representation

func (*MutableClusterInfo) SetBrokerEBSVolumeInfo

func (s *MutableClusterInfo) SetBrokerEBSVolumeInfo(v []*BrokerEBSVolumeInfo) *MutableClusterInfo

SetBrokerEBSVolumeInfo sets the BrokerEBSVolumeInfo field's value.

func (*MutableClusterInfo) SetConfigurationInfo

func (s *MutableClusterInfo) SetConfigurationInfo(v *ConfigurationInfo) *MutableClusterInfo

SetConfigurationInfo sets the ConfigurationInfo field's value.

func (*MutableClusterInfo) SetNumberOfBrokerNodes

func (s *MutableClusterInfo) SetNumberOfBrokerNodes(v int64) *MutableClusterInfo

SetNumberOfBrokerNodes sets the NumberOfBrokerNodes field's value.

func (MutableClusterInfo) String

func (s MutableClusterInfo) String() string

String returns the string representation

type NodeInfo

type NodeInfo struct {

    // The start time.
    AddedToClusterTime *string `locationName:"addedToClusterTime" type:"string"`

    // The broker node info.
    BrokerNodeInfo *BrokerNodeInfo `locationName:"brokerNodeInfo" type:"structure"`

    // The instance type.
    InstanceType *string `locationName:"instanceType" type:"string"`

    // The Amazon Resource Name (ARN) of the node.
    NodeARN *string `locationName:"nodeARN" type:"string"`

    // The node type.
    NodeType *string `locationName:"nodeType" type:"string" enum:"NodeType"`

    // The ZookeeperNodeInfo.
    ZookeeperNodeInfo *ZookeeperNodeInfo `locationName:"zookeeperNodeInfo" type:"structure"`
    // contains filtered or unexported fields
}

The node information object.

func (NodeInfo) GoString

func (s NodeInfo) GoString() string

GoString returns the string representation

func (*NodeInfo) SetAddedToClusterTime

func (s *NodeInfo) SetAddedToClusterTime(v string) *NodeInfo

SetAddedToClusterTime sets the AddedToClusterTime field's value.

func (*NodeInfo) SetBrokerNodeInfo

func (s *NodeInfo) SetBrokerNodeInfo(v *BrokerNodeInfo) *NodeInfo

SetBrokerNodeInfo sets the BrokerNodeInfo field's value.

func (*NodeInfo) SetInstanceType

func (s *NodeInfo) SetInstanceType(v string) *NodeInfo

SetInstanceType sets the InstanceType field's value.

func (*NodeInfo) SetNodeARN

func (s *NodeInfo) SetNodeARN(v string) *NodeInfo

SetNodeARN sets the NodeARN field's value.

func (*NodeInfo) SetNodeType

func (s *NodeInfo) SetNodeType(v string) *NodeInfo

SetNodeType sets the NodeType field's value.

func (*NodeInfo) SetZookeeperNodeInfo

func (s *NodeInfo) SetZookeeperNodeInfo(v *ZookeeperNodeInfo) *NodeInfo

SetZookeeperNodeInfo sets the ZookeeperNodeInfo field's value.

func (NodeInfo) String

func (s NodeInfo) String() string

String returns the string representation

type StorageInfo

type StorageInfo struct {

    // EBS volume information.
    EbsStorageInfo *EBSStorageInfo `locationName:"ebsStorageInfo" type:"structure"`
    // contains filtered or unexported fields
}

Contains information about storage volumes attached to MSK broker nodes.

func (StorageInfo) GoString

func (s StorageInfo) GoString() string

GoString returns the string representation

func (*StorageInfo) SetEbsStorageInfo

func (s *StorageInfo) SetEbsStorageInfo(v *EBSStorageInfo) *StorageInfo

SetEbsStorageInfo sets the EbsStorageInfo field's value.

func (StorageInfo) String

func (s StorageInfo) String() string

String returns the string representation

func (*StorageInfo) Validate

func (s *StorageInfo) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type TagResourceInput

type TagResourceInput struct {

    // ResourceArn is a required field
    ResourceArn *string `location:"uri" locationName:"resourceArn" type:"string" required:"true"`

    // The key-value pair for the resource tag.
    //
    // Tags is a required field
    Tags map[string]*string `locationName:"tags" type:"map" required:"true"`
    // contains filtered or unexported fields
}

Tag a resource.

func (TagResourceInput) GoString

func (s TagResourceInput) GoString() string

GoString returns the string representation

func (*TagResourceInput) SetResourceArn

func (s *TagResourceInput) SetResourceArn(v string) *TagResourceInput

SetResourceArn sets the ResourceArn field's value.

func (*TagResourceInput) SetTags

func (s *TagResourceInput) SetTags(v map[string]*string) *TagResourceInput

SetTags sets the Tags field's value.

func (TagResourceInput) String

func (s TagResourceInput) String() string

String returns the string representation

func (*TagResourceInput) Validate

func (s *TagResourceInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type TagResourceOutput

type TagResourceOutput struct {
    // contains filtered or unexported fields
}

func (TagResourceOutput) GoString

func (s TagResourceOutput) GoString() string

GoString returns the string representation

func (TagResourceOutput) String

func (s TagResourceOutput) String() string

String returns the string representation

type Tls

type Tls struct {

    // List of ACM Certificate Authority ARNs.
    CertificateAuthorityArnList []*string `locationName:"certificateAuthorityArnList" type:"list"`
    // contains filtered or unexported fields
}

Details for client authentication using TLS.

func (Tls) GoString

func (s Tls) GoString() string

GoString returns the string representation

func (*Tls) SetCertificateAuthorityArnList

func (s *Tls) SetCertificateAuthorityArnList(v []*string) *Tls

SetCertificateAuthorityArnList sets the CertificateAuthorityArnList field's value.

func (Tls) String

func (s Tls) String() string

String returns the string representation

type UntagResourceInput

type UntagResourceInput struct {

    // ResourceArn is a required field
    ResourceArn *string `location:"uri" locationName:"resourceArn" type:"string" required:"true"`

    // TagKeys is a required field
    TagKeys []*string `location:"querystring" locationName:"tagKeys" type:"list" required:"true"`
    // contains filtered or unexported fields
}

func (UntagResourceInput) GoString

func (s UntagResourceInput) GoString() string

GoString returns the string representation

func (*UntagResourceInput) SetResourceArn

func (s *UntagResourceInput) SetResourceArn(v string) *UntagResourceInput

SetResourceArn sets the ResourceArn field's value.

func (*UntagResourceInput) SetTagKeys

func (s *UntagResourceInput) SetTagKeys(v []*string) *UntagResourceInput

SetTagKeys sets the TagKeys field's value.

func (UntagResourceInput) String

func (s UntagResourceInput) String() string

String returns the string representation

func (*UntagResourceInput) Validate

func (s *UntagResourceInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type UntagResourceOutput

type UntagResourceOutput struct {
    // contains filtered or unexported fields
}

func (UntagResourceOutput) GoString

func (s UntagResourceOutput) GoString() string

GoString returns the string representation

func (UntagResourceOutput) String

func (s UntagResourceOutput) String() string

String returns the string representation

type UpdateBrokerCountInput

type UpdateBrokerCountInput struct {

    // ClusterArn is a required field
    ClusterArn *string `location:"uri" locationName:"clusterArn" type:"string" required:"true"`

    // The current version of the cluster.
    //
    // CurrentVersion is a required field
    CurrentVersion *string `locationName:"currentVersion" type:"string" required:"true"`

    // The number of broker nodes that you want the cluster to have after this operation
    // completes successfully.
    //
    // TargetNumberOfBrokerNodes is a required field
    TargetNumberOfBrokerNodes *int64 `locationName:"targetNumberOfBrokerNodes" min:"1" type:"integer" required:"true"`
    // contains filtered or unexported fields
}

Request body for UpdateBrokerCount.

func (UpdateBrokerCountInput) GoString

func (s UpdateBrokerCountInput) GoString() string

GoString returns the string representation

func (*UpdateBrokerCountInput) SetClusterArn

func (s *UpdateBrokerCountInput) SetClusterArn(v string) *UpdateBrokerCountInput

SetClusterArn sets the ClusterArn field's value.

func (*UpdateBrokerCountInput) SetCurrentVersion

func (s *UpdateBrokerCountInput) SetCurrentVersion(v string) *UpdateBrokerCountInput

SetCurrentVersion sets the CurrentVersion field's value.

func (*UpdateBrokerCountInput) SetTargetNumberOfBrokerNodes

func (s *UpdateBrokerCountInput) SetTargetNumberOfBrokerNodes(v int64) *UpdateBrokerCountInput

SetTargetNumberOfBrokerNodes sets the TargetNumberOfBrokerNodes field's value.

func (UpdateBrokerCountInput) String

func (s UpdateBrokerCountInput) String() string

String returns the string representation

func (*UpdateBrokerCountInput) Validate

func (s *UpdateBrokerCountInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type UpdateBrokerCountOutput

type UpdateBrokerCountOutput struct {

    // The Amazon Resource Name (ARN) of the cluster.
    ClusterArn *string `locationName:"clusterArn" type:"string"`

    // The Amazon Resource Name (ARN) of the cluster operation.
    ClusterOperationArn *string `locationName:"clusterOperationArn" type:"string"`
    // contains filtered or unexported fields
}

Response body for UpdateBrokerCount.

func (UpdateBrokerCountOutput) GoString

func (s UpdateBrokerCountOutput) GoString() string

GoString returns the string representation

func (*UpdateBrokerCountOutput) SetClusterArn

func (s *UpdateBrokerCountOutput) SetClusterArn(v string) *UpdateBrokerCountOutput

SetClusterArn sets the ClusterArn field's value.

func (*UpdateBrokerCountOutput) SetClusterOperationArn

func (s *UpdateBrokerCountOutput) SetClusterOperationArn(v string) *UpdateBrokerCountOutput

SetClusterOperationArn sets the ClusterOperationArn field's value.

func (UpdateBrokerCountOutput) String

func (s UpdateBrokerCountOutput) String() string

String returns the string representation

type UpdateBrokerStorageInput

type UpdateBrokerStorageInput struct {

    // ClusterArn is a required field
    ClusterArn *string `location:"uri" locationName:"clusterArn" type:"string" required:"true"`

    // The version of cluster to update from. A successful operation will then generate
    // a new version.
    //
    // CurrentVersion is a required field
    CurrentVersion *string `locationName:"currentVersion" type:"string" required:"true"`

    // Describes the target volume size and the ID of the broker to apply the update
    // to.
    //
    // The value you specify for Target-Volume-in-GiB must be a whole number that
    // is greater than 100 GiB.
    //
    // The storage per broker after the update operation can't exceed 16384 GiB.
    //
    // TargetBrokerEBSVolumeInfo is a required field
    TargetBrokerEBSVolumeInfo []*BrokerEBSVolumeInfo `locationName:"targetBrokerEBSVolumeInfo" type:"list" required:"true"`
    // contains filtered or unexported fields
}

Request object for UpdateBrokerStorage.

func (UpdateBrokerStorageInput) GoString

func (s UpdateBrokerStorageInput) GoString() string

GoString returns the string representation

func (*UpdateBrokerStorageInput) SetClusterArn

func (s *UpdateBrokerStorageInput) SetClusterArn(v string) *UpdateBrokerStorageInput

SetClusterArn sets the ClusterArn field's value.

func (*UpdateBrokerStorageInput) SetCurrentVersion

func (s *UpdateBrokerStorageInput) SetCurrentVersion(v string) *UpdateBrokerStorageInput

SetCurrentVersion sets the CurrentVersion field's value.

func (*UpdateBrokerStorageInput) SetTargetBrokerEBSVolumeInfo

func (s *UpdateBrokerStorageInput) SetTargetBrokerEBSVolumeInfo(v []*BrokerEBSVolumeInfo) *UpdateBrokerStorageInput

SetTargetBrokerEBSVolumeInfo sets the TargetBrokerEBSVolumeInfo field's value.

func (UpdateBrokerStorageInput) String

func (s UpdateBrokerStorageInput) String() string

String returns the string representation

func (*UpdateBrokerStorageInput) Validate

func (s *UpdateBrokerStorageInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type UpdateBrokerStorageOutput

type UpdateBrokerStorageOutput struct {

    // The Amazon Resource Name (ARN) of the cluster.
    ClusterArn *string `locationName:"clusterArn" type:"string"`

    // The Amazon Resource Name (ARN) of the cluster operation.
    ClusterOperationArn *string `locationName:"clusterOperationArn" type:"string"`
    // contains filtered or unexported fields
}

Response body for UpdateBrokerStorage.

func (UpdateBrokerStorageOutput) GoString

func (s UpdateBrokerStorageOutput) GoString() string

GoString returns the string representation

func (*UpdateBrokerStorageOutput) SetClusterArn

func (s *UpdateBrokerStorageOutput) SetClusterArn(v string) *UpdateBrokerStorageOutput

SetClusterArn sets the ClusterArn field's value.

func (*UpdateBrokerStorageOutput) SetClusterOperationArn

func (s *UpdateBrokerStorageOutput) SetClusterOperationArn(v string) *UpdateBrokerStorageOutput

SetClusterOperationArn sets the ClusterOperationArn field's value.

func (UpdateBrokerStorageOutput) String

func (s UpdateBrokerStorageOutput) String() string

String returns the string representation

type UpdateClusterConfigurationInput

type UpdateClusterConfigurationInput struct {

    // ClusterArn is a required field
    ClusterArn *string `location:"uri" locationName:"clusterArn" type:"string" required:"true"`

    // Represents the configuration that you want MSK to use for the cluster.
    //
    // ConfigurationInfo is a required field
    ConfigurationInfo *ConfigurationInfo `locationName:"configurationInfo" type:"structure" required:"true"`

    // The version of the cluster that you want to update.
    //
    // CurrentVersion is a required field
    CurrentVersion *string `locationName:"currentVersion" type:"string" required:"true"`
    // contains filtered or unexported fields
}

Request body for UpdateClusterConfiguration.

func (UpdateClusterConfigurationInput) GoString

func (s UpdateClusterConfigurationInput) GoString() string

GoString returns the string representation

func (*UpdateClusterConfigurationInput) SetClusterArn

func (s *UpdateClusterConfigurationInput) SetClusterArn(v string) *UpdateClusterConfigurationInput

SetClusterArn sets the ClusterArn field's value.

func (*UpdateClusterConfigurationInput) SetConfigurationInfo

func (s *UpdateClusterConfigurationInput) SetConfigurationInfo(v *ConfigurationInfo) *UpdateClusterConfigurationInput

SetConfigurationInfo sets the ConfigurationInfo field's value.

func (*UpdateClusterConfigurationInput) SetCurrentVersion

func (s *UpdateClusterConfigurationInput) SetCurrentVersion(v string) *UpdateClusterConfigurationInput

SetCurrentVersion sets the CurrentVersion field's value.

func (UpdateClusterConfigurationInput) String

func (s UpdateClusterConfigurationInput) String() string

String returns the string representation

func (*UpdateClusterConfigurationInput) Validate

func (s *UpdateClusterConfigurationInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type UpdateClusterConfigurationOutput

type UpdateClusterConfigurationOutput struct {

    // The Amazon Resource Name (ARN) of the cluster.
    ClusterArn *string `locationName:"clusterArn" type:"string"`

    // The Amazon Resource Name (ARN) of the cluster operation.
    ClusterOperationArn *string `locationName:"clusterOperationArn" type:"string"`
    // contains filtered or unexported fields
}

Response body for UpdateClusterConfiguration.

func (UpdateClusterConfigurationOutput) GoString

func (s UpdateClusterConfigurationOutput) GoString() string

GoString returns the string representation

func (*UpdateClusterConfigurationOutput) SetClusterArn

func (s *UpdateClusterConfigurationOutput) SetClusterArn(v string) *UpdateClusterConfigurationOutput

SetClusterArn sets the ClusterArn field's value.

func (*UpdateClusterConfigurationOutput) SetClusterOperationArn

func (s *UpdateClusterConfigurationOutput) SetClusterOperationArn(v string) *UpdateClusterConfigurationOutput

SetClusterOperationArn sets the ClusterOperationArn field's value.

func (UpdateClusterConfigurationOutput) String

func (s UpdateClusterConfigurationOutput) String() string

String returns the string representation

type ZookeeperNodeInfo

type ZookeeperNodeInfo struct {

    // The attached elastic network interface of the broker.
    AttachedENIId *string `locationName:"attachedENIId" type:"string"`

    // The virtual private cloud (VPC) IP address of the client.
    ClientVpcIpAddress *string `locationName:"clientVpcIpAddress" type:"string"`

    // Endpoints for accessing the ZooKeeper.
    Endpoints []*string `locationName:"endpoints" type:"list"`

    // The role-specific ID for Zookeeper.
    ZookeeperId *float64 `locationName:"zookeeperId" type:"double"`

    // The version of Zookeeper.
    ZookeeperVersion *string `locationName:"zookeeperVersion" type:"string"`
    // contains filtered or unexported fields
}

Zookeeper node information.

func (ZookeeperNodeInfo) GoString

func (s ZookeeperNodeInfo) GoString() string

GoString returns the string representation

func (*ZookeeperNodeInfo) SetAttachedENIId

func (s *ZookeeperNodeInfo) SetAttachedENIId(v string) *ZookeeperNodeInfo

SetAttachedENIId sets the AttachedENIId field's value.

func (*ZookeeperNodeInfo) SetClientVpcIpAddress

func (s *ZookeeperNodeInfo) SetClientVpcIpAddress(v string) *ZookeeperNodeInfo

SetClientVpcIpAddress sets the ClientVpcIpAddress field's value.

func (*ZookeeperNodeInfo) SetEndpoints

func (s *ZookeeperNodeInfo) SetEndpoints(v []*string) *ZookeeperNodeInfo

SetEndpoints sets the Endpoints field's value.

func (*ZookeeperNodeInfo) SetZookeeperId

func (s *ZookeeperNodeInfo) SetZookeeperId(v float64) *ZookeeperNodeInfo

SetZookeeperId sets the ZookeeperId field's value.

func (*ZookeeperNodeInfo) SetZookeeperVersion

func (s *ZookeeperNodeInfo) SetZookeeperVersion(v string) *ZookeeperNodeInfo

SetZookeeperVersion sets the ZookeeperVersion field's value.

func (ZookeeperNodeInfo) String

func (s ZookeeperNodeInfo) String() string

String returns the string representation