v1alpha1

package
v0.0.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 29, 2024 License: Apache-2.0 Imports: 6 Imported by: 2

Documentation

Overview

+k8s:deepcopy-gen=package Package v1alpha1 is the v1alpha1 version of the kafka.services.k8s.aws API. +groupName=kafka.services.k8s.aws

Index

Constants

This section is empty.

Variables

View Source
var (
	// GroupVersion is the API Group Version used to register the objects
	GroupVersion = schema.GroupVersion{Group: "kafka.services.k8s.aws", Version: "v1alpha1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)

Functions

This section is empty.

Types

type BrokerAZDistribution

type BrokerAZDistribution string
const (
	BrokerAZDistribution_DEFAULT BrokerAZDistribution = "DEFAULT"
)

type BrokerEBSVolumeInfo

type BrokerEBSVolumeInfo struct {
	KafkaBrokerNodeID *string `json:"kafkaBrokerNodeID,omitempty"`
	// Contains information about provisioned throughput for EBS storage volumes
	// attached to kafka broker nodes.
	ProvisionedThroughput *ProvisionedThroughput `json:"provisionedThroughput,omitempty"`
	VolumeSizeGB          *int64                 `json:"volumeSizeGB,omitempty"`
}

Specifies the EBS volume upgrade information. The broker identifier must be set to the keyword ALL. This means the changes apply to all the brokers in the cluster.

func (*BrokerEBSVolumeInfo) DeepCopy

func (in *BrokerEBSVolumeInfo) DeepCopy() *BrokerEBSVolumeInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerEBSVolumeInfo.

func (*BrokerEBSVolumeInfo) DeepCopyInto

func (in *BrokerEBSVolumeInfo) DeepCopyInto(out *BrokerEBSVolumeInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type BrokerLogs

type BrokerLogs struct {
	// Details of the CloudWatch Logs destination for broker logs.
	CloudWatchLogs *CloudWatchLogs `json:"cloudWatchLogs,omitempty"`
	// Firehose details for BrokerLogs.
	Firehose *Firehose `json:"firehose,omitempty"`
	// The details of the Amazon S3 destination for broker logs.
	S3 *S3 `json:"s3,omitempty"`
}

The broker logs configuration for this MSK cluster.

func (*BrokerLogs) DeepCopy

func (in *BrokerLogs) DeepCopy() *BrokerLogs

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerLogs.

func (*BrokerLogs) DeepCopyInto

func (in *BrokerLogs) DeepCopyInto(out *BrokerLogs)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type BrokerNodeGroupInfo

type BrokerNodeGroupInfo struct {
	// The distribution of broker nodes across Availability Zones. By default, broker
	// nodes are distributed among the Availability Zones of your Region. Currently,
	// the only supported value is DEFAULT. You can either specify this value explicitly
	// or leave it out.
	BrokerAZDistribution *string   `json:"brokerAZDistribution,omitempty"`
	ClientSubnets        []*string `json:"clientSubnets,omitempty"`
	// Information about the broker access configuration.
	ConnectivityInfo *ConnectivityInfo `json:"connectivityInfo,omitempty"`
	InstanceType     *string           `json:"instanceType,omitempty"`
	SecurityGroups   []*string         `json:"securityGroups,omitempty"`
	// Contains information about storage volumes attached to MSK broker nodes.
	StorageInfo *StorageInfo `json:"storageInfo,omitempty"`
}

Describes the setup to be used for Apache Kafka broker nodes in the cluster.

func (*BrokerNodeGroupInfo) DeepCopy

func (in *BrokerNodeGroupInfo) DeepCopy() *BrokerNodeGroupInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerNodeGroupInfo.

func (*BrokerNodeGroupInfo) DeepCopyInto

func (in *BrokerNodeGroupInfo) DeepCopyInto(out *BrokerNodeGroupInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type BrokerNodeInfo

type BrokerNodeInfo struct {
	AttachedENIID      *string `json:"attachedENIID,omitempty"`
	ClientSubnet       *string `json:"clientSubnet,omitempty"`
	ClientVPCIPAddress *string `json:"clientVPCIPAddress,omitempty"`
	// Information about the current software installed on the cluster.
	CurrentBrokerSoftwareInfo *BrokerSoftwareInfo `json:"currentBrokerSoftwareInfo,omitempty"`
	Endpoints                 []*string           `json:"endpoints,omitempty"`
}

BrokerNodeInfo

func (*BrokerNodeInfo) DeepCopy

func (in *BrokerNodeInfo) DeepCopy() *BrokerNodeInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerNodeInfo.

func (*BrokerNodeInfo) DeepCopyInto

func (in *BrokerNodeInfo) DeepCopyInto(out *BrokerNodeInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type BrokerSoftwareInfo

type BrokerSoftwareInfo struct {
	ConfigurationARN      *string `json:"configurationARN,omitempty"`
	ConfigurationRevision *int64  `json:"configurationRevision,omitempty"`
	KafkaVersion          *string `json:"kafkaVersion,omitempty"`
}

Information about the current software installed on the cluster.

func (*BrokerSoftwareInfo) DeepCopy

func (in *BrokerSoftwareInfo) DeepCopy() *BrokerSoftwareInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerSoftwareInfo.

func (*BrokerSoftwareInfo) DeepCopyInto

func (in *BrokerSoftwareInfo) DeepCopyInto(out *BrokerSoftwareInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClientAuthentication

type ClientAuthentication struct {
	SASL *SASL `json:"sasl,omitempty"`
	// Details for client authentication using TLS.
	TLS *TLS `json:"tls,omitempty"`
	// Contains information about unauthenticated traffic to the cluster.
	Unauthenticated *Unauthenticated `json:"unauthenticated,omitempty"`
}

Includes all client authentication information.

func (*ClientAuthentication) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClientAuthentication.

func (*ClientAuthentication) DeepCopyInto

func (in *ClientAuthentication) DeepCopyInto(out *ClientAuthentication)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClientBroker

type ClientBroker string
const (
	ClientBroker_TLS           ClientBroker = "TLS"
	ClientBroker_TLS_PLAINTEXT ClientBroker = "TLS_PLAINTEXT"
	ClientBroker_PLAINTEXT     ClientBroker = "PLAINTEXT"
)

type CloudWatchLogs

type CloudWatchLogs struct {
	Enabled  *bool   `json:"enabled,omitempty"`
	LogGroup *string `json:"logGroup,omitempty"`
}

Details of the CloudWatch Logs destination for broker logs.

func (*CloudWatchLogs) DeepCopy

func (in *CloudWatchLogs) DeepCopy() *CloudWatchLogs

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudWatchLogs.

func (*CloudWatchLogs) DeepCopyInto

func (in *CloudWatchLogs) DeepCopyInto(out *CloudWatchLogs)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Cluster

type Cluster struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              ClusterSpec   `json:"spec,omitempty"`
	Status            ClusterStatus `json:"status,omitempty"`
}

Cluster is the Schema for the Clusters API +kubebuilder:object:root=true +kubebuilder:subresource:status

func (*Cluster) DeepCopy

func (in *Cluster) DeepCopy() *Cluster

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Cluster.

func (*Cluster) DeepCopyInto

func (in *Cluster) DeepCopyInto(out *Cluster)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Cluster) DeepCopyObject

func (in *Cluster) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type ClusterInfo

type ClusterInfo struct {
	ActiveOperationARN *string `json:"activeOperationARN,omitempty"`
	// Describes the setup to be used for Apache Kafka broker nodes in the cluster.
	BrokerNodeGroupInfo *BrokerNodeGroupInfo `json:"brokerNodeGroupInfo,omitempty"`
	// Includes all client authentication information.
	ClientAuthentication *ClientAuthentication `json:"clientAuthentication,omitempty"`
	ClusterARN           *string               `json:"clusterARN,omitempty"`
	ClusterName          *string               `json:"clusterName,omitempty"`
	CreationTime         *metav1.Time          `json:"creationTime,omitempty"`
	// Information about the current software installed on the cluster.
	CurrentBrokerSoftwareInfo *BrokerSoftwareInfo `json:"currentBrokerSoftwareInfo,omitempty"`
	CurrentVersion            *string             `json:"currentVersion,omitempty"`
	// 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.
	EncryptionInfo *EncryptionInfo `json:"encryptionInfo,omitempty"`
	// Specifies which metrics are gathered for the MSK cluster. This property has
	// the following possible values: DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER,
	// and PER_TOPIC_PER_PARTITION. For a list of the metrics associated with each
	// of these levels of monitoring, see Monitoring (https://docs.aws.amazon.com/msk/latest/developerguide/monitoring.html).
	EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty"`
	// You can configure your MSK cluster to send broker logs to different destination
	// types. This is a container for the configuration details related to broker
	// logs.
	LoggingInfo         *LoggingInfo `json:"loggingInfo,omitempty"`
	NumberOfBrokerNodes *int64       `json:"numberOfBrokerNodes,omitempty"`
	// JMX and Node monitoring for the MSK cluster.
	OpenMonitoring *OpenMonitoring `json:"openMonitoring,omitempty"`
	// The state of an Apache Kafka cluster.
	State *string `json:"state,omitempty"`
	// Contains information about the state of the Amazon MSK cluster.
	StateInfo *StateInfo `json:"stateInfo,omitempty"`
	// Controls storage mode for various supported storage tiers.
	StorageMode               *string            `json:"storageMode,omitempty"`
	Tags                      map[string]*string `json:"tags,omitempty"`
	ZookeeperConnectString    *string            `json:"zookeeperConnectString,omitempty"`
	ZookeeperConnectStringTLS *string            `json:"zookeeperConnectStringTLS,omitempty"`
}

Returns information about a cluster.

func (*ClusterInfo) DeepCopy

func (in *ClusterInfo) DeepCopy() *ClusterInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterInfo.

func (*ClusterInfo) DeepCopyInto

func (in *ClusterInfo) DeepCopyInto(out *ClusterInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterList

type ClusterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Cluster `json:"items"`
}

ClusterList contains a list of Cluster +kubebuilder:object:root=true

func (*ClusterList) DeepCopy

func (in *ClusterList) DeepCopy() *ClusterList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterList.

func (*ClusterList) DeepCopyInto

func (in *ClusterList) DeepCopyInto(out *ClusterList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ClusterList) DeepCopyObject

func (in *ClusterList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type ClusterOperationInfo

type ClusterOperationInfo struct {
	ClientRequestID *string      `json:"clientRequestID,omitempty"`
	ClusterARN      *string      `json:"clusterARN,omitempty"`
	CreationTime    *metav1.Time `json:"creationTime,omitempty"`
	EndTime         *metav1.Time `json:"endTime,omitempty"`
	OperationARN    *string      `json:"operationARN,omitempty"`
	OperationState  *string      `json:"operationState,omitempty"`
	OperationType   *string      `json:"operationType,omitempty"`
}

Returns information about a cluster operation.

func (*ClusterOperationInfo) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterOperationInfo.

func (*ClusterOperationInfo) DeepCopyInto

func (in *ClusterOperationInfo) DeepCopyInto(out *ClusterOperationInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterOperationStep

type ClusterOperationStep struct {
	StepName *string `json:"stepName,omitempty"`
}

Step taken during a cluster operation.

func (*ClusterOperationStep) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterOperationStep.

func (*ClusterOperationStep) DeepCopyInto

func (in *ClusterOperationStep) DeepCopyInto(out *ClusterOperationStep)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterOperationStepInfo

type ClusterOperationStepInfo struct {
	StepStatus *string `json:"stepStatus,omitempty"`
}

State information about the operation step.

func (*ClusterOperationStepInfo) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterOperationStepInfo.

func (*ClusterOperationStepInfo) DeepCopyInto

func (in *ClusterOperationStepInfo) DeepCopyInto(out *ClusterOperationStepInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterSpec

type ClusterSpec struct {

	// Information about the brokers.
	// +kubebuilder:validation:Required
	BrokerNodeGroupInfo *BrokerNodeGroupInfo `json:"brokerNodeGroupInfo"`
	// Includes all client authentication related information.
	ClientAuthentication *ClientAuthentication `json:"clientAuthentication,omitempty"`
	// Represents the configuration that you want MSK to use for the cluster.
	ConfigurationInfo *ConfigurationInfo `json:"configurationInfo,omitempty"`
	// Includes all encryption-related information.
	EncryptionInfo *EncryptionInfo `json:"encryptionInfo,omitempty"`
	// Specifies the level of monitoring for the MSK cluster. The possible values
	// are DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER, and PER_TOPIC_PER_PARTITION.
	EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty"`
	// The version of Apache Kafka.
	// +kubebuilder:validation:Required
	KafkaVersion *string `json:"kafkaVersion"`
	// LoggingInfo details.
	LoggingInfo *LoggingInfo `json:"loggingInfo,omitempty"`
	// The name of the cluster.
	// +kubebuilder:validation:Required
	Name *string `json:"name"`
	// The number of Apache Kafka broker nodes in the Amazon MSK cluster.
	// +kubebuilder:validation:Required
	NumberOfBrokerNodes *int64 `json:"numberOfBrokerNodes"`
	// The settings for open monitoring.
	OpenMonitoring *OpenMonitoringInfo `json:"openMonitoring,omitempty"`
	// This controls storage mode for supported storage tiers.
	StorageMode *string `json:"storageMode,omitempty"`
	// Create tags when creating the cluster.
	Tags map[string]*string `json:"tags,omitempty"`
}

ClusterSpec defines the desired state of Cluster.

Returns information about a cluster of either the provisioned or the serverless type.

func (*ClusterSpec) DeepCopy

func (in *ClusterSpec) DeepCopy() *ClusterSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSpec.

func (*ClusterSpec) DeepCopyInto

func (in *ClusterSpec) DeepCopyInto(out *ClusterSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterState

type ClusterState string
const (
	ClusterState_ACTIVE           ClusterState = "ACTIVE"
	ClusterState_CREATING         ClusterState = "CREATING"
	ClusterState_DELETING         ClusterState = "DELETING"
	ClusterState_FAILED           ClusterState = "FAILED"
	ClusterState_HEALING          ClusterState = "HEALING"
	ClusterState_MAINTENANCE      ClusterState = "MAINTENANCE"
	ClusterState_REBOOTING_BROKER ClusterState = "REBOOTING_BROKER"
	ClusterState_UPDATING         ClusterState = "UPDATING"
)

type ClusterStatus

type ClusterStatus struct {
	// All CRs managed by ACK have a common `Status.ACKResourceMetadata` member
	// that is used to contain resource sync state, account ownership,
	// constructed ARN for the resource
	// +kubebuilder:validation:Optional
	ACKResourceMetadata *ackv1alpha1.ResourceMetadata `json:"ackResourceMetadata"`
	// All CRS managed by ACK have a common `Status.Conditions` member that
	// contains a collection of `ackv1alpha1.Condition` objects that describe
	// the various terminal states of the CR and its backend AWS service API
	// resource
	// +kubebuilder:validation:Optional
	Conditions []*ackv1alpha1.Condition `json:"conditions"`
	// The state of the cluster. The possible states are ACTIVE, CREATING, DELETING,
	// FAILED, HEALING, MAINTENANCE, REBOOTING_BROKER, and UPDATING.
	// +kubebuilder:validation:Optional
	State *string `json:"state,omitempty"`
}

ClusterStatus defines the observed state of Cluster

func (*ClusterStatus) DeepCopy

func (in *ClusterStatus) DeepCopy() *ClusterStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterStatus.

func (*ClusterStatus) DeepCopyInto

func (in *ClusterStatus) DeepCopyInto(out *ClusterStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterType

type ClusterType string
const (
	ClusterType_PROVISIONED ClusterType = "PROVISIONED"
	ClusterType_SERVERLESS  ClusterType = "SERVERLESS"
)

type Cluster_SDK

type Cluster_SDK struct {
	ActiveOperationARN *string      `json:"activeOperationARN,omitempty"`
	ClusterARN         *string      `json:"clusterARN,omitempty"`
	ClusterName        *string      `json:"clusterName,omitempty"`
	CreationTime       *metav1.Time `json:"creationTime,omitempty"`
	CurrentVersion     *string      `json:"currentVersion,omitempty"`
	// The state of an Apache Kafka cluster.
	State *string `json:"state,omitempty"`
	// Contains information about the state of the Amazon MSK cluster.
	StateInfo *StateInfo         `json:"stateInfo,omitempty"`
	Tags      map[string]*string `json:"tags,omitempty"`
}

Returns information about a cluster of either the provisioned or the serverless type.

func (*Cluster_SDK) DeepCopy

func (in *Cluster_SDK) DeepCopy() *Cluster_SDK

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Cluster_SDK.

func (*Cluster_SDK) DeepCopyInto

func (in *Cluster_SDK) DeepCopyInto(out *Cluster_SDK)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CompatibleKafkaVersion

type CompatibleKafkaVersion struct {
	SourceVersion  *string   `json:"sourceVersion,omitempty"`
	TargetVersions []*string `json:"targetVersions,omitempty"`
}

Contains source Apache Kafka versions and compatible target Apache Kafka versions.

func (*CompatibleKafkaVersion) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CompatibleKafkaVersion.

func (*CompatibleKafkaVersion) DeepCopyInto

func (in *CompatibleKafkaVersion) DeepCopyInto(out *CompatibleKafkaVersion)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Configuration

type Configuration struct {
	ARN           *string      `json:"arn,omitempty"`
	CreationTime  *metav1.Time `json:"creationTime,omitempty"`
	Description   *string      `json:"description,omitempty"`
	KafkaVersions []*string    `json:"kafkaVersions,omitempty"`
	Name          *string      `json:"name,omitempty"`
}

Represents an MSK Configuration.

func (*Configuration) DeepCopy

func (in *Configuration) DeepCopy() *Configuration

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Configuration.

func (*Configuration) DeepCopyInto

func (in *Configuration) DeepCopyInto(out *Configuration)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ConfigurationInfo

type ConfigurationInfo struct {
	ARN      *string `json:"arn,omitempty"`
	Revision *int64  `json:"revision,omitempty"`
}

Specifies the configuration to use for the brokers.

func (*ConfigurationInfo) DeepCopy

func (in *ConfigurationInfo) DeepCopy() *ConfigurationInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationInfo.

func (*ConfigurationInfo) DeepCopyInto

func (in *ConfigurationInfo) DeepCopyInto(out *ConfigurationInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ConfigurationRevision

type ConfigurationRevision struct {
	CreationTime *metav1.Time `json:"creationTime,omitempty"`
	Description  *string      `json:"description,omitempty"`
	Revision     *int64       `json:"revision,omitempty"`
}

Describes a configuration revision.

func (*ConfigurationRevision) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationRevision.

func (*ConfigurationRevision) DeepCopyInto

func (in *ConfigurationRevision) DeepCopyInto(out *ConfigurationRevision)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ConfigurationState

type ConfigurationState string
const (
	ConfigurationState_ACTIVE        ConfigurationState = "ACTIVE"
	ConfigurationState_DELETING      ConfigurationState = "DELETING"
	ConfigurationState_DELETE_FAILED ConfigurationState = "DELETE_FAILED"
)

type ConnectivityInfo

type ConnectivityInfo struct {
	// Broker public access control.
	PublicAccess *PublicAccess `json:"publicAccess,omitempty"`
}

Information about the broker access configuration.

func (*ConnectivityInfo) DeepCopy

func (in *ConnectivityInfo) DeepCopy() *ConnectivityInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectivityInfo.

func (*ConnectivityInfo) DeepCopyInto

func (in *ConnectivityInfo) DeepCopyInto(out *ConnectivityInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type EBSStorageInfo

type EBSStorageInfo struct {
	// Contains information about provisioned throughput for EBS storage volumes
	// attached to kafka broker nodes.
	ProvisionedThroughput *ProvisionedThroughput `json:"provisionedThroughput,omitempty"`
	VolumeSize            *int64                 `json:"volumeSize,omitempty"`
}

Contains information about the EBS storage volumes attached to Apache Kafka broker nodes.

func (*EBSStorageInfo) DeepCopy

func (in *EBSStorageInfo) DeepCopy() *EBSStorageInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EBSStorageInfo.

func (*EBSStorageInfo) DeepCopyInto

func (in *EBSStorageInfo) DeepCopyInto(out *EBSStorageInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type EncryptionAtRest

type EncryptionAtRest struct {
	DataVolumeKMSKeyID *string `json:"dataVolumeKMSKeyID,omitempty"`
}

The data-volume encryption details.

func (*EncryptionAtRest) DeepCopy

func (in *EncryptionAtRest) DeepCopy() *EncryptionAtRest

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EncryptionAtRest.

func (*EncryptionAtRest) DeepCopyInto

func (in *EncryptionAtRest) DeepCopyInto(out *EncryptionAtRest)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type EncryptionInTransit

type EncryptionInTransit struct {
	// Client-broker encryption in transit setting.
	ClientBroker *string `json:"clientBroker,omitempty"`
	InCluster    *bool   `json:"inCluster,omitempty"`
}

The settings for encrypting data in transit.

func (*EncryptionInTransit) DeepCopy

func (in *EncryptionInTransit) DeepCopy() *EncryptionInTransit

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EncryptionInTransit.

func (*EncryptionInTransit) DeepCopyInto

func (in *EncryptionInTransit) DeepCopyInto(out *EncryptionInTransit)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type EncryptionInfo

type EncryptionInfo struct {
	// The data-volume encryption details.
	EncryptionAtRest *EncryptionAtRest `json:"encryptionAtRest,omitempty"`
	// The settings for encrypting data in transit.
	EncryptionInTransit *EncryptionInTransit `json:"encryptionInTransit,omitempty"`
}

Includes encryption-related information, such as the AWS KMS key used for encrypting data at rest and whether you want MSK to encrypt your data in transit.

func (*EncryptionInfo) DeepCopy

func (in *EncryptionInfo) DeepCopy() *EncryptionInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EncryptionInfo.

func (*EncryptionInfo) DeepCopyInto

func (in *EncryptionInfo) DeepCopyInto(out *EncryptionInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type EnhancedMonitoring

type EnhancedMonitoring string
const (
	EnhancedMonitoring_DEFAULT                 EnhancedMonitoring = "DEFAULT"
	EnhancedMonitoring_PER_BROKER              EnhancedMonitoring = "PER_BROKER"
	EnhancedMonitoring_PER_TOPIC_PER_BROKER    EnhancedMonitoring = "PER_TOPIC_PER_BROKER"
	EnhancedMonitoring_PER_TOPIC_PER_PARTITION EnhancedMonitoring = "PER_TOPIC_PER_PARTITION"
)

type ErrorInfo

type ErrorInfo struct {
	ErrorCode   *string `json:"errorCode,omitempty"`
	ErrorString *string `json:"errorString,omitempty"`
}

Returns information about an error state of the cluster.

func (*ErrorInfo) DeepCopy

func (in *ErrorInfo) DeepCopy() *ErrorInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ErrorInfo.

func (*ErrorInfo) DeepCopyInto

func (in *ErrorInfo) DeepCopyInto(out *ErrorInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Firehose

type Firehose struct {
	DeliveryStream *string `json:"deliveryStream,omitempty"`
	Enabled        *bool   `json:"enabled,omitempty"`
}

Firehose details for BrokerLogs.

func (*Firehose) DeepCopy

func (in *Firehose) DeepCopy() *Firehose

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Firehose.

func (*Firehose) DeepCopyInto

func (in *Firehose) DeepCopyInto(out *Firehose)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type IAM

type IAM struct {
	Enabled *bool `json:"enabled,omitempty"`
}

func (*IAM) DeepCopy

func (in *IAM) DeepCopy() *IAM

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new IAM.

func (*IAM) DeepCopyInto

func (in *IAM) DeepCopyInto(out *IAM)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type JmxExporter

type JmxExporter struct {
	EnabledInBroker *bool `json:"enabledInBroker,omitempty"`
}

Indicates whether you want to enable or disable the JMX Exporter.

func (*JmxExporter) DeepCopy

func (in *JmxExporter) DeepCopy() *JmxExporter

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JmxExporter.

func (*JmxExporter) DeepCopyInto

func (in *JmxExporter) DeepCopyInto(out *JmxExporter)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type JmxExporterInfo

type JmxExporterInfo struct {
	EnabledInBroker *bool `json:"enabledInBroker,omitempty"`
}

Indicates whether you want to enable or disable the JMX Exporter.

func (*JmxExporterInfo) DeepCopy

func (in *JmxExporterInfo) DeepCopy() *JmxExporterInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JmxExporterInfo.

func (*JmxExporterInfo) DeepCopyInto

func (in *JmxExporterInfo) DeepCopyInto(out *JmxExporterInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type KafkaVersion

type KafkaVersion struct {
	Version *string `json:"version,omitempty"`
}

Information about a Apache Kafka version.

func (*KafkaVersion) DeepCopy

func (in *KafkaVersion) DeepCopy() *KafkaVersion

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaVersion.

func (*KafkaVersion) DeepCopyInto

func (in *KafkaVersion) DeepCopyInto(out *KafkaVersion)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type KafkaVersionStatus

type KafkaVersionStatus string
const (
	KafkaVersionStatus_ACTIVE     KafkaVersionStatus = "ACTIVE"
	KafkaVersionStatus_DEPRECATED KafkaVersionStatus = "DEPRECATED"
)

type LoggingInfo

type LoggingInfo struct {
	// The broker logs configuration for this MSK cluster.
	BrokerLogs *BrokerLogs `json:"brokerLogs,omitempty"`
}

You can configure your MSK cluster to send broker logs to different destination types. This is a container for the configuration details related to broker logs.

func (*LoggingInfo) DeepCopy

func (in *LoggingInfo) DeepCopy() *LoggingInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LoggingInfo.

func (*LoggingInfo) DeepCopyInto

func (in *LoggingInfo) DeepCopyInto(out *LoggingInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type MutableClusterInfo

type MutableClusterInfo struct {
	// Includes all client authentication information.
	ClientAuthentication *ClientAuthentication `json:"clientAuthentication,omitempty"`
	// Specifies the configuration to use for the brokers.
	ConfigurationInfo *ConfigurationInfo `json:"configurationInfo,omitempty"`
	// Information about the broker access configuration.
	ConnectivityInfo *ConnectivityInfo `json:"connectivityInfo,omitempty"`
	// 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.
	EncryptionInfo *EncryptionInfo `json:"encryptionInfo,omitempty"`
	// Specifies which metrics are gathered for the MSK cluster. This property has
	// the following possible values: DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER,
	// and PER_TOPIC_PER_PARTITION. For a list of the metrics associated with each
	// of these levels of monitoring, see Monitoring (https://docs.aws.amazon.com/msk/latest/developerguide/monitoring.html).
	EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty"`
	InstanceType       *string `json:"instanceType,omitempty"`
	KafkaVersion       *string `json:"kafkaVersion,omitempty"`
	// You can configure your MSK cluster to send broker logs to different destination
	// types. This is a container for the configuration details related to broker
	// logs.
	LoggingInfo         *LoggingInfo `json:"loggingInfo,omitempty"`
	NumberOfBrokerNodes *int64       `json:"numberOfBrokerNodes,omitempty"`
	// JMX and Node monitoring for the MSK cluster.
	OpenMonitoring *OpenMonitoring `json:"openMonitoring,omitempty"`
	// Controls storage mode for various supported storage tiers.
	StorageMode *string `json:"storageMode,omitempty"`
}

Information about cluster attributes that can be updated via update APIs.

func (*MutableClusterInfo) DeepCopy

func (in *MutableClusterInfo) DeepCopy() *MutableClusterInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MutableClusterInfo.

func (*MutableClusterInfo) DeepCopyInto

func (in *MutableClusterInfo) DeepCopyInto(out *MutableClusterInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type NodeExporter

type NodeExporter struct {
	EnabledInBroker *bool `json:"enabledInBroker,omitempty"`
}

Indicates whether you want to enable or disable the Node Exporter.

func (*NodeExporter) DeepCopy

func (in *NodeExporter) DeepCopy() *NodeExporter

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NodeExporter.

func (*NodeExporter) DeepCopyInto

func (in *NodeExporter) DeepCopyInto(out *NodeExporter)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type NodeExporterInfo

type NodeExporterInfo struct {
	EnabledInBroker *bool `json:"enabledInBroker,omitempty"`
}

Indicates whether you want to enable or disable the Node Exporter.

func (*NodeExporterInfo) DeepCopy

func (in *NodeExporterInfo) DeepCopy() *NodeExporterInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NodeExporterInfo.

func (*NodeExporterInfo) DeepCopyInto

func (in *NodeExporterInfo) DeepCopyInto(out *NodeExporterInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type NodeInfo

type NodeInfo struct {
	AddedToClusterTime *string `json:"addedToClusterTime,omitempty"`
	InstanceType       *string `json:"instanceType,omitempty"`
	NodeARN            *string `json:"nodeARN,omitempty"`
}

The node information object.

func (*NodeInfo) DeepCopy

func (in *NodeInfo) DeepCopy() *NodeInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NodeInfo.

func (*NodeInfo) DeepCopyInto

func (in *NodeInfo) DeepCopyInto(out *NodeInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type NodeType

type NodeType string
const (
	NodeType_BROKER NodeType = "BROKER"
)

type OpenMonitoring

type OpenMonitoring struct {
	// Prometheus settings for open monitoring.
	Prometheus *Prometheus `json:"prometheus,omitempty"`
}

JMX and Node monitoring for the MSK cluster.

func (*OpenMonitoring) DeepCopy

func (in *OpenMonitoring) DeepCopy() *OpenMonitoring

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OpenMonitoring.

func (*OpenMonitoring) DeepCopyInto

func (in *OpenMonitoring) DeepCopyInto(out *OpenMonitoring)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OpenMonitoringInfo

type OpenMonitoringInfo struct {
	// Prometheus settings.
	Prometheus *PrometheusInfo `json:"prometheus,omitempty"`
}

JMX and Node monitoring for the MSK cluster.

func (*OpenMonitoringInfo) DeepCopy

func (in *OpenMonitoringInfo) DeepCopy() *OpenMonitoringInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OpenMonitoringInfo.

func (*OpenMonitoringInfo) DeepCopyInto

func (in *OpenMonitoringInfo) DeepCopyInto(out *OpenMonitoringInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Prometheus

type Prometheus struct {
	// Indicates whether you want to enable or disable the JMX Exporter.
	JmxExporter *JmxExporter `json:"jmxExporter,omitempty"`
	// Indicates whether you want to enable or disable the Node Exporter.
	NodeExporter *NodeExporter `json:"nodeExporter,omitempty"`
}

Prometheus settings for open monitoring.

func (*Prometheus) DeepCopy

func (in *Prometheus) DeepCopy() *Prometheus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Prometheus.

func (*Prometheus) DeepCopyInto

func (in *Prometheus) DeepCopyInto(out *Prometheus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PrometheusInfo

type PrometheusInfo struct {
	// Indicates whether you want to enable or disable the JMX Exporter.
	JmxExporter *JmxExporterInfo `json:"jmxExporter,omitempty"`
	// Indicates whether you want to enable or disable the Node Exporter.
	NodeExporter *NodeExporterInfo `json:"nodeExporter,omitempty"`
}

Prometheus settings.

func (*PrometheusInfo) DeepCopy

func (in *PrometheusInfo) DeepCopy() *PrometheusInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PrometheusInfo.

func (*PrometheusInfo) DeepCopyInto

func (in *PrometheusInfo) DeepCopyInto(out *PrometheusInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Provisioned

type Provisioned struct {
	// Describes the setup to be used for Apache Kafka broker nodes in the cluster.
	BrokerNodeGroupInfo *BrokerNodeGroupInfo `json:"brokerNodeGroupInfo,omitempty"`
	// Includes all client authentication information.
	ClientAuthentication *ClientAuthentication `json:"clientAuthentication,omitempty"`
	// Information about the current software installed on the cluster.
	CurrentBrokerSoftwareInfo *BrokerSoftwareInfo `json:"currentBrokerSoftwareInfo,omitempty"`
	// 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.
	EncryptionInfo *EncryptionInfo `json:"encryptionInfo,omitempty"`
	// Specifies which metrics are gathered for the MSK cluster. This property has
	// the following possible values: DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER,
	// and PER_TOPIC_PER_PARTITION. For a list of the metrics associated with each
	// of these levels of monitoring, see Monitoring (https://docs.aws.amazon.com/msk/latest/developerguide/monitoring.html).
	EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty"`
	// You can configure your MSK cluster to send broker logs to different destination
	// types. This is a container for the configuration details related to broker
	// logs.
	LoggingInfo         *LoggingInfo `json:"loggingInfo,omitempty"`
	NumberOfBrokerNodes *int64       `json:"numberOfBrokerNodes,omitempty"`
	// JMX and Node monitoring for the MSK cluster.
	OpenMonitoring *OpenMonitoringInfo `json:"openMonitoring,omitempty"`
	// Controls storage mode for various supported storage tiers.
	StorageMode               *string `json:"storageMode,omitempty"`
	ZookeeperConnectString    *string `json:"zookeeperConnectString,omitempty"`
	ZookeeperConnectStringTLS *string `json:"zookeeperConnectStringTLS,omitempty"`
}

Describes the provisioned cluster.

func (*Provisioned) DeepCopy

func (in *Provisioned) DeepCopy() *Provisioned

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Provisioned.

func (*Provisioned) DeepCopyInto

func (in *Provisioned) DeepCopyInto(out *Provisioned)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ProvisionedRequest

type ProvisionedRequest struct {
	// Describes the setup to be used for Apache Kafka broker nodes in the cluster.
	BrokerNodeGroupInfo *BrokerNodeGroupInfo `json:"brokerNodeGroupInfo,omitempty"`
	// Includes all client authentication information.
	ClientAuthentication *ClientAuthentication `json:"clientAuthentication,omitempty"`
	// Specifies the configuration to use for the brokers.
	ConfigurationInfo *ConfigurationInfo `json:"configurationInfo,omitempty"`
	// 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.
	EncryptionInfo *EncryptionInfo `json:"encryptionInfo,omitempty"`
	// Specifies which metrics are gathered for the MSK cluster. This property has
	// the following possible values: DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER,
	// and PER_TOPIC_PER_PARTITION. For a list of the metrics associated with each
	// of these levels of monitoring, see Monitoring (https://docs.aws.amazon.com/msk/latest/developerguide/monitoring.html).
	EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty"`
	KafkaVersion       *string `json:"kafkaVersion,omitempty"`
	// You can configure your MSK cluster to send broker logs to different destination
	// types. This is a container for the configuration details related to broker
	// logs.
	LoggingInfo         *LoggingInfo `json:"loggingInfo,omitempty"`
	NumberOfBrokerNodes *int64       `json:"numberOfBrokerNodes,omitempty"`
	// JMX and Node monitoring for the MSK cluster.
	OpenMonitoring *OpenMonitoringInfo `json:"openMonitoring,omitempty"`
	// Controls storage mode for various supported storage tiers.
	StorageMode *string `json:"storageMode,omitempty"`
}

Creates a provisioned cluster.

func (*ProvisionedRequest) DeepCopy

func (in *ProvisionedRequest) DeepCopy() *ProvisionedRequest

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ProvisionedRequest.

func (*ProvisionedRequest) DeepCopyInto

func (in *ProvisionedRequest) DeepCopyInto(out *ProvisionedRequest)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ProvisionedThroughput

type ProvisionedThroughput struct {
	Enabled          *bool  `json:"enabled,omitempty"`
	VolumeThroughput *int64 `json:"volumeThroughput,omitempty"`
}

Contains information about provisioned throughput for EBS storage volumes attached to kafka broker nodes.

func (*ProvisionedThroughput) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ProvisionedThroughput.

func (*ProvisionedThroughput) DeepCopyInto

func (in *ProvisionedThroughput) DeepCopyInto(out *ProvisionedThroughput)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PublicAccess

type PublicAccess struct {
	Type *string `json:"type_,omitempty"`
}

Broker public access control.

func (*PublicAccess) DeepCopy

func (in *PublicAccess) DeepCopy() *PublicAccess

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PublicAccess.

func (*PublicAccess) DeepCopyInto

func (in *PublicAccess) DeepCopyInto(out *PublicAccess)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type S3

type S3 struct {
	Bucket  *string `json:"bucket,omitempty"`
	Enabled *bool   `json:"enabled,omitempty"`
	Prefix  *string `json:"prefix,omitempty"`
}

The details of the Amazon S3 destination for broker logs.

func (*S3) DeepCopy

func (in *S3) DeepCopy() *S3

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new S3.

func (*S3) DeepCopyInto

func (in *S3) DeepCopyInto(out *S3)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SASL

type SASL struct {
	IAM   *IAM   `json:"iam,omitempty"`
	SCRAM *SCRAM `json:"scram,omitempty"`
}

func (*SASL) DeepCopy

func (in *SASL) DeepCopy() *SASL

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SASL.

func (*SASL) DeepCopyInto

func (in *SASL) DeepCopyInto(out *SASL)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SCRAM

type SCRAM struct {
	Enabled *bool `json:"enabled,omitempty"`
}

func (*SCRAM) DeepCopy

func (in *SCRAM) DeepCopy() *SCRAM

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SCRAM.

func (*SCRAM) DeepCopyInto

func (in *SCRAM) DeepCopyInto(out *SCRAM)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ServerlessSASL

type ServerlessSASL struct {
	IAM *IAM `json:"iam,omitempty"`
}

Describes the serverless cluster SASL information.

func (*ServerlessSASL) DeepCopy

func (in *ServerlessSASL) DeepCopy() *ServerlessSASL

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerlessSASL.

func (*ServerlessSASL) DeepCopyInto

func (in *ServerlessSASL) DeepCopyInto(out *ServerlessSASL)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StateInfo

type StateInfo struct {
	Code    *string `json:"code,omitempty"`
	Message *string `json:"message,omitempty"`
}

Contains information about the state of the Amazon MSK cluster.

func (*StateInfo) DeepCopy

func (in *StateInfo) DeepCopy() *StateInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StateInfo.

func (*StateInfo) DeepCopyInto

func (in *StateInfo) DeepCopyInto(out *StateInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StorageInfo

type StorageInfo struct {
	// Contains information about the EBS storage volumes attached to Apache Kafka
	// broker nodes.
	EBSStorageInfo *EBSStorageInfo `json:"ebsStorageInfo,omitempty"`
}

Contains information about storage volumes attached to MSK broker nodes.

func (*StorageInfo) DeepCopy

func (in *StorageInfo) DeepCopy() *StorageInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StorageInfo.

func (*StorageInfo) DeepCopyInto

func (in *StorageInfo) DeepCopyInto(out *StorageInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StorageMode

type StorageMode string
const (
	StorageMode_LOCAL  StorageMode = "LOCAL"
	StorageMode_TIERED StorageMode = "TIERED"
)

type TLS

type TLS struct {
	CertificateAuthorityARNList []*string `json:"certificateAuthorityARNList,omitempty"`
	Enabled                     *bool     `json:"enabled,omitempty"`
}

Details for client authentication using TLS.

func (*TLS) DeepCopy

func (in *TLS) DeepCopy() *TLS

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TLS.

func (*TLS) DeepCopyInto

func (in *TLS) DeepCopyInto(out *TLS)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Unauthenticated

type Unauthenticated struct {
	Enabled *bool `json:"enabled,omitempty"`
}

Contains information about unauthenticated traffic to the cluster.

func (*Unauthenticated) DeepCopy

func (in *Unauthenticated) DeepCopy() *Unauthenticated

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Unauthenticated.

func (*Unauthenticated) DeepCopyInto

func (in *Unauthenticated) DeepCopyInto(out *Unauthenticated)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type UnprocessedSCRAMSecret

type UnprocessedSCRAMSecret struct {
	ErrorCode    *string `json:"errorCode,omitempty"`
	ErrorMessage *string `json:"errorMessage,omitempty"`
	SecretARN    *string `json:"secretARN,omitempty"`
}

func (*UnprocessedSCRAMSecret) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UnprocessedSCRAMSecret.

func (*UnprocessedSCRAMSecret) DeepCopyInto

func (in *UnprocessedSCRAMSecret) DeepCopyInto(out *UnprocessedSCRAMSecret)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VPCConfig

type VPCConfig struct {
	SecurityGroupIDs []*string `json:"securityGroupIDs,omitempty"`
	SubnetIDs        []*string `json:"subnetIDs,omitempty"`
}

The configuration of the Amazon VPCs for the cluster.

func (*VPCConfig) DeepCopy

func (in *VPCConfig) DeepCopy() *VPCConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VPCConfig.

func (*VPCConfig) DeepCopyInto

func (in *VPCConfig) DeepCopyInto(out *VPCConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ZookeeperNodeInfo

type ZookeeperNodeInfo struct {
	AttachedENIID      *string   `json:"attachedENIID,omitempty"`
	ClientVPCIPAddress *string   `json:"clientVPCIPAddress,omitempty"`
	Endpoints          []*string `json:"endpoints,omitempty"`
	ZookeeperVersion   *string   `json:"zookeeperVersion,omitempty"`
}

Zookeeper node information.

func (*ZookeeperNodeInfo) DeepCopy

func (in *ZookeeperNodeInfo) DeepCopy() *ZookeeperNodeInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ZookeeperNodeInfo.

func (*ZookeeperNodeInfo) DeepCopyInto

func (in *ZookeeperNodeInfo) DeepCopyInto(out *ZookeeperNodeInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL