Documentation ¶
Overview ¶
Package kafka provides the client and types for making API requests to Managed Streaming for Kafka.
The operations for managing an Amazon MSK cluster.
See https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14 for more information on this service.
See kafka package documentation for more information. https://docs.aws.amazon.com/sdk-for-go/api/service/kafka/
Using the Client ¶
To contact Managed Streaming for Kafka with the SDK use the New function to create a new service client. With that client you can make API requests to the service. These clients are safe to use concurrently.
See the SDK's documentation for more information on how to use the SDK. https://docs.aws.amazon.com/sdk-for-go/api/
See aws.Config documentation for more information on configuring SDK clients. https://docs.aws.amazon.com/sdk-for-go/api/aws/#Config
See the Managed Streaming for Kafka client Kafka for more information on creating client for this service. https://docs.aws.amazon.com/sdk-for-go/api/service/kafka/#New
Index ¶
- Constants
- type BrokerEBSVolumeInfo
- type BrokerNodeGroupInfo
- func (s BrokerNodeGroupInfo) GoString() string
- func (s *BrokerNodeGroupInfo) SetBrokerAZDistribution(v string) *BrokerNodeGroupInfo
- func (s *BrokerNodeGroupInfo) SetClientSubnets(v []*string) *BrokerNodeGroupInfo
- func (s *BrokerNodeGroupInfo) SetInstanceType(v string) *BrokerNodeGroupInfo
- func (s *BrokerNodeGroupInfo) SetSecurityGroups(v []*string) *BrokerNodeGroupInfo
- func (s *BrokerNodeGroupInfo) SetStorageInfo(v *StorageInfo) *BrokerNodeGroupInfo
- func (s BrokerNodeGroupInfo) String() string
- func (s *BrokerNodeGroupInfo) Validate() error
- type BrokerNodeInfo
- func (s BrokerNodeInfo) GoString() 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) String() string
- type BrokerSoftwareInfo
- func (s BrokerSoftwareInfo) GoString() 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) String() string
- type ClientAuthentication
- type ClusterInfo
- func (s ClusterInfo) GoString() string
- func (s *ClusterInfo) SetActiveOperationArn(v string) *ClusterInfo
- func (s *ClusterInfo) SetBrokerNodeGroupInfo(v *BrokerNodeGroupInfo) *ClusterInfo
- func (s *ClusterInfo) SetClientAuthentication(v *ClientAuthentication) *ClusterInfo
- func (s *ClusterInfo) SetClusterArn(v string) *ClusterInfo
- func (s *ClusterInfo) SetClusterName(v string) *ClusterInfo
- func (s *ClusterInfo) SetCreationTime(v time.Time) *ClusterInfo
- func (s *ClusterInfo) SetCurrentBrokerSoftwareInfo(v *BrokerSoftwareInfo) *ClusterInfo
- func (s *ClusterInfo) SetCurrentVersion(v string) *ClusterInfo
- func (s *ClusterInfo) SetEncryptionInfo(v *EncryptionInfo) *ClusterInfo
- func (s *ClusterInfo) SetEnhancedMonitoring(v string) *ClusterInfo
- func (s *ClusterInfo) SetNumberOfBrokerNodes(v int64) *ClusterInfo
- func (s *ClusterInfo) SetState(v string) *ClusterInfo
- func (s *ClusterInfo) SetTags(v map[string]*string) *ClusterInfo
- func (s *ClusterInfo) SetZookeeperConnectString(v string) *ClusterInfo
- func (s ClusterInfo) String() string
- type ClusterOperationInfo
- func (s ClusterOperationInfo) GoString() string
- func (s *ClusterOperationInfo) SetClientRequestId(v string) *ClusterOperationInfo
- func (s *ClusterOperationInfo) SetClusterArn(v string) *ClusterOperationInfo
- func (s *ClusterOperationInfo) SetCreationTime(v time.Time) *ClusterOperationInfo
- func (s *ClusterOperationInfo) SetEndTime(v time.Time) *ClusterOperationInfo
- func (s *ClusterOperationInfo) SetErrorInfo(v *ErrorInfo) *ClusterOperationInfo
- func (s *ClusterOperationInfo) SetOperationArn(v string) *ClusterOperationInfo
- func (s *ClusterOperationInfo) SetOperationState(v string) *ClusterOperationInfo
- func (s *ClusterOperationInfo) SetOperationType(v string) *ClusterOperationInfo
- func (s *ClusterOperationInfo) SetSourceClusterInfo(v *MutableClusterInfo) *ClusterOperationInfo
- func (s *ClusterOperationInfo) SetTargetClusterInfo(v *MutableClusterInfo) *ClusterOperationInfo
- func (s ClusterOperationInfo) String() string
- type Configuration
- func (s Configuration) GoString() 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) String() string
- type ConfigurationInfo
- type ConfigurationRevision
- func (s ConfigurationRevision) GoString() string
- 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) String() string
- type CreateClusterInput
- func (s CreateClusterInput) GoString() string
- func (s *CreateClusterInput) SetBrokerNodeGroupInfo(v *BrokerNodeGroupInfo) *CreateClusterInput
- func (s *CreateClusterInput) SetClientAuthentication(v *ClientAuthentication) *CreateClusterInput
- func (s *CreateClusterInput) SetClusterName(v string) *CreateClusterInput
- func (s *CreateClusterInput) SetConfigurationInfo(v *ConfigurationInfo) *CreateClusterInput
- func (s *CreateClusterInput) SetEncryptionInfo(v *EncryptionInfo) *CreateClusterInput
- func (s *CreateClusterInput) SetEnhancedMonitoring(v string) *CreateClusterInput
- func (s *CreateClusterInput) SetKafkaVersion(v string) *CreateClusterInput
- func (s *CreateClusterInput) SetNumberOfBrokerNodes(v int64) *CreateClusterInput
- func (s *CreateClusterInput) SetTags(v map[string]*string) *CreateClusterInput
- func (s CreateClusterInput) String() string
- func (s *CreateClusterInput) Validate() error
- type CreateClusterOutput
- func (s CreateClusterOutput) GoString() 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) String() string
- type CreateConfigurationInput
- func (s CreateConfigurationInput) GoString() string
- 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) String() string
- func (s *CreateConfigurationInput) Validate() error
- type CreateConfigurationOutput
- func (s CreateConfigurationOutput) GoString() 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) String() string
- type DeleteClusterInput
- type DeleteClusterOutput
- type DescribeClusterInput
- type DescribeClusterOperationInput
- type DescribeClusterOperationOutput
- type DescribeClusterOutput
- type DescribeConfigurationInput
- type DescribeConfigurationOutput
- func (s DescribeConfigurationOutput) GoString() 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) String() string
- type DescribeConfigurationRevisionInput
- func (s DescribeConfigurationRevisionInput) GoString() string
- func (s *DescribeConfigurationRevisionInput) SetArn(v string) *DescribeConfigurationRevisionInput
- func (s *DescribeConfigurationRevisionInput) SetRevision(v int64) *DescribeConfigurationRevisionInput
- func (s DescribeConfigurationRevisionInput) String() string
- func (s *DescribeConfigurationRevisionInput) Validate() error
- type DescribeConfigurationRevisionOutput
- func (s DescribeConfigurationRevisionOutput) GoString() string
- 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) String() string
- type EBSStorageInfo
- type EncryptionAtRest
- type EncryptionInTransit
- type EncryptionInfo
- type ErrorInfo
- type GetBootstrapBrokersInput
- type GetBootstrapBrokersOutput
- func (s GetBootstrapBrokersOutput) GoString() string
- func (s *GetBootstrapBrokersOutput) SetBootstrapBrokerString(v string) *GetBootstrapBrokersOutput
- func (s *GetBootstrapBrokersOutput) SetBootstrapBrokerStringTls(v string) *GetBootstrapBrokersOutput
- func (s GetBootstrapBrokersOutput) String() string
- type Kafka
- func (c *Kafka) CreateCluster(input *CreateClusterInput) (*CreateClusterOutput, error)
- func (c *Kafka) CreateClusterRequest(input *CreateClusterInput) (req *request.Request, output *CreateClusterOutput)
- func (c *Kafka) CreateClusterWithContext(ctx aws.Context, input *CreateClusterInput, opts ...request.Option) (*CreateClusterOutput, error)
- func (c *Kafka) CreateConfiguration(input *CreateConfigurationInput) (*CreateConfigurationOutput, error)
- func (c *Kafka) CreateConfigurationRequest(input *CreateConfigurationInput) (req *request.Request, output *CreateConfigurationOutput)
- func (c *Kafka) CreateConfigurationWithContext(ctx aws.Context, input *CreateConfigurationInput, opts ...request.Option) (*CreateConfigurationOutput, error)
- func (c *Kafka) DeleteCluster(input *DeleteClusterInput) (*DeleteClusterOutput, error)
- func (c *Kafka) DeleteClusterRequest(input *DeleteClusterInput) (req *request.Request, output *DeleteClusterOutput)
- func (c *Kafka) DeleteClusterWithContext(ctx aws.Context, input *DeleteClusterInput, opts ...request.Option) (*DeleteClusterOutput, error)
- func (c *Kafka) DescribeCluster(input *DescribeClusterInput) (*DescribeClusterOutput, error)
- func (c *Kafka) DescribeClusterOperation(input *DescribeClusterOperationInput) (*DescribeClusterOperationOutput, error)
- func (c *Kafka) DescribeClusterOperationRequest(input *DescribeClusterOperationInput) (req *request.Request, output *DescribeClusterOperationOutput)
- func (c *Kafka) DescribeClusterOperationWithContext(ctx aws.Context, input *DescribeClusterOperationInput, opts ...request.Option) (*DescribeClusterOperationOutput, error)
- func (c *Kafka) DescribeClusterRequest(input *DescribeClusterInput) (req *request.Request, output *DescribeClusterOutput)
- func (c *Kafka) DescribeClusterWithContext(ctx aws.Context, input *DescribeClusterInput, opts ...request.Option) (*DescribeClusterOutput, error)
- func (c *Kafka) DescribeConfiguration(input *DescribeConfigurationInput) (*DescribeConfigurationOutput, error)
- func (c *Kafka) DescribeConfigurationRequest(input *DescribeConfigurationInput) (req *request.Request, output *DescribeConfigurationOutput)
- func (c *Kafka) DescribeConfigurationRevision(input *DescribeConfigurationRevisionInput) (*DescribeConfigurationRevisionOutput, error)
- func (c *Kafka) DescribeConfigurationRevisionRequest(input *DescribeConfigurationRevisionInput) (req *request.Request, output *DescribeConfigurationRevisionOutput)
- func (c *Kafka) DescribeConfigurationRevisionWithContext(ctx aws.Context, input *DescribeConfigurationRevisionInput, ...) (*DescribeConfigurationRevisionOutput, error)
- func (c *Kafka) DescribeConfigurationWithContext(ctx aws.Context, input *DescribeConfigurationInput, opts ...request.Option) (*DescribeConfigurationOutput, error)
- func (c *Kafka) GetBootstrapBrokers(input *GetBootstrapBrokersInput) (*GetBootstrapBrokersOutput, error)
- func (c *Kafka) GetBootstrapBrokersRequest(input *GetBootstrapBrokersInput) (req *request.Request, output *GetBootstrapBrokersOutput)
- func (c *Kafka) GetBootstrapBrokersWithContext(ctx aws.Context, input *GetBootstrapBrokersInput, opts ...request.Option) (*GetBootstrapBrokersOutput, error)
- func (c *Kafka) ListClusterOperations(input *ListClusterOperationsInput) (*ListClusterOperationsOutput, error)
- func (c *Kafka) ListClusterOperationsPages(input *ListClusterOperationsInput, ...) error
- func (c *Kafka) ListClusterOperationsPagesWithContext(ctx aws.Context, input *ListClusterOperationsInput, ...) error
- func (c *Kafka) ListClusterOperationsRequest(input *ListClusterOperationsInput) (req *request.Request, output *ListClusterOperationsOutput)
- func (c *Kafka) ListClusterOperationsWithContext(ctx aws.Context, input *ListClusterOperationsInput, opts ...request.Option) (*ListClusterOperationsOutput, error)
- func (c *Kafka) ListClusters(input *ListClustersInput) (*ListClustersOutput, error)
- func (c *Kafka) ListClustersPages(input *ListClustersInput, fn func(*ListClustersOutput, bool) bool) error
- func (c *Kafka) ListClustersPagesWithContext(ctx aws.Context, input *ListClustersInput, ...) error
- func (c *Kafka) ListClustersRequest(input *ListClustersInput) (req *request.Request, output *ListClustersOutput)
- func (c *Kafka) ListClustersWithContext(ctx aws.Context, input *ListClustersInput, opts ...request.Option) (*ListClustersOutput, error)
- func (c *Kafka) ListConfigurationRevisions(input *ListConfigurationRevisionsInput) (*ListConfigurationRevisionsOutput, error)
- func (c *Kafka) ListConfigurationRevisionsPages(input *ListConfigurationRevisionsInput, ...) error
- func (c *Kafka) ListConfigurationRevisionsPagesWithContext(ctx aws.Context, input *ListConfigurationRevisionsInput, ...) error
- func (c *Kafka) ListConfigurationRevisionsRequest(input *ListConfigurationRevisionsInput) (req *request.Request, output *ListConfigurationRevisionsOutput)
- func (c *Kafka) ListConfigurationRevisionsWithContext(ctx aws.Context, input *ListConfigurationRevisionsInput, ...) (*ListConfigurationRevisionsOutput, error)
- func (c *Kafka) ListConfigurations(input *ListConfigurationsInput) (*ListConfigurationsOutput, error)
- func (c *Kafka) ListConfigurationsPages(input *ListConfigurationsInput, fn func(*ListConfigurationsOutput, bool) bool) error
- func (c *Kafka) ListConfigurationsPagesWithContext(ctx aws.Context, input *ListConfigurationsInput, ...) error
- func (c *Kafka) ListConfigurationsRequest(input *ListConfigurationsInput) (req *request.Request, output *ListConfigurationsOutput)
- func (c *Kafka) ListConfigurationsWithContext(ctx aws.Context, input *ListConfigurationsInput, opts ...request.Option) (*ListConfigurationsOutput, error)
- func (c *Kafka) ListNodes(input *ListNodesInput) (*ListNodesOutput, error)
- func (c *Kafka) ListNodesPages(input *ListNodesInput, fn func(*ListNodesOutput, bool) bool) error
- func (c *Kafka) ListNodesPagesWithContext(ctx aws.Context, input *ListNodesInput, fn func(*ListNodesOutput, bool) bool, ...) error
- func (c *Kafka) ListNodesRequest(input *ListNodesInput) (req *request.Request, output *ListNodesOutput)
- func (c *Kafka) ListNodesWithContext(ctx aws.Context, input *ListNodesInput, opts ...request.Option) (*ListNodesOutput, error)
- func (c *Kafka) ListTagsForResource(input *ListTagsForResourceInput) (*ListTagsForResourceOutput, error)
- func (c *Kafka) ListTagsForResourceRequest(input *ListTagsForResourceInput) (req *request.Request, output *ListTagsForResourceOutput)
- func (c *Kafka) ListTagsForResourceWithContext(ctx aws.Context, input *ListTagsForResourceInput, opts ...request.Option) (*ListTagsForResourceOutput, error)
- func (c *Kafka) TagResource(input *TagResourceInput) (*TagResourceOutput, error)
- func (c *Kafka) TagResourceRequest(input *TagResourceInput) (req *request.Request, output *TagResourceOutput)
- func (c *Kafka) TagResourceWithContext(ctx aws.Context, input *TagResourceInput, opts ...request.Option) (*TagResourceOutput, error)
- func (c *Kafka) UntagResource(input *UntagResourceInput) (*UntagResourceOutput, error)
- func (c *Kafka) UntagResourceRequest(input *UntagResourceInput) (req *request.Request, output *UntagResourceOutput)
- func (c *Kafka) UntagResourceWithContext(ctx aws.Context, input *UntagResourceInput, opts ...request.Option) (*UntagResourceOutput, error)
- func (c *Kafka) UpdateBrokerStorage(input *UpdateBrokerStorageInput) (*UpdateBrokerStorageOutput, error)
- func (c *Kafka) UpdateBrokerStorageRequest(input *UpdateBrokerStorageInput) (req *request.Request, output *UpdateBrokerStorageOutput)
- func (c *Kafka) UpdateBrokerStorageWithContext(ctx aws.Context, input *UpdateBrokerStorageInput, opts ...request.Option) (*UpdateBrokerStorageOutput, error)
- func (c *Kafka) UpdateClusterConfiguration(input *UpdateClusterConfigurationInput) (*UpdateClusterConfigurationOutput, error)
- func (c *Kafka) UpdateClusterConfigurationRequest(input *UpdateClusterConfigurationInput) (req *request.Request, output *UpdateClusterConfigurationOutput)
- func (c *Kafka) UpdateClusterConfigurationWithContext(ctx aws.Context, input *UpdateClusterConfigurationInput, ...) (*UpdateClusterConfigurationOutput, error)
- type ListClusterOperationsInput
- func (s ListClusterOperationsInput) GoString() 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) String() string
- func (s *ListClusterOperationsInput) Validate() error
- type ListClusterOperationsOutput
- func (s ListClusterOperationsOutput) GoString() string
- func (s *ListClusterOperationsOutput) SetClusterOperationInfoList(v []*ClusterOperationInfo) *ListClusterOperationsOutput
- func (s *ListClusterOperationsOutput) SetNextToken(v string) *ListClusterOperationsOutput
- func (s ListClusterOperationsOutput) String() string
- type ListClustersInput
- func (s ListClustersInput) GoString() 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) String() string
- func (s *ListClustersInput) Validate() error
- type ListClustersOutput
- type ListConfigurationRevisionsInput
- func (s ListConfigurationRevisionsInput) GoString() 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) String() string
- func (s *ListConfigurationRevisionsInput) Validate() error
- type ListConfigurationRevisionsOutput
- func (s ListConfigurationRevisionsOutput) GoString() string
- func (s *ListConfigurationRevisionsOutput) SetNextToken(v string) *ListConfigurationRevisionsOutput
- func (s *ListConfigurationRevisionsOutput) SetRevisions(v []*ConfigurationRevision) *ListConfigurationRevisionsOutput
- func (s ListConfigurationRevisionsOutput) String() string
- type ListConfigurationsInput
- func (s ListConfigurationsInput) GoString() string
- func (s *ListConfigurationsInput) SetMaxResults(v int64) *ListConfigurationsInput
- func (s *ListConfigurationsInput) SetNextToken(v string) *ListConfigurationsInput
- func (s ListConfigurationsInput) String() string
- func (s *ListConfigurationsInput) Validate() error
- type ListConfigurationsOutput
- type ListNodesInput
- func (s ListNodesInput) GoString() 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) String() string
- func (s *ListNodesInput) Validate() error
- type ListNodesOutput
- type ListTagsForResourceInput
- type ListTagsForResourceOutput
- type MutableClusterInfo
- func (s MutableClusterInfo) GoString() string
- func (s *MutableClusterInfo) SetBrokerEBSVolumeInfo(v []*BrokerEBSVolumeInfo) *MutableClusterInfo
- func (s *MutableClusterInfo) SetConfigurationInfo(v *ConfigurationInfo) *MutableClusterInfo
- func (s *MutableClusterInfo) SetNumberOfBrokerNodes(v int64) *MutableClusterInfo
- func (s MutableClusterInfo) String() string
- type NodeInfo
- func (s NodeInfo) GoString() string
- 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) String() string
- type StorageInfo
- type TagResourceInput
- type TagResourceOutput
- type Tls
- type UntagResourceInput
- type UntagResourceOutput
- type UpdateBrokerStorageInput
- func (s UpdateBrokerStorageInput) GoString() string
- func (s *UpdateBrokerStorageInput) SetClusterArn(v string) *UpdateBrokerStorageInput
- func (s *UpdateBrokerStorageInput) SetCurrentVersion(v string) *UpdateBrokerStorageInput
- func (s *UpdateBrokerStorageInput) SetTargetBrokerEBSVolumeInfo(v []*BrokerEBSVolumeInfo) *UpdateBrokerStorageInput
- func (s UpdateBrokerStorageInput) String() string
- func (s *UpdateBrokerStorageInput) Validate() error
- type UpdateBrokerStorageOutput
- type UpdateClusterConfigurationInput
- func (s UpdateClusterConfigurationInput) GoString() 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) String() string
- func (s *UpdateClusterConfigurationInput) Validate() error
- type UpdateClusterConfigurationOutput
- func (s UpdateClusterConfigurationOutput) GoString() string
- func (s *UpdateClusterConfigurationOutput) SetClusterArn(v string) *UpdateClusterConfigurationOutput
- func (s *UpdateClusterConfigurationOutput) SetClusterOperationArn(v string) *UpdateClusterConfigurationOutput
- func (s UpdateClusterConfigurationOutput) String() string
- type ZookeeperNodeInfo
- func (s ZookeeperNodeInfo) GoString() 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) String() string
Constants ¶
const ( // ClientBrokerTls is a ClientBroker enum value ClientBrokerTls = "TLS" // ClientBrokerTlsPlaintext is a ClientBroker enum value ClientBrokerTlsPlaintext = "TLS_PLAINTEXT" // ClientBrokerPlaintext is a ClientBroker enum value ClientBrokerPlaintext = "PLAINTEXT" )
Client-broker encryption in transit setting.
const ( // ClusterStateActive is a ClusterState enum value ClusterStateActive = "ACTIVE" // ClusterStateCreating is a ClusterState enum value ClusterStateCreating = "CREATING" // ClusterStateUpdating is a ClusterState enum value ClusterStateUpdating = "UPDATING" // ClusterStateDeleting is a ClusterState enum value ClusterStateDeleting = "DELETING" // ClusterStateFailed is a ClusterState enum value ClusterStateFailed = "FAILED" )
The state of a Kafka cluster.
const ( // EnhancedMonitoringDefault is a EnhancedMonitoring enum value EnhancedMonitoringDefault = "DEFAULT" // EnhancedMonitoringPerBroker is a EnhancedMonitoring enum value EnhancedMonitoringPerBroker = "PER_BROKER" // EnhancedMonitoringPerTopicPerBroker is a EnhancedMonitoring enum value EnhancedMonitoringPerTopicPerBroker = "PER_TOPIC_PER_BROKER" )
Specifies which metrics are gathered for the MSK cluster. This property has three possible values: DEFAULT, PER_BROKER, and PER_TOPIC_PER_BROKER. For a list of the metrics associated with each of these three levels of monitoring, see Monitoring (https://docs.aws.amazon.com/msk/latest/developerguide/monitoring.html).
const ( // ErrCodeBadRequestException for service response error code // "BadRequestException". // // Returns information about an error. ErrCodeBadRequestException = "BadRequestException" // ErrCodeConflictException for service response error code // "ConflictException". // // Returns information about an error. ErrCodeConflictException = "ConflictException" // ErrCodeForbiddenException for service response error code // "ForbiddenException". // // Returns information about an error. ErrCodeForbiddenException = "ForbiddenException" // ErrCodeInternalServerErrorException for service response error code // "InternalServerErrorException". // // Returns information about an error. ErrCodeInternalServerErrorException = "InternalServerErrorException" // ErrCodeNotFoundException for service response error code // "NotFoundException". // // Returns information about an error. ErrCodeNotFoundException = "NotFoundException" // "ServiceUnavailableException". // // Returns information about an error. ErrCodeServiceUnavailableException = "ServiceUnavailableException" // ErrCodeTooManyRequestsException for service response error code // "TooManyRequestsException". // // Returns information about an error. ErrCodeTooManyRequestsException = "TooManyRequestsException" // "UnauthorizedException". // // Returns information about an error. ErrCodeUnauthorizedException = "UnauthorizedException" )
const ( ServiceName = "Kafka" // Name of service. EndpointsID = "kafka" // ID to lookup a service endpoint with. ServiceID = "Kafka" // ServiceID is a unique identifer of a specific service. )
Service information constants
const (
// BrokerAZDistributionDefault is a BrokerAZDistribution enum value
BrokerAZDistributionDefault = "DEFAULT"
)
The distribution of broker nodes across Availability Zones. By default, broker nodes are distributed among three Availability Zones. Currently, the only supported value is DEFAULT. You can either specify this value explicitly or leave it out.
const (
// NodeTypeBroker is a NodeType enum value
NodeTypeBroker = "BROKER"
)
The broker or Zookeeper node.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BrokerEBSVolumeInfo ¶
type BrokerEBSVolumeInfo struct { // The ID of the broker to update. // // KafkaBrokerNodeId is a required field KafkaBrokerNodeId *string `locationName:"kafkaBrokerNodeId" type:"string" required:"true"` // Size of the EBS volume to update. // // VolumeSizeGB is a required field VolumeSizeGB *int64 `locationName:"volumeSizeGB" type:"integer" required:"true"` // contains filtered or unexported fields }
Specifies the EBS volume upgrade information. The broker identifier must be set to the keyword ALL. This means the changes apply to all the brokers in the cluster.
func (BrokerEBSVolumeInfo) GoString ¶
func (s BrokerEBSVolumeInfo) GoString() string
GoString returns the string representation
func (*BrokerEBSVolumeInfo) SetKafkaBrokerNodeId ¶
func (s *BrokerEBSVolumeInfo) SetKafkaBrokerNodeId(v string) *BrokerEBSVolumeInfo
SetKafkaBrokerNodeId sets the KafkaBrokerNodeId field's value.
func (*BrokerEBSVolumeInfo) SetVolumeSizeGB ¶
func (s *BrokerEBSVolumeInfo) SetVolumeSizeGB(v int64) *BrokerEBSVolumeInfo
SetVolumeSizeGB sets the VolumeSizeGB field's value.
func (BrokerEBSVolumeInfo) String ¶
func (s BrokerEBSVolumeInfo) String() string
String returns the string representation
func (*BrokerEBSVolumeInfo) Validate ¶
func (s *BrokerEBSVolumeInfo) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type BrokerNodeGroupInfo ¶
type BrokerNodeGroupInfo struct { // The distribution of broker nodes across Availability Zones. BrokerAZDistribution *string `locationName:"brokerAZDistribution" type:"string" enum:"BrokerAZDistribution"` // The list of subnets to connect to in the client virtual private cloud (VPC). // AWS creates elastic network interfaces inside these subnets. Client applications // use elastic network interfaces to produce and consume data. Client subnets // can't be in Availability Zone us-east-1e. // // ClientSubnets is a required field ClientSubnets []*string `locationName:"clientSubnets" type:"list" required:"true"` // The type of Amazon EC2 instances to use for Kafka brokers. The following // instance types are allowed: kafka.m5.large, kafka.m5.xlarge, kafka.m5.2xlarge,kafka.m5.4xlarge, // kafka.m5.12xlarge, and kafka.m5.24xlarge. // // InstanceType is a required field InstanceType *string `locationName:"instanceType" min:"5" type:"string" required:"true"` // The AWS security groups to associate with the elastic network interfaces // in order to specify who can connect to and communicate with the Amazon MSK // cluster. If you don't specify a security group, Amazon MSK uses the default // security group associated with the VPC. SecurityGroups []*string `locationName:"securityGroups" type:"list"` // Contains information about storage volumes attached to MSK broker nodes. StorageInfo *StorageInfo `locationName:"storageInfo" type:"structure"` // contains filtered or unexported fields }
Describes the setup to be used for Kafka broker nodes in the cluster.
func (BrokerNodeGroupInfo) GoString ¶
func (s BrokerNodeGroupInfo) GoString() string
GoString returns the string representation
func (*BrokerNodeGroupInfo) SetBrokerAZDistribution ¶
func (s *BrokerNodeGroupInfo) SetBrokerAZDistribution(v string) *BrokerNodeGroupInfo
SetBrokerAZDistribution sets the BrokerAZDistribution field's value.
func (*BrokerNodeGroupInfo) SetClientSubnets ¶
func (s *BrokerNodeGroupInfo) SetClientSubnets(v []*string) *BrokerNodeGroupInfo
SetClientSubnets sets the ClientSubnets field's value.
func (*BrokerNodeGroupInfo) SetInstanceType ¶
func (s *BrokerNodeGroupInfo) SetInstanceType(v string) *BrokerNodeGroupInfo
SetInstanceType sets the InstanceType field's value.
func (*BrokerNodeGroupInfo) SetSecurityGroups ¶
func (s *BrokerNodeGroupInfo) SetSecurityGroups(v []*string) *BrokerNodeGroupInfo
SetSecurityGroups sets the SecurityGroups field's value.
func (*BrokerNodeGroupInfo) SetStorageInfo ¶
func (s *BrokerNodeGroupInfo) SetStorageInfo(v *StorageInfo) *BrokerNodeGroupInfo
SetStorageInfo sets the StorageInfo field's value.
func (BrokerNodeGroupInfo) String ¶
func (s BrokerNodeGroupInfo) String() string
String returns the string representation
func (*BrokerNodeGroupInfo) Validate ¶
func (s *BrokerNodeGroupInfo) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type BrokerNodeInfo ¶
type BrokerNodeInfo struct { // The attached elastic network interface of the broker. AttachedENIId *string `locationName:"attachedENIId" type:"string"` // The ID of the broker. BrokerId *float64 `locationName:"brokerId" type:"double"` // The client subnet to which this broker node belongs. ClientSubnet *string `locationName:"clientSubnet" type:"string"` // The virtual private cloud (VPC) of the client. ClientVpcIpAddress *string `locationName:"clientVpcIpAddress" type:"string"` // Information about the version of software currently deployed on the Kafka // brokers in the cluster. CurrentBrokerSoftwareInfo *BrokerSoftwareInfo `locationName:"currentBrokerSoftwareInfo" type:"structure"` // Endpoints for accessing the broker. Endpoints []*string `locationName:"endpoints" type:"list"` // contains filtered or unexported fields }
BrokerNodeInfo
func (BrokerNodeInfo) GoString ¶
func (s BrokerNodeInfo) GoString() string
GoString returns the string representation
func (*BrokerNodeInfo) SetAttachedENIId ¶
func (s *BrokerNodeInfo) SetAttachedENIId(v string) *BrokerNodeInfo
SetAttachedENIId sets the AttachedENIId field's value.
func (*BrokerNodeInfo) SetBrokerId ¶
func (s *BrokerNodeInfo) SetBrokerId(v float64) *BrokerNodeInfo
SetBrokerId sets the BrokerId field's value.
func (*BrokerNodeInfo) SetClientSubnet ¶
func (s *BrokerNodeInfo) SetClientSubnet(v string) *BrokerNodeInfo
SetClientSubnet sets the ClientSubnet field's value.
func (*BrokerNodeInfo) SetClientVpcIpAddress ¶
func (s *BrokerNodeInfo) SetClientVpcIpAddress(v string) *BrokerNodeInfo
SetClientVpcIpAddress sets the ClientVpcIpAddress field's value.
func (*BrokerNodeInfo) SetCurrentBrokerSoftwareInfo ¶
func (s *BrokerNodeInfo) SetCurrentBrokerSoftwareInfo(v *BrokerSoftwareInfo) *BrokerNodeInfo
SetCurrentBrokerSoftwareInfo sets the CurrentBrokerSoftwareInfo field's value.
func (*BrokerNodeInfo) SetEndpoints ¶
func (s *BrokerNodeInfo) SetEndpoints(v []*string) *BrokerNodeInfo
SetEndpoints sets the Endpoints field's value.
func (BrokerNodeInfo) String ¶
func (s BrokerNodeInfo) String() string
String returns the string representation
type BrokerSoftwareInfo ¶
type BrokerSoftwareInfo struct { // The Amazon Resource Name (ARN) of the configuration used for the cluster. // This field isn't visible in this preview release. ConfigurationArn *string `locationName:"configurationArn" type:"string"` // The revision of the configuration to use. This field isn't visible in this // preview release. ConfigurationRevision *int64 `locationName:"configurationRevision" type:"long"` // The version of Apache Kafka. KafkaVersion *string `locationName:"kafkaVersion" type:"string"` // contains filtered or unexported fields }
Information about the current software installed on the cluster.
func (BrokerSoftwareInfo) GoString ¶
func (s BrokerSoftwareInfo) GoString() string
GoString returns the string representation
func (*BrokerSoftwareInfo) SetConfigurationArn ¶
func (s *BrokerSoftwareInfo) SetConfigurationArn(v string) *BrokerSoftwareInfo
SetConfigurationArn sets the ConfigurationArn field's value.
func (*BrokerSoftwareInfo) SetConfigurationRevision ¶
func (s *BrokerSoftwareInfo) SetConfigurationRevision(v int64) *BrokerSoftwareInfo
SetConfigurationRevision sets the ConfigurationRevision field's value.
func (*BrokerSoftwareInfo) SetKafkaVersion ¶
func (s *BrokerSoftwareInfo) SetKafkaVersion(v string) *BrokerSoftwareInfo
SetKafkaVersion sets the KafkaVersion field's value.
func (BrokerSoftwareInfo) String ¶
func (s BrokerSoftwareInfo) String() string
String returns the string representation
type ClientAuthentication ¶
type ClientAuthentication struct { // Details for ClientAuthentication using TLS. Tls *Tls `locationName:"tls" type:"structure"` // contains filtered or unexported fields }
Includes all client authentication information.
func (ClientAuthentication) GoString ¶
func (s ClientAuthentication) GoString() string
GoString returns the string representation
func (*ClientAuthentication) SetTls ¶
func (s *ClientAuthentication) SetTls(v *Tls) *ClientAuthentication
SetTls sets the Tls field's value.
func (ClientAuthentication) String ¶
func (s ClientAuthentication) String() string
String returns the string representation
type ClusterInfo ¶
type ClusterInfo struct { // Arn of active cluster operation. ActiveOperationArn *string `locationName:"activeOperationArn" type:"string"` // Information about the broker nodes. BrokerNodeGroupInfo *BrokerNodeGroupInfo `locationName:"brokerNodeGroupInfo" type:"structure"` // Includes all client authentication information. ClientAuthentication *ClientAuthentication `locationName:"clientAuthentication" type:"structure"` // The Amazon Resource Name (ARN) that uniquely identifies the cluster. ClusterArn *string `locationName:"clusterArn" type:"string"` // The name of the cluster. ClusterName *string `locationName:"clusterName" type:"string"` // The time when the cluster was created. CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"iso8601"` // Information about the version of software currently deployed on the Kafka // brokers in the cluster. CurrentBrokerSoftwareInfo *BrokerSoftwareInfo `locationName:"currentBrokerSoftwareInfo" type:"structure"` // The current version of the MSK cluster. CurrentVersion *string `locationName:"currentVersion" type:"string"` // Includes all encryption-related information. EncryptionInfo *EncryptionInfo `locationName:"encryptionInfo" type:"structure"` // Specifies which metrics are gathered for the MSK cluster. This property has // three possible values: DEFAULT, PER_BROKER, and PER_TOPIC_PER_BROKER. For // a list of the metrics associated with each of these three levels of monitoring, // see Monitoring (https://docs.aws.amazon.com/msk/latest/developerguide/monitoring.html). EnhancedMonitoring *string `locationName:"enhancedMonitoring" type:"string" enum:"EnhancedMonitoring"` // The number of broker nodes in the cluster. NumberOfBrokerNodes *int64 `locationName:"numberOfBrokerNodes" type:"integer"` // The state of the cluster. The possible states are CREATING, ACTIVE, and FAILED. State *string `locationName:"state" type:"string" enum:"ClusterState"` // Tags attached to the cluster. Tags map[string]*string `locationName:"tags" type:"map"` // The connection string to use to connect to the Apache ZooKeeper cluster. ZookeeperConnectString *string `locationName:"zookeeperConnectString" type:"string"` // contains filtered or unexported fields }
Returns information about a cluster.
func (ClusterInfo) GoString ¶
func (s ClusterInfo) GoString() string
GoString returns the string representation
func (*ClusterInfo) SetActiveOperationArn ¶
func (s *ClusterInfo) SetActiveOperationArn(v string) *ClusterInfo
SetActiveOperationArn sets the ActiveOperationArn field's value.
func (*ClusterInfo) SetBrokerNodeGroupInfo ¶
func (s *ClusterInfo) SetBrokerNodeGroupInfo(v *BrokerNodeGroupInfo) *ClusterInfo
SetBrokerNodeGroupInfo sets the BrokerNodeGroupInfo field's value.
func (*ClusterInfo) SetClientAuthentication ¶
func (s *ClusterInfo) SetClientAuthentication(v *ClientAuthentication) *ClusterInfo
SetClientAuthentication sets the ClientAuthentication field's value.
func (*ClusterInfo) SetClusterArn ¶
func (s *ClusterInfo) SetClusterArn(v string) *ClusterInfo
SetClusterArn sets the ClusterArn field's value.
func (*ClusterInfo) SetClusterName ¶
func (s *ClusterInfo) SetClusterName(v string) *ClusterInfo
SetClusterName sets the ClusterName field's value.
func (*ClusterInfo) SetCreationTime ¶
func (s *ClusterInfo) SetCreationTime(v time.Time) *ClusterInfo
SetCreationTime sets the CreationTime field's value.
func (*ClusterInfo) SetCurrentBrokerSoftwareInfo ¶
func (s *ClusterInfo) SetCurrentBrokerSoftwareInfo(v *BrokerSoftwareInfo) *ClusterInfo
SetCurrentBrokerSoftwareInfo sets the CurrentBrokerSoftwareInfo field's value.
func (*ClusterInfo) SetCurrentVersion ¶
func (s *ClusterInfo) SetCurrentVersion(v string) *ClusterInfo
SetCurrentVersion sets the CurrentVersion field's value.
func (*ClusterInfo) SetEncryptionInfo ¶
func (s *ClusterInfo) SetEncryptionInfo(v *EncryptionInfo) *ClusterInfo
SetEncryptionInfo sets the EncryptionInfo field's value.
func (*ClusterInfo) SetEnhancedMonitoring ¶
func (s *ClusterInfo) SetEnhancedMonitoring(v string) *ClusterInfo
SetEnhancedMonitoring sets the EnhancedMonitoring field's value.
func (*ClusterInfo) SetNumberOfBrokerNodes ¶
func (s *ClusterInfo) SetNumberOfBrokerNodes(v int64) *ClusterInfo
SetNumberOfBrokerNodes sets the NumberOfBrokerNodes field's value.
func (*ClusterInfo) SetState ¶
func (s *ClusterInfo) SetState(v string) *ClusterInfo
SetState sets the State field's value.
func (*ClusterInfo) SetTags ¶
func (s *ClusterInfo) SetTags(v map[string]*string) *ClusterInfo
SetTags sets the Tags field's value.
func (*ClusterInfo) SetZookeeperConnectString ¶
func (s *ClusterInfo) SetZookeeperConnectString(v string) *ClusterInfo
SetZookeeperConnectString sets the ZookeeperConnectString field's value.
func (ClusterInfo) String ¶
func (s ClusterInfo) String() string
String returns the string representation
type ClusterOperationInfo ¶
type ClusterOperationInfo struct { // The ID of the API request that triggered this operation. ClientRequestId *string `locationName:"clientRequestId" type:"string"` // ARN of the cluster. ClusterArn *string `locationName:"clusterArn" type:"string"` // The time at which operation was created. CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"iso8601"` // The time at which the operation finished. EndTime *time.Time `locationName:"endTime" type:"timestamp" timestampFormat:"iso8601"` // Describes the error if the operation fails. ErrorInfo *ErrorInfo `locationName:"errorInfo" type:"structure"` // ARN of the cluster operation. OperationArn *string `locationName:"operationArn" type:"string"` // State of the cluster operation. OperationState *string `locationName:"operationState" type:"string"` // Type of the cluster operation. OperationType *string `locationName:"operationType" type:"string"` // Information about cluster attributes before a cluster is updated. SourceClusterInfo *MutableClusterInfo `locationName:"sourceClusterInfo" type:"structure"` // Information about cluster attributes after a cluster is updated. TargetClusterInfo *MutableClusterInfo `locationName:"targetClusterInfo" type:"structure"` // contains filtered or unexported fields }
Returns information about a cluster operation.
func (ClusterOperationInfo) GoString ¶
func (s ClusterOperationInfo) GoString() string
GoString returns the string representation
func (*ClusterOperationInfo) SetClientRequestId ¶
func (s *ClusterOperationInfo) SetClientRequestId(v string) *ClusterOperationInfo
SetClientRequestId sets the ClientRequestId field's value.
func (*ClusterOperationInfo) SetClusterArn ¶
func (s *ClusterOperationInfo) SetClusterArn(v string) *ClusterOperationInfo
SetClusterArn sets the ClusterArn field's value.
func (*ClusterOperationInfo) SetCreationTime ¶
func (s *ClusterOperationInfo) SetCreationTime(v time.Time) *ClusterOperationInfo
SetCreationTime sets the CreationTime field's value.
func (*ClusterOperationInfo) SetEndTime ¶
func (s *ClusterOperationInfo) SetEndTime(v time.Time) *ClusterOperationInfo
SetEndTime sets the EndTime field's value.
func (*ClusterOperationInfo) SetErrorInfo ¶
func (s *ClusterOperationInfo) SetErrorInfo(v *ErrorInfo) *ClusterOperationInfo
SetErrorInfo sets the ErrorInfo field's value.
func (*ClusterOperationInfo) SetOperationArn ¶
func (s *ClusterOperationInfo) SetOperationArn(v string) *ClusterOperationInfo
SetOperationArn sets the OperationArn field's value.
func (*ClusterOperationInfo) SetOperationState ¶
func (s *ClusterOperationInfo) SetOperationState(v string) *ClusterOperationInfo
SetOperationState sets the OperationState field's value.
func (*ClusterOperationInfo) SetOperationType ¶
func (s *ClusterOperationInfo) SetOperationType(v string) *ClusterOperationInfo
SetOperationType sets the OperationType field's value.
func (*ClusterOperationInfo) SetSourceClusterInfo ¶
func (s *ClusterOperationInfo) SetSourceClusterInfo(v *MutableClusterInfo) *ClusterOperationInfo
SetSourceClusterInfo sets the SourceClusterInfo field's value.
func (*ClusterOperationInfo) SetTargetClusterInfo ¶
func (s *ClusterOperationInfo) SetTargetClusterInfo(v *MutableClusterInfo) *ClusterOperationInfo
SetTargetClusterInfo sets the TargetClusterInfo field's value.
func (ClusterOperationInfo) String ¶
func (s ClusterOperationInfo) String() string
String returns the string representation
type Configuration ¶
type Configuration struct { // The Amazon Resource Name (ARN) of the configuration. // // Arn is a required field Arn *string `locationName:"arn" type:"string" required:"true"` // CreationTime is a required field CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"iso8601" required:"true"` // The description of the configuration. // // Description is a required field Description *string `locationName:"description" type:"string" required:"true"` // An array of the versions of Apache Kafka with which you can use this MSK // configuration. You can use this configuration for an MSK cluster only if // the Apache Kafka version specified for the cluster appears in this array. // // KafkaVersions is a required field KafkaVersions []*string `locationName:"kafkaVersions" type:"list" required:"true"` // Latest revision of the configuration. // // LatestRevision is a required field LatestRevision *ConfigurationRevision `locationName:"latestRevision" type:"structure" required:"true"` // The name of the configuration. // // Name is a required field Name *string `locationName:"name" type:"string" required:"true"` // contains filtered or unexported fields }
Represents an MSK Configuration.
func (Configuration) GoString ¶
func (s Configuration) GoString() string
GoString returns the string representation
func (*Configuration) SetArn ¶
func (s *Configuration) SetArn(v string) *Configuration
SetArn sets the Arn field's value.
func (*Configuration) SetCreationTime ¶
func (s *Configuration) SetCreationTime(v time.Time) *Configuration
SetCreationTime sets the CreationTime field's value.
func (*Configuration) SetDescription ¶
func (s *Configuration) SetDescription(v string) *Configuration
SetDescription sets the Description field's value.
func (*Configuration) SetKafkaVersions ¶
func (s *Configuration) SetKafkaVersions(v []*string) *Configuration
SetKafkaVersions sets the KafkaVersions field's value.
func (*Configuration) SetLatestRevision ¶
func (s *Configuration) SetLatestRevision(v *ConfigurationRevision) *Configuration
SetLatestRevision sets the LatestRevision field's value.
func (*Configuration) SetName ¶
func (s *Configuration) SetName(v string) *Configuration
SetName sets the Name field's value.
func (Configuration) String ¶
func (s Configuration) String() string
String returns the string representation
type ConfigurationInfo ¶
type ConfigurationInfo struct { // ARN of the configuration to use. // // Arn is a required field Arn *string `locationName:"arn" type:"string" required:"true"` // The revision of the configuration to use. // // Revision is a required field Revision *int64 `locationName:"revision" type:"long" required:"true"` // contains filtered or unexported fields }
Specifies the configuration to use for the brokers.
func (ConfigurationInfo) GoString ¶
func (s ConfigurationInfo) GoString() string
GoString returns the string representation
func (*ConfigurationInfo) SetArn ¶
func (s *ConfigurationInfo) SetArn(v string) *ConfigurationInfo
SetArn sets the Arn field's value.
func (*ConfigurationInfo) SetRevision ¶
func (s *ConfigurationInfo) SetRevision(v int64) *ConfigurationInfo
SetRevision sets the Revision field's value.
func (ConfigurationInfo) String ¶
func (s ConfigurationInfo) String() string
String returns the string representation
func (*ConfigurationInfo) Validate ¶
func (s *ConfigurationInfo) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ConfigurationRevision ¶
type ConfigurationRevision struct { // The time when the configuration revision was created. // // CreationTime is a required field CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"iso8601" required:"true"` // The description of the configuration revision. Description *string `locationName:"description" type:"string"` // The revision number. // // Revision is a required field Revision *int64 `locationName:"revision" type:"long" required:"true"` // contains filtered or unexported fields }
Describes a configuration revision.
func (ConfigurationRevision) GoString ¶
func (s ConfigurationRevision) GoString() string
GoString returns the string representation
func (*ConfigurationRevision) SetCreationTime ¶
func (s *ConfigurationRevision) SetCreationTime(v time.Time) *ConfigurationRevision
SetCreationTime sets the CreationTime field's value.
func (*ConfigurationRevision) SetDescription ¶
func (s *ConfigurationRevision) SetDescription(v string) *ConfigurationRevision
SetDescription sets the Description field's value.
func (*ConfigurationRevision) SetRevision ¶
func (s *ConfigurationRevision) SetRevision(v int64) *ConfigurationRevision
SetRevision sets the Revision field's value.
func (ConfigurationRevision) String ¶
func (s ConfigurationRevision) String() string
String returns the string representation
type CreateClusterInput ¶
type CreateClusterInput struct { // Information about the broker nodes in the cluster. // // BrokerNodeGroupInfo is a required field BrokerNodeGroupInfo *BrokerNodeGroupInfo `locationName:"brokerNodeGroupInfo" type:"structure" required:"true"` // Includes all client authentication related information. ClientAuthentication *ClientAuthentication `locationName:"clientAuthentication" type:"structure"` // The name of the cluster. // // ClusterName is a required field ClusterName *string `locationName:"clusterName" min:"1" type:"string" required:"true"` // Represents the configuration that you want MSK to use for the brokers in // a cluster. ConfigurationInfo *ConfigurationInfo `locationName:"configurationInfo" type:"structure"` // Includes all encryption-related information. EncryptionInfo *EncryptionInfo `locationName:"encryptionInfo" type:"structure"` // Specifies the level of monitoring for the MSK cluster. The possible values // are DEFAULT, PER_BROKER, and PER_TOPIC_PER_BROKER. EnhancedMonitoring *string `locationName:"enhancedMonitoring" type:"string" enum:"EnhancedMonitoring"` // The version of Apache Kafka. // // KafkaVersion is a required field KafkaVersion *string `locationName:"kafkaVersion" min:"1" type:"string" required:"true"` // The number of Kafka broker nodes in the Amazon MSK cluster. // // NumberOfBrokerNodes is a required field NumberOfBrokerNodes *int64 `locationName:"numberOfBrokerNodes" min:"1" type:"integer" required:"true"` // Create tags when creating the cluster. Tags map[string]*string `locationName:"tags" type:"map"` // contains filtered or unexported fields }
Creates a cluster.
func (CreateClusterInput) GoString ¶
func (s CreateClusterInput) GoString() string
GoString returns the string representation
func (*CreateClusterInput) SetBrokerNodeGroupInfo ¶
func (s *CreateClusterInput) SetBrokerNodeGroupInfo(v *BrokerNodeGroupInfo) *CreateClusterInput
SetBrokerNodeGroupInfo sets the BrokerNodeGroupInfo field's value.
func (*CreateClusterInput) SetClientAuthentication ¶
func (s *CreateClusterInput) SetClientAuthentication(v *ClientAuthentication) *CreateClusterInput
SetClientAuthentication sets the ClientAuthentication field's value.
func (*CreateClusterInput) SetClusterName ¶
func (s *CreateClusterInput) SetClusterName(v string) *CreateClusterInput
SetClusterName sets the ClusterName field's value.
func (*CreateClusterInput) SetConfigurationInfo ¶
func (s *CreateClusterInput) SetConfigurationInfo(v *ConfigurationInfo) *CreateClusterInput
SetConfigurationInfo sets the ConfigurationInfo field's value.
func (*CreateClusterInput) SetEncryptionInfo ¶
func (s *CreateClusterInput) SetEncryptionInfo(v *EncryptionInfo) *CreateClusterInput
SetEncryptionInfo sets the EncryptionInfo field's value.
func (*CreateClusterInput) SetEnhancedMonitoring ¶
func (s *CreateClusterInput) SetEnhancedMonitoring(v string) *CreateClusterInput
SetEnhancedMonitoring sets the EnhancedMonitoring field's value.
func (*CreateClusterInput) SetKafkaVersion ¶
func (s *CreateClusterInput) SetKafkaVersion(v string) *CreateClusterInput
SetKafkaVersion sets the KafkaVersion field's value.
func (*CreateClusterInput) SetNumberOfBrokerNodes ¶
func (s *CreateClusterInput) SetNumberOfBrokerNodes(v int64) *CreateClusterInput
SetNumberOfBrokerNodes sets the NumberOfBrokerNodes field's value.
func (*CreateClusterInput) SetTags ¶
func (s *CreateClusterInput) SetTags(v map[string]*string) *CreateClusterInput
SetTags sets the Tags field's value.
func (CreateClusterInput) String ¶
func (s CreateClusterInput) String() string
String returns the string representation
func (*CreateClusterInput) Validate ¶
func (s *CreateClusterInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type CreateClusterOutput ¶
type CreateClusterOutput struct { // The Amazon Resource Name (ARN) of the cluster. ClusterArn *string `locationName:"clusterArn" type:"string"` // The name of the MSK cluster. ClusterName *string `locationName:"clusterName" type:"string"` // The state of the cluster. The possible states are CREATING, ACTIVE, and FAILED. State *string `locationName:"state" type:"string" enum:"ClusterState"` // contains filtered or unexported fields }
Returns information about the created cluster.
func (CreateClusterOutput) GoString ¶
func (s CreateClusterOutput) GoString() string
GoString returns the string representation
func (*CreateClusterOutput) SetClusterArn ¶
func (s *CreateClusterOutput) SetClusterArn(v string) *CreateClusterOutput
SetClusterArn sets the ClusterArn field's value.
func (*CreateClusterOutput) SetClusterName ¶
func (s *CreateClusterOutput) SetClusterName(v string) *CreateClusterOutput
SetClusterName sets the ClusterName field's value.
func (*CreateClusterOutput) SetState ¶
func (s *CreateClusterOutput) SetState(v string) *CreateClusterOutput
SetState sets the State field's value.
func (CreateClusterOutput) String ¶
func (s CreateClusterOutput) String() string
String returns the string representation
type CreateConfigurationInput ¶
type CreateConfigurationInput struct { // The description of the configuration. Description *string `locationName:"description" type:"string"` // The versions of Apache Kafka with which you can use this MSK configuration. // // KafkaVersions is a required field KafkaVersions []*string `locationName:"kafkaVersions" type:"list" required:"true"` // The name of the configuration. // // Name is a required field Name *string `locationName:"name" type:"string" required:"true"` // ServerProperties is automatically base64 encoded/decoded by the SDK. // // ServerProperties is a required field ServerProperties []byte `locationName:"serverProperties" type:"blob" required:"true"` // contains filtered or unexported fields }
Request body for CreateConfiguration.
func (CreateConfigurationInput) GoString ¶
func (s CreateConfigurationInput) GoString() string
GoString returns the string representation
func (*CreateConfigurationInput) SetDescription ¶
func (s *CreateConfigurationInput) SetDescription(v string) *CreateConfigurationInput
SetDescription sets the Description field's value.
func (*CreateConfigurationInput) SetKafkaVersions ¶
func (s *CreateConfigurationInput) SetKafkaVersions(v []*string) *CreateConfigurationInput
SetKafkaVersions sets the KafkaVersions field's value.
func (*CreateConfigurationInput) SetName ¶
func (s *CreateConfigurationInput) SetName(v string) *CreateConfigurationInput
SetName sets the Name field's value.
func (*CreateConfigurationInput) SetServerProperties ¶
func (s *CreateConfigurationInput) SetServerProperties(v []byte) *CreateConfigurationInput
SetServerProperties sets the ServerProperties field's value.
func (CreateConfigurationInput) String ¶
func (s CreateConfigurationInput) String() string
String returns the string representation
func (*CreateConfigurationInput) Validate ¶
func (s *CreateConfigurationInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type CreateConfigurationOutput ¶
type CreateConfigurationOutput struct { // The Amazon Resource Name (ARN) of the configuration. Arn *string `locationName:"arn" type:"string"` // The time when the configuration was created. CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"iso8601"` // Latest revision of the configuration. LatestRevision *ConfigurationRevision `locationName:"latestRevision" type:"structure"` // The name of the configuration. Name *string `locationName:"name" type:"string"` // contains filtered or unexported fields }
Response body for CreateConfiguration
func (CreateConfigurationOutput) GoString ¶
func (s CreateConfigurationOutput) GoString() string
GoString returns the string representation
func (*CreateConfigurationOutput) SetArn ¶
func (s *CreateConfigurationOutput) SetArn(v string) *CreateConfigurationOutput
SetArn sets the Arn field's value.
func (*CreateConfigurationOutput) SetCreationTime ¶
func (s *CreateConfigurationOutput) SetCreationTime(v time.Time) *CreateConfigurationOutput
SetCreationTime sets the CreationTime field's value.
func (*CreateConfigurationOutput) SetLatestRevision ¶
func (s *CreateConfigurationOutput) SetLatestRevision(v *ConfigurationRevision) *CreateConfigurationOutput
SetLatestRevision sets the LatestRevision field's value.
func (*CreateConfigurationOutput) SetName ¶
func (s *CreateConfigurationOutput) SetName(v string) *CreateConfigurationOutput
SetName sets the Name field's value.
func (CreateConfigurationOutput) String ¶
func (s CreateConfigurationOutput) String() string
String returns the string representation
type DeleteClusterInput ¶
type DeleteClusterInput struct { // ClusterArn is a required field ClusterArn *string `location:"uri" locationName:"clusterArn" type:"string" required:"true"` CurrentVersion *string `location:"querystring" locationName:"currentVersion" type:"string"` // contains filtered or unexported fields }
func (DeleteClusterInput) GoString ¶
func (s DeleteClusterInput) GoString() string
GoString returns the string representation
func (*DeleteClusterInput) SetClusterArn ¶
func (s *DeleteClusterInput) SetClusterArn(v string) *DeleteClusterInput
SetClusterArn sets the ClusterArn field's value.
func (*DeleteClusterInput) SetCurrentVersion ¶
func (s *DeleteClusterInput) SetCurrentVersion(v string) *DeleteClusterInput
SetCurrentVersion sets the CurrentVersion field's value.
func (DeleteClusterInput) String ¶
func (s DeleteClusterInput) String() string
String returns the string representation
func (*DeleteClusterInput) Validate ¶
func (s *DeleteClusterInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DeleteClusterOutput ¶
type DeleteClusterOutput struct { // The Amazon Resource Name (ARN) of the cluster. ClusterArn *string `locationName:"clusterArn" type:"string"` // The state of the cluster. The possible states are CREATING, ACTIVE, and FAILED. State *string `locationName:"state" type:"string" enum:"ClusterState"` // contains filtered or unexported fields }
Returns information about the deleted cluster.
func (DeleteClusterOutput) GoString ¶
func (s DeleteClusterOutput) GoString() string
GoString returns the string representation
func (*DeleteClusterOutput) SetClusterArn ¶
func (s *DeleteClusterOutput) SetClusterArn(v string) *DeleteClusterOutput
SetClusterArn sets the ClusterArn field's value.
func (*DeleteClusterOutput) SetState ¶
func (s *DeleteClusterOutput) SetState(v string) *DeleteClusterOutput
SetState sets the State field's value.
func (DeleteClusterOutput) String ¶
func (s DeleteClusterOutput) String() string
String returns the string representation
type DescribeClusterInput ¶
type DescribeClusterInput struct { // ClusterArn is a required field ClusterArn *string `location:"uri" locationName:"clusterArn" type:"string" required:"true"` // contains filtered or unexported fields }
func (DescribeClusterInput) GoString ¶
func (s DescribeClusterInput) GoString() string
GoString returns the string representation
func (*DescribeClusterInput) SetClusterArn ¶
func (s *DescribeClusterInput) SetClusterArn(v string) *DescribeClusterInput
SetClusterArn sets the ClusterArn field's value.
func (DescribeClusterInput) String ¶
func (s DescribeClusterInput) String() string
String returns the string representation
func (*DescribeClusterInput) Validate ¶
func (s *DescribeClusterInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DescribeClusterOperationInput ¶
type DescribeClusterOperationInput struct { // ClusterOperationArn is a required field ClusterOperationArn *string `location:"uri" locationName:"clusterOperationArn" type:"string" required:"true"` // contains filtered or unexported fields }
func (DescribeClusterOperationInput) GoString ¶
func (s DescribeClusterOperationInput) GoString() string
GoString returns the string representation
func (*DescribeClusterOperationInput) SetClusterOperationArn ¶
func (s *DescribeClusterOperationInput) SetClusterOperationArn(v string) *DescribeClusterOperationInput
SetClusterOperationArn sets the ClusterOperationArn field's value.
func (DescribeClusterOperationInput) String ¶
func (s DescribeClusterOperationInput) String() string
String returns the string representation
func (*DescribeClusterOperationInput) Validate ¶
func (s *DescribeClusterOperationInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DescribeClusterOperationOutput ¶
type DescribeClusterOperationOutput struct { // Cluster operation information ClusterOperationInfo *ClusterOperationInfo `locationName:"clusterOperationInfo" type:"structure"` // contains filtered or unexported fields }
Information about a cluster operation.
func (DescribeClusterOperationOutput) GoString ¶
func (s DescribeClusterOperationOutput) GoString() string
GoString returns the string representation
func (*DescribeClusterOperationOutput) SetClusterOperationInfo ¶
func (s *DescribeClusterOperationOutput) SetClusterOperationInfo(v *ClusterOperationInfo) *DescribeClusterOperationOutput
SetClusterOperationInfo sets the ClusterOperationInfo field's value.
func (DescribeClusterOperationOutput) String ¶
func (s DescribeClusterOperationOutput) String() string
String returns the string representation
type DescribeClusterOutput ¶
type DescribeClusterOutput struct { // The cluster information. ClusterInfo *ClusterInfo `locationName:"clusterInfo" type:"structure"` // contains filtered or unexported fields }
Returns information about a cluster.
func (DescribeClusterOutput) GoString ¶
func (s DescribeClusterOutput) GoString() string
GoString returns the string representation
func (*DescribeClusterOutput) SetClusterInfo ¶
func (s *DescribeClusterOutput) SetClusterInfo(v *ClusterInfo) *DescribeClusterOutput
SetClusterInfo sets the ClusterInfo field's value.
func (DescribeClusterOutput) String ¶
func (s DescribeClusterOutput) String() string
String returns the string representation
type DescribeConfigurationInput ¶
type DescribeConfigurationInput struct { // Arn is a required field Arn *string `location:"uri" locationName:"arn" type:"string" required:"true"` // contains filtered or unexported fields }
func (DescribeConfigurationInput) GoString ¶
func (s DescribeConfigurationInput) GoString() string
GoString returns the string representation
func (*DescribeConfigurationInput) SetArn ¶
func (s *DescribeConfigurationInput) SetArn(v string) *DescribeConfigurationInput
SetArn sets the Arn field's value.
func (DescribeConfigurationInput) String ¶
func (s DescribeConfigurationInput) String() string
String returns the string representation
func (*DescribeConfigurationInput) Validate ¶
func (s *DescribeConfigurationInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DescribeConfigurationOutput ¶
type DescribeConfigurationOutput struct { // The Amazon Resource Name (ARN) of the configuration. Arn *string `locationName:"arn" type:"string"` // The time when the configuration was created. CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"iso8601"` // The description of the configuration. Description *string `locationName:"description" type:"string"` // The versions of Apache Kafka with which you can use this MSK configuration. KafkaVersions []*string `locationName:"kafkaVersions" type:"list"` // Latest revision of the configuration. LatestRevision *ConfigurationRevision `locationName:"latestRevision" type:"structure"` // The name of the configuration. Name *string `locationName:"name" type:"string"` // contains filtered or unexported fields }
Response body for DescribeConfiguration.
func (DescribeConfigurationOutput) GoString ¶
func (s DescribeConfigurationOutput) GoString() string
GoString returns the string representation
func (*DescribeConfigurationOutput) SetArn ¶
func (s *DescribeConfigurationOutput) SetArn(v string) *DescribeConfigurationOutput
SetArn sets the Arn field's value.
func (*DescribeConfigurationOutput) SetCreationTime ¶
func (s *DescribeConfigurationOutput) SetCreationTime(v time.Time) *DescribeConfigurationOutput
SetCreationTime sets the CreationTime field's value.
func (*DescribeConfigurationOutput) SetDescription ¶
func (s *DescribeConfigurationOutput) SetDescription(v string) *DescribeConfigurationOutput
SetDescription sets the Description field's value.
func (*DescribeConfigurationOutput) SetKafkaVersions ¶
func (s *DescribeConfigurationOutput) SetKafkaVersions(v []*string) *DescribeConfigurationOutput
SetKafkaVersions sets the KafkaVersions field's value.
func (*DescribeConfigurationOutput) SetLatestRevision ¶
func (s *DescribeConfigurationOutput) SetLatestRevision(v *ConfigurationRevision) *DescribeConfigurationOutput
SetLatestRevision sets the LatestRevision field's value.
func (*DescribeConfigurationOutput) SetName ¶
func (s *DescribeConfigurationOutput) SetName(v string) *DescribeConfigurationOutput
SetName sets the Name field's value.
func (DescribeConfigurationOutput) String ¶
func (s DescribeConfigurationOutput) String() string
String returns the string representation
type DescribeConfigurationRevisionInput ¶
type DescribeConfigurationRevisionInput struct { // Arn is a required field Arn *string `location:"uri" locationName:"arn" type:"string" required:"true"` // Revision is a required field Revision *int64 `location:"uri" locationName:"revision" type:"long" required:"true"` // contains filtered or unexported fields }
func (DescribeConfigurationRevisionInput) GoString ¶
func (s DescribeConfigurationRevisionInput) GoString() string
GoString returns the string representation
func (*DescribeConfigurationRevisionInput) SetArn ¶
func (s *DescribeConfigurationRevisionInput) SetArn(v string) *DescribeConfigurationRevisionInput
SetArn sets the Arn field's value.
func (*DescribeConfigurationRevisionInput) SetRevision ¶
func (s *DescribeConfigurationRevisionInput) SetRevision(v int64) *DescribeConfigurationRevisionInput
SetRevision sets the Revision field's value.
func (DescribeConfigurationRevisionInput) String ¶
func (s DescribeConfigurationRevisionInput) String() string
String returns the string representation
func (*DescribeConfigurationRevisionInput) Validate ¶
func (s *DescribeConfigurationRevisionInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DescribeConfigurationRevisionOutput ¶
type DescribeConfigurationRevisionOutput struct { // The Amazon Resource Name (ARN) of the configuration. Arn *string `locationName:"arn" type:"string"` // The time when the configuration was created. CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"iso8601"` // The description of the configuration. Description *string `locationName:"description" type:"string"` // The revision number. Revision *int64 `locationName:"revision" type:"long"` // ServerProperties is automatically base64 encoded/decoded by the SDK. ServerProperties []byte `locationName:"serverProperties" type:"blob"` // contains filtered or unexported fields }
Response body for DescribeConfigurationRevision.
func (DescribeConfigurationRevisionOutput) GoString ¶
func (s DescribeConfigurationRevisionOutput) GoString() string
GoString returns the string representation
func (*DescribeConfigurationRevisionOutput) SetArn ¶
func (s *DescribeConfigurationRevisionOutput) SetArn(v string) *DescribeConfigurationRevisionOutput
SetArn sets the Arn field's value.
func (*DescribeConfigurationRevisionOutput) SetCreationTime ¶
func (s *DescribeConfigurationRevisionOutput) SetCreationTime(v time.Time) *DescribeConfigurationRevisionOutput
SetCreationTime sets the CreationTime field's value.
func (*DescribeConfigurationRevisionOutput) SetDescription ¶
func (s *DescribeConfigurationRevisionOutput) SetDescription(v string) *DescribeConfigurationRevisionOutput
SetDescription sets the Description field's value.
func (*DescribeConfigurationRevisionOutput) SetRevision ¶
func (s *DescribeConfigurationRevisionOutput) SetRevision(v int64) *DescribeConfigurationRevisionOutput
SetRevision sets the Revision field's value.
func (*DescribeConfigurationRevisionOutput) SetServerProperties ¶
func (s *DescribeConfigurationRevisionOutput) SetServerProperties(v []byte) *DescribeConfigurationRevisionOutput
SetServerProperties sets the ServerProperties field's value.
func (DescribeConfigurationRevisionOutput) String ¶
func (s DescribeConfigurationRevisionOutput) String() string
String returns the string representation
type EBSStorageInfo ¶
type EBSStorageInfo struct { // The size in GiB of the EBS volume for the data drive on each broker node. VolumeSize *int64 `locationName:"volumeSize" min:"1" type:"integer"` // contains filtered or unexported fields }
Contains information about the EBS storage volumes attached to Kafka broker nodes.
func (EBSStorageInfo) GoString ¶
func (s EBSStorageInfo) GoString() string
GoString returns the string representation
func (*EBSStorageInfo) SetVolumeSize ¶
func (s *EBSStorageInfo) SetVolumeSize(v int64) *EBSStorageInfo
SetVolumeSize sets the VolumeSize field's value.
func (EBSStorageInfo) String ¶
func (s EBSStorageInfo) String() string
String returns the string representation
func (*EBSStorageInfo) Validate ¶
func (s *EBSStorageInfo) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type EncryptionAtRest ¶
type EncryptionAtRest struct { // The ARN of the AWS KMS key for encrypting data at rest. If you don't specify // a KMS key, MSK creates one for you and uses it. // // DataVolumeKMSKeyId is a required field DataVolumeKMSKeyId *string `locationName:"dataVolumeKMSKeyId" type:"string" required:"true"` // contains filtered or unexported fields }
The data-volume encryption details.
func (EncryptionAtRest) GoString ¶
func (s EncryptionAtRest) GoString() string
GoString returns the string representation
func (*EncryptionAtRest) SetDataVolumeKMSKeyId ¶
func (s *EncryptionAtRest) SetDataVolumeKMSKeyId(v string) *EncryptionAtRest
SetDataVolumeKMSKeyId sets the DataVolumeKMSKeyId field's value.
func (EncryptionAtRest) String ¶
func (s EncryptionAtRest) String() string
String returns the string representation
func (*EncryptionAtRest) Validate ¶
func (s *EncryptionAtRest) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type EncryptionInTransit ¶
type EncryptionInTransit struct { // Indicates the encryption setting for data in transit between clients and // brokers. The following are the possible values. // // TLS means that client-broker communication is enabled with TLS only. // // TLS_PLAINTEXT means that client-broker communication is enabled for both // TLS-encrypted, as well as plaintext data. // // PLAINTEXT means that client-broker communication is enabled in plaintext // only. // // The default value is TLS_PLAINTEXT. ClientBroker *string `locationName:"clientBroker" type:"string" enum:"ClientBroker"` // When set to true, it indicates that data communication among the broker nodes // of the cluster is encrypted. When set to false, the communication happens // in plaintext. // // The default value is true. InCluster *bool `locationName:"inCluster" type:"boolean"` // contains filtered or unexported fields }
The settings for encrypting data in transit.
func (EncryptionInTransit) GoString ¶
func (s EncryptionInTransit) GoString() string
GoString returns the string representation
func (*EncryptionInTransit) SetClientBroker ¶
func (s *EncryptionInTransit) SetClientBroker(v string) *EncryptionInTransit
SetClientBroker sets the ClientBroker field's value.
func (*EncryptionInTransit) SetInCluster ¶
func (s *EncryptionInTransit) SetInCluster(v bool) *EncryptionInTransit
SetInCluster sets the InCluster field's value.
func (EncryptionInTransit) String ¶
func (s EncryptionInTransit) String() string
String returns the string representation
type EncryptionInfo ¶
type EncryptionInfo struct { // The data-volume encryption details. EncryptionAtRest *EncryptionAtRest `locationName:"encryptionAtRest" type:"structure"` // The details for encryption in transit. EncryptionInTransit *EncryptionInTransit `locationName:"encryptionInTransit" type:"structure"` // contains filtered or unexported fields }
Includes encryption-related information, such as the AWS KMS key used for encrypting data at rest and whether you want MSK to encrypt your data in transit.
func (EncryptionInfo) GoString ¶
func (s EncryptionInfo) GoString() string
GoString returns the string representation
func (*EncryptionInfo) SetEncryptionAtRest ¶
func (s *EncryptionInfo) SetEncryptionAtRest(v *EncryptionAtRest) *EncryptionInfo
SetEncryptionAtRest sets the EncryptionAtRest field's value.
func (*EncryptionInfo) SetEncryptionInTransit ¶
func (s *EncryptionInfo) SetEncryptionInTransit(v *EncryptionInTransit) *EncryptionInfo
SetEncryptionInTransit sets the EncryptionInTransit field's value.
func (EncryptionInfo) String ¶
func (s EncryptionInfo) String() string
String returns the string representation
func (*EncryptionInfo) Validate ¶
func (s *EncryptionInfo) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ErrorInfo ¶
type ErrorInfo struct { // A number describing the error programmatically. ErrorCode *string `locationName:"errorCode" type:"string"` // An optional field to provide more details about the error. ErrorString *string `locationName:"errorString" type:"string"` // contains filtered or unexported fields }
Returns information about an error state of the cluster.
func (*ErrorInfo) SetErrorCode ¶
SetErrorCode sets the ErrorCode field's value.
func (*ErrorInfo) SetErrorString ¶
SetErrorString sets the ErrorString field's value.
type GetBootstrapBrokersInput ¶
type GetBootstrapBrokersInput struct { // ClusterArn is a required field ClusterArn *string `location:"uri" locationName:"clusterArn" type:"string" required:"true"` // contains filtered or unexported fields }
func (GetBootstrapBrokersInput) GoString ¶
func (s GetBootstrapBrokersInput) GoString() string
GoString returns the string representation
func (*GetBootstrapBrokersInput) SetClusterArn ¶
func (s *GetBootstrapBrokersInput) SetClusterArn(v string) *GetBootstrapBrokersInput
SetClusterArn sets the ClusterArn field's value.
func (GetBootstrapBrokersInput) String ¶
func (s GetBootstrapBrokersInput) String() string
String returns the string representation
func (*GetBootstrapBrokersInput) Validate ¶
func (s *GetBootstrapBrokersInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type GetBootstrapBrokersOutput ¶
type GetBootstrapBrokersOutput struct { // A string containing one or more hostname:port pairs. BootstrapBrokerString *string `locationName:"bootstrapBrokerString" type:"string"` // A string containing one or more DNS names (or IP) and TLS port pairs. BootstrapBrokerStringTls *string `locationName:"bootstrapBrokerStringTls" type:"string"` // contains filtered or unexported fields }
Returns a string containing one or more hostname:port pairs.
func (GetBootstrapBrokersOutput) GoString ¶
func (s GetBootstrapBrokersOutput) GoString() string
GoString returns the string representation
func (*GetBootstrapBrokersOutput) SetBootstrapBrokerString ¶
func (s *GetBootstrapBrokersOutput) SetBootstrapBrokerString(v string) *GetBootstrapBrokersOutput
SetBootstrapBrokerString sets the BootstrapBrokerString field's value.
func (*GetBootstrapBrokersOutput) SetBootstrapBrokerStringTls ¶
func (s *GetBootstrapBrokersOutput) SetBootstrapBrokerStringTls(v string) *GetBootstrapBrokersOutput
SetBootstrapBrokerStringTls sets the BootstrapBrokerStringTls field's value.
func (GetBootstrapBrokersOutput) String ¶
func (s GetBootstrapBrokersOutput) String() string
String returns the string representation
type Kafka ¶
Kafka provides the API operation methods for making requests to Managed Streaming for Kafka. See this package's package overview docs for details on the service.
Kafka methods are safe to use concurrently. It is not safe to modify mutate any of the struct's properties though.
func New ¶
func New(p client.ConfigProvider, cfgs ...*aws.Config) *Kafka
New creates a new instance of the Kafka client with a session. If additional configuration is needed for the client instance use the optional aws.Config parameter to add your extra config.
Example:
// Create a Kafka client from just a session. svc := kafka.New(mySession) // Create a Kafka client with additional configuration svc := kafka.New(mySession, aws.NewConfig().WithRegion("us-west-2"))
func (*Kafka) CreateCluster ¶
func (c *Kafka) CreateCluster(input *CreateClusterInput) (*CreateClusterOutput, error)
CreateCluster API operation for Managed Streaming for Kafka.
Creates a new MSK cluster.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka's API operation CreateCluster for usage and error information.
Returned Error Codes:
ErrCodeBadRequestException "BadRequestException" Returns information about an error.
ErrCodeInternalServerErrorException "InternalServerErrorException" Returns information about an error.
ErrCodeUnauthorizedException "UnauthorizedException" Returns information about an error.
ErrCodeForbiddenException "ForbiddenException" Returns information about an error.
ErrCodeServiceUnavailableException "ServiceUnavailableException" Returns information about an error.
ErrCodeTooManyRequestsException "TooManyRequestsException" Returns information about an error.
ErrCodeConflictException "ConflictException" Returns information about an error.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/CreateCluster
func (*Kafka) CreateClusterRequest ¶
func (c *Kafka) CreateClusterRequest(input *CreateClusterInput) (req *request.Request, output *CreateClusterOutput)
CreateClusterRequest generates a "aws/request.Request" representing the client's request for the CreateCluster operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See CreateCluster for more information on using the CreateCluster API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the CreateClusterRequest method. req, resp := client.CreateClusterRequest(params) err := req.Send() if err == nil { // resp is now filled fmt.Println(resp) }
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/CreateCluster
func (*Kafka) CreateClusterWithContext ¶
func (c *Kafka) CreateClusterWithContext(ctx aws.Context, input *CreateClusterInput, opts ...request.Option) (*CreateClusterOutput, error)
CreateClusterWithContext is the same as CreateCluster with the addition of the ability to pass a context and additional request options.
See CreateCluster for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*Kafka) CreateConfiguration ¶
func (c *Kafka) CreateConfiguration(input *CreateConfigurationInput) (*CreateConfigurationOutput, error)
CreateConfiguration API operation for Managed Streaming for Kafka.
Creates a new MSK configuration.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka's API operation CreateConfiguration for usage and error information.
Returned Error Codes:
ErrCodeBadRequestException "BadRequestException" Returns information about an error.
ErrCodeInternalServerErrorException "InternalServerErrorException" Returns information about an error.
ErrCodeUnauthorizedException "UnauthorizedException" Returns information about an error.
ErrCodeForbiddenException "ForbiddenException" Returns information about an error.
ErrCodeServiceUnavailableException "ServiceUnavailableException" Returns information about an error.
ErrCodeTooManyRequestsException "TooManyRequestsException" Returns information about an error.
ErrCodeConflictException "ConflictException" Returns information about an error.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/CreateConfiguration
func (*Kafka) CreateConfigurationRequest ¶
func (c *Kafka) CreateConfigurationRequest(input *CreateConfigurationInput) (req *request.Request, output *CreateConfigurationOutput)
CreateConfigurationRequest generates a "aws/request.Request" representing the client's request for the CreateConfiguration operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See CreateConfiguration for more information on using the CreateConfiguration API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the CreateConfigurationRequest method. req, resp := client.CreateConfigurationRequest(params) err := req.Send() if err == nil { // resp is now filled fmt.Println(resp) }
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/CreateConfiguration
func (*Kafka) CreateConfigurationWithContext ¶
func (c *Kafka) CreateConfigurationWithContext(ctx aws.Context, input *CreateConfigurationInput, opts ...request.Option) (*CreateConfigurationOutput, error)
CreateConfigurationWithContext is the same as CreateConfiguration with the addition of the ability to pass a context and additional request options.
See CreateConfiguration for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*Kafka) DeleteCluster ¶
func (c *Kafka) DeleteCluster(input *DeleteClusterInput) (*DeleteClusterOutput, error)
DeleteCluster API operation for Managed Streaming for Kafka.
Deletes the MSK cluster specified by the Amazon Resource Name (ARN) in the request.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka's API operation DeleteCluster for usage and error information.
Returned Error Codes:
ErrCodeNotFoundException "NotFoundException" Returns information about an error.
ErrCodeBadRequestException "BadRequestException" Returns information about an error.
ErrCodeInternalServerErrorException "InternalServerErrorException" Returns information about an error.
ErrCodeForbiddenException "ForbiddenException" Returns information about an error.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DeleteCluster
func (*Kafka) DeleteClusterRequest ¶
func (c *Kafka) DeleteClusterRequest(input *DeleteClusterInput) (req *request.Request, output *DeleteClusterOutput)
DeleteClusterRequest generates a "aws/request.Request" representing the client's request for the DeleteCluster operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See DeleteCluster for more information on using the DeleteCluster API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the DeleteClusterRequest method. req, resp := client.DeleteClusterRequest(params) err := req.Send() if err == nil { // resp is now filled fmt.Println(resp) }
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DeleteCluster
func (*Kafka) DeleteClusterWithContext ¶
func (c *Kafka) DeleteClusterWithContext(ctx aws.Context, input *DeleteClusterInput, opts ...request.Option) (*DeleteClusterOutput, error)
DeleteClusterWithContext is the same as DeleteCluster with the addition of the ability to pass a context and additional request options.
See DeleteCluster for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*Kafka) DescribeCluster ¶
func (c *Kafka) DescribeCluster(input *DescribeClusterInput) (*DescribeClusterOutput, error)
DescribeCluster API operation for Managed Streaming for Kafka.
Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka's API operation DescribeCluster for usage and error information.
Returned Error Codes:
ErrCodeNotFoundException "NotFoundException" Returns information about an error.
ErrCodeBadRequestException "BadRequestException" Returns information about an error.
ErrCodeUnauthorizedException "UnauthorizedException" Returns information about an error.
ErrCodeInternalServerErrorException "InternalServerErrorException" Returns information about an error.
ErrCodeForbiddenException "ForbiddenException" Returns information about an error.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeCluster
func (*Kafka) DescribeClusterOperation ¶
func (c *Kafka) DescribeClusterOperation(input *DescribeClusterOperationInput) (*DescribeClusterOperationOutput, error)
DescribeClusterOperation API operation for Managed Streaming for Kafka.
Returns a description of the cluster operation specified by the ARN.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka's API operation DescribeClusterOperation for usage and error information.
Returned Error Codes:
ErrCodeNotFoundException "NotFoundException" Returns information about an error.
ErrCodeBadRequestException "BadRequestException" Returns information about an error.
ErrCodeUnauthorizedException "UnauthorizedException" Returns information about an error.
ErrCodeInternalServerErrorException "InternalServerErrorException" Returns information about an error.
ErrCodeForbiddenException "ForbiddenException" Returns information about an error.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeClusterOperation
func (*Kafka) DescribeClusterOperationRequest ¶
func (c *Kafka) DescribeClusterOperationRequest(input *DescribeClusterOperationInput) (req *request.Request, output *DescribeClusterOperationOutput)
DescribeClusterOperationRequest generates a "aws/request.Request" representing the client's request for the DescribeClusterOperation operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See DescribeClusterOperation for more information on using the DescribeClusterOperation API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the DescribeClusterOperationRequest method. req, resp := client.DescribeClusterOperationRequest(params) err := req.Send() if err == nil { // resp is now filled fmt.Println(resp) }
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeClusterOperation
func (*Kafka) DescribeClusterOperationWithContext ¶
func (c *Kafka) DescribeClusterOperationWithContext(ctx aws.Context, input *DescribeClusterOperationInput, opts ...request.Option) (*DescribeClusterOperationOutput, error)
DescribeClusterOperationWithContext is the same as DescribeClusterOperation with the addition of the ability to pass a context and additional request options.
See DescribeClusterOperation for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*Kafka) DescribeClusterRequest ¶
func (c *Kafka) DescribeClusterRequest(input *DescribeClusterInput) (req *request.Request, output *DescribeClusterOutput)
DescribeClusterRequest generates a "aws/request.Request" representing the client's request for the DescribeCluster operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See DescribeCluster for more information on using the DescribeCluster API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the DescribeClusterRequest method. req, resp := client.DescribeClusterRequest(params) err := req.Send() if err == nil { // resp is now filled fmt.Println(resp) }
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeCluster
func (*Kafka) DescribeClusterWithContext ¶
func (c *Kafka) DescribeClusterWithContext(ctx aws.Context, input *DescribeClusterInput, opts ...request.Option) (*DescribeClusterOutput, error)
DescribeClusterWithContext is the same as DescribeCluster with the addition of the ability to pass a context and additional request options.
See DescribeCluster for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*Kafka) DescribeConfiguration ¶
func (c *Kafka) DescribeConfiguration(input *DescribeConfigurationInput) (*DescribeConfigurationOutput, error)
DescribeConfiguration API operation for Managed Streaming for Kafka.
Returns a description of this MSK configuration.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka's API operation DescribeConfiguration for usage and error information.
Returned Error Codes:
ErrCodeBadRequestException "BadRequestException" Returns information about an error.
ErrCodeUnauthorizedException "UnauthorizedException" Returns information about an error.
ErrCodeInternalServerErrorException "InternalServerErrorException" Returns information about an error.
ErrCodeForbiddenException "ForbiddenException" Returns information about an error.
ErrCodeNotFoundException "NotFoundException" Returns information about an error.
ErrCodeServiceUnavailableException "ServiceUnavailableException" Returns information about an error.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeConfiguration
func (*Kafka) DescribeConfigurationRequest ¶
func (c *Kafka) DescribeConfigurationRequest(input *DescribeConfigurationInput) (req *request.Request, output *DescribeConfigurationOutput)
DescribeConfigurationRequest generates a "aws/request.Request" representing the client's request for the DescribeConfiguration operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See DescribeConfiguration for more information on using the DescribeConfiguration API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the DescribeConfigurationRequest method. req, resp := client.DescribeConfigurationRequest(params) err := req.Send() if err == nil { // resp is now filled fmt.Println(resp) }
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeConfiguration
func (*Kafka) DescribeConfigurationRevision ¶
func (c *Kafka) DescribeConfigurationRevision(input *DescribeConfigurationRevisionInput) (*DescribeConfigurationRevisionOutput, error)
DescribeConfigurationRevision API operation for Managed Streaming for Kafka.
Returns a description of this revision of the configuration.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka's API operation DescribeConfigurationRevision for usage and error information.
Returned Error Codes:
ErrCodeBadRequestException "BadRequestException" Returns information about an error.
ErrCodeUnauthorizedException "UnauthorizedException" Returns information about an error.
ErrCodeInternalServerErrorException "InternalServerErrorException" Returns information about an error.
ErrCodeForbiddenException "ForbiddenException" Returns information about an error.
ErrCodeNotFoundException "NotFoundException" Returns information about an error.
ErrCodeServiceUnavailableException "ServiceUnavailableException" Returns information about an error.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeConfigurationRevision
func (*Kafka) DescribeConfigurationRevisionRequest ¶
func (c *Kafka) DescribeConfigurationRevisionRequest(input *DescribeConfigurationRevisionInput) (req *request.Request, output *DescribeConfigurationRevisionOutput)
DescribeConfigurationRevisionRequest generates a "aws/request.Request" representing the client's request for the DescribeConfigurationRevision operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See DescribeConfigurationRevision for more information on using the DescribeConfigurationRevision API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the DescribeConfigurationRevisionRequest method. req, resp := client.DescribeConfigurationRevisionRequest(params) err := req.Send() if err == nil { // resp is now filled fmt.Println(resp) }
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeConfigurationRevision
func (*Kafka) DescribeConfigurationRevisionWithContext ¶
func (c *Kafka) DescribeConfigurationRevisionWithContext(ctx aws.Context, input *DescribeConfigurationRevisionInput, opts ...request.Option) (*DescribeConfigurationRevisionOutput, error)
DescribeConfigurationRevisionWithContext is the same as DescribeConfigurationRevision with the addition of the ability to pass a context and additional request options.
See DescribeConfigurationRevision for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*Kafka) DescribeConfigurationWithContext ¶
func (c *Kafka) DescribeConfigurationWithContext(ctx aws.Context, input *DescribeConfigurationInput, opts ...request.Option) (*DescribeConfigurationOutput, error)
DescribeConfigurationWithContext is the same as DescribeConfiguration with the addition of the ability to pass a context and additional request options.
See DescribeConfiguration for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*Kafka) GetBootstrapBrokers ¶
func (c *Kafka) GetBootstrapBrokers(input *GetBootstrapBrokersInput) (*GetBootstrapBrokersOutput, error)
GetBootstrapBrokers API operation for Managed Streaming for Kafka.
A list of brokers that a client application can use to bootstrap.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka's API operation GetBootstrapBrokers for usage and error information.
Returned Error Codes:
ErrCodeBadRequestException "BadRequestException" Returns information about an error.
ErrCodeUnauthorizedException "UnauthorizedException" Returns information about an error.
ErrCodeInternalServerErrorException "InternalServerErrorException" Returns information about an error.
ErrCodeConflictException "ConflictException" Returns information about an error.
ErrCodeForbiddenException "ForbiddenException" Returns information about an error.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/GetBootstrapBrokers
func (*Kafka) GetBootstrapBrokersRequest ¶
func (c *Kafka) GetBootstrapBrokersRequest(input *GetBootstrapBrokersInput) (req *request.Request, output *GetBootstrapBrokersOutput)
GetBootstrapBrokersRequest generates a "aws/request.Request" representing the client's request for the GetBootstrapBrokers operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See GetBootstrapBrokers for more information on using the GetBootstrapBrokers API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the GetBootstrapBrokersRequest method. req, resp := client.GetBootstrapBrokersRequest(params) err := req.Send() if err == nil { // resp is now filled fmt.Println(resp) }
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/GetBootstrapBrokers
func (*Kafka) GetBootstrapBrokersWithContext ¶
func (c *Kafka) GetBootstrapBrokersWithContext(ctx aws.Context, input *GetBootstrapBrokersInput, opts ...request.Option) (*GetBootstrapBrokersOutput, error)
GetBootstrapBrokersWithContext is the same as GetBootstrapBrokers with the addition of the ability to pass a context and additional request options.
See GetBootstrapBrokers for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*Kafka) ListClusterOperations ¶
func (c *Kafka) ListClusterOperations(input *ListClusterOperationsInput) (*ListClusterOperationsOutput, error)
ListClusterOperations API operation for Managed Streaming for Kafka.
Returns a list of all the operations that have been performed on the specified MSK cluster.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka's API operation ListClusterOperations for usage and error information.
Returned Error Codes:
ErrCodeBadRequestException "BadRequestException" Returns information about an error.
ErrCodeInternalServerErrorException "InternalServerErrorException" Returns information about an error.
ErrCodeUnauthorizedException "UnauthorizedException" Returns information about an error.
ErrCodeForbiddenException "ForbiddenException" Returns information about an error.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListClusterOperations
func (*Kafka) ListClusterOperationsPages ¶
func (c *Kafka) ListClusterOperationsPages(input *ListClusterOperationsInput, fn func(*ListClusterOperationsOutput, bool) bool) error
ListClusterOperationsPages iterates over the pages of a ListClusterOperations operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.
See ListClusterOperations method for more information on how to use this operation.
Note: This operation can generate multiple requests to a service.
// Example iterating over at most 3 pages of a ListClusterOperations operation. pageNum := 0 err := client.ListClusterOperationsPages(params, func(page *kafka.ListClusterOperationsOutput, lastPage bool) bool { pageNum++ fmt.Println(page) return pageNum <= 3 })
func (*Kafka) ListClusterOperationsPagesWithContext ¶
func (c *Kafka) ListClusterOperationsPagesWithContext(ctx aws.Context, input *ListClusterOperationsInput, fn func(*ListClusterOperationsOutput, bool) bool, opts ...request.Option) error
ListClusterOperationsPagesWithContext same as ListClusterOperationsPages except it takes a Context and allows setting request options on the pages.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*Kafka) ListClusterOperationsRequest ¶
func (c *Kafka) ListClusterOperationsRequest(input *ListClusterOperationsInput) (req *request.Request, output *ListClusterOperationsOutput)
ListClusterOperationsRequest generates a "aws/request.Request" representing the client's request for the ListClusterOperations operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See ListClusterOperations for more information on using the ListClusterOperations API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the ListClusterOperationsRequest method. req, resp := client.ListClusterOperationsRequest(params) err := req.Send() if err == nil { // resp is now filled fmt.Println(resp) }
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListClusterOperations
func (*Kafka) ListClusterOperationsWithContext ¶
func (c *Kafka) ListClusterOperationsWithContext(ctx aws.Context, input *ListClusterOperationsInput, opts ...request.Option) (*ListClusterOperationsOutput, error)
ListClusterOperationsWithContext is the same as ListClusterOperations with the addition of the ability to pass a context and additional request options.
See ListClusterOperations for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*Kafka) ListClusters ¶
func (c *Kafka) ListClusters(input *ListClustersInput) (*ListClustersOutput, error)
ListClusters API operation for Managed Streaming for Kafka.
Returns a list of all the MSK clusters in the current Region.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka's API operation ListClusters for usage and error information.
Returned Error Codes:
ErrCodeBadRequestException "BadRequestException" Returns information about an error.
ErrCodeInternalServerErrorException "InternalServerErrorException" Returns information about an error.
ErrCodeUnauthorizedException "UnauthorizedException" Returns information about an error.
ErrCodeForbiddenException "ForbiddenException" Returns information about an error.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListClusters
func (*Kafka) ListClustersPages ¶
func (c *Kafka) ListClustersPages(input *ListClustersInput, fn func(*ListClustersOutput, bool) bool) error
ListClustersPages iterates over the pages of a ListClusters operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.
See ListClusters method for more information on how to use this operation.
Note: This operation can generate multiple requests to a service.
// Example iterating over at most 3 pages of a ListClusters operation. pageNum := 0 err := client.ListClustersPages(params, func(page *kafka.ListClustersOutput, lastPage bool) bool { pageNum++ fmt.Println(page) return pageNum <= 3 })
func (*Kafka) ListClustersPagesWithContext ¶
func (c *Kafka) ListClustersPagesWithContext(ctx aws.Context, input *ListClustersInput, fn func(*ListClustersOutput, bool) bool, opts ...request.Option) error
ListClustersPagesWithContext same as ListClustersPages except it takes a Context and allows setting request options on the pages.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*Kafka) ListClustersRequest ¶
func (c *Kafka) ListClustersRequest(input *ListClustersInput) (req *request.Request, output *ListClustersOutput)
ListClustersRequest generates a "aws/request.Request" representing the client's request for the ListClusters operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See ListClusters for more information on using the ListClusters API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the ListClustersRequest method. req, resp := client.ListClustersRequest(params) err := req.Send() if err == nil { // resp is now filled fmt.Println(resp) }
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListClusters
func (*Kafka) ListClustersWithContext ¶
func (c *Kafka) ListClustersWithContext(ctx aws.Context, input *ListClustersInput, opts ...request.Option) (*ListClustersOutput, error)
ListClustersWithContext is the same as ListClusters with the addition of the ability to pass a context and additional request options.
See ListClusters for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*Kafka) ListConfigurationRevisions ¶
func (c *Kafka) ListConfigurationRevisions(input *ListConfigurationRevisionsInput) (*ListConfigurationRevisionsOutput, error)
ListConfigurationRevisions API operation for Managed Streaming for Kafka.
Returns a list of all the MSK configurations in this Region.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka's API operation ListConfigurationRevisions for usage and error information.
Returned Error Codes:
ErrCodeBadRequestException "BadRequestException" Returns information about an error.
ErrCodeUnauthorizedException "UnauthorizedException" Returns information about an error.
ErrCodeInternalServerErrorException "InternalServerErrorException" Returns information about an error.
ErrCodeForbiddenException "ForbiddenException" Returns information about an error.
ErrCodeNotFoundException "NotFoundException" Returns information about an error.
ErrCodeServiceUnavailableException "ServiceUnavailableException" Returns information about an error.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListConfigurationRevisions
func (*Kafka) ListConfigurationRevisionsPages ¶
func (c *Kafka) ListConfigurationRevisionsPages(input *ListConfigurationRevisionsInput, fn func(*ListConfigurationRevisionsOutput, bool) bool) error
ListConfigurationRevisionsPages iterates over the pages of a ListConfigurationRevisions operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.
See ListConfigurationRevisions method for more information on how to use this operation.
Note: This operation can generate multiple requests to a service.
// Example iterating over at most 3 pages of a ListConfigurationRevisions operation. pageNum := 0 err := client.ListConfigurationRevisionsPages(params, func(page *kafka.ListConfigurationRevisionsOutput, lastPage bool) bool { pageNum++ fmt.Println(page) return pageNum <= 3 })
func (*Kafka) ListConfigurationRevisionsPagesWithContext ¶
func (c *Kafka) ListConfigurationRevisionsPagesWithContext(ctx aws.Context, input *ListConfigurationRevisionsInput, fn func(*ListConfigurationRevisionsOutput, bool) bool, opts ...request.Option) error
ListConfigurationRevisionsPagesWithContext same as ListConfigurationRevisionsPages except it takes a Context and allows setting request options on the pages.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*Kafka) ListConfigurationRevisionsRequest ¶
func (c *Kafka) ListConfigurationRevisionsRequest(input *ListConfigurationRevisionsInput) (req *request.Request, output *ListConfigurationRevisionsOutput)
ListConfigurationRevisionsRequest generates a "aws/request.Request" representing the client's request for the ListConfigurationRevisions operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See ListConfigurationRevisions for more information on using the ListConfigurationRevisions API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the ListConfigurationRevisionsRequest method. req, resp := client.ListConfigurationRevisionsRequest(params) err := req.Send() if err == nil { // resp is now filled fmt.Println(resp) }
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListConfigurationRevisions
func (*Kafka) ListConfigurationRevisionsWithContext ¶
func (c *Kafka) ListConfigurationRevisionsWithContext(ctx aws.Context, input *ListConfigurationRevisionsInput, opts ...request.Option) (*ListConfigurationRevisionsOutput, error)
ListConfigurationRevisionsWithContext is the same as ListConfigurationRevisions with the addition of the ability to pass a context and additional request options.
See ListConfigurationRevisions for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*Kafka) ListConfigurations ¶
func (c *Kafka) ListConfigurations(input *ListConfigurationsInput) (*ListConfigurationsOutput, error)
ListConfigurations API operation for Managed Streaming for Kafka.
Returns a list of all the MSK configurations in this Region.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka's API operation ListConfigurations for usage and error information.
Returned Error Codes:
ErrCodeServiceUnavailableException "ServiceUnavailableException" Returns information about an error.
ErrCodeBadRequestException "BadRequestException" Returns information about an error.
ErrCodeUnauthorizedException "UnauthorizedException" Returns information about an error.
ErrCodeInternalServerErrorException "InternalServerErrorException" Returns information about an error.
ErrCodeForbiddenException "ForbiddenException" Returns information about an error.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListConfigurations
func (*Kafka) ListConfigurationsPages ¶
func (c *Kafka) ListConfigurationsPages(input *ListConfigurationsInput, fn func(*ListConfigurationsOutput, bool) bool) error
ListConfigurationsPages iterates over the pages of a ListConfigurations operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.
See ListConfigurations method for more information on how to use this operation.
Note: This operation can generate multiple requests to a service.
// Example iterating over at most 3 pages of a ListConfigurations operation. pageNum := 0 err := client.ListConfigurationsPages(params, func(page *kafka.ListConfigurationsOutput, lastPage bool) bool { pageNum++ fmt.Println(page) return pageNum <= 3 })
func (*Kafka) ListConfigurationsPagesWithContext ¶
func (c *Kafka) ListConfigurationsPagesWithContext(ctx aws.Context, input *ListConfigurationsInput, fn func(*ListConfigurationsOutput, bool) bool, opts ...request.Option) error
ListConfigurationsPagesWithContext same as ListConfigurationsPages except it takes a Context and allows setting request options on the pages.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*Kafka) ListConfigurationsRequest ¶
func (c *Kafka) ListConfigurationsRequest(input *ListConfigurationsInput) (req *request.Request, output *ListConfigurationsOutput)
ListConfigurationsRequest generates a "aws/request.Request" representing the client's request for the ListConfigurations operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See ListConfigurations for more information on using the ListConfigurations API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the ListConfigurationsRequest method. req, resp := client.ListConfigurationsRequest(params) err := req.Send() if err == nil { // resp is now filled fmt.Println(resp) }
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListConfigurations
func (*Kafka) ListConfigurationsWithContext ¶
func (c *Kafka) ListConfigurationsWithContext(ctx aws.Context, input *ListConfigurationsInput, opts ...request.Option) (*ListConfigurationsOutput, error)
ListConfigurationsWithContext is the same as ListConfigurations with the addition of the ability to pass a context and additional request options.
See ListConfigurations for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*Kafka) ListNodes ¶
func (c *Kafka) ListNodes(input *ListNodesInput) (*ListNodesOutput, error)
ListNodes API operation for Managed Streaming for Kafka.
Returns a list of the broker nodes in the cluster.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka's API operation ListNodes for usage and error information.
Returned Error Codes:
ErrCodeNotFoundException "NotFoundException" Returns information about an error.
ErrCodeBadRequestException "BadRequestException" Returns information about an error.
ErrCodeInternalServerErrorException "InternalServerErrorException" Returns information about an error.
ErrCodeForbiddenException "ForbiddenException" Returns information about an error.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListNodes
func (*Kafka) ListNodesPages ¶
func (c *Kafka) ListNodesPages(input *ListNodesInput, fn func(*ListNodesOutput, bool) bool) error
ListNodesPages iterates over the pages of a ListNodes operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.
See ListNodes method for more information on how to use this operation.
Note: This operation can generate multiple requests to a service.
// Example iterating over at most 3 pages of a ListNodes operation. pageNum := 0 err := client.ListNodesPages(params, func(page *kafka.ListNodesOutput, lastPage bool) bool { pageNum++ fmt.Println(page) return pageNum <= 3 })
func (*Kafka) ListNodesPagesWithContext ¶
func (c *Kafka) ListNodesPagesWithContext(ctx aws.Context, input *ListNodesInput, fn func(*ListNodesOutput, bool) bool, opts ...request.Option) error
ListNodesPagesWithContext same as ListNodesPages except it takes a Context and allows setting request options on the pages.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*Kafka) ListNodesRequest ¶
func (c *Kafka) ListNodesRequest(input *ListNodesInput) (req *request.Request, output *ListNodesOutput)
ListNodesRequest generates a "aws/request.Request" representing the client's request for the ListNodes operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See ListNodes for more information on using the ListNodes API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the ListNodesRequest method. req, resp := client.ListNodesRequest(params) err := req.Send() if err == nil { // resp is now filled fmt.Println(resp) }
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListNodes
func (*Kafka) ListNodesWithContext ¶
func (c *Kafka) ListNodesWithContext(ctx aws.Context, input *ListNodesInput, opts ...request.Option) (*ListNodesOutput, error)
ListNodesWithContext is the same as ListNodes with the addition of the ability to pass a context and additional request options.
See ListNodes for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*Kafka) ListTagsForResource ¶
func (c *Kafka) ListTagsForResource(input *ListTagsForResourceInput) (*ListTagsForResourceOutput, error)
ListTagsForResource API operation for Managed Streaming for Kafka.
Returns a list of the tags associated with the specified resource.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka's API operation ListTagsForResource for usage and error information.
Returned Error Codes:
ErrCodeNotFoundException "NotFoundException" Returns information about an error.
ErrCodeBadRequestException "BadRequestException" Returns information about an error.
ErrCodeInternalServerErrorException "InternalServerErrorException" Returns information about an error.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListTagsForResource
func (*Kafka) ListTagsForResourceRequest ¶
func (c *Kafka) ListTagsForResourceRequest(input *ListTagsForResourceInput) (req *request.Request, output *ListTagsForResourceOutput)
ListTagsForResourceRequest generates a "aws/request.Request" representing the client's request for the ListTagsForResource operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See ListTagsForResource for more information on using the ListTagsForResource API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the ListTagsForResourceRequest method. req, resp := client.ListTagsForResourceRequest(params) err := req.Send() if err == nil { // resp is now filled fmt.Println(resp) }
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListTagsForResource
func (*Kafka) ListTagsForResourceWithContext ¶
func (c *Kafka) ListTagsForResourceWithContext(ctx aws.Context, input *ListTagsForResourceInput, opts ...request.Option) (*ListTagsForResourceOutput, error)
ListTagsForResourceWithContext is the same as ListTagsForResource with the addition of the ability to pass a context and additional request options.
See ListTagsForResource for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*Kafka) TagResource ¶
func (c *Kafka) TagResource(input *TagResourceInput) (*TagResourceOutput, error)
TagResource API operation for Managed Streaming for Kafka.
Adds tags to the specified MSK resource.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka's API operation TagResource for usage and error information.
Returned Error Codes:
ErrCodeNotFoundException "NotFoundException" Returns information about an error.
ErrCodeBadRequestException "BadRequestException" Returns information about an error.
ErrCodeInternalServerErrorException "InternalServerErrorException" Returns information about an error.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/TagResource
func (*Kafka) TagResourceRequest ¶
func (c *Kafka) TagResourceRequest(input *TagResourceInput) (req *request.Request, output *TagResourceOutput)
TagResourceRequest generates a "aws/request.Request" representing the client's request for the TagResource operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See TagResource for more information on using the TagResource API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the TagResourceRequest method. req, resp := client.TagResourceRequest(params) err := req.Send() if err == nil { // resp is now filled fmt.Println(resp) }
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/TagResource
func (*Kafka) TagResourceWithContext ¶
func (c *Kafka) TagResourceWithContext(ctx aws.Context, input *TagResourceInput, opts ...request.Option) (*TagResourceOutput, error)
TagResourceWithContext is the same as TagResource with the addition of the ability to pass a context and additional request options.
See TagResource for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*Kafka) UntagResource ¶
func (c *Kafka) UntagResource(input *UntagResourceInput) (*UntagResourceOutput, error)
UntagResource API operation for Managed Streaming for Kafka.
Removes the tags associated with the keys that are provided in the query.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka's API operation UntagResource for usage and error information.
Returned Error Codes:
ErrCodeNotFoundException "NotFoundException" Returns information about an error.
ErrCodeBadRequestException "BadRequestException" Returns information about an error.
ErrCodeInternalServerErrorException "InternalServerErrorException" Returns information about an error.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UntagResource
func (*Kafka) UntagResourceRequest ¶
func (c *Kafka) UntagResourceRequest(input *UntagResourceInput) (req *request.Request, output *UntagResourceOutput)
UntagResourceRequest generates a "aws/request.Request" representing the client's request for the UntagResource operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See UntagResource for more information on using the UntagResource API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the UntagResourceRequest method. req, resp := client.UntagResourceRequest(params) err := req.Send() if err == nil { // resp is now filled fmt.Println(resp) }
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UntagResource
func (*Kafka) UntagResourceWithContext ¶
func (c *Kafka) UntagResourceWithContext(ctx aws.Context, input *UntagResourceInput, opts ...request.Option) (*UntagResourceOutput, error)
UntagResourceWithContext is the same as UntagResource with the addition of the ability to pass a context and additional request options.
See UntagResource for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*Kafka) UpdateBrokerStorage ¶
func (c *Kafka) UpdateBrokerStorage(input *UpdateBrokerStorageInput) (*UpdateBrokerStorageOutput, error)
UpdateBrokerStorage API operation for Managed Streaming for Kafka.
Updates the EBS storage associated with MSK brokers.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka's API operation UpdateBrokerStorage for usage and error information.
Returned Error Codes:
ErrCodeServiceUnavailableException "ServiceUnavailableException" Returns information about an error.
ErrCodeBadRequestException "BadRequestException" Returns information about an error.
ErrCodeUnauthorizedException "UnauthorizedException" Returns information about an error.
ErrCodeInternalServerErrorException "InternalServerErrorException" Returns information about an error.
ErrCodeForbiddenException "ForbiddenException" Returns information about an error.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateBrokerStorage
func (*Kafka) UpdateBrokerStorageRequest ¶
func (c *Kafka) UpdateBrokerStorageRequest(input *UpdateBrokerStorageInput) (req *request.Request, output *UpdateBrokerStorageOutput)
UpdateBrokerStorageRequest generates a "aws/request.Request" representing the client's request for the UpdateBrokerStorage operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See UpdateBrokerStorage for more information on using the UpdateBrokerStorage API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the UpdateBrokerStorageRequest method. req, resp := client.UpdateBrokerStorageRequest(params) err := req.Send() if err == nil { // resp is now filled fmt.Println(resp) }
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateBrokerStorage
func (*Kafka) UpdateBrokerStorageWithContext ¶
func (c *Kafka) UpdateBrokerStorageWithContext(ctx aws.Context, input *UpdateBrokerStorageInput, opts ...request.Option) (*UpdateBrokerStorageOutput, error)
UpdateBrokerStorageWithContext is the same as UpdateBrokerStorage with the addition of the ability to pass a context and additional request options.
See UpdateBrokerStorage for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*Kafka) UpdateClusterConfiguration ¶
func (c *Kafka) UpdateClusterConfiguration(input *UpdateClusterConfigurationInput) (*UpdateClusterConfigurationOutput, error)
UpdateClusterConfiguration API operation for Managed Streaming for Kafka.
Updates the cluster with the configuration that is specified in the request body.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka's API operation UpdateClusterConfiguration for usage and error information.
Returned Error Codes:
ErrCodeBadRequestException "BadRequestException" Returns information about an error.
ErrCodeUnauthorizedException "UnauthorizedException" Returns information about an error.
ErrCodeInternalServerErrorException "InternalServerErrorException" Returns information about an error.
ErrCodeForbiddenException "ForbiddenException" Returns information about an error.
ErrCodeNotFoundException "NotFoundException" Returns information about an error.
ErrCodeServiceUnavailableException "ServiceUnavailableException" Returns information about an error.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateClusterConfiguration
func (*Kafka) UpdateClusterConfigurationRequest ¶
func (c *Kafka) UpdateClusterConfigurationRequest(input *UpdateClusterConfigurationInput) (req *request.Request, output *UpdateClusterConfigurationOutput)
UpdateClusterConfigurationRequest generates a "aws/request.Request" representing the client's request for the UpdateClusterConfiguration operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See UpdateClusterConfiguration for more information on using the UpdateClusterConfiguration API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the UpdateClusterConfigurationRequest method. req, resp := client.UpdateClusterConfigurationRequest(params) err := req.Send() if err == nil { // resp is now filled fmt.Println(resp) }
See also, https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateClusterConfiguration
func (*Kafka) UpdateClusterConfigurationWithContext ¶
func (c *Kafka) UpdateClusterConfigurationWithContext(ctx aws.Context, input *UpdateClusterConfigurationInput, opts ...request.Option) (*UpdateClusterConfigurationOutput, error)
UpdateClusterConfigurationWithContext is the same as UpdateClusterConfiguration with the addition of the ability to pass a context and additional request options.
See UpdateClusterConfiguration for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
type ListClusterOperationsInput ¶
type ListClusterOperationsInput struct { // ClusterArn is a required field ClusterArn *string `location:"uri" locationName:"clusterArn" type:"string" required:"true"` MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"` NextToken *string `location:"querystring" locationName:"nextToken" type:"string"` // contains filtered or unexported fields }
func (ListClusterOperationsInput) GoString ¶
func (s ListClusterOperationsInput) GoString() string
GoString returns the string representation
func (*ListClusterOperationsInput) SetClusterArn ¶
func (s *ListClusterOperationsInput) SetClusterArn(v string) *ListClusterOperationsInput
SetClusterArn sets the ClusterArn field's value.
func (*ListClusterOperationsInput) SetMaxResults ¶
func (s *ListClusterOperationsInput) SetMaxResults(v int64) *ListClusterOperationsInput
SetMaxResults sets the MaxResults field's value.
func (*ListClusterOperationsInput) SetNextToken ¶
func (s *ListClusterOperationsInput) SetNextToken(v string) *ListClusterOperationsInput
SetNextToken sets the NextToken field's value.
func (ListClusterOperationsInput) String ¶
func (s ListClusterOperationsInput) String() string
String returns the string representation
func (*ListClusterOperationsInput) Validate ¶
func (s *ListClusterOperationsInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListClusterOperationsOutput ¶
type ListClusterOperationsOutput struct { // An array of cluster operation information objects. ClusterOperationInfoList []*ClusterOperationInfo `locationName:"clusterOperationInfoList" type:"list"` // If the response of ListClusterOperations is truncated, it returns a NextToken // in the response. This Nexttoken should be sent in the subsequent request // to ListClusterOperations. NextToken *string `locationName:"nextToken" type:"string"` // contains filtered or unexported fields }
The response contains an array containing cluster operation information and a next token if the response is truncated.
func (ListClusterOperationsOutput) GoString ¶
func (s ListClusterOperationsOutput) GoString() string
GoString returns the string representation
func (*ListClusterOperationsOutput) SetClusterOperationInfoList ¶
func (s *ListClusterOperationsOutput) SetClusterOperationInfoList(v []*ClusterOperationInfo) *ListClusterOperationsOutput
SetClusterOperationInfoList sets the ClusterOperationInfoList field's value.
func (*ListClusterOperationsOutput) SetNextToken ¶
func (s *ListClusterOperationsOutput) SetNextToken(v string) *ListClusterOperationsOutput
SetNextToken sets the NextToken field's value.
func (ListClusterOperationsOutput) String ¶
func (s ListClusterOperationsOutput) String() string
String returns the string representation
type ListClustersInput ¶
type ListClustersInput struct { ClusterNameFilter *string `location:"querystring" locationName:"clusterNameFilter" type:"string"` MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"` NextToken *string `location:"querystring" locationName:"nextToken" type:"string"` // contains filtered or unexported fields }
func (ListClustersInput) GoString ¶
func (s ListClustersInput) GoString() string
GoString returns the string representation
func (*ListClustersInput) SetClusterNameFilter ¶
func (s *ListClustersInput) SetClusterNameFilter(v string) *ListClustersInput
SetClusterNameFilter sets the ClusterNameFilter field's value.
func (*ListClustersInput) SetMaxResults ¶
func (s *ListClustersInput) SetMaxResults(v int64) *ListClustersInput
SetMaxResults sets the MaxResults field's value.
func (*ListClustersInput) SetNextToken ¶
func (s *ListClustersInput) SetNextToken(v string) *ListClustersInput
SetNextToken sets the NextToken field's value.
func (ListClustersInput) String ¶
func (s ListClustersInput) String() string
String returns the string representation
func (*ListClustersInput) Validate ¶
func (s *ListClustersInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListClustersOutput ¶
type ListClustersOutput struct { // Information on each of the MSK clusters in the response. ClusterInfoList []*ClusterInfo `locationName:"clusterInfoList" type:"list"` // The paginated results marker. When the result of a ListClusters operation // is truncated, the call returns NextToken in the response. To get another // batch of clusters, provide this token in your next request. NextToken *string `locationName:"nextToken" type:"string"` // contains filtered or unexported fields }
The response contains an array containing cluster information and a next token if the response is truncated.
func (ListClustersOutput) GoString ¶
func (s ListClustersOutput) GoString() string
GoString returns the string representation
func (*ListClustersOutput) SetClusterInfoList ¶
func (s *ListClustersOutput) SetClusterInfoList(v []*ClusterInfo) *ListClustersOutput
SetClusterInfoList sets the ClusterInfoList field's value.
func (*ListClustersOutput) SetNextToken ¶
func (s *ListClustersOutput) SetNextToken(v string) *ListClustersOutput
SetNextToken sets the NextToken field's value.
func (ListClustersOutput) String ¶
func (s ListClustersOutput) String() string
String returns the string representation
type ListConfigurationRevisionsInput ¶
type ListConfigurationRevisionsInput struct { // Arn is a required field Arn *string `location:"uri" locationName:"arn" type:"string" required:"true"` MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"` NextToken *string `location:"querystring" locationName:"nextToken" type:"string"` // contains filtered or unexported fields }
func (ListConfigurationRevisionsInput) GoString ¶
func (s ListConfigurationRevisionsInput) GoString() string
GoString returns the string representation
func (*ListConfigurationRevisionsInput) SetArn ¶
func (s *ListConfigurationRevisionsInput) SetArn(v string) *ListConfigurationRevisionsInput
SetArn sets the Arn field's value.
func (*ListConfigurationRevisionsInput) SetMaxResults ¶
func (s *ListConfigurationRevisionsInput) SetMaxResults(v int64) *ListConfigurationRevisionsInput
SetMaxResults sets the MaxResults field's value.
func (*ListConfigurationRevisionsInput) SetNextToken ¶
func (s *ListConfigurationRevisionsInput) SetNextToken(v string) *ListConfigurationRevisionsInput
SetNextToken sets the NextToken field's value.
func (ListConfigurationRevisionsInput) String ¶
func (s ListConfigurationRevisionsInput) String() string
String returns the string representation
func (*ListConfigurationRevisionsInput) Validate ¶
func (s *ListConfigurationRevisionsInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListConfigurationRevisionsOutput ¶
type ListConfigurationRevisionsOutput struct { // Paginated results marker. NextToken *string `locationName:"nextToken" type:"string"` // List of ConfigurationRevision objects. Revisions []*ConfigurationRevision `locationName:"revisions" type:"list"` // contains filtered or unexported fields }
Information about revisions of an MSK configuration.
func (ListConfigurationRevisionsOutput) GoString ¶
func (s ListConfigurationRevisionsOutput) GoString() string
GoString returns the string representation
func (*ListConfigurationRevisionsOutput) SetNextToken ¶
func (s *ListConfigurationRevisionsOutput) SetNextToken(v string) *ListConfigurationRevisionsOutput
SetNextToken sets the NextToken field's value.
func (*ListConfigurationRevisionsOutput) SetRevisions ¶
func (s *ListConfigurationRevisionsOutput) SetRevisions(v []*ConfigurationRevision) *ListConfigurationRevisionsOutput
SetRevisions sets the Revisions field's value.
func (ListConfigurationRevisionsOutput) String ¶
func (s ListConfigurationRevisionsOutput) String() string
String returns the string representation
type ListConfigurationsInput ¶
type ListConfigurationsInput struct { MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"` NextToken *string `location:"querystring" locationName:"nextToken" type:"string"` // contains filtered or unexported fields }
func (ListConfigurationsInput) GoString ¶
func (s ListConfigurationsInput) GoString() string
GoString returns the string representation
func (*ListConfigurationsInput) SetMaxResults ¶
func (s *ListConfigurationsInput) SetMaxResults(v int64) *ListConfigurationsInput
SetMaxResults sets the MaxResults field's value.
func (*ListConfigurationsInput) SetNextToken ¶
func (s *ListConfigurationsInput) SetNextToken(v string) *ListConfigurationsInput
SetNextToken sets the NextToken field's value.
func (ListConfigurationsInput) String ¶
func (s ListConfigurationsInput) String() string
String returns the string representation
func (*ListConfigurationsInput) Validate ¶
func (s *ListConfigurationsInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListConfigurationsOutput ¶
type ListConfigurationsOutput struct { // An array of MSK configurations. Configurations []*Configuration `locationName:"configurations" type:"list"` // The paginated results marker. When the result of a ListConfigurations operation // is truncated, the call returns NextToken in the response. To get another // batch of configurations, provide this token in your next request. NextToken *string `locationName:"nextToken" type:"string"` // contains filtered or unexported fields }
The response contains an array of Configuration and a next token if the response is truncated.
func (ListConfigurationsOutput) GoString ¶
func (s ListConfigurationsOutput) GoString() string
GoString returns the string representation
func (*ListConfigurationsOutput) SetConfigurations ¶
func (s *ListConfigurationsOutput) SetConfigurations(v []*Configuration) *ListConfigurationsOutput
SetConfigurations sets the Configurations field's value.
func (*ListConfigurationsOutput) SetNextToken ¶
func (s *ListConfigurationsOutput) SetNextToken(v string) *ListConfigurationsOutput
SetNextToken sets the NextToken field's value.
func (ListConfigurationsOutput) String ¶
func (s ListConfigurationsOutput) String() string
String returns the string representation
type ListNodesInput ¶
type ListNodesInput struct { // ClusterArn is a required field ClusterArn *string `location:"uri" locationName:"clusterArn" type:"string" required:"true"` MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"` NextToken *string `location:"querystring" locationName:"nextToken" type:"string"` // contains filtered or unexported fields }
func (ListNodesInput) GoString ¶
func (s ListNodesInput) GoString() string
GoString returns the string representation
func (*ListNodesInput) SetClusterArn ¶
func (s *ListNodesInput) SetClusterArn(v string) *ListNodesInput
SetClusterArn sets the ClusterArn field's value.
func (*ListNodesInput) SetMaxResults ¶
func (s *ListNodesInput) SetMaxResults(v int64) *ListNodesInput
SetMaxResults sets the MaxResults field's value.
func (*ListNodesInput) SetNextToken ¶
func (s *ListNodesInput) SetNextToken(v string) *ListNodesInput
SetNextToken sets the NextToken field's value.
func (ListNodesInput) String ¶
func (s ListNodesInput) String() string
String returns the string representation
func (*ListNodesInput) Validate ¶
func (s *ListNodesInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListNodesOutput ¶
type ListNodesOutput struct { // The paginated results marker. When the result of a ListNodes operation is // truncated, the call returns NextToken in the response. To get another batch // of nodes, provide this token in your next request. NextToken *string `locationName:"nextToken" type:"string"` // List containing a NodeInfo object. NodeInfoList []*NodeInfo `locationName:"nodeInfoList" type:"list"` // contains filtered or unexported fields }
Information about nodes in the cluster.
func (ListNodesOutput) GoString ¶
func (s ListNodesOutput) GoString() string
GoString returns the string representation
func (*ListNodesOutput) SetNextToken ¶
func (s *ListNodesOutput) SetNextToken(v string) *ListNodesOutput
SetNextToken sets the NextToken field's value.
func (*ListNodesOutput) SetNodeInfoList ¶
func (s *ListNodesOutput) SetNodeInfoList(v []*NodeInfo) *ListNodesOutput
SetNodeInfoList sets the NodeInfoList field's value.
func (ListNodesOutput) String ¶
func (s ListNodesOutput) String() string
String returns the string representation
type ListTagsForResourceInput ¶
type ListTagsForResourceInput struct { // ResourceArn is a required field ResourceArn *string `location:"uri" locationName:"resourceArn" type:"string" required:"true"` // contains filtered or unexported fields }
func (ListTagsForResourceInput) GoString ¶
func (s ListTagsForResourceInput) GoString() string
GoString returns the string representation
func (*ListTagsForResourceInput) SetResourceArn ¶
func (s *ListTagsForResourceInput) SetResourceArn(v string) *ListTagsForResourceInput
SetResourceArn sets the ResourceArn field's value.
func (ListTagsForResourceInput) String ¶
func (s ListTagsForResourceInput) String() string
String returns the string representation
func (*ListTagsForResourceInput) Validate ¶
func (s *ListTagsForResourceInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListTagsForResourceOutput ¶
type ListTagsForResourceOutput struct { // The key-value pair for the resource tag. Tags map[string]*string `locationName:"tags" type:"map"` // contains filtered or unexported fields }
Response of listing tags for a resource.
func (ListTagsForResourceOutput) GoString ¶
func (s ListTagsForResourceOutput) GoString() string
GoString returns the string representation
func (*ListTagsForResourceOutput) SetTags ¶
func (s *ListTagsForResourceOutput) SetTags(v map[string]*string) *ListTagsForResourceOutput
SetTags sets the Tags field's value.
func (ListTagsForResourceOutput) String ¶
func (s ListTagsForResourceOutput) String() string
String returns the string representation
type MutableClusterInfo ¶
type MutableClusterInfo struct { // Specifies the size of the EBS volume and the ID of the associated broker. BrokerEBSVolumeInfo []*BrokerEBSVolumeInfo `locationName:"brokerEBSVolumeInfo" type:"list"` // Information about the changes in the configuration of the brokers. ConfigurationInfo *ConfigurationInfo `locationName:"configurationInfo" type:"structure"` // The number of broker nodes in the cluster. NumberOfBrokerNodes *int64 `locationName:"numberOfBrokerNodes" type:"integer"` // contains filtered or unexported fields }
Information about cluster attributes that can be updated via update APIs.
func (MutableClusterInfo) GoString ¶
func (s MutableClusterInfo) GoString() string
GoString returns the string representation
func (*MutableClusterInfo) SetBrokerEBSVolumeInfo ¶
func (s *MutableClusterInfo) SetBrokerEBSVolumeInfo(v []*BrokerEBSVolumeInfo) *MutableClusterInfo
SetBrokerEBSVolumeInfo sets the BrokerEBSVolumeInfo field's value.
func (*MutableClusterInfo) SetConfigurationInfo ¶
func (s *MutableClusterInfo) SetConfigurationInfo(v *ConfigurationInfo) *MutableClusterInfo
SetConfigurationInfo sets the ConfigurationInfo field's value.
func (*MutableClusterInfo) SetNumberOfBrokerNodes ¶
func (s *MutableClusterInfo) SetNumberOfBrokerNodes(v int64) *MutableClusterInfo
SetNumberOfBrokerNodes sets the NumberOfBrokerNodes field's value.
func (MutableClusterInfo) String ¶
func (s MutableClusterInfo) String() string
String returns the string representation
type NodeInfo ¶
type NodeInfo struct { // The start time. AddedToClusterTime *string `locationName:"addedToClusterTime" type:"string"` // The broker node info. BrokerNodeInfo *BrokerNodeInfo `locationName:"brokerNodeInfo" type:"structure"` // The instance type. InstanceType *string `locationName:"instanceType" type:"string"` // The Amazon Resource Name (ARN) of the node. NodeARN *string `locationName:"nodeARN" type:"string"` // The node type. NodeType *string `locationName:"nodeType" type:"string" enum:"NodeType"` // The ZookeeperNodeInfo. ZookeeperNodeInfo *ZookeeperNodeInfo `locationName:"zookeeperNodeInfo" type:"structure"` // contains filtered or unexported fields }
The node information object.
func (*NodeInfo) SetAddedToClusterTime ¶
SetAddedToClusterTime sets the AddedToClusterTime field's value.
func (*NodeInfo) SetBrokerNodeInfo ¶
func (s *NodeInfo) SetBrokerNodeInfo(v *BrokerNodeInfo) *NodeInfo
SetBrokerNodeInfo sets the BrokerNodeInfo field's value.
func (*NodeInfo) SetInstanceType ¶
SetInstanceType sets the InstanceType field's value.
func (*NodeInfo) SetNodeARN ¶
SetNodeARN sets the NodeARN field's value.
func (*NodeInfo) SetNodeType ¶
SetNodeType sets the NodeType field's value.
func (*NodeInfo) SetZookeeperNodeInfo ¶
func (s *NodeInfo) SetZookeeperNodeInfo(v *ZookeeperNodeInfo) *NodeInfo
SetZookeeperNodeInfo sets the ZookeeperNodeInfo field's value.
type StorageInfo ¶
type StorageInfo struct { // EBS volume information. EbsStorageInfo *EBSStorageInfo `locationName:"ebsStorageInfo" type:"structure"` // contains filtered or unexported fields }
Contains information about storage volumes attached to MSK broker nodes.
func (StorageInfo) GoString ¶
func (s StorageInfo) GoString() string
GoString returns the string representation
func (*StorageInfo) SetEbsStorageInfo ¶
func (s *StorageInfo) SetEbsStorageInfo(v *EBSStorageInfo) *StorageInfo
SetEbsStorageInfo sets the EbsStorageInfo field's value.
func (StorageInfo) String ¶
func (s StorageInfo) String() string
String returns the string representation
func (*StorageInfo) Validate ¶
func (s *StorageInfo) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type TagResourceInput ¶
type TagResourceInput struct { // ResourceArn is a required field ResourceArn *string `location:"uri" locationName:"resourceArn" type:"string" required:"true"` // The key-value pair for the resource tag. // // Tags is a required field Tags map[string]*string `locationName:"tags" type:"map" required:"true"` // contains filtered or unexported fields }
Tag a resource.
func (TagResourceInput) GoString ¶
func (s TagResourceInput) GoString() string
GoString returns the string representation
func (*TagResourceInput) SetResourceArn ¶
func (s *TagResourceInput) SetResourceArn(v string) *TagResourceInput
SetResourceArn sets the ResourceArn field's value.
func (*TagResourceInput) SetTags ¶
func (s *TagResourceInput) SetTags(v map[string]*string) *TagResourceInput
SetTags sets the Tags field's value.
func (TagResourceInput) String ¶
func (s TagResourceInput) String() string
String returns the string representation
func (*TagResourceInput) Validate ¶
func (s *TagResourceInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type TagResourceOutput ¶
type TagResourceOutput struct {
// contains filtered or unexported fields
}
func (TagResourceOutput) GoString ¶
func (s TagResourceOutput) GoString() string
GoString returns the string representation
func (TagResourceOutput) String ¶
func (s TagResourceOutput) String() string
String returns the string representation
type Tls ¶
type Tls struct { // List of ACM Certificate Authority ARNs. CertificateAuthorityArnList []*string `locationName:"certificateAuthorityArnList" type:"list"` // contains filtered or unexported fields }
Details for client authentication using TLS.
func (*Tls) SetCertificateAuthorityArnList ¶
SetCertificateAuthorityArnList sets the CertificateAuthorityArnList field's value.
type UntagResourceInput ¶
type UntagResourceInput struct { // ResourceArn is a required field ResourceArn *string `location:"uri" locationName:"resourceArn" type:"string" required:"true"` // TagKeys is a required field TagKeys []*string `location:"querystring" locationName:"tagKeys" type:"list" required:"true"` // contains filtered or unexported fields }
func (UntagResourceInput) GoString ¶
func (s UntagResourceInput) GoString() string
GoString returns the string representation
func (*UntagResourceInput) SetResourceArn ¶
func (s *UntagResourceInput) SetResourceArn(v string) *UntagResourceInput
SetResourceArn sets the ResourceArn field's value.
func (*UntagResourceInput) SetTagKeys ¶
func (s *UntagResourceInput) SetTagKeys(v []*string) *UntagResourceInput
SetTagKeys sets the TagKeys field's value.
func (UntagResourceInput) String ¶
func (s UntagResourceInput) String() string
String returns the string representation
func (*UntagResourceInput) Validate ¶
func (s *UntagResourceInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type UntagResourceOutput ¶
type UntagResourceOutput struct {
// contains filtered or unexported fields
}
func (UntagResourceOutput) GoString ¶
func (s UntagResourceOutput) GoString() string
GoString returns the string representation
func (UntagResourceOutput) String ¶
func (s UntagResourceOutput) String() string
String returns the string representation
type UpdateBrokerStorageInput ¶
type UpdateBrokerStorageInput struct { // ClusterArn is a required field ClusterArn *string `location:"uri" locationName:"clusterArn" type:"string" required:"true"` // The version of cluster to update from. A successful operation will then generate // a new version. // // CurrentVersion is a required field CurrentVersion *string `locationName:"currentVersion" type:"string" required:"true"` // Describes the target volume size and the ID of the broker to apply the update // to. // // TargetBrokerEBSVolumeInfo is a required field TargetBrokerEBSVolumeInfo []*BrokerEBSVolumeInfo `locationName:"targetBrokerEBSVolumeInfo" type:"list" required:"true"` // contains filtered or unexported fields }
Request object for UpdateBrokerStorage.
func (UpdateBrokerStorageInput) GoString ¶
func (s UpdateBrokerStorageInput) GoString() string
GoString returns the string representation
func (*UpdateBrokerStorageInput) SetClusterArn ¶
func (s *UpdateBrokerStorageInput) SetClusterArn(v string) *UpdateBrokerStorageInput
SetClusterArn sets the ClusterArn field's value.
func (*UpdateBrokerStorageInput) SetCurrentVersion ¶
func (s *UpdateBrokerStorageInput) SetCurrentVersion(v string) *UpdateBrokerStorageInput
SetCurrentVersion sets the CurrentVersion field's value.
func (*UpdateBrokerStorageInput) SetTargetBrokerEBSVolumeInfo ¶
func (s *UpdateBrokerStorageInput) SetTargetBrokerEBSVolumeInfo(v []*BrokerEBSVolumeInfo) *UpdateBrokerStorageInput
SetTargetBrokerEBSVolumeInfo sets the TargetBrokerEBSVolumeInfo field's value.
func (UpdateBrokerStorageInput) String ¶
func (s UpdateBrokerStorageInput) String() string
String returns the string representation
func (*UpdateBrokerStorageInput) Validate ¶
func (s *UpdateBrokerStorageInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type UpdateBrokerStorageOutput ¶
type UpdateBrokerStorageOutput struct { // The Amazon Resource Name (ARN) of the cluster. ClusterArn *string `locationName:"clusterArn" type:"string"` // The Amazon Resource Name (ARN) of the cluster operation. ClusterOperationArn *string `locationName:"clusterOperationArn" type:"string"` // contains filtered or unexported fields }
Response body for UpdateBrokerStorage.
func (UpdateBrokerStorageOutput) GoString ¶
func (s UpdateBrokerStorageOutput) GoString() string
GoString returns the string representation
func (*UpdateBrokerStorageOutput) SetClusterArn ¶
func (s *UpdateBrokerStorageOutput) SetClusterArn(v string) *UpdateBrokerStorageOutput
SetClusterArn sets the ClusterArn field's value.
func (*UpdateBrokerStorageOutput) SetClusterOperationArn ¶
func (s *UpdateBrokerStorageOutput) SetClusterOperationArn(v string) *UpdateBrokerStorageOutput
SetClusterOperationArn sets the ClusterOperationArn field's value.
func (UpdateBrokerStorageOutput) String ¶
func (s UpdateBrokerStorageOutput) String() string
String returns the string representation
type UpdateClusterConfigurationInput ¶
type UpdateClusterConfigurationInput struct { // ClusterArn is a required field ClusterArn *string `location:"uri" locationName:"clusterArn" type:"string" required:"true"` // Represents the configuration that you want MSK to use for the brokers in // a cluster. // // ConfigurationInfo is a required field ConfigurationInfo *ConfigurationInfo `locationName:"configurationInfo" type:"structure" required:"true"` // The version of the cluster that needs to be updated. // // CurrentVersion is a required field CurrentVersion *string `locationName:"currentVersion" type:"string" required:"true"` // contains filtered or unexported fields }
Request body for UpdateClusterConfiguration.
func (UpdateClusterConfigurationInput) GoString ¶
func (s UpdateClusterConfigurationInput) GoString() string
GoString returns the string representation
func (*UpdateClusterConfigurationInput) SetClusterArn ¶
func (s *UpdateClusterConfigurationInput) SetClusterArn(v string) *UpdateClusterConfigurationInput
SetClusterArn sets the ClusterArn field's value.
func (*UpdateClusterConfigurationInput) SetConfigurationInfo ¶
func (s *UpdateClusterConfigurationInput) SetConfigurationInfo(v *ConfigurationInfo) *UpdateClusterConfigurationInput
SetConfigurationInfo sets the ConfigurationInfo field's value.
func (*UpdateClusterConfigurationInput) SetCurrentVersion ¶
func (s *UpdateClusterConfigurationInput) SetCurrentVersion(v string) *UpdateClusterConfigurationInput
SetCurrentVersion sets the CurrentVersion field's value.
func (UpdateClusterConfigurationInput) String ¶
func (s UpdateClusterConfigurationInput) String() string
String returns the string representation
func (*UpdateClusterConfigurationInput) Validate ¶
func (s *UpdateClusterConfigurationInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type UpdateClusterConfigurationOutput ¶
type UpdateClusterConfigurationOutput struct { // The Amazon Resource Name (ARN) of the cluster. ClusterArn *string `locationName:"clusterArn" type:"string"` // The Amazon Resource Name (ARN) of the cluster operation. ClusterOperationArn *string `locationName:"clusterOperationArn" type:"string"` // contains filtered or unexported fields }
Response body for UpdateClusterConfiguration.
func (UpdateClusterConfigurationOutput) GoString ¶
func (s UpdateClusterConfigurationOutput) GoString() string
GoString returns the string representation
func (*UpdateClusterConfigurationOutput) SetClusterArn ¶
func (s *UpdateClusterConfigurationOutput) SetClusterArn(v string) *UpdateClusterConfigurationOutput
SetClusterArn sets the ClusterArn field's value.
func (*UpdateClusterConfigurationOutput) SetClusterOperationArn ¶
func (s *UpdateClusterConfigurationOutput) SetClusterOperationArn(v string) *UpdateClusterConfigurationOutput
SetClusterOperationArn sets the ClusterOperationArn field's value.
func (UpdateClusterConfigurationOutput) String ¶
func (s UpdateClusterConfigurationOutput) String() string
String returns the string representation
type ZookeeperNodeInfo ¶
type ZookeeperNodeInfo struct { // The attached elastic network interface of the broker. AttachedENIId *string `locationName:"attachedENIId" type:"string"` // The virtual private cloud (VPC) IP address of the client. ClientVpcIpAddress *string `locationName:"clientVpcIpAddress" type:"string"` // Endpoints for accessing the ZooKeeper. Endpoints []*string `locationName:"endpoints" type:"list"` // The role-specific ID for Zookeeper. ZookeeperId *float64 `locationName:"zookeeperId" type:"double"` // The version of Zookeeper. ZookeeperVersion *string `locationName:"zookeeperVersion" type:"string"` // contains filtered or unexported fields }
Zookeeper node information.
func (ZookeeperNodeInfo) GoString ¶
func (s ZookeeperNodeInfo) GoString() string
GoString returns the string representation
func (*ZookeeperNodeInfo) SetAttachedENIId ¶
func (s *ZookeeperNodeInfo) SetAttachedENIId(v string) *ZookeeperNodeInfo
SetAttachedENIId sets the AttachedENIId field's value.
func (*ZookeeperNodeInfo) SetClientVpcIpAddress ¶
func (s *ZookeeperNodeInfo) SetClientVpcIpAddress(v string) *ZookeeperNodeInfo
SetClientVpcIpAddress sets the ClientVpcIpAddress field's value.
func (*ZookeeperNodeInfo) SetEndpoints ¶
func (s *ZookeeperNodeInfo) SetEndpoints(v []*string) *ZookeeperNodeInfo
SetEndpoints sets the Endpoints field's value.
func (*ZookeeperNodeInfo) SetZookeeperId ¶
func (s *ZookeeperNodeInfo) SetZookeeperId(v float64) *ZookeeperNodeInfo
SetZookeeperId sets the ZookeeperId field's value.
func (*ZookeeperNodeInfo) SetZookeeperVersion ¶
func (s *ZookeeperNodeInfo) SetZookeeperVersion(v string) *ZookeeperNodeInfo
SetZookeeperVersion sets the ZookeeperVersion field's value.
func (ZookeeperNodeInfo) String ¶
func (s ZookeeperNodeInfo) String() string
String returns the string representation
Directories ¶
Path | Synopsis |
---|---|
Package kafkaiface provides an interface to enable mocking the Managed Streaming for Kafka service client for testing your code.
|
Package kafkaiface provides an interface to enable mocking the Managed Streaming for Kafka service client for testing your code. |