v1alpha1

package
v0.47.2 Latest Latest
Warning

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

 Go to latest Published: Apr 15, 2024 License: Apache-2.0 Imports: 13 Imported by: 2

Documentation

Index

Constants

View Source 
const (
	CRDGroup   = "kafka.aws.crossplane.io"
	CRDVersion = "v1alpha1"
)

Package type metadata.

Variables

View Source 
var (
	ClusterKind             = "Cluster"
	ClusterGroupKind        = schema.GroupKind{Group: CRDGroup, Kind: ClusterKind}.String()
	ClusterKindAPIVersion   = ClusterKind + "." + GroupVersion.String()
	ClusterGroupVersionKind = GroupVersion.WithKind(ClusterKind)
)

Repository type metadata.

View Source 
var (
	ConfigurationKind             = "Configuration"
	ConfigurationGroupKind        = schema.GroupKind{Group: CRDGroup, Kind: ConfigurationKind}.String()
	ConfigurationKindAPIVersion   = ConfigurationKind + "." + GroupVersion.String()
	ConfigurationGroupVersionKind = GroupVersion.WithKind(ConfigurationKind)
)

Repository type metadata.

View Source 
var (
	// GroupVersion is the API Group Version used to register the objects
	GroupVersion = schema.GroupVersion{Group: CRDGroup, Version: CRDVersion}

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

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

Functions

func ConfugurationARN added in v0.44.1 

func ConfugurationARN() reference.ExtractValueFn

ConfugurationARN returns the status.atProvider.ARN of a Configuration.

Types

type BrokerAZDistribution 

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

type BrokerEBSVolumeInfo 

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

	VolumeSizeGB *int64 `json:"volumeSizeGB,omitempty"`
}

+kubebuilder:skipversion

func (*BrokerEBSVolumeInfo) DeepCopy 

func (in *BrokerEBSVolumeInfo) DeepCopy() *BrokerEBSVolumeInfo

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

func (*BrokerEBSVolumeInfo) DeepCopyInto 

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

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

type BrokerLogs 

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

+kubebuilder:skipversion

func (*BrokerLogs) DeepCopy 

func (in *BrokerLogs) DeepCopy() *BrokerLogs

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

func (*BrokerLogs) DeepCopyInto 

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

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

type BrokerNodeGroupInfo 

type BrokerNodeGroupInfo struct {
	// The distribution of broker nodes across Availability Zones. By default, broker
	// nodes are distributed among the Availability Zones of your Region. Currently,
	// the only supported value is DEFAULT. You can either specify this value explicitly
	// or leave it out.
	BrokerAZDistribution *string `json:"brokerAZDistribution,omitempty"`

	ClientSubnets []*string `json:"clientSubnets,omitempty"`
	// Information about the broker access configuration.
	ConnectivityInfo *ConnectivityInfo `json:"connectivityInfo,omitempty"`

	InstanceType *string `json:"instanceType,omitempty"`

	SecurityGroups []*string `json:"securityGroups,omitempty"`
	// Contains information about storage volumes attached to MSK broker nodes.
	StorageInfo *StorageInfo `json:"storageInfo,omitempty"`

	ZoneIDs []*string `json:"zoneIDs,omitempty"`
}

+kubebuilder:skipversion

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

+kubebuilder:skipversion

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

+kubebuilder:skipversion

func (*BrokerSoftwareInfo) DeepCopy 

func (in *BrokerSoftwareInfo) DeepCopy() *BrokerSoftwareInfo

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

func (*BrokerSoftwareInfo) DeepCopyInto 

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

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

type ClientAuthentication 

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

+kubebuilder:skipversion

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

type ClientVPCConnection added in v0.44.0 

type ClientVPCConnection struct {
	Authentication *string `json:"authentication,omitempty"`

	CreationTime *metav1.Time `json:"creationTime,omitempty"`

	Owner *string `json:"owner,omitempty"`

	VPCConnectionARN *string `json:"vpcConnectionARN,omitempty"`
}

+kubebuilder:skipversion

func (*ClientVPCConnection) DeepCopy added in v0.44.0 

func (in *ClientVPCConnection) DeepCopy() *ClientVPCConnection

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

func (*ClientVPCConnection) DeepCopyInto added in v0.44.0 

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

+kubebuilder:skipversion

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"`
	Status            ClusterStatus `json:"status,omitempty"`
}

Cluster is the Schema for the Clusters API +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:storageversion +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,aws}

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.

func (*Cluster) GetCondition 

func (mg *Cluster) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this Cluster.

func (*Cluster) GetDeletionPolicy 

func (mg *Cluster) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this Cluster.

func (*Cluster) GetManagementPolicies added in v0.43.0 

func (mg *Cluster) GetManagementPolicies() xpv1.ManagementPolicies

GetManagementPolicies of this Cluster.

func (*Cluster) GetProviderConfigReference 

func (mg *Cluster) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this Cluster.

func (*Cluster) GetPublishConnectionDetailsTo 

func (mg *Cluster) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this Cluster.

func (*Cluster) GetWriteConnectionSecretToReference 

func (mg *Cluster) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this Cluster.

func (*Cluster) ResolveReferences 

func (mg *Cluster) ResolveReferences(ctx context.Context, c client.Reader) error

ResolveReferences of this Cluster.

func (*Cluster) SetConditions 

func (mg *Cluster) SetConditions(c ...xpv1.Condition)

SetConditions of this Cluster.

func (*Cluster) SetDeletionPolicy 

func (mg *Cluster) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this Cluster.

func (*Cluster) SetManagementPolicies added in v0.43.0 

func (mg *Cluster) SetManagementPolicies(r xpv1.ManagementPolicies)

SetManagementPolicies of this Cluster.

func (*Cluster) SetProviderConfigReference 

func (mg *Cluster) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this Cluster.

func (*Cluster) SetPublishConnectionDetailsTo 

func (mg *Cluster) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this Cluster.

func (*Cluster) SetWriteConnectionSecretToReference 

func (mg *Cluster) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this Cluster.

type ClusterInfo 

type ClusterInfo struct {
	ActiveOperationARN *string `json:"activeOperationARN,omitempty"`
	// Describes the setup to be used for Apache Kafka broker nodes in the cluster.
	BrokerNodeGroupInfo *BrokerNodeGroupInfo `json:"brokerNodeGroupInfo,omitempty"`
	// Includes all client authentication information.
	ClientAuthentication *ClientAuthentication `json:"clientAuthentication,omitempty"`

	ClusterARN *string `json:"clusterARN,omitempty"`

	ClusterName *string `json:"clusterName,omitempty"`

	CreationTime *metav1.Time `json:"creationTime,omitempty"`
	// Information about the current software installed on the cluster.
	CurrentBrokerSoftwareInfo *BrokerSoftwareInfo `json:"currentBrokerSoftwareInfo,omitempty"`

	CurrentVersion *string `json:"currentVersion,omitempty"`
	// Includes encryption-related information, such as the AWS KMS key used for
	// encrypting data at rest and whether you want MSK to encrypt your data in
	// transit.
	EncryptionInfo *EncryptionInfo `json:"encryptionInfo,omitempty"`
	// Specifies which metrics are gathered for the MSK cluster. This property has
	// the following possible values: DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER,
	// and PER_TOPIC_PER_PARTITION. For a list of the metrics associated with each
	// of these levels of monitoring, see Monitoring (https://docs.aws.amazon.com/msk/latest/developerguide/monitoring.html).
	EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty"`
	// You can configure your MSK cluster to send broker logs to different destination
	// types. This is a container for the configuration details related to broker
	// logs.
	LoggingInfo *LoggingInfo `json:"loggingInfo,omitempty"`

	NumberOfBrokerNodes *int64 `json:"numberOfBrokerNodes,omitempty"`
	// JMX and Node monitoring for the MSK cluster.
	OpenMonitoring *OpenMonitoring `json:"openMonitoring,omitempty"`
	// The state of an Apache Kafka cluster.
	State *string `json:"state,omitempty"`
	// Contains information about the state of the Amazon MSK cluster.
	StateInfo *StateInfo `json:"stateInfo,omitempty"`
	// Controls storage mode for various supported storage tiers.
	StorageMode *string `json:"storageMode,omitempty"`

	Tags map[string]*string `json:"tags,omitempty"`

	ZookeeperConnectString *string `json:"zookeeperConnectString,omitempty"`

	ZookeeperConnectStringTLS *string `json:"zookeeperConnectStringTLS,omitempty"`
}

+kubebuilder:skipversion

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 Clusters

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.

func (*ClusterList) GetItems 

func (l *ClusterList) GetItems() []resource.Managed

GetItems of this ClusterList.

type ClusterObservation 

type ClusterObservation struct {
	// The Amazon Resource Name (ARN) of the cluster.
	ClusterARN *string `json:"clusterARN,omitempty"`
	// Cluster policy version.
	ClusterPolicyVersion *string `json:"clusterPolicyVersion,omitempty"`
	// The state of the cluster. The possible states are ACTIVE, CREATING, DELETING,
	// FAILED, HEALING, MAINTENANCE, REBOOTING_BROKER, and UPDATING.
	State *string `json:"state,omitempty"`
}

ClusterObservation defines the observed state of Cluster

func (*ClusterObservation) DeepCopy 

func (in *ClusterObservation) DeepCopy() *ClusterObservation

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

func (*ClusterObservation) DeepCopyInto 

func (in *ClusterObservation) DeepCopyInto(out *ClusterObservation)

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

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

+kubebuilder:skipversion

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

+kubebuilder:skipversion

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

+kubebuilder:skipversion

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 v0.44.0 

type ClusterOperationV2 struct {
	ClusterARN *string `json:"clusterARN,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"`
}

+kubebuilder:skipversion

func (*ClusterOperationV2) DeepCopy added in v0.44.0 

func (in *ClusterOperationV2) DeepCopy() *ClusterOperationV2

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

func (*ClusterOperationV2) DeepCopyInto added in v0.44.0 

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

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

type ClusterOperationV2Summary added in v0.44.0 

type ClusterOperationV2Summary struct {
	ClusterARN *string `json:"clusterARN,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"`
}

+kubebuilder:skipversion

func (*ClusterOperationV2Summary) DeepCopy added in v0.44.0 

func (in *ClusterOperationV2Summary) DeepCopy() *ClusterOperationV2Summary

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

func (*ClusterOperationV2Summary) DeepCopyInto added in v0.44.0 

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

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

type ClusterParameters 

type ClusterParameters struct {
	// Region is which region the Cluster will be created.
	// +kubebuilder:validation:Required
	Region string `json:"region"`
	// Includes all client authentication related information.
	ClientAuthentication *ClientAuthentication `json:"clientAuthentication,omitempty"`
	// The name of the cluster.
	// +kubebuilder:validation:Required
	ClusterName *string `json:"clusterName"`
	// Includes all encryption-related information.
	EncryptionInfo *EncryptionInfo `json:"encryptionInfo,omitempty"`
	// Specifies the level of monitoring for the MSK cluster. The possible values
	// are DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER, and PER_TOPIC_PER_PARTITION.
	EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty"`
	// The version of Apache Kafka.
	// +kubebuilder:validation:Required
	KafkaVersion *string `json:"kafkaVersion"`
	// LoggingInfo details.
	LoggingInfo *LoggingInfo `json:"loggingInfo,omitempty"`
	// The number of Apache Kafka broker nodes in the Amazon MSK cluster.
	// +kubebuilder:validation:Required
	NumberOfBrokerNodes *int64 `json:"numberOfBrokerNodes"`
	// The settings for open monitoring.
	OpenMonitoring *OpenMonitoringInfo `json:"openMonitoring,omitempty"`
	// This controls storage mode for supported storage tiers.
	StorageMode *string `json:"storageMode,omitempty"`
	// Create tags when creating the cluster.
	Tags                    map[string]*string `json:"tags,omitempty"`
	CustomClusterParameters `json:",inline"`
}

ClusterParameters defines the desired state of Cluster

func (*ClusterParameters) DeepCopy 

func (in *ClusterParameters) DeepCopy() *ClusterParameters

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

func (*ClusterParameters) DeepCopyInto 

func (in *ClusterParameters) DeepCopyInto(out *ClusterParameters)

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

type ClusterSpec 

type ClusterSpec struct {
	xpv1.ResourceSpec `json:",inline"`
	ForProvider       ClusterParameters `json:"forProvider"`
}

ClusterSpec defines the desired state of 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 {
	xpv1.ResourceStatus `json:",inline"`
	AtProvider          ClusterObservation `json:"atProvider,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 added in v0.34.0 

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

type Cluster_SDK added in v0.34.0 

type Cluster_SDK struct {
	ActiveOperationARN *string `json:"activeOperationARN,omitempty"`

	ClusterARN *string `json:"clusterARN,omitempty"`

	ClusterName *string `json:"clusterName,omitempty"`

	CreationTime *metav1.Time `json:"creationTime,omitempty"`

	CurrentVersion *string `json:"currentVersion,omitempty"`
	// The state of an Apache Kafka cluster.
	State *string `json:"state,omitempty"`
	// Contains information about the state of the Amazon MSK cluster.
	StateInfo *StateInfo `json:"stateInfo,omitempty"`

	Tags map[string]*string `json:"tags,omitempty"`
}

+kubebuilder:skipversion

func (*Cluster_SDK) DeepCopy added in v0.34.0 

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

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

+kubebuilder:skipversion

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"`
	Status            ConfigurationStatus `json:"status,omitempty"`
}

Configuration is the Schema for the Configurations API +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:storageversion +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,aws}

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 

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

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

func (*Configuration) GetCondition 

func (mg *Configuration) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this Configuration.

func (*Configuration) GetDeletionPolicy 

func (mg *Configuration) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this Configuration.

func (*Configuration) GetManagementPolicies added in v0.43.0 

func (mg *Configuration) GetManagementPolicies() xpv1.ManagementPolicies

GetManagementPolicies of this Configuration.

func (*Configuration) GetProviderConfigReference 

func (mg *Configuration) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this Configuration.

func (*Configuration) GetPublishConnectionDetailsTo 

func (mg *Configuration) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this Configuration.

func (*Configuration) GetWriteConnectionSecretToReference 

func (mg *Configuration) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this Configuration.

func (*Configuration) SetConditions 

func (mg *Configuration) SetConditions(c ...xpv1.Condition)

SetConditions of this Configuration.

func (*Configuration) SetDeletionPolicy 

func (mg *Configuration) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this Configuration.

func (*Configuration) SetManagementPolicies added in v0.43.0 

func (mg *Configuration) SetManagementPolicies(r xpv1.ManagementPolicies)

SetManagementPolicies of this Configuration.

func (*Configuration) SetProviderConfigReference 

func (mg *Configuration) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this Configuration.

func (*Configuration) SetPublishConnectionDetailsTo 

func (mg *Configuration) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this Configuration.

func (*Configuration) SetWriteConnectionSecretToReference 

func (mg *Configuration) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this Configuration.

type ConfigurationInfo 

type ConfigurationInfo struct {
	ARN *string `json:"arn,omitempty"`

	Revision *int64 `json:"revision,omitempty"`
}

+kubebuilder:skipversion

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 

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

ConfigurationList contains a list of Configurations

func (*ConfigurationList) DeepCopy 

func (in *ConfigurationList) DeepCopy() *ConfigurationList

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

func (*ConfigurationList) DeepCopyInto 

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 

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

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

func (*ConfigurationList) GetItems 

func (l *ConfigurationList) GetItems() []resource.Managed

GetItems of this ConfigurationList.

type ConfigurationObservation 

type ConfigurationObservation struct {
	// The Amazon Resource Name (ARN) of the configuration.
	ARN *string `json:"arn,omitempty"`
	// The time when the configuration was created.
	CreationTime *metav1.Time `json:"creationTime,omitempty"`
	// Latest revision of the configuration.
	LatestRevision *ConfigurationRevision `json:"latestRevision,omitempty"`
	// The name of the configuration. Configuration names are strings that match
	// the regex "^[0-9A-Za-z-]+$".
	Name *string `json:"name,omitempty"`
	// The state of the configuration. The possible states are ACTIVE, DELETING
	// and DELETE_FAILED.
	State *string `json:"state,omitempty"`
}

ConfigurationObservation defines the observed state of Configuration

func (*ConfigurationObservation) DeepCopy 

func (in *ConfigurationObservation) DeepCopy() *ConfigurationObservation

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

func (*ConfigurationObservation) DeepCopyInto 

func (in *ConfigurationObservation) DeepCopyInto(out *ConfigurationObservation)

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

type ConfigurationParameters 

type ConfigurationParameters struct {
	// Region is which region the Configuration will be created.
	// +kubebuilder:validation:Required
	Region string `json:"region"`
	// 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"`
	CustomConfigurationParameters `json:",inline"`
}

ConfigurationParameters defines the desired state of Configuration

func (*ConfigurationParameters) DeepCopy 

func (in *ConfigurationParameters) DeepCopy() *ConfigurationParameters

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

func (*ConfigurationParameters) DeepCopyInto 

func (in *ConfigurationParameters) DeepCopyInto(out *ConfigurationParameters)

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

type ConfigurationRevision 

type ConfigurationRevision struct {
	CreationTime *metav1.Time `json:"creationTime,omitempty"`

	Description *string `json:"description,omitempty"`

	Revision *int64 `json:"revision,omitempty"`
}

+kubebuilder:skipversion

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 

type ConfigurationSpec struct {
	xpv1.ResourceSpec `json:",inline"`
	ForProvider       ConfigurationParameters `json:"forProvider"`
}

ConfigurationSpec defines the desired state of Configuration

func (*ConfigurationSpec) DeepCopy 

func (in *ConfigurationSpec) DeepCopy() *ConfigurationSpec

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

func (*ConfigurationSpec) DeepCopyInto 

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_DELETING      ConfigurationState = "DELETING"
	ConfigurationState_DELETE_FAILED ConfigurationState = "DELETE_FAILED"
)

type ConfigurationStatus 

type ConfigurationStatus struct {
	xpv1.ResourceStatus `json:",inline"`
	AtProvider          ConfigurationObservation `json:"atProvider,omitempty"`
}

ConfigurationStatus defines the observed state of Configuration.

func (*ConfigurationStatus) DeepCopy 

func (in *ConfigurationStatus) DeepCopy() *ConfigurationStatus

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

func (*ConfigurationStatus) DeepCopyInto 

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 

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

+kubebuilder:skipversion

func (*Configuration_SDK) DeepCopy 

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 

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

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

+kubebuilder:skipversion

func (*ConnectivityInfo) DeepCopy added in v0.34.0 

func (in *ConnectivityInfo) DeepCopy() *ConnectivityInfo

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

func (*ConnectivityInfo) DeepCopyInto added in v0.34.0 

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

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

type CustomBrokerNodeGroupInfo 

type CustomBrokerNodeGroupInfo struct {
	// +optional
	// +crossplane:generate:reference:type=github.com/crossplane-contrib/provider-aws/apis/ec2/v1beta1.Subnet
	// +crossplane:generate:reference:refFieldName=ClientSubnetRefs
	// +crossplane:generate:reference:selectorFieldName=ClientSubnetSelector
	ClientSubnets []*string `json:"clientSubnets,omitempty"`

	// ClientSubnetRefs is a list of references to Subnets used to set
	// the ClientSubnets.
	// +optional
	ClientSubnetRefs []xpv1.Reference `json:"clientSubnetRefs,omitempty"`

	// ClientSubnetSelector selects references to Subnets used
	// to set the ClientSubnets.
	// +optional
	ClientSubnetSelector *xpv1.Selector `json:"clientSubnetSelector,omitempty"`

	InstanceType *string `json:"instanceType,omitempty"`

	// +optional
	// +crossplane:generate:reference:type=github.com/crossplane-contrib/provider-aws/apis/ec2/v1beta1.SecurityGroup
	// +crossplane:generate:reference:refFieldName=SecurityGroupRefs
	// +crossplane:generate:reference:selectorFieldName=SecurityGroupSelector
	SecurityGroups []*string `json:"securityGroups,omitempty"`

	// SecurityGroupRefs is a list of references to SecurityGroups used to set
	// the SecurityGroups.
	// +optional
	SecurityGroupRefs []xpv1.Reference `json:"securityGroupRefs,omitempty"`

	// SecurityGroupSelector selects references to SecurityGroup used
	// to set the SecurityGroups.
	// +optional
	SecurityGroupSelector *xpv1.Selector `json:"securityGroupSelector,omitempty"`

	// Contains information about storage volumes attached to MSK broker nodes.
	StorageInfo *StorageInfo `json:"storageInfo,omitempty"`

	// ConnectivityInfo Information about the broker access configuration.
	ConnectivityInfo *CustomConnectivityInfo `json:"connectivityInfo,omitempty"`
}

CustomBrokerNodeGroupInfo contains the additional fields for BrokerNodeGroupInfo.

func (*CustomBrokerNodeGroupInfo) DeepCopy 

func (in *CustomBrokerNodeGroupInfo) DeepCopy() *CustomBrokerNodeGroupInfo

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

func (*CustomBrokerNodeGroupInfo) DeepCopyInto 

func (in *CustomBrokerNodeGroupInfo) DeepCopyInto(out *CustomBrokerNodeGroupInfo)

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

type CustomClusterParameters 

type CustomClusterParameters struct {
	// Information about the brokers
	CustomBrokerNodeGroupInfo *CustomBrokerNodeGroupInfo `json:"brokerNodeGroupInfo,omitempty"`

	// ClusterPolicy of the MSK cluster.
	ClusterPolicy *common.ResourcePolicy `json:"clusterPolicy,omitempty"`

	// Represents the configuration that you want MSK to use for the cluster.
	CustomConfigurationInfo *CustomConfigurationInfo `json:"configurationInfo,omitempty"`
}

CustomClusterParameters contains the additional fields for ClusterParameters.

func (*CustomClusterParameters) DeepCopy 

func (in *CustomClusterParameters) DeepCopy() *CustomClusterParameters

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

func (*CustomClusterParameters) DeepCopyInto 

func (in *CustomClusterParameters) DeepCopyInto(out *CustomClusterParameters)

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

type CustomConfigurationInfo 

type CustomConfigurationInfo struct {
	// ARN of the configuration to use.
	// +optional
	// +crossplane:generate:reference:type=Configuration
	// +crossplane:generate:reference:extractor=ConfugurationARN()
	ARN *string `json:"arn,omitempty"`

	// ARNRef is a reference to a Kafka Configuration used to set ARN.
	// +optional
	ARNRef *xpv1.Reference `json:"arnRef,omitempty"`

	// ARNSelector selects a reference to a Kafka Configuration used to set ARN.
	// +optional
	ARNSelector *xpv1.Selector `json:"arnSelector,omitempty"`

	Revision *int64 `json:"revision,omitempty"`
}

CustomConfigurationInfo contains the additional fields for ConfigurationInfo.

func (*CustomConfigurationInfo) DeepCopy 

func (in *CustomConfigurationInfo) DeepCopy() *CustomConfigurationInfo

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

func (*CustomConfigurationInfo) DeepCopyInto 

func (in *CustomConfigurationInfo) DeepCopyInto(out *CustomConfigurationInfo)

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

type CustomConfigurationParameters 

type CustomConfigurationParameters struct {
	// kafka server configurations
	Properties []string `json:"properties"`
}

CustomConfigurationParameters contains the additional fields for ConfigurationParameters.

func (*CustomConfigurationParameters) DeepCopy 

func (in *CustomConfigurationParameters) DeepCopy() *CustomConfigurationParameters

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

func (*CustomConfigurationParameters) DeepCopyInto 

func (in *CustomConfigurationParameters) DeepCopyInto(out *CustomConfigurationParameters)

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

type CustomConnectivityInfo added in v0.44.0 

type CustomConnectivityInfo struct {
	// Broker public access control.
	PublicAccess *CustomPublicAccess `json:"publicAccess,omitempty"`
	// Broker VPC connectivity access control.
	VPCConnectivity *VPCConnectivity `json:"vpcConnectivity,omitempty"`
}

CustomConnectivityInfo replaces ConnectivityInfo because it contains a json tag "type_" that is does not follow the convention.

+kubebuilder:skipversion

func (*CustomConnectivityInfo) DeepCopy added in v0.44.0 

func (in *CustomConnectivityInfo) DeepCopy() *CustomConnectivityInfo

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

func (*CustomConnectivityInfo) DeepCopyInto added in v0.44.0 

func (in *CustomConnectivityInfo) DeepCopyInto(out *CustomConnectivityInfo)

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

type CustomPublicAccess added in v0.44.0 

type CustomPublicAccess struct {
	// Type of the public access control.
	Type *string `json:"type,omitempty"`
}

CustomPublicAccess replaces PublicAccess because it contains a json tag "type_" that is does not follow the convention.

+kubebuilder:skipversion

func (*CustomPublicAccess) DeepCopy added in v0.44.0 

func (in *CustomPublicAccess) DeepCopy() *CustomPublicAccess

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

func (*CustomPublicAccess) DeepCopyInto added in v0.44.0 

func (in *CustomPublicAccess) DeepCopyInto(out *CustomPublicAccess)

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

type EBSStorageInfo 

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

	VolumeSize *int64 `json:"volumeSize,omitempty"`
}

+kubebuilder:skipversion

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

+kubebuilder:skipversion

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

+kubebuilder:skipversion

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

+kubebuilder:skipversion

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

+kubebuilder:skipversion

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

+kubebuilder:skipversion

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

+kubebuilder:skipversion

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

+kubebuilder:skipversion

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

+kubebuilder:skipversion

func (*JmxExporterInfo) DeepCopy 

func (in *JmxExporterInfo) DeepCopy() *JmxExporterInfo

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

func (*JmxExporterInfo) DeepCopyInto 

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

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

type KafkaVersion 

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

+kubebuilder:skipversion

func (*KafkaVersion) DeepCopy 

func (in *KafkaVersion) DeepCopy() *KafkaVersion

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

func (*KafkaVersion) DeepCopyInto 

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

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

type KafkaVersionStatus 

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

type LoggingInfo 

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

+kubebuilder:skipversion

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"`
	// Information about the broker access configuration.
	ConnectivityInfo *ConnectivityInfo `json:"connectivityInfo,omitempty"`
	// Includes encryption-related information, such as the AWS KMS key used for
	// encrypting data at rest and whether you want MSK to encrypt your data in
	// transit.
	EncryptionInfo *EncryptionInfo `json:"encryptionInfo,omitempty"`
	// Specifies which metrics are gathered for the MSK cluster. This property has
	// the following possible values: DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER,
	// and PER_TOPIC_PER_PARTITION. For a list of the metrics associated with each
	// of these levels of monitoring, see Monitoring (https://docs.aws.amazon.com/msk/latest/developerguide/monitoring.html).
	EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty"`

	InstanceType *string `json:"instanceType,omitempty"`

	KafkaVersion *string `json:"kafkaVersion,omitempty"`
	// You can configure your MSK cluster to send broker logs to different destination
	// types. This is a container for the configuration details related to broker
	// logs.
	LoggingInfo *LoggingInfo `json:"loggingInfo,omitempty"`

	NumberOfBrokerNodes *int64 `json:"numberOfBrokerNodes,omitempty"`
	// JMX and Node monitoring for the MSK cluster.
	OpenMonitoring *OpenMonitoring `json:"openMonitoring,omitempty"`
	// Controls storage mode for various supported storage tiers.
	StorageMode *string `json:"storageMode,omitempty"`
}

+kubebuilder:skipversion

func (*MutableClusterInfo) DeepCopy 

func (in *MutableClusterInfo) DeepCopy() *MutableClusterInfo

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

func (*MutableClusterInfo) DeepCopyInto 

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

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

type NodeExporter 

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

+kubebuilder:skipversion

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

+kubebuilder:skipversion

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

+kubebuilder:skipversion

func (*NodeInfo) DeepCopy 

func (in *NodeInfo) DeepCopy() *NodeInfo

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

func (*NodeInfo) DeepCopyInto 

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

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

type NodeType 

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

type OpenMonitoring 

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

+kubebuilder:skipversion

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

+kubebuilder:skipversion

func (*OpenMonitoringInfo) DeepCopy 

func (in *OpenMonitoringInfo) DeepCopy() *OpenMonitoringInfo

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

func (*OpenMonitoringInfo) DeepCopyInto 

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

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

type Prometheus 

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

+kubebuilder:skipversion

func (*Prometheus) DeepCopy 

func (in *Prometheus) DeepCopy() *Prometheus

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

func (*Prometheus) DeepCopyInto 

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

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

type PrometheusInfo 

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

+kubebuilder:skipversion

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

type Provisioned struct {
	// Describes the setup to be used for Apache Kafka broker nodes in the cluster.
	BrokerNodeGroupInfo *BrokerNodeGroupInfo `json:"brokerNodeGroupInfo,omitempty"`
	// Includes all client authentication information.
	ClientAuthentication *ClientAuthentication `json:"clientAuthentication,omitempty"`
	// Information about the current software installed on the cluster.
	CurrentBrokerSoftwareInfo *BrokerSoftwareInfo `json:"currentBrokerSoftwareInfo,omitempty"`
	// Includes encryption-related information, such as the AWS KMS key used for
	// encrypting data at rest and whether you want MSK to encrypt your data in
	// transit.
	EncryptionInfo *EncryptionInfo `json:"encryptionInfo,omitempty"`
	// Specifies which metrics are gathered for the MSK cluster. This property has
	// the following possible values: DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER,
	// and PER_TOPIC_PER_PARTITION. For a list of the metrics associated with each
	// of these levels of monitoring, see Monitoring (https://docs.aws.amazon.com/msk/latest/developerguide/monitoring.html).
	EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty"`
	// You can configure your MSK cluster to send broker logs to different destination
	// types. This is a container for the configuration details related to broker
	// logs.
	LoggingInfo *LoggingInfo `json:"loggingInfo,omitempty"`

	NumberOfBrokerNodes *int64 `json:"numberOfBrokerNodes,omitempty"`
	// JMX and Node monitoring for the MSK cluster.
	OpenMonitoring *OpenMonitoringInfo `json:"openMonitoring,omitempty"`
	// Controls storage mode for various supported storage tiers.
	StorageMode *string `json:"storageMode,omitempty"`

	ZookeeperConnectString *string `json:"zookeeperConnectString,omitempty"`

	ZookeeperConnectStringTLS *string `json:"zookeeperConnectStringTLS,omitempty"`
}

+kubebuilder:skipversion

func (*Provisioned) DeepCopy added in v0.34.0 

func (in *Provisioned) DeepCopy() *Provisioned

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

func (*Provisioned) DeepCopyInto added in v0.34.0 

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

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"`
	// Includes encryption-related information, such as the AWS KMS key used for
	// encrypting data at rest and whether you want MSK to encrypt your data in
	// transit.
	EncryptionInfo *EncryptionInfo `json:"encryptionInfo,omitempty"`
	// Specifies which metrics are gathered for the MSK cluster. This property has
	// the following possible values: DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER,
	// and PER_TOPIC_PER_PARTITION. For a list of the metrics associated with each
	// of these levels of monitoring, see Monitoring (https://docs.aws.amazon.com/msk/latest/developerguide/monitoring.html).
	EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty"`

	KafkaVersion *string `json:"kafkaVersion,omitempty"`
	// You can configure your MSK cluster to send broker logs to different destination
	// types. This is a container for the configuration details related to broker
	// logs.
	LoggingInfo *LoggingInfo `json:"loggingInfo,omitempty"`

	NumberOfBrokerNodes *int64 `json:"numberOfBrokerNodes,omitempty"`
	// JMX and Node monitoring for the MSK cluster.
	OpenMonitoring *OpenMonitoringInfo `json:"openMonitoring,omitempty"`
	// Controls storage mode for various supported storage tiers.
	StorageMode *string `json:"storageMode,omitempty"`
}

+kubebuilder:skipversion

func (*ProvisionedRequest) DeepCopy added in v0.34.0 

func (in *ProvisionedRequest) DeepCopy() *ProvisionedRequest

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

func (*ProvisionedRequest) DeepCopyInto added in v0.34.0 

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

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

	VolumeThroughput *int64 `json:"volumeThroughput,omitempty"`
}

+kubebuilder:skipversion

func (*ProvisionedThroughput) DeepCopy added in v0.34.0 

func (in *ProvisionedThroughput) DeepCopy() *ProvisionedThroughput

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

func (*ProvisionedThroughput) DeepCopyInto added in v0.34.0 

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

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

+kubebuilder:skipversion

func (*PublicAccess) DeepCopy added in v0.34.0 

func (in *PublicAccess) DeepCopy() *PublicAccess

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

func (*PublicAccess) DeepCopyInto added in v0.34.0 

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

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

type S3 

type S3 struct {
	Bucket *string `json:"bucket,omitempty"`

	Enabled *bool `json:"enabled,omitempty"`

	Prefix *string `json:"prefix,omitempty"`
}

+kubebuilder:skipversion

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

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

	SCRAM *SCRAM `json:"scram,omitempty"`
}

+kubebuilder:skipversion

func (*SASL) DeepCopy added in v0.39.0 

func (in *SASL) DeepCopy() *SASL

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

func (*SASL) DeepCopyInto added in v0.39.0 

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

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

+kubebuilder:skipversion

func (*SCRAM) DeepCopy added in v0.39.0 

func (in *SCRAM) DeepCopy() *SCRAM

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

func (*SCRAM) DeepCopyInto added in v0.39.0 

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

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

type ServerlessSASL added in v0.39.0 

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

+kubebuilder:skipversion

func (*ServerlessSASL) DeepCopy added in v0.39.0 

func (in *ServerlessSASL) DeepCopy() *ServerlessSASL

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

func (*ServerlessSASL) DeepCopyInto added in v0.39.0 

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

+kubebuilder:skipversion

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

+kubebuilder:skipversion

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

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

+kubebuilder:skipversion

func (*TLS) DeepCopy 

func (in *TLS) DeepCopy() *TLS

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

func (*TLS) DeepCopyInto 

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

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

type Unauthenticated 

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

+kubebuilder:skipversion

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

type UnprocessedSCRAMSecret struct {
	ErrorCode *string `json:"errorCode,omitempty"`

	ErrorMessage *string `json:"errorMessage,omitempty"`

	SecretARN *string `json:"secretARN,omitempty"`
}

+kubebuilder:skipversion

func (*UnprocessedSCRAMSecret) DeepCopy added in v0.39.0 

func (in *UnprocessedSCRAMSecret) DeepCopy() *UnprocessedSCRAMSecret

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

func (*UnprocessedSCRAMSecret) DeepCopyInto added in v0.39.0 

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 v0.44.0 

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

+kubebuilder:skipversion

func (*UserIdentity) DeepCopy added in v0.44.0 

func (in *UserIdentity) DeepCopy() *UserIdentity

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

func (*UserIdentity) DeepCopyInto added in v0.44.0 

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 v0.44.0 

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

type VPCConfig added in v0.34.0 

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

	SubnetIDs []*string `json:"subnetIDs,omitempty"`
}

+kubebuilder:skipversion

func (*VPCConfig) DeepCopy added in v0.34.0 

func (in *VPCConfig) DeepCopy() *VPCConfig

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

func (*VPCConfig) DeepCopyInto added in v0.34.0 

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 v0.44.0 

type VPCConnection struct {
	Authentication *string `json:"authentication,omitempty"`

	CreationTime *metav1.Time `json:"creationTime,omitempty"`

	TargetClusterARN *string `json:"targetClusterARN,omitempty"`

	VPCConnectionARN *string `json:"vpcConnectionARN,omitempty"`

	VPCID *string `json:"vpcID,omitempty"`
}

+kubebuilder:skipversion

func (*VPCConnection) DeepCopy added in v0.44.0 

func (in *VPCConnection) DeepCopy() *VPCConnection

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

func (*VPCConnection) DeepCopyInto added in v0.44.0 

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

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

type VPCConnectionInfo added in v0.44.0 

type VPCConnectionInfo struct {
	CreationTime *metav1.Time `json:"creationTime,omitempty"`

	Owner *string `json:"owner,omitempty"`

	VPCConnectionARN *string `json:"vpcConnectionARN,omitempty"`
}

+kubebuilder:skipversion

func (*VPCConnectionInfo) DeepCopy added in v0.44.0 

func (in *VPCConnectionInfo) DeepCopy() *VPCConnectionInfo

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

func (*VPCConnectionInfo) DeepCopyInto added in v0.44.0 

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 v0.44.0 

type VPCConnectionInfoServerless struct {
	CreationTime *metav1.Time `json:"creationTime,omitempty"`

	Owner *string `json:"owner,omitempty"`

	VPCConnectionARN *string `json:"vpcConnectionARN,omitempty"`
}

+kubebuilder:skipversion

func (*VPCConnectionInfoServerless) DeepCopy added in v0.44.0 

func (in *VPCConnectionInfoServerless) DeepCopy() *VPCConnectionInfoServerless

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

func (*VPCConnectionInfoServerless) DeepCopyInto added in v0.44.0 

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

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

type VPCConnectionState added in v0.44.0 

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

type VPCConnectivity added in v0.44.0 

type VPCConnectivity struct {
	ClientAuthentication *VPCConnectivityClientAuthentication `json:"clientAuthentication,omitempty"`
}

+kubebuilder:skipversion

func (*VPCConnectivity) DeepCopy added in v0.44.0 

func (in *VPCConnectivity) DeepCopy() *VPCConnectivity

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

func (*VPCConnectivity) DeepCopyInto added in v0.44.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 v0.44.0 

type VPCConnectivityClientAuthentication struct {
	SASL *VPCConnectivitySASL `json:"sasl,omitempty"`

	TLS *VPCConnectivityTLS `json:"tls,omitempty"`
}

+kubebuilder:skipversion

func (*VPCConnectivityClientAuthentication) DeepCopy added in v0.44.0 

func (in *VPCConnectivityClientAuthentication) DeepCopy() *VPCConnectivityClientAuthentication

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

func (*VPCConnectivityClientAuthentication) DeepCopyInto added in v0.44.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 v0.44.0 

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

+kubebuilder:skipversion

func (*VPCConnectivityIAM) DeepCopy added in v0.44.0 

func (in *VPCConnectivityIAM) DeepCopy() *VPCConnectivityIAM

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

func (*VPCConnectivityIAM) DeepCopyInto added in v0.44.0 

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 v0.44.0 

type VPCConnectivitySASL struct {
	IAM *VPCConnectivityIAM `json:"iam,omitempty"`

	SCRAM *VPCConnectivitySCRAM `json:"scram,omitempty"`
}

+kubebuilder:skipversion

func (*VPCConnectivitySASL) DeepCopy added in v0.44.0 

func (in *VPCConnectivitySASL) DeepCopy() *VPCConnectivitySASL

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

func (*VPCConnectivitySASL) DeepCopyInto added in v0.44.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 v0.44.0 

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

+kubebuilder:skipversion

func (*VPCConnectivitySCRAM) DeepCopy added in v0.44.0 

func (in *VPCConnectivitySCRAM) DeepCopy() *VPCConnectivitySCRAM

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

func (*VPCConnectivitySCRAM) DeepCopyInto added in v0.44.0 

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 v0.44.0 

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

+kubebuilder:skipversion

func (*VPCConnectivityTLS) DeepCopy added in v0.44.0 

func (in *VPCConnectivityTLS) DeepCopy() *VPCConnectivityTLS

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

func (*VPCConnectivityTLS) DeepCopyInto added in v0.44.0 

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

+kubebuilder:skipversion

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.