Versions in this module Expand all Collapse all v1 v1.0.1 Jul 4, 2024 v1.0.0 Jul 4, 2024 Changes in this version + const BrokerAZDistributionDefault + const ClientBrokerPlaintext + const ClientBrokerTls + const ClientBrokerTlsPlaintext + const ClusterStateActive + const ClusterStateCreating + const ClusterStateDeleting + const ClusterStateFailed + const ClusterStateHealing + const ClusterStateMaintenance + const ClusterStateRebootingBroker + const ClusterStateUpdating + const ClusterTypeProvisioned + const ClusterTypeServerless + const ConfigurationStateActive + const ConfigurationStateDeleteFailed + const ConfigurationStateDeleting + const EndpointsID + const EnhancedMonitoringDefault + const EnhancedMonitoringPerBroker + const EnhancedMonitoringPerTopicPerBroker + const EnhancedMonitoringPerTopicPerPartition + const ErrCodeBadRequestException + const ErrCodeConflictException + const ErrCodeForbiddenException + const ErrCodeInternalServerErrorException + const ErrCodeNotFoundException + const ErrCodeServiceUnavailableException + const ErrCodeTooManyRequestsException + const ErrCodeUnauthorizedException + const KafkaVersionStatusActive + const KafkaVersionStatusDeprecated + const NodeTypeBroker + const ServiceID + const ServiceName + const StorageModeLocal + const StorageModeTiered + const UserIdentityTypeAwsaccount + const UserIdentityTypeAwsservice + const VpcConnectionStateAvailable + const VpcConnectionStateCreating + const VpcConnectionStateDeactivating + const VpcConnectionStateDeleting + const VpcConnectionStateFailed + const VpcConnectionStateInactive + const VpcConnectionStateRejected + const VpcConnectionStateRejecting + func BrokerAZDistribution_Values() []string + func ClientBroker_Values() []string + func ClusterState_Values() []string + func ClusterType_Values() []string + func ConfigurationState_Values() []string + func EnhancedMonitoring_Values() []string + func KafkaVersionStatus_Values() []string + func NodeType_Values() []string + func StorageMode_Values() []string + func UserIdentityType_Values() []string + func VpcConnectionState_Values() []string + type BadRequestException struct + InvalidParameter *string + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *BadRequestException) Code() string + func (s *BadRequestException) Error() string + func (s *BadRequestException) Message() string + func (s *BadRequestException) OrigErr() error + func (s *BadRequestException) RequestID() string + func (s *BadRequestException) StatusCode() int + func (s BadRequestException) GoString() string + func (s BadRequestException) String() string + type BatchAssociateScramSecretInput struct + ClusterArn *string + SecretArnList []*string + func (s *BatchAssociateScramSecretInput) SetClusterArn(v string) *BatchAssociateScramSecretInput + func (s *BatchAssociateScramSecretInput) SetSecretArnList(v []*string) *BatchAssociateScramSecretInput + func (s *BatchAssociateScramSecretInput) Validate() error + func (s BatchAssociateScramSecretInput) GoString() string + func (s BatchAssociateScramSecretInput) String() string + type BatchAssociateScramSecretOutput struct + ClusterArn *string + UnprocessedScramSecrets []*UnprocessedScramSecret + func (s *BatchAssociateScramSecretOutput) SetClusterArn(v string) *BatchAssociateScramSecretOutput + func (s *BatchAssociateScramSecretOutput) SetUnprocessedScramSecrets(v []*UnprocessedScramSecret) *BatchAssociateScramSecretOutput + func (s BatchAssociateScramSecretOutput) GoString() string + func (s BatchAssociateScramSecretOutput) String() string + type BatchDisassociateScramSecretInput struct + ClusterArn *string + SecretArnList []*string + func (s *BatchDisassociateScramSecretInput) SetClusterArn(v string) *BatchDisassociateScramSecretInput + func (s *BatchDisassociateScramSecretInput) SetSecretArnList(v []*string) *BatchDisassociateScramSecretInput + func (s *BatchDisassociateScramSecretInput) Validate() error + func (s BatchDisassociateScramSecretInput) GoString() string + func (s BatchDisassociateScramSecretInput) String() string + type BatchDisassociateScramSecretOutput struct + ClusterArn *string + UnprocessedScramSecrets []*UnprocessedScramSecret + func (s *BatchDisassociateScramSecretOutput) SetClusterArn(v string) *BatchDisassociateScramSecretOutput + func (s *BatchDisassociateScramSecretOutput) SetUnprocessedScramSecrets(v []*UnprocessedScramSecret) *BatchDisassociateScramSecretOutput + func (s BatchDisassociateScramSecretOutput) GoString() string + func (s BatchDisassociateScramSecretOutput) String() string + type BrokerEBSVolumeInfo struct + KafkaBrokerNodeId *string + ProvisionedThroughput *ProvisionedThroughput + VolumeSizeGB *int64 + func (s *BrokerEBSVolumeInfo) SetKafkaBrokerNodeId(v string) *BrokerEBSVolumeInfo + func (s *BrokerEBSVolumeInfo) SetProvisionedThroughput(v *ProvisionedThroughput) *BrokerEBSVolumeInfo + func (s *BrokerEBSVolumeInfo) SetVolumeSizeGB(v int64) *BrokerEBSVolumeInfo + func (s *BrokerEBSVolumeInfo) Validate() error + func (s BrokerEBSVolumeInfo) GoString() string + func (s BrokerEBSVolumeInfo) String() string + type BrokerLogs struct + CloudWatchLogs *CloudWatchLogs + Firehose *Firehose + S3 *S3 + func (s *BrokerLogs) SetCloudWatchLogs(v *CloudWatchLogs) *BrokerLogs + func (s *BrokerLogs) SetFirehose(v *Firehose) *BrokerLogs + func (s *BrokerLogs) SetS3(v *S3) *BrokerLogs + func (s *BrokerLogs) Validate() error + func (s BrokerLogs) GoString() string + func (s BrokerLogs) String() string + type BrokerNodeGroupInfo struct + BrokerAZDistribution *string + ClientSubnets []*string + ConnectivityInfo *ConnectivityInfo + InstanceType *string + SecurityGroups []*string + StorageInfo *StorageInfo + ZoneIds []*string + func (s *BrokerNodeGroupInfo) SetBrokerAZDistribution(v string) *BrokerNodeGroupInfo + func (s *BrokerNodeGroupInfo) SetClientSubnets(v []*string) *BrokerNodeGroupInfo + func (s *BrokerNodeGroupInfo) SetConnectivityInfo(v *ConnectivityInfo) *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) SetZoneIds(v []*string) *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 + Sasl *Sasl + Tls *Tls + Unauthenticated *Unauthenticated + func (s *ClientAuthentication) SetSasl(v *Sasl) *ClientAuthentication + func (s *ClientAuthentication) SetTls(v *Tls) *ClientAuthentication + func (s *ClientAuthentication) SetUnauthenticated(v *Unauthenticated) *ClientAuthentication + func (s ClientAuthentication) GoString() string + func (s ClientAuthentication) String() string + type ClientVpcConnection struct + Authentication *string + CreationTime *time.Time + Owner *string + State *string + VpcConnectionArn *string + func (s *ClientVpcConnection) SetAuthentication(v string) *ClientVpcConnection + func (s *ClientVpcConnection) SetCreationTime(v time.Time) *ClientVpcConnection + func (s *ClientVpcConnection) SetOwner(v string) *ClientVpcConnection + func (s *ClientVpcConnection) SetState(v string) *ClientVpcConnection + func (s *ClientVpcConnection) SetVpcConnectionArn(v string) *ClientVpcConnection + func (s ClientVpcConnection) GoString() string + func (s ClientVpcConnection) String() string + type CloudWatchLogs struct + Enabled *bool + LogGroup *string + func (s *CloudWatchLogs) SetEnabled(v bool) *CloudWatchLogs + func (s *CloudWatchLogs) SetLogGroup(v string) *CloudWatchLogs + func (s *CloudWatchLogs) Validate() error + func (s CloudWatchLogs) GoString() string + func (s CloudWatchLogs) String() string + type Cluster struct + ActiveOperationArn *string + ClusterArn *string + ClusterName *string + ClusterType *string + CreationTime *time.Time + CurrentVersion *string + Provisioned *Provisioned + Serverless *Serverless + State *string + StateInfo *StateInfo + Tags map[string]*string + func (s *Cluster) SetActiveOperationArn(v string) *Cluster + func (s *Cluster) SetClusterArn(v string) *Cluster + func (s *Cluster) SetClusterName(v string) *Cluster + func (s *Cluster) SetClusterType(v string) *Cluster + func (s *Cluster) SetCreationTime(v time.Time) *Cluster + func (s *Cluster) SetCurrentVersion(v string) *Cluster + func (s *Cluster) SetProvisioned(v *Provisioned) *Cluster + func (s *Cluster) SetServerless(v *Serverless) *Cluster + func (s *Cluster) SetState(v string) *Cluster + func (s *Cluster) SetStateInfo(v *StateInfo) *Cluster + func (s *Cluster) SetTags(v map[string]*string) *Cluster + func (s Cluster) GoString() string + func (s Cluster) 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 + LoggingInfo *LoggingInfo + NumberOfBrokerNodes *int64 + OpenMonitoring *OpenMonitoring + State *string + StateInfo *StateInfo + StorageMode *string + Tags map[string]*string + ZookeeperConnectString *string + ZookeeperConnectStringTls *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) SetLoggingInfo(v *LoggingInfo) *ClusterInfo + func (s *ClusterInfo) SetNumberOfBrokerNodes(v int64) *ClusterInfo + func (s *ClusterInfo) SetOpenMonitoring(v *OpenMonitoring) *ClusterInfo + func (s *ClusterInfo) SetState(v string) *ClusterInfo + func (s *ClusterInfo) SetStateInfo(v *StateInfo) *ClusterInfo + func (s *ClusterInfo) SetStorageMode(v string) *ClusterInfo + func (s *ClusterInfo) SetTags(v map[string]*string) *ClusterInfo + func (s *ClusterInfo) SetZookeeperConnectString(v string) *ClusterInfo + func (s *ClusterInfo) SetZookeeperConnectStringTls(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 + OperationSteps []*ClusterOperationStep + OperationType *string + SourceClusterInfo *MutableClusterInfo + TargetClusterInfo *MutableClusterInfo + VpcConnectionInfo *VpcConnectionInfo + 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) SetOperationSteps(v []*ClusterOperationStep) *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) SetVpcConnectionInfo(v *VpcConnectionInfo) *ClusterOperationInfo + func (s ClusterOperationInfo) GoString() string + func (s ClusterOperationInfo) String() string + type ClusterOperationStep struct + StepInfo *ClusterOperationStepInfo + StepName *string + func (s *ClusterOperationStep) SetStepInfo(v *ClusterOperationStepInfo) *ClusterOperationStep + func (s *ClusterOperationStep) SetStepName(v string) *ClusterOperationStep + func (s ClusterOperationStep) GoString() string + func (s ClusterOperationStep) String() string + type ClusterOperationStepInfo struct + StepStatus *string + func (s *ClusterOperationStepInfo) SetStepStatus(v string) *ClusterOperationStepInfo + func (s ClusterOperationStepInfo) GoString() string + func (s ClusterOperationStepInfo) String() string + type ClusterOperationV2 struct + ClusterArn *string + ClusterType *string + EndTime *time.Time + OperationArn *string + OperationState *string + OperationType *string + Provisioned *ClusterOperationV2Provisioned + Serverless *ClusterOperationV2Serverless + StartTime *time.Time + func (s *ClusterOperationV2) SetClusterArn(v string) *ClusterOperationV2 + func (s *ClusterOperationV2) SetClusterType(v string) *ClusterOperationV2 + func (s *ClusterOperationV2) SetEndTime(v time.Time) *ClusterOperationV2 + func (s *ClusterOperationV2) SetOperationArn(v string) *ClusterOperationV2 + func (s *ClusterOperationV2) SetOperationState(v string) *ClusterOperationV2 + func (s *ClusterOperationV2) SetOperationType(v string) *ClusterOperationV2 + func (s *ClusterOperationV2) SetProvisioned(v *ClusterOperationV2Provisioned) *ClusterOperationV2 + func (s *ClusterOperationV2) SetServerless(v *ClusterOperationV2Serverless) *ClusterOperationV2 + func (s *ClusterOperationV2) SetStartTime(v time.Time) *ClusterOperationV2 + func (s ClusterOperationV2) GoString() string + func (s ClusterOperationV2) String() string + type ClusterOperationV2Provisioned struct + OperationSteps []*ClusterOperationStep + SourceClusterInfo *MutableClusterInfo + TargetClusterInfo *MutableClusterInfo + VpcConnectionInfo *VpcConnectionInfo + func (s *ClusterOperationV2Provisioned) SetOperationSteps(v []*ClusterOperationStep) *ClusterOperationV2Provisioned + func (s *ClusterOperationV2Provisioned) SetSourceClusterInfo(v *MutableClusterInfo) *ClusterOperationV2Provisioned + func (s *ClusterOperationV2Provisioned) SetTargetClusterInfo(v *MutableClusterInfo) *ClusterOperationV2Provisioned + func (s *ClusterOperationV2Provisioned) SetVpcConnectionInfo(v *VpcConnectionInfo) *ClusterOperationV2Provisioned + func (s ClusterOperationV2Provisioned) GoString() string + func (s ClusterOperationV2Provisioned) String() string + type ClusterOperationV2Serverless struct + VpcConnectionInfo *VpcConnectionInfoServerless + func (s *ClusterOperationV2Serverless) SetVpcConnectionInfo(v *VpcConnectionInfoServerless) *ClusterOperationV2Serverless + func (s ClusterOperationV2Serverless) GoString() string + func (s ClusterOperationV2Serverless) String() string + type ClusterOperationV2Summary struct + ClusterArn *string + ClusterType *string + EndTime *time.Time + OperationArn *string + OperationState *string + OperationType *string + StartTime *time.Time + func (s *ClusterOperationV2Summary) SetClusterArn(v string) *ClusterOperationV2Summary + func (s *ClusterOperationV2Summary) SetClusterType(v string) *ClusterOperationV2Summary + func (s *ClusterOperationV2Summary) SetEndTime(v time.Time) *ClusterOperationV2Summary + func (s *ClusterOperationV2Summary) SetOperationArn(v string) *ClusterOperationV2Summary + func (s *ClusterOperationV2Summary) SetOperationState(v string) *ClusterOperationV2Summary + func (s *ClusterOperationV2Summary) SetOperationType(v string) *ClusterOperationV2Summary + func (s *ClusterOperationV2Summary) SetStartTime(v time.Time) *ClusterOperationV2Summary + func (s ClusterOperationV2Summary) GoString() string + func (s ClusterOperationV2Summary) String() string + type CompatibleKafkaVersion struct + SourceVersion *string + TargetVersions []*string + func (s *CompatibleKafkaVersion) SetSourceVersion(v string) *CompatibleKafkaVersion + func (s *CompatibleKafkaVersion) SetTargetVersions(v []*string) *CompatibleKafkaVersion + func (s CompatibleKafkaVersion) GoString() string + func (s CompatibleKafkaVersion) String() string + type Configuration struct + Arn *string + CreationTime *time.Time + Description *string + KafkaVersions []*string + LatestRevision *ConfigurationRevision + Name *string + State *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) SetState(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 ConflictException struct + InvalidParameter *string + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *ConflictException) Code() string + func (s *ConflictException) Error() string + func (s *ConflictException) Message() string + func (s *ConflictException) OrigErr() error + func (s *ConflictException) RequestID() string + func (s *ConflictException) StatusCode() int + func (s ConflictException) GoString() string + func (s ConflictException) String() string + type ConnectivityInfo struct + PublicAccess *PublicAccess + VpcConnectivity *VpcConnectivity + func (s *ConnectivityInfo) SetPublicAccess(v *PublicAccess) *ConnectivityInfo + func (s *ConnectivityInfo) SetVpcConnectivity(v *VpcConnectivity) *ConnectivityInfo + func (s ConnectivityInfo) GoString() string + func (s ConnectivityInfo) String() string + type CreateClusterInput struct + BrokerNodeGroupInfo *BrokerNodeGroupInfo + ClientAuthentication *ClientAuthentication + ClusterName *string + ConfigurationInfo *ConfigurationInfo + EncryptionInfo *EncryptionInfo + EnhancedMonitoring *string + KafkaVersion *string + LoggingInfo *LoggingInfo + NumberOfBrokerNodes *int64 + OpenMonitoring *OpenMonitoringInfo + StorageMode *string + 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) SetLoggingInfo(v *LoggingInfo) *CreateClusterInput + func (s *CreateClusterInput) SetNumberOfBrokerNodes(v int64) *CreateClusterInput + func (s *CreateClusterInput) SetOpenMonitoring(v *OpenMonitoringInfo) *CreateClusterInput + func (s *CreateClusterInput) SetStorageMode(v string) *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 CreateClusterV2Input struct + ClusterName *string + Provisioned *ProvisionedRequest + Serverless *ServerlessRequest + Tags map[string]*string + func (s *CreateClusterV2Input) SetClusterName(v string) *CreateClusterV2Input + func (s *CreateClusterV2Input) SetProvisioned(v *ProvisionedRequest) *CreateClusterV2Input + func (s *CreateClusterV2Input) SetServerless(v *ServerlessRequest) *CreateClusterV2Input + func (s *CreateClusterV2Input) SetTags(v map[string]*string) *CreateClusterV2Input + func (s *CreateClusterV2Input) Validate() error + func (s CreateClusterV2Input) GoString() string + func (s CreateClusterV2Input) String() string + type CreateClusterV2Output struct + ClusterArn *string + ClusterName *string + ClusterType *string + State *string + func (s *CreateClusterV2Output) SetClusterArn(v string) *CreateClusterV2Output + func (s *CreateClusterV2Output) SetClusterName(v string) *CreateClusterV2Output + func (s *CreateClusterV2Output) SetClusterType(v string) *CreateClusterV2Output + func (s *CreateClusterV2Output) SetState(v string) *CreateClusterV2Output + func (s CreateClusterV2Output) GoString() string + func (s CreateClusterV2Output) 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 + State *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) SetState(v string) *CreateConfigurationOutput + func (s CreateConfigurationOutput) GoString() string + func (s CreateConfigurationOutput) String() string + type CreateVpcConnectionInput struct + Authentication *string + ClientSubnets []*string + SecurityGroups []*string + Tags map[string]*string + TargetClusterArn *string + VpcId *string + func (s *CreateVpcConnectionInput) SetAuthentication(v string) *CreateVpcConnectionInput + func (s *CreateVpcConnectionInput) SetClientSubnets(v []*string) *CreateVpcConnectionInput + func (s *CreateVpcConnectionInput) SetSecurityGroups(v []*string) *CreateVpcConnectionInput + func (s *CreateVpcConnectionInput) SetTags(v map[string]*string) *CreateVpcConnectionInput + func (s *CreateVpcConnectionInput) SetTargetClusterArn(v string) *CreateVpcConnectionInput + func (s *CreateVpcConnectionInput) SetVpcId(v string) *CreateVpcConnectionInput + func (s *CreateVpcConnectionInput) Validate() error + func (s CreateVpcConnectionInput) GoString() string + func (s CreateVpcConnectionInput) String() string + type CreateVpcConnectionOutput struct + Authentication *string + ClientSubnets []*string + CreationTime *time.Time + SecurityGroups []*string + State *string + Tags map[string]*string + VpcConnectionArn *string + VpcId *string + func (s *CreateVpcConnectionOutput) SetAuthentication(v string) *CreateVpcConnectionOutput + func (s *CreateVpcConnectionOutput) SetClientSubnets(v []*string) *CreateVpcConnectionOutput + func (s *CreateVpcConnectionOutput) SetCreationTime(v time.Time) *CreateVpcConnectionOutput + func (s *CreateVpcConnectionOutput) SetSecurityGroups(v []*string) *CreateVpcConnectionOutput + func (s *CreateVpcConnectionOutput) SetState(v string) *CreateVpcConnectionOutput + func (s *CreateVpcConnectionOutput) SetTags(v map[string]*string) *CreateVpcConnectionOutput + func (s *CreateVpcConnectionOutput) SetVpcConnectionArn(v string) *CreateVpcConnectionOutput + func (s *CreateVpcConnectionOutput) SetVpcId(v string) *CreateVpcConnectionOutput + func (s CreateVpcConnectionOutput) GoString() string + func (s CreateVpcConnectionOutput) 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 DeleteClusterPolicyInput struct + ClusterArn *string + func (s *DeleteClusterPolicyInput) SetClusterArn(v string) *DeleteClusterPolicyInput + func (s *DeleteClusterPolicyInput) Validate() error + func (s DeleteClusterPolicyInput) GoString() string + func (s DeleteClusterPolicyInput) String() string + type DeleteClusterPolicyOutput struct + func (s DeleteClusterPolicyOutput) GoString() string + func (s DeleteClusterPolicyOutput) String() string + type DeleteConfigurationInput struct + Arn *string + func (s *DeleteConfigurationInput) SetArn(v string) *DeleteConfigurationInput + func (s *DeleteConfigurationInput) Validate() error + func (s DeleteConfigurationInput) GoString() string + func (s DeleteConfigurationInput) String() string + type DeleteConfigurationOutput struct + Arn *string + State *string + func (s *DeleteConfigurationOutput) SetArn(v string) *DeleteConfigurationOutput + func (s *DeleteConfigurationOutput) SetState(v string) *DeleteConfigurationOutput + func (s DeleteConfigurationOutput) GoString() string + func (s DeleteConfigurationOutput) String() string + type DeleteVpcConnectionInput struct + Arn *string + func (s *DeleteVpcConnectionInput) SetArn(v string) *DeleteVpcConnectionInput + func (s *DeleteVpcConnectionInput) Validate() error + func (s DeleteVpcConnectionInput) GoString() string + func (s DeleteVpcConnectionInput) String() string + type DeleteVpcConnectionOutput struct + State *string + VpcConnectionArn *string + func (s *DeleteVpcConnectionOutput) SetState(v string) *DeleteVpcConnectionOutput + func (s *DeleteVpcConnectionOutput) SetVpcConnectionArn(v string) *DeleteVpcConnectionOutput + func (s DeleteVpcConnectionOutput) GoString() string + func (s DeleteVpcConnectionOutput) 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 DescribeClusterOperationV2Input struct + ClusterOperationArn *string + func (s *DescribeClusterOperationV2Input) SetClusterOperationArn(v string) *DescribeClusterOperationV2Input + func (s *DescribeClusterOperationV2Input) Validate() error + func (s DescribeClusterOperationV2Input) GoString() string + func (s DescribeClusterOperationV2Input) String() string + type DescribeClusterOperationV2Output struct + ClusterOperationInfo *ClusterOperationV2 + func (s *DescribeClusterOperationV2Output) SetClusterOperationInfo(v *ClusterOperationV2) *DescribeClusterOperationV2Output + func (s DescribeClusterOperationV2Output) GoString() string + func (s DescribeClusterOperationV2Output) 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 DescribeClusterV2Input struct + ClusterArn *string + func (s *DescribeClusterV2Input) SetClusterArn(v string) *DescribeClusterV2Input + func (s *DescribeClusterV2Input) Validate() error + func (s DescribeClusterV2Input) GoString() string + func (s DescribeClusterV2Input) String() string + type DescribeClusterV2Output struct + ClusterInfo *Cluster + func (s *DescribeClusterV2Output) SetClusterInfo(v *Cluster) *DescribeClusterV2Output + func (s DescribeClusterV2Output) GoString() string + func (s DescribeClusterV2Output) 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 + State *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) SetState(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 DescribeVpcConnectionInput struct + Arn *string + func (s *DescribeVpcConnectionInput) SetArn(v string) *DescribeVpcConnectionInput + func (s *DescribeVpcConnectionInput) Validate() error + func (s DescribeVpcConnectionInput) GoString() string + func (s DescribeVpcConnectionInput) String() string + type DescribeVpcConnectionOutput struct + Authentication *string + CreationTime *time.Time + SecurityGroups []*string + State *string + Subnets []*string + Tags map[string]*string + TargetClusterArn *string + VpcConnectionArn *string + VpcId *string + func (s *DescribeVpcConnectionOutput) SetAuthentication(v string) *DescribeVpcConnectionOutput + func (s *DescribeVpcConnectionOutput) SetCreationTime(v time.Time) *DescribeVpcConnectionOutput + func (s *DescribeVpcConnectionOutput) SetSecurityGroups(v []*string) *DescribeVpcConnectionOutput + func (s *DescribeVpcConnectionOutput) SetState(v string) *DescribeVpcConnectionOutput + func (s *DescribeVpcConnectionOutput) SetSubnets(v []*string) *DescribeVpcConnectionOutput + func (s *DescribeVpcConnectionOutput) SetTags(v map[string]*string) *DescribeVpcConnectionOutput + func (s *DescribeVpcConnectionOutput) SetTargetClusterArn(v string) *DescribeVpcConnectionOutput + func (s *DescribeVpcConnectionOutput) SetVpcConnectionArn(v string) *DescribeVpcConnectionOutput + func (s *DescribeVpcConnectionOutput) SetVpcId(v string) *DescribeVpcConnectionOutput + func (s DescribeVpcConnectionOutput) GoString() string + func (s DescribeVpcConnectionOutput) String() string + type EBSStorageInfo struct + ProvisionedThroughput *ProvisionedThroughput + VolumeSize *int64 + func (s *EBSStorageInfo) SetProvisionedThroughput(v *ProvisionedThroughput) *EBSStorageInfo + 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 Firehose struct + DeliveryStream *string + Enabled *bool + func (s *Firehose) SetDeliveryStream(v string) *Firehose + func (s *Firehose) SetEnabled(v bool) *Firehose + func (s *Firehose) Validate() error + func (s Firehose) GoString() string + func (s Firehose) String() string + type ForbiddenException struct + InvalidParameter *string + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *ForbiddenException) Code() string + func (s *ForbiddenException) Error() string + func (s *ForbiddenException) Message() string + func (s *ForbiddenException) OrigErr() error + func (s *ForbiddenException) RequestID() string + func (s *ForbiddenException) StatusCode() int + func (s ForbiddenException) GoString() string + func (s ForbiddenException) 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 + BootstrapBrokerStringPublicSaslIam *string + BootstrapBrokerStringPublicSaslScram *string + BootstrapBrokerStringPublicTls *string + BootstrapBrokerStringSaslIam *string + BootstrapBrokerStringSaslScram *string + BootstrapBrokerStringTls *string + BootstrapBrokerStringVpcConnectivitySaslIam *string + BootstrapBrokerStringVpcConnectivitySaslScram *string + BootstrapBrokerStringVpcConnectivityTls *string + func (s *GetBootstrapBrokersOutput) SetBootstrapBrokerString(v string) *GetBootstrapBrokersOutput + func (s *GetBootstrapBrokersOutput) SetBootstrapBrokerStringPublicSaslIam(v string) *GetBootstrapBrokersOutput + func (s *GetBootstrapBrokersOutput) SetBootstrapBrokerStringPublicSaslScram(v string) *GetBootstrapBrokersOutput + func (s *GetBootstrapBrokersOutput) SetBootstrapBrokerStringPublicTls(v string) *GetBootstrapBrokersOutput + func (s *GetBootstrapBrokersOutput) SetBootstrapBrokerStringSaslIam(v string) *GetBootstrapBrokersOutput + func (s *GetBootstrapBrokersOutput) SetBootstrapBrokerStringSaslScram(v string) *GetBootstrapBrokersOutput + func (s *GetBootstrapBrokersOutput) SetBootstrapBrokerStringTls(v string) *GetBootstrapBrokersOutput + func (s *GetBootstrapBrokersOutput) SetBootstrapBrokerStringVpcConnectivitySaslIam(v string) *GetBootstrapBrokersOutput + func (s *GetBootstrapBrokersOutput) SetBootstrapBrokerStringVpcConnectivitySaslScram(v string) *GetBootstrapBrokersOutput + func (s *GetBootstrapBrokersOutput) SetBootstrapBrokerStringVpcConnectivityTls(v string) *GetBootstrapBrokersOutput + func (s GetBootstrapBrokersOutput) GoString() string + func (s GetBootstrapBrokersOutput) String() string + type GetClusterPolicyInput struct + ClusterArn *string + func (s *GetClusterPolicyInput) SetClusterArn(v string) *GetClusterPolicyInput + func (s *GetClusterPolicyInput) Validate() error + func (s GetClusterPolicyInput) GoString() string + func (s GetClusterPolicyInput) String() string + type GetClusterPolicyOutput struct + CurrentVersion *string + Policy *string + func (s *GetClusterPolicyOutput) SetCurrentVersion(v string) *GetClusterPolicyOutput + func (s *GetClusterPolicyOutput) SetPolicy(v string) *GetClusterPolicyOutput + func (s GetClusterPolicyOutput) GoString() string + func (s GetClusterPolicyOutput) String() string + type GetCompatibleKafkaVersionsInput struct + ClusterArn *string + func (s *GetCompatibleKafkaVersionsInput) SetClusterArn(v string) *GetCompatibleKafkaVersionsInput + func (s GetCompatibleKafkaVersionsInput) GoString() string + func (s GetCompatibleKafkaVersionsInput) String() string + type GetCompatibleKafkaVersionsOutput struct + CompatibleKafkaVersions []*CompatibleKafkaVersion + func (s *GetCompatibleKafkaVersionsOutput) SetCompatibleKafkaVersions(v []*CompatibleKafkaVersion) *GetCompatibleKafkaVersionsOutput + func (s GetCompatibleKafkaVersionsOutput) GoString() string + func (s GetCompatibleKafkaVersionsOutput) String() string + type Iam struct + Enabled *bool + func (s *Iam) SetEnabled(v bool) *Iam + func (s Iam) GoString() string + func (s Iam) String() string + type InternalServerErrorException struct + InvalidParameter *string + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *InternalServerErrorException) Code() string + func (s *InternalServerErrorException) Error() string + func (s *InternalServerErrorException) Message() string + func (s *InternalServerErrorException) OrigErr() error + func (s *InternalServerErrorException) RequestID() string + func (s *InternalServerErrorException) StatusCode() int + func (s InternalServerErrorException) GoString() string + func (s InternalServerErrorException) String() string + type JmxExporter struct + EnabledInBroker *bool + func (s *JmxExporter) SetEnabledInBroker(v bool) *JmxExporter + func (s JmxExporter) GoString() string + func (s JmxExporter) String() string + type JmxExporterInfo struct + EnabledInBroker *bool + func (s *JmxExporterInfo) SetEnabledInBroker(v bool) *JmxExporterInfo + func (s *JmxExporterInfo) Validate() error + func (s JmxExporterInfo) GoString() string + func (s JmxExporterInfo) String() string + type Kafka struct + func New(p client.ConfigProvider, cfgs ...*aws.Config) *Kafka + func (c *Kafka) BatchAssociateScramSecret(input *BatchAssociateScramSecretInput) (*BatchAssociateScramSecretOutput, error) + func (c *Kafka) BatchAssociateScramSecretRequest(input *BatchAssociateScramSecretInput) (req *request.Request, output *BatchAssociateScramSecretOutput) + func (c *Kafka) BatchAssociateScramSecretWithContext(ctx aws.Context, input *BatchAssociateScramSecretInput, opts ...request.Option) (*BatchAssociateScramSecretOutput, error) + func (c *Kafka) BatchDisassociateScramSecret(input *BatchDisassociateScramSecretInput) (*BatchDisassociateScramSecretOutput, error) + func (c *Kafka) BatchDisassociateScramSecretRequest(input *BatchDisassociateScramSecretInput) (req *request.Request, output *BatchDisassociateScramSecretOutput) + func (c *Kafka) BatchDisassociateScramSecretWithContext(ctx aws.Context, input *BatchDisassociateScramSecretInput, ...) (*BatchDisassociateScramSecretOutput, error) + func (c *Kafka) CreateCluster(input *CreateClusterInput) (*CreateClusterOutput, error) + func (c *Kafka) CreateClusterRequest(input *CreateClusterInput) (req *request.Request, output *CreateClusterOutput) + func (c *Kafka) CreateClusterV2(input *CreateClusterV2Input) (*CreateClusterV2Output, error) + func (c *Kafka) CreateClusterV2Request(input *CreateClusterV2Input) (req *request.Request, output *CreateClusterV2Output) + func (c *Kafka) CreateClusterV2WithContext(ctx aws.Context, input *CreateClusterV2Input, opts ...request.Option) (*CreateClusterV2Output, error) + 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) CreateVpcConnection(input *CreateVpcConnectionInput) (*CreateVpcConnectionOutput, error) + func (c *Kafka) CreateVpcConnectionRequest(input *CreateVpcConnectionInput) (req *request.Request, output *CreateVpcConnectionOutput) + func (c *Kafka) CreateVpcConnectionWithContext(ctx aws.Context, input *CreateVpcConnectionInput, opts ...request.Option) (*CreateVpcConnectionOutput, error) + func (c *Kafka) DeleteCluster(input *DeleteClusterInput) (*DeleteClusterOutput, error) + func (c *Kafka) DeleteClusterPolicy(input *DeleteClusterPolicyInput) (*DeleteClusterPolicyOutput, error) + func (c *Kafka) DeleteClusterPolicyRequest(input *DeleteClusterPolicyInput) (req *request.Request, output *DeleteClusterPolicyOutput) + func (c *Kafka) DeleteClusterPolicyWithContext(ctx aws.Context, input *DeleteClusterPolicyInput, opts ...request.Option) (*DeleteClusterPolicyOutput, 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) DeleteConfiguration(input *DeleteConfigurationInput) (*DeleteConfigurationOutput, error) + func (c *Kafka) DeleteConfigurationRequest(input *DeleteConfigurationInput) (req *request.Request, output *DeleteConfigurationOutput) + func (c *Kafka) DeleteConfigurationWithContext(ctx aws.Context, input *DeleteConfigurationInput, opts ...request.Option) (*DeleteConfigurationOutput, error) + func (c *Kafka) DeleteVpcConnection(input *DeleteVpcConnectionInput) (*DeleteVpcConnectionOutput, error) + func (c *Kafka) DeleteVpcConnectionRequest(input *DeleteVpcConnectionInput) (req *request.Request, output *DeleteVpcConnectionOutput) + func (c *Kafka) DeleteVpcConnectionWithContext(ctx aws.Context, input *DeleteVpcConnectionInput, opts ...request.Option) (*DeleteVpcConnectionOutput, 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) DescribeClusterOperationV2(input *DescribeClusterOperationV2Input) (*DescribeClusterOperationV2Output, error) + func (c *Kafka) DescribeClusterOperationV2Request(input *DescribeClusterOperationV2Input) (req *request.Request, output *DescribeClusterOperationV2Output) + func (c *Kafka) DescribeClusterOperationV2WithContext(ctx aws.Context, input *DescribeClusterOperationV2Input, ...) (*DescribeClusterOperationV2Output, error) + 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) DescribeClusterV2(input *DescribeClusterV2Input) (*DescribeClusterV2Output, error) + func (c *Kafka) DescribeClusterV2Request(input *DescribeClusterV2Input) (req *request.Request, output *DescribeClusterV2Output) + func (c *Kafka) DescribeClusterV2WithContext(ctx aws.Context, input *DescribeClusterV2Input, opts ...request.Option) (*DescribeClusterV2Output, error) + 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) DescribeVpcConnection(input *DescribeVpcConnectionInput) (*DescribeVpcConnectionOutput, error) + func (c *Kafka) DescribeVpcConnectionRequest(input *DescribeVpcConnectionInput) (req *request.Request, output *DescribeVpcConnectionOutput) + func (c *Kafka) DescribeVpcConnectionWithContext(ctx aws.Context, input *DescribeVpcConnectionInput, opts ...request.Option) (*DescribeVpcConnectionOutput, 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) GetClusterPolicy(input *GetClusterPolicyInput) (*GetClusterPolicyOutput, error) + func (c *Kafka) GetClusterPolicyRequest(input *GetClusterPolicyInput) (req *request.Request, output *GetClusterPolicyOutput) + func (c *Kafka) GetClusterPolicyWithContext(ctx aws.Context, input *GetClusterPolicyInput, opts ...request.Option) (*GetClusterPolicyOutput, error) + func (c *Kafka) GetCompatibleKafkaVersions(input *GetCompatibleKafkaVersionsInput) (*GetCompatibleKafkaVersionsOutput, error) + func (c *Kafka) GetCompatibleKafkaVersionsRequest(input *GetCompatibleKafkaVersionsInput) (req *request.Request, output *GetCompatibleKafkaVersionsOutput) + func (c *Kafka) GetCompatibleKafkaVersionsWithContext(ctx aws.Context, input *GetCompatibleKafkaVersionsInput, ...) (*GetCompatibleKafkaVersionsOutput, error) + func (c *Kafka) ListClientVpcConnections(input *ListClientVpcConnectionsInput) (*ListClientVpcConnectionsOutput, error) + func (c *Kafka) ListClientVpcConnectionsPages(input *ListClientVpcConnectionsInput, ...) error + func (c *Kafka) ListClientVpcConnectionsPagesWithContext(ctx aws.Context, input *ListClientVpcConnectionsInput, ...) error + func (c *Kafka) ListClientVpcConnectionsRequest(input *ListClientVpcConnectionsInput) (req *request.Request, output *ListClientVpcConnectionsOutput) + func (c *Kafka) ListClientVpcConnectionsWithContext(ctx aws.Context, input *ListClientVpcConnectionsInput, opts ...request.Option) (*ListClientVpcConnectionsOutput, 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) ListClusterOperationsV2(input *ListClusterOperationsV2Input) (*ListClusterOperationsV2Output, error) + func (c *Kafka) ListClusterOperationsV2Pages(input *ListClusterOperationsV2Input, ...) error + func (c *Kafka) ListClusterOperationsV2PagesWithContext(ctx aws.Context, input *ListClusterOperationsV2Input, ...) error + func (c *Kafka) ListClusterOperationsV2Request(input *ListClusterOperationsV2Input) (req *request.Request, output *ListClusterOperationsV2Output) + func (c *Kafka) ListClusterOperationsV2WithContext(ctx aws.Context, input *ListClusterOperationsV2Input, opts ...request.Option) (*ListClusterOperationsV2Output, error) + 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) ListClustersV2(input *ListClustersV2Input) (*ListClustersV2Output, error) + func (c *Kafka) ListClustersV2Pages(input *ListClustersV2Input, fn func(*ListClustersV2Output, bool) bool) error + func (c *Kafka) ListClustersV2PagesWithContext(ctx aws.Context, input *ListClustersV2Input, ...) error + func (c *Kafka) ListClustersV2Request(input *ListClustersV2Input) (req *request.Request, output *ListClustersV2Output) + func (c *Kafka) ListClustersV2WithContext(ctx aws.Context, input *ListClustersV2Input, opts ...request.Option) (*ListClustersV2Output, error) + 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) ListKafkaVersions(input *ListKafkaVersionsInput) (*ListKafkaVersionsOutput, error) + func (c *Kafka) ListKafkaVersionsPages(input *ListKafkaVersionsInput, fn func(*ListKafkaVersionsOutput, bool) bool) error + func (c *Kafka) ListKafkaVersionsPagesWithContext(ctx aws.Context, input *ListKafkaVersionsInput, ...) error + func (c *Kafka) ListKafkaVersionsRequest(input *ListKafkaVersionsInput) (req *request.Request, output *ListKafkaVersionsOutput) + func (c *Kafka) ListKafkaVersionsWithContext(ctx aws.Context, input *ListKafkaVersionsInput, opts ...request.Option) (*ListKafkaVersionsOutput, 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) ListScramSecrets(input *ListScramSecretsInput) (*ListScramSecretsOutput, error) + func (c *Kafka) ListScramSecretsPages(input *ListScramSecretsInput, fn func(*ListScramSecretsOutput, bool) bool) error + func (c *Kafka) ListScramSecretsPagesWithContext(ctx aws.Context, input *ListScramSecretsInput, ...) error + func (c *Kafka) ListScramSecretsRequest(input *ListScramSecretsInput) (req *request.Request, output *ListScramSecretsOutput) + func (c *Kafka) ListScramSecretsWithContext(ctx aws.Context, input *ListScramSecretsInput, opts ...request.Option) (*ListScramSecretsOutput, 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) ListVpcConnections(input *ListVpcConnectionsInput) (*ListVpcConnectionsOutput, error) + func (c *Kafka) ListVpcConnectionsPages(input *ListVpcConnectionsInput, fn func(*ListVpcConnectionsOutput, bool) bool) error + func (c *Kafka) ListVpcConnectionsPagesWithContext(ctx aws.Context, input *ListVpcConnectionsInput, ...) error + func (c *Kafka) ListVpcConnectionsRequest(input *ListVpcConnectionsInput) (req *request.Request, output *ListVpcConnectionsOutput) + func (c *Kafka) ListVpcConnectionsWithContext(ctx aws.Context, input *ListVpcConnectionsInput, opts ...request.Option) (*ListVpcConnectionsOutput, error) + func (c *Kafka) PutClusterPolicy(input *PutClusterPolicyInput) (*PutClusterPolicyOutput, error) + func (c *Kafka) PutClusterPolicyRequest(input *PutClusterPolicyInput) (req *request.Request, output *PutClusterPolicyOutput) + func (c *Kafka) PutClusterPolicyWithContext(ctx aws.Context, input *PutClusterPolicyInput, opts ...request.Option) (*PutClusterPolicyOutput, error) + func (c *Kafka) RebootBroker(input *RebootBrokerInput) (*RebootBrokerOutput, error) + func (c *Kafka) RebootBrokerRequest(input *RebootBrokerInput) (req *request.Request, output *RebootBrokerOutput) + func (c *Kafka) RebootBrokerWithContext(ctx aws.Context, input *RebootBrokerInput, opts ...request.Option) (*RebootBrokerOutput, error) + func (c *Kafka) RejectClientVpcConnection(input *RejectClientVpcConnectionInput) (*RejectClientVpcConnectionOutput, error) + func (c *Kafka) RejectClientVpcConnectionRequest(input *RejectClientVpcConnectionInput) (req *request.Request, output *RejectClientVpcConnectionOutput) + func (c *Kafka) RejectClientVpcConnectionWithContext(ctx aws.Context, input *RejectClientVpcConnectionInput, opts ...request.Option) (*RejectClientVpcConnectionOutput, 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) UpdateBrokerCount(input *UpdateBrokerCountInput) (*UpdateBrokerCountOutput, error) + func (c *Kafka) UpdateBrokerCountRequest(input *UpdateBrokerCountInput) (req *request.Request, output *UpdateBrokerCountOutput) + func (c *Kafka) UpdateBrokerCountWithContext(ctx aws.Context, input *UpdateBrokerCountInput, opts ...request.Option) (*UpdateBrokerCountOutput, 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) UpdateBrokerType(input *UpdateBrokerTypeInput) (*UpdateBrokerTypeOutput, error) + func (c *Kafka) UpdateBrokerTypeRequest(input *UpdateBrokerTypeInput) (req *request.Request, output *UpdateBrokerTypeOutput) + func (c *Kafka) UpdateBrokerTypeWithContext(ctx aws.Context, input *UpdateBrokerTypeInput, opts ...request.Option) (*UpdateBrokerTypeOutput, 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) + func (c *Kafka) UpdateClusterKafkaVersion(input *UpdateClusterKafkaVersionInput) (*UpdateClusterKafkaVersionOutput, error) + func (c *Kafka) UpdateClusterKafkaVersionRequest(input *UpdateClusterKafkaVersionInput) (req *request.Request, output *UpdateClusterKafkaVersionOutput) + func (c *Kafka) UpdateClusterKafkaVersionWithContext(ctx aws.Context, input *UpdateClusterKafkaVersionInput, opts ...request.Option) (*UpdateClusterKafkaVersionOutput, error) + func (c *Kafka) UpdateConfiguration(input *UpdateConfigurationInput) (*UpdateConfigurationOutput, error) + func (c *Kafka) UpdateConfigurationRequest(input *UpdateConfigurationInput) (req *request.Request, output *UpdateConfigurationOutput) + func (c *Kafka) UpdateConfigurationWithContext(ctx aws.Context, input *UpdateConfigurationInput, opts ...request.Option) (*UpdateConfigurationOutput, error) + func (c *Kafka) UpdateConnectivity(input *UpdateConnectivityInput) (*UpdateConnectivityOutput, error) + func (c *Kafka) UpdateConnectivityRequest(input *UpdateConnectivityInput) (req *request.Request, output *UpdateConnectivityOutput) + func (c *Kafka) UpdateConnectivityWithContext(ctx aws.Context, input *UpdateConnectivityInput, opts ...request.Option) (*UpdateConnectivityOutput, error) + func (c *Kafka) UpdateMonitoring(input *UpdateMonitoringInput) (*UpdateMonitoringOutput, error) + func (c *Kafka) UpdateMonitoringRequest(input *UpdateMonitoringInput) (req *request.Request, output *UpdateMonitoringOutput) + func (c *Kafka) UpdateMonitoringWithContext(ctx aws.Context, input *UpdateMonitoringInput, opts ...request.Option) (*UpdateMonitoringOutput, error) + func (c *Kafka) UpdateSecurity(input *UpdateSecurityInput) (*UpdateSecurityOutput, error) + func (c *Kafka) UpdateSecurityRequest(input *UpdateSecurityInput) (req *request.Request, output *UpdateSecurityOutput) + func (c *Kafka) UpdateSecurityWithContext(ctx aws.Context, input *UpdateSecurityInput, opts ...request.Option) (*UpdateSecurityOutput, error) + func (c *Kafka) UpdateStorage(input *UpdateStorageInput) (*UpdateStorageOutput, error) + func (c *Kafka) UpdateStorageRequest(input *UpdateStorageInput) (req *request.Request, output *UpdateStorageOutput) + func (c *Kafka) UpdateStorageWithContext(ctx aws.Context, input *UpdateStorageInput, opts ...request.Option) (*UpdateStorageOutput, error) + type KafkaVersion struct + Status *string + Version *string + func (s *KafkaVersion) SetStatus(v string) *KafkaVersion + func (s *KafkaVersion) SetVersion(v string) *KafkaVersion + func (s KafkaVersion) GoString() string + func (s KafkaVersion) String() string + type ListClientVpcConnectionsInput struct + ClusterArn *string + MaxResults *int64 + NextToken *string + func (s *ListClientVpcConnectionsInput) SetClusterArn(v string) *ListClientVpcConnectionsInput + func (s *ListClientVpcConnectionsInput) SetMaxResults(v int64) *ListClientVpcConnectionsInput + func (s *ListClientVpcConnectionsInput) SetNextToken(v string) *ListClientVpcConnectionsInput + func (s *ListClientVpcConnectionsInput) Validate() error + func (s ListClientVpcConnectionsInput) GoString() string + func (s ListClientVpcConnectionsInput) String() string + type ListClientVpcConnectionsOutput struct + ClientVpcConnections []*ClientVpcConnection + NextToken *string + func (s *ListClientVpcConnectionsOutput) SetClientVpcConnections(v []*ClientVpcConnection) *ListClientVpcConnectionsOutput + func (s *ListClientVpcConnectionsOutput) SetNextToken(v string) *ListClientVpcConnectionsOutput + func (s ListClientVpcConnectionsOutput) GoString() string + func (s ListClientVpcConnectionsOutput) String() string + 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 ListClusterOperationsV2Input struct + ClusterArn *string + MaxResults *int64 + NextToken *string + func (s *ListClusterOperationsV2Input) SetClusterArn(v string) *ListClusterOperationsV2Input + func (s *ListClusterOperationsV2Input) SetMaxResults(v int64) *ListClusterOperationsV2Input + func (s *ListClusterOperationsV2Input) SetNextToken(v string) *ListClusterOperationsV2Input + func (s *ListClusterOperationsV2Input) Validate() error + func (s ListClusterOperationsV2Input) GoString() string + func (s ListClusterOperationsV2Input) String() string + type ListClusterOperationsV2Output struct + ClusterOperationInfoList []*ClusterOperationV2Summary + NextToken *string + func (s *ListClusterOperationsV2Output) SetClusterOperationInfoList(v []*ClusterOperationV2Summary) *ListClusterOperationsV2Output + func (s *ListClusterOperationsV2Output) SetNextToken(v string) *ListClusterOperationsV2Output + func (s ListClusterOperationsV2Output) GoString() string + func (s ListClusterOperationsV2Output) 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 ListClustersV2Input struct + ClusterNameFilter *string + ClusterTypeFilter *string + MaxResults *int64 + NextToken *string + func (s *ListClustersV2Input) SetClusterNameFilter(v string) *ListClustersV2Input + func (s *ListClustersV2Input) SetClusterTypeFilter(v string) *ListClustersV2Input + func (s *ListClustersV2Input) SetMaxResults(v int64) *ListClustersV2Input + func (s *ListClustersV2Input) SetNextToken(v string) *ListClustersV2Input + func (s *ListClustersV2Input) Validate() error + func (s ListClustersV2Input) GoString() string + func (s ListClustersV2Input) String() string + type ListClustersV2Output struct + ClusterInfoList []*Cluster + NextToken *string + func (s *ListClustersV2Output) SetClusterInfoList(v []*Cluster) *ListClustersV2Output + func (s *ListClustersV2Output) SetNextToken(v string) *ListClustersV2Output + func (s ListClustersV2Output) GoString() string + func (s ListClustersV2Output) 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 ListKafkaVersionsInput struct + MaxResults *int64 + NextToken *string + func (s *ListKafkaVersionsInput) SetMaxResults(v int64) *ListKafkaVersionsInput + func (s *ListKafkaVersionsInput) SetNextToken(v string) *ListKafkaVersionsInput + func (s *ListKafkaVersionsInput) Validate() error + func (s ListKafkaVersionsInput) GoString() string + func (s ListKafkaVersionsInput) String() string + type ListKafkaVersionsOutput struct + KafkaVersions []*KafkaVersion + NextToken *string + func (s *ListKafkaVersionsOutput) SetKafkaVersions(v []*KafkaVersion) *ListKafkaVersionsOutput + func (s *ListKafkaVersionsOutput) SetNextToken(v string) *ListKafkaVersionsOutput + func (s ListKafkaVersionsOutput) GoString() string + func (s ListKafkaVersionsOutput) 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 ListScramSecretsInput struct + ClusterArn *string + MaxResults *int64 + NextToken *string + func (s *ListScramSecretsInput) SetClusterArn(v string) *ListScramSecretsInput + func (s *ListScramSecretsInput) SetMaxResults(v int64) *ListScramSecretsInput + func (s *ListScramSecretsInput) SetNextToken(v string) *ListScramSecretsInput + func (s *ListScramSecretsInput) Validate() error + func (s ListScramSecretsInput) GoString() string + func (s ListScramSecretsInput) String() string + type ListScramSecretsOutput struct + NextToken *string + SecretArnList []*string + func (s *ListScramSecretsOutput) SetNextToken(v string) *ListScramSecretsOutput + func (s *ListScramSecretsOutput) SetSecretArnList(v []*string) *ListScramSecretsOutput + func (s ListScramSecretsOutput) GoString() string + func (s ListScramSecretsOutput) 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 ListVpcConnectionsInput struct + MaxResults *int64 + NextToken *string + func (s *ListVpcConnectionsInput) SetMaxResults(v int64) *ListVpcConnectionsInput + func (s *ListVpcConnectionsInput) SetNextToken(v string) *ListVpcConnectionsInput + func (s *ListVpcConnectionsInput) Validate() error + func (s ListVpcConnectionsInput) GoString() string + func (s ListVpcConnectionsInput) String() string + type ListVpcConnectionsOutput struct + NextToken *string + VpcConnections []*VpcConnection + func (s *ListVpcConnectionsOutput) SetNextToken(v string) *ListVpcConnectionsOutput + func (s *ListVpcConnectionsOutput) SetVpcConnections(v []*VpcConnection) *ListVpcConnectionsOutput + func (s ListVpcConnectionsOutput) GoString() string + func (s ListVpcConnectionsOutput) String() string + type LoggingInfo struct + BrokerLogs *BrokerLogs + func (s *LoggingInfo) SetBrokerLogs(v *BrokerLogs) *LoggingInfo + func (s *LoggingInfo) Validate() error + func (s LoggingInfo) GoString() string + func (s LoggingInfo) String() string + type MutableClusterInfo struct + BrokerEBSVolumeInfo []*BrokerEBSVolumeInfo + ClientAuthentication *ClientAuthentication + ConfigurationInfo *ConfigurationInfo + ConnectivityInfo *ConnectivityInfo + EncryptionInfo *EncryptionInfo + EnhancedMonitoring *string + InstanceType *string + KafkaVersion *string + LoggingInfo *LoggingInfo + NumberOfBrokerNodes *int64 + OpenMonitoring *OpenMonitoring + StorageMode *string + func (s *MutableClusterInfo) SetBrokerEBSVolumeInfo(v []*BrokerEBSVolumeInfo) *MutableClusterInfo + func (s *MutableClusterInfo) SetClientAuthentication(v *ClientAuthentication) *MutableClusterInfo + func (s *MutableClusterInfo) SetConfigurationInfo(v *ConfigurationInfo) *MutableClusterInfo + func (s *MutableClusterInfo) SetConnectivityInfo(v *ConnectivityInfo) *MutableClusterInfo + func (s *MutableClusterInfo) SetEncryptionInfo(v *EncryptionInfo) *MutableClusterInfo + func (s *MutableClusterInfo) SetEnhancedMonitoring(v string) *MutableClusterInfo + func (s *MutableClusterInfo) SetInstanceType(v string) *MutableClusterInfo + func (s *MutableClusterInfo) SetKafkaVersion(v string) *MutableClusterInfo + func (s *MutableClusterInfo) SetLoggingInfo(v *LoggingInfo) *MutableClusterInfo + func (s *MutableClusterInfo) SetNumberOfBrokerNodes(v int64) *MutableClusterInfo + func (s *MutableClusterInfo) SetOpenMonitoring(v *OpenMonitoring) *MutableClusterInfo + func (s *MutableClusterInfo) SetStorageMode(v string) *MutableClusterInfo + func (s MutableClusterInfo) GoString() string + func (s MutableClusterInfo) String() string + type NodeExporter struct + EnabledInBroker *bool + func (s *NodeExporter) SetEnabledInBroker(v bool) *NodeExporter + func (s NodeExporter) GoString() string + func (s NodeExporter) String() string + type NodeExporterInfo struct + EnabledInBroker *bool + func (s *NodeExporterInfo) SetEnabledInBroker(v bool) *NodeExporterInfo + func (s *NodeExporterInfo) Validate() error + func (s NodeExporterInfo) GoString() string + func (s NodeExporterInfo) 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 NotFoundException struct + InvalidParameter *string + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *NotFoundException) Code() string + func (s *NotFoundException) Error() string + func (s *NotFoundException) Message() string + func (s *NotFoundException) OrigErr() error + func (s *NotFoundException) RequestID() string + func (s *NotFoundException) StatusCode() int + func (s NotFoundException) GoString() string + func (s NotFoundException) String() string + type OpenMonitoring struct + Prometheus *Prometheus + func (s *OpenMonitoring) SetPrometheus(v *Prometheus) *OpenMonitoring + func (s OpenMonitoring) GoString() string + func (s OpenMonitoring) String() string + type OpenMonitoringInfo struct + Prometheus *PrometheusInfo + func (s *OpenMonitoringInfo) SetPrometheus(v *PrometheusInfo) *OpenMonitoringInfo + func (s *OpenMonitoringInfo) Validate() error + func (s OpenMonitoringInfo) GoString() string + func (s OpenMonitoringInfo) String() string + type Prometheus struct + JmxExporter *JmxExporter + NodeExporter *NodeExporter + func (s *Prometheus) SetJmxExporter(v *JmxExporter) *Prometheus + func (s *Prometheus) SetNodeExporter(v *NodeExporter) *Prometheus + func (s Prometheus) GoString() string + func (s Prometheus) String() string + type PrometheusInfo struct + JmxExporter *JmxExporterInfo + NodeExporter *NodeExporterInfo + func (s *PrometheusInfo) SetJmxExporter(v *JmxExporterInfo) *PrometheusInfo + func (s *PrometheusInfo) SetNodeExporter(v *NodeExporterInfo) *PrometheusInfo + func (s *PrometheusInfo) Validate() error + func (s PrometheusInfo) GoString() string + func (s PrometheusInfo) String() string + type Provisioned struct + BrokerNodeGroupInfo *BrokerNodeGroupInfo + ClientAuthentication *ClientAuthentication + CurrentBrokerSoftwareInfo *BrokerSoftwareInfo + EncryptionInfo *EncryptionInfo + EnhancedMonitoring *string + LoggingInfo *LoggingInfo + NumberOfBrokerNodes *int64 + OpenMonitoring *OpenMonitoringInfo + StorageMode *string + ZookeeperConnectString *string + ZookeeperConnectStringTls *string + func (s *Provisioned) SetBrokerNodeGroupInfo(v *BrokerNodeGroupInfo) *Provisioned + func (s *Provisioned) SetClientAuthentication(v *ClientAuthentication) *Provisioned + func (s *Provisioned) SetCurrentBrokerSoftwareInfo(v *BrokerSoftwareInfo) *Provisioned + func (s *Provisioned) SetEncryptionInfo(v *EncryptionInfo) *Provisioned + func (s *Provisioned) SetEnhancedMonitoring(v string) *Provisioned + func (s *Provisioned) SetLoggingInfo(v *LoggingInfo) *Provisioned + func (s *Provisioned) SetNumberOfBrokerNodes(v int64) *Provisioned + func (s *Provisioned) SetOpenMonitoring(v *OpenMonitoringInfo) *Provisioned + func (s *Provisioned) SetStorageMode(v string) *Provisioned + func (s *Provisioned) SetZookeeperConnectString(v string) *Provisioned + func (s *Provisioned) SetZookeeperConnectStringTls(v string) *Provisioned + func (s Provisioned) GoString() string + func (s Provisioned) String() string + type ProvisionedRequest struct + BrokerNodeGroupInfo *BrokerNodeGroupInfo + ClientAuthentication *ClientAuthentication + ConfigurationInfo *ConfigurationInfo + EncryptionInfo *EncryptionInfo + EnhancedMonitoring *string + KafkaVersion *string + LoggingInfo *LoggingInfo + NumberOfBrokerNodes *int64 + OpenMonitoring *OpenMonitoringInfo + StorageMode *string + func (s *ProvisionedRequest) SetBrokerNodeGroupInfo(v *BrokerNodeGroupInfo) *ProvisionedRequest + func (s *ProvisionedRequest) SetClientAuthentication(v *ClientAuthentication) *ProvisionedRequest + func (s *ProvisionedRequest) SetConfigurationInfo(v *ConfigurationInfo) *ProvisionedRequest + func (s *ProvisionedRequest) SetEncryptionInfo(v *EncryptionInfo) *ProvisionedRequest + func (s *ProvisionedRequest) SetEnhancedMonitoring(v string) *ProvisionedRequest + func (s *ProvisionedRequest) SetKafkaVersion(v string) *ProvisionedRequest + func (s *ProvisionedRequest) SetLoggingInfo(v *LoggingInfo) *ProvisionedRequest + func (s *ProvisionedRequest) SetNumberOfBrokerNodes(v int64) *ProvisionedRequest + func (s *ProvisionedRequest) SetOpenMonitoring(v *OpenMonitoringInfo) *ProvisionedRequest + func (s *ProvisionedRequest) SetStorageMode(v string) *ProvisionedRequest + func (s *ProvisionedRequest) Validate() error + func (s ProvisionedRequest) GoString() string + func (s ProvisionedRequest) String() string + type ProvisionedThroughput struct + Enabled *bool + VolumeThroughput *int64 + func (s *ProvisionedThroughput) SetEnabled(v bool) *ProvisionedThroughput + func (s *ProvisionedThroughput) SetVolumeThroughput(v int64) *ProvisionedThroughput + func (s ProvisionedThroughput) GoString() string + func (s ProvisionedThroughput) String() string + type PublicAccess struct + Type *string + func (s *PublicAccess) SetType(v string) *PublicAccess + func (s PublicAccess) GoString() string + func (s PublicAccess) String() string + type PutClusterPolicyInput struct + ClusterArn *string + CurrentVersion *string + Policy *string + func (s *PutClusterPolicyInput) SetClusterArn(v string) *PutClusterPolicyInput + func (s *PutClusterPolicyInput) SetCurrentVersion(v string) *PutClusterPolicyInput + func (s *PutClusterPolicyInput) SetPolicy(v string) *PutClusterPolicyInput + func (s *PutClusterPolicyInput) Validate() error + func (s PutClusterPolicyInput) GoString() string + func (s PutClusterPolicyInput) String() string + type PutClusterPolicyOutput struct + CurrentVersion *string + func (s *PutClusterPolicyOutput) SetCurrentVersion(v string) *PutClusterPolicyOutput + func (s PutClusterPolicyOutput) GoString() string + func (s PutClusterPolicyOutput) String() string + type RebootBrokerInput struct + BrokerIds []*string + ClusterArn *string + func (s *RebootBrokerInput) SetBrokerIds(v []*string) *RebootBrokerInput + func (s *RebootBrokerInput) SetClusterArn(v string) *RebootBrokerInput + func (s *RebootBrokerInput) Validate() error + func (s RebootBrokerInput) GoString() string + func (s RebootBrokerInput) String() string + type RebootBrokerOutput struct + ClusterArn *string + ClusterOperationArn *string + func (s *RebootBrokerOutput) SetClusterArn(v string) *RebootBrokerOutput + func (s *RebootBrokerOutput) SetClusterOperationArn(v string) *RebootBrokerOutput + func (s RebootBrokerOutput) GoString() string + func (s RebootBrokerOutput) String() string + type RejectClientVpcConnectionInput struct + ClusterArn *string + VpcConnectionArn *string + func (s *RejectClientVpcConnectionInput) SetClusterArn(v string) *RejectClientVpcConnectionInput + func (s *RejectClientVpcConnectionInput) SetVpcConnectionArn(v string) *RejectClientVpcConnectionInput + func (s *RejectClientVpcConnectionInput) Validate() error + func (s RejectClientVpcConnectionInput) GoString() string + func (s RejectClientVpcConnectionInput) String() string + type RejectClientVpcConnectionOutput struct + func (s RejectClientVpcConnectionOutput) GoString() string + func (s RejectClientVpcConnectionOutput) String() string + type S3 struct + Bucket *string + Enabled *bool + Prefix *string + func (s *S3) SetBucket(v string) *S3 + func (s *S3) SetEnabled(v bool) *S3 + func (s *S3) SetPrefix(v string) *S3 + func (s *S3) Validate() error + func (s S3) GoString() string + func (s S3) String() string + type Sasl struct + Iam *Iam + Scram *Scram + func (s *Sasl) SetIam(v *Iam) *Sasl + func (s *Sasl) SetScram(v *Scram) *Sasl + func (s Sasl) GoString() string + func (s Sasl) String() string + type Scram struct + Enabled *bool + func (s *Scram) SetEnabled(v bool) *Scram + func (s Scram) GoString() string + func (s Scram) String() string + type Serverless struct + ClientAuthentication *ServerlessClientAuthentication + VpcConfigs []*VpcConfig + func (s *Serverless) SetClientAuthentication(v *ServerlessClientAuthentication) *Serverless + func (s *Serverless) SetVpcConfigs(v []*VpcConfig) *Serverless + func (s Serverless) GoString() string + func (s Serverless) String() string + type ServerlessClientAuthentication struct + Sasl *ServerlessSasl + func (s *ServerlessClientAuthentication) SetSasl(v *ServerlessSasl) *ServerlessClientAuthentication + func (s ServerlessClientAuthentication) GoString() string + func (s ServerlessClientAuthentication) String() string + type ServerlessRequest struct + ClientAuthentication *ServerlessClientAuthentication + VpcConfigs []*VpcConfig + func (s *ServerlessRequest) SetClientAuthentication(v *ServerlessClientAuthentication) *ServerlessRequest + func (s *ServerlessRequest) SetVpcConfigs(v []*VpcConfig) *ServerlessRequest + func (s *ServerlessRequest) Validate() error + func (s ServerlessRequest) GoString() string + func (s ServerlessRequest) String() string + type ServerlessSasl struct + Iam *Iam + func (s *ServerlessSasl) SetIam(v *Iam) *ServerlessSasl + func (s ServerlessSasl) GoString() string + func (s ServerlessSasl) String() string + type ServiceUnavailableException struct + InvalidParameter *string + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *ServiceUnavailableException) Code() string + func (s *ServiceUnavailableException) Error() string + func (s *ServiceUnavailableException) Message() string + func (s *ServiceUnavailableException) OrigErr() error + func (s *ServiceUnavailableException) RequestID() string + func (s *ServiceUnavailableException) StatusCode() int + func (s ServiceUnavailableException) GoString() string + func (s ServiceUnavailableException) String() string + type StateInfo struct + Code *string + Message *string + func (s *StateInfo) SetCode(v string) *StateInfo + func (s *StateInfo) SetMessage(v string) *StateInfo + func (s StateInfo) GoString() string + func (s StateInfo) 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 + Enabled *bool + func (s *Tls) SetCertificateAuthorityArnList(v []*string) *Tls + func (s *Tls) SetEnabled(v bool) *Tls + func (s Tls) GoString() string + func (s Tls) String() string + type TooManyRequestsException struct + InvalidParameter *string + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *TooManyRequestsException) Code() string + func (s *TooManyRequestsException) Error() string + func (s *TooManyRequestsException) Message() string + func (s *TooManyRequestsException) OrigErr() error + func (s *TooManyRequestsException) RequestID() string + func (s *TooManyRequestsException) StatusCode() int + func (s TooManyRequestsException) GoString() string + func (s TooManyRequestsException) String() string + type Unauthenticated struct + Enabled *bool + func (s *Unauthenticated) SetEnabled(v bool) *Unauthenticated + func (s Unauthenticated) GoString() string + func (s Unauthenticated) String() string + type UnauthorizedException struct + InvalidParameter *string + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *UnauthorizedException) Code() string + func (s *UnauthorizedException) Error() string + func (s *UnauthorizedException) Message() string + func (s *UnauthorizedException) OrigErr() error + func (s *UnauthorizedException) RequestID() string + func (s *UnauthorizedException) StatusCode() int + func (s UnauthorizedException) GoString() string + func (s UnauthorizedException) String() string + type UnprocessedScramSecret struct + ErrorCode *string + ErrorMessage *string + SecretArn *string + func (s *UnprocessedScramSecret) SetErrorCode(v string) *UnprocessedScramSecret + func (s *UnprocessedScramSecret) SetErrorMessage(v string) *UnprocessedScramSecret + func (s *UnprocessedScramSecret) SetSecretArn(v string) *UnprocessedScramSecret + func (s UnprocessedScramSecret) GoString() string + func (s UnprocessedScramSecret) 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 UpdateBrokerCountInput struct + ClusterArn *string + CurrentVersion *string + TargetNumberOfBrokerNodes *int64 + func (s *UpdateBrokerCountInput) SetClusterArn(v string) *UpdateBrokerCountInput + func (s *UpdateBrokerCountInput) SetCurrentVersion(v string) *UpdateBrokerCountInput + func (s *UpdateBrokerCountInput) SetTargetNumberOfBrokerNodes(v int64) *UpdateBrokerCountInput + func (s *UpdateBrokerCountInput) Validate() error + func (s UpdateBrokerCountInput) GoString() string + func (s UpdateBrokerCountInput) String() string + type UpdateBrokerCountOutput struct + ClusterArn *string + ClusterOperationArn *string + func (s *UpdateBrokerCountOutput) SetClusterArn(v string) *UpdateBrokerCountOutput + func (s *UpdateBrokerCountOutput) SetClusterOperationArn(v string) *UpdateBrokerCountOutput + func (s UpdateBrokerCountOutput) GoString() string + func (s UpdateBrokerCountOutput) 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 UpdateBrokerTypeInput struct + ClusterArn *string + CurrentVersion *string + TargetInstanceType *string + func (s *UpdateBrokerTypeInput) SetClusterArn(v string) *UpdateBrokerTypeInput + func (s *UpdateBrokerTypeInput) SetCurrentVersion(v string) *UpdateBrokerTypeInput + func (s *UpdateBrokerTypeInput) SetTargetInstanceType(v string) *UpdateBrokerTypeInput + func (s *UpdateBrokerTypeInput) Validate() error + func (s UpdateBrokerTypeInput) GoString() string + func (s UpdateBrokerTypeInput) String() string + type UpdateBrokerTypeOutput struct + ClusterArn *string + ClusterOperationArn *string + func (s *UpdateBrokerTypeOutput) SetClusterArn(v string) *UpdateBrokerTypeOutput + func (s *UpdateBrokerTypeOutput) SetClusterOperationArn(v string) *UpdateBrokerTypeOutput + func (s UpdateBrokerTypeOutput) GoString() string + func (s UpdateBrokerTypeOutput) 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 UpdateClusterKafkaVersionInput struct + ClusterArn *string + ConfigurationInfo *ConfigurationInfo + CurrentVersion *string + TargetKafkaVersion *string + func (s *UpdateClusterKafkaVersionInput) SetClusterArn(v string) *UpdateClusterKafkaVersionInput + func (s *UpdateClusterKafkaVersionInput) SetConfigurationInfo(v *ConfigurationInfo) *UpdateClusterKafkaVersionInput + func (s *UpdateClusterKafkaVersionInput) SetCurrentVersion(v string) *UpdateClusterKafkaVersionInput + func (s *UpdateClusterKafkaVersionInput) SetTargetKafkaVersion(v string) *UpdateClusterKafkaVersionInput + func (s *UpdateClusterKafkaVersionInput) Validate() error + func (s UpdateClusterKafkaVersionInput) GoString() string + func (s UpdateClusterKafkaVersionInput) String() string + type UpdateClusterKafkaVersionOutput struct + ClusterArn *string + ClusterOperationArn *string + func (s *UpdateClusterKafkaVersionOutput) SetClusterArn(v string) *UpdateClusterKafkaVersionOutput + func (s *UpdateClusterKafkaVersionOutput) SetClusterOperationArn(v string) *UpdateClusterKafkaVersionOutput + func (s UpdateClusterKafkaVersionOutput) GoString() string + func (s UpdateClusterKafkaVersionOutput) String() string + type UpdateConfigurationInput struct + Arn *string + Description *string + ServerProperties []byte + func (s *UpdateConfigurationInput) SetArn(v string) *UpdateConfigurationInput + func (s *UpdateConfigurationInput) SetDescription(v string) *UpdateConfigurationInput + func (s *UpdateConfigurationInput) SetServerProperties(v []byte) *UpdateConfigurationInput + func (s *UpdateConfigurationInput) Validate() error + func (s UpdateConfigurationInput) GoString() string + func (s UpdateConfigurationInput) String() string + type UpdateConfigurationOutput struct + Arn *string + LatestRevision *ConfigurationRevision + func (s *UpdateConfigurationOutput) SetArn(v string) *UpdateConfigurationOutput + func (s *UpdateConfigurationOutput) SetLatestRevision(v *ConfigurationRevision) *UpdateConfigurationOutput + func (s UpdateConfigurationOutput) GoString() string + func (s UpdateConfigurationOutput) String() string + type UpdateConnectivityInput struct + ClusterArn *string + ConnectivityInfo *ConnectivityInfo + CurrentVersion *string + func (s *UpdateConnectivityInput) SetClusterArn(v string) *UpdateConnectivityInput + func (s *UpdateConnectivityInput) SetConnectivityInfo(v *ConnectivityInfo) *UpdateConnectivityInput + func (s *UpdateConnectivityInput) SetCurrentVersion(v string) *UpdateConnectivityInput + func (s *UpdateConnectivityInput) Validate() error + func (s UpdateConnectivityInput) GoString() string + func (s UpdateConnectivityInput) String() string + type UpdateConnectivityOutput struct + ClusterArn *string + ClusterOperationArn *string + func (s *UpdateConnectivityOutput) SetClusterArn(v string) *UpdateConnectivityOutput + func (s *UpdateConnectivityOutput) SetClusterOperationArn(v string) *UpdateConnectivityOutput + func (s UpdateConnectivityOutput) GoString() string + func (s UpdateConnectivityOutput) String() string + type UpdateMonitoringInput struct + ClusterArn *string + CurrentVersion *string + EnhancedMonitoring *string + LoggingInfo *LoggingInfo + OpenMonitoring *OpenMonitoringInfo + func (s *UpdateMonitoringInput) SetClusterArn(v string) *UpdateMonitoringInput + func (s *UpdateMonitoringInput) SetCurrentVersion(v string) *UpdateMonitoringInput + func (s *UpdateMonitoringInput) SetEnhancedMonitoring(v string) *UpdateMonitoringInput + func (s *UpdateMonitoringInput) SetLoggingInfo(v *LoggingInfo) *UpdateMonitoringInput + func (s *UpdateMonitoringInput) SetOpenMonitoring(v *OpenMonitoringInfo) *UpdateMonitoringInput + func (s *UpdateMonitoringInput) Validate() error + func (s UpdateMonitoringInput) GoString() string + func (s UpdateMonitoringInput) String() string + type UpdateMonitoringOutput struct + ClusterArn *string + ClusterOperationArn *string + func (s *UpdateMonitoringOutput) SetClusterArn(v string) *UpdateMonitoringOutput + func (s *UpdateMonitoringOutput) SetClusterOperationArn(v string) *UpdateMonitoringOutput + func (s UpdateMonitoringOutput) GoString() string + func (s UpdateMonitoringOutput) String() string + type UpdateSecurityInput struct + ClientAuthentication *ClientAuthentication + ClusterArn *string + CurrentVersion *string + EncryptionInfo *EncryptionInfo + func (s *UpdateSecurityInput) SetClientAuthentication(v *ClientAuthentication) *UpdateSecurityInput + func (s *UpdateSecurityInput) SetClusterArn(v string) *UpdateSecurityInput + func (s *UpdateSecurityInput) SetCurrentVersion(v string) *UpdateSecurityInput + func (s *UpdateSecurityInput) SetEncryptionInfo(v *EncryptionInfo) *UpdateSecurityInput + func (s *UpdateSecurityInput) Validate() error + func (s UpdateSecurityInput) GoString() string + func (s UpdateSecurityInput) String() string + type UpdateSecurityOutput struct + ClusterArn *string + ClusterOperationArn *string + func (s *UpdateSecurityOutput) SetClusterArn(v string) *UpdateSecurityOutput + func (s *UpdateSecurityOutput) SetClusterOperationArn(v string) *UpdateSecurityOutput + func (s UpdateSecurityOutput) GoString() string + func (s UpdateSecurityOutput) String() string + type UpdateStorageInput struct + ClusterArn *string + CurrentVersion *string + ProvisionedThroughput *ProvisionedThroughput + StorageMode *string + VolumeSizeGB *int64 + func (s *UpdateStorageInput) SetClusterArn(v string) *UpdateStorageInput + func (s *UpdateStorageInput) SetCurrentVersion(v string) *UpdateStorageInput + func (s *UpdateStorageInput) SetProvisionedThroughput(v *ProvisionedThroughput) *UpdateStorageInput + func (s *UpdateStorageInput) SetStorageMode(v string) *UpdateStorageInput + func (s *UpdateStorageInput) SetVolumeSizeGB(v int64) *UpdateStorageInput + func (s *UpdateStorageInput) Validate() error + func (s UpdateStorageInput) GoString() string + func (s UpdateStorageInput) String() string + type UpdateStorageOutput struct + ClusterArn *string + ClusterOperationArn *string + func (s *UpdateStorageOutput) SetClusterArn(v string) *UpdateStorageOutput + func (s *UpdateStorageOutput) SetClusterOperationArn(v string) *UpdateStorageOutput + func (s UpdateStorageOutput) GoString() string + func (s UpdateStorageOutput) String() string + type UserIdentity struct + PrincipalId *string + Type *string + func (s *UserIdentity) SetPrincipalId(v string) *UserIdentity + func (s *UserIdentity) SetType(v string) *UserIdentity + func (s UserIdentity) GoString() string + func (s UserIdentity) String() string + type VpcConfig struct + SecurityGroupIds []*string + SubnetIds []*string + func (s *VpcConfig) SetSecurityGroupIds(v []*string) *VpcConfig + func (s *VpcConfig) SetSubnetIds(v []*string) *VpcConfig + func (s *VpcConfig) Validate() error + func (s VpcConfig) GoString() string + func (s VpcConfig) String() string + type VpcConnection struct + Authentication *string + CreationTime *time.Time + State *string + TargetClusterArn *string + VpcConnectionArn *string + VpcId *string + func (s *VpcConnection) SetAuthentication(v string) *VpcConnection + func (s *VpcConnection) SetCreationTime(v time.Time) *VpcConnection + func (s *VpcConnection) SetState(v string) *VpcConnection + func (s *VpcConnection) SetTargetClusterArn(v string) *VpcConnection + func (s *VpcConnection) SetVpcConnectionArn(v string) *VpcConnection + func (s *VpcConnection) SetVpcId(v string) *VpcConnection + func (s VpcConnection) GoString() string + func (s VpcConnection) String() string + type VpcConnectionInfo struct + CreationTime *time.Time + Owner *string + UserIdentity *UserIdentity + VpcConnectionArn *string + func (s *VpcConnectionInfo) SetCreationTime(v time.Time) *VpcConnectionInfo + func (s *VpcConnectionInfo) SetOwner(v string) *VpcConnectionInfo + func (s *VpcConnectionInfo) SetUserIdentity(v *UserIdentity) *VpcConnectionInfo + func (s *VpcConnectionInfo) SetVpcConnectionArn(v string) *VpcConnectionInfo + func (s VpcConnectionInfo) GoString() string + func (s VpcConnectionInfo) String() string + type VpcConnectionInfoServerless struct + CreationTime *time.Time + Owner *string + UserIdentity *UserIdentity + VpcConnectionArn *string + func (s *VpcConnectionInfoServerless) SetCreationTime(v time.Time) *VpcConnectionInfoServerless + func (s *VpcConnectionInfoServerless) SetOwner(v string) *VpcConnectionInfoServerless + func (s *VpcConnectionInfoServerless) SetUserIdentity(v *UserIdentity) *VpcConnectionInfoServerless + func (s *VpcConnectionInfoServerless) SetVpcConnectionArn(v string) *VpcConnectionInfoServerless + func (s VpcConnectionInfoServerless) GoString() string + func (s VpcConnectionInfoServerless) String() string + type VpcConnectivity struct + ClientAuthentication *VpcConnectivityClientAuthentication + func (s *VpcConnectivity) SetClientAuthentication(v *VpcConnectivityClientAuthentication) *VpcConnectivity + func (s VpcConnectivity) GoString() string + func (s VpcConnectivity) String() string + type VpcConnectivityClientAuthentication struct + Sasl *VpcConnectivitySasl + Tls *VpcConnectivityTls + func (s *VpcConnectivityClientAuthentication) SetSasl(v *VpcConnectivitySasl) *VpcConnectivityClientAuthentication + func (s *VpcConnectivityClientAuthentication) SetTls(v *VpcConnectivityTls) *VpcConnectivityClientAuthentication + func (s VpcConnectivityClientAuthentication) GoString() string + func (s VpcConnectivityClientAuthentication) String() string + type VpcConnectivityIam struct + Enabled *bool + func (s *VpcConnectivityIam) SetEnabled(v bool) *VpcConnectivityIam + func (s VpcConnectivityIam) GoString() string + func (s VpcConnectivityIam) String() string + type VpcConnectivitySasl struct + Iam *VpcConnectivityIam + Scram *VpcConnectivityScram + func (s *VpcConnectivitySasl) SetIam(v *VpcConnectivityIam) *VpcConnectivitySasl + func (s *VpcConnectivitySasl) SetScram(v *VpcConnectivityScram) *VpcConnectivitySasl + func (s VpcConnectivitySasl) GoString() string + func (s VpcConnectivitySasl) String() string + type VpcConnectivityScram struct + Enabled *bool + func (s *VpcConnectivityScram) SetEnabled(v bool) *VpcConnectivityScram + func (s VpcConnectivityScram) GoString() string + func (s VpcConnectivityScram) String() string + type VpcConnectivityTls struct + Enabled *bool + func (s *VpcConnectivityTls) SetEnabled(v bool) *VpcConnectivityTls + func (s VpcConnectivityTls) GoString() string + func (s VpcConnectivityTls) 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
Go to main page