v1alpha1

package
v1.12.0 Latest Latest
Warning

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

 Go to latest Published: Aug 28, 2026 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

View Source 
const (
	// AssociatedSCRAMSecretsManagedByExternal is the value of the
	// AssociatedSCRAMSecretsManagedByAnnotation annotation that indicates that
	// the SCRAM secret associations of a cluster are managed by an external
	// entity. When set, the controller fully ignores the
	// `spec.associatedSCRAMSecrets` field.
	AssociatedSCRAMSecretsManagedByExternal = "external"
	// AssociatedSCRAMSecretsManagedByACKController is the value of the
	// AssociatedSCRAMSecretsManagedByAnnotation annotation that indicates that
	// the SCRAM secret associations of a cluster are managed by the ACK
	// controller. This is the default behavior.
	AssociatedSCRAMSecretsManagedByACKController = "ack-kafka-controller"
)

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
)
View Source 
var (
	// AssociatedSCRAMSecretsManagedByAnnotation is the annotation key used to
	// set the management style for the SCRAM secret associations of a cluster.
	// This annotation can only be set on a Cluster custom resource.
	//
	// The value of this annotation must be one of the following:
	//
	// - 'external':            The SCRAM secret associations are managed by an
	//                          external entity, causing the controller to
	//                          completely ignore the `spec.associatedSCRAMSecrets`
	//                          field. The controller will neither associate nor
	//                          disassociate any SCRAM secret, leaving association
	//                          management entirely to the customer.
	//
	// - 'ack-kafka-controller': The SCRAM secret associations are managed by the
	//                          ACK controller, causing the controller to reconcile
	//                          the set of associated SCRAM secrets with the value
	//                          of the `spec.associatedSCRAMSecrets` field.
	//
	// By default the SCRAM secret associations are managed by the controller. If
	// the annotation is not set, or the value is not one of the above, the
	// controller will default to managing the associations as if the annotation
	// was set to "ack-kafka-controller". Only the "external" value changes the
	// controller's behavior.
	AssociatedSCRAMSecretsManagedByAnnotation = fmt.Sprintf("%s/scram-secrets-managed-by", GroupVersion.Group)
)

Functions

This section is empty.

Types

type AmazonMskCluster added in v1.0.3 

type AmazonMskCluster struct {
	MskClusterARN *string `json:"mskClusterARN,omitempty"`
}

Details of an Amazon MSK Cluster.

func (*AmazonMskCluster) DeepCopy added in v1.0.3 

func (in *AmazonMskCluster) DeepCopy() *AmazonMskCluster

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

func (*AmazonMskCluster) DeepCopyInto added in v1.0.3 

func (in *AmazonMskCluster) DeepCopyInto(out *AmazonMskCluster)

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

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 {
	CloudWatchLogs *CloudWatchLogs `json:"cloudWatchLogs,omitempty"`
	Firehose       *Firehose       `json:"firehose,omitempty"`
	S3             *S3             `json:"s3,omitempty"`
}

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. This is an optional
	// parameter. If you don't specify it, Amazon MSK gives it the value DEFAULT.
	// You can also explicitly set this parameter to the value DEFAULT. No other
	// values are currently allowed.
	//
	// Amazon MSK distributes the broker nodes evenly across the Availability Zones
	// that correspond to the subnets you provide when you create the cluster.
	BrokerAZDistribution *string `json:"brokerAZDistribution,omitempty"`
	// Reference field for ClientSubnets
	ClientSubnetRefs []*ackv1alpha1.AWSResourceReferenceWrapper `json:"clientSubnetRefs,omitempty"`
	ClientSubnets    []*string                                  `json:"clientSubnets,omitempty"`
	// Information about the broker access configuration.
	ConnectivityInfo *ConnectivityInfo `json:"connectivityInfo,omitempty"`
	InstanceType     *string           `json:"instanceType,omitempty"`
	// Reference field for SecurityGroups
	SecurityGroupRefs []*ackv1alpha1.AWSResourceReferenceWrapper `json:"securityGroupRefs,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 {
	// Details for client authentication using SASL.
	SASL *SASL `json:"sasl,omitempty"`
	// Details for client authentication using TLS.
	TLS             *TLS             `json:"tls,omitempty"`
	Unauthenticated *Unauthenticated `json:"unauthenticated,omitempty"`
}

Includes all client authentication information.

func (*ClientAuthentication) DeepCopy 

func (in *ClientAuthentication) DeepCopy() *ClientAuthentication

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_PLAINTEXT     ClientBroker = "PLAINTEXT"
	ClientBroker_TLS           ClientBroker = "TLS"
	ClientBroker_TLS_PLAINTEXT ClientBroker = "TLS_PLAINTEXT"
)

type ClientVPCConnection added in v1.0.3 

type ClientVPCConnection struct {
	Authentication *string      `json:"authentication,omitempty"`
	CreationTime   *metav1.Time `json:"creationTime,omitempty"`
	Owner          *string      `json:"owner,omitempty"`
	// The state of a VPC connection.
	State            *string `json:"state,omitempty"`
	VPCConnectionARN *string `json:"vpcConnectionARN,omitempty"`
}

The client VPC connection object.

func (*ClientVPCConnection) DeepCopy added in v1.0.3 

func (in *ClientVPCConnection) DeepCopy() *ClientVPCConnection

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

func (*ClientVPCConnection) DeepCopyInto added in v1.0.3 

func (in *ClientVPCConnection) DeepCopyInto(out *ClientVPCConnection)

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

type CloudWatchLogs 

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

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"`
	// A type of an action required from the customer.
	CustomerActionStatus *string `json:"customerActionStatus,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"`
	LoggingInfo         *LoggingInfo `json:"loggingInfo,omitempty"`
	NumberOfBrokerNodes *int64       `json:"numberOfBrokerNodes,omitempty"`
	// JMX and Node monitoring for the MSK cluster.
	OpenMonitoring *OpenMonitoring `json:"openMonitoring,omitempty"`
	// Specifies whether or not intelligent rebalancing is turned on for a newly
	// created MSK Provisioned cluster with Express brokers. Intelligent rebalancing
	// performs automatic partition balancing operations when you scale your clusters
	// up or down. By default, intelligent rebalancing is ACTIVE for all new Express-based
	// clusters.
	Rebalancing *Rebalancing `json:"rebalancing,omitempty"`
	// The state of the Apache Kafka cluster.
	State     *string    `json:"state,omitempty"`
	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 

func (in *ClusterOperationInfo) DeepCopy() *ClusterOperationInfo

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 

func (in *ClusterOperationStep) DeepCopy() *ClusterOperationStep

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 

func (in *ClusterOperationStepInfo) DeepCopy() *ClusterOperationStepInfo

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 ClusterOperationV2 added in v1.0.3 

type ClusterOperationV2 struct {
	ClusterARN *string `json:"clusterARN,omitempty"`
	// The type of cluster.
	ClusterType    *string      `json:"clusterType,omitempty"`
	EndTime        *metav1.Time `json:"endTime,omitempty"`
	OperationARN   *string      `json:"operationARN,omitempty"`
	OperationState *string      `json:"operationState,omitempty"`
	OperationType  *string      `json:"operationType,omitempty"`
	StartTime      *metav1.Time `json:"startTime,omitempty"`
}

Returns information about a cluster operation.

func (*ClusterOperationV2) DeepCopy added in v1.0.3 

func (in *ClusterOperationV2) DeepCopy() *ClusterOperationV2

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

func (*ClusterOperationV2) DeepCopyInto added in v1.0.3 

func (in *ClusterOperationV2) DeepCopyInto(out *ClusterOperationV2)

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

type ClusterOperationV2Serverless added in v1.5.0 

type ClusterOperationV2Serverless struct {
	// Describes the cluster's connectivity information, such as its network type,
	// which is IPv4 or DUAL.
	SourceClusterInfo *ServerlessConnectivityInfo `json:"sourceClusterInfo,omitempty"`
	// Describes the cluster's connectivity information, such as its network type,
	// which is IPv4 or DUAL.
	TargetClusterInfo *ServerlessConnectivityInfo `json:"targetClusterInfo,omitempty"`
}

Returns information about a serverless cluster operation.

func (*ClusterOperationV2Serverless) DeepCopy added in v1.5.0 

func (in *ClusterOperationV2Serverless) DeepCopy() *ClusterOperationV2Serverless

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

func (*ClusterOperationV2Serverless) DeepCopyInto added in v1.5.0 

func (in *ClusterOperationV2Serverless) DeepCopyInto(out *ClusterOperationV2Serverless)

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

type ClusterOperationV2Summary added in v1.0.3 

type ClusterOperationV2Summary struct {
	ClusterARN *string `json:"clusterARN,omitempty"`
	// The type of cluster.
	ClusterType    *string      `json:"clusterType,omitempty"`
	EndTime        *metav1.Time `json:"endTime,omitempty"`
	OperationARN   *string      `json:"operationARN,omitempty"`
	OperationState *string      `json:"operationState,omitempty"`
	OperationType  *string      `json:"operationType,omitempty"`
	StartTime      *metav1.Time `json:"startTime,omitempty"`
}

Returns information about a cluster operation.

func (*ClusterOperationV2Summary) DeepCopy added in v1.0.3 

func (in *ClusterOperationV2Summary) DeepCopy() *ClusterOperationV2Summary

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

func (*ClusterOperationV2Summary) DeepCopyInto added in v1.0.3 

func (in *ClusterOperationV2Summary) DeepCopyInto(out *ClusterOperationV2Summary)

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

type ClusterSpec 

type ClusterSpec struct {
	AssociatedSCRAMSecretRefs []*ackv1alpha1.AWSResourceReferenceWrapper `json:"associatedSCRAMSecretRefs,omitempty"`
	AssociatedSCRAMSecrets    []*string                                  `json:"associatedSCRAMSecrets,omitempty"`
	// Information about the broker nodes in the cluster.
	// +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 brokers in
	// a 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  *LoggingInfo `json:"loggingInfo,omitempty"`
	// The name of the cluster.
	// +kubebuilder:validation:Required
	Name *string `json:"name"`
	// The number of broker nodes in the cluster.
	// +kubebuilder:validation:Required
	NumberOfBrokerNodes *int64 `json:"numberOfBrokerNodes"`
	// The settings for open monitoring.
	OpenMonitoring *OpenMonitoringInfo `json:"openMonitoring,omitempty"`
	// The cluster policy.
	Policy *string `json:"policy,omitempty"`
	// Specifies if intelligent rebalancing should be turned on for the new MSK
	// Provisioned cluster with Express brokers. By default, intelligent rebalancing
	// status is ACTIVE for all new clusters.
	Rebalancing *Rebalancing `json:"rebalancing,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.

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"`
	// +kubebuilder:validation:Optional
	BootstrapBrokerString *string `json:"bootstrapBrokerString,omitempty"`
	// +kubebuilder:validation:Optional
	BootstrapBrokerStringPublicSASLIAM *string `json:"bootstrapBrokerStringPublicSASLIAM,omitempty"`
	// +kubebuilder:validation:Optional
	BootstrapBrokerStringPublicSASLSCRAM *string `json:"bootstrapBrokerStringPublicSASLSCRAM,omitempty"`
	// +kubebuilder:validation:Optional
	BootstrapBrokerStringPublicTLS *string `json:"bootstrapBrokerStringPublicTLS,omitempty"`
	// +kubebuilder:validation:Optional
	BootstrapBrokerStringSASLIAM *string `json:"bootstrapBrokerStringSASLIAM,omitempty"`
	// +kubebuilder:validation:Optional
	BootstrapBrokerStringSASLSCRAM *string `json:"bootstrapBrokerStringSASLSCRAM,omitempty"`
	// +kubebuilder:validation:Optional
	BootstrapBrokerStringTLS *string `json:"bootstrapBrokerStringTLS,omitempty"`
	// +kubebuilder:validation:Optional
	BootstrapBrokerStringVPCConnectivitySASLIAM *string `json:"bootstrapBrokerStringVPCConnectivitySASLIAM,omitempty"`
	// +kubebuilder:validation:Optional
	BootstrapBrokerStringVPCConnectivitySASLSCRAM *string `json:"bootstrapBrokerStringVPCConnectivitySASLSCRAM,omitempty"`
	// +kubebuilder:validation:Optional
	BootstrapBrokerStringVPCConnectivityTLS *string `json:"bootstrapBrokerStringVPCConnectivityTLS,omitempty"`
	// The current version of the MSK cluster.
	// +kubebuilder:validation:Optional
	CurrentVersion *string `json:"currentVersion,omitempty"`
	// 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"`
	// +kubebuilder:validation:Optional
	ZookeeperConnectString *string `json:"zookeeperConnectString,omitempty"`
	// +kubebuilder:validation:Optional
	ZookeeperConnectStringTLS *string `json:"zookeeperConnectStringTLS,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"`
	// The type of cluster.
	ClusterType    *string      `json:"clusterType,omitempty"`
	CreationTime   *metav1.Time `json:"creationTime,omitempty"`
	CurrentVersion *string      `json:"currentVersion,omitempty"`
	// Provisioned cluster.
	Provisioned *Provisioned `json:"provisioned,omitempty"`
	// Serverless cluster.
	Serverless *Serverless `json:"serverless,omitempty"`
	// The state of the Apache Kafka cluster.
	State     *string            `json:"state,omitempty"`
	StateInfo *StateInfo         `json:"stateInfo,omitempty"`
	Tags      map[string]*string `json:"tags,omitempty"`
}

Returns information about a cluster.

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 

func (in *CompatibleKafkaVersion) DeepCopy() *CompatibleKafkaVersion

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 {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              ConfigurationSpec   `json:"spec,omitempty"`
	Status            ConfigurationStatus `json:"status,omitempty"`
}

Configuration is the Schema for the Configurations API +kubebuilder:object:root=true +kubebuilder:subresource:status

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.

func (*Configuration) DeepCopyObject added in v0.0.7 

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

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

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 ConfigurationList added in v0.0.7 

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

ConfigurationList contains a list of Configuration +kubebuilder:object:root=true

func (*ConfigurationList) DeepCopy added in v0.0.7 

func (in *ConfigurationList) DeepCopy() *ConfigurationList

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

func (*ConfigurationList) DeepCopyInto added in v0.0.7 

func (in *ConfigurationList) DeepCopyInto(out *ConfigurationList)

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

func (*ConfigurationList) DeepCopyObject added in v0.0.7 

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

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

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 

func (in *ConfigurationRevision) DeepCopy() *ConfigurationRevision

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 ConfigurationSpec added in v0.0.7 

type ConfigurationSpec struct {

	// The description of the configuration.
	Description *string `json:"description,omitempty"`
	// The versions of Apache Kafka with which you can use this MSK configuration.
	KafkaVersions []*string `json:"kafkaVersions,omitempty"`
	// The name of the configuration.
	// +kubebuilder:validation:Required
	Name *string `json:"name"`
	// Contents of the server.properties file. When using the API, you must ensure
	// that the contents of the file are base64 encoded. When using the AWS Management
	// Console, the SDK, or the AWS CLI, the contents of server.properties can be
	// in plaintext.
	// +kubebuilder:validation:Required
	ServerProperties []byte `json:"serverProperties"`
}

ConfigurationSpec defines the desired state of Configuration.

Represents an MSK Configuration.

func (*ConfigurationSpec) DeepCopy added in v0.0.7 

func (in *ConfigurationSpec) DeepCopy() *ConfigurationSpec

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

func (*ConfigurationSpec) DeepCopyInto added in v0.0.7 

func (in *ConfigurationSpec) DeepCopyInto(out *ConfigurationSpec)

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_DELETE_FAILED ConfigurationState = "DELETE_FAILED"
	ConfigurationState_DELETING      ConfigurationState = "DELETING"
)

type ConfigurationStatus added in v0.0.7 

type ConfigurationStatus 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 time when the configuration was created.
	// +kubebuilder:validation:Optional
	CreationTime *metav1.Time `json:"creationTime,omitempty"`
	// Latest revision of the configuration.
	// +kubebuilder:validation:Optional
	LatestRevision *ConfigurationRevision `json:"latestRevision,omitempty"`
	// The state of the configuration. The possible states are ACTIVE, DELETING,
	// and DELETE_FAILED.
	// +kubebuilder:validation:Optional
	State *string `json:"state,omitempty"`
}

ConfigurationStatus defines the observed state of Configuration

func (*ConfigurationStatus) DeepCopy added in v0.0.7 

func (in *ConfigurationStatus) DeepCopy() *ConfigurationStatus

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

func (*ConfigurationStatus) DeepCopyInto added in v0.0.7 

func (in *ConfigurationStatus) DeepCopyInto(out *ConfigurationStatus)

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

type Configuration_SDK added in v0.0.7 

type Configuration_SDK struct {
	ARN           *string      `json:"arn,omitempty"`
	CreationTime  *metav1.Time `json:"creationTime,omitempty"`
	Description   *string      `json:"description,omitempty"`
	KafkaVersions []*string    `json:"kafkaVersions,omitempty"`
	// Describes a configuration revision.
	LatestRevision *ConfigurationRevision `json:"latestRevision,omitempty"`
	Name           *string                `json:"name,omitempty"`
	// The state of a configuration.
	State *string `json:"state,omitempty"`
}

Represents an MSK Configuration.

func (*Configuration_SDK) DeepCopy added in v0.0.7 

func (in *Configuration_SDK) DeepCopy() *Configuration_SDK

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

func (*Configuration_SDK) DeepCopyInto added in v0.0.7 

func (in *Configuration_SDK) DeepCopyInto(out *Configuration_SDK)

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

type ConnectivityInfo 

type ConnectivityInfo struct {
	// The network type of the cluster, which is IPv4 or DUAL. The DUAL network
	// type uses both IPv4 and IPv6 addresses for your cluster and its resources.
	//
	// By default, a cluster uses the IPv4 network type.
	NetworkType *string `json:"networkType,omitempty"`
	// Public access control for brokers.
	PublicAccess *PublicAccess `json:"publicAccess,omitempty"`
	// VPC connectivity access control for brokers.
	VPCConnectivity *VPCConnectivity `json:"vpcConnectivity,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 ConsumerGroupReplication added in v1.0.3 

type ConsumerGroupReplication struct {
	DetectAndCopyNewConsumerGroups  *bool `json:"detectAndCopyNewConsumerGroups,omitempty"`
	SynchroniseConsumerGroupOffsets *bool `json:"synchroniseConsumerGroupOffsets,omitempty"`
}

Details about consumer group replication.

func (*ConsumerGroupReplication) DeepCopy added in v1.0.3 

func (in *ConsumerGroupReplication) DeepCopy() *ConsumerGroupReplication

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

func (*ConsumerGroupReplication) DeepCopyInto added in v1.0.3 

func (in *ConsumerGroupReplication) DeepCopyInto(out *ConsumerGroupReplication)

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

type ConsumerGroupReplicationUpdate added in v1.0.3 

type ConsumerGroupReplicationUpdate struct {
	DetectAndCopyNewConsumerGroups  *bool `json:"detectAndCopyNewConsumerGroups,omitempty"`
	SynchroniseConsumerGroupOffsets *bool `json:"synchroniseConsumerGroupOffsets,omitempty"`
}

Details about consumer group replication.

func (*ConsumerGroupReplicationUpdate) DeepCopy added in v1.0.3 

func (in *ConsumerGroupReplicationUpdate) DeepCopy() *ConsumerGroupReplicationUpdate

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

func (*ConsumerGroupReplicationUpdate) DeepCopyInto added in v1.0.3 

func (in *ConsumerGroupReplicationUpdate) DeepCopyInto(out *ConsumerGroupReplicationUpdate)

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

type ControllerNodeInfo added in v1.0.3 

type ControllerNodeInfo struct {
	Endpoints []*string `json:"endpoints,omitempty"`
}

Controller node information.

func (*ControllerNodeInfo) DeepCopy added in v1.0.3 

func (in *ControllerNodeInfo) DeepCopy() *ControllerNodeInfo

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

func (*ControllerNodeInfo) DeepCopyInto added in v1.0.3 

func (in *ControllerNodeInfo) DeepCopyInto(out *ControllerNodeInfo)

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

type CustomerActionStatus added in v1.0.3 

type CustomerActionStatus string
const (
	CustomerActionStatus_ACTION_RECOMMENDED       CustomerActionStatus = "ACTION_RECOMMENDED"
	CustomerActionStatus_CRITICAL_ACTION_REQUIRED CustomerActionStatus = "CRITICAL_ACTION_REQUIRED"
	CustomerActionStatus_NONE                     CustomerActionStatus = "NONE"
)

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"`
}

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"`
}

Details for IAM access control.

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 turn on or turn off 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 turn on or turn off 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 KafkaClusterClientVPCConfig added in v1.0.3 

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

Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.

func (*KafkaClusterClientVPCConfig) DeepCopy added in v1.0.3 

func (in *KafkaClusterClientVPCConfig) DeepCopy() *KafkaClusterClientVPCConfig

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

func (*KafkaClusterClientVPCConfig) DeepCopyInto added in v1.0.3 

func (in *KafkaClusterClientVPCConfig) DeepCopyInto(out *KafkaClusterClientVPCConfig)

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

type KafkaClusterDescription added in v1.0.3 

type KafkaClusterDescription struct {
	KafkaClusterAlias *string `json:"kafkaClusterAlias,omitempty"`
}

Information about Kafka Cluster used as source / target for replication.

func (*KafkaClusterDescription) DeepCopy added in v1.0.3 

func (in *KafkaClusterDescription) DeepCopy() *KafkaClusterDescription

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

func (*KafkaClusterDescription) DeepCopyInto added in v1.0.3 

func (in *KafkaClusterDescription) DeepCopyInto(out *KafkaClusterDescription)

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

type KafkaClusterSummary added in v1.0.3 

type KafkaClusterSummary struct {
	KafkaClusterAlias *string `json:"kafkaClusterAlias,omitempty"`
}

Summarized information about Kafka Cluster used as source / target for replication.

func (*KafkaClusterSummary) DeepCopy added in v1.0.3 

func (in *KafkaClusterSummary) DeepCopy() *KafkaClusterSummary

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

func (*KafkaClusterSummary) DeepCopyInto added in v1.0.3 

func (in *KafkaClusterSummary) DeepCopyInto(out *KafkaClusterSummary)

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"`
}

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 {
	BrokerLogs *BrokerLogs `json:"brokerLogs,omitempty"`
}

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"`
	LoggingInfo         *LoggingInfo `json:"loggingInfo,omitempty"`
	NumberOfBrokerNodes *int64       `json:"numberOfBrokerNodes,omitempty"`
	// JMX and Node monitoring for the MSK cluster.
	OpenMonitoring *OpenMonitoring `json:"openMonitoring,omitempty"`
	// Specifies whether or not intelligent rebalancing is turned on for a newly
	// created MSK Provisioned cluster with Express brokers. Intelligent rebalancing
	// performs automatic partition balancing operations when you scale your clusters
	// up or down. By default, intelligent rebalancing is ACTIVE for all new Express-based
	// clusters.
	Rebalancing *Rebalancing `json:"rebalancing,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 NetworkType added in v1.5.0 

type NetworkType string
const (
	NetworkType_DUAL NetworkType = "DUAL"
	NetworkType_IPV4 NetworkType = "IPV4"
)

type NodeExporter 

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

Indicates whether you want to turn on or turn off 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 turn on or turn off 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.
	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 turn on or turn off the JMX Exporter.
	JmxExporter *JmxExporter `json:"jmxExporter,omitempty"`
	// Indicates whether you want to turn on or turn off the Node Exporter.
	NodeExporter *NodeExporter `json:"nodeExporter,omitempty"`
}

Prometheus settings.

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 turn on or turn off the JMX Exporter.
	JmxExporter *JmxExporterInfo `json:"jmxExporter,omitempty"`
	// Indicates whether you want to turn on or turn off 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"`
	// A type of an action required from the customer.
	CustomerActionStatus *string `json:"customerActionStatus,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"`
	LoggingInfo         *LoggingInfo `json:"loggingInfo,omitempty"`
	NumberOfBrokerNodes *int64       `json:"numberOfBrokerNodes,omitempty"`
	// JMX and Node monitoring for the MSK cluster.
	OpenMonitoring *OpenMonitoringInfo `json:"openMonitoring,omitempty"`
	// Specifies whether or not intelligent rebalancing is turned on for a newly
	// created MSK Provisioned cluster with Express brokers. Intelligent rebalancing
	// performs automatic partition balancing operations when you scale your clusters
	// up or down. By default, intelligent rebalancing is ACTIVE for all new Express-based
	// clusters.
	Rebalancing *Rebalancing `json:"rebalancing,omitempty"`
	// Controls storage mode for various supported storage tiers.
	StorageMode               *string `json:"storageMode,omitempty"`
	ZookeeperConnectString    *string `json:"zookeeperConnectString,omitempty"`
	ZookeeperConnectStringTLS *string `json:"zookeeperConnectStringTLS,omitempty"`
}

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"`
	LoggingInfo         *LoggingInfo `json:"loggingInfo,omitempty"`
	NumberOfBrokerNodes *int64       `json:"numberOfBrokerNodes,omitempty"`
	// JMX and Node monitoring for the MSK cluster.
	OpenMonitoring *OpenMonitoringInfo `json:"openMonitoring,omitempty"`
	// Specifies whether or not intelligent rebalancing is turned on for a newly
	// created MSK Provisioned cluster with Express brokers. Intelligent rebalancing
	// performs automatic partition balancing operations when you scale your clusters
	// up or down. By default, intelligent rebalancing is ACTIVE for all new Express-based
	// clusters.
	Rebalancing *Rebalancing `json:"rebalancing,omitempty"`
	// Controls storage mode for various supported storage tiers.
	StorageMode *string `json:"storageMode,omitempty"`
}

Provisioned cluster request.

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 

func (in *ProvisionedThroughput) DeepCopy() *ProvisionedThroughput

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"`
}

Public access control for brokers.

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 Rebalancing added in v1.5.0 

type Rebalancing struct {
	// Intelligent rebalancing status. The default intelligent rebalancing status
	// is ACTIVE for all new Express-based clusters.
	Status *string `json:"status,omitempty"`
}

Specifies whether or not intelligent rebalancing is turned on for a newly created MSK Provisioned cluster with Express brokers. Intelligent rebalancing performs automatic partition balancing operations when you scale your clusters up or down. By default, intelligent rebalancing is ACTIVE for all new Express-based clusters.

func (*Rebalancing) DeepCopy added in v1.5.0 

func (in *Rebalancing) DeepCopy() *Rebalancing

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

func (*Rebalancing) DeepCopyInto added in v1.5.0 

func (in *Rebalancing) DeepCopyInto(out *Rebalancing)

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

type RebalancingStatus added in v1.5.0 

type RebalancingStatus string
const (
	RebalancingStatus_ACTIVE RebalancingStatus = "ACTIVE"
	RebalancingStatus_PAUSED RebalancingStatus = "PAUSED"
)

type ReplicationInfo added in v1.0.3 

type ReplicationInfo struct {
	SourceKafkaClusterARN *string `json:"sourceKafkaClusterARN,omitempty"`
	TargetKafkaClusterARN *string `json:"targetKafkaClusterARN,omitempty"`
}

Specifies configuration for replication between a source and target Kafka cluster.

func (*ReplicationInfo) DeepCopy added in v1.0.3 

func (in *ReplicationInfo) DeepCopy() *ReplicationInfo

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

func (*ReplicationInfo) DeepCopyInto added in v1.0.3 

func (in *ReplicationInfo) DeepCopyInto(out *ReplicationInfo)

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

type ReplicationInfoDescription added in v1.0.3 

type ReplicationInfoDescription struct {
	SourceKafkaClusterAlias *string `json:"sourceKafkaClusterAlias,omitempty"`
	TargetKafkaClusterAlias *string `json:"targetKafkaClusterAlias,omitempty"`
}

Specifies configuration for replication between a source and target Kafka cluster (sourceKafkaClusterAlias -> targetKafkaClusterAlias)

func (*ReplicationInfoDescription) DeepCopy added in v1.0.3 

func (in *ReplicationInfoDescription) DeepCopy() *ReplicationInfoDescription

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

func (*ReplicationInfoDescription) DeepCopyInto added in v1.0.3 

func (in *ReplicationInfoDescription) DeepCopyInto(out *ReplicationInfoDescription)

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

type ReplicationInfoSummary added in v1.0.3 

type ReplicationInfoSummary struct {
	SourceKafkaClusterAlias *string `json:"sourceKafkaClusterAlias,omitempty"`
	TargetKafkaClusterAlias *string `json:"targetKafkaClusterAlias,omitempty"`
}

Summarized information of replication between clusters.

func (*ReplicationInfoSummary) DeepCopy added in v1.0.3 

func (in *ReplicationInfoSummary) DeepCopy() *ReplicationInfoSummary

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

func (*ReplicationInfoSummary) DeepCopyInto added in v1.0.3 

func (in *ReplicationInfoSummary) DeepCopyInto(out *ReplicationInfoSummary)

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

type ReplicationStartingPositionType added in v1.0.3 

type ReplicationStartingPositionType string
const (
	ReplicationStartingPositionType_EARLIEST ReplicationStartingPositionType = "EARLIEST"
	ReplicationStartingPositionType_LATEST   ReplicationStartingPositionType = "LATEST"
)

type ReplicationStateInfo added in v1.0.3 

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

Details about the state of a replicator

func (*ReplicationStateInfo) DeepCopy added in v1.0.3 

func (in *ReplicationStateInfo) DeepCopy() *ReplicationStateInfo

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

func (*ReplicationStateInfo) DeepCopyInto added in v1.0.3 

func (in *ReplicationStateInfo) DeepCopyInto(out *ReplicationStateInfo)

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

type ReplicationTopicNameConfigurationType added in v1.0.3 

type ReplicationTopicNameConfigurationType string
const (
	ReplicationTopicNameConfigurationType_IDENTICAL                          ReplicationTopicNameConfigurationType = "IDENTICAL"
	ReplicationTopicNameConfigurationType_PREFIXED_WITH_SOURCE_CLUSTER_ALIAS ReplicationTopicNameConfigurationType = "PREFIXED_WITH_SOURCE_CLUSTER_ALIAS"
)

type ReplicatorState added in v1.0.3 

type ReplicatorState string
const (
	ReplicatorState_CREATING ReplicatorState = "CREATING"
	ReplicatorState_DELETING ReplicatorState = "DELETING"
	ReplicatorState_FAILED   ReplicatorState = "FAILED"
	ReplicatorState_RUNNING  ReplicatorState = "RUNNING"
	ReplicatorState_UPDATING ReplicatorState = "UPDATING"
)

type ReplicatorSummary added in v1.0.3 

type ReplicatorSummary struct {
	CreationTime          *metav1.Time `json:"creationTime,omitempty"`
	CurrentVersion        *string      `json:"currentVersion,omitempty"`
	IsReplicatorReference *bool        `json:"isReplicatorReference,omitempty"`
	ReplicatorARN         *string      `json:"replicatorARN,omitempty"`
	ReplicatorName        *string      `json:"replicatorName,omitempty"`
	ReplicatorResourceARN *string      `json:"replicatorResourceARN,omitempty"`
}

Information about a replicator.

func (*ReplicatorSummary) DeepCopy added in v1.0.3 

func (in *ReplicatorSummary) DeepCopy() *ReplicatorSummary

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

func (*ReplicatorSummary) DeepCopyInto added in v1.0.3 

func (in *ReplicatorSummary) DeepCopyInto(out *ReplicatorSummary)

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"`
}

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 {
	// Details for IAM access control.
	IAM *IAM `json:"iam,omitempty"`
	// Details for SASL/SCRAM client authentication.
	SCRAM *SCRAM `json:"scram,omitempty"`
}

Details for client authentication using SASL.

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"`
}

Details for SASL/SCRAM client authentication.

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 Serverless added in v1.1.0 

type Serverless struct {
	// Includes all client authentication information.
	ClientAuthentication *ServerlessClientAuthentication `json:"clientAuthentication,omitempty"`
	// Describes the cluster's connectivity information, such as its network type,
	// which is IPv4 or DUAL.
	ConnectivityInfo *ServerlessConnectivityInfo `json:"connectivityInfo,omitempty"`
	VPCConfigs       []*VPCConfig                `json:"vpcConfigs,omitempty"`
}

Serverless cluster.

func (*Serverless) DeepCopy added in v1.1.0 

func (in *Serverless) DeepCopy() *Serverless

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

func (*Serverless) DeepCopyInto added in v1.1.0 

func (in *Serverless) DeepCopyInto(out *Serverless)

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

type ServerlessClientAuthentication added in v1.1.0 

type ServerlessClientAuthentication struct {
	// Details for client authentication using SASL.
	SASL *ServerlessSASL `json:"sasl,omitempty"`
}

Includes all client authentication information.

func (*ServerlessClientAuthentication) DeepCopy added in v1.1.0 

func (in *ServerlessClientAuthentication) DeepCopy() *ServerlessClientAuthentication

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

func (*ServerlessClientAuthentication) DeepCopyInto added in v1.1.0 

func (in *ServerlessClientAuthentication) DeepCopyInto(out *ServerlessClientAuthentication)

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

type ServerlessCluster added in v1.1.0 

type ServerlessCluster struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              ServerlessClusterSpec   `json:"spec,omitempty"`
	Status            ServerlessClusterStatus `json:"status,omitempty"`
}

ServerlessCluster is the Schema for the ServerlessClusters API +kubebuilder:object:root=true +kubebuilder:subresource:status

func (*ServerlessCluster) DeepCopy added in v1.1.0 

func (in *ServerlessCluster) DeepCopy() *ServerlessCluster

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

func (*ServerlessCluster) DeepCopyInto added in v1.1.0 

func (in *ServerlessCluster) DeepCopyInto(out *ServerlessCluster)

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

func (*ServerlessCluster) DeepCopyObject added in v1.1.0 

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

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

type ServerlessClusterList added in v1.1.0 

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

ServerlessClusterList contains a list of ServerlessCluster +kubebuilder:object:root=true

func (*ServerlessClusterList) DeepCopy added in v1.1.0 

func (in *ServerlessClusterList) DeepCopy() *ServerlessClusterList

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

func (*ServerlessClusterList) DeepCopyInto added in v1.1.0 

func (in *ServerlessClusterList) DeepCopyInto(out *ServerlessClusterList)

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

func (*ServerlessClusterList) DeepCopyObject added in v1.1.0 

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

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

type ServerlessClusterSpec added in v1.1.0 

type ServerlessClusterSpec struct {
	AssociatedSCRAMSecretRefs []*ackv1alpha1.AWSResourceReferenceWrapper `json:"associatedSCRAMSecretRefs,omitempty"`
	AssociatedSCRAMSecrets    []*string                                  `json:"associatedSCRAMSecrets,omitempty"`
	// The name of the cluster.
	// +kubebuilder:validation:Required
	Name *string `json:"name"`
	// The cluster policy.
	Policy *string `json:"policy,omitempty"`
	// Information about the provisioned cluster.
	Provisioned *ProvisionedRequest `json:"provisioned,omitempty"`
	// Information about the serverless cluster.
	Serverless *ServerlessRequest `json:"serverless,omitempty"`
	// A map of tags that you want the cluster to have.
	Tags map[string]*string `json:"tags,omitempty"`
}

ServerlessClusterSpec defines the desired state of ServerlessCluster.

func (*ServerlessClusterSpec) DeepCopy added in v1.1.0 

func (in *ServerlessClusterSpec) DeepCopy() *ServerlessClusterSpec

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

func (*ServerlessClusterSpec) DeepCopyInto added in v1.1.0 

func (in *ServerlessClusterSpec) DeepCopyInto(out *ServerlessClusterSpec)

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

type ServerlessClusterStatus added in v1.1.0 

type ServerlessClusterStatus 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 current version of the MSK cluster.
	// +kubebuilder:validation:Optional
	CurrentVersion *string `json:"currentVersion,omitempty"`
	// 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"`
	// The type of the cluster. The possible states are PROVISIONED or SERVERLESS.
	// +kubebuilder:validation:Optional
	Type *string `json:"type,omitempty"`
}

ServerlessClusterStatus defines the observed state of ServerlessCluster

func (*ServerlessClusterStatus) DeepCopy added in v1.1.0 

func (in *ServerlessClusterStatus) DeepCopy() *ServerlessClusterStatus

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

func (*ServerlessClusterStatus) DeepCopyInto added in v1.1.0 

func (in *ServerlessClusterStatus) DeepCopyInto(out *ServerlessClusterStatus)

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

type ServerlessConnectivityInfo added in v1.5.0 

type ServerlessConnectivityInfo struct {
	// The network type of the cluster, which is IPv4 or DUAL. The DUAL network
	// type uses both IPv4 and IPv6 addresses for your cluster and its resources.
	//
	// By default, a cluster uses the IPv4 network type.
	NetworkType *string `json:"networkType,omitempty"`
}

Describes the cluster's connectivity information, such as its network type, which is IPv4 or DUAL.

func (*ServerlessConnectivityInfo) DeepCopy added in v1.5.0 

func (in *ServerlessConnectivityInfo) DeepCopy() *ServerlessConnectivityInfo

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

func (*ServerlessConnectivityInfo) DeepCopyInto added in v1.5.0 

func (in *ServerlessConnectivityInfo) DeepCopyInto(out *ServerlessConnectivityInfo)

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

type ServerlessRequest added in v1.1.0 

type ServerlessRequest struct {
	// Includes all client authentication information.
	ClientAuthentication *ServerlessClientAuthentication `json:"clientAuthentication,omitempty"`
	VPCConfigs           []*VPCConfig                    `json:"vpcConfigs,omitempty"`
}

Serverless cluster request.

func (*ServerlessRequest) DeepCopy added in v1.1.0 

func (in *ServerlessRequest) DeepCopy() *ServerlessRequest

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

func (*ServerlessRequest) DeepCopyInto added in v1.1.0 

func (in *ServerlessRequest) DeepCopyInto(out *ServerlessRequest)

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

type ServerlessSASL 

type ServerlessSASL struct {
	// Details for IAM access control.
	IAM *IAM `json:"iam,omitempty"`
}

Details for client authentication using SASL.

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"`
}

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 TargetCompressionType added in v1.0.3 

type TargetCompressionType string
const (
	TargetCompressionType_GZIP   TargetCompressionType = "GZIP"
	TargetCompressionType_LZ4    TargetCompressionType = "LZ4"
	TargetCompressionType_NONE   TargetCompressionType = "NONE"
	TargetCompressionType_SNAPPY TargetCompressionType = "SNAPPY"
	TargetCompressionType_ZSTD   TargetCompressionType = "ZSTD"
)

type TopicInfo added in v1.5.0 

type TopicInfo struct {
	OutOfSyncReplicaCount *int64  `json:"outOfSyncReplicaCount,omitempty"`
	PartitionCount        *int64  `json:"partitionCount,omitempty"`
	ReplicationFactor     *int64  `json:"replicationFactor,omitempty"`
	TopicARN              *string `json:"topicARN,omitempty"`
	TopicName             *string `json:"topicName,omitempty"`
}

Includes identification info about the topic.

func (*TopicInfo) DeepCopy added in v1.5.0 

func (in *TopicInfo) DeepCopy() *TopicInfo

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

func (*TopicInfo) DeepCopyInto added in v1.5.0 

func (in *TopicInfo) DeepCopyInto(out *TopicInfo)

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

type TopicPartitionInfo added in v1.5.0 

type TopicPartitionInfo struct {
	Leader    *int64 `json:"leader,omitempty"`
	Partition *int64 `json:"partition,omitempty"`
}

Contains information about a topic partition.

func (*TopicPartitionInfo) DeepCopy added in v1.5.0 

func (in *TopicPartitionInfo) DeepCopy() *TopicPartitionInfo

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

func (*TopicPartitionInfo) DeepCopyInto added in v1.5.0 

func (in *TopicPartitionInfo) DeepCopyInto(out *TopicPartitionInfo)

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

type TopicReplication added in v1.0.3 

type TopicReplication struct {
	CopyAccessControlListsForTopics *bool `json:"copyAccessControlListsForTopics,omitempty"`
	CopyTopicConfigurations         *bool `json:"copyTopicConfigurations,omitempty"`
	DetectAndCopyNewTopics          *bool `json:"detectAndCopyNewTopics,omitempty"`
}

Details about topic replication.

func (*TopicReplication) DeepCopy added in v1.0.3 

func (in *TopicReplication) DeepCopy() *TopicReplication

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

func (*TopicReplication) DeepCopyInto added in v1.0.3 

func (in *TopicReplication) DeepCopyInto(out *TopicReplication)

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

type TopicReplicationUpdate added in v1.0.3 

type TopicReplicationUpdate struct {
	CopyAccessControlListsForTopics *bool `json:"copyAccessControlListsForTopics,omitempty"`
	CopyTopicConfigurations         *bool `json:"copyTopicConfigurations,omitempty"`
	DetectAndCopyNewTopics          *bool `json:"detectAndCopyNewTopics,omitempty"`
}

Details for updating the topic replication of a replicator.

func (*TopicReplicationUpdate) DeepCopy added in v1.0.3 

func (in *TopicReplicationUpdate) DeepCopy() *TopicReplicationUpdate

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

func (*TopicReplicationUpdate) DeepCopyInto added in v1.0.3 

func (in *TopicReplicationUpdate) DeepCopyInto(out *TopicReplicationUpdate)

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

type TopicState added in v1.5.0 

type TopicState string
const (
	TopicState_ACTIVE   TopicState = "ACTIVE"
	TopicState_CREATING TopicState = "CREATING"
	TopicState_DELETING TopicState = "DELETING"
	TopicState_UPDATING TopicState = "UPDATING"
)

type Unauthenticated 

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

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"`
}

Error info for scram secret associate/disassociate failure.

func (*UnprocessedSCRAMSecret) DeepCopy 

func (in *UnprocessedSCRAMSecret) DeepCopy() *UnprocessedSCRAMSecret

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 UserIdentity added in v1.0.3 

type UserIdentity struct {
	PrincipalID *string `json:"principalID,omitempty"`
}

Description of the requester that calls the API operation.

func (*UserIdentity) DeepCopy added in v1.0.3 

func (in *UserIdentity) DeepCopy() *UserIdentity

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

func (*UserIdentity) DeepCopyInto added in v1.0.3 

func (in *UserIdentity) DeepCopyInto(out *UserIdentity)

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

type UserIdentityType added in v1.0.3 

type UserIdentityType string
const (
	UserIdentityType_AWSACCOUNT UserIdentityType = "AWSACCOUNT"
	UserIdentityType_AWSSERVICE UserIdentityType = "AWSSERVICE"
)

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 VPCConnection added in v1.0.3 

type VPCConnection struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              VPCConnectionSpec   `json:"spec,omitempty"`
	Status            VPCConnectionStatus `json:"status,omitempty"`
}

VPCConnection is the Schema for the VPCConnections API +kubebuilder:object:root=true +kubebuilder:subresource:status

func (*VPCConnection) DeepCopy added in v1.0.3 

func (in *VPCConnection) DeepCopy() *VPCConnection

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

func (*VPCConnection) DeepCopyInto added in v1.0.3 

func (in *VPCConnection) DeepCopyInto(out *VPCConnection)

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

func (*VPCConnection) DeepCopyObject added in v1.9.0 

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

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

type VPCConnectionInfo added in v1.0.3 

type VPCConnectionInfo struct {
	CreationTime     *metav1.Time `json:"creationTime,omitempty"`
	Owner            *string      `json:"owner,omitempty"`
	VPCConnectionARN *string      `json:"vpcConnectionARN,omitempty"`
}

Description of the VPC connection.

func (*VPCConnectionInfo) DeepCopy added in v1.0.3 

func (in *VPCConnectionInfo) DeepCopy() *VPCConnectionInfo

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

func (*VPCConnectionInfo) DeepCopyInto added in v1.0.3 

func (in *VPCConnectionInfo) DeepCopyInto(out *VPCConnectionInfo)

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

type VPCConnectionInfoServerless added in v1.0.3 

type VPCConnectionInfoServerless struct {
	CreationTime     *metav1.Time `json:"creationTime,omitempty"`
	Owner            *string      `json:"owner,omitempty"`
	VPCConnectionARN *string      `json:"vpcConnectionARN,omitempty"`
}

Description of the VPC connection.

func (*VPCConnectionInfoServerless) DeepCopy added in v1.0.3 

func (in *VPCConnectionInfoServerless) DeepCopy() *VPCConnectionInfoServerless

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

func (*VPCConnectionInfoServerless) DeepCopyInto added in v1.0.3 

func (in *VPCConnectionInfoServerless) DeepCopyInto(out *VPCConnectionInfoServerless)

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

type VPCConnectionList added in v1.9.0 

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

VPCConnectionList contains a list of VPCConnection +kubebuilder:object:root=true

func (*VPCConnectionList) DeepCopy added in v1.9.0 

func (in *VPCConnectionList) DeepCopy() *VPCConnectionList

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

func (*VPCConnectionList) DeepCopyInto added in v1.9.0 

func (in *VPCConnectionList) DeepCopyInto(out *VPCConnectionList)

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

func (*VPCConnectionList) DeepCopyObject added in v1.9.0 

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

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

type VPCConnectionSpec added in v1.9.0 

type VPCConnectionSpec struct {

	// The authentication type of VPC connection.
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable once set"
	// +kubebuilder:validation:Required
	Authentication   *string                                    `json:"authentication"`
	ClientSubnetRefs []*ackv1alpha1.AWSResourceReferenceWrapper `json:"clientSubnetRefs,omitempty"`
	// The list of client subnets.
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable once set"
	ClientSubnets     []*string                                  `json:"clientSubnets,omitempty"`
	SecurityGroupRefs []*ackv1alpha1.AWSResourceReferenceWrapper `json:"securityGroupRefs,omitempty"`
	// The list of security groups.
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable once set"
	SecurityGroups []*string `json:"securityGroups,omitempty"`
	// A map of tags for the VPC connection.
	Tags map[string]*string `json:"tags,omitempty"`
	// The cluster Amazon Resource Name (ARN) for the VPC connection.
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable once set"
	TargetClusterARN *string                                  `json:"targetClusterARN,omitempty"`
	TargetClusterRef *ackv1alpha1.AWSResourceReferenceWrapper `json:"targetClusterRef,omitempty"`
	// The VPC ID of VPC connection.
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable once set"
	VPCID  *string                                  `json:"vpcID,omitempty"`
	VPCRef *ackv1alpha1.AWSResourceReferenceWrapper `json:"vpcRef,omitempty"`
}

VpcConnectionSpec defines the desired state of VpcConnection.

The VPC connection object.

func (*VPCConnectionSpec) DeepCopy added in v1.9.0 

func (in *VPCConnectionSpec) DeepCopy() *VPCConnectionSpec

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

func (*VPCConnectionSpec) DeepCopyInto added in v1.9.0 

func (in *VPCConnectionSpec) DeepCopyInto(out *VPCConnectionSpec)

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

type VPCConnectionState added in v1.0.3 

type VPCConnectionState string
const (
	VPCConnectionState_AVAILABLE    VPCConnectionState = "AVAILABLE"
	VPCConnectionState_CREATING     VPCConnectionState = "CREATING"
	VPCConnectionState_DEACTIVATING VPCConnectionState = "DEACTIVATING"
	VPCConnectionState_DELETING     VPCConnectionState = "DELETING"
	VPCConnectionState_FAILED       VPCConnectionState = "FAILED"
	VPCConnectionState_INACTIVE     VPCConnectionState = "INACTIVE"
	VPCConnectionState_REJECTED     VPCConnectionState = "REJECTED"
	VPCConnectionState_REJECTING    VPCConnectionState = "REJECTING"
)

type VPCConnectionStatus added in v1.9.0 

type VPCConnectionStatus 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 creation time of VPC connection.
	// +kubebuilder:validation:Optional
	CreationTime *metav1.Time `json:"creationTime,omitempty"`
	// The State of Vpc Connection.
	// +kubebuilder:validation:Optional
	State *string `json:"state,omitempty"`
}

VPCConnectionStatus defines the observed state of VPCConnection

func (*VPCConnectionStatus) DeepCopy added in v1.9.0 

func (in *VPCConnectionStatus) DeepCopy() *VPCConnectionStatus

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

func (*VPCConnectionStatus) DeepCopyInto added in v1.9.0 

func (in *VPCConnectionStatus) DeepCopyInto(out *VPCConnectionStatus)

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

type VPCConnection_SDK added in v1.9.0 

type VPCConnection_SDK struct {
	Authentication *string      `json:"authentication,omitempty"`
	CreationTime   *metav1.Time `json:"creationTime,omitempty"`
	// The state of a VPC connection.
	State            *string `json:"state,omitempty"`
	TargetClusterARN *string `json:"targetClusterARN,omitempty"`
	VPCConnectionARN *string `json:"vpcConnectionARN,omitempty"`
	VPCID            *string `json:"vpcID,omitempty"`
}

The VPC connection object.

func (*VPCConnection_SDK) DeepCopy added in v1.9.0 

func (in *VPCConnection_SDK) DeepCopy() *VPCConnection_SDK

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

func (*VPCConnection_SDK) DeepCopyInto added in v1.9.0 

func (in *VPCConnection_SDK) DeepCopyInto(out *VPCConnection_SDK)

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

type VPCConnectivity added in v1.10.0 

type VPCConnectivity struct {
	// Includes all client authentication information for VPC connectivity.
	ClientAuthentication *VPCConnectivityClientAuthentication `json:"clientAuthentication,omitempty"`
}

VPC connectivity access control for brokers.

func (*VPCConnectivity) DeepCopy added in v1.10.0 

func (in *VPCConnectivity) DeepCopy() *VPCConnectivity

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

func (*VPCConnectivity) DeepCopyInto added in v1.10.0 

func (in *VPCConnectivity) DeepCopyInto(out *VPCConnectivity)

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

type VPCConnectivityClientAuthentication added in v1.10.0 

type VPCConnectivityClientAuthentication struct {
	// Details for SASL client authentication for VPC connectivity.
	SASL *VPCConnectivitySASL `json:"sasl,omitempty"`
	// Details for TLS client authentication for VPC connectivity.
	TLS *VPCConnectivityTLS `json:"tls,omitempty"`
}

Includes all client authentication information for VPC connectivity.

func (*VPCConnectivityClientAuthentication) DeepCopy added in v1.10.0 

func (in *VPCConnectivityClientAuthentication) DeepCopy() *VPCConnectivityClientAuthentication

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

func (*VPCConnectivityClientAuthentication) DeepCopyInto added in v1.10.0 

func (in *VPCConnectivityClientAuthentication) DeepCopyInto(out *VPCConnectivityClientAuthentication)

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

type VPCConnectivityIAM added in v1.0.3 

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

Details for IAM access control for VPC connectivity.

func (*VPCConnectivityIAM) DeepCopy added in v1.0.3 

func (in *VPCConnectivityIAM) DeepCopy() *VPCConnectivityIAM

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

func (*VPCConnectivityIAM) DeepCopyInto added in v1.0.3 

func (in *VPCConnectivityIAM) DeepCopyInto(out *VPCConnectivityIAM)

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

type VPCConnectivitySASL added in v1.10.0 

type VPCConnectivitySASL struct {
	// Details for IAM access control for VPC connectivity.
	IAM *VPCConnectivityIAM `json:"iam,omitempty"`
	// Details for SASL/SCRAM client authentication for VPC connectivity.
	SCRAM *VPCConnectivitySCRAM `json:"scram,omitempty"`
}

Details for SASL client authentication for VPC connectivity.

func (*VPCConnectivitySASL) DeepCopy added in v1.10.0 

func (in *VPCConnectivitySASL) DeepCopy() *VPCConnectivitySASL

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

func (*VPCConnectivitySASL) DeepCopyInto added in v1.10.0 

func (in *VPCConnectivitySASL) DeepCopyInto(out *VPCConnectivitySASL)

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

type VPCConnectivitySCRAM added in v1.0.3 

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

Details for SASL/SCRAM client authentication for VPC connectivity.

func (*VPCConnectivitySCRAM) DeepCopy added in v1.0.3 

func (in *VPCConnectivitySCRAM) DeepCopy() *VPCConnectivitySCRAM

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

func (*VPCConnectivitySCRAM) DeepCopyInto added in v1.0.3 

func (in *VPCConnectivitySCRAM) DeepCopyInto(out *VPCConnectivitySCRAM)

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

type VPCConnectivityTLS added in v1.0.3 

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

Details for TLS client authentication for VPC connectivity.

func (*VPCConnectivityTLS) DeepCopy added in v1.0.3 

func (in *VPCConnectivityTLS) DeepCopy() *VPCConnectivityTLS

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

func (*VPCConnectivityTLS) DeepCopyInto added in v1.0.3 

func (in *VPCConnectivityTLS) DeepCopyInto(out *VPCConnectivityTLS)

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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.