Documentation ¶
Overview ¶
+groupName=msk.aws.kubeform.com
Index ¶
- Variables
- func GetDecoder() map[string]jsoniter.ValDecoder
- func GetEncoder() map[string]jsoniter.ValEncoder
- func Kind(kind string) schema.GroupKind
- func Resource(resource string) schema.GroupResource
- type Cluster
- func (in *Cluster) DeepCopy() *Cluster
- func (in *Cluster) DeepCopyInto(out *Cluster)
- func (in *Cluster) DeepCopyObject() runtime.Object
- func (r *Cluster) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *Cluster) ValidateCreate() error
- func (r *Cluster) ValidateDelete() error
- func (r *Cluster) ValidateUpdate(old runtime.Object) error
- type ClusterList
- type ClusterSpec
- type ClusterSpecBrokerNodeGroupInfo
- type ClusterSpecBrokerNodeGroupInfoCodec
- type ClusterSpecClientAuthentication
- type ClusterSpecClientAuthenticationCodec
- type ClusterSpecClientAuthenticationSasl
- type ClusterSpecClientAuthenticationSaslCodec
- type ClusterSpecClientAuthenticationTls
- type ClusterSpecClientAuthenticationTlsCodec
- type ClusterSpecConfigurationInfo
- type ClusterSpecConfigurationInfoCodec
- type ClusterSpecEncryptionInfo
- type ClusterSpecEncryptionInfoCodec
- type ClusterSpecEncryptionInfoEncryptionInTransit
- type ClusterSpecEncryptionInfoEncryptionInTransitCodec
- func (ClusterSpecEncryptionInfoEncryptionInTransitCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (ClusterSpecEncryptionInfoEncryptionInTransitCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (ClusterSpecEncryptionInfoEncryptionInTransitCodec) IsEmpty(ptr unsafe.Pointer) bool
- type ClusterSpecLoggingInfo
- type ClusterSpecLoggingInfoBrokerLogs
- type ClusterSpecLoggingInfoBrokerLogsCloudwatchLogs
- type ClusterSpecLoggingInfoBrokerLogsCloudwatchLogsCodec
- func (ClusterSpecLoggingInfoBrokerLogsCloudwatchLogsCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (ClusterSpecLoggingInfoBrokerLogsCloudwatchLogsCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (ClusterSpecLoggingInfoBrokerLogsCloudwatchLogsCodec) IsEmpty(ptr unsafe.Pointer) bool
- type ClusterSpecLoggingInfoBrokerLogsCodec
- type ClusterSpecLoggingInfoBrokerLogsFirehose
- type ClusterSpecLoggingInfoBrokerLogsFirehoseCodec
- type ClusterSpecLoggingInfoBrokerLogsS3
- type ClusterSpecLoggingInfoBrokerLogsS3Codec
- type ClusterSpecLoggingInfoCodec
- type ClusterSpecOpenMonitoring
- type ClusterSpecOpenMonitoringCodec
- type ClusterSpecOpenMonitoringPrometheus
- type ClusterSpecOpenMonitoringPrometheusCodec
- type ClusterSpecOpenMonitoringPrometheusJmxExporter
- type ClusterSpecOpenMonitoringPrometheusJmxExporterCodec
- func (ClusterSpecOpenMonitoringPrometheusJmxExporterCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (ClusterSpecOpenMonitoringPrometheusJmxExporterCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (ClusterSpecOpenMonitoringPrometheusJmxExporterCodec) IsEmpty(ptr unsafe.Pointer) bool
- type ClusterSpecOpenMonitoringPrometheusNodeExporter
- type ClusterSpecOpenMonitoringPrometheusNodeExporterCodec
- func (ClusterSpecOpenMonitoringPrometheusNodeExporterCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (ClusterSpecOpenMonitoringPrometheusNodeExporterCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (ClusterSpecOpenMonitoringPrometheusNodeExporterCodec) IsEmpty(ptr unsafe.Pointer) bool
- type ClusterSpecResource
- type ClusterStatus
- type Configuration
- func (in *Configuration) DeepCopy() *Configuration
- func (in *Configuration) DeepCopyInto(out *Configuration)
- func (in *Configuration) DeepCopyObject() runtime.Object
- func (r *Configuration) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *Configuration) ValidateCreate() error
- func (r *Configuration) ValidateDelete() error
- func (r *Configuration) ValidateUpdate(old runtime.Object) error
- type ConfigurationList
- type ConfigurationSpec
- type ConfigurationSpecResource
- type ConfigurationStatus
- type ScramSecretAssociation
- func (in *ScramSecretAssociation) DeepCopy() *ScramSecretAssociation
- func (in *ScramSecretAssociation) DeepCopyInto(out *ScramSecretAssociation)
- func (in *ScramSecretAssociation) DeepCopyObject() runtime.Object
- func (r *ScramSecretAssociation) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *ScramSecretAssociation) ValidateCreate() error
- func (r *ScramSecretAssociation) ValidateDelete() error
- func (r *ScramSecretAssociation) ValidateUpdate(old runtime.Object) error
- type ScramSecretAssociationList
- type ScramSecretAssociationSpec
- type ScramSecretAssociationSpecResource
- type ScramSecretAssociationStatus
Constants ¶
This section is empty.
Variables ¶
var ( // TODO: move SchemeBuilder with zz_generated.deepcopy.go to k8s.io/api. // localSchemeBuilder and AddToScheme will stay in k8s.io/kubernetes. SchemeBuilder runtime.SchemeBuilder AddToScheme = localSchemeBuilder.AddToScheme )
var SchemeGroupVersion = schema.GroupVersion{Group: msk.GroupName, Version: "v1alpha1"}
Functions ¶
func GetDecoder ¶
func GetDecoder() map[string]jsoniter.ValDecoder
func GetEncoder ¶
func GetEncoder() map[string]jsoniter.ValEncoder
func Resource ¶
func Resource(resource string) schema.GroupResource
Resource takes an unqualified resource and returns a Group qualified GroupResource
Types ¶
type Cluster ¶
type Cluster struct { metav1.TypeMeta `json:",inline,omitempty"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec ClusterSpec `json:"spec,omitempty"` Status ClusterStatus `json:"status,omitempty"` }
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) SetupWebhookWithManager ¶
func (*Cluster) ValidateCreate ¶
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*Cluster) ValidateDelete ¶
ValidateDelete implements webhook.Validator so a webhook will be registered for the type
type ClusterList ¶
type ClusterList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` // Items is a list of Cluster CRD objects Items []Cluster `json:"items,omitempty"` }
ClusterList is 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.
type ClusterSpec ¶
type ClusterSpec struct { State *ClusterSpecResource `json:"state,omitempty" tf:"-"` Resource ClusterSpecResource `json:"resource" tf:"resource"` UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"` TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"` ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"` BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"` }
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 ClusterSpecBrokerNodeGroupInfo ¶
type ClusterSpecBrokerNodeGroupInfo struct { // +optional AzDistribution *string `json:"azDistribution,omitempty" tf:"az_distribution"` ClientSubnets []string `json:"clientSubnets" tf:"client_subnets"` EbsVolumeSize *int64 `json:"ebsVolumeSize" tf:"ebs_volume_size"` InstanceType *string `json:"instanceType" tf:"instance_type"` SecurityGroups []string `json:"securityGroups" tf:"security_groups"` }
func (*ClusterSpecBrokerNodeGroupInfo) DeepCopy ¶
func (in *ClusterSpecBrokerNodeGroupInfo) DeepCopy() *ClusterSpecBrokerNodeGroupInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSpecBrokerNodeGroupInfo.
func (*ClusterSpecBrokerNodeGroupInfo) DeepCopyInto ¶
func (in *ClusterSpecBrokerNodeGroupInfo) DeepCopyInto(out *ClusterSpecBrokerNodeGroupInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterSpecBrokerNodeGroupInfoCodec ¶
type ClusterSpecBrokerNodeGroupInfoCodec struct { }
+k8s:deepcopy-gen=false
func (ClusterSpecBrokerNodeGroupInfoCodec) Decode ¶
func (ClusterSpecBrokerNodeGroupInfoCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
type ClusterSpecClientAuthentication ¶
type ClusterSpecClientAuthentication struct { // +optional Sasl *ClusterSpecClientAuthenticationSasl `json:"sasl,omitempty" tf:"sasl"` // +optional Tls *ClusterSpecClientAuthenticationTls `json:"tls,omitempty" tf:"tls"` }
func (*ClusterSpecClientAuthentication) DeepCopy ¶
func (in *ClusterSpecClientAuthentication) DeepCopy() *ClusterSpecClientAuthentication
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSpecClientAuthentication.
func (*ClusterSpecClientAuthentication) DeepCopyInto ¶
func (in *ClusterSpecClientAuthentication) DeepCopyInto(out *ClusterSpecClientAuthentication)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterSpecClientAuthenticationCodec ¶
type ClusterSpecClientAuthenticationCodec struct { }
+k8s:deepcopy-gen=false
func (ClusterSpecClientAuthenticationCodec) Decode ¶
func (ClusterSpecClientAuthenticationCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
type ClusterSpecClientAuthenticationSasl ¶
type ClusterSpecClientAuthenticationSasl struct { // +optional Iam *bool `json:"iam,omitempty" tf:"iam"` // +optional Scram *bool `json:"scram,omitempty" tf:"scram"` }
func (*ClusterSpecClientAuthenticationSasl) DeepCopy ¶
func (in *ClusterSpecClientAuthenticationSasl) DeepCopy() *ClusterSpecClientAuthenticationSasl
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSpecClientAuthenticationSasl.
func (*ClusterSpecClientAuthenticationSasl) DeepCopyInto ¶
func (in *ClusterSpecClientAuthenticationSasl) DeepCopyInto(out *ClusterSpecClientAuthenticationSasl)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterSpecClientAuthenticationSaslCodec ¶
type ClusterSpecClientAuthenticationSaslCodec struct { }
+k8s:deepcopy-gen=false
func (ClusterSpecClientAuthenticationSaslCodec) Decode ¶
func (ClusterSpecClientAuthenticationSaslCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
type ClusterSpecClientAuthenticationTls ¶
type ClusterSpecClientAuthenticationTls struct { // +optional CertificateAuthorityArns []string `json:"certificateAuthorityArns,omitempty" tf:"certificate_authority_arns"` }
func (*ClusterSpecClientAuthenticationTls) DeepCopy ¶
func (in *ClusterSpecClientAuthenticationTls) DeepCopy() *ClusterSpecClientAuthenticationTls
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSpecClientAuthenticationTls.
func (*ClusterSpecClientAuthenticationTls) DeepCopyInto ¶
func (in *ClusterSpecClientAuthenticationTls) DeepCopyInto(out *ClusterSpecClientAuthenticationTls)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterSpecClientAuthenticationTlsCodec ¶
type ClusterSpecClientAuthenticationTlsCodec struct { }
+k8s:deepcopy-gen=false
func (ClusterSpecClientAuthenticationTlsCodec) Decode ¶
func (ClusterSpecClientAuthenticationTlsCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
type ClusterSpecConfigurationInfo ¶
type ClusterSpecConfigurationInfo struct { Arn *string `json:"arn" tf:"arn"` Revision *int64 `json:"revision" tf:"revision"` }
func (*ClusterSpecConfigurationInfo) DeepCopy ¶
func (in *ClusterSpecConfigurationInfo) DeepCopy() *ClusterSpecConfigurationInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSpecConfigurationInfo.
func (*ClusterSpecConfigurationInfo) DeepCopyInto ¶
func (in *ClusterSpecConfigurationInfo) DeepCopyInto(out *ClusterSpecConfigurationInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterSpecConfigurationInfoCodec ¶
type ClusterSpecConfigurationInfoCodec struct { }
+k8s:deepcopy-gen=false
func (ClusterSpecConfigurationInfoCodec) Decode ¶
func (ClusterSpecConfigurationInfoCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
type ClusterSpecEncryptionInfo ¶
type ClusterSpecEncryptionInfo struct { // +optional EncryptionAtRestKmsKeyArn *string `json:"encryptionAtRestKmsKeyArn,omitempty" tf:"encryption_at_rest_kms_key_arn"` // +optional EncryptionInTransit *ClusterSpecEncryptionInfoEncryptionInTransit `json:"encryptionInTransit,omitempty" tf:"encryption_in_transit"` }
func (*ClusterSpecEncryptionInfo) DeepCopy ¶
func (in *ClusterSpecEncryptionInfo) DeepCopy() *ClusterSpecEncryptionInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSpecEncryptionInfo.
func (*ClusterSpecEncryptionInfo) DeepCopyInto ¶
func (in *ClusterSpecEncryptionInfo) DeepCopyInto(out *ClusterSpecEncryptionInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterSpecEncryptionInfoCodec ¶
type ClusterSpecEncryptionInfoCodec struct { }
+k8s:deepcopy-gen=false
func (ClusterSpecEncryptionInfoCodec) Decode ¶
func (ClusterSpecEncryptionInfoCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
type ClusterSpecEncryptionInfoEncryptionInTransit ¶
type ClusterSpecEncryptionInfoEncryptionInTransit struct { // +optional ClientBroker *string `json:"clientBroker,omitempty" tf:"client_broker"` // +optional InCluster *bool `json:"inCluster,omitempty" tf:"in_cluster"` }
func (*ClusterSpecEncryptionInfoEncryptionInTransit) DeepCopy ¶
func (in *ClusterSpecEncryptionInfoEncryptionInTransit) DeepCopy() *ClusterSpecEncryptionInfoEncryptionInTransit
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSpecEncryptionInfoEncryptionInTransit.
func (*ClusterSpecEncryptionInfoEncryptionInTransit) DeepCopyInto ¶
func (in *ClusterSpecEncryptionInfoEncryptionInTransit) DeepCopyInto(out *ClusterSpecEncryptionInfoEncryptionInTransit)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterSpecEncryptionInfoEncryptionInTransitCodec ¶
type ClusterSpecEncryptionInfoEncryptionInTransitCodec struct { }
+k8s:deepcopy-gen=false
func (ClusterSpecEncryptionInfoEncryptionInTransitCodec) Decode ¶
func (ClusterSpecEncryptionInfoEncryptionInTransitCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
type ClusterSpecLoggingInfo ¶
type ClusterSpecLoggingInfo struct {
BrokerLogs *ClusterSpecLoggingInfoBrokerLogs `json:"brokerLogs" tf:"broker_logs"`
}
func (*ClusterSpecLoggingInfo) DeepCopy ¶
func (in *ClusterSpecLoggingInfo) DeepCopy() *ClusterSpecLoggingInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSpecLoggingInfo.
func (*ClusterSpecLoggingInfo) DeepCopyInto ¶
func (in *ClusterSpecLoggingInfo) DeepCopyInto(out *ClusterSpecLoggingInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterSpecLoggingInfoBrokerLogs ¶
type ClusterSpecLoggingInfoBrokerLogs struct { // +optional CloudwatchLogs *ClusterSpecLoggingInfoBrokerLogsCloudwatchLogs `json:"cloudwatchLogs,omitempty" tf:"cloudwatch_logs"` // +optional Firehose *ClusterSpecLoggingInfoBrokerLogsFirehose `json:"firehose,omitempty" tf:"firehose"` // +optional S3 *ClusterSpecLoggingInfoBrokerLogsS3 `json:"s3,omitempty" tf:"s3"` }
func (*ClusterSpecLoggingInfoBrokerLogs) DeepCopy ¶
func (in *ClusterSpecLoggingInfoBrokerLogs) DeepCopy() *ClusterSpecLoggingInfoBrokerLogs
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSpecLoggingInfoBrokerLogs.
func (*ClusterSpecLoggingInfoBrokerLogs) DeepCopyInto ¶
func (in *ClusterSpecLoggingInfoBrokerLogs) DeepCopyInto(out *ClusterSpecLoggingInfoBrokerLogs)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterSpecLoggingInfoBrokerLogsCloudwatchLogs ¶
type ClusterSpecLoggingInfoBrokerLogsCloudwatchLogs struct { Enabled *bool `json:"enabled" tf:"enabled"` // +optional LogGroup *string `json:"logGroup,omitempty" tf:"log_group"` }
func (*ClusterSpecLoggingInfoBrokerLogsCloudwatchLogs) DeepCopy ¶
func (in *ClusterSpecLoggingInfoBrokerLogsCloudwatchLogs) DeepCopy() *ClusterSpecLoggingInfoBrokerLogsCloudwatchLogs
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSpecLoggingInfoBrokerLogsCloudwatchLogs.
func (*ClusterSpecLoggingInfoBrokerLogsCloudwatchLogs) DeepCopyInto ¶
func (in *ClusterSpecLoggingInfoBrokerLogsCloudwatchLogs) DeepCopyInto(out *ClusterSpecLoggingInfoBrokerLogsCloudwatchLogs)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterSpecLoggingInfoBrokerLogsCloudwatchLogsCodec ¶
type ClusterSpecLoggingInfoBrokerLogsCloudwatchLogsCodec struct { }
+k8s:deepcopy-gen=false
func (ClusterSpecLoggingInfoBrokerLogsCloudwatchLogsCodec) Decode ¶
func (ClusterSpecLoggingInfoBrokerLogsCloudwatchLogsCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
type ClusterSpecLoggingInfoBrokerLogsCodec ¶
type ClusterSpecLoggingInfoBrokerLogsCodec struct { }
+k8s:deepcopy-gen=false
func (ClusterSpecLoggingInfoBrokerLogsCodec) Decode ¶
func (ClusterSpecLoggingInfoBrokerLogsCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
type ClusterSpecLoggingInfoBrokerLogsFirehose ¶
type ClusterSpecLoggingInfoBrokerLogsFirehose struct { // +optional DeliveryStream *string `json:"deliveryStream,omitempty" tf:"delivery_stream"` Enabled *bool `json:"enabled" tf:"enabled"` }
func (*ClusterSpecLoggingInfoBrokerLogsFirehose) DeepCopy ¶
func (in *ClusterSpecLoggingInfoBrokerLogsFirehose) DeepCopy() *ClusterSpecLoggingInfoBrokerLogsFirehose
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSpecLoggingInfoBrokerLogsFirehose.
func (*ClusterSpecLoggingInfoBrokerLogsFirehose) DeepCopyInto ¶
func (in *ClusterSpecLoggingInfoBrokerLogsFirehose) DeepCopyInto(out *ClusterSpecLoggingInfoBrokerLogsFirehose)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterSpecLoggingInfoBrokerLogsFirehoseCodec ¶
type ClusterSpecLoggingInfoBrokerLogsFirehoseCodec struct { }
+k8s:deepcopy-gen=false
func (ClusterSpecLoggingInfoBrokerLogsFirehoseCodec) Decode ¶
func (ClusterSpecLoggingInfoBrokerLogsFirehoseCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
type ClusterSpecLoggingInfoBrokerLogsS3 ¶
type ClusterSpecLoggingInfoBrokerLogsS3 struct { // +optional Bucket *string `json:"bucket,omitempty" tf:"bucket"` Enabled *bool `json:"enabled" tf:"enabled"` // +optional Prefix *string `json:"prefix,omitempty" tf:"prefix"` }
func (*ClusterSpecLoggingInfoBrokerLogsS3) DeepCopy ¶
func (in *ClusterSpecLoggingInfoBrokerLogsS3) DeepCopy() *ClusterSpecLoggingInfoBrokerLogsS3
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSpecLoggingInfoBrokerLogsS3.
func (*ClusterSpecLoggingInfoBrokerLogsS3) DeepCopyInto ¶
func (in *ClusterSpecLoggingInfoBrokerLogsS3) DeepCopyInto(out *ClusterSpecLoggingInfoBrokerLogsS3)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterSpecLoggingInfoBrokerLogsS3Codec ¶
type ClusterSpecLoggingInfoBrokerLogsS3Codec struct { }
+k8s:deepcopy-gen=false
func (ClusterSpecLoggingInfoBrokerLogsS3Codec) Decode ¶
func (ClusterSpecLoggingInfoBrokerLogsS3Codec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
type ClusterSpecLoggingInfoCodec ¶
type ClusterSpecLoggingInfoCodec struct { }
+k8s:deepcopy-gen=false
func (ClusterSpecLoggingInfoCodec) Decode ¶
func (ClusterSpecLoggingInfoCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
type ClusterSpecOpenMonitoring ¶
type ClusterSpecOpenMonitoring struct {
Prometheus *ClusterSpecOpenMonitoringPrometheus `json:"prometheus" tf:"prometheus"`
}
func (*ClusterSpecOpenMonitoring) DeepCopy ¶
func (in *ClusterSpecOpenMonitoring) DeepCopy() *ClusterSpecOpenMonitoring
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSpecOpenMonitoring.
func (*ClusterSpecOpenMonitoring) DeepCopyInto ¶
func (in *ClusterSpecOpenMonitoring) DeepCopyInto(out *ClusterSpecOpenMonitoring)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterSpecOpenMonitoringCodec ¶
type ClusterSpecOpenMonitoringCodec struct { }
+k8s:deepcopy-gen=false
func (ClusterSpecOpenMonitoringCodec) Decode ¶
func (ClusterSpecOpenMonitoringCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
type ClusterSpecOpenMonitoringPrometheus ¶
type ClusterSpecOpenMonitoringPrometheus struct { // +optional JmxExporter *ClusterSpecOpenMonitoringPrometheusJmxExporter `json:"jmxExporter,omitempty" tf:"jmx_exporter"` // +optional NodeExporter *ClusterSpecOpenMonitoringPrometheusNodeExporter `json:"nodeExporter,omitempty" tf:"node_exporter"` }
func (*ClusterSpecOpenMonitoringPrometheus) DeepCopy ¶
func (in *ClusterSpecOpenMonitoringPrometheus) DeepCopy() *ClusterSpecOpenMonitoringPrometheus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSpecOpenMonitoringPrometheus.
func (*ClusterSpecOpenMonitoringPrometheus) DeepCopyInto ¶
func (in *ClusterSpecOpenMonitoringPrometheus) DeepCopyInto(out *ClusterSpecOpenMonitoringPrometheus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterSpecOpenMonitoringPrometheusCodec ¶
type ClusterSpecOpenMonitoringPrometheusCodec struct { }
+k8s:deepcopy-gen=false
func (ClusterSpecOpenMonitoringPrometheusCodec) Decode ¶
func (ClusterSpecOpenMonitoringPrometheusCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
type ClusterSpecOpenMonitoringPrometheusJmxExporter ¶
type ClusterSpecOpenMonitoringPrometheusJmxExporter struct {
EnabledInBroker *bool `json:"enabledInBroker" tf:"enabled_in_broker"`
}
func (*ClusterSpecOpenMonitoringPrometheusJmxExporter) DeepCopy ¶
func (in *ClusterSpecOpenMonitoringPrometheusJmxExporter) DeepCopy() *ClusterSpecOpenMonitoringPrometheusJmxExporter
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSpecOpenMonitoringPrometheusJmxExporter.
func (*ClusterSpecOpenMonitoringPrometheusJmxExporter) DeepCopyInto ¶
func (in *ClusterSpecOpenMonitoringPrometheusJmxExporter) DeepCopyInto(out *ClusterSpecOpenMonitoringPrometheusJmxExporter)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterSpecOpenMonitoringPrometheusJmxExporterCodec ¶
type ClusterSpecOpenMonitoringPrometheusJmxExporterCodec struct { }
+k8s:deepcopy-gen=false
func (ClusterSpecOpenMonitoringPrometheusJmxExporterCodec) Decode ¶
func (ClusterSpecOpenMonitoringPrometheusJmxExporterCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
type ClusterSpecOpenMonitoringPrometheusNodeExporter ¶
type ClusterSpecOpenMonitoringPrometheusNodeExporter struct {
EnabledInBroker *bool `json:"enabledInBroker" tf:"enabled_in_broker"`
}
func (*ClusterSpecOpenMonitoringPrometheusNodeExporter) DeepCopy ¶
func (in *ClusterSpecOpenMonitoringPrometheusNodeExporter) DeepCopy() *ClusterSpecOpenMonitoringPrometheusNodeExporter
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSpecOpenMonitoringPrometheusNodeExporter.
func (*ClusterSpecOpenMonitoringPrometheusNodeExporter) DeepCopyInto ¶
func (in *ClusterSpecOpenMonitoringPrometheusNodeExporter) DeepCopyInto(out *ClusterSpecOpenMonitoringPrometheusNodeExporter)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterSpecOpenMonitoringPrometheusNodeExporterCodec ¶
type ClusterSpecOpenMonitoringPrometheusNodeExporterCodec struct { }
+k8s:deepcopy-gen=false
func (ClusterSpecOpenMonitoringPrometheusNodeExporterCodec) Decode ¶
func (ClusterSpecOpenMonitoringPrometheusNodeExporterCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
type ClusterSpecResource ¶
type ClusterSpecResource struct { Timeouts *base.ResourceTimeout `json:"timeouts,omitempty" tf:"timeouts"` ID string `json:"id,omitempty" tf:"id,omitempty"` // +optional Arn *string `json:"arn,omitempty" tf:"arn"` // +optional BootstrapBrokers *string `json:"bootstrapBrokers,omitempty" tf:"bootstrap_brokers"` // +optional BootstrapBrokersSaslIam *string `json:"bootstrapBrokersSaslIam,omitempty" tf:"bootstrap_brokers_sasl_iam"` // +optional BootstrapBrokersSaslScram *string `json:"bootstrapBrokersSaslScram,omitempty" tf:"bootstrap_brokers_sasl_scram"` // +optional BootstrapBrokersTls *string `json:"bootstrapBrokersTls,omitempty" tf:"bootstrap_brokers_tls"` BrokerNodeGroupInfo *ClusterSpecBrokerNodeGroupInfo `json:"brokerNodeGroupInfo" tf:"broker_node_group_info"` // +optional ClientAuthentication *ClusterSpecClientAuthentication `json:"clientAuthentication,omitempty" tf:"client_authentication"` ClusterName *string `json:"clusterName" tf:"cluster_name"` // +optional ConfigurationInfo *ClusterSpecConfigurationInfo `json:"configurationInfo,omitempty" tf:"configuration_info"` // +optional CurrentVersion *string `json:"currentVersion,omitempty" tf:"current_version"` // +optional EncryptionInfo *ClusterSpecEncryptionInfo `json:"encryptionInfo,omitempty" tf:"encryption_info"` // +optional EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty" tf:"enhanced_monitoring"` KafkaVersion *string `json:"kafkaVersion" tf:"kafka_version"` // +optional LoggingInfo *ClusterSpecLoggingInfo `json:"loggingInfo,omitempty" tf:"logging_info"` NumberOfBrokerNodes *int64 `json:"numberOfBrokerNodes" tf:"number_of_broker_nodes"` // +optional OpenMonitoring *ClusterSpecOpenMonitoring `json:"openMonitoring,omitempty" tf:"open_monitoring"` // +optional Tags *map[string]string `json:"tags,omitempty" tf:"tags"` // +optional TagsAll *map[string]string `json:"tagsAll,omitempty" tf:"tags_all"` // +optional ZookeeperConnectString *string `json:"zookeeperConnectString,omitempty" tf:"zookeeper_connect_string"` // +optional ZookeeperConnectStringTls *string `json:"zookeeperConnectStringTls,omitempty" tf:"zookeeper_connect_string_tls"` }
func (*ClusterSpecResource) DeepCopy ¶
func (in *ClusterSpecResource) DeepCopy() *ClusterSpecResource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSpecResource.
func (*ClusterSpecResource) DeepCopyInto ¶
func (in *ClusterSpecResource) DeepCopyInto(out *ClusterSpecResource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterStatus ¶
type ClusterStatus struct { // Resource generation, which is updated on mutation by the API Server. // +optional ObservedGeneration int64 `json:"observedGeneration,omitempty"` // +optional Phase status.Status `json:"phase,omitempty"` // +optional Conditions []kmapi.Condition `json:"conditions,omitempty"` }
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 Configuration ¶
type Configuration struct { metav1.TypeMeta `json:",inline,omitempty"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec ConfigurationSpec `json:"spec,omitempty"` Status ConfigurationStatus `json:"status,omitempty"` }
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) SetupWebhookWithManager ¶
func (r *Configuration) SetupWebhookWithManager(mgr ctrl.Manager) error
func (*Configuration) ValidateCreate ¶
func (r *Configuration) ValidateCreate() error
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*Configuration) ValidateDelete ¶
func (r *Configuration) ValidateDelete() error
ValidateDelete implements webhook.Validator so a webhook will be registered for the type
func (*Configuration) ValidateUpdate ¶
func (r *Configuration) ValidateUpdate(old runtime.Object) error
ValidateUpdate implements webhook.Validator so a webhook will be registered for the type
type ConfigurationList ¶
type ConfigurationList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` // Items is a list of Configuration CRD objects Items []Configuration `json:"items,omitempty"` }
ConfigurationList is 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.
type ConfigurationSpec ¶
type ConfigurationSpec struct { State *ConfigurationSpecResource `json:"state,omitempty" tf:"-"` Resource ConfigurationSpecResource `json:"resource" tf:"resource"` UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"` TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"` ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"` BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"` }
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 ConfigurationSpecResource ¶
type ConfigurationSpecResource struct { ID string `json:"id,omitempty" tf:"id,omitempty"` // +optional Arn *string `json:"arn,omitempty" tf:"arn"` // +optional Description *string `json:"description,omitempty" tf:"description"` // +optional KafkaVersions []string `json:"kafkaVersions,omitempty" tf:"kafka_versions"` // +optional LatestRevision *int64 `json:"latestRevision,omitempty" tf:"latest_revision"` Name *string `json:"name" tf:"name"` ServerProperties *string `json:"serverProperties" tf:"server_properties"` }
func (*ConfigurationSpecResource) DeepCopy ¶
func (in *ConfigurationSpecResource) DeepCopy() *ConfigurationSpecResource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationSpecResource.
func (*ConfigurationSpecResource) DeepCopyInto ¶
func (in *ConfigurationSpecResource) DeepCopyInto(out *ConfigurationSpecResource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConfigurationStatus ¶
type ConfigurationStatus struct { // Resource generation, which is updated on mutation by the API Server. // +optional ObservedGeneration int64 `json:"observedGeneration,omitempty"` // +optional Phase status.Status `json:"phase,omitempty"` // +optional Conditions []kmapi.Condition `json:"conditions,omitempty"` }
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 ScramSecretAssociation ¶
type ScramSecretAssociation struct { metav1.TypeMeta `json:",inline,omitempty"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec ScramSecretAssociationSpec `json:"spec,omitempty"` Status ScramSecretAssociationStatus `json:"status,omitempty"` }
func (*ScramSecretAssociation) DeepCopy ¶
func (in *ScramSecretAssociation) DeepCopy() *ScramSecretAssociation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ScramSecretAssociation.
func (*ScramSecretAssociation) DeepCopyInto ¶
func (in *ScramSecretAssociation) DeepCopyInto(out *ScramSecretAssociation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ScramSecretAssociation) DeepCopyObject ¶
func (in *ScramSecretAssociation) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ScramSecretAssociation) SetupWebhookWithManager ¶
func (r *ScramSecretAssociation) SetupWebhookWithManager(mgr ctrl.Manager) error
func (*ScramSecretAssociation) ValidateCreate ¶
func (r *ScramSecretAssociation) ValidateCreate() error
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*ScramSecretAssociation) ValidateDelete ¶
func (r *ScramSecretAssociation) ValidateDelete() error
ValidateDelete implements webhook.Validator so a webhook will be registered for the type
func (*ScramSecretAssociation) ValidateUpdate ¶
func (r *ScramSecretAssociation) ValidateUpdate(old runtime.Object) error
ValidateUpdate implements webhook.Validator so a webhook will be registered for the type
type ScramSecretAssociationList ¶
type ScramSecretAssociationList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` // Items is a list of ScramSecretAssociation CRD objects Items []ScramSecretAssociation `json:"items,omitempty"` }
ScramSecretAssociationList is a list of ScramSecretAssociations
func (*ScramSecretAssociationList) DeepCopy ¶
func (in *ScramSecretAssociationList) DeepCopy() *ScramSecretAssociationList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ScramSecretAssociationList.
func (*ScramSecretAssociationList) DeepCopyInto ¶
func (in *ScramSecretAssociationList) DeepCopyInto(out *ScramSecretAssociationList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ScramSecretAssociationList) DeepCopyObject ¶
func (in *ScramSecretAssociationList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ScramSecretAssociationSpec ¶
type ScramSecretAssociationSpec struct { State *ScramSecretAssociationSpecResource `json:"state,omitempty" tf:"-"` Resource ScramSecretAssociationSpecResource `json:"resource" tf:"resource"` UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"` TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"` ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"` BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"` }
func (*ScramSecretAssociationSpec) DeepCopy ¶
func (in *ScramSecretAssociationSpec) DeepCopy() *ScramSecretAssociationSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ScramSecretAssociationSpec.
func (*ScramSecretAssociationSpec) DeepCopyInto ¶
func (in *ScramSecretAssociationSpec) DeepCopyInto(out *ScramSecretAssociationSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ScramSecretAssociationSpecResource ¶
type ScramSecretAssociationSpecResource struct { ID string `json:"id,omitempty" tf:"id,omitempty"` ClusterArn *string `json:"clusterArn" tf:"cluster_arn"` SecretArnList []string `json:"secretArnList" tf:"secret_arn_list"` }
func (*ScramSecretAssociationSpecResource) DeepCopy ¶
func (in *ScramSecretAssociationSpecResource) DeepCopy() *ScramSecretAssociationSpecResource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ScramSecretAssociationSpecResource.
func (*ScramSecretAssociationSpecResource) DeepCopyInto ¶
func (in *ScramSecretAssociationSpecResource) DeepCopyInto(out *ScramSecretAssociationSpecResource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ScramSecretAssociationStatus ¶
type ScramSecretAssociationStatus struct { // Resource generation, which is updated on mutation by the API Server. // +optional ObservedGeneration int64 `json:"observedGeneration,omitempty"` // +optional Phase status.Status `json:"phase,omitempty"` // +optional Conditions []kmapi.Condition `json:"conditions,omitempty"` }
func (*ScramSecretAssociationStatus) DeepCopy ¶
func (in *ScramSecretAssociationStatus) DeepCopy() *ScramSecretAssociationStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ScramSecretAssociationStatus.
func (*ScramSecretAssociationStatus) DeepCopyInto ¶
func (in *ScramSecretAssociationStatus) DeepCopyInto(out *ScramSecretAssociationStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.