Documentation ¶
Index ¶
- Constants
- Variables
- func ConfugurationARN() reference.ExtractValueFn
- type BrokerAZDistribution
- type BrokerEBSVolumeInfo
- type BrokerLogs
- type BrokerNodeGroupInfo
- type BrokerNodeInfo
- type BrokerSoftwareInfo
- type ClientAuthentication
- type ClientBroker
- type ClientVPCConnection
- 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) GetManagementPolicies() xpv1.ManagementPolicies
- func (mg *Cluster) GetProviderConfigReference() *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) SetManagementPolicies(r xpv1.ManagementPolicies)
- func (mg *Cluster) SetProviderConfigReference(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 ClusterOperationV2
- type ClusterOperationV2Summary
- 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) GetManagementPolicies() xpv1.ManagementPolicies
- func (mg *Configuration) GetProviderConfigReference() *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) SetManagementPolicies(r xpv1.ManagementPolicies)
- func (mg *Configuration) SetProviderConfigReference(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 CustomConnectivityInfo
- type CustomPublicAccess
- 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 UserIdentity
- type UserIdentityType
- type VPCConfig
- type VPCConnection
- type VPCConnectionInfo
- type VPCConnectionInfoServerless
- type VPCConnectionState
- type VPCConnectivity
- type VPCConnectivityClientAuthentication
- type VPCConnectivityIAM
- type VPCConnectivitySASL
- type VPCConnectivitySCRAM
- type VPCConnectivityTLS
- 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 ¶
func ConfugurationARN ¶ added in v0.44.1
func ConfugurationARN() reference.ExtractValueFn
ConfugurationARN returns the status.atProvider.ARN of a Configuration.
Types ¶
type BrokerAZDistribution ¶
type BrokerAZDistribution string
const (
BrokerAZDistribution_DEFAULT BrokerAZDistribution = "DEFAULT"
)
type BrokerEBSVolumeInfo ¶
type BrokerEBSVolumeInfo struct { KafkaBrokerNodeID *string `json:"kafkaBrokerNodeID,omitempty"` // Contains information about provisioned throughput for EBS storage volumes // attached to kafka broker nodes. ProvisionedThroughput *ProvisionedThroughput `json:"provisionedThroughput,omitempty"` VolumeSizeGB *int64 `json:"volumeSizeGB,omitempty"` }
+kubebuilder:skipversion
func (*BrokerEBSVolumeInfo) DeepCopy ¶
func (in *BrokerEBSVolumeInfo) DeepCopy() *BrokerEBSVolumeInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerEBSVolumeInfo.
func (*BrokerEBSVolumeInfo) DeepCopyInto ¶
func (in *BrokerEBSVolumeInfo) DeepCopyInto(out *BrokerEBSVolumeInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BrokerLogs ¶
type BrokerLogs struct { // Details of the CloudWatch Logs destination for broker logs. CloudWatchLogs *CloudWatchLogs `json:"cloudWatchLogs,omitempty"` // Firehose details for BrokerLogs. Firehose *Firehose `json:"firehose,omitempty"` // The details of the Amazon S3 destination for broker logs. S3 *S3 `json:"s3,omitempty"` }
+kubebuilder:skipversion
func (*BrokerLogs) DeepCopy ¶
func (in *BrokerLogs) DeepCopy() *BrokerLogs
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerLogs.
func (*BrokerLogs) DeepCopyInto ¶
func (in *BrokerLogs) DeepCopyInto(out *BrokerLogs)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BrokerNodeGroupInfo ¶
type BrokerNodeGroupInfo struct { // The distribution of broker nodes across Availability Zones. By default, broker // nodes are distributed among the Availability Zones of your Region. Currently, // the only supported value is DEFAULT. You can either specify this value explicitly // or leave it out. BrokerAZDistribution *string `json:"brokerAZDistribution,omitempty"` ClientSubnets []*string `json:"clientSubnets,omitempty"` // Information about the broker access configuration. ConnectivityInfo *ConnectivityInfo `json:"connectivityInfo,omitempty"` InstanceType *string `json:"instanceType,omitempty"` SecurityGroups []*string `json:"securityGroups,omitempty"` // Contains information about storage volumes attached to MSK broker nodes. StorageInfo *StorageInfo `json:"storageInfo,omitempty"` ZoneIDs []*string `json:"zoneIDs,omitempty"` }
+kubebuilder:skipversion
func (*BrokerNodeGroupInfo) DeepCopy ¶
func (in *BrokerNodeGroupInfo) DeepCopy() *BrokerNodeGroupInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerNodeGroupInfo.
func (*BrokerNodeGroupInfo) DeepCopyInto ¶
func (in *BrokerNodeGroupInfo) DeepCopyInto(out *BrokerNodeGroupInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BrokerNodeInfo ¶
type BrokerNodeInfo struct { AttachedENIID *string `json:"attachedENIID,omitempty"` ClientSubnet *string `json:"clientSubnet,omitempty"` ClientVPCIPAddress *string `json:"clientVPCIPAddress,omitempty"` // Information about the current software installed on the cluster. CurrentBrokerSoftwareInfo *BrokerSoftwareInfo `json:"currentBrokerSoftwareInfo,omitempty"` Endpoints []*string `json:"endpoints,omitempty"` }
+kubebuilder:skipversion
func (*BrokerNodeInfo) DeepCopy ¶
func (in *BrokerNodeInfo) DeepCopy() *BrokerNodeInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerNodeInfo.
func (*BrokerNodeInfo) DeepCopyInto ¶
func (in *BrokerNodeInfo) DeepCopyInto(out *BrokerNodeInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BrokerSoftwareInfo ¶
type BrokerSoftwareInfo struct { ConfigurationARN *string `json:"configurationARN,omitempty"` ConfigurationRevision *int64 `json:"configurationRevision,omitempty"` KafkaVersion *string `json:"kafkaVersion,omitempty"` }
+kubebuilder:skipversion
func (*BrokerSoftwareInfo) DeepCopy ¶
func (in *BrokerSoftwareInfo) DeepCopy() *BrokerSoftwareInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerSoftwareInfo.
func (*BrokerSoftwareInfo) DeepCopyInto ¶
func (in *BrokerSoftwareInfo) DeepCopyInto(out *BrokerSoftwareInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClientAuthentication ¶
type ClientAuthentication struct { SASL *SASL `json:"sasl,omitempty"` // Details for client authentication using TLS. TLS *TLS `json:"tls,omitempty"` // Contains information about unauthenticated traffic to the cluster. Unauthenticated *Unauthenticated `json:"unauthenticated,omitempty"` }
+kubebuilder:skipversion
func (*ClientAuthentication) DeepCopy ¶
func (in *ClientAuthentication) DeepCopy() *ClientAuthentication
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClientAuthentication.
func (*ClientAuthentication) DeepCopyInto ¶
func (in *ClientAuthentication) DeepCopyInto(out *ClientAuthentication)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClientBroker ¶
type ClientBroker string
const ( ClientBroker_TLS ClientBroker = "TLS" ClientBroker_TLS_PLAINTEXT ClientBroker = "TLS_PLAINTEXT" ClientBroker_PLAINTEXT ClientBroker = "PLAINTEXT" )
type ClientVPCConnection ¶ added in v0.44.0
type ClientVPCConnection struct { Authentication *string `json:"authentication,omitempty"` CreationTime *metav1.Time `json:"creationTime,omitempty"` Owner *string `json:"owner,omitempty"` VPCConnectionARN *string `json:"vpcConnectionARN,omitempty"` }
+kubebuilder:skipversion
func (*ClientVPCConnection) DeepCopy ¶ added in v0.44.0
func (in *ClientVPCConnection) DeepCopy() *ClientVPCConnection
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClientVPCConnection.
func (*ClientVPCConnection) DeepCopyInto ¶ added in v0.44.0
func (in *ClientVPCConnection) DeepCopyInto(out *ClientVPCConnection)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CloudWatchLogs ¶
type CloudWatchLogs struct { Enabled *bool `json:"enabled,omitempty"` LogGroup *string `json:"logGroup,omitempty"` }
+kubebuilder:skipversion
func (*CloudWatchLogs) DeepCopy ¶
func (in *CloudWatchLogs) DeepCopy() *CloudWatchLogs
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudWatchLogs.
func (*CloudWatchLogs) DeepCopyInto ¶
func (in *CloudWatchLogs) DeepCopyInto(out *CloudWatchLogs)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Cluster ¶
type Cluster struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec ClusterSpec `json:"spec"` Status ClusterStatus `json:"status,omitempty"` }
Cluster is the Schema for the Clusters API +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:storageversion +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,aws}
func (*Cluster) DeepCopy ¶
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) GetManagementPolicies ¶ added in v0.43.0
func (mg *Cluster) GetManagementPolicies() xpv1.ManagementPolicies
GetManagementPolicies of this Cluster.
func (*Cluster) GetProviderConfigReference ¶
GetProviderConfigReference of this Cluster.
func (*Cluster) GetPublishConnectionDetailsTo ¶
func (mg *Cluster) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
GetPublishConnectionDetailsTo of this Cluster.
func (*Cluster) GetWriteConnectionSecretToReference ¶
func (mg *Cluster) GetWriteConnectionSecretToReference() *xpv1.SecretReference
GetWriteConnectionSecretToReference of this Cluster.
func (*Cluster) ResolveReferences ¶
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) SetManagementPolicies ¶ added in v0.43.0
func (mg *Cluster) SetManagementPolicies(r xpv1.ManagementPolicies)
SetManagementPolicies of this Cluster.
func (*Cluster) SetProviderConfigReference ¶
SetProviderConfigReference of this Cluster.
func (*Cluster) SetPublishConnectionDetailsTo ¶
func (mg *Cluster) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
SetPublishConnectionDetailsTo of this Cluster.
func (*Cluster) SetWriteConnectionSecretToReference ¶
func (mg *Cluster) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
SetWriteConnectionSecretToReference of this Cluster.
type ClusterInfo ¶
type ClusterInfo struct { ActiveOperationARN *string `json:"activeOperationARN,omitempty"` // Describes the setup to be used for Apache Kafka broker nodes in the cluster. BrokerNodeGroupInfo *BrokerNodeGroupInfo `json:"brokerNodeGroupInfo,omitempty"` // Includes all client authentication information. ClientAuthentication *ClientAuthentication `json:"clientAuthentication,omitempty"` ClusterARN *string `json:"clusterARN,omitempty"` ClusterName *string `json:"clusterName,omitempty"` CreationTime *metav1.Time `json:"creationTime,omitempty"` // Information about the current software installed on the cluster. CurrentBrokerSoftwareInfo *BrokerSoftwareInfo `json:"currentBrokerSoftwareInfo,omitempty"` CurrentVersion *string `json:"currentVersion,omitempty"` // Includes encryption-related information, such as the AWS KMS key used for // encrypting data at rest and whether you want MSK to encrypt your data in // transit. EncryptionInfo *EncryptionInfo `json:"encryptionInfo,omitempty"` // Specifies which metrics are gathered for the MSK cluster. This property has // the following possible values: DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER, // and PER_TOPIC_PER_PARTITION. For a list of the metrics associated with each // of these levels of monitoring, see Monitoring (https://docs.aws.amazon.com/msk/latest/developerguide/monitoring.html). EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty"` // You can configure your MSK cluster to send broker logs to different destination // types. This is a container for the configuration details related to broker // logs. LoggingInfo *LoggingInfo `json:"loggingInfo,omitempty"` NumberOfBrokerNodes *int64 `json:"numberOfBrokerNodes,omitempty"` // JMX and Node monitoring for the MSK cluster. OpenMonitoring *OpenMonitoring `json:"openMonitoring,omitempty"` // The state of an Apache Kafka cluster. State *string `json:"state,omitempty"` // Contains information about the state of the Amazon MSK cluster. StateInfo *StateInfo `json:"stateInfo,omitempty"` // Controls storage mode for various supported storage tiers. StorageMode *string `json:"storageMode,omitempty"` Tags map[string]*string `json:"tags,omitempty"` ZookeeperConnectString *string `json:"zookeeperConnectString,omitempty"` ZookeeperConnectStringTLS *string `json:"zookeeperConnectStringTLS,omitempty"` }
+kubebuilder:skipversion
func (*ClusterInfo) DeepCopy ¶
func (in *ClusterInfo) DeepCopy() *ClusterInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterInfo.
func (*ClusterInfo) DeepCopyInto ¶
func (in *ClusterInfo) DeepCopyInto(out *ClusterInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterList ¶
type ClusterList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Cluster `json:"items"` }
ClusterList contains a list of Clusters
func (*ClusterList) DeepCopy ¶
func (in *ClusterList) DeepCopy() *ClusterList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterList.
func (*ClusterList) DeepCopyInto ¶
func (in *ClusterList) DeepCopyInto(out *ClusterList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ClusterList) DeepCopyObject ¶
func (in *ClusterList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ClusterList) GetItems ¶
func (l *ClusterList) GetItems() []resource.Managed
GetItems of this ClusterList.
type ClusterObservation ¶
type ClusterObservation struct { // Information about the brokers. BrokerNodeGroupInfo *BrokerNodeGroupInfo `json:"brokerNodeGroupInfo,omitempty"` // The Amazon Resource Name (ARN) of the cluster. ClusterARN *string `json:"clusterARN,omitempty"` // Cluster policy version. ClusterPolicyVersion *string `json:"clusterPolicyVersion,omitempty"` // The state of the cluster. The possible states are ACTIVE, CREATING, DELETING, // FAILED, HEALING, MAINTENANCE, REBOOTING_BROKER, and UPDATING. State *string `json:"state,omitempty"` }
ClusterObservation defines the observed state of Cluster
func (*ClusterObservation) DeepCopy ¶
func (in *ClusterObservation) DeepCopy() *ClusterObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterObservation.
func (*ClusterObservation) DeepCopyInto ¶
func (in *ClusterObservation) DeepCopyInto(out *ClusterObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterOperationInfo ¶
type ClusterOperationInfo struct { ClientRequestID *string `json:"clientRequestID,omitempty"` ClusterARN *string `json:"clusterARN,omitempty"` CreationTime *metav1.Time `json:"creationTime,omitempty"` EndTime *metav1.Time `json:"endTime,omitempty"` OperationARN *string `json:"operationARN,omitempty"` OperationState *string `json:"operationState,omitempty"` OperationType *string `json:"operationType,omitempty"` }
+kubebuilder:skipversion
func (*ClusterOperationInfo) DeepCopy ¶
func (in *ClusterOperationInfo) DeepCopy() *ClusterOperationInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterOperationInfo.
func (*ClusterOperationInfo) DeepCopyInto ¶
func (in *ClusterOperationInfo) DeepCopyInto(out *ClusterOperationInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterOperationStep ¶
type ClusterOperationStep struct {
StepName *string `json:"stepName,omitempty"`
}
+kubebuilder:skipversion
func (*ClusterOperationStep) DeepCopy ¶
func (in *ClusterOperationStep) DeepCopy() *ClusterOperationStep
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterOperationStep.
func (*ClusterOperationStep) DeepCopyInto ¶
func (in *ClusterOperationStep) DeepCopyInto(out *ClusterOperationStep)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterOperationStepInfo ¶
type ClusterOperationStepInfo struct {
StepStatus *string `json:"stepStatus,omitempty"`
}
+kubebuilder:skipversion
func (*ClusterOperationStepInfo) DeepCopy ¶
func (in *ClusterOperationStepInfo) DeepCopy() *ClusterOperationStepInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterOperationStepInfo.
func (*ClusterOperationStepInfo) DeepCopyInto ¶
func (in *ClusterOperationStepInfo) DeepCopyInto(out *ClusterOperationStepInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterOperationV2 ¶ added in v0.44.0
type ClusterOperationV2 struct { ClusterARN *string `json:"clusterARN,omitempty"` EndTime *metav1.Time `json:"endTime,omitempty"` OperationARN *string `json:"operationARN,omitempty"` OperationState *string `json:"operationState,omitempty"` OperationType *string `json:"operationType,omitempty"` StartTime *metav1.Time `json:"startTime,omitempty"` }
+kubebuilder:skipversion
func (*ClusterOperationV2) DeepCopy ¶ added in v0.44.0
func (in *ClusterOperationV2) DeepCopy() *ClusterOperationV2
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterOperationV2.
func (*ClusterOperationV2) DeepCopyInto ¶ added in v0.44.0
func (in *ClusterOperationV2) DeepCopyInto(out *ClusterOperationV2)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterOperationV2Summary ¶ added in v0.44.0
type ClusterOperationV2Summary struct { ClusterARN *string `json:"clusterARN,omitempty"` EndTime *metav1.Time `json:"endTime,omitempty"` OperationARN *string `json:"operationARN,omitempty"` OperationState *string `json:"operationState,omitempty"` OperationType *string `json:"operationType,omitempty"` StartTime *metav1.Time `json:"startTime,omitempty"` }
+kubebuilder:skipversion
func (*ClusterOperationV2Summary) DeepCopy ¶ added in v0.44.0
func (in *ClusterOperationV2Summary) DeepCopy() *ClusterOperationV2Summary
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterOperationV2Summary.
func (*ClusterOperationV2Summary) DeepCopyInto ¶ added in v0.44.0
func (in *ClusterOperationV2Summary) DeepCopyInto(out *ClusterOperationV2Summary)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterParameters ¶
type ClusterParameters struct { // Region is which region the Cluster will be created. // +kubebuilder:validation:Required Region string `json:"region"` // Includes all client authentication related information. ClientAuthentication *ClientAuthentication `json:"clientAuthentication,omitempty"` // The name of the cluster. // +kubebuilder:validation:Required ClusterName *string `json:"clusterName"` // Includes all encryption-related information. EncryptionInfo *EncryptionInfo `json:"encryptionInfo,omitempty"` // Specifies the level of monitoring for the MSK cluster. The possible values // are DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER, and PER_TOPIC_PER_PARTITION. EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty"` // The version of Apache Kafka. // +kubebuilder:validation:Required KafkaVersion *string `json:"kafkaVersion"` // LoggingInfo details. LoggingInfo *LoggingInfo `json:"loggingInfo,omitempty"` // The number of Apache Kafka broker nodes in the Amazon MSK cluster. // +kubebuilder:validation:Required NumberOfBrokerNodes *int64 `json:"numberOfBrokerNodes"` // The settings for open monitoring. OpenMonitoring *OpenMonitoringInfo `json:"openMonitoring,omitempty"` // This controls storage mode for supported storage tiers. StorageMode *string `json:"storageMode,omitempty"` // Create tags when creating the cluster. Tags map[string]*string `json:"tags,omitempty"` CustomClusterParameters `json:",inline"` }
ClusterParameters defines the desired state of Cluster
func (*ClusterParameters) DeepCopy ¶
func (in *ClusterParameters) DeepCopy() *ClusterParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterParameters.
func (*ClusterParameters) DeepCopyInto ¶
func (in *ClusterParameters) DeepCopyInto(out *ClusterParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterSpec ¶
type ClusterSpec struct { xpv1.ResourceSpec `json:",inline"` ForProvider ClusterParameters `json:"forProvider"` }
ClusterSpec defines the desired state of Cluster
func (*ClusterSpec) DeepCopy ¶
func (in *ClusterSpec) DeepCopy() *ClusterSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSpec.
func (*ClusterSpec) DeepCopyInto ¶
func (in *ClusterSpec) DeepCopyInto(out *ClusterSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterState ¶
type ClusterState string
const ( ClusterState_ACTIVE ClusterState = "ACTIVE" ClusterState_CREATING ClusterState = "CREATING" ClusterState_DELETING ClusterState = "DELETING" ClusterState_FAILED ClusterState = "FAILED" ClusterState_HEALING ClusterState = "HEALING" ClusterState_MAINTENANCE ClusterState = "MAINTENANCE" ClusterState_REBOOTING_BROKER ClusterState = "REBOOTING_BROKER" ClusterState_UPDATING ClusterState = "UPDATING" )
type ClusterStatus ¶
type ClusterStatus struct { xpv1.ResourceStatus `json:",inline"` AtProvider ClusterObservation `json:"atProvider,omitempty"` }
ClusterStatus defines the observed state of Cluster.
func (*ClusterStatus) DeepCopy ¶
func (in *ClusterStatus) DeepCopy() *ClusterStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterStatus.
func (*ClusterStatus) DeepCopyInto ¶
func (in *ClusterStatus) DeepCopyInto(out *ClusterStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterType ¶ added in v0.34.0
type ClusterType string
const ( ClusterType_PROVISIONED ClusterType = "PROVISIONED" ClusterType_SERVERLESS ClusterType = "SERVERLESS" )
type Cluster_SDK ¶ added in v0.34.0
type Cluster_SDK struct { ActiveOperationARN *string `json:"activeOperationARN,omitempty"` ClusterARN *string `json:"clusterARN,omitempty"` ClusterName *string `json:"clusterName,omitempty"` CreationTime *metav1.Time `json:"creationTime,omitempty"` CurrentVersion *string `json:"currentVersion,omitempty"` // The state of an Apache Kafka cluster. State *string `json:"state,omitempty"` // Contains information about the state of the Amazon MSK cluster. StateInfo *StateInfo `json:"stateInfo,omitempty"` Tags map[string]*string `json:"tags,omitempty"` }
+kubebuilder:skipversion
func (*Cluster_SDK) DeepCopy ¶ added in v0.34.0
func (in *Cluster_SDK) DeepCopy() *Cluster_SDK
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Cluster_SDK.
func (*Cluster_SDK) DeepCopyInto ¶ added in v0.34.0
func (in *Cluster_SDK) DeepCopyInto(out *Cluster_SDK)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CompatibleKafkaVersion ¶
type CompatibleKafkaVersion struct { SourceVersion *string `json:"sourceVersion,omitempty"` TargetVersions []*string `json:"targetVersions,omitempty"` }
+kubebuilder:skipversion
func (*CompatibleKafkaVersion) DeepCopy ¶
func (in *CompatibleKafkaVersion) DeepCopy() *CompatibleKafkaVersion
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CompatibleKafkaVersion.
func (*CompatibleKafkaVersion) DeepCopyInto ¶
func (in *CompatibleKafkaVersion) DeepCopyInto(out *CompatibleKafkaVersion)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Configuration ¶
type Configuration struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec ConfigurationSpec `json:"spec"` Status ConfigurationStatus `json:"status,omitempty"` }
Configuration is the Schema for the Configurations API +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:storageversion +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,aws}
func (*Configuration) DeepCopy ¶
func (in *Configuration) DeepCopy() *Configuration
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Configuration.
func (*Configuration) DeepCopyInto ¶
func (in *Configuration) DeepCopyInto(out *Configuration)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Configuration) DeepCopyObject ¶
func (in *Configuration) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Configuration) GetCondition ¶
func (mg *Configuration) GetCondition(ct xpv1.ConditionType) xpv1.Condition
GetCondition of this Configuration.
func (*Configuration) GetDeletionPolicy ¶
func (mg *Configuration) GetDeletionPolicy() xpv1.DeletionPolicy
GetDeletionPolicy of this Configuration.
func (*Configuration) GetManagementPolicies ¶ added in v0.43.0
func (mg *Configuration) GetManagementPolicies() xpv1.ManagementPolicies
GetManagementPolicies of this Configuration.
func (*Configuration) GetProviderConfigReference ¶
func (mg *Configuration) GetProviderConfigReference() *xpv1.Reference
GetProviderConfigReference of this Configuration.
func (*Configuration) GetPublishConnectionDetailsTo ¶
func (mg *Configuration) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
GetPublishConnectionDetailsTo of this Configuration.
func (*Configuration) GetWriteConnectionSecretToReference ¶
func (mg *Configuration) GetWriteConnectionSecretToReference() *xpv1.SecretReference
GetWriteConnectionSecretToReference of this Configuration.
func (*Configuration) SetConditions ¶
func (mg *Configuration) SetConditions(c ...xpv1.Condition)
SetConditions of this Configuration.
func (*Configuration) SetDeletionPolicy ¶
func (mg *Configuration) SetDeletionPolicy(r xpv1.DeletionPolicy)
SetDeletionPolicy of this Configuration.
func (*Configuration) SetManagementPolicies ¶ added in v0.43.0
func (mg *Configuration) SetManagementPolicies(r xpv1.ManagementPolicies)
SetManagementPolicies of this Configuration.
func (*Configuration) SetProviderConfigReference ¶
func (mg *Configuration) SetProviderConfigReference(r *xpv1.Reference)
SetProviderConfigReference of this Configuration.
func (*Configuration) SetPublishConnectionDetailsTo ¶
func (mg *Configuration) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
SetPublishConnectionDetailsTo of this Configuration.
func (*Configuration) SetWriteConnectionSecretToReference ¶
func (mg *Configuration) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
SetWriteConnectionSecretToReference of this Configuration.
type ConfigurationInfo ¶
type ConfigurationInfo struct { ARN *string `json:"arn,omitempty"` Revision *int64 `json:"revision,omitempty"` }
+kubebuilder:skipversion
func (*ConfigurationInfo) DeepCopy ¶
func (in *ConfigurationInfo) DeepCopy() *ConfigurationInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationInfo.
func (*ConfigurationInfo) DeepCopyInto ¶
func (in *ConfigurationInfo) DeepCopyInto(out *ConfigurationInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConfigurationList ¶
type ConfigurationList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Configuration `json:"items"` }
ConfigurationList contains a list of Configurations
func (*ConfigurationList) DeepCopy ¶
func (in *ConfigurationList) DeepCopy() *ConfigurationList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationList.
func (*ConfigurationList) DeepCopyInto ¶
func (in *ConfigurationList) DeepCopyInto(out *ConfigurationList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ConfigurationList) DeepCopyObject ¶
func (in *ConfigurationList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ConfigurationList) GetItems ¶
func (l *ConfigurationList) GetItems() []resource.Managed
GetItems of this ConfigurationList.
type ConfigurationObservation ¶
type ConfigurationObservation struct { // The Amazon Resource Name (ARN) of the configuration. ARN *string `json:"arn,omitempty"` // The time when the configuration was created. CreationTime *metav1.Time `json:"creationTime,omitempty"` // Latest revision of the configuration. LatestRevision *ConfigurationRevision `json:"latestRevision,omitempty"` // The name of the configuration. Configuration names are strings that match // the regex "^[0-9A-Za-z-]+$". Name *string `json:"name,omitempty"` // The state of the configuration. The possible states are ACTIVE, DELETING // and DELETE_FAILED. State *string `json:"state,omitempty"` }
ConfigurationObservation defines the observed state of Configuration
func (*ConfigurationObservation) DeepCopy ¶
func (in *ConfigurationObservation) DeepCopy() *ConfigurationObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationObservation.
func (*ConfigurationObservation) DeepCopyInto ¶
func (in *ConfigurationObservation) DeepCopyInto(out *ConfigurationObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConfigurationParameters ¶
type ConfigurationParameters struct { // Region is which region the Configuration will be created. // +kubebuilder:validation:Required Region string `json:"region"` // The description of the configuration. Description *string `json:"description,omitempty"` // The versions of Apache Kafka with which you can use this MSK configuration. KafkaVersions []*string `json:"kafkaVersions,omitempty"` CustomConfigurationParameters `json:",inline"` }
ConfigurationParameters defines the desired state of Configuration
func (*ConfigurationParameters) DeepCopy ¶
func (in *ConfigurationParameters) DeepCopy() *ConfigurationParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationParameters.
func (*ConfigurationParameters) DeepCopyInto ¶
func (in *ConfigurationParameters) DeepCopyInto(out *ConfigurationParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConfigurationRevision ¶
type ConfigurationRevision struct { CreationTime *metav1.Time `json:"creationTime,omitempty"` Description *string `json:"description,omitempty"` Revision *int64 `json:"revision,omitempty"` }
+kubebuilder:skipversion
func (*ConfigurationRevision) DeepCopy ¶
func (in *ConfigurationRevision) DeepCopy() *ConfigurationRevision
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationRevision.
func (*ConfigurationRevision) DeepCopyInto ¶
func (in *ConfigurationRevision) DeepCopyInto(out *ConfigurationRevision)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConfigurationSpec ¶
type ConfigurationSpec struct { xpv1.ResourceSpec `json:",inline"` ForProvider ConfigurationParameters `json:"forProvider"` }
ConfigurationSpec defines the desired state of Configuration
func (*ConfigurationSpec) DeepCopy ¶
func (in *ConfigurationSpec) DeepCopy() *ConfigurationSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationSpec.
func (*ConfigurationSpec) DeepCopyInto ¶
func (in *ConfigurationSpec) DeepCopyInto(out *ConfigurationSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConfigurationState ¶
type ConfigurationState string
const ( ConfigurationState_ACTIVE ConfigurationState = "ACTIVE" ConfigurationState_DELETING ConfigurationState = "DELETING" ConfigurationState_DELETE_FAILED ConfigurationState = "DELETE_FAILED" )
type ConfigurationStatus ¶
type ConfigurationStatus struct { xpv1.ResourceStatus `json:",inline"` AtProvider ConfigurationObservation `json:"atProvider,omitempty"` }
ConfigurationStatus defines the observed state of Configuration.
func (*ConfigurationStatus) DeepCopy ¶
func (in *ConfigurationStatus) DeepCopy() *ConfigurationStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationStatus.
func (*ConfigurationStatus) DeepCopyInto ¶
func (in *ConfigurationStatus) DeepCopyInto(out *ConfigurationStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Configuration_SDK ¶
type Configuration_SDK struct { ARN *string `json:"arn,omitempty"` CreationTime *metav1.Time `json:"creationTime,omitempty"` Description *string `json:"description,omitempty"` KafkaVersions []*string `json:"kafkaVersions,omitempty"` // Describes a configuration revision. LatestRevision *ConfigurationRevision `json:"latestRevision,omitempty"` Name *string `json:"name,omitempty"` // The state of a configuration. State *string `json:"state,omitempty"` }
+kubebuilder:skipversion
func (*Configuration_SDK) DeepCopy ¶
func (in *Configuration_SDK) DeepCopy() *Configuration_SDK
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Configuration_SDK.
func (*Configuration_SDK) DeepCopyInto ¶
func (in *Configuration_SDK) DeepCopyInto(out *Configuration_SDK)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConnectivityInfo ¶ added in v0.34.0
type ConnectivityInfo struct { // Broker public access control. PublicAccess *PublicAccess `json:"publicAccess,omitempty"` // Broker VPC connectivity access control. VPCConnectivity *VPCConnectivity `json:"vpcConnectivity,omitempty"` }
+kubebuilder:skipversion
func (*ConnectivityInfo) DeepCopy ¶ added in v0.34.0
func (in *ConnectivityInfo) DeepCopy() *ConnectivityInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectivityInfo.
func (*ConnectivityInfo) DeepCopyInto ¶ added in v0.34.0
func (in *ConnectivityInfo) DeepCopyInto(out *ConnectivityInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CustomBrokerNodeGroupInfo ¶
type CustomBrokerNodeGroupInfo struct { // +optional // +crossplane:generate:reference:type=github.com/crossplane-contrib/provider-aws/apis/ec2/v1beta1.Subnet // +crossplane:generate:reference:refFieldName=ClientSubnetRefs // +crossplane:generate:reference:selectorFieldName=ClientSubnetSelector ClientSubnets []*string `json:"clientSubnets,omitempty"` // ClientSubnetRefs is a list of references to Subnets used to set // the ClientSubnets. // +optional ClientSubnetRefs []xpv1.Reference `json:"clientSubnetRefs,omitempty"` // ClientSubnetSelector selects references to Subnets used // to set the ClientSubnets. // +optional ClientSubnetSelector *xpv1.Selector `json:"clientSubnetSelector,omitempty"` InstanceType *string `json:"instanceType,omitempty"` // +optional // +crossplane:generate:reference:type=github.com/crossplane-contrib/provider-aws/apis/ec2/v1beta1.SecurityGroup // +crossplane:generate:reference:refFieldName=SecurityGroupRefs // +crossplane:generate:reference:selectorFieldName=SecurityGroupSelector SecurityGroups []*string `json:"securityGroups,omitempty"` // SecurityGroupRefs is a list of references to SecurityGroups used to set // the SecurityGroups. // +optional SecurityGroupRefs []xpv1.Reference `json:"securityGroupRefs,omitempty"` // SecurityGroupSelector selects references to SecurityGroup used // to set the SecurityGroups. // +optional SecurityGroupSelector *xpv1.Selector `json:"securityGroupSelector,omitempty"` // Contains information about storage volumes attached to MSK broker nodes. StorageInfo *StorageInfo `json:"storageInfo,omitempty"` // ConnectivityInfo Information about the broker access configuration. ConnectivityInfo *CustomConnectivityInfo `json:"connectivityInfo,omitempty"` }
CustomBrokerNodeGroupInfo contains the additional fields for BrokerNodeGroupInfo.
func (*CustomBrokerNodeGroupInfo) DeepCopy ¶
func (in *CustomBrokerNodeGroupInfo) DeepCopy() *CustomBrokerNodeGroupInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomBrokerNodeGroupInfo.
func (*CustomBrokerNodeGroupInfo) DeepCopyInto ¶
func (in *CustomBrokerNodeGroupInfo) DeepCopyInto(out *CustomBrokerNodeGroupInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CustomClusterParameters ¶
type CustomClusterParameters struct { // Information about the brokers CustomBrokerNodeGroupInfo *CustomBrokerNodeGroupInfo `json:"brokerNodeGroupInfo,omitempty"` // ClusterPolicy of the MSK cluster. ClusterPolicy *common.ResourcePolicy `json:"clusterPolicy,omitempty"` // Represents the configuration that you want MSK to use for the cluster. CustomConfigurationInfo *CustomConfigurationInfo `json:"configurationInfo,omitempty"` }
CustomClusterParameters contains the additional fields for ClusterParameters.
func (*CustomClusterParameters) DeepCopy ¶
func (in *CustomClusterParameters) DeepCopy() *CustomClusterParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomClusterParameters.
func (*CustomClusterParameters) DeepCopyInto ¶
func (in *CustomClusterParameters) DeepCopyInto(out *CustomClusterParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CustomConfigurationInfo ¶
type CustomConfigurationInfo struct { // ARN of the configuration to use. // +optional // +crossplane:generate:reference:type=Configuration // +crossplane:generate:reference:extractor=ConfugurationARN() ARN *string `json:"arn,omitempty"` // ARNRef is a reference to a Kafka Configuration used to set ARN. // +optional ARNRef *xpv1.Reference `json:"arnRef,omitempty"` // ARNSelector selects a reference to a Kafka Configuration used to set ARN. // +optional ARNSelector *xpv1.Selector `json:"arnSelector,omitempty"` Revision *int64 `json:"revision,omitempty"` }
CustomConfigurationInfo contains the additional fields for ConfigurationInfo.
func (*CustomConfigurationInfo) DeepCopy ¶
func (in *CustomConfigurationInfo) DeepCopy() *CustomConfigurationInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomConfigurationInfo.
func (*CustomConfigurationInfo) DeepCopyInto ¶
func (in *CustomConfigurationInfo) DeepCopyInto(out *CustomConfigurationInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CustomConfigurationParameters ¶
type CustomConfigurationParameters struct { // kafka server configurations Properties []string `json:"properties"` }
CustomConfigurationParameters contains the additional fields for ConfigurationParameters.
func (*CustomConfigurationParameters) DeepCopy ¶
func (in *CustomConfigurationParameters) DeepCopy() *CustomConfigurationParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomConfigurationParameters.
func (*CustomConfigurationParameters) DeepCopyInto ¶
func (in *CustomConfigurationParameters) DeepCopyInto(out *CustomConfigurationParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CustomConnectivityInfo ¶ added in v0.44.0
type CustomConnectivityInfo struct { // Broker public access control. PublicAccess *CustomPublicAccess `json:"publicAccess,omitempty"` // Broker VPC connectivity access control. VPCConnectivity *VPCConnectivity `json:"vpcConnectivity,omitempty"` }
CustomConnectivityInfo replaces ConnectivityInfo because it contains a json tag "type_" that is does not follow the convention.
+kubebuilder:skipversion
func (*CustomConnectivityInfo) DeepCopy ¶ added in v0.44.0
func (in *CustomConnectivityInfo) DeepCopy() *CustomConnectivityInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomConnectivityInfo.
func (*CustomConnectivityInfo) DeepCopyInto ¶ added in v0.44.0
func (in *CustomConnectivityInfo) DeepCopyInto(out *CustomConnectivityInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CustomPublicAccess ¶ added in v0.44.0
type CustomPublicAccess struct { // Type of the public access control. Type *string `json:"type,omitempty"` }
CustomPublicAccess replaces PublicAccess because it contains a json tag "type_" that is does not follow the convention.
+kubebuilder:skipversion
func (*CustomPublicAccess) DeepCopy ¶ added in v0.44.0
func (in *CustomPublicAccess) DeepCopy() *CustomPublicAccess
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPublicAccess.
func (*CustomPublicAccess) DeepCopyInto ¶ added in v0.44.0
func (in *CustomPublicAccess) DeepCopyInto(out *CustomPublicAccess)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EBSStorageInfo ¶
type EBSStorageInfo struct { // Contains information about provisioned throughput for EBS storage volumes // attached to kafka broker nodes. ProvisionedThroughput *ProvisionedThroughput `json:"provisionedThroughput,omitempty"` VolumeSize *int64 `json:"volumeSize,omitempty"` }
+kubebuilder:skipversion
func (*EBSStorageInfo) DeepCopy ¶
func (in *EBSStorageInfo) DeepCopy() *EBSStorageInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EBSStorageInfo.
func (*EBSStorageInfo) DeepCopyInto ¶
func (in *EBSStorageInfo) DeepCopyInto(out *EBSStorageInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EncryptionAtRest ¶
type EncryptionAtRest struct {
DataVolumeKMSKeyID *string `json:"dataVolumeKMSKeyID,omitempty"`
}
+kubebuilder:skipversion
func (*EncryptionAtRest) DeepCopy ¶
func (in *EncryptionAtRest) DeepCopy() *EncryptionAtRest
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EncryptionAtRest.
func (*EncryptionAtRest) DeepCopyInto ¶
func (in *EncryptionAtRest) DeepCopyInto(out *EncryptionAtRest)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EncryptionInTransit ¶
type EncryptionInTransit struct { // Client-broker encryption in transit setting. ClientBroker *string `json:"clientBroker,omitempty"` InCluster *bool `json:"inCluster,omitempty"` }
+kubebuilder:skipversion
func (*EncryptionInTransit) DeepCopy ¶
func (in *EncryptionInTransit) DeepCopy() *EncryptionInTransit
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EncryptionInTransit.
func (*EncryptionInTransit) DeepCopyInto ¶
func (in *EncryptionInTransit) DeepCopyInto(out *EncryptionInTransit)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EncryptionInfo ¶
type EncryptionInfo struct { // The data-volume encryption details. EncryptionAtRest *EncryptionAtRest `json:"encryptionAtRest,omitempty"` // The settings for encrypting data in transit. EncryptionInTransit *EncryptionInTransit `json:"encryptionInTransit,omitempty"` }
+kubebuilder:skipversion
func (*EncryptionInfo) DeepCopy ¶
func (in *EncryptionInfo) DeepCopy() *EncryptionInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EncryptionInfo.
func (*EncryptionInfo) DeepCopyInto ¶
func (in *EncryptionInfo) DeepCopyInto(out *EncryptionInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EnhancedMonitoring ¶
type EnhancedMonitoring string
const ( EnhancedMonitoring_DEFAULT EnhancedMonitoring = "DEFAULT" EnhancedMonitoring_PER_BROKER EnhancedMonitoring = "PER_BROKER" EnhancedMonitoring_PER_TOPIC_PER_BROKER EnhancedMonitoring = "PER_TOPIC_PER_BROKER" EnhancedMonitoring_PER_TOPIC_PER_PARTITION EnhancedMonitoring = "PER_TOPIC_PER_PARTITION" )
type ErrorInfo ¶
type ErrorInfo struct { ErrorCode *string `json:"errorCode,omitempty"` ErrorString *string `json:"errorString,omitempty"` }
+kubebuilder:skipversion
func (*ErrorInfo) DeepCopy ¶
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 UserIdentity ¶ added in v0.44.0
type UserIdentity struct {
PrincipalID *string `json:"principalID,omitempty"`
}
+kubebuilder:skipversion
func (*UserIdentity) DeepCopy ¶ added in v0.44.0
func (in *UserIdentity) DeepCopy() *UserIdentity
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UserIdentity.
func (*UserIdentity) DeepCopyInto ¶ added in v0.44.0
func (in *UserIdentity) DeepCopyInto(out *UserIdentity)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type UserIdentityType ¶ added in v0.44.0
type UserIdentityType string
const ( UserIdentityType_AWSACCOUNT UserIdentityType = "AWSACCOUNT" UserIdentityType_AWSSERVICE UserIdentityType = "AWSSERVICE" )
type VPCConfig ¶ added in v0.34.0
type VPCConfig struct { SecurityGroupIDs []*string `json:"securityGroupIDs,omitempty"` SubnetIDs []*string `json:"subnetIDs,omitempty"` }
+kubebuilder:skipversion
func (*VPCConfig) DeepCopy ¶ added in v0.34.0
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 VPCConnection ¶ added in v0.44.0
type VPCConnection struct { Authentication *string `json:"authentication,omitempty"` CreationTime *metav1.Time `json:"creationTime,omitempty"` TargetClusterARN *string `json:"targetClusterARN,omitempty"` VPCConnectionARN *string `json:"vpcConnectionARN,omitempty"` VPCID *string `json:"vpcID,omitempty"` }
+kubebuilder:skipversion
func (*VPCConnection) DeepCopy ¶ added in v0.44.0
func (in *VPCConnection) DeepCopy() *VPCConnection
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VPCConnection.
func (*VPCConnection) DeepCopyInto ¶ added in v0.44.0
func (in *VPCConnection) DeepCopyInto(out *VPCConnection)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type VPCConnectionInfo ¶ added in v0.44.0
type VPCConnectionInfo struct { CreationTime *metav1.Time `json:"creationTime,omitempty"` Owner *string `json:"owner,omitempty"` VPCConnectionARN *string `json:"vpcConnectionARN,omitempty"` }
+kubebuilder:skipversion
func (*VPCConnectionInfo) DeepCopy ¶ added in v0.44.0
func (in *VPCConnectionInfo) DeepCopy() *VPCConnectionInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VPCConnectionInfo.
func (*VPCConnectionInfo) DeepCopyInto ¶ added in v0.44.0
func (in *VPCConnectionInfo) DeepCopyInto(out *VPCConnectionInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type VPCConnectionInfoServerless ¶ added in v0.44.0
type VPCConnectionInfoServerless struct { CreationTime *metav1.Time `json:"creationTime,omitempty"` Owner *string `json:"owner,omitempty"` VPCConnectionARN *string `json:"vpcConnectionARN,omitempty"` }
+kubebuilder:skipversion
func (*VPCConnectionInfoServerless) DeepCopy ¶ added in v0.44.0
func (in *VPCConnectionInfoServerless) DeepCopy() *VPCConnectionInfoServerless
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VPCConnectionInfoServerless.
func (*VPCConnectionInfoServerless) DeepCopyInto ¶ added in v0.44.0
func (in *VPCConnectionInfoServerless) DeepCopyInto(out *VPCConnectionInfoServerless)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type VPCConnectionState ¶ added in v0.44.0
type VPCConnectionState string
const ( VPCConnectionState_CREATING VPCConnectionState = "CREATING" VPCConnectionState_AVAILABLE VPCConnectionState = "AVAILABLE" VPCConnectionState_INACTIVE VPCConnectionState = "INACTIVE" VPCConnectionState_DEACTIVATING VPCConnectionState = "DEACTIVATING" VPCConnectionState_DELETING VPCConnectionState = "DELETING" VPCConnectionState_FAILED VPCConnectionState = "FAILED" VPCConnectionState_REJECTED VPCConnectionState = "REJECTED" VPCConnectionState_REJECTING VPCConnectionState = "REJECTING" )
type VPCConnectivity ¶ added in v0.44.0
type VPCConnectivity struct {
ClientAuthentication *VPCConnectivityClientAuthentication `json:"clientAuthentication,omitempty"`
}
+kubebuilder:skipversion
func (*VPCConnectivity) DeepCopy ¶ added in v0.44.0
func (in *VPCConnectivity) DeepCopy() *VPCConnectivity
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VPCConnectivity.
func (*VPCConnectivity) DeepCopyInto ¶ added in v0.44.0
func (in *VPCConnectivity) DeepCopyInto(out *VPCConnectivity)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type VPCConnectivityClientAuthentication ¶ added in v0.44.0
type VPCConnectivityClientAuthentication struct { SASL *VPCConnectivitySASL `json:"sasl,omitempty"` TLS *VPCConnectivityTLS `json:"tls,omitempty"` }
+kubebuilder:skipversion
func (*VPCConnectivityClientAuthentication) DeepCopy ¶ added in v0.44.0
func (in *VPCConnectivityClientAuthentication) DeepCopy() *VPCConnectivityClientAuthentication
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VPCConnectivityClientAuthentication.
func (*VPCConnectivityClientAuthentication) DeepCopyInto ¶ added in v0.44.0
func (in *VPCConnectivityClientAuthentication) DeepCopyInto(out *VPCConnectivityClientAuthentication)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type VPCConnectivityIAM ¶ added in v0.44.0
type VPCConnectivityIAM struct {
Enabled *bool `json:"enabled,omitempty"`
}
+kubebuilder:skipversion
func (*VPCConnectivityIAM) DeepCopy ¶ added in v0.44.0
func (in *VPCConnectivityIAM) DeepCopy() *VPCConnectivityIAM
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VPCConnectivityIAM.
func (*VPCConnectivityIAM) DeepCopyInto ¶ added in v0.44.0
func (in *VPCConnectivityIAM) DeepCopyInto(out *VPCConnectivityIAM)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type VPCConnectivitySASL ¶ added in v0.44.0
type VPCConnectivitySASL struct { IAM *VPCConnectivityIAM `json:"iam,omitempty"` SCRAM *VPCConnectivitySCRAM `json:"scram,omitempty"` }
+kubebuilder:skipversion
func (*VPCConnectivitySASL) DeepCopy ¶ added in v0.44.0
func (in *VPCConnectivitySASL) DeepCopy() *VPCConnectivitySASL
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VPCConnectivitySASL.
func (*VPCConnectivitySASL) DeepCopyInto ¶ added in v0.44.0
func (in *VPCConnectivitySASL) DeepCopyInto(out *VPCConnectivitySASL)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type VPCConnectivitySCRAM ¶ added in v0.44.0
type VPCConnectivitySCRAM struct {
Enabled *bool `json:"enabled,omitempty"`
}
+kubebuilder:skipversion
func (*VPCConnectivitySCRAM) DeepCopy ¶ added in v0.44.0
func (in *VPCConnectivitySCRAM) DeepCopy() *VPCConnectivitySCRAM
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VPCConnectivitySCRAM.
func (*VPCConnectivitySCRAM) DeepCopyInto ¶ added in v0.44.0
func (in *VPCConnectivitySCRAM) DeepCopyInto(out *VPCConnectivitySCRAM)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type VPCConnectivityTLS ¶ added in v0.44.0
type VPCConnectivityTLS struct {
Enabled *bool `json:"enabled,omitempty"`
}
+kubebuilder:skipversion
func (*VPCConnectivityTLS) DeepCopy ¶ added in v0.44.0
func (in *VPCConnectivityTLS) DeepCopy() *VPCConnectivityTLS
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VPCConnectivityTLS.
func (*VPCConnectivityTLS) DeepCopyInto ¶ added in v0.44.0
func (in *VPCConnectivityTLS) DeepCopyInto(out *VPCConnectivityTLS)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ZookeeperNodeInfo ¶
type ZookeeperNodeInfo struct { AttachedENIID *string `json:"attachedENIID,omitempty"` ClientVPCIPAddress *string `json:"clientVPCIPAddress,omitempty"` Endpoints []*string `json:"endpoints,omitempty"` ZookeeperVersion *string `json:"zookeeperVersion,omitempty"` }
+kubebuilder:skipversion
func (*ZookeeperNodeInfo) DeepCopy ¶
func (in *ZookeeperNodeInfo) DeepCopy() *ZookeeperNodeInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ZookeeperNodeInfo.
func (*ZookeeperNodeInfo) DeepCopyInto ¶
func (in *ZookeeperNodeInfo) DeepCopyInto(out *ZookeeperNodeInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.