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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
func (s BrokerEBSVolumeInfo) GoString() string
GoString returns the string representation
func (*BrokerEBSVolumeInfo) SetKafkaBrokerNodeId ¶ added in v1.19.41
func (s *BrokerEBSVolumeInfo) SetKafkaBrokerNodeId(v string) *BrokerEBSVolumeInfo
SetKafkaBrokerNodeId sets the KafkaBrokerNodeId field's value.
func (*BrokerEBSVolumeInfo) SetVolumeSizeGB ¶ added in v1.19.41
func (s *BrokerEBSVolumeInfo) SetVolumeSizeGB(v int64) *BrokerEBSVolumeInfo
SetVolumeSizeGB sets the VolumeSizeGB field's value.
func (BrokerEBSVolumeInfo) String ¶ added in v1.19.41
func (s BrokerEBSVolumeInfo) String() string
String returns the string representation
func (*BrokerEBSVolumeInfo) Validate ¶ added in v1.19.41
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
func (s ClientAuthentication) GoString() string
GoString returns the string representation
func (*ClientAuthentication) SetTls ¶ added in v1.19.41
func (s *ClientAuthentication) SetTls(v *Tls) *ClientAuthentication
SetTls sets the Tls field's value.
func (ClientAuthentication) String ¶ added in v1.19.41
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
func (s ClusterOperationInfo) GoString() string
GoString returns the string representation
func (*ClusterOperationInfo) SetClientRequestId ¶ added in v1.19.41
func (s *ClusterOperationInfo) SetClientRequestId(v string) *ClusterOperationInfo
SetClientRequestId sets the ClientRequestId field's value.
func (*ClusterOperationInfo) SetClusterArn ¶ added in v1.19.41
func (s *ClusterOperationInfo) SetClusterArn(v string) *ClusterOperationInfo
SetClusterArn sets the ClusterArn field's value.
func (*ClusterOperationInfo) SetCreationTime ¶ added in v1.19.41
func (s *ClusterOperationInfo) SetCreationTime(v time.Time) *ClusterOperationInfo
SetCreationTime sets the CreationTime field's value.
func (*ClusterOperationInfo) SetEndTime ¶ added in v1.19.41
func (s *ClusterOperationInfo) SetEndTime(v time.Time) *ClusterOperationInfo
SetEndTime sets the EndTime field's value.
func (*ClusterOperationInfo) SetErrorInfo ¶ added in v1.19.41
func (s *ClusterOperationInfo) SetErrorInfo(v *ErrorInfo) *ClusterOperationInfo
SetErrorInfo sets the ErrorInfo field's value.
func (*ClusterOperationInfo) SetOperationArn ¶ added in v1.19.41
func (s *ClusterOperationInfo) SetOperationArn(v string) *ClusterOperationInfo
SetOperationArn sets the OperationArn field's value.
func (*ClusterOperationInfo) SetOperationState ¶ added in v1.19.41
func (s *ClusterOperationInfo) SetOperationState(v string) *ClusterOperationInfo
SetOperationState sets the OperationState field's value.
func (*ClusterOperationInfo) SetOperationType ¶ added in v1.19.41
func (s *ClusterOperationInfo) SetOperationType(v string) *ClusterOperationInfo
SetOperationType sets the OperationType field's value.
func (*ClusterOperationInfo) SetSourceClusterInfo ¶ added in v1.19.41
func (s *ClusterOperationInfo) SetSourceClusterInfo(v *MutableClusterInfo) *ClusterOperationInfo
SetSourceClusterInfo sets the SourceClusterInfo field's value.
func (*ClusterOperationInfo) SetTargetClusterInfo ¶ added in v1.19.41
func (s *ClusterOperationInfo) SetTargetClusterInfo(v *MutableClusterInfo) *ClusterOperationInfo
SetTargetClusterInfo sets the TargetClusterInfo field's value.
func (ClusterOperationInfo) String ¶ added in v1.19.41
func (s ClusterOperationInfo) String() string
String returns the string representation
type Configuration ¶ added in v1.19.34
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 ¶ added in v1.19.34
func (s Configuration) GoString() string
GoString returns the string representation
func (*Configuration) SetArn ¶ added in v1.19.34
func (s *Configuration) SetArn(v string) *Configuration
SetArn sets the Arn field's value.
func (*Configuration) SetCreationTime ¶ added in v1.19.34
func (s *Configuration) SetCreationTime(v time.Time) *Configuration
SetCreationTime sets the CreationTime field's value.
func (*Configuration) SetDescription ¶ added in v1.19.34
func (s *Configuration) SetDescription(v string) *Configuration
SetDescription sets the Description field's value.
func (*Configuration) SetKafkaVersions ¶ added in v1.19.34
func (s *Configuration) SetKafkaVersions(v []*string) *Configuration
SetKafkaVersions sets the KafkaVersions field's value.
func (*Configuration) SetLatestRevision ¶ added in v1.19.34
func (s *Configuration) SetLatestRevision(v *ConfigurationRevision) *Configuration
SetLatestRevision sets the LatestRevision field's value.
func (*Configuration) SetName ¶ added in v1.19.34
func (s *Configuration) SetName(v string) *Configuration
SetName sets the Name field's value.
func (Configuration) String ¶ added in v1.19.34
func (s Configuration) String() string
String returns the string representation
type ConfigurationInfo ¶ added in v1.19.34
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 ¶ added in v1.19.34
func (s ConfigurationInfo) GoString() string
GoString returns the string representation
func (*ConfigurationInfo) SetArn ¶ added in v1.19.34
func (s *ConfigurationInfo) SetArn(v string) *ConfigurationInfo
SetArn sets the Arn field's value.
func (*ConfigurationInfo) SetRevision ¶ added in v1.19.34
func (s *ConfigurationInfo) SetRevision(v int64) *ConfigurationInfo
SetRevision sets the Revision field's value.
func (ConfigurationInfo) String ¶ added in v1.19.34
func (s ConfigurationInfo) String() string
String returns the string representation
func (*ConfigurationInfo) Validate ¶ added in v1.19.34
func (s *ConfigurationInfo) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ConfigurationRevision ¶ added in v1.19.34
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 ¶ added in v1.19.34
func (s ConfigurationRevision) GoString() string
GoString returns the string representation
func (*ConfigurationRevision) SetCreationTime ¶ added in v1.19.34
func (s *ConfigurationRevision) SetCreationTime(v time.Time) *ConfigurationRevision
SetCreationTime sets the CreationTime field's value.
func (*ConfigurationRevision) SetDescription ¶ added in v1.19.34
func (s *ConfigurationRevision) SetDescription(v string) *ConfigurationRevision
SetDescription sets the Description field's value.
func (*ConfigurationRevision) SetRevision ¶ added in v1.19.34
func (s *ConfigurationRevision) SetRevision(v int64) *ConfigurationRevision
SetRevision sets the Revision field's value.
func (ConfigurationRevision) String ¶ added in v1.19.34
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 ¶ added in v1.19.41
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 ¶ added in v1.19.34
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 ¶ added in v1.19.41
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 ¶ added in v1.19.34
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 ¶ added in v1.19.34
func (s CreateConfigurationInput) GoString() string
GoString returns the string representation
func (*CreateConfigurationInput) SetDescription ¶ added in v1.19.34
func (s *CreateConfigurationInput) SetDescription(v string) *CreateConfigurationInput
SetDescription sets the Description field's value.
func (*CreateConfigurationInput) SetKafkaVersions ¶ added in v1.19.34
func (s *CreateConfigurationInput) SetKafkaVersions(v []*string) *CreateConfigurationInput
SetKafkaVersions sets the KafkaVersions field's value.
func (*CreateConfigurationInput) SetName ¶ added in v1.19.34
func (s *CreateConfigurationInput) SetName(v string) *CreateConfigurationInput
SetName sets the Name field's value.
func (*CreateConfigurationInput) SetServerProperties ¶ added in v1.19.34
func (s *CreateConfigurationInput) SetServerProperties(v []byte) *CreateConfigurationInput
SetServerProperties sets the ServerProperties field's value.
func (CreateConfigurationInput) String ¶ added in v1.19.34
func (s CreateConfigurationInput) String() string
String returns the string representation
func (*CreateConfigurationInput) Validate ¶ added in v1.19.34
func (s *CreateConfigurationInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type CreateConfigurationOutput ¶ added in v1.19.34
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 ¶ added in v1.19.34
func (s CreateConfigurationOutput) GoString() string
GoString returns the string representation
func (*CreateConfigurationOutput) SetArn ¶ added in v1.19.34
func (s *CreateConfigurationOutput) SetArn(v string) *CreateConfigurationOutput
SetArn sets the Arn field's value.
func (*CreateConfigurationOutput) SetCreationTime ¶ added in v1.19.34
func (s *CreateConfigurationOutput) SetCreationTime(v time.Time) *CreateConfigurationOutput
SetCreationTime sets the CreationTime field's value.
func (*CreateConfigurationOutput) SetLatestRevision ¶ added in v1.19.34
func (s *CreateConfigurationOutput) SetLatestRevision(v *ConfigurationRevision) *CreateConfigurationOutput
SetLatestRevision sets the LatestRevision field's value.
func (*CreateConfigurationOutput) SetName ¶ added in v1.19.34
func (s *CreateConfigurationOutput) SetName(v string) *CreateConfigurationOutput
SetName sets the Name field's value.
func (CreateConfigurationOutput) String ¶ added in v1.19.34
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
func (s DescribeClusterOperationInput) GoString() string
GoString returns the string representation
func (*DescribeClusterOperationInput) SetClusterOperationArn ¶ added in v1.19.41
func (s *DescribeClusterOperationInput) SetClusterOperationArn(v string) *DescribeClusterOperationInput
SetClusterOperationArn sets the ClusterOperationArn field's value.
func (DescribeClusterOperationInput) String ¶ added in v1.19.41
func (s DescribeClusterOperationInput) String() string
String returns the string representation
func (*DescribeClusterOperationInput) Validate ¶ added in v1.19.41
func (s *DescribeClusterOperationInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DescribeClusterOperationOutput ¶ added in v1.19.41
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 ¶ added in v1.19.41
func (s DescribeClusterOperationOutput) GoString() string
GoString returns the string representation
func (*DescribeClusterOperationOutput) SetClusterOperationInfo ¶ added in v1.19.41
func (s *DescribeClusterOperationOutput) SetClusterOperationInfo(v *ClusterOperationInfo) *DescribeClusterOperationOutput
SetClusterOperationInfo sets the ClusterOperationInfo field's value.
func (DescribeClusterOperationOutput) String ¶ added in v1.19.41
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 ¶ added in v1.19.34
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 ¶ added in v1.19.34
func (s DescribeConfigurationInput) GoString() string
GoString returns the string representation
func (*DescribeConfigurationInput) SetArn ¶ added in v1.19.34
func (s *DescribeConfigurationInput) SetArn(v string) *DescribeConfigurationInput
SetArn sets the Arn field's value.
func (DescribeConfigurationInput) String ¶ added in v1.19.34
func (s DescribeConfigurationInput) String() string
String returns the string representation
func (*DescribeConfigurationInput) Validate ¶ added in v1.19.34
func (s *DescribeConfigurationInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DescribeConfigurationOutput ¶ added in v1.19.34
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 ¶ added in v1.19.34
func (s DescribeConfigurationOutput) GoString() string
GoString returns the string representation
func (*DescribeConfigurationOutput) SetArn ¶ added in v1.19.34
func (s *DescribeConfigurationOutput) SetArn(v string) *DescribeConfigurationOutput
SetArn sets the Arn field's value.
func (*DescribeConfigurationOutput) SetCreationTime ¶ added in v1.19.34
func (s *DescribeConfigurationOutput) SetCreationTime(v time.Time) *DescribeConfigurationOutput
SetCreationTime sets the CreationTime field's value.
func (*DescribeConfigurationOutput) SetDescription ¶ added in v1.19.34
func (s *DescribeConfigurationOutput) SetDescription(v string) *DescribeConfigurationOutput
SetDescription sets the Description field's value.
func (*DescribeConfigurationOutput) SetKafkaVersions ¶ added in v1.19.34
func (s *DescribeConfigurationOutput) SetKafkaVersions(v []*string) *DescribeConfigurationOutput
SetKafkaVersions sets the KafkaVersions field's value.
func (*DescribeConfigurationOutput) SetLatestRevision ¶ added in v1.19.34
func (s *DescribeConfigurationOutput) SetLatestRevision(v *ConfigurationRevision) *DescribeConfigurationOutput
SetLatestRevision sets the LatestRevision field's value.
func (*DescribeConfigurationOutput) SetName ¶ added in v1.19.34
func (s *DescribeConfigurationOutput) SetName(v string) *DescribeConfigurationOutput
SetName sets the Name field's value.
func (DescribeConfigurationOutput) String ¶ added in v1.19.34
func (s DescribeConfigurationOutput) String() string
String returns the string representation
type DescribeConfigurationRevisionInput ¶ added in v1.19.34
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 ¶ added in v1.19.34
func (s DescribeConfigurationRevisionInput) GoString() string
GoString returns the string representation
func (*DescribeConfigurationRevisionInput) SetArn ¶ added in v1.19.34
func (s *DescribeConfigurationRevisionInput) SetArn(v string) *DescribeConfigurationRevisionInput
SetArn sets the Arn field's value.
func (*DescribeConfigurationRevisionInput) SetRevision ¶ added in v1.19.34
func (s *DescribeConfigurationRevisionInput) SetRevision(v int64) *DescribeConfigurationRevisionInput
SetRevision sets the Revision field's value.
func (DescribeConfigurationRevisionInput) String ¶ added in v1.19.34
func (s DescribeConfigurationRevisionInput) String() string
String returns the string representation
func (*DescribeConfigurationRevisionInput) Validate ¶ added in v1.19.34
func (s *DescribeConfigurationRevisionInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DescribeConfigurationRevisionOutput ¶ added in v1.19.34
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 ¶ added in v1.19.34
func (s DescribeConfigurationRevisionOutput) GoString() string
GoString returns the string representation
func (*DescribeConfigurationRevisionOutput) SetArn ¶ added in v1.19.34
func (s *DescribeConfigurationRevisionOutput) SetArn(v string) *DescribeConfigurationRevisionOutput
SetArn sets the Arn field's value.
func (*DescribeConfigurationRevisionOutput) SetCreationTime ¶ added in v1.19.34
func (s *DescribeConfigurationRevisionOutput) SetCreationTime(v time.Time) *DescribeConfigurationRevisionOutput
SetCreationTime sets the CreationTime field's value.
func (*DescribeConfigurationRevisionOutput) SetDescription ¶ added in v1.19.34
func (s *DescribeConfigurationRevisionOutput) SetDescription(v string) *DescribeConfigurationRevisionOutput
SetDescription sets the Description field's value.
func (*DescribeConfigurationRevisionOutput) SetRevision ¶ added in v1.19.34
func (s *DescribeConfigurationRevisionOutput) SetRevision(v int64) *DescribeConfigurationRevisionOutput
SetRevision sets the Revision field's value.
func (*DescribeConfigurationRevisionOutput) SetServerProperties ¶ added in v1.19.34
func (s *DescribeConfigurationRevisionOutput) SetServerProperties(v []byte) *DescribeConfigurationRevisionOutput
SetServerProperties sets the ServerProperties field's value.
func (DescribeConfigurationRevisionOutput) String ¶ added in v1.19.34
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
func (s EncryptionInTransit) GoString() string
GoString returns the string representation
func (*EncryptionInTransit) SetClientBroker ¶ added in v1.19.41
func (s *EncryptionInTransit) SetClientBroker(v string) *EncryptionInTransit
SetClientBroker sets the ClientBroker field's value.
func (*EncryptionInTransit) SetInCluster ¶ added in v1.19.41
func (s *EncryptionInTransit) SetInCluster(v bool) *EncryptionInTransit
SetInCluster sets the InCluster field's value.
func (EncryptionInTransit) String ¶ added in v1.19.41
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
SetErrorCode sets the ErrorCode field's value.
func (*ErrorInfo) SetErrorString ¶ added in v1.19.41
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 ¶ added in v1.19.41
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 ¶ added in v1.19.34
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 ¶ added in v1.19.34
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 ¶ added in v1.19.34
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
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 ¶ added in v1.19.34
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 ¶ added in v1.19.34
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 ¶ added in v1.19.34
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 ¶ added in v1.19.34
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 ¶ added in v1.19.34
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 ¶ added in v1.19.34
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
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 ¶ added in v1.19.34
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 ¶ added in v1.19.34
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
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 ¶ added in v1.19.34
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 ¶ added in v1.19.34
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 ¶ added in v1.19.34
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 ¶ added in v1.19.34
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 ¶ added in v1.19.34
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 ¶ added in v1.19.34
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 ¶ added in v1.19.34
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 ¶ added in v1.19.14
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 ¶ added in v1.19.14
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 ¶ added in v1.19.14
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 ¶ added in v1.19.14
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 ¶ added in v1.19.14
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 ¶ added in v1.19.14
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 ¶ added in v1.19.14
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 ¶ added in v1.19.14
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 ¶ added in v1.19.14
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
func (s ListClusterOperationsInput) GoString() string
GoString returns the string representation
func (*ListClusterOperationsInput) SetClusterArn ¶ added in v1.19.41
func (s *ListClusterOperationsInput) SetClusterArn(v string) *ListClusterOperationsInput
SetClusterArn sets the ClusterArn field's value.
func (*ListClusterOperationsInput) SetMaxResults ¶ added in v1.19.41
func (s *ListClusterOperationsInput) SetMaxResults(v int64) *ListClusterOperationsInput
SetMaxResults sets the MaxResults field's value.
func (*ListClusterOperationsInput) SetNextToken ¶ added in v1.19.41
func (s *ListClusterOperationsInput) SetNextToken(v string) *ListClusterOperationsInput
SetNextToken sets the NextToken field's value.
func (ListClusterOperationsInput) String ¶ added in v1.19.41
func (s ListClusterOperationsInput) String() string
String returns the string representation
func (*ListClusterOperationsInput) Validate ¶ added in v1.19.41
func (s *ListClusterOperationsInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListClusterOperationsOutput ¶ added in v1.19.41
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 ¶ added in v1.19.41
func (s ListClusterOperationsOutput) GoString() string
GoString returns the string representation
func (*ListClusterOperationsOutput) SetClusterOperationInfoList ¶ added in v1.19.41
func (s *ListClusterOperationsOutput) SetClusterOperationInfoList(v []*ClusterOperationInfo) *ListClusterOperationsOutput
SetClusterOperationInfoList sets the ClusterOperationInfoList field's value.
func (*ListClusterOperationsOutput) SetNextToken ¶ added in v1.19.41
func (s *ListClusterOperationsOutput) SetNextToken(v string) *ListClusterOperationsOutput
SetNextToken sets the NextToken field's value.
func (ListClusterOperationsOutput) String ¶ added in v1.19.41
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 ¶ added in v1.19.41
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 ¶ added in v1.19.41
func (s ListConfigurationRevisionsInput) GoString() string
GoString returns the string representation
func (*ListConfigurationRevisionsInput) SetArn ¶ added in v1.19.41
func (s *ListConfigurationRevisionsInput) SetArn(v string) *ListConfigurationRevisionsInput
SetArn sets the Arn field's value.
func (*ListConfigurationRevisionsInput) SetMaxResults ¶ added in v1.19.41
func (s *ListConfigurationRevisionsInput) SetMaxResults(v int64) *ListConfigurationRevisionsInput
SetMaxResults sets the MaxResults field's value.
func (*ListConfigurationRevisionsInput) SetNextToken ¶ added in v1.19.41
func (s *ListConfigurationRevisionsInput) SetNextToken(v string) *ListConfigurationRevisionsInput
SetNextToken sets the NextToken field's value.
func (ListConfigurationRevisionsInput) String ¶ added in v1.19.41
func (s ListConfigurationRevisionsInput) String() string
String returns the string representation
func (*ListConfigurationRevisionsInput) Validate ¶ added in v1.19.41
func (s *ListConfigurationRevisionsInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListConfigurationRevisionsOutput ¶ added in v1.19.41
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 ¶ added in v1.19.41
func (s ListConfigurationRevisionsOutput) GoString() string
GoString returns the string representation
func (*ListConfigurationRevisionsOutput) SetNextToken ¶ added in v1.19.41
func (s *ListConfigurationRevisionsOutput) SetNextToken(v string) *ListConfigurationRevisionsOutput
SetNextToken sets the NextToken field's value.
func (*ListConfigurationRevisionsOutput) SetRevisions ¶ added in v1.19.41
func (s *ListConfigurationRevisionsOutput) SetRevisions(v []*ConfigurationRevision) *ListConfigurationRevisionsOutput
SetRevisions sets the Revisions field's value.
func (ListConfigurationRevisionsOutput) String ¶ added in v1.19.41
func (s ListConfigurationRevisionsOutput) String() string
String returns the string representation
type ListConfigurationsInput ¶ added in v1.19.34
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 ¶ added in v1.19.34
func (s ListConfigurationsInput) GoString() string
GoString returns the string representation
func (*ListConfigurationsInput) SetMaxResults ¶ added in v1.19.34
func (s *ListConfigurationsInput) SetMaxResults(v int64) *ListConfigurationsInput
SetMaxResults sets the MaxResults field's value.
func (*ListConfigurationsInput) SetNextToken ¶ added in v1.19.34
func (s *ListConfigurationsInput) SetNextToken(v string) *ListConfigurationsInput
SetNextToken sets the NextToken field's value.
func (ListConfigurationsInput) String ¶ added in v1.19.34
func (s ListConfigurationsInput) String() string
String returns the string representation
func (*ListConfigurationsInput) Validate ¶ added in v1.19.41
func (s *ListConfigurationsInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListConfigurationsOutput ¶ added in v1.19.34
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 ¶ added in v1.19.34
func (s ListConfigurationsOutput) GoString() string
GoString returns the string representation
func (*ListConfigurationsOutput) SetConfigurations ¶ added in v1.19.34
func (s *ListConfigurationsOutput) SetConfigurations(v []*Configuration) *ListConfigurationsOutput
SetConfigurations sets the Configurations field's value.
func (*ListConfigurationsOutput) SetNextToken ¶ added in v1.19.34
func (s *ListConfigurationsOutput) SetNextToken(v string) *ListConfigurationsOutput
SetNextToken sets the NextToken field's value.
func (ListConfigurationsOutput) String ¶ added in v1.19.34
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 ¶ added in v1.19.14
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 ¶ added in v1.19.14
func (s ListTagsForResourceInput) GoString() string
GoString returns the string representation
func (*ListTagsForResourceInput) SetResourceArn ¶ added in v1.19.14
func (s *ListTagsForResourceInput) SetResourceArn(v string) *ListTagsForResourceInput
SetResourceArn sets the ResourceArn field's value.
func (ListTagsForResourceInput) String ¶ added in v1.19.14
func (s ListTagsForResourceInput) String() string
String returns the string representation
func (*ListTagsForResourceInput) Validate ¶ added in v1.19.14
func (s *ListTagsForResourceInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListTagsForResourceOutput ¶ added in v1.19.14
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 ¶ added in v1.19.14
func (s ListTagsForResourceOutput) GoString() string
GoString returns the string representation
func (*ListTagsForResourceOutput) SetTags ¶ added in v1.19.14
func (s *ListTagsForResourceOutput) SetTags(v map[string]*string) *ListTagsForResourceOutput
SetTags sets the Tags field's value.
func (ListTagsForResourceOutput) String ¶ added in v1.19.14
func (s ListTagsForResourceOutput) String() string
String returns the string representation
type MutableClusterInfo ¶ added in v1.19.41
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 ¶ added in v1.19.41
func (s MutableClusterInfo) GoString() string
GoString returns the string representation
func (*MutableClusterInfo) SetBrokerEBSVolumeInfo ¶ added in v1.19.41
func (s *MutableClusterInfo) SetBrokerEBSVolumeInfo(v []*BrokerEBSVolumeInfo) *MutableClusterInfo
SetBrokerEBSVolumeInfo sets the BrokerEBSVolumeInfo field's value.
func (*MutableClusterInfo) SetConfigurationInfo ¶ added in v1.19.41
func (s *MutableClusterInfo) SetConfigurationInfo(v *ConfigurationInfo) *MutableClusterInfo
SetConfigurationInfo sets the ConfigurationInfo field's value.
func (*MutableClusterInfo) SetNumberOfBrokerNodes ¶ added in v1.19.41
func (s *MutableClusterInfo) SetNumberOfBrokerNodes(v int64) *MutableClusterInfo
SetNumberOfBrokerNodes sets the NumberOfBrokerNodes field's value.
func (MutableClusterInfo) String ¶ added in v1.19.41
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 ¶ added in v1.19.14
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 ¶ added in v1.19.14
func (s TagResourceInput) GoString() string
GoString returns the string representation
func (*TagResourceInput) SetResourceArn ¶ added in v1.19.14
func (s *TagResourceInput) SetResourceArn(v string) *TagResourceInput
SetResourceArn sets the ResourceArn field's value.
func (*TagResourceInput) SetTags ¶ added in v1.19.14
func (s *TagResourceInput) SetTags(v map[string]*string) *TagResourceInput
SetTags sets the Tags field's value.
func (TagResourceInput) String ¶ added in v1.19.14
func (s TagResourceInput) String() string
String returns the string representation
func (*TagResourceInput) Validate ¶ added in v1.19.14
func (s *TagResourceInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type TagResourceOutput ¶ added in v1.19.14
type TagResourceOutput struct {
// contains filtered or unexported fields
}
func (TagResourceOutput) GoString ¶ added in v1.19.14
func (s TagResourceOutput) GoString() string
GoString returns the string representation
func (TagResourceOutput) String ¶ added in v1.19.14
func (s TagResourceOutput) String() string
String returns the string representation
type Tls ¶ added in v1.19.41
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 ¶ added in v1.19.41
SetCertificateAuthorityArnList sets the CertificateAuthorityArnList field's value.
type UntagResourceInput ¶ added in v1.19.14
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 ¶ added in v1.19.14
func (s UntagResourceInput) GoString() string
GoString returns the string representation
func (*UntagResourceInput) SetResourceArn ¶ added in v1.19.14
func (s *UntagResourceInput) SetResourceArn(v string) *UntagResourceInput
SetResourceArn sets the ResourceArn field's value.
func (*UntagResourceInput) SetTagKeys ¶ added in v1.19.14
func (s *UntagResourceInput) SetTagKeys(v []*string) *UntagResourceInput
SetTagKeys sets the TagKeys field's value.
func (UntagResourceInput) String ¶ added in v1.19.14
func (s UntagResourceInput) String() string
String returns the string representation
func (*UntagResourceInput) Validate ¶ added in v1.19.14
func (s *UntagResourceInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type UntagResourceOutput ¶ added in v1.19.14
type UntagResourceOutput struct {
// contains filtered or unexported fields
}
func (UntagResourceOutput) GoString ¶ added in v1.19.14
func (s UntagResourceOutput) GoString() string
GoString returns the string representation
func (UntagResourceOutput) String ¶ added in v1.19.14
func (s UntagResourceOutput) String() string
String returns the string representation
type UpdateBrokerStorageInput ¶ added in v1.19.41
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 ¶ added in v1.19.41
func (s UpdateBrokerStorageInput) GoString() string
GoString returns the string representation
func (*UpdateBrokerStorageInput) SetClusterArn ¶ added in v1.19.41
func (s *UpdateBrokerStorageInput) SetClusterArn(v string) *UpdateBrokerStorageInput
SetClusterArn sets the ClusterArn field's value.
func (*UpdateBrokerStorageInput) SetCurrentVersion ¶ added in v1.19.41
func (s *UpdateBrokerStorageInput) SetCurrentVersion(v string) *UpdateBrokerStorageInput
SetCurrentVersion sets the CurrentVersion field's value.
func (*UpdateBrokerStorageInput) SetTargetBrokerEBSVolumeInfo ¶ added in v1.19.41
func (s *UpdateBrokerStorageInput) SetTargetBrokerEBSVolumeInfo(v []*BrokerEBSVolumeInfo) *UpdateBrokerStorageInput
SetTargetBrokerEBSVolumeInfo sets the TargetBrokerEBSVolumeInfo field's value.
func (UpdateBrokerStorageInput) String ¶ added in v1.19.41
func (s UpdateBrokerStorageInput) String() string
String returns the string representation
func (*UpdateBrokerStorageInput) Validate ¶ added in v1.19.41
func (s *UpdateBrokerStorageInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type UpdateBrokerStorageOutput ¶ added in v1.19.41
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 ¶ added in v1.19.41
func (s UpdateBrokerStorageOutput) GoString() string
GoString returns the string representation
func (*UpdateBrokerStorageOutput) SetClusterArn ¶ added in v1.19.41
func (s *UpdateBrokerStorageOutput) SetClusterArn(v string) *UpdateBrokerStorageOutput
SetClusterArn sets the ClusterArn field's value.
func (*UpdateBrokerStorageOutput) SetClusterOperationArn ¶ added in v1.19.41
func (s *UpdateBrokerStorageOutput) SetClusterOperationArn(v string) *UpdateBrokerStorageOutput
SetClusterOperationArn sets the ClusterOperationArn field's value.
func (UpdateBrokerStorageOutput) String ¶ added in v1.19.41
func (s UpdateBrokerStorageOutput) String() string
String returns the string representation
type UpdateClusterConfigurationInput ¶ added in v1.19.41
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 ¶ added in v1.19.41
func (s UpdateClusterConfigurationInput) GoString() string
GoString returns the string representation
func (*UpdateClusterConfigurationInput) SetClusterArn ¶ added in v1.19.41
func (s *UpdateClusterConfigurationInput) SetClusterArn(v string) *UpdateClusterConfigurationInput
SetClusterArn sets the ClusterArn field's value.
func (*UpdateClusterConfigurationInput) SetConfigurationInfo ¶ added in v1.19.41
func (s *UpdateClusterConfigurationInput) SetConfigurationInfo(v *ConfigurationInfo) *UpdateClusterConfigurationInput
SetConfigurationInfo sets the ConfigurationInfo field's value.
func (*UpdateClusterConfigurationInput) SetCurrentVersion ¶ added in v1.19.41
func (s *UpdateClusterConfigurationInput) SetCurrentVersion(v string) *UpdateClusterConfigurationInput
SetCurrentVersion sets the CurrentVersion field's value.
func (UpdateClusterConfigurationInput) String ¶ added in v1.19.41
func (s UpdateClusterConfigurationInput) String() string
String returns the string representation
func (*UpdateClusterConfigurationInput) Validate ¶ added in v1.19.41
func (s *UpdateClusterConfigurationInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type UpdateClusterConfigurationOutput ¶ added in v1.19.41
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 ¶ added in v1.19.41
func (s UpdateClusterConfigurationOutput) GoString() string
GoString returns the string representation
func (*UpdateClusterConfigurationOutput) SetClusterArn ¶ added in v1.19.41
func (s *UpdateClusterConfigurationOutput) SetClusterArn(v string) *UpdateClusterConfigurationOutput
SetClusterArn sets the ClusterArn field's value.
func (*UpdateClusterConfigurationOutput) SetClusterOperationArn ¶ added in v1.19.41
func (s *UpdateClusterConfigurationOutput) SetClusterOperationArn(v string) *UpdateClusterConfigurationOutput
SetClusterOperationArn sets the ClusterOperationArn field's value.
func (UpdateClusterConfigurationOutput) String ¶ added in v1.19.41
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 ¶ added in v1.19.41
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. |