package kafka

import "github.com/aws/aws-sdk-go-v2/service/kafka"

Package kafka provides the client and types for making API requests to 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 use 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 Kafka client for more information on creating client for this service. https://docs.aws.amazon.com/sdk-for-go/api/service/kafka/#New

Index

Constants 

const (
	ServiceName = "Kafka" // Service's name
	ServiceID   = "Kafka" // Service's identifier
	EndpointsID = "kafka" // Service's Endpoint identifier
)
const (

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

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

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

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

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

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

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

	// ErrCodeUnauthorizedException for service response error code
	// "UnauthorizedException".
	//
	// Returns information about an error.
	ErrCodeUnauthorizedException = "UnauthorizedException"
)

Types

type Authentication 

type Authentication struct {

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

Includes all client authentication information. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ClientAuthentication

func (Authentication) MarshalFields 

func (s Authentication) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (Authentication) String 

func (s Authentication) String() string

String returns the string representation

type Broker 

type Broker string

Client-broker encryption in transit setting. 

const (
	BrokerTls          Broker = "TLS"
	BrokerTlsPlaintext Broker = "TLS_PLAINTEXT"
	BrokerPlaintext    Broker = "PLAINTEXT"
)

Enum values for Broker

func (Broker) MarshalValue 

func (enum Broker) MarshalValue() (string, error)

func (Broker) MarshalValueBuf 

func (enum Broker) MarshalValueBuf(b []byte) ([]byte, error)

type BrokerAZDistribution 

type BrokerAZDistribution string

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 (
	BrokerAZDistributionDefault BrokerAZDistribution = "DEFAULT"
)

Enum values for BrokerAZDistribution

func (BrokerAZDistribution) MarshalValue 

func (enum BrokerAZDistribution) MarshalValue() (string, error)

func (BrokerAZDistribution) MarshalValueBuf 

func (enum BrokerAZDistribution) MarshalValueBuf(b []byte) ([]byte, error)

type BrokerEBSVolumeInfo 

type BrokerEBSVolumeInfo struct {

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

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

Specifies the EBS volume upgrade information. The broker identifier must be set to the keyword ALL. This means the changes apply to all the brokers in the cluster. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/BrokerEBSVolumeInfo

func (BrokerEBSVolumeInfo) MarshalFields 

func (s BrokerEBSVolumeInfo) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (BrokerEBSVolumeInfo) String 

func (s BrokerEBSVolumeInfo) String() string

String returns the string representation

func (*BrokerEBSVolumeInfo) Validate 

func (s *BrokerEBSVolumeInfo) Validate() error

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

type BrokerNodeGroupInfo 

type BrokerNodeGroupInfo struct {

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

	// 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. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/BrokerNodeGroupInfo

func (BrokerNodeGroupInfo) MarshalFields 

func (s BrokerNodeGroupInfo) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

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 Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/BrokerNodeInfo

func (BrokerNodeInfo) MarshalFields 

func (s BrokerNodeInfo) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

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. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/BrokerSoftwareInfo

func (BrokerSoftwareInfo) MarshalFields 

func (s BrokerSoftwareInfo) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (BrokerSoftwareInfo) String 

func (s BrokerSoftwareInfo) String() string

String returns the string representation

type Client 

type Client struct {
	*aws.Client
}

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

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

func New 

func New(config aws.Config) *Client

New creates a new instance of the client from the provided Config.

Example: 

// Create a client from just a config.
svc := kafka.New(myConfig)

func (*Client) CreateClusterRequest 

func (c *Client) CreateClusterRequest(input *CreateClusterInput) CreateClusterRequest

CreateClusterRequest returns a request value for making API operation for Managed Streaming for Kafka.

Creates a new MSK cluster. 

// Example sending a request using CreateClusterRequest.
req := client.CreateClusterRequest(params)
resp, err := req.Send(context.TODO())
if err == nil {
    fmt.Println(resp)
}

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

func (*Client) CreateConfigurationRequest 

func (c *Client) CreateConfigurationRequest(input *CreateConfigurationInput) CreateConfigurationRequest

CreateConfigurationRequest returns a request value for making API operation for Managed Streaming for Kafka.

Creates a new MSK configuration. 

// Example sending a request using CreateConfigurationRequest.
req := client.CreateConfigurationRequest(params)
resp, err := req.Send(context.TODO())
if err == nil {
    fmt.Println(resp)
}

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

func (*Client) DeleteClusterRequest 

func (c *Client) DeleteClusterRequest(input *DeleteClusterInput) DeleteClusterRequest

DeleteClusterRequest returns a request value for making API operation for Managed Streaming for Kafka.

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

// Example sending a request using DeleteClusterRequest.
req := client.DeleteClusterRequest(params)
resp, err := req.Send(context.TODO())
if err == nil {
    fmt.Println(resp)
}

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

func (*Client) DescribeClusterOperationRequest 

func (c *Client) DescribeClusterOperationRequest(input *DescribeClusterOperationInput) DescribeClusterOperationRequest

DescribeClusterOperationRequest returns a request value for making API operation for Managed Streaming for Kafka.

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

// Example sending a request using DescribeClusterOperationRequest.
req := client.DescribeClusterOperationRequest(params)
resp, err := req.Send(context.TODO())
if err == nil {
    fmt.Println(resp)
}

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

func (*Client) DescribeClusterRequest 

func (c *Client) DescribeClusterRequest(input *DescribeClusterInput) DescribeClusterRequest

DescribeClusterRequest returns a request value for making API operation for Managed Streaming for Kafka.

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

// Example sending a request using DescribeClusterRequest.
req := client.DescribeClusterRequest(params)
resp, err := req.Send(context.TODO())
if err == nil {
    fmt.Println(resp)
}

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

func (*Client) DescribeConfigurationRequest 

func (c *Client) DescribeConfigurationRequest(input *DescribeConfigurationInput) DescribeConfigurationRequest

DescribeConfigurationRequest returns a request value for making API operation for Managed Streaming for Kafka.

Returns a description of this MSK configuration. 

// Example sending a request using DescribeConfigurationRequest.
req := client.DescribeConfigurationRequest(params)
resp, err := req.Send(context.TODO())
if err == nil {
    fmt.Println(resp)
}

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

func (*Client) DescribeConfigurationRevisionRequest 

func (c *Client) DescribeConfigurationRevisionRequest(input *DescribeConfigurationRevisionInput) DescribeConfigurationRevisionRequest

DescribeConfigurationRevisionRequest returns a request value for making API operation for Managed Streaming for Kafka.

Returns a description of this revision of the configuration. 

// Example sending a request using DescribeConfigurationRevisionRequest.
req := client.DescribeConfigurationRevisionRequest(params)
resp, err := req.Send(context.TODO())
if err == nil {
    fmt.Println(resp)
}

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

func (*Client) GetBootstrapBrokersRequest 

func (c *Client) GetBootstrapBrokersRequest(input *GetBootstrapBrokersInput) GetBootstrapBrokersRequest

GetBootstrapBrokersRequest returns a request value for making API operation for Managed Streaming for Kafka.

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

// Example sending a request using GetBootstrapBrokersRequest.
req := client.GetBootstrapBrokersRequest(params)
resp, err := req.Send(context.TODO())
if err == nil {
    fmt.Println(resp)
}

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

func (*Client) ListClusterOperationsRequest 

func (c *Client) ListClusterOperationsRequest(input *ListClusterOperationsInput) ListClusterOperationsRequest

ListClusterOperationsRequest returns a request value for making API operation for Managed Streaming for Kafka.

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

// Example sending a request using ListClusterOperationsRequest.
req := client.ListClusterOperationsRequest(params)
resp, err := req.Send(context.TODO())
if err == nil {
    fmt.Println(resp)
}

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

func (*Client) ListClustersRequest 

func (c *Client) ListClustersRequest(input *ListClustersInput) ListClustersRequest

ListClustersRequest returns a request value for making API operation for Managed Streaming for Kafka.

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

// Example sending a request using ListClustersRequest.
req := client.ListClustersRequest(params)
resp, err := req.Send(context.TODO())
if err == nil {
    fmt.Println(resp)
}

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

func (*Client) ListConfigurationRevisionsRequest 

func (c *Client) ListConfigurationRevisionsRequest(input *ListConfigurationRevisionsInput) ListConfigurationRevisionsRequest

ListConfigurationRevisionsRequest returns a request value for making API operation for Managed Streaming for Kafka.

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

// Example sending a request using ListConfigurationRevisionsRequest.
req := client.ListConfigurationRevisionsRequest(params)
resp, err := req.Send(context.TODO())
if err == nil {
    fmt.Println(resp)
}

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

func (*Client) ListConfigurationsRequest 

func (c *Client) ListConfigurationsRequest(input *ListConfigurationsInput) ListConfigurationsRequest

ListConfigurationsRequest returns a request value for making API operation for Managed Streaming for Kafka.

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

// Example sending a request using ListConfigurationsRequest.
req := client.ListConfigurationsRequest(params)
resp, err := req.Send(context.TODO())
if err == nil {
    fmt.Println(resp)
}

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

func (*Client) ListNodesRequest 

func (c *Client) ListNodesRequest(input *ListNodesInput) ListNodesRequest

ListNodesRequest returns a request value for making API operation for Managed Streaming for Kafka.

Returns a list of the broker nodes in the cluster. 

// Example sending a request using ListNodesRequest.
req := client.ListNodesRequest(params)
resp, err := req.Send(context.TODO())
if err == nil {
    fmt.Println(resp)
}

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

func (*Client) ListTagsForResourceRequest 

func (c *Client) ListTagsForResourceRequest(input *ListTagsForResourceInput) ListTagsForResourceRequest

ListTagsForResourceRequest returns a request value for making API operation for Managed Streaming for Kafka.

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

// Example sending a request using ListTagsForResourceRequest.
req := client.ListTagsForResourceRequest(params)
resp, err := req.Send(context.TODO())
if err == nil {
    fmt.Println(resp)
}

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

func (*Client) TagResourceRequest 

func (c *Client) TagResourceRequest(input *TagResourceInput) TagResourceRequest

TagResourceRequest returns a request value for making API operation for Managed Streaming for Kafka.

Adds tags to the specified MSK resource. 

// Example sending a request using TagResourceRequest.
req := client.TagResourceRequest(params)
resp, err := req.Send(context.TODO())
if err == nil {
    fmt.Println(resp)
}

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

func (*Client) UntagResourceRequest 

func (c *Client) UntagResourceRequest(input *UntagResourceInput) UntagResourceRequest

UntagResourceRequest returns a request value for making API operation for Managed Streaming for Kafka.

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

// Example sending a request using UntagResourceRequest.
req := client.UntagResourceRequest(params)
resp, err := req.Send(context.TODO())
if err == nil {
    fmt.Println(resp)
}

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

func (*Client) UpdateBrokerStorageRequest 

func (c *Client) UpdateBrokerStorageRequest(input *UpdateBrokerStorageInput) UpdateBrokerStorageRequest

UpdateBrokerStorageRequest returns a request value for making API operation for Managed Streaming for Kafka.

Updates the EBS storage associated with MSK brokers. 

// Example sending a request using UpdateBrokerStorageRequest.
req := client.UpdateBrokerStorageRequest(params)
resp, err := req.Send(context.TODO())
if err == nil {
    fmt.Println(resp)
}

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

func (*Client) UpdateClusterConfigurationRequest 

func (c *Client) UpdateClusterConfigurationRequest(input *UpdateClusterConfigurationInput) UpdateClusterConfigurationRequest

UpdateClusterConfigurationRequest returns a request value for making API operation for Managed Streaming for Kafka.

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

// Example sending a request using UpdateClusterConfigurationRequest.
req := client.UpdateClusterConfigurationRequest(params)
resp, err := req.Send(context.TODO())
if err == nil {
    fmt.Println(resp)
}

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

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 *Authentication `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 EnhancedMonitoring `locationName:"enhancedMonitoring" type:"string" enum:"true"`

	// 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 ClusterState `locationName:"state" type:"string" enum:"true"`

	// 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. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ClusterInfo

func (ClusterInfo) MarshalFields 

func (s ClusterInfo) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (ClusterInfo) String 

func (s ClusterInfo) String() string

String returns the string representation

type ClusterOperationInfo 

type ClusterOperationInfo struct {

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

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

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

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

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

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

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

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

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

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

Returns information about a cluster operation. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ClusterOperationInfo

func (ClusterOperationInfo) MarshalFields 

func (s ClusterOperationInfo) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (ClusterOperationInfo) String 

func (s ClusterOperationInfo) String() string

String returns the string representation

type ClusterState 

type ClusterState string

The state of a Kafka cluster. 

const (
	ClusterStateActive   ClusterState = "ACTIVE"
	ClusterStateCreating ClusterState = "CREATING"
	ClusterStateUpdating ClusterState = "UPDATING"
	ClusterStateDeleting ClusterState = "DELETING"
	ClusterStateFailed   ClusterState = "FAILED"
)

Enum values for ClusterState

func (ClusterState) MarshalValue 

func (enum ClusterState) MarshalValue() (string, error)

func (ClusterState) MarshalValueBuf 

func (enum ClusterState) MarshalValueBuf(b []byte) ([]byte, error)

type Configuration 

type Configuration struct {

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

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

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

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

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

	// The name of the configuration.
	//
	// Name is a required field
	Name *string `locationName:"name" type:"string" required:"true"`
	// contains filtered or unexported fields
}

Represents an MSK Configuration. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/Configuration

func (Configuration) MarshalFields 

func (s Configuration) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (Configuration) String 

func (s Configuration) String() string

String returns the string representation

type ConfigurationInfo 

type ConfigurationInfo struct {

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

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

Specifies the configuration to use for the brokers. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ConfigurationInfo

func (ConfigurationInfo) MarshalFields 

func (s ConfigurationInfo) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (ConfigurationInfo) String 

func (s ConfigurationInfo) String() string

String returns the string representation

func (*ConfigurationInfo) Validate 

func (s *ConfigurationInfo) Validate() error

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

type ConfigurationRevision 

type ConfigurationRevision struct {

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

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

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

Describes a configuration revision. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ConfigurationRevision

func (ConfigurationRevision) MarshalFields 

func (s ConfigurationRevision) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (ConfigurationRevision) String 

func (s ConfigurationRevision) String() string

String returns the string representation

type CreateClusterInput 

type CreateClusterInput struct {

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

	// Includes all client authentication related information.
	ClientAuthentication *Authentication `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 EnhancedMonitoring `locationName:"enhancedMonitoring" type:"string" enum:"true"`

	// 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. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/CreateClusterRequest

func (CreateClusterInput) MarshalFields 

func (s CreateClusterInput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

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 ClusterState `locationName:"state" type:"string" enum:"true"`
	// contains filtered or unexported fields
}

Returns information about the created cluster. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/CreateClusterResponse

func (CreateClusterOutput) MarshalFields 

func (s CreateClusterOutput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (CreateClusterOutput) String 

func (s CreateClusterOutput) String() string

String returns the string representation

type CreateClusterRequest 

type CreateClusterRequest struct {
	*aws.Request
	Input *CreateClusterInput
	Copy  func(*CreateClusterInput) CreateClusterRequest
}

CreateClusterRequest is the request type for the CreateCluster API operation.

func (CreateClusterRequest) Send 

func (r CreateClusterRequest) Send(ctx context.Context) (*CreateClusterResponse, error)

Send marshals and sends the CreateCluster API request.

type CreateClusterResponse 

type CreateClusterResponse struct {
	*CreateClusterOutput
	// contains filtered or unexported fields
}

CreateClusterResponse is the response type for the CreateCluster API operation.

func (*CreateClusterResponse) SDKResponseMetdata 

func (r *CreateClusterResponse) SDKResponseMetdata() *aws.Response

SDKResponseMetdata returns the response metadata for the CreateCluster request.

type CreateConfigurationInput 

type CreateConfigurationInput struct {

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

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

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

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

Request body for CreateConfiguration. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/CreateConfigurationRequest

func (CreateConfigurationInput) MarshalFields 

func (s CreateConfigurationInput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (CreateConfigurationInput) String 

func (s CreateConfigurationInput) String() string

String returns the string representation

func (*CreateConfigurationInput) Validate 

func (s *CreateConfigurationInput) Validate() error

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

type CreateConfigurationOutput 

type CreateConfigurationOutput struct {

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

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

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

	// The name of the configuration.
	Name *string `locationName:"name" type:"string"`
	// contains filtered or unexported fields
}

Response body for CreateConfiguration Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/CreateConfigurationResponse

func (CreateConfigurationOutput) MarshalFields 

func (s CreateConfigurationOutput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (CreateConfigurationOutput) String 

func (s CreateConfigurationOutput) String() string

String returns the string representation

type CreateConfigurationRequest 

type CreateConfigurationRequest struct {
	*aws.Request
	Input *CreateConfigurationInput
	Copy  func(*CreateConfigurationInput) CreateConfigurationRequest
}

CreateConfigurationRequest is the request type for the CreateConfiguration API operation.

func (CreateConfigurationRequest) Send 

func (r CreateConfigurationRequest) Send(ctx context.Context) (*CreateConfigurationResponse, error)

Send marshals and sends the CreateConfiguration API request.

type CreateConfigurationResponse 

type CreateConfigurationResponse struct {
	*CreateConfigurationOutput
	// contains filtered or unexported fields
}

CreateConfigurationResponse is the response type for the CreateConfiguration API operation.

func (*CreateConfigurationResponse) SDKResponseMetdata 

func (r *CreateConfigurationResponse) SDKResponseMetdata() *aws.Response

SDKResponseMetdata returns the response metadata for the CreateConfiguration request.

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
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DeleteClusterRequest

func (DeleteClusterInput) MarshalFields 

func (s DeleteClusterInput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

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 ClusterState `locationName:"state" type:"string" enum:"true"`
	// contains filtered or unexported fields
}

Returns information about the deleted cluster. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DeleteClusterResponse

func (DeleteClusterOutput) MarshalFields 

func (s DeleteClusterOutput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (DeleteClusterOutput) String 

func (s DeleteClusterOutput) String() string

String returns the string representation

type DeleteClusterRequest 

type DeleteClusterRequest struct {
	*aws.Request
	Input *DeleteClusterInput
	Copy  func(*DeleteClusterInput) DeleteClusterRequest
}

DeleteClusterRequest is the request type for the DeleteCluster API operation.

func (DeleteClusterRequest) Send 

func (r DeleteClusterRequest) Send(ctx context.Context) (*DeleteClusterResponse, error)

Send marshals and sends the DeleteCluster API request.

type DeleteClusterResponse 

type DeleteClusterResponse struct {
	*DeleteClusterOutput
	// contains filtered or unexported fields
}

DeleteClusterResponse is the response type for the DeleteCluster API operation.

func (*DeleteClusterResponse) SDKResponseMetdata 

func (r *DeleteClusterResponse) SDKResponseMetdata() *aws.Response

SDKResponseMetdata returns the response metadata for the DeleteCluster request.

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
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeClusterRequest

func (DescribeClusterInput) MarshalFields 

func (s DescribeClusterInput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (DescribeClusterInput) String 

func (s DescribeClusterInput) String() string

String returns the string representation

func (*DescribeClusterInput) Validate 

func (s *DescribeClusterInput) Validate() error

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

type DescribeClusterOperationInput 

type DescribeClusterOperationInput struct {

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

Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeClusterOperationRequest

func (DescribeClusterOperationInput) MarshalFields 

func (s DescribeClusterOperationInput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (DescribeClusterOperationInput) String 

func (s DescribeClusterOperationInput) String() string

String returns the string representation

func (*DescribeClusterOperationInput) Validate 

func (s *DescribeClusterOperationInput) Validate() error

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

type DescribeClusterOperationOutput 

type DescribeClusterOperationOutput struct {

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

Information about a cluster operation. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeClusterOperationResponse

func (DescribeClusterOperationOutput) MarshalFields 

func (s DescribeClusterOperationOutput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (DescribeClusterOperationOutput) String 

func (s DescribeClusterOperationOutput) String() string

String returns the string representation

type DescribeClusterOperationRequest 

type DescribeClusterOperationRequest struct {
	*aws.Request
	Input *DescribeClusterOperationInput
	Copy  func(*DescribeClusterOperationInput) DescribeClusterOperationRequest
}

DescribeClusterOperationRequest is the request type for the DescribeClusterOperation API operation.

func (DescribeClusterOperationRequest) Send 

func (r DescribeClusterOperationRequest) Send(ctx context.Context) (*DescribeClusterOperationResponse, error)

Send marshals and sends the DescribeClusterOperation API request.

type DescribeClusterOperationResponse 

type DescribeClusterOperationResponse struct {
	*DescribeClusterOperationOutput
	// contains filtered or unexported fields
}

DescribeClusterOperationResponse is the response type for the DescribeClusterOperation API operation.

func (*DescribeClusterOperationResponse) SDKResponseMetdata 

func (r *DescribeClusterOperationResponse) SDKResponseMetdata() *aws.Response

SDKResponseMetdata returns the response metadata for the DescribeClusterOperation request.

type DescribeClusterOutput 

type DescribeClusterOutput struct {

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

Returns information about a cluster. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeClusterResponse

func (DescribeClusterOutput) MarshalFields 

func (s DescribeClusterOutput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (DescribeClusterOutput) String 

func (s DescribeClusterOutput) String() string

String returns the string representation

type DescribeClusterRequest 

type DescribeClusterRequest struct {
	*aws.Request
	Input *DescribeClusterInput
	Copy  func(*DescribeClusterInput) DescribeClusterRequest
}

DescribeClusterRequest is the request type for the DescribeCluster API operation.

func (DescribeClusterRequest) Send 

func (r DescribeClusterRequest) Send(ctx context.Context) (*DescribeClusterResponse, error)

Send marshals and sends the DescribeCluster API request.

type DescribeClusterResponse 

type DescribeClusterResponse struct {
	*DescribeClusterOutput
	// contains filtered or unexported fields
}

DescribeClusterResponse is the response type for the DescribeCluster API operation.

func (*DescribeClusterResponse) SDKResponseMetdata 

func (r *DescribeClusterResponse) SDKResponseMetdata() *aws.Response

SDKResponseMetdata returns the response metadata for the DescribeCluster request.

type DescribeConfigurationInput 

type DescribeConfigurationInput struct {

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

Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeConfigurationRequest

func (DescribeConfigurationInput) MarshalFields 

func (s DescribeConfigurationInput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (DescribeConfigurationInput) String 

func (s DescribeConfigurationInput) String() string

String returns the string representation

func (*DescribeConfigurationInput) Validate 

func (s *DescribeConfigurationInput) Validate() error

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

type DescribeConfigurationOutput 

type DescribeConfigurationOutput struct {

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

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

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

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

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

	// The name of the configuration.
	Name *string `locationName:"name" type:"string"`
	// contains filtered or unexported fields
}

Response body for DescribeConfiguration. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeConfigurationResponse

func (DescribeConfigurationOutput) MarshalFields 

func (s DescribeConfigurationOutput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (DescribeConfigurationOutput) String 

func (s DescribeConfigurationOutput) String() string

String returns the string representation

type DescribeConfigurationRequest 

type DescribeConfigurationRequest struct {
	*aws.Request
	Input *DescribeConfigurationInput
	Copy  func(*DescribeConfigurationInput) DescribeConfigurationRequest
}

DescribeConfigurationRequest is the request type for the DescribeConfiguration API operation.

func (DescribeConfigurationRequest) Send 

func (r DescribeConfigurationRequest) Send(ctx context.Context) (*DescribeConfigurationResponse, error)

Send marshals and sends the DescribeConfiguration API request.

type DescribeConfigurationResponse 

type DescribeConfigurationResponse struct {
	*DescribeConfigurationOutput
	// contains filtered or unexported fields
}

DescribeConfigurationResponse is the response type for the DescribeConfiguration API operation.

func (*DescribeConfigurationResponse) SDKResponseMetdata 

func (r *DescribeConfigurationResponse) SDKResponseMetdata() *aws.Response

SDKResponseMetdata returns the response metadata for the DescribeConfiguration request.

type DescribeConfigurationRevisionInput 

type DescribeConfigurationRevisionInput struct {

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

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

Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeConfigurationRevisionRequest

func (DescribeConfigurationRevisionInput) MarshalFields 

func (s DescribeConfigurationRevisionInput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (DescribeConfigurationRevisionInput) String 

func (s DescribeConfigurationRevisionInput) String() string

String returns the string representation

func (*DescribeConfigurationRevisionInput) Validate 

func (s *DescribeConfigurationRevisionInput) Validate() error

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

type DescribeConfigurationRevisionOutput 

type DescribeConfigurationRevisionOutput struct {

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

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

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

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

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

Response body for DescribeConfigurationRevision. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/DescribeConfigurationRevisionResponse

func (DescribeConfigurationRevisionOutput) MarshalFields 

func (s DescribeConfigurationRevisionOutput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (DescribeConfigurationRevisionOutput) String 

func (s DescribeConfigurationRevisionOutput) String() string

String returns the string representation

type DescribeConfigurationRevisionRequest 

type DescribeConfigurationRevisionRequest struct {
	*aws.Request
	Input *DescribeConfigurationRevisionInput
	Copy  func(*DescribeConfigurationRevisionInput) DescribeConfigurationRevisionRequest
}

DescribeConfigurationRevisionRequest is the request type for the DescribeConfigurationRevision API operation.

func (DescribeConfigurationRevisionRequest) Send 

func (r DescribeConfigurationRevisionRequest) Send(ctx context.Context) (*DescribeConfigurationRevisionResponse, error)

Send marshals and sends the DescribeConfigurationRevision API request.

type DescribeConfigurationRevisionResponse 

type DescribeConfigurationRevisionResponse struct {
	*DescribeConfigurationRevisionOutput
	// contains filtered or unexported fields
}

DescribeConfigurationRevisionResponse is the response type for the DescribeConfigurationRevision API operation.

func (*DescribeConfigurationRevisionResponse) SDKResponseMetdata 

func (r *DescribeConfigurationRevisionResponse) SDKResponseMetdata() *aws.Response

SDKResponseMetdata returns the response metadata for the DescribeConfigurationRevision request.

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. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/EBSStorageInfo

func (EBSStorageInfo) MarshalFields 

func (s EBSStorageInfo) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

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. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/EncryptionAtRest

func (EncryptionAtRest) MarshalFields 

func (s EncryptionAtRest) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (EncryptionAtRest) String 

func (s EncryptionAtRest) String() string

String returns the string representation

func (*EncryptionAtRest) Validate 

func (s *EncryptionAtRest) Validate() error

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

type EncryptionInTransit 

type EncryptionInTransit struct {

	// Indicates the encryption setting for data in transit between clients and
	// brokers. The following are the possible values.
	//
	// TLS means that client-broker communication is enabled with TLS only.
	//
	// TLS_PLAINTEXT means that client-broker communication is enabled for both
	// TLS-encrypted, as well as plaintext data.
	//
	// PLAINTEXT means that client-broker communication is enabled in plaintext
	// only.
	//
	// The default value is TLS_PLAINTEXT.
	ClientBroker Broker `locationName:"clientBroker" type:"string" enum:"true"`

	// 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. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/EncryptionInTransit

func (EncryptionInTransit) MarshalFields 

func (s EncryptionInTransit) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (EncryptionInTransit) String 

func (s EncryptionInTransit) String() string

String returns the string representation

type EncryptionInfo 

type EncryptionInfo struct {

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

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

Includes encryption-related information, such as the AWS KMS key used for encrypting data at rest and whether you want MSK to encrypt your data in transit. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/EncryptionInfo

func (EncryptionInfo) MarshalFields 

func (s EncryptionInfo) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

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 EnhancedMonitoring 

type EnhancedMonitoring string

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 (
	EnhancedMonitoringDefault           EnhancedMonitoring = "DEFAULT"
	EnhancedMonitoringPerBroker         EnhancedMonitoring = "PER_BROKER"
	EnhancedMonitoringPerTopicPerBroker EnhancedMonitoring = "PER_TOPIC_PER_BROKER"
)

Enum values for EnhancedMonitoring

func (EnhancedMonitoring) MarshalValue 

func (enum EnhancedMonitoring) MarshalValue() (string, error)

func (EnhancedMonitoring) MarshalValueBuf 

func (enum EnhancedMonitoring) MarshalValueBuf(b []byte) ([]byte, error)

type ErrorInfo 

type ErrorInfo struct {

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

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

Returns information about an error state of the cluster. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ErrorInfo

func (ErrorInfo) MarshalFields 

func (s ErrorInfo) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (ErrorInfo) String 

func (s ErrorInfo) String() string

String returns the string representation

type GetBootstrapBrokersInput 

type GetBootstrapBrokersInput struct {

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

Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/GetBootstrapBrokersRequest

func (GetBootstrapBrokersInput) MarshalFields 

func (s GetBootstrapBrokersInput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

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. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/GetBootstrapBrokersResponse

func (GetBootstrapBrokersOutput) MarshalFields 

func (s GetBootstrapBrokersOutput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (GetBootstrapBrokersOutput) String 

func (s GetBootstrapBrokersOutput) String() string

String returns the string representation

type GetBootstrapBrokersRequest 

type GetBootstrapBrokersRequest struct {
	*aws.Request
	Input *GetBootstrapBrokersInput
	Copy  func(*GetBootstrapBrokersInput) GetBootstrapBrokersRequest
}

GetBootstrapBrokersRequest is the request type for the GetBootstrapBrokers API operation.

func (GetBootstrapBrokersRequest) Send 

func (r GetBootstrapBrokersRequest) Send(ctx context.Context) (*GetBootstrapBrokersResponse, error)

Send marshals and sends the GetBootstrapBrokers API request.

type GetBootstrapBrokersResponse 

type GetBootstrapBrokersResponse struct {
	*GetBootstrapBrokersOutput
	// contains filtered or unexported fields
}

GetBootstrapBrokersResponse is the response type for the GetBootstrapBrokers API operation.

func (*GetBootstrapBrokersResponse) SDKResponseMetdata 

func (r *GetBootstrapBrokersResponse) SDKResponseMetdata() *aws.Response

SDKResponseMetdata returns the response metadata for the GetBootstrapBrokers request.

type ListClusterOperationsInput 

type ListClusterOperationsInput struct {

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

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

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

Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListClusterOperationsRequest

func (ListClusterOperationsInput) MarshalFields 

func (s ListClusterOperationsInput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (ListClusterOperationsInput) String 

func (s ListClusterOperationsInput) String() string

String returns the string representation

func (*ListClusterOperationsInput) Validate 

func (s *ListClusterOperationsInput) Validate() error

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

type ListClusterOperationsOutput 

type ListClusterOperationsOutput struct {

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

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

The response contains an array containing cluster operation information and a next token if the response is truncated. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListClusterOperationsResponse

func (ListClusterOperationsOutput) MarshalFields 

func (s ListClusterOperationsOutput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (ListClusterOperationsOutput) String 

func (s ListClusterOperationsOutput) String() string

String returns the string representation

type ListClusterOperationsPaginator 

type ListClusterOperationsPaginator struct {
	aws.Pager
}

ListClusterOperationsPaginator is used to paginate the request. This can be done by calling Next and CurrentPage.

func NewListClusterOperationsPaginator 

func NewListClusterOperationsPaginator(req ListClusterOperationsRequest) ListClusterOperationsPaginator

NewListClusterOperationsRequestPaginator returns a paginator for ListClusterOperations. Use Next method to get the next page, and CurrentPage to get the current response page from the paginator. Next will return false, if there are no more pages, or an error was encountered.

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

// Example iterating over pages.
req := client.ListClusterOperationsRequest(input)
p := kafka.NewListClusterOperationsRequestPaginator(req)

for p.Next(context.TODO()) {
    page := p.CurrentPage()
}

if err := p.Err(); err != nil {
    return err
}

func (*ListClusterOperationsPaginator) CurrentPage 

func (p *ListClusterOperationsPaginator) CurrentPage() *ListClusterOperationsOutput

type ListClusterOperationsRequest 

type ListClusterOperationsRequest struct {
	*aws.Request
	Input *ListClusterOperationsInput
	Copy  func(*ListClusterOperationsInput) ListClusterOperationsRequest
}

ListClusterOperationsRequest is the request type for the ListClusterOperations API operation.

func (ListClusterOperationsRequest) Send 

func (r ListClusterOperationsRequest) Send(ctx context.Context) (*ListClusterOperationsResponse, error)

Send marshals and sends the ListClusterOperations API request.

type ListClusterOperationsResponse 

type ListClusterOperationsResponse struct {
	*ListClusterOperationsOutput
	// contains filtered or unexported fields
}

ListClusterOperationsResponse is the response type for the ListClusterOperations API operation.

func (*ListClusterOperationsResponse) SDKResponseMetdata 

func (r *ListClusterOperationsResponse) SDKResponseMetdata() *aws.Response

SDKResponseMetdata returns the response metadata for the ListClusterOperations request.

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
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListClustersRequest

func (ListClustersInput) MarshalFields 

func (s ListClustersInput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

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. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListClustersResponse

func (ListClustersOutput) MarshalFields 

func (s ListClustersOutput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (ListClustersOutput) String 

func (s ListClustersOutput) String() string

String returns the string representation

type ListClustersPaginator 

type ListClustersPaginator struct {
	aws.Pager
}

ListClustersPaginator is used to paginate the request. This can be done by calling Next and CurrentPage.

func NewListClustersPaginator 

func NewListClustersPaginator(req ListClustersRequest) ListClustersPaginator

NewListClustersRequestPaginator returns a paginator for ListClusters. Use Next method to get the next page, and CurrentPage to get the current response page from the paginator. Next will return false, if there are no more pages, or an error was encountered.

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

// Example iterating over pages.
req := client.ListClustersRequest(input)
p := kafka.NewListClustersRequestPaginator(req)

for p.Next(context.TODO()) {
    page := p.CurrentPage()
}

if err := p.Err(); err != nil {
    return err
}

func (*ListClustersPaginator) CurrentPage 

func (p *ListClustersPaginator) CurrentPage() *ListClustersOutput

type ListClustersRequest 

type ListClustersRequest struct {
	*aws.Request
	Input *ListClustersInput
	Copy  func(*ListClustersInput) ListClustersRequest
}

ListClustersRequest is the request type for the ListClusters API operation.

func (ListClustersRequest) Send 

func (r ListClustersRequest) Send(ctx context.Context) (*ListClustersResponse, error)

Send marshals and sends the ListClusters API request.

type ListClustersResponse 

type ListClustersResponse struct {
	*ListClustersOutput
	// contains filtered or unexported fields
}

ListClustersResponse is the response type for the ListClusters API operation.

func (*ListClustersResponse) SDKResponseMetdata 

func (r *ListClustersResponse) SDKResponseMetdata() *aws.Response

SDKResponseMetdata returns the response metadata for the ListClusters request.

type ListConfigurationRevisionsInput 

type ListConfigurationRevisionsInput struct {

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

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

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

Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListConfigurationRevisionsRequest

func (ListConfigurationRevisionsInput) MarshalFields 

func (s ListConfigurationRevisionsInput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (ListConfigurationRevisionsInput) String 

func (s ListConfigurationRevisionsInput) String() string

String returns the string representation

func (*ListConfigurationRevisionsInput) Validate 

func (s *ListConfigurationRevisionsInput) Validate() error

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

type ListConfigurationRevisionsOutput 

type ListConfigurationRevisionsOutput struct {

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

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

Information about revisions of an MSK configuration. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListConfigurationRevisionsResponse

func (ListConfigurationRevisionsOutput) MarshalFields 

func (s ListConfigurationRevisionsOutput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (ListConfigurationRevisionsOutput) String 

func (s ListConfigurationRevisionsOutput) String() string

String returns the string representation

type ListConfigurationRevisionsPaginator 

type ListConfigurationRevisionsPaginator struct {
	aws.Pager
}

ListConfigurationRevisionsPaginator is used to paginate the request. This can be done by calling Next and CurrentPage.

func NewListConfigurationRevisionsPaginator 

func NewListConfigurationRevisionsPaginator(req ListConfigurationRevisionsRequest) ListConfigurationRevisionsPaginator

NewListConfigurationRevisionsRequestPaginator returns a paginator for ListConfigurationRevisions. Use Next method to get the next page, and CurrentPage to get the current response page from the paginator. Next will return false, if there are no more pages, or an error was encountered.

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

// Example iterating over pages.
req := client.ListConfigurationRevisionsRequest(input)
p := kafka.NewListConfigurationRevisionsRequestPaginator(req)

for p.Next(context.TODO()) {
    page := p.CurrentPage()
}

if err := p.Err(); err != nil {
    return err
}

func (*ListConfigurationRevisionsPaginator) CurrentPage 

func (p *ListConfigurationRevisionsPaginator) CurrentPage() *ListConfigurationRevisionsOutput

type ListConfigurationRevisionsRequest 

type ListConfigurationRevisionsRequest struct {
	*aws.Request
	Input *ListConfigurationRevisionsInput
	Copy  func(*ListConfigurationRevisionsInput) ListConfigurationRevisionsRequest
}

ListConfigurationRevisionsRequest is the request type for the ListConfigurationRevisions API operation.

func (ListConfigurationRevisionsRequest) Send 

func (r ListConfigurationRevisionsRequest) Send(ctx context.Context) (*ListConfigurationRevisionsResponse, error)

Send marshals and sends the ListConfigurationRevisions API request.

type ListConfigurationRevisionsResponse 

type ListConfigurationRevisionsResponse struct {
	*ListConfigurationRevisionsOutput
	// contains filtered or unexported fields
}

ListConfigurationRevisionsResponse is the response type for the ListConfigurationRevisions API operation.

func (*ListConfigurationRevisionsResponse) SDKResponseMetdata 

func (r *ListConfigurationRevisionsResponse) SDKResponseMetdata() *aws.Response

SDKResponseMetdata returns the response metadata for the ListConfigurationRevisions request.

type ListConfigurationsInput 

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

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

Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListConfigurationsRequest

func (ListConfigurationsInput) MarshalFields 

func (s ListConfigurationsInput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (ListConfigurationsInput) String 

func (s ListConfigurationsInput) String() string

String returns the string representation

func (*ListConfigurationsInput) Validate 

func (s *ListConfigurationsInput) Validate() error

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

type ListConfigurationsOutput 

type ListConfigurationsOutput struct {

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

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

The response contains an array of Configuration and a next token if the response is truncated. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListConfigurationsResponse

func (ListConfigurationsOutput) MarshalFields 

func (s ListConfigurationsOutput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (ListConfigurationsOutput) String 

func (s ListConfigurationsOutput) String() string

String returns the string representation

type ListConfigurationsPaginator 

type ListConfigurationsPaginator struct {
	aws.Pager
}

ListConfigurationsPaginator is used to paginate the request. This can be done by calling Next and CurrentPage.

func NewListConfigurationsPaginator 

func NewListConfigurationsPaginator(req ListConfigurationsRequest) ListConfigurationsPaginator

NewListConfigurationsRequestPaginator returns a paginator for ListConfigurations. Use Next method to get the next page, and CurrentPage to get the current response page from the paginator. Next will return false, if there are no more pages, or an error was encountered.

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

// Example iterating over pages.
req := client.ListConfigurationsRequest(input)
p := kafka.NewListConfigurationsRequestPaginator(req)

for p.Next(context.TODO()) {
    page := p.CurrentPage()
}

if err := p.Err(); err != nil {
    return err
}

func (*ListConfigurationsPaginator) CurrentPage 

func (p *ListConfigurationsPaginator) CurrentPage() *ListConfigurationsOutput

type ListConfigurationsRequest 

type ListConfigurationsRequest struct {
	*aws.Request
	Input *ListConfigurationsInput
	Copy  func(*ListConfigurationsInput) ListConfigurationsRequest
}

ListConfigurationsRequest is the request type for the ListConfigurations API operation.

func (ListConfigurationsRequest) Send 

func (r ListConfigurationsRequest) Send(ctx context.Context) (*ListConfigurationsResponse, error)

Send marshals and sends the ListConfigurations API request.

type ListConfigurationsResponse 

type ListConfigurationsResponse struct {
	*ListConfigurationsOutput
	// contains filtered or unexported fields
}

ListConfigurationsResponse is the response type for the ListConfigurations API operation.

func (*ListConfigurationsResponse) SDKResponseMetdata 

func (r *ListConfigurationsResponse) SDKResponseMetdata() *aws.Response

SDKResponseMetdata returns the response metadata for the ListConfigurations request.

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
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListNodesRequest

func (ListNodesInput) MarshalFields 

func (s ListNodesInput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

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. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListNodesResponse

func (ListNodesOutput) MarshalFields 

func (s ListNodesOutput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (ListNodesOutput) String 

func (s ListNodesOutput) String() string

String returns the string representation

type ListNodesPaginator 

type ListNodesPaginator struct {
	aws.Pager
}

ListNodesPaginator is used to paginate the request. This can be done by calling Next and CurrentPage.

func NewListNodesPaginator 

func NewListNodesPaginator(req ListNodesRequest) ListNodesPaginator

NewListNodesRequestPaginator returns a paginator for ListNodes. Use Next method to get the next page, and CurrentPage to get the current response page from the paginator. Next will return false, if there are no more pages, or an error was encountered.

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

// Example iterating over pages.
req := client.ListNodesRequest(input)
p := kafka.NewListNodesRequestPaginator(req)

for p.Next(context.TODO()) {
    page := p.CurrentPage()
}

if err := p.Err(); err != nil {
    return err
}

func (*ListNodesPaginator) CurrentPage 

func (p *ListNodesPaginator) CurrentPage() *ListNodesOutput

type ListNodesRequest 

type ListNodesRequest struct {
	*aws.Request
	Input *ListNodesInput
	Copy  func(*ListNodesInput) ListNodesRequest
}

ListNodesRequest is the request type for the ListNodes API operation.

func (ListNodesRequest) Send 

func (r ListNodesRequest) Send(ctx context.Context) (*ListNodesResponse, error)

Send marshals and sends the ListNodes API request.

type ListNodesResponse 

type ListNodesResponse struct {
	*ListNodesOutput
	// contains filtered or unexported fields
}

ListNodesResponse is the response type for the ListNodes API operation.

func (*ListNodesResponse) SDKResponseMetdata 

func (r *ListNodesResponse) SDKResponseMetdata() *aws.Response

SDKResponseMetdata returns the response metadata for the ListNodes request.

type ListTagsForResourceInput 

type ListTagsForResourceInput struct {

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

Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListTagsForResourceRequest

func (ListTagsForResourceInput) MarshalFields 

func (s ListTagsForResourceInput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (ListTagsForResourceInput) String 

func (s ListTagsForResourceInput) String() string

String returns the string representation

func (*ListTagsForResourceInput) Validate 

func (s *ListTagsForResourceInput) Validate() error

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

type ListTagsForResourceOutput 

type ListTagsForResourceOutput struct {

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

Response of listing tags for a resource. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ListTagsForResourceResponse

func (ListTagsForResourceOutput) MarshalFields 

func (s ListTagsForResourceOutput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (ListTagsForResourceOutput) String 

func (s ListTagsForResourceOutput) String() string

String returns the string representation

type ListTagsForResourceRequest 

type ListTagsForResourceRequest struct {
	*aws.Request
	Input *ListTagsForResourceInput
	Copy  func(*ListTagsForResourceInput) ListTagsForResourceRequest
}

ListTagsForResourceRequest is the request type for the ListTagsForResource API operation.

func (ListTagsForResourceRequest) Send 

func (r ListTagsForResourceRequest) Send(ctx context.Context) (*ListTagsForResourceResponse, error)

Send marshals and sends the ListTagsForResource API request.

type ListTagsForResourceResponse 

type ListTagsForResourceResponse struct {
	*ListTagsForResourceOutput
	// contains filtered or unexported fields
}

ListTagsForResourceResponse is the response type for the ListTagsForResource API operation.

func (*ListTagsForResourceResponse) SDKResponseMetdata 

func (r *ListTagsForResourceResponse) SDKResponseMetdata() *aws.Response

SDKResponseMetdata returns the response metadata for the ListTagsForResource request.

type MutableClusterInfo 

type MutableClusterInfo struct {

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

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

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

Information about cluster attributes that can be updated via update APIs. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/MutableClusterInfo

func (MutableClusterInfo) MarshalFields 

func (s MutableClusterInfo) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (MutableClusterInfo) String 

func (s MutableClusterInfo) String() string

String returns the string representation

type NodeInfo 

type NodeInfo struct {

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

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

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

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

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

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

The node information object. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/NodeInfo

func (NodeInfo) MarshalFields 

func (s NodeInfo) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (NodeInfo) String 

func (s NodeInfo) String() string

String returns the string representation

type NodeType 

type NodeType string

The broker or Zookeeper node. 

const (
	NodeTypeBroker NodeType = "BROKER"
)

Enum values for NodeType

func (NodeType) MarshalValue 

func (enum NodeType) MarshalValue() (string, error)

func (NodeType) MarshalValueBuf 

func (enum NodeType) MarshalValueBuf(b []byte) ([]byte, error)

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. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/StorageInfo

func (StorageInfo) MarshalFields 

func (s StorageInfo) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (StorageInfo) String 

func (s StorageInfo) String() string

String returns the string representation

func (*StorageInfo) Validate 

func (s *StorageInfo) Validate() error

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

type TagResourceInput 

type TagResourceInput struct {

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

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

Tag a resource. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/TagResourceRequest

func (TagResourceInput) MarshalFields 

func (s TagResourceInput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (TagResourceInput) String 

func (s TagResourceInput) String() string

String returns the string representation

func (*TagResourceInput) Validate 

func (s *TagResourceInput) Validate() error

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

type TagResourceOutput 

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

Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/TagResourceOutput

func (TagResourceOutput) MarshalFields 

func (s TagResourceOutput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (TagResourceOutput) String 

func (s TagResourceOutput) String() string

String returns the string representation

type TagResourceRequest 

type TagResourceRequest struct {
	*aws.Request
	Input *TagResourceInput
	Copy  func(*TagResourceInput) TagResourceRequest
}

TagResourceRequest is the request type for the TagResource API operation.

func (TagResourceRequest) Send 

func (r TagResourceRequest) Send(ctx context.Context) (*TagResourceResponse, error)

Send marshals and sends the TagResource API request.

type TagResourceResponse 

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

TagResourceResponse is the response type for the TagResource API operation.

func (*TagResourceResponse) SDKResponseMetdata 

func (r *TagResourceResponse) SDKResponseMetdata() *aws.Response

SDKResponseMetdata returns the response metadata for the TagResource request.

type Tls 

type Tls struct {

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

Details for client authentication using TLS. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/Tls

func (Tls) MarshalFields 

func (s Tls) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (Tls) String 

func (s Tls) String() string

String returns the string representation

type UntagResourceInput 

type UntagResourceInput struct {

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

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

Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UntagResourceRequest

func (UntagResourceInput) MarshalFields 

func (s UntagResourceInput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (UntagResourceInput) String 

func (s UntagResourceInput) String() string

String returns the string representation

func (*UntagResourceInput) Validate 

func (s *UntagResourceInput) Validate() error

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

type UntagResourceOutput 

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

Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UntagResourceOutput

func (UntagResourceOutput) MarshalFields 

func (s UntagResourceOutput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (UntagResourceOutput) String 

func (s UntagResourceOutput) String() string

String returns the string representation

type UntagResourceRequest 

type UntagResourceRequest struct {
	*aws.Request
	Input *UntagResourceInput
	Copy  func(*UntagResourceInput) UntagResourceRequest
}

UntagResourceRequest is the request type for the UntagResource API operation.

func (UntagResourceRequest) Send 

func (r UntagResourceRequest) Send(ctx context.Context) (*UntagResourceResponse, error)

Send marshals and sends the UntagResource API request.

type UntagResourceResponse 

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

UntagResourceResponse is the response type for the UntagResource API operation.

func (*UntagResourceResponse) SDKResponseMetdata 

func (r *UntagResourceResponse) SDKResponseMetdata() *aws.Response

SDKResponseMetdata returns the response metadata for the UntagResource request.

type UpdateBrokerStorageInput 

type UpdateBrokerStorageInput struct {

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

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

	// Describes the target volume size and the ID of the broker to apply the update
	// to.
	//
	// TargetBrokerEBSVolumeInfo is a required field
	TargetBrokerEBSVolumeInfo []BrokerEBSVolumeInfo `locationName:"targetBrokerEBSVolumeInfo" type:"list" required:"true"`
	// contains filtered or unexported fields
}

Request object for UpdateBrokerStorage. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateBrokerStorageRequest

func (UpdateBrokerStorageInput) MarshalFields 

func (s UpdateBrokerStorageInput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (UpdateBrokerStorageInput) String 

func (s UpdateBrokerStorageInput) String() string

String returns the string representation

func (*UpdateBrokerStorageInput) Validate 

func (s *UpdateBrokerStorageInput) Validate() error

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

type UpdateBrokerStorageOutput 

type UpdateBrokerStorageOutput struct {

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

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

Response body for UpdateBrokerStorage. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateBrokerStorageResponse

func (UpdateBrokerStorageOutput) MarshalFields 

func (s UpdateBrokerStorageOutput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (UpdateBrokerStorageOutput) String 

func (s UpdateBrokerStorageOutput) String() string

String returns the string representation

type UpdateBrokerStorageRequest 

type UpdateBrokerStorageRequest struct {
	*aws.Request
	Input *UpdateBrokerStorageInput
	Copy  func(*UpdateBrokerStorageInput) UpdateBrokerStorageRequest
}

UpdateBrokerStorageRequest is the request type for the UpdateBrokerStorage API operation.

func (UpdateBrokerStorageRequest) Send 

func (r UpdateBrokerStorageRequest) Send(ctx context.Context) (*UpdateBrokerStorageResponse, error)

Send marshals and sends the UpdateBrokerStorage API request.

type UpdateBrokerStorageResponse 

type UpdateBrokerStorageResponse struct {
	*UpdateBrokerStorageOutput
	// contains filtered or unexported fields
}

UpdateBrokerStorageResponse is the response type for the UpdateBrokerStorage API operation.

func (*UpdateBrokerStorageResponse) SDKResponseMetdata 

func (r *UpdateBrokerStorageResponse) SDKResponseMetdata() *aws.Response

SDKResponseMetdata returns the response metadata for the UpdateBrokerStorage request.

type UpdateClusterConfigurationInput 

type UpdateClusterConfigurationInput struct {

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

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

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

Request body for UpdateClusterConfiguration. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateClusterConfigurationRequest

func (UpdateClusterConfigurationInput) MarshalFields 

func (s UpdateClusterConfigurationInput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (UpdateClusterConfigurationInput) String 

func (s UpdateClusterConfigurationInput) String() string

String returns the string representation

func (*UpdateClusterConfigurationInput) Validate 

func (s *UpdateClusterConfigurationInput) Validate() error

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

type UpdateClusterConfigurationOutput 

type UpdateClusterConfigurationOutput struct {

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

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

Response body for UpdateClusterConfiguration. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/UpdateClusterConfigurationResponse

func (UpdateClusterConfigurationOutput) MarshalFields 

func (s UpdateClusterConfigurationOutput) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (UpdateClusterConfigurationOutput) String 

func (s UpdateClusterConfigurationOutput) String() string

String returns the string representation

type UpdateClusterConfigurationRequest 

type UpdateClusterConfigurationRequest struct {
	*aws.Request
	Input *UpdateClusterConfigurationInput
	Copy  func(*UpdateClusterConfigurationInput) UpdateClusterConfigurationRequest
}

UpdateClusterConfigurationRequest is the request type for the UpdateClusterConfiguration API operation.

func (UpdateClusterConfigurationRequest) Send 

func (r UpdateClusterConfigurationRequest) Send(ctx context.Context) (*UpdateClusterConfigurationResponse, error)

Send marshals and sends the UpdateClusterConfiguration API request.

type UpdateClusterConfigurationResponse 

type UpdateClusterConfigurationResponse struct {
	*UpdateClusterConfigurationOutput
	// contains filtered or unexported fields
}

UpdateClusterConfigurationResponse is the response type for the UpdateClusterConfiguration API operation.

func (*UpdateClusterConfigurationResponse) SDKResponseMetdata 

func (r *UpdateClusterConfigurationResponse) SDKResponseMetdata() *aws.Response

SDKResponseMetdata returns the response metadata for the UpdateClusterConfiguration request.

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. Please also see https://docs.aws.amazon.com/goto/WebAPI/kafka-2018-11-14/ZookeeperNodeInfo

func (ZookeeperNodeInfo) MarshalFields 

func (s ZookeeperNodeInfo) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (ZookeeperNodeInfo) String 

func (s ZookeeperNodeInfo) String() string

String returns the string representation

Source Files

api_client.go api_doc.go api_enums.go api_errors.go api_op_CreateCluster.go api_op_CreateConfiguration.go api_op_DeleteCluster.go api_op_DescribeCluster.go api_op_DescribeClusterOperation.go api_op_DescribeConfiguration.go api_op_DescribeConfigurationRevision.go api_op_GetBootstrapBrokers.go api_op_ListClusterOperations.go api_op_ListClusters.go api_op_ListConfigurationRevisions.go api_op_ListConfigurations.go api_op_ListNodes.go api_op_ListTagsForResource.go api_op_TagResource.go api_op_UntagResource.go api_op_UpdateBrokerStorage.go api_op_UpdateClusterConfiguration.go api_types.go

Directories

PathSynopsis
service/kafka/kafkaifacePackage kafkaiface provides an interface to enable mocking the Managed Streaming for Kafka service client for testing your code.
Version
v0.11.0
Published
Aug 23, 2019
Platform
js/wasm
Imports
8 packages
Last checked
1 minute ago –

Tools for package owners.