v1alpha1

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

type BrokerAZDistribution string

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

type BrokerLogs struct {
	CloudWatchLogs *CloudWatchLogs `json:"cloudWatchLogs,omitempty"`
	Firehose       *Firehose       `json:"firehose,omitempty"`
	S3             *S3             `json:"s3,omitempty"`
}

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

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

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

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

type ClientBroker string

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

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

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

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

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

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

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

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

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

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

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

type ClusterState string

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

type ClusterType string

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

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

type Configuration struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              ConfigurationSpec   `json:"spec,omitempty"`
	Status            ConfigurationStatus `json:"status,omitempty"`
}

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

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

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

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

type ConfigurationState string

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

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

type ConnectivityInfo struct {
	// Public access control for brokers.
	PublicAccess *PublicAccess `json:"publicAccess,omitempty"`
}

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

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

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

type CustomerActionStatus string

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

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

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

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

type EnhancedMonitoring string

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

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

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

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

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

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

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

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

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

type KafkaVersionStatus string

type LoggingInfo struct {
	BrokerLogs *BrokerLogs `json:"brokerLogs,omitempty"`
}

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"`
	// Controls storage mode for various supported storage tiers.
	StorageMode *string `json:"storageMode,omitempty"`
}

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

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

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

type NodeType string

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

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

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

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

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"`
	// Controls storage mode for various supported storage tiers.
	StorageMode               *string `json:"storageMode,omitempty"`
	ZookeeperConnectString    *string `json:"zookeeperConnectString,omitempty"`
	ZookeeperConnectStringTLS *string `json:"zookeeperConnectStringTLS,omitempty"`
}

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"`
	// Controls storage mode for various supported storage tiers.
	StorageMode *string `json:"storageMode,omitempty"`
}

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

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

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

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

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

type ReplicationStartingPositionType string

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

type ReplicationTopicNameConfigurationType string

type ReplicatorState string

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

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

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

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

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

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

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

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

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

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

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

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

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

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

type StorageMode string

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

type TargetCompressionType string

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

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

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

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

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

type UserIdentityType string

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

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

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

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

type VPCConnectionState string

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

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

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

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