Documentation
¶
Overview ¶
+k8s:deepcopy-gen=package Package v1alpha1 is the v1alpha1 version of the kafka.services.k8s.aws API. +groupName=kafka.services.k8s.aws
Index ¶
- Variables
- type BrokerAZDistribution
- type BrokerEBSVolumeInfo
- type BrokerLogs
- type BrokerNodeGroupInfo
- type BrokerNodeInfo
- type BrokerSoftwareInfo
- type ClientAuthentication
- type ClientBroker
- type CloudWatchLogs
- type Cluster
- type ClusterInfo
- type ClusterList
- type ClusterOperationInfo
- type ClusterOperationStep
- type ClusterOperationStepInfo
- type ClusterSpec
- type ClusterState
- type ClusterStatus
- type ClusterType
- type Cluster_SDK
- type CompatibleKafkaVersion
- type Configuration
- type ConfigurationInfo
- type ConfigurationList
- type ConfigurationRevision
- type ConfigurationSpec
- type ConfigurationState
- type ConfigurationStatus
- type Configuration_SDK
- type ConnectivityInfo
- type EBSStorageInfo
- type EncryptionAtRest
- type EncryptionInTransit
- type EncryptionInfo
- type EnhancedMonitoring
- type ErrorInfo
- type Firehose
- type IAM
- type JmxExporter
- type JmxExporterInfo
- type KafkaVersion
- type KafkaVersionStatus
- type LoggingInfo
- type MutableClusterInfo
- type NodeExporter
- type NodeExporterInfo
- type NodeInfo
- type NodeType
- type OpenMonitoring
- type OpenMonitoringInfo
- type Prometheus
- type PrometheusInfo
- type Provisioned
- type ProvisionedRequest
- type ProvisionedThroughput
- type PublicAccess
- type S3
- type SASL
- type SCRAM
- type ServerlessSASL
- type StateInfo
- type StorageInfo
- type StorageMode
- type TLS
- type Unauthenticated
- type UnprocessedSCRAMSecret
- type VPCConfig
- type ZookeeperNodeInfo
Constants ¶
This section is empty.
Variables ¶
var ( // GroupVersion is the API Group Version used to register the objects GroupVersion = schema.GroupVersion{Group: "kafka.services.k8s.aws", Version: "v1alpha1"} // SchemeBuilder is used to add go types to the GroupVersionKind scheme SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion} // AddToScheme adds the types in this group-version to the given scheme. AddToScheme = SchemeBuilder.AddToScheme )
Functions ¶
This section is empty.
Types ¶
type BrokerAZDistribution ¶
type BrokerAZDistribution string
const (
BrokerAZDistribution_DEFAULT BrokerAZDistribution = "DEFAULT"
)
type BrokerEBSVolumeInfo ¶
type BrokerEBSVolumeInfo struct { KafkaBrokerNodeID *string `json:"kafkaBrokerNodeID,omitempty"` // Contains information about provisioned throughput for EBS storage volumes // attached to kafka broker nodes. ProvisionedThroughput *ProvisionedThroughput `json:"provisionedThroughput,omitempty"` VolumeSizeGB *int64 `json:"volumeSizeGB,omitempty"` }
Specifies the EBS volume upgrade information. The broker identifier must be set to the keyword ALL. This means the changes apply to all the brokers in the cluster.
func (*BrokerEBSVolumeInfo) DeepCopy ¶
func (in *BrokerEBSVolumeInfo) DeepCopy() *BrokerEBSVolumeInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerEBSVolumeInfo.
func (*BrokerEBSVolumeInfo) DeepCopyInto ¶
func (in *BrokerEBSVolumeInfo) DeepCopyInto(out *BrokerEBSVolumeInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BrokerLogs ¶
type BrokerLogs struct { // Details of the CloudWatch Logs destination for broker logs. CloudWatchLogs *CloudWatchLogs `json:"cloudWatchLogs,omitempty"` // Firehose details for BrokerLogs. Firehose *Firehose `json:"firehose,omitempty"` // The details of the Amazon S3 destination for broker logs. S3 *S3 `json:"s3,omitempty"` }
The broker logs configuration for this MSK cluster.
func (*BrokerLogs) DeepCopy ¶
func (in *BrokerLogs) DeepCopy() *BrokerLogs
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerLogs.
func (*BrokerLogs) DeepCopyInto ¶
func (in *BrokerLogs) DeepCopyInto(out *BrokerLogs)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BrokerNodeGroupInfo ¶
type BrokerNodeGroupInfo struct { // The distribution of broker nodes across Availability Zones. By default, broker // nodes are distributed among the Availability Zones of your Region. Currently, // the only supported value is DEFAULT. You can either specify this value explicitly // or leave it out. BrokerAZDistribution *string `json:"brokerAZDistribution,omitempty"` ClientSubnets []*string `json:"clientSubnets,omitempty"` // Information about the broker access configuration. ConnectivityInfo *ConnectivityInfo `json:"connectivityInfo,omitempty"` InstanceType *string `json:"instanceType,omitempty"` SecurityGroups []*string `json:"securityGroups,omitempty"` // Contains information about storage volumes attached to MSK broker nodes. StorageInfo *StorageInfo `json:"storageInfo,omitempty"` }
Describes the setup to be used for Apache Kafka broker nodes in the cluster.
func (*BrokerNodeGroupInfo) DeepCopy ¶
func (in *BrokerNodeGroupInfo) DeepCopy() *BrokerNodeGroupInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerNodeGroupInfo.
func (*BrokerNodeGroupInfo) DeepCopyInto ¶
func (in *BrokerNodeGroupInfo) DeepCopyInto(out *BrokerNodeGroupInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BrokerNodeInfo ¶
type BrokerNodeInfo struct { AttachedENIID *string `json:"attachedENIID,omitempty"` ClientSubnet *string `json:"clientSubnet,omitempty"` ClientVPCIPAddress *string `json:"clientVPCIPAddress,omitempty"` // Information about the current software installed on the cluster. CurrentBrokerSoftwareInfo *BrokerSoftwareInfo `json:"currentBrokerSoftwareInfo,omitempty"` Endpoints []*string `json:"endpoints,omitempty"` }
BrokerNodeInfo
func (*BrokerNodeInfo) DeepCopy ¶
func (in *BrokerNodeInfo) DeepCopy() *BrokerNodeInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerNodeInfo.
func (*BrokerNodeInfo) DeepCopyInto ¶
func (in *BrokerNodeInfo) DeepCopyInto(out *BrokerNodeInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BrokerSoftwareInfo ¶
type BrokerSoftwareInfo struct { ConfigurationARN *string `json:"configurationARN,omitempty"` ConfigurationRevision *int64 `json:"configurationRevision,omitempty"` KafkaVersion *string `json:"kafkaVersion,omitempty"` }
Information about the current software installed on the cluster.
func (*BrokerSoftwareInfo) DeepCopy ¶
func (in *BrokerSoftwareInfo) DeepCopy() *BrokerSoftwareInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerSoftwareInfo.
func (*BrokerSoftwareInfo) DeepCopyInto ¶
func (in *BrokerSoftwareInfo) DeepCopyInto(out *BrokerSoftwareInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClientAuthentication ¶
type ClientAuthentication struct { SASL *SASL `json:"sasl,omitempty"` // Details for client authentication using TLS. TLS *TLS `json:"tls,omitempty"` // Contains information about unauthenticated traffic to the cluster. Unauthenticated *Unauthenticated `json:"unauthenticated,omitempty"` }
Includes all client authentication information.
func (*ClientAuthentication) DeepCopy ¶
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 CloudWatchLogs ¶
type CloudWatchLogs struct { Enabled *bool `json:"enabled,omitempty"` LogGroup *string `json:"logGroup,omitempty"` }
Details of the CloudWatch Logs destination for broker logs.
func (*CloudWatchLogs) DeepCopy ¶
func (in *CloudWatchLogs) DeepCopy() *CloudWatchLogs
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudWatchLogs.
func (*CloudWatchLogs) DeepCopyInto ¶
func (in *CloudWatchLogs) DeepCopyInto(out *CloudWatchLogs)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Cluster ¶
type Cluster struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec ClusterSpec `json:"spec,omitempty"` Status ClusterStatus `json:"status,omitempty"` }
Cluster is the Schema for the Clusters API +kubebuilder:object:root=true +kubebuilder:subresource:status
func (*Cluster) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Cluster.
func (*Cluster) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Cluster) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ClusterInfo ¶
type ClusterInfo struct { ActiveOperationARN *string `json:"activeOperationARN,omitempty"` // Describes the setup to be used for Apache Kafka broker nodes in the cluster. BrokerNodeGroupInfo *BrokerNodeGroupInfo `json:"brokerNodeGroupInfo,omitempty"` // Includes all client authentication information. ClientAuthentication *ClientAuthentication `json:"clientAuthentication,omitempty"` ClusterARN *string `json:"clusterARN,omitempty"` ClusterName *string `json:"clusterName,omitempty"` CreationTime *metav1.Time `json:"creationTime,omitempty"` // Information about the current software installed on the cluster. CurrentBrokerSoftwareInfo *BrokerSoftwareInfo `json:"currentBrokerSoftwareInfo,omitempty"` CurrentVersion *string `json:"currentVersion,omitempty"` // Includes encryption-related information, such as the AWS KMS key used for // encrypting data at rest and whether you want MSK to encrypt your data in // transit. EncryptionInfo *EncryptionInfo `json:"encryptionInfo,omitempty"` // Specifies which metrics are gathered for the MSK cluster. This property has // the following possible values: DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER, // and PER_TOPIC_PER_PARTITION. For a list of the metrics associated with each // of these levels of monitoring, see Monitoring (https://docs.aws.amazon.com/msk/latest/developerguide/monitoring.html). EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty"` // You can configure your MSK cluster to send broker logs to different destination // types. This is a container for the configuration details related to broker // logs. LoggingInfo *LoggingInfo `json:"loggingInfo,omitempty"` NumberOfBrokerNodes *int64 `json:"numberOfBrokerNodes,omitempty"` // JMX and Node monitoring for the MSK cluster. OpenMonitoring *OpenMonitoring `json:"openMonitoring,omitempty"` // The state of an Apache Kafka cluster. State *string `json:"state,omitempty"` // Contains information about the state of the Amazon MSK cluster. StateInfo *StateInfo `json:"stateInfo,omitempty"` // Controls storage mode for various supported storage tiers. StorageMode *string `json:"storageMode,omitempty"` Tags map[string]*string `json:"tags,omitempty"` ZookeeperConnectString *string `json:"zookeeperConnectString,omitempty"` ZookeeperConnectStringTLS *string `json:"zookeeperConnectStringTLS,omitempty"` }
Returns information about a cluster.
func (*ClusterInfo) DeepCopy ¶
func (in *ClusterInfo) DeepCopy() *ClusterInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterInfo.
func (*ClusterInfo) DeepCopyInto ¶
func (in *ClusterInfo) DeepCopyInto(out *ClusterInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterList ¶
type ClusterList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Cluster `json:"items"` }
ClusterList contains a list of Cluster +kubebuilder:object:root=true
func (*ClusterList) DeepCopy ¶
func (in *ClusterList) DeepCopy() *ClusterList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterList.
func (*ClusterList) DeepCopyInto ¶
func (in *ClusterList) DeepCopyInto(out *ClusterList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ClusterList) DeepCopyObject ¶
func (in *ClusterList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ClusterOperationInfo ¶
type ClusterOperationInfo struct { ClientRequestID *string `json:"clientRequestID,omitempty"` ClusterARN *string `json:"clusterARN,omitempty"` CreationTime *metav1.Time `json:"creationTime,omitempty"` EndTime *metav1.Time `json:"endTime,omitempty"` OperationARN *string `json:"operationARN,omitempty"` OperationState *string `json:"operationState,omitempty"` OperationType *string `json:"operationType,omitempty"` }
Returns information about a cluster operation.
func (*ClusterOperationInfo) DeepCopy ¶
func (in *ClusterOperationInfo) DeepCopy() *ClusterOperationInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterOperationInfo.
func (*ClusterOperationInfo) DeepCopyInto ¶
func (in *ClusterOperationInfo) DeepCopyInto(out *ClusterOperationInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterOperationStep ¶
type ClusterOperationStep struct {
StepName *string `json:"stepName,omitempty"`
}
Step taken during a cluster operation.
func (*ClusterOperationStep) DeepCopy ¶
func (in *ClusterOperationStep) DeepCopy() *ClusterOperationStep
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterOperationStep.
func (*ClusterOperationStep) DeepCopyInto ¶
func (in *ClusterOperationStep) DeepCopyInto(out *ClusterOperationStep)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterOperationStepInfo ¶
type ClusterOperationStepInfo struct {
StepStatus *string `json:"stepStatus,omitempty"`
}
State information about the operation step.
func (*ClusterOperationStepInfo) DeepCopy ¶
func (in *ClusterOperationStepInfo) DeepCopy() *ClusterOperationStepInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterOperationStepInfo.
func (*ClusterOperationStepInfo) DeepCopyInto ¶
func (in *ClusterOperationStepInfo) DeepCopyInto(out *ClusterOperationStepInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterSpec ¶
type ClusterSpec struct { // Information about the brokers. // +kubebuilder:validation:Required BrokerNodeGroupInfo *BrokerNodeGroupInfo `json:"brokerNodeGroupInfo"` // Includes all client authentication related information. ClientAuthentication *ClientAuthentication `json:"clientAuthentication,omitempty"` // Represents the configuration that you want MSK to use for the cluster. ConfigurationInfo *ConfigurationInfo `json:"configurationInfo,omitempty"` // Includes all encryption-related information. EncryptionInfo *EncryptionInfo `json:"encryptionInfo,omitempty"` // Specifies the level of monitoring for the MSK cluster. The possible values // are DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER, and PER_TOPIC_PER_PARTITION. EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty"` // The version of Apache Kafka. // +kubebuilder:validation:Required KafkaVersion *string `json:"kafkaVersion"` // LoggingInfo details. LoggingInfo *LoggingInfo `json:"loggingInfo,omitempty"` // The name of the cluster. // +kubebuilder:validation:Required Name *string `json:"name"` // The number of Apache Kafka broker nodes in the Amazon MSK cluster. // +kubebuilder:validation:Required NumberOfBrokerNodes *int64 `json:"numberOfBrokerNodes"` // The settings for open monitoring. OpenMonitoring *OpenMonitoringInfo `json:"openMonitoring,omitempty"` // This controls storage mode for supported storage tiers. StorageMode *string `json:"storageMode,omitempty"` // Create tags when creating the cluster. Tags map[string]*string `json:"tags,omitempty"` }
ClusterSpec defines the desired state of Cluster.
Returns information about a cluster of either the provisioned or the serverless type.
func (*ClusterSpec) DeepCopy ¶
func (in *ClusterSpec) DeepCopy() *ClusterSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSpec.
func (*ClusterSpec) DeepCopyInto ¶
func (in *ClusterSpec) DeepCopyInto(out *ClusterSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterState ¶
type ClusterState string
const ( ClusterState_ACTIVE ClusterState = "ACTIVE" ClusterState_CREATING ClusterState = "CREATING" ClusterState_DELETING ClusterState = "DELETING" ClusterState_FAILED ClusterState = "FAILED" ClusterState_HEALING ClusterState = "HEALING" ClusterState_MAINTENANCE ClusterState = "MAINTENANCE" ClusterState_REBOOTING_BROKER ClusterState = "REBOOTING_BROKER" ClusterState_UPDATING ClusterState = "UPDATING" )
type ClusterStatus ¶
type ClusterStatus struct { // All CRs managed by ACK have a common `Status.ACKResourceMetadata` member // that is used to contain resource sync state, account ownership, // constructed ARN for the resource // +kubebuilder:validation:Optional ACKResourceMetadata *ackv1alpha1.ResourceMetadata `json:"ackResourceMetadata"` // All CRS managed by ACK have a common `Status.Conditions` member that // contains a collection of `ackv1alpha1.Condition` objects that describe // the various terminal states of the CR and its backend AWS service API // resource // +kubebuilder:validation:Optional Conditions []*ackv1alpha1.Condition `json:"conditions"` // The state of the cluster. The possible states are ACTIVE, CREATING, DELETING, // FAILED, HEALING, MAINTENANCE, REBOOTING_BROKER, and UPDATING. // +kubebuilder:validation:Optional State *string `json:"state,omitempty"` // +kubebuilder:validation:Optional ZookeeperConnectString *string `json:"zookeeperConnectString,omitempty"` // +kubebuilder:validation:Optional ZookeeperConnectStringTLS *string `json:"zookeeperConnectStringTLS,omitempty"` }
ClusterStatus defines the observed state of Cluster
func (*ClusterStatus) DeepCopy ¶
func (in *ClusterStatus) DeepCopy() *ClusterStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterStatus.
func (*ClusterStatus) DeepCopyInto ¶
func (in *ClusterStatus) DeepCopyInto(out *ClusterStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterType ¶
type ClusterType string
const ( ClusterType_PROVISIONED ClusterType = "PROVISIONED" ClusterType_SERVERLESS ClusterType = "SERVERLESS" )
type Cluster_SDK ¶
type Cluster_SDK struct { ActiveOperationARN *string `json:"activeOperationARN,omitempty"` ClusterARN *string `json:"clusterARN,omitempty"` ClusterName *string `json:"clusterName,omitempty"` CreationTime *metav1.Time `json:"creationTime,omitempty"` CurrentVersion *string `json:"currentVersion,omitempty"` // The state of an Apache Kafka cluster. State *string `json:"state,omitempty"` // Contains information about the state of the Amazon MSK cluster. StateInfo *StateInfo `json:"stateInfo,omitempty"` Tags map[string]*string `json:"tags,omitempty"` }
Returns information about a cluster of either the provisioned or the serverless type.
func (*Cluster_SDK) DeepCopy ¶
func (in *Cluster_SDK) DeepCopy() *Cluster_SDK
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Cluster_SDK.
func (*Cluster_SDK) DeepCopyInto ¶
func (in *Cluster_SDK) DeepCopyInto(out *Cluster_SDK)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CompatibleKafkaVersion ¶
type CompatibleKafkaVersion struct { SourceVersion *string `json:"sourceVersion,omitempty"` TargetVersions []*string `json:"targetVersions,omitempty"` }
Contains source Apache Kafka versions and compatible target Apache Kafka versions.
func (*CompatibleKafkaVersion) DeepCopy ¶
func (in *CompatibleKafkaVersion) DeepCopy() *CompatibleKafkaVersion
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CompatibleKafkaVersion.
func (*CompatibleKafkaVersion) DeepCopyInto ¶
func (in *CompatibleKafkaVersion) DeepCopyInto(out *CompatibleKafkaVersion)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Configuration ¶
type Configuration struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec ConfigurationSpec `json:"spec,omitempty"` Status ConfigurationStatus `json:"status,omitempty"` }
Configuration is the Schema for the Configurations API +kubebuilder:object:root=true +kubebuilder:subresource:status
func (*Configuration) DeepCopy ¶
func (in *Configuration) DeepCopy() *Configuration
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Configuration.
func (*Configuration) DeepCopyInto ¶
func (in *Configuration) DeepCopyInto(out *Configuration)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Configuration) DeepCopyObject ¶ added in v0.0.7
func (in *Configuration) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ConfigurationInfo ¶
type ConfigurationInfo struct { ARN *string `json:"arn,omitempty"` Revision *int64 `json:"revision,omitempty"` }
Specifies the configuration to use for the brokers.
func (*ConfigurationInfo) DeepCopy ¶
func (in *ConfigurationInfo) DeepCopy() *ConfigurationInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationInfo.
func (*ConfigurationInfo) DeepCopyInto ¶
func (in *ConfigurationInfo) DeepCopyInto(out *ConfigurationInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConfigurationList ¶ added in v0.0.7
type ConfigurationList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Configuration `json:"items"` }
ConfigurationList contains a list of Configuration +kubebuilder:object:root=true
func (*ConfigurationList) DeepCopy ¶ added in v0.0.7
func (in *ConfigurationList) DeepCopy() *ConfigurationList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationList.
func (*ConfigurationList) DeepCopyInto ¶ added in v0.0.7
func (in *ConfigurationList) DeepCopyInto(out *ConfigurationList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ConfigurationList) DeepCopyObject ¶ added in v0.0.7
func (in *ConfigurationList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ConfigurationRevision ¶
type ConfigurationRevision struct { CreationTime *metav1.Time `json:"creationTime,omitempty"` Description *string `json:"description,omitempty"` Revision *int64 `json:"revision,omitempty"` }
Describes a configuration revision.
func (*ConfigurationRevision) DeepCopy ¶
func (in *ConfigurationRevision) DeepCopy() *ConfigurationRevision
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationRevision.
func (*ConfigurationRevision) DeepCopyInto ¶
func (in *ConfigurationRevision) DeepCopyInto(out *ConfigurationRevision)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConfigurationSpec ¶ added in v0.0.7
type ConfigurationSpec struct { // The description of the configuration. Description *string `json:"description,omitempty"` // The versions of Apache Kafka with which you can use this MSK configuration. KafkaVersions []*string `json:"kafkaVersions,omitempty"` // The name of the configuration. Configuration names are strings that match // the regex "^[0-9A-Za-z-]+$". // +kubebuilder:validation:Required Name *string `json:"name"` // +kubebuilder:validation:Required ServerProperties []byte `json:"serverProperties"` }
ConfigurationSpec defines the desired state of Configuration.
Represents an MSK Configuration.
func (*ConfigurationSpec) DeepCopy ¶ added in v0.0.7
func (in *ConfigurationSpec) DeepCopy() *ConfigurationSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationSpec.
func (*ConfigurationSpec) DeepCopyInto ¶ added in v0.0.7
func (in *ConfigurationSpec) DeepCopyInto(out *ConfigurationSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConfigurationState ¶
type ConfigurationState string
const ( ConfigurationState_ACTIVE ConfigurationState = "ACTIVE" ConfigurationState_DELETING ConfigurationState = "DELETING" ConfigurationState_DELETE_FAILED ConfigurationState = "DELETE_FAILED" )
type ConfigurationStatus ¶ added in v0.0.7
type ConfigurationStatus struct { // All CRs managed by ACK have a common `Status.ACKResourceMetadata` member // that is used to contain resource sync state, account ownership, // constructed ARN for the resource // +kubebuilder:validation:Optional ACKResourceMetadata *ackv1alpha1.ResourceMetadata `json:"ackResourceMetadata"` // All CRS managed by ACK have a common `Status.Conditions` member that // contains a collection of `ackv1alpha1.Condition` objects that describe // the various terminal states of the CR and its backend AWS service API // resource // +kubebuilder:validation:Optional Conditions []*ackv1alpha1.Condition `json:"conditions"` // The time when the configuration was created. // +kubebuilder:validation:Optional CreationTime *metav1.Time `json:"creationTime,omitempty"` // Latest revision of the configuration. // +kubebuilder:validation:Optional LatestRevision *ConfigurationRevision `json:"latestRevision,omitempty"` // The state of the configuration. The possible states are ACTIVE, DELETING // and DELETE_FAILED. // +kubebuilder:validation:Optional State *string `json:"state,omitempty"` }
ConfigurationStatus defines the observed state of Configuration
func (*ConfigurationStatus) DeepCopy ¶ added in v0.0.7
func (in *ConfigurationStatus) DeepCopy() *ConfigurationStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationStatus.
func (*ConfigurationStatus) DeepCopyInto ¶ added in v0.0.7
func (in *ConfigurationStatus) DeepCopyInto(out *ConfigurationStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Configuration_SDK ¶ added in v0.0.7
type Configuration_SDK struct { ARN *string `json:"arn,omitempty"` CreationTime *metav1.Time `json:"creationTime,omitempty"` Description *string `json:"description,omitempty"` KafkaVersions []*string `json:"kafkaVersions,omitempty"` // Describes a configuration revision. LatestRevision *ConfigurationRevision `json:"latestRevision,omitempty"` Name *string `json:"name,omitempty"` // The state of a configuration. State *string `json:"state,omitempty"` }
Represents an MSK Configuration.
func (*Configuration_SDK) DeepCopy ¶ added in v0.0.7
func (in *Configuration_SDK) DeepCopy() *Configuration_SDK
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Configuration_SDK.
func (*Configuration_SDK) DeepCopyInto ¶ added in v0.0.7
func (in *Configuration_SDK) DeepCopyInto(out *Configuration_SDK)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConnectivityInfo ¶
type ConnectivityInfo struct { // Broker public access control. PublicAccess *PublicAccess `json:"publicAccess,omitempty"` }
Information about the broker access configuration.
func (*ConnectivityInfo) DeepCopy ¶
func (in *ConnectivityInfo) DeepCopy() *ConnectivityInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectivityInfo.
func (*ConnectivityInfo) DeepCopyInto ¶
func (in *ConnectivityInfo) DeepCopyInto(out *ConnectivityInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EBSStorageInfo ¶
type EBSStorageInfo struct { // Contains information about provisioned throughput for EBS storage volumes // attached to kafka broker nodes. ProvisionedThroughput *ProvisionedThroughput `json:"provisionedThroughput,omitempty"` VolumeSize *int64 `json:"volumeSize,omitempty"` }
Contains information about the EBS storage volumes attached to Apache Kafka broker nodes.
func (*EBSStorageInfo) DeepCopy ¶
func (in *EBSStorageInfo) DeepCopy() *EBSStorageInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EBSStorageInfo.
func (*EBSStorageInfo) DeepCopyInto ¶
func (in *EBSStorageInfo) DeepCopyInto(out *EBSStorageInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EncryptionAtRest ¶
type EncryptionAtRest struct {
DataVolumeKMSKeyID *string `json:"dataVolumeKMSKeyID,omitempty"`
}
The data-volume encryption details.
func (*EncryptionAtRest) DeepCopy ¶
func (in *EncryptionAtRest) DeepCopy() *EncryptionAtRest
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EncryptionAtRest.
func (*EncryptionAtRest) DeepCopyInto ¶
func (in *EncryptionAtRest) DeepCopyInto(out *EncryptionAtRest)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EncryptionInTransit ¶
type EncryptionInTransit struct { // Client-broker encryption in transit setting. ClientBroker *string `json:"clientBroker,omitempty"` InCluster *bool `json:"inCluster,omitempty"` }
The settings for encrypting data in transit.
func (*EncryptionInTransit) DeepCopy ¶
func (in *EncryptionInTransit) DeepCopy() *EncryptionInTransit
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EncryptionInTransit.
func (*EncryptionInTransit) DeepCopyInto ¶
func (in *EncryptionInTransit) DeepCopyInto(out *EncryptionInTransit)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EncryptionInfo ¶
type EncryptionInfo struct { // The data-volume encryption details. EncryptionAtRest *EncryptionAtRest `json:"encryptionAtRest,omitempty"` // The settings for encrypting data in transit. EncryptionInTransit *EncryptionInTransit `json:"encryptionInTransit,omitempty"` }
Includes encryption-related information, such as the AWS KMS key used for encrypting data at rest and whether you want MSK to encrypt your data in transit.
func (*EncryptionInfo) DeepCopy ¶
func (in *EncryptionInfo) DeepCopy() *EncryptionInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EncryptionInfo.
func (*EncryptionInfo) DeepCopyInto ¶
func (in *EncryptionInfo) DeepCopyInto(out *EncryptionInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EnhancedMonitoring ¶
type EnhancedMonitoring string
const ( EnhancedMonitoring_DEFAULT EnhancedMonitoring = "DEFAULT" EnhancedMonitoring_PER_BROKER EnhancedMonitoring = "PER_BROKER" EnhancedMonitoring_PER_TOPIC_PER_BROKER EnhancedMonitoring = "PER_TOPIC_PER_BROKER" EnhancedMonitoring_PER_TOPIC_PER_PARTITION EnhancedMonitoring = "PER_TOPIC_PER_PARTITION" )
type ErrorInfo ¶
type ErrorInfo struct { ErrorCode *string `json:"errorCode,omitempty"` ErrorString *string `json:"errorString,omitempty"` }
Returns information about an error state of the cluster.
func (*ErrorInfo) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ErrorInfo.
func (*ErrorInfo) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Firehose ¶
type Firehose struct { DeliveryStream *string `json:"deliveryStream,omitempty"` Enabled *bool `json:"enabled,omitempty"` }
Firehose details for BrokerLogs.
func (*Firehose) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Firehose.
func (*Firehose) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type IAM ¶
type IAM struct {
Enabled *bool `json:"enabled,omitempty"`
}
func (*IAM) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new IAM.
func (*IAM) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type JmxExporter ¶
type JmxExporter struct {
EnabledInBroker *bool `json:"enabledInBroker,omitempty"`
}
Indicates whether you want to enable or disable the JMX Exporter.
func (*JmxExporter) DeepCopy ¶
func (in *JmxExporter) DeepCopy() *JmxExporter
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JmxExporter.
func (*JmxExporter) DeepCopyInto ¶
func (in *JmxExporter) DeepCopyInto(out *JmxExporter)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type JmxExporterInfo ¶
type JmxExporterInfo struct {
EnabledInBroker *bool `json:"enabledInBroker,omitempty"`
}
Indicates whether you want to enable or disable the JMX Exporter.
func (*JmxExporterInfo) DeepCopy ¶
func (in *JmxExporterInfo) DeepCopy() *JmxExporterInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JmxExporterInfo.
func (*JmxExporterInfo) DeepCopyInto ¶
func (in *JmxExporterInfo) DeepCopyInto(out *JmxExporterInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KafkaVersion ¶
type KafkaVersion struct {
Version *string `json:"version,omitempty"`
}
Information about a Apache Kafka version.
func (*KafkaVersion) DeepCopy ¶
func (in *KafkaVersion) DeepCopy() *KafkaVersion
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaVersion.
func (*KafkaVersion) DeepCopyInto ¶
func (in *KafkaVersion) DeepCopyInto(out *KafkaVersion)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KafkaVersionStatus ¶
type KafkaVersionStatus string
const ( KafkaVersionStatus_ACTIVE KafkaVersionStatus = "ACTIVE" KafkaVersionStatus_DEPRECATED KafkaVersionStatus = "DEPRECATED" )
type LoggingInfo ¶
type LoggingInfo struct { // The broker logs configuration for this MSK cluster. BrokerLogs *BrokerLogs `json:"brokerLogs,omitempty"` }
You can configure your MSK cluster to send broker logs to different destination types. This is a container for the configuration details related to broker logs.
func (*LoggingInfo) DeepCopy ¶
func (in *LoggingInfo) DeepCopy() *LoggingInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LoggingInfo.
func (*LoggingInfo) DeepCopyInto ¶
func (in *LoggingInfo) DeepCopyInto(out *LoggingInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type MutableClusterInfo ¶
type MutableClusterInfo struct { // Includes all client authentication information. ClientAuthentication *ClientAuthentication `json:"clientAuthentication,omitempty"` // Specifies the configuration to use for the brokers. ConfigurationInfo *ConfigurationInfo `json:"configurationInfo,omitempty"` // Information about the broker access configuration. ConnectivityInfo *ConnectivityInfo `json:"connectivityInfo,omitempty"` // Includes encryption-related information, such as the AWS KMS key used for // encrypting data at rest and whether you want MSK to encrypt your data in // transit. EncryptionInfo *EncryptionInfo `json:"encryptionInfo,omitempty"` // Specifies which metrics are gathered for the MSK cluster. This property has // the following possible values: DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER, // and PER_TOPIC_PER_PARTITION. For a list of the metrics associated with each // of these levels of monitoring, see Monitoring (https://docs.aws.amazon.com/msk/latest/developerguide/monitoring.html). EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty"` InstanceType *string `json:"instanceType,omitempty"` KafkaVersion *string `json:"kafkaVersion,omitempty"` // You can configure your MSK cluster to send broker logs to different destination // types. This is a container for the configuration details related to broker // logs. LoggingInfo *LoggingInfo `json:"loggingInfo,omitempty"` NumberOfBrokerNodes *int64 `json:"numberOfBrokerNodes,omitempty"` // JMX and Node monitoring for the MSK cluster. OpenMonitoring *OpenMonitoring `json:"openMonitoring,omitempty"` // Controls storage mode for various supported storage tiers. StorageMode *string `json:"storageMode,omitempty"` }
Information about cluster attributes that can be updated via update APIs.
func (*MutableClusterInfo) DeepCopy ¶
func (in *MutableClusterInfo) DeepCopy() *MutableClusterInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MutableClusterInfo.
func (*MutableClusterInfo) DeepCopyInto ¶
func (in *MutableClusterInfo) DeepCopyInto(out *MutableClusterInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type NodeExporter ¶
type NodeExporter struct {
EnabledInBroker *bool `json:"enabledInBroker,omitempty"`
}
Indicates whether you want to enable or disable the Node Exporter.
func (*NodeExporter) DeepCopy ¶
func (in *NodeExporter) DeepCopy() *NodeExporter
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NodeExporter.
func (*NodeExporter) DeepCopyInto ¶
func (in *NodeExporter) DeepCopyInto(out *NodeExporter)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type NodeExporterInfo ¶
type NodeExporterInfo struct {
EnabledInBroker *bool `json:"enabledInBroker,omitempty"`
}
Indicates whether you want to enable or disable the Node Exporter.
func (*NodeExporterInfo) DeepCopy ¶
func (in *NodeExporterInfo) DeepCopy() *NodeExporterInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NodeExporterInfo.
func (*NodeExporterInfo) DeepCopyInto ¶
func (in *NodeExporterInfo) DeepCopyInto(out *NodeExporterInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type NodeInfo ¶
type NodeInfo struct { AddedToClusterTime *string `json:"addedToClusterTime,omitempty"` InstanceType *string `json:"instanceType,omitempty"` NodeARN *string `json:"nodeARN,omitempty"` }
The node information object.
func (*NodeInfo) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NodeInfo.
func (*NodeInfo) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type OpenMonitoring ¶
type OpenMonitoring struct { // Prometheus settings for open monitoring. Prometheus *Prometheus `json:"prometheus,omitempty"` }
JMX and Node monitoring for the MSK cluster.
func (*OpenMonitoring) DeepCopy ¶
func (in *OpenMonitoring) DeepCopy() *OpenMonitoring
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OpenMonitoring.
func (*OpenMonitoring) DeepCopyInto ¶
func (in *OpenMonitoring) DeepCopyInto(out *OpenMonitoring)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type OpenMonitoringInfo ¶
type OpenMonitoringInfo struct { // Prometheus settings. Prometheus *PrometheusInfo `json:"prometheus,omitempty"` }
JMX and Node monitoring for the MSK cluster.
func (*OpenMonitoringInfo) DeepCopy ¶
func (in *OpenMonitoringInfo) DeepCopy() *OpenMonitoringInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OpenMonitoringInfo.
func (*OpenMonitoringInfo) DeepCopyInto ¶
func (in *OpenMonitoringInfo) DeepCopyInto(out *OpenMonitoringInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Prometheus ¶
type Prometheus struct { // Indicates whether you want to enable or disable the JMX Exporter. JmxExporter *JmxExporter `json:"jmxExporter,omitempty"` // Indicates whether you want to enable or disable the Node Exporter. NodeExporter *NodeExporter `json:"nodeExporter,omitempty"` }
Prometheus settings for open monitoring.
func (*Prometheus) DeepCopy ¶
func (in *Prometheus) DeepCopy() *Prometheus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Prometheus.
func (*Prometheus) DeepCopyInto ¶
func (in *Prometheus) DeepCopyInto(out *Prometheus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PrometheusInfo ¶
type PrometheusInfo struct { // Indicates whether you want to enable or disable the JMX Exporter. JmxExporter *JmxExporterInfo `json:"jmxExporter,omitempty"` // Indicates whether you want to enable or disable the Node Exporter. NodeExporter *NodeExporterInfo `json:"nodeExporter,omitempty"` }
Prometheus settings.
func (*PrometheusInfo) DeepCopy ¶
func (in *PrometheusInfo) DeepCopy() *PrometheusInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PrometheusInfo.
func (*PrometheusInfo) DeepCopyInto ¶
func (in *PrometheusInfo) DeepCopyInto(out *PrometheusInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Provisioned ¶
type Provisioned struct { // Describes the setup to be used for Apache Kafka broker nodes in the cluster. BrokerNodeGroupInfo *BrokerNodeGroupInfo `json:"brokerNodeGroupInfo,omitempty"` // Includes all client authentication information. ClientAuthentication *ClientAuthentication `json:"clientAuthentication,omitempty"` // Information about the current software installed on the cluster. CurrentBrokerSoftwareInfo *BrokerSoftwareInfo `json:"currentBrokerSoftwareInfo,omitempty"` // Includes encryption-related information, such as the AWS KMS key used for // encrypting data at rest and whether you want MSK to encrypt your data in // transit. EncryptionInfo *EncryptionInfo `json:"encryptionInfo,omitempty"` // Specifies which metrics are gathered for the MSK cluster. This property has // the following possible values: DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER, // and PER_TOPIC_PER_PARTITION. For a list of the metrics associated with each // of these levels of monitoring, see Monitoring (https://docs.aws.amazon.com/msk/latest/developerguide/monitoring.html). EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty"` // You can configure your MSK cluster to send broker logs to different destination // types. This is a container for the configuration details related to broker // logs. LoggingInfo *LoggingInfo `json:"loggingInfo,omitempty"` NumberOfBrokerNodes *int64 `json:"numberOfBrokerNodes,omitempty"` // JMX and Node monitoring for the MSK cluster. OpenMonitoring *OpenMonitoringInfo `json:"openMonitoring,omitempty"` // Controls storage mode for various supported storage tiers. StorageMode *string `json:"storageMode,omitempty"` ZookeeperConnectString *string `json:"zookeeperConnectString,omitempty"` ZookeeperConnectStringTLS *string `json:"zookeeperConnectStringTLS,omitempty"` }
Describes the provisioned cluster.
func (*Provisioned) DeepCopy ¶
func (in *Provisioned) DeepCopy() *Provisioned
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Provisioned.
func (*Provisioned) DeepCopyInto ¶
func (in *Provisioned) DeepCopyInto(out *Provisioned)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ProvisionedRequest ¶
type ProvisionedRequest struct { // Describes the setup to be used for Apache Kafka broker nodes in the cluster. BrokerNodeGroupInfo *BrokerNodeGroupInfo `json:"brokerNodeGroupInfo,omitempty"` // Includes all client authentication information. ClientAuthentication *ClientAuthentication `json:"clientAuthentication,omitempty"` // Specifies the configuration to use for the brokers. ConfigurationInfo *ConfigurationInfo `json:"configurationInfo,omitempty"` // Includes encryption-related information, such as the AWS KMS key used for // encrypting data at rest and whether you want MSK to encrypt your data in // transit. EncryptionInfo *EncryptionInfo `json:"encryptionInfo,omitempty"` // Specifies which metrics are gathered for the MSK cluster. This property has // the following possible values: DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER, // and PER_TOPIC_PER_PARTITION. For a list of the metrics associated with each // of these levels of monitoring, see Monitoring (https://docs.aws.amazon.com/msk/latest/developerguide/monitoring.html). EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty"` KafkaVersion *string `json:"kafkaVersion,omitempty"` // You can configure your MSK cluster to send broker logs to different destination // types. This is a container for the configuration details related to broker // logs. LoggingInfo *LoggingInfo `json:"loggingInfo,omitempty"` NumberOfBrokerNodes *int64 `json:"numberOfBrokerNodes,omitempty"` // JMX and Node monitoring for the MSK cluster. OpenMonitoring *OpenMonitoringInfo `json:"openMonitoring,omitempty"` // Controls storage mode for various supported storage tiers. StorageMode *string `json:"storageMode,omitempty"` }
Creates a provisioned cluster.
func (*ProvisionedRequest) DeepCopy ¶
func (in *ProvisionedRequest) DeepCopy() *ProvisionedRequest
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ProvisionedRequest.
func (*ProvisionedRequest) DeepCopyInto ¶
func (in *ProvisionedRequest) DeepCopyInto(out *ProvisionedRequest)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ProvisionedThroughput ¶
type ProvisionedThroughput struct { Enabled *bool `json:"enabled,omitempty"` VolumeThroughput *int64 `json:"volumeThroughput,omitempty"` }
Contains information about provisioned throughput for EBS storage volumes attached to kafka broker nodes.
func (*ProvisionedThroughput) DeepCopy ¶
func (in *ProvisionedThroughput) DeepCopy() *ProvisionedThroughput
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ProvisionedThroughput.
func (*ProvisionedThroughput) DeepCopyInto ¶
func (in *ProvisionedThroughput) DeepCopyInto(out *ProvisionedThroughput)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PublicAccess ¶
type PublicAccess struct {
Type *string `json:"type_,omitempty"`
}
Broker public access control.
func (*PublicAccess) DeepCopy ¶
func (in *PublicAccess) DeepCopy() *PublicAccess
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PublicAccess.
func (*PublicAccess) DeepCopyInto ¶
func (in *PublicAccess) DeepCopyInto(out *PublicAccess)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type S3 ¶
type S3 struct { Bucket *string `json:"bucket,omitempty"` Enabled *bool `json:"enabled,omitempty"` Prefix *string `json:"prefix,omitempty"` }
The details of the Amazon S3 destination for broker logs.
func (*S3) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new S3.
func (*S3) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SASL ¶
func (*SASL) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SASL.
func (*SASL) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SCRAM ¶
type SCRAM struct {
Enabled *bool `json:"enabled,omitempty"`
}
func (*SCRAM) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SCRAM.
func (*SCRAM) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServerlessSASL ¶
type ServerlessSASL struct {
IAM *IAM `json:"iam,omitempty"`
}
Describes the serverless cluster SASL information.
func (*ServerlessSASL) DeepCopy ¶
func (in *ServerlessSASL) DeepCopy() *ServerlessSASL
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerlessSASL.
func (*ServerlessSASL) DeepCopyInto ¶
func (in *ServerlessSASL) DeepCopyInto(out *ServerlessSASL)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StateInfo ¶
type StateInfo struct { Code *string `json:"code,omitempty"` Message *string `json:"message,omitempty"` }
Contains information about the state of the Amazon MSK cluster.
func (*StateInfo) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StateInfo.
func (*StateInfo) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StorageInfo ¶
type StorageInfo struct { // Contains information about the EBS storage volumes attached to Apache Kafka // broker nodes. EBSStorageInfo *EBSStorageInfo `json:"ebsStorageInfo,omitempty"` }
Contains information about storage volumes attached to MSK broker nodes.
func (*StorageInfo) DeepCopy ¶
func (in *StorageInfo) DeepCopy() *StorageInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StorageInfo.
func (*StorageInfo) DeepCopyInto ¶
func (in *StorageInfo) DeepCopyInto(out *StorageInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StorageMode ¶
type StorageMode string
const ( StorageMode_LOCAL StorageMode = "LOCAL" StorageMode_TIERED StorageMode = "TIERED" )
type TLS ¶
type TLS struct { CertificateAuthorityARNList []*string `json:"certificateAuthorityARNList,omitempty"` Enabled *bool `json:"enabled,omitempty"` }
Details for client authentication using TLS.
func (*TLS) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TLS.
func (*TLS) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Unauthenticated ¶
type Unauthenticated struct {
Enabled *bool `json:"enabled,omitempty"`
}
Contains information about unauthenticated traffic to the cluster.
func (*Unauthenticated) DeepCopy ¶
func (in *Unauthenticated) DeepCopy() *Unauthenticated
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Unauthenticated.
func (*Unauthenticated) DeepCopyInto ¶
func (in *Unauthenticated) DeepCopyInto(out *Unauthenticated)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type UnprocessedSCRAMSecret ¶
type UnprocessedSCRAMSecret struct { ErrorCode *string `json:"errorCode,omitempty"` ErrorMessage *string `json:"errorMessage,omitempty"` SecretARN *string `json:"secretARN,omitempty"` }
func (*UnprocessedSCRAMSecret) DeepCopy ¶
func (in *UnprocessedSCRAMSecret) DeepCopy() *UnprocessedSCRAMSecret
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UnprocessedSCRAMSecret.
func (*UnprocessedSCRAMSecret) DeepCopyInto ¶
func (in *UnprocessedSCRAMSecret) DeepCopyInto(out *UnprocessedSCRAMSecret)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type VPCConfig ¶
type VPCConfig struct { SecurityGroupIDs []*string `json:"securityGroupIDs,omitempty"` SubnetIDs []*string `json:"subnetIDs,omitempty"` }
The configuration of the Amazon VPCs for the cluster.
func (*VPCConfig) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VPCConfig.
func (*VPCConfig) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ZookeeperNodeInfo ¶
type ZookeeperNodeInfo struct { AttachedENIID *string `json:"attachedENIID,omitempty"` ClientVPCIPAddress *string `json:"clientVPCIPAddress,omitempty"` Endpoints []*string `json:"endpoints,omitempty"` ZookeeperVersion *string `json:"zookeeperVersion,omitempty"` }
Zookeeper node information.
func (*ZookeeperNodeInfo) DeepCopy ¶
func (in *ZookeeperNodeInfo) DeepCopy() *ZookeeperNodeInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ZookeeperNodeInfo.
func (*ZookeeperNodeInfo) DeepCopyInto ¶
func (in *ZookeeperNodeInfo) DeepCopyInto(out *ZookeeperNodeInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.