Versions in this module Expand all Collapse all v1 v1.99.1 Feb 10, 2020 v1.99.0 Feb 10, 2020 Changes in this version + const BrokerAZDistributionDefault + const ClientBrokerPlaintext + const ClientBrokerTls + const ClientBrokerTlsPlaintext + const ClusterStateActive + const ClusterStateCreating + const ClusterStateDeleting + const ClusterStateFailed + const ClusterStateUpdating + const EndpointsID + const EnhancedMonitoringDefault + const EnhancedMonitoringPerBroker + const EnhancedMonitoringPerTopicPerBroker + const ErrCodeBadRequestException + const ErrCodeConflictException + const ErrCodeForbiddenException + const ErrCodeInternalServerErrorException + const ErrCodeNotFoundException + const ErrCodeServiceUnavailableException + const ErrCodeTooManyRequestsException + const ErrCodeUnauthorizedException + const NodeTypeBroker + const ServiceID + const ServiceName + type BrokerEBSVolumeInfo struct + KafkaBrokerNodeId *string + VolumeSizeGB *int64 + func (s *BrokerEBSVolumeInfo) SetKafkaBrokerNodeId(v string) *BrokerEBSVolumeInfo + func (s *BrokerEBSVolumeInfo) SetVolumeSizeGB(v int64) *BrokerEBSVolumeInfo + func (s *BrokerEBSVolumeInfo) Validate() error + func (s BrokerEBSVolumeInfo) GoString() string + func (s BrokerEBSVolumeInfo) String() string + type BrokerNodeGroupInfo struct + BrokerAZDistribution *string + ClientSubnets []*string + InstanceType *string + SecurityGroups []*string + StorageInfo *StorageInfo + 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 + func (s *BrokerNodeGroupInfo) Validate() error + func (s BrokerNodeGroupInfo) GoString() string + func (s BrokerNodeGroupInfo) String() string + type BrokerNodeInfo struct + AttachedENIId *string + BrokerId *float64 + ClientSubnet *string + ClientVpcIpAddress *string + CurrentBrokerSoftwareInfo *BrokerSoftwareInfo + Endpoints []*string + 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 + func (s BrokerNodeInfo) GoString() string + func (s BrokerNodeInfo) String() string + type BrokerSoftwareInfo struct + ConfigurationArn *string + ConfigurationRevision *int64 + KafkaVersion *string + func (s *BrokerSoftwareInfo) SetConfigurationArn(v string) *BrokerSoftwareInfo + func (s *BrokerSoftwareInfo) SetConfigurationRevision(v int64) *BrokerSoftwareInfo + func (s *BrokerSoftwareInfo) SetKafkaVersion(v string) *BrokerSoftwareInfo + func (s BrokerSoftwareInfo) GoString() string + func (s BrokerSoftwareInfo) String() string + type ClientAuthentication struct + Tls *Tls + func (s *ClientAuthentication) SetTls(v *Tls) *ClientAuthentication + func (s ClientAuthentication) GoString() string + func (s ClientAuthentication) String() string + type ClusterInfo struct + ActiveOperationArn *string + BrokerNodeGroupInfo *BrokerNodeGroupInfo + ClientAuthentication *ClientAuthentication + ClusterArn *string + ClusterName *string + CreationTime *time.Time + CurrentBrokerSoftwareInfo *BrokerSoftwareInfo + CurrentVersion *string + EncryptionInfo *EncryptionInfo + EnhancedMonitoring *string + NumberOfBrokerNodes *int64 + State *string + Tags map[string]*string + ZookeeperConnectString *string + 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 + func (s ClusterInfo) GoString() string + func (s ClusterInfo) String() string + type ClusterOperationInfo struct + ClientRequestId *string + ClusterArn *string + CreationTime *time.Time + EndTime *time.Time + ErrorInfo *ErrorInfo + OperationArn *string + OperationState *string + OperationType *string + SourceClusterInfo *MutableClusterInfo + TargetClusterInfo *MutableClusterInfo + 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 + func (s ClusterOperationInfo) GoString() string + func (s ClusterOperationInfo) String() string + type Configuration struct + Arn *string + CreationTime *time.Time + Description *string + KafkaVersions []*string + LatestRevision *ConfigurationRevision + Name *string + 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 + func (s Configuration) GoString() string + func (s Configuration) String() string + type ConfigurationInfo struct + Arn *string + Revision *int64 + func (s *ConfigurationInfo) SetArn(v string) *ConfigurationInfo + func (s *ConfigurationInfo) SetRevision(v int64) *ConfigurationInfo + func (s *ConfigurationInfo) Validate() error + func (s ConfigurationInfo) GoString() string + func (s ConfigurationInfo) String() string + type ConfigurationRevision struct + CreationTime *time.Time + Description *string + Revision *int64 + func (s *ConfigurationRevision) SetCreationTime(v time.Time) *ConfigurationRevision + func (s *ConfigurationRevision) SetDescription(v string) *ConfigurationRevision + func (s *ConfigurationRevision) SetRevision(v int64) *ConfigurationRevision + func (s ConfigurationRevision) GoString() string + func (s ConfigurationRevision) String() string + type CreateClusterInput struct + BrokerNodeGroupInfo *BrokerNodeGroupInfo + ClientAuthentication *ClientAuthentication + ClusterName *string + ConfigurationInfo *ConfigurationInfo + EncryptionInfo *EncryptionInfo + EnhancedMonitoring *string + KafkaVersion *string + NumberOfBrokerNodes *int64 + Tags map[string]*string + 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 + func (s *CreateClusterInput) Validate() error + func (s CreateClusterInput) GoString() string + func (s CreateClusterInput) String() string + type CreateClusterOutput struct + ClusterArn *string + ClusterName *string + State *string + func (s *CreateClusterOutput) SetClusterArn(v string) *CreateClusterOutput + func (s *CreateClusterOutput) SetClusterName(v string) *CreateClusterOutput + func (s *CreateClusterOutput) SetState(v string) *CreateClusterOutput + func (s CreateClusterOutput) GoString() string + func (s CreateClusterOutput) String() string + type CreateConfigurationInput struct + Description *string + KafkaVersions []*string + Name *string + ServerProperties []byte + 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 + func (s *CreateConfigurationInput) Validate() error + func (s CreateConfigurationInput) GoString() string + func (s CreateConfigurationInput) String() string + type CreateConfigurationOutput struct + Arn *string + CreationTime *time.Time + LatestRevision *ConfigurationRevision + Name *string + 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 + func (s CreateConfigurationOutput) GoString() string + func (s CreateConfigurationOutput) String() string + type DeleteClusterInput struct + ClusterArn *string + CurrentVersion *string + func (s *DeleteClusterInput) SetClusterArn(v string) *DeleteClusterInput + func (s *DeleteClusterInput) SetCurrentVersion(v string) *DeleteClusterInput + func (s *DeleteClusterInput) Validate() error + func (s DeleteClusterInput) GoString() string + func (s DeleteClusterInput) String() string + type DeleteClusterOutput struct + ClusterArn *string + State *string + func (s *DeleteClusterOutput) SetClusterArn(v string) *DeleteClusterOutput + func (s *DeleteClusterOutput) SetState(v string) *DeleteClusterOutput + func (s DeleteClusterOutput) GoString() string + func (s DeleteClusterOutput) String() string + type DescribeClusterInput struct + ClusterArn *string + func (s *DescribeClusterInput) SetClusterArn(v string) *DescribeClusterInput + func (s *DescribeClusterInput) Validate() error + func (s DescribeClusterInput) GoString() string + func (s DescribeClusterInput) String() string + type DescribeClusterOperationInput struct + ClusterOperationArn *string + func (s *DescribeClusterOperationInput) SetClusterOperationArn(v string) *DescribeClusterOperationInput + func (s *DescribeClusterOperationInput) Validate() error + func (s DescribeClusterOperationInput) GoString() string + func (s DescribeClusterOperationInput) String() string + type DescribeClusterOperationOutput struct + ClusterOperationInfo *ClusterOperationInfo + func (s *DescribeClusterOperationOutput) SetClusterOperationInfo(v *ClusterOperationInfo) *DescribeClusterOperationOutput + func (s DescribeClusterOperationOutput) GoString() string + func (s DescribeClusterOperationOutput) String() string + type DescribeClusterOutput struct + ClusterInfo *ClusterInfo + func (s *DescribeClusterOutput) SetClusterInfo(v *ClusterInfo) *DescribeClusterOutput + func (s DescribeClusterOutput) GoString() string + func (s DescribeClusterOutput) String() string + type DescribeConfigurationInput struct + Arn *string + func (s *DescribeConfigurationInput) SetArn(v string) *DescribeConfigurationInput + func (s *DescribeConfigurationInput) Validate() error + func (s DescribeConfigurationInput) GoString() string + func (s DescribeConfigurationInput) String() string + type DescribeConfigurationOutput struct + Arn *string + CreationTime *time.Time + Description *string + KafkaVersions []*string + LatestRevision *ConfigurationRevision + Name *string + 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 + func (s DescribeConfigurationOutput) GoString() string + func (s DescribeConfigurationOutput) String() string + type DescribeConfigurationRevisionInput struct + Arn *string + Revision *int64 + func (s *DescribeConfigurationRevisionInput) SetArn(v string) *DescribeConfigurationRevisionInput + func (s *DescribeConfigurationRevisionInput) SetRevision(v int64) *DescribeConfigurationRevisionInput + func (s *DescribeConfigurationRevisionInput) Validate() error + func (s DescribeConfigurationRevisionInput) GoString() string + func (s DescribeConfigurationRevisionInput) String() string + type DescribeConfigurationRevisionOutput struct + Arn *string + CreationTime *time.Time + Description *string + Revision *int64 + ServerProperties []byte + 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 + func (s DescribeConfigurationRevisionOutput) GoString() string + func (s DescribeConfigurationRevisionOutput) String() string + type EBSStorageInfo struct + VolumeSize *int64 + func (s *EBSStorageInfo) SetVolumeSize(v int64) *EBSStorageInfo + func (s *EBSStorageInfo) Validate() error + func (s EBSStorageInfo) GoString() string + func (s EBSStorageInfo) String() string + type EncryptionAtRest struct + DataVolumeKMSKeyId *string + func (s *EncryptionAtRest) SetDataVolumeKMSKeyId(v string) *EncryptionAtRest + func (s *EncryptionAtRest) Validate() error + func (s EncryptionAtRest) GoString() string + func (s EncryptionAtRest) String() string + type EncryptionInTransit struct + ClientBroker *string + InCluster *bool + func (s *EncryptionInTransit) SetClientBroker(v string) *EncryptionInTransit + func (s *EncryptionInTransit) SetInCluster(v bool) *EncryptionInTransit + func (s EncryptionInTransit) GoString() string + func (s EncryptionInTransit) String() string + type EncryptionInfo struct + EncryptionAtRest *EncryptionAtRest + EncryptionInTransit *EncryptionInTransit + func (s *EncryptionInfo) SetEncryptionAtRest(v *EncryptionAtRest) *EncryptionInfo + func (s *EncryptionInfo) SetEncryptionInTransit(v *EncryptionInTransit) *EncryptionInfo + func (s *EncryptionInfo) Validate() error + func (s EncryptionInfo) GoString() string + func (s EncryptionInfo) String() string + type ErrorInfo struct + ErrorCode *string + ErrorString *string + func (s *ErrorInfo) SetErrorCode(v string) *ErrorInfo + func (s *ErrorInfo) SetErrorString(v string) *ErrorInfo + func (s ErrorInfo) GoString() string + func (s ErrorInfo) String() string + type GetBootstrapBrokersInput struct + ClusterArn *string + func (s *GetBootstrapBrokersInput) SetClusterArn(v string) *GetBootstrapBrokersInput + func (s *GetBootstrapBrokersInput) Validate() error + func (s GetBootstrapBrokersInput) GoString() string + func (s GetBootstrapBrokersInput) String() string + type GetBootstrapBrokersOutput struct + BootstrapBrokerString *string + BootstrapBrokerStringTls *string + func (s *GetBootstrapBrokersOutput) SetBootstrapBrokerString(v string) *GetBootstrapBrokersOutput + func (s *GetBootstrapBrokersOutput) SetBootstrapBrokerStringTls(v string) *GetBootstrapBrokersOutput + func (s GetBootstrapBrokersOutput) GoString() string + func (s GetBootstrapBrokersOutput) String() string + type Kafka struct + func New(p client.ConfigProvider, cfgs ...*aws.Config) *Kafka + func (c *Kafka) CreateCluster(input *CreateClusterInput) (*CreateClusterOutput, error) + func (c *Kafka) CreateClusterRequest(input *CreateClusterInput) (req *request.Request, output *CreateClusterOutput) + func (c *Kafka) CreateClusterWithContext(ctx aws.Context, input *CreateClusterInput, opts ...request.Option) (*CreateClusterOutput, error) + func (c *Kafka) CreateConfiguration(input *CreateConfigurationInput) (*CreateConfigurationOutput, error) + func (c *Kafka) CreateConfigurationRequest(input *CreateConfigurationInput) (req *request.Request, output *CreateConfigurationOutput) + func (c *Kafka) CreateConfigurationWithContext(ctx aws.Context, input *CreateConfigurationInput, opts ...request.Option) (*CreateConfigurationOutput, error) + func (c *Kafka) DeleteCluster(input *DeleteClusterInput) (*DeleteClusterOutput, error) + func (c *Kafka) DeleteClusterRequest(input *DeleteClusterInput) (req *request.Request, output *DeleteClusterOutput) + func (c *Kafka) DeleteClusterWithContext(ctx aws.Context, input *DeleteClusterInput, opts ...request.Option) (*DeleteClusterOutput, error) + func (c *Kafka) DescribeCluster(input *DescribeClusterInput) (*DescribeClusterOutput, error) + func (c *Kafka) DescribeClusterOperation(input *DescribeClusterOperationInput) (*DescribeClusterOperationOutput, error) + func (c *Kafka) DescribeClusterOperationRequest(input *DescribeClusterOperationInput) (req *request.Request, output *DescribeClusterOperationOutput) + func (c *Kafka) DescribeClusterOperationWithContext(ctx aws.Context, input *DescribeClusterOperationInput, opts ...request.Option) (*DescribeClusterOperationOutput, error) + func (c *Kafka) DescribeClusterRequest(input *DescribeClusterInput) (req *request.Request, output *DescribeClusterOutput) + func (c *Kafka) DescribeClusterWithContext(ctx aws.Context, input *DescribeClusterInput, opts ...request.Option) (*DescribeClusterOutput, error) + func (c *Kafka) DescribeConfiguration(input *DescribeConfigurationInput) (*DescribeConfigurationOutput, error) + func (c *Kafka) DescribeConfigurationRequest(input *DescribeConfigurationInput) (req *request.Request, output *DescribeConfigurationOutput) + func (c *Kafka) DescribeConfigurationRevision(input *DescribeConfigurationRevisionInput) (*DescribeConfigurationRevisionOutput, error) + func (c *Kafka) DescribeConfigurationRevisionRequest(input *DescribeConfigurationRevisionInput) (req *request.Request, output *DescribeConfigurationRevisionOutput) + func (c *Kafka) DescribeConfigurationRevisionWithContext(ctx aws.Context, input *DescribeConfigurationRevisionInput, ...) (*DescribeConfigurationRevisionOutput, error) + func (c *Kafka) DescribeConfigurationWithContext(ctx aws.Context, input *DescribeConfigurationInput, opts ...request.Option) (*DescribeConfigurationOutput, error) + func (c *Kafka) GetBootstrapBrokers(input *GetBootstrapBrokersInput) (*GetBootstrapBrokersOutput, error) + func (c *Kafka) GetBootstrapBrokersRequest(input *GetBootstrapBrokersInput) (req *request.Request, output *GetBootstrapBrokersOutput) + func (c *Kafka) GetBootstrapBrokersWithContext(ctx aws.Context, input *GetBootstrapBrokersInput, opts ...request.Option) (*GetBootstrapBrokersOutput, error) + func (c *Kafka) ListClusterOperations(input *ListClusterOperationsInput) (*ListClusterOperationsOutput, error) + func (c *Kafka) ListClusterOperationsPages(input *ListClusterOperationsInput, ...) error + func (c *Kafka) ListClusterOperationsPagesWithContext(ctx aws.Context, input *ListClusterOperationsInput, ...) error + func (c *Kafka) ListClusterOperationsRequest(input *ListClusterOperationsInput) (req *request.Request, output *ListClusterOperationsOutput) + func (c *Kafka) ListClusterOperationsWithContext(ctx aws.Context, input *ListClusterOperationsInput, opts ...request.Option) (*ListClusterOperationsOutput, error) + func (c *Kafka) ListClusters(input *ListClustersInput) (*ListClustersOutput, error) + func (c *Kafka) ListClustersPages(input *ListClustersInput, fn func(*ListClustersOutput, bool) bool) error + func (c *Kafka) ListClustersPagesWithContext(ctx aws.Context, input *ListClustersInput, ...) error + func (c *Kafka) ListClustersRequest(input *ListClustersInput) (req *request.Request, output *ListClustersOutput) + func (c *Kafka) ListClustersWithContext(ctx aws.Context, input *ListClustersInput, opts ...request.Option) (*ListClustersOutput, error) + func (c *Kafka) ListConfigurationRevisions(input *ListConfigurationRevisionsInput) (*ListConfigurationRevisionsOutput, error) + func (c *Kafka) ListConfigurationRevisionsPages(input *ListConfigurationRevisionsInput, ...) error + func (c *Kafka) ListConfigurationRevisionsPagesWithContext(ctx aws.Context, input *ListConfigurationRevisionsInput, ...) error + func (c *Kafka) ListConfigurationRevisionsRequest(input *ListConfigurationRevisionsInput) (req *request.Request, output *ListConfigurationRevisionsOutput) + func (c *Kafka) ListConfigurationRevisionsWithContext(ctx aws.Context, input *ListConfigurationRevisionsInput, ...) (*ListConfigurationRevisionsOutput, error) + func (c *Kafka) ListConfigurations(input *ListConfigurationsInput) (*ListConfigurationsOutput, error) + func (c *Kafka) ListConfigurationsPages(input *ListConfigurationsInput, fn func(*ListConfigurationsOutput, bool) bool) error + func (c *Kafka) ListConfigurationsPagesWithContext(ctx aws.Context, input *ListConfigurationsInput, ...) error + func (c *Kafka) ListConfigurationsRequest(input *ListConfigurationsInput) (req *request.Request, output *ListConfigurationsOutput) + func (c *Kafka) ListConfigurationsWithContext(ctx aws.Context, input *ListConfigurationsInput, opts ...request.Option) (*ListConfigurationsOutput, error) + func (c *Kafka) ListNodes(input *ListNodesInput) (*ListNodesOutput, error) + func (c *Kafka) ListNodesPages(input *ListNodesInput, fn func(*ListNodesOutput, bool) bool) error + func (c *Kafka) ListNodesPagesWithContext(ctx aws.Context, input *ListNodesInput, fn func(*ListNodesOutput, bool) bool, ...) error + func (c *Kafka) ListNodesRequest(input *ListNodesInput) (req *request.Request, output *ListNodesOutput) + func (c *Kafka) ListNodesWithContext(ctx aws.Context, input *ListNodesInput, opts ...request.Option) (*ListNodesOutput, error) + func (c *Kafka) ListTagsForResource(input *ListTagsForResourceInput) (*ListTagsForResourceOutput, error) + func (c *Kafka) ListTagsForResourceRequest(input *ListTagsForResourceInput) (req *request.Request, output *ListTagsForResourceOutput) + func (c *Kafka) ListTagsForResourceWithContext(ctx aws.Context, input *ListTagsForResourceInput, opts ...request.Option) (*ListTagsForResourceOutput, error) + func (c *Kafka) TagResource(input *TagResourceInput) (*TagResourceOutput, error) + func (c *Kafka) TagResourceRequest(input *TagResourceInput) (req *request.Request, output *TagResourceOutput) + func (c *Kafka) TagResourceWithContext(ctx aws.Context, input *TagResourceInput, opts ...request.Option) (*TagResourceOutput, error) + func (c *Kafka) UntagResource(input *UntagResourceInput) (*UntagResourceOutput, error) + func (c *Kafka) UntagResourceRequest(input *UntagResourceInput) (req *request.Request, output *UntagResourceOutput) + func (c *Kafka) UntagResourceWithContext(ctx aws.Context, input *UntagResourceInput, opts ...request.Option) (*UntagResourceOutput, error) + func (c *Kafka) UpdateBrokerStorage(input *UpdateBrokerStorageInput) (*UpdateBrokerStorageOutput, error) + func (c *Kafka) UpdateBrokerStorageRequest(input *UpdateBrokerStorageInput) (req *request.Request, output *UpdateBrokerStorageOutput) + func (c *Kafka) UpdateBrokerStorageWithContext(ctx aws.Context, input *UpdateBrokerStorageInput, opts ...request.Option) (*UpdateBrokerStorageOutput, error) + func (c *Kafka) UpdateClusterConfiguration(input *UpdateClusterConfigurationInput) (*UpdateClusterConfigurationOutput, error) + func (c *Kafka) UpdateClusterConfigurationRequest(input *UpdateClusterConfigurationInput) (req *request.Request, output *UpdateClusterConfigurationOutput) + func (c *Kafka) UpdateClusterConfigurationWithContext(ctx aws.Context, input *UpdateClusterConfigurationInput, ...) (*UpdateClusterConfigurationOutput, error) + type ListClusterOperationsInput struct + ClusterArn *string + MaxResults *int64 + NextToken *string + func (s *ListClusterOperationsInput) SetClusterArn(v string) *ListClusterOperationsInput + func (s *ListClusterOperationsInput) SetMaxResults(v int64) *ListClusterOperationsInput + func (s *ListClusterOperationsInput) SetNextToken(v string) *ListClusterOperationsInput + func (s *ListClusterOperationsInput) Validate() error + func (s ListClusterOperationsInput) GoString() string + func (s ListClusterOperationsInput) String() string + type ListClusterOperationsOutput struct + ClusterOperationInfoList []*ClusterOperationInfo + NextToken *string + func (s *ListClusterOperationsOutput) SetClusterOperationInfoList(v []*ClusterOperationInfo) *ListClusterOperationsOutput + func (s *ListClusterOperationsOutput) SetNextToken(v string) *ListClusterOperationsOutput + func (s ListClusterOperationsOutput) GoString() string + func (s ListClusterOperationsOutput) String() string + type ListClustersInput struct + ClusterNameFilter *string + MaxResults *int64 + NextToken *string + func (s *ListClustersInput) SetClusterNameFilter(v string) *ListClustersInput + func (s *ListClustersInput) SetMaxResults(v int64) *ListClustersInput + func (s *ListClustersInput) SetNextToken(v string) *ListClustersInput + func (s *ListClustersInput) Validate() error + func (s ListClustersInput) GoString() string + func (s ListClustersInput) String() string + type ListClustersOutput struct + ClusterInfoList []*ClusterInfo + NextToken *string + func (s *ListClustersOutput) SetClusterInfoList(v []*ClusterInfo) *ListClustersOutput + func (s *ListClustersOutput) SetNextToken(v string) *ListClustersOutput + func (s ListClustersOutput) GoString() string + func (s ListClustersOutput) String() string + type ListConfigurationRevisionsInput struct + Arn *string + MaxResults *int64 + NextToken *string + func (s *ListConfigurationRevisionsInput) SetArn(v string) *ListConfigurationRevisionsInput + func (s *ListConfigurationRevisionsInput) SetMaxResults(v int64) *ListConfigurationRevisionsInput + func (s *ListConfigurationRevisionsInput) SetNextToken(v string) *ListConfigurationRevisionsInput + func (s *ListConfigurationRevisionsInput) Validate() error + func (s ListConfigurationRevisionsInput) GoString() string + func (s ListConfigurationRevisionsInput) String() string + type ListConfigurationRevisionsOutput struct + NextToken *string + Revisions []*ConfigurationRevision + func (s *ListConfigurationRevisionsOutput) SetNextToken(v string) *ListConfigurationRevisionsOutput + func (s *ListConfigurationRevisionsOutput) SetRevisions(v []*ConfigurationRevision) *ListConfigurationRevisionsOutput + func (s ListConfigurationRevisionsOutput) GoString() string + func (s ListConfigurationRevisionsOutput) String() string + type ListConfigurationsInput struct + MaxResults *int64 + NextToken *string + func (s *ListConfigurationsInput) SetMaxResults(v int64) *ListConfigurationsInput + func (s *ListConfigurationsInput) SetNextToken(v string) *ListConfigurationsInput + func (s *ListConfigurationsInput) Validate() error + func (s ListConfigurationsInput) GoString() string + func (s ListConfigurationsInput) String() string + type ListConfigurationsOutput struct + Configurations []*Configuration + NextToken *string + func (s *ListConfigurationsOutput) SetConfigurations(v []*Configuration) *ListConfigurationsOutput + func (s *ListConfigurationsOutput) SetNextToken(v string) *ListConfigurationsOutput + func (s ListConfigurationsOutput) GoString() string + func (s ListConfigurationsOutput) String() string + type ListNodesInput struct + ClusterArn *string + MaxResults *int64 + NextToken *string + func (s *ListNodesInput) SetClusterArn(v string) *ListNodesInput + func (s *ListNodesInput) SetMaxResults(v int64) *ListNodesInput + func (s *ListNodesInput) SetNextToken(v string) *ListNodesInput + func (s *ListNodesInput) Validate() error + func (s ListNodesInput) GoString() string + func (s ListNodesInput) String() string + type ListNodesOutput struct + NextToken *string + NodeInfoList []*NodeInfo + func (s *ListNodesOutput) SetNextToken(v string) *ListNodesOutput + func (s *ListNodesOutput) SetNodeInfoList(v []*NodeInfo) *ListNodesOutput + func (s ListNodesOutput) GoString() string + func (s ListNodesOutput) String() string + type ListTagsForResourceInput struct + ResourceArn *string + func (s *ListTagsForResourceInput) SetResourceArn(v string) *ListTagsForResourceInput + func (s *ListTagsForResourceInput) Validate() error + func (s ListTagsForResourceInput) GoString() string + func (s ListTagsForResourceInput) String() string + type ListTagsForResourceOutput struct + Tags map[string]*string + func (s *ListTagsForResourceOutput) SetTags(v map[string]*string) *ListTagsForResourceOutput + func (s ListTagsForResourceOutput) GoString() string + func (s ListTagsForResourceOutput) String() string + type MutableClusterInfo struct + BrokerEBSVolumeInfo []*BrokerEBSVolumeInfo + ConfigurationInfo *ConfigurationInfo + NumberOfBrokerNodes *int64 + func (s *MutableClusterInfo) SetBrokerEBSVolumeInfo(v []*BrokerEBSVolumeInfo) *MutableClusterInfo + func (s *MutableClusterInfo) SetConfigurationInfo(v *ConfigurationInfo) *MutableClusterInfo + func (s *MutableClusterInfo) SetNumberOfBrokerNodes(v int64) *MutableClusterInfo + func (s MutableClusterInfo) GoString() string + func (s MutableClusterInfo) String() string + type NodeInfo struct + AddedToClusterTime *string + BrokerNodeInfo *BrokerNodeInfo + InstanceType *string + NodeARN *string + NodeType *string + ZookeeperNodeInfo *ZookeeperNodeInfo + 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 + func (s NodeInfo) GoString() string + func (s NodeInfo) String() string + type StorageInfo struct + EbsStorageInfo *EBSStorageInfo + func (s *StorageInfo) SetEbsStorageInfo(v *EBSStorageInfo) *StorageInfo + func (s *StorageInfo) Validate() error + func (s StorageInfo) GoString() string + func (s StorageInfo) String() string + type TagResourceInput struct + ResourceArn *string + Tags map[string]*string + func (s *TagResourceInput) SetResourceArn(v string) *TagResourceInput + func (s *TagResourceInput) SetTags(v map[string]*string) *TagResourceInput + func (s *TagResourceInput) Validate() error + func (s TagResourceInput) GoString() string + func (s TagResourceInput) String() string + type TagResourceOutput struct + func (s TagResourceOutput) GoString() string + func (s TagResourceOutput) String() string + type Tls struct + CertificateAuthorityArnList []*string + func (s *Tls) SetCertificateAuthorityArnList(v []*string) *Tls + func (s Tls) GoString() string + func (s Tls) String() string + type UntagResourceInput struct + ResourceArn *string + TagKeys []*string + func (s *UntagResourceInput) SetResourceArn(v string) *UntagResourceInput + func (s *UntagResourceInput) SetTagKeys(v []*string) *UntagResourceInput + func (s *UntagResourceInput) Validate() error + func (s UntagResourceInput) GoString() string + func (s UntagResourceInput) String() string + type UntagResourceOutput struct + func (s UntagResourceOutput) GoString() string + func (s UntagResourceOutput) String() string + type UpdateBrokerStorageInput struct + ClusterArn *string + CurrentVersion *string + TargetBrokerEBSVolumeInfo []*BrokerEBSVolumeInfo + func (s *UpdateBrokerStorageInput) SetClusterArn(v string) *UpdateBrokerStorageInput + func (s *UpdateBrokerStorageInput) SetCurrentVersion(v string) *UpdateBrokerStorageInput + func (s *UpdateBrokerStorageInput) SetTargetBrokerEBSVolumeInfo(v []*BrokerEBSVolumeInfo) *UpdateBrokerStorageInput + func (s *UpdateBrokerStorageInput) Validate() error + func (s UpdateBrokerStorageInput) GoString() string + func (s UpdateBrokerStorageInput) String() string + type UpdateBrokerStorageOutput struct + ClusterArn *string + ClusterOperationArn *string + func (s *UpdateBrokerStorageOutput) SetClusterArn(v string) *UpdateBrokerStorageOutput + func (s *UpdateBrokerStorageOutput) SetClusterOperationArn(v string) *UpdateBrokerStorageOutput + func (s UpdateBrokerStorageOutput) GoString() string + func (s UpdateBrokerStorageOutput) String() string + type UpdateClusterConfigurationInput struct + ClusterArn *string + ConfigurationInfo *ConfigurationInfo + CurrentVersion *string + func (s *UpdateClusterConfigurationInput) SetClusterArn(v string) *UpdateClusterConfigurationInput + func (s *UpdateClusterConfigurationInput) SetConfigurationInfo(v *ConfigurationInfo) *UpdateClusterConfigurationInput + func (s *UpdateClusterConfigurationInput) SetCurrentVersion(v string) *UpdateClusterConfigurationInput + func (s *UpdateClusterConfigurationInput) Validate() error + func (s UpdateClusterConfigurationInput) GoString() string + func (s UpdateClusterConfigurationInput) String() string + type UpdateClusterConfigurationOutput struct + ClusterArn *string + ClusterOperationArn *string + func (s *UpdateClusterConfigurationOutput) SetClusterArn(v string) *UpdateClusterConfigurationOutput + func (s *UpdateClusterConfigurationOutput) SetClusterOperationArn(v string) *UpdateClusterConfigurationOutput + func (s UpdateClusterConfigurationOutput) GoString() string + func (s UpdateClusterConfigurationOutput) String() string + type ZookeeperNodeInfo struct + AttachedENIId *string + ClientVpcIpAddress *string + Endpoints []*string + ZookeeperId *float64 + ZookeeperVersion *string + 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 + func (s ZookeeperNodeInfo) GoString() string + func (s ZookeeperNodeInfo) String() string