Documentation
¶
Index ¶
- Constants
- Variables
- type BrokerAZDistribution
- type BrokerEBSVolumeInfo
- type BrokerLogs
- type BrokerNodeGroupInfo
- type BrokerNodeInfo
- type BrokerSoftwareInfo
- type ClientAuthentication
- type ClientBroker
- type CloudWatchLogs
- type Cluster
- func (in *Cluster) DeepCopy() *Cluster
- func (in *Cluster) DeepCopyInto(out *Cluster)
- func (in *Cluster) DeepCopyObject() runtime.Object
- func (mg *Cluster) GetCondition(ct xpv1.ConditionType) xpv1.Condition
- func (mg *Cluster) GetDeletionPolicy() xpv1.DeletionPolicy
- func (mg *Cluster) GetProviderConfigReference() *xpv1.Reference
- func (mg *Cluster) GetProviderReference() *xpv1.Reference
- func (mg *Cluster) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *Cluster) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (mg *Cluster) ResolveReferences(ctx context.Context, c client.Reader) error
- func (mg *Cluster) SetConditions(c ...xpv1.Condition)
- func (mg *Cluster) SetDeletionPolicy(r xpv1.DeletionPolicy)
- func (mg *Cluster) SetProviderConfigReference(r *xpv1.Reference)
- func (mg *Cluster) SetProviderReference(r *xpv1.Reference)
- func (mg *Cluster) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
- func (mg *Cluster) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
- type ClusterInfo
- type ClusterList
- type ClusterObservation
- type ClusterOperationInfo
- type ClusterOperationStep
- type ClusterOperationStepInfo
- type ClusterParameters
- type ClusterSpec
- type ClusterState
- type ClusterStatus
- type ClusterType
- type Cluster_SDK
- type CompatibleKafkaVersion
- type Configuration
- func (in *Configuration) DeepCopy() *Configuration
- func (in *Configuration) DeepCopyInto(out *Configuration)
- func (in *Configuration) DeepCopyObject() runtime.Object
- func (mg *Configuration) GetCondition(ct xpv1.ConditionType) xpv1.Condition
- func (mg *Configuration) GetDeletionPolicy() xpv1.DeletionPolicy
- func (mg *Configuration) GetProviderConfigReference() *xpv1.Reference
- func (mg *Configuration) GetProviderReference() *xpv1.Reference
- func (mg *Configuration) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *Configuration) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (mg *Configuration) SetConditions(c ...xpv1.Condition)
- func (mg *Configuration) SetDeletionPolicy(r xpv1.DeletionPolicy)
- func (mg *Configuration) SetProviderConfigReference(r *xpv1.Reference)
- func (mg *Configuration) SetProviderReference(r *xpv1.Reference)
- func (mg *Configuration) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
- func (mg *Configuration) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
- type ConfigurationInfo
- type ConfigurationList
- type ConfigurationObservation
- type ConfigurationParameters
- type ConfigurationRevision
- type ConfigurationSpec
- type ConfigurationState
- type ConfigurationStatus
- type Configuration_SDK
- type ConnectivityInfo
- type CustomBrokerNodeGroupInfo
- type CustomClusterParameters
- type CustomConfigurationInfo
- type CustomConfigurationParameters
- 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 ¶
const ( CRDGroup = "kafka.aws.crossplane.io" CRDVersion = "v1alpha1" )
Package type metadata.
Variables ¶
var ( ClusterKind = "Cluster" ClusterGroupKind = schema.GroupKind{Group: CRDGroup, Kind: ClusterKind}.String() ClusterKindAPIVersion = ClusterKind + "." + GroupVersion.String() ClusterGroupVersionKind = GroupVersion.WithKind(ClusterKind) )
Repository type metadata.
var ( ConfigurationKind = "Configuration" ConfigurationGroupKind = schema.GroupKind{Group: CRDGroup, Kind: ConfigurationKind}.String() ConfigurationKindAPIVersion = ConfigurationKind + "." + GroupVersion.String() ConfigurationGroupVersionKind = GroupVersion.WithKind(ConfigurationKind) )
Repository type metadata.
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 ¶
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"`
}
+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"`
}
+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 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 ¶
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.
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) GetProviderConfigReference ¶
GetProviderConfigReference of this Cluster.
func (*Cluster) GetProviderReference ¶
GetProviderReference of this Cluster. Deprecated: Use GetProviderConfigReference.
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 ¶
ResolveReferences of this Cluster.
func (*Cluster) SetConditions ¶
SetConditions of this Cluster.
func (*Cluster) SetDeletionPolicy ¶
func (mg *Cluster) SetDeletionPolicy(r xpv1.DeletionPolicy)
SetDeletionPolicy of this Cluster.
func (*Cluster) SetProviderConfigReference ¶
SetProviderConfigReference of this Cluster.
func (*Cluster) SetProviderReference ¶
SetProviderReference of this Cluster. Deprecated: Use SetProviderConfigReference.
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"`
// 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 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) GetProviderConfigReference ¶
func (mg *Configuration) GetProviderConfigReference() *xpv1.Reference
GetProviderConfigReference of this Configuration.
func (*Configuration) GetProviderReference ¶
func (mg *Configuration) GetProviderReference() *xpv1.Reference
GetProviderReference of this Configuration. Deprecated: Use GetProviderConfigReference.
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) SetProviderConfigReference ¶
func (mg *Configuration) SetProviderConfigReference(r *xpv1.Reference)
SetProviderConfigReference of this Configuration.
func (*Configuration) SetProviderReference ¶
func (mg *Configuration) SetProviderReference(r *xpv1.Reference)
SetProviderReference of this Configuration. Deprecated: Use SetProviderConfigReference.
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"`
}
+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"`
}
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"`
// 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
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 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 ¶
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"`
}
+kubebuilder:skipversion
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"`
}
+kubebuilder:skipversion
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"`
}
+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 ¶
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"`
}
+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 ¶
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 ¶ added in v0.39.0
+kubebuilder:skipversion
func (*SASL) DeepCopy ¶ added in v0.39.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SASL.
func (*SASL) DeepCopyInto ¶ added in v0.39.0
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
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SCRAM.
func (*SCRAM) DeepCopyInto ¶ added in v0.39.0
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 ¶
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"`
}
+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 ¶
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"`
}
+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 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
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VPCConfig.
func (*VPCConfig) DeepCopyInto ¶ added in v0.34.0
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.