v1alpha1

package

Go to main page

Versions in this module

v0

v0.5.0

May 8, 2022

Changes in this version

type ClusterSpecResource

+ ZookeeperConnectStringTls *string

v0.4.0

Oct 20, 2021

Changes in this version

type ClusterSpec

+ BackendRef *core.LocalObjectReference

type ConfigurationSpec

+ BackendRef *core.LocalObjectReference

type ScramSecretAssociationSpec

+ BackendRef *core.LocalObjectReference

v0.3.0

Aug 2, 2021

v0.2.0

Jul 13, 2021

v0.1.1

Jul 13, 2021

Changes in this version

type ClusterSpec

+ State *ClusterSpecResource

type ConfigurationSpec

+ State *ConfigurationSpecResource

type ScramSecretAssociationSpec

+ State *ScramSecretAssociationSpecResource

v0.1.0

Jul 2, 2021

Changes in this version

+ var AddToScheme = localSchemeBuilder.AddToScheme

+ var SchemeBuilder runtime.SchemeBuilder

+ var SchemeGroupVersion = schema.GroupVersion

+ 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 struct

+ Spec ClusterSpec

+ Status ClusterStatus

+ 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 struct

+ Items []Cluster

+ func (in *ClusterList) DeepCopy() *ClusterList

+ func (in *ClusterList) DeepCopyInto(out *ClusterList)

+ func (in *ClusterList) DeepCopyObject() runtime.Object

+ type ClusterSpec struct

+ KubeformOutput *ClusterSpecResource

+ ProviderRef core.LocalObjectReference

+ Resource ClusterSpecResource

+ TerminationPolicy base.TerminationPolicy

+ UpdatePolicy base.UpdatePolicy

+ func (in *ClusterSpec) DeepCopy() *ClusterSpec

+ func (in *ClusterSpec) DeepCopyInto(out *ClusterSpec)

+ type ClusterSpecBrokerNodeGroupInfo struct

+ AzDistribution *string

+ ClientSubnets []string

+ EbsVolumeSize *int64

+ InstanceType *string

+ SecurityGroups []string

+ func (in *ClusterSpecBrokerNodeGroupInfo) DeepCopy() *ClusterSpecBrokerNodeGroupInfo

+ func (in *ClusterSpecBrokerNodeGroupInfo) DeepCopyInto(out *ClusterSpecBrokerNodeGroupInfo)

+ type ClusterSpecBrokerNodeGroupInfoCodec struct

+ func (ClusterSpecBrokerNodeGroupInfoCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

+ func (ClusterSpecBrokerNodeGroupInfoCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

+ func (ClusterSpecBrokerNodeGroupInfoCodec) IsEmpty(ptr unsafe.Pointer) bool

+ type ClusterSpecClientAuthentication struct

+ Sasl *ClusterSpecClientAuthenticationSasl

+ Tls *ClusterSpecClientAuthenticationTls

+ func (in *ClusterSpecClientAuthentication) DeepCopy() *ClusterSpecClientAuthentication

+ func (in *ClusterSpecClientAuthentication) DeepCopyInto(out *ClusterSpecClientAuthentication)

+ type ClusterSpecClientAuthenticationCodec struct

+ func (ClusterSpecClientAuthenticationCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

+ func (ClusterSpecClientAuthenticationCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

+ func (ClusterSpecClientAuthenticationCodec) IsEmpty(ptr unsafe.Pointer) bool

+ type ClusterSpecClientAuthenticationSasl struct

+ Iam *bool

+ Scram *bool

+ func (in *ClusterSpecClientAuthenticationSasl) DeepCopy() *ClusterSpecClientAuthenticationSasl

+ func (in *ClusterSpecClientAuthenticationSasl) DeepCopyInto(out *ClusterSpecClientAuthenticationSasl)

+ type ClusterSpecClientAuthenticationSaslCodec struct

+ func (ClusterSpecClientAuthenticationSaslCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

+ func (ClusterSpecClientAuthenticationSaslCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

+ func (ClusterSpecClientAuthenticationSaslCodec) IsEmpty(ptr unsafe.Pointer) bool

+ type ClusterSpecClientAuthenticationTls struct

+ CertificateAuthorityArns []string

+ func (in *ClusterSpecClientAuthenticationTls) DeepCopy() *ClusterSpecClientAuthenticationTls

+ func (in *ClusterSpecClientAuthenticationTls) DeepCopyInto(out *ClusterSpecClientAuthenticationTls)

+ type ClusterSpecClientAuthenticationTlsCodec struct

+ func (ClusterSpecClientAuthenticationTlsCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

+ func (ClusterSpecClientAuthenticationTlsCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

+ func (ClusterSpecClientAuthenticationTlsCodec) IsEmpty(ptr unsafe.Pointer) bool

+ type ClusterSpecConfigurationInfo struct

+ Arn *string

+ Revision *int64

+ func (in *ClusterSpecConfigurationInfo) DeepCopy() *ClusterSpecConfigurationInfo

+ func (in *ClusterSpecConfigurationInfo) DeepCopyInto(out *ClusterSpecConfigurationInfo)

+ type ClusterSpecConfigurationInfoCodec struct

+ func (ClusterSpecConfigurationInfoCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

+ func (ClusterSpecConfigurationInfoCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

+ func (ClusterSpecConfigurationInfoCodec) IsEmpty(ptr unsafe.Pointer) bool

+ type ClusterSpecEncryptionInfo struct

+ EncryptionAtRestKmsKeyArn *string

+ EncryptionInTransit *ClusterSpecEncryptionInfoEncryptionInTransit

+ func (in *ClusterSpecEncryptionInfo) DeepCopy() *ClusterSpecEncryptionInfo

+ func (in *ClusterSpecEncryptionInfo) DeepCopyInto(out *ClusterSpecEncryptionInfo)

+ type ClusterSpecEncryptionInfoCodec struct

+ func (ClusterSpecEncryptionInfoCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

+ func (ClusterSpecEncryptionInfoCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

+ func (ClusterSpecEncryptionInfoCodec) IsEmpty(ptr unsafe.Pointer) bool

+ type ClusterSpecEncryptionInfoEncryptionInTransit struct

+ ClientBroker *string

+ InCluster *bool

+ func (in *ClusterSpecEncryptionInfoEncryptionInTransit) DeepCopy() *ClusterSpecEncryptionInfoEncryptionInTransit

+ func (in *ClusterSpecEncryptionInfoEncryptionInTransit) DeepCopyInto(out *ClusterSpecEncryptionInfoEncryptionInTransit)

+ type ClusterSpecEncryptionInfoEncryptionInTransitCodec struct

+ 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 struct

+ BrokerLogs *ClusterSpecLoggingInfoBrokerLogs

+ func (in *ClusterSpecLoggingInfo) DeepCopy() *ClusterSpecLoggingInfo

+ func (in *ClusterSpecLoggingInfo) DeepCopyInto(out *ClusterSpecLoggingInfo)

+ type ClusterSpecLoggingInfoBrokerLogs struct

+ CloudwatchLogs *ClusterSpecLoggingInfoBrokerLogsCloudwatchLogs

+ Firehose *ClusterSpecLoggingInfoBrokerLogsFirehose

+ S3 *ClusterSpecLoggingInfoBrokerLogsS3

+ func (in *ClusterSpecLoggingInfoBrokerLogs) DeepCopy() *ClusterSpecLoggingInfoBrokerLogs

+ func (in *ClusterSpecLoggingInfoBrokerLogs) DeepCopyInto(out *ClusterSpecLoggingInfoBrokerLogs)

+ type ClusterSpecLoggingInfoBrokerLogsCloudwatchLogs struct

+ Enabled *bool

+ LogGroup *string

+ func (in *ClusterSpecLoggingInfoBrokerLogsCloudwatchLogs) DeepCopy() *ClusterSpecLoggingInfoBrokerLogsCloudwatchLogs

+ func (in *ClusterSpecLoggingInfoBrokerLogsCloudwatchLogs) DeepCopyInto(out *ClusterSpecLoggingInfoBrokerLogsCloudwatchLogs)

+ type ClusterSpecLoggingInfoBrokerLogsCloudwatchLogsCodec struct

+ 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 struct

+ func (ClusterSpecLoggingInfoBrokerLogsCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

+ func (ClusterSpecLoggingInfoBrokerLogsCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

+ func (ClusterSpecLoggingInfoBrokerLogsCodec) IsEmpty(ptr unsafe.Pointer) bool

+ type ClusterSpecLoggingInfoBrokerLogsFirehose struct

+ DeliveryStream *string

+ Enabled *bool

+ func (in *ClusterSpecLoggingInfoBrokerLogsFirehose) DeepCopy() *ClusterSpecLoggingInfoBrokerLogsFirehose

+ func (in *ClusterSpecLoggingInfoBrokerLogsFirehose) DeepCopyInto(out *ClusterSpecLoggingInfoBrokerLogsFirehose)

+ type ClusterSpecLoggingInfoBrokerLogsFirehoseCodec struct

+ func (ClusterSpecLoggingInfoBrokerLogsFirehoseCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

+ func (ClusterSpecLoggingInfoBrokerLogsFirehoseCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

+ func (ClusterSpecLoggingInfoBrokerLogsFirehoseCodec) IsEmpty(ptr unsafe.Pointer) bool

+ type ClusterSpecLoggingInfoBrokerLogsS3 struct

+ Bucket *string

+ Enabled *bool

+ Prefix *string

+ func (in *ClusterSpecLoggingInfoBrokerLogsS3) DeepCopy() *ClusterSpecLoggingInfoBrokerLogsS3

+ func (in *ClusterSpecLoggingInfoBrokerLogsS3) DeepCopyInto(out *ClusterSpecLoggingInfoBrokerLogsS3)

+ type ClusterSpecLoggingInfoBrokerLogsS3Codec struct

+ func (ClusterSpecLoggingInfoBrokerLogsS3Codec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

+ func (ClusterSpecLoggingInfoBrokerLogsS3Codec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

+ func (ClusterSpecLoggingInfoBrokerLogsS3Codec) IsEmpty(ptr unsafe.Pointer) bool

+ type ClusterSpecLoggingInfoCodec struct

+ func (ClusterSpecLoggingInfoCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

+ func (ClusterSpecLoggingInfoCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

+ func (ClusterSpecLoggingInfoCodec) IsEmpty(ptr unsafe.Pointer) bool

+ type ClusterSpecOpenMonitoring struct

+ Prometheus *ClusterSpecOpenMonitoringPrometheus

+ func (in *ClusterSpecOpenMonitoring) DeepCopy() *ClusterSpecOpenMonitoring

+ func (in *ClusterSpecOpenMonitoring) DeepCopyInto(out *ClusterSpecOpenMonitoring)

+ type ClusterSpecOpenMonitoringCodec struct

+ func (ClusterSpecOpenMonitoringCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

+ func (ClusterSpecOpenMonitoringCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

+ func (ClusterSpecOpenMonitoringCodec) IsEmpty(ptr unsafe.Pointer) bool

+ type ClusterSpecOpenMonitoringPrometheus struct

+ JmxExporter *ClusterSpecOpenMonitoringPrometheusJmxExporter

+ NodeExporter *ClusterSpecOpenMonitoringPrometheusNodeExporter

+ func (in *ClusterSpecOpenMonitoringPrometheus) DeepCopy() *ClusterSpecOpenMonitoringPrometheus

+ func (in *ClusterSpecOpenMonitoringPrometheus) DeepCopyInto(out *ClusterSpecOpenMonitoringPrometheus)

+ type ClusterSpecOpenMonitoringPrometheusCodec struct

+ func (ClusterSpecOpenMonitoringPrometheusCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

+ func (ClusterSpecOpenMonitoringPrometheusCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

+ func (ClusterSpecOpenMonitoringPrometheusCodec) IsEmpty(ptr unsafe.Pointer) bool

+ type ClusterSpecOpenMonitoringPrometheusJmxExporter struct

+ EnabledInBroker *bool

+ func (in *ClusterSpecOpenMonitoringPrometheusJmxExporter) DeepCopy() *ClusterSpecOpenMonitoringPrometheusJmxExporter

+ func (in *ClusterSpecOpenMonitoringPrometheusJmxExporter) DeepCopyInto(out *ClusterSpecOpenMonitoringPrometheusJmxExporter)

+ type ClusterSpecOpenMonitoringPrometheusJmxExporterCodec struct

+ 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 struct

+ EnabledInBroker *bool

+ func (in *ClusterSpecOpenMonitoringPrometheusNodeExporter) DeepCopy() *ClusterSpecOpenMonitoringPrometheusNodeExporter

+ func (in *ClusterSpecOpenMonitoringPrometheusNodeExporter) DeepCopyInto(out *ClusterSpecOpenMonitoringPrometheusNodeExporter)

+ type ClusterSpecOpenMonitoringPrometheusNodeExporterCodec struct

+ 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 struct

+ Arn *string

+ BootstrapBrokers *string

+ BootstrapBrokersSaslIam *string

+ BootstrapBrokersSaslScram *string

+ BootstrapBrokersTls *string

+ BrokerNodeGroupInfo *ClusterSpecBrokerNodeGroupInfo

+ ClientAuthentication *ClusterSpecClientAuthentication

+ ClusterName *string

+ ConfigurationInfo *ClusterSpecConfigurationInfo

+ CurrentVersion *string

+ EncryptionInfo *ClusterSpecEncryptionInfo

+ EnhancedMonitoring *string

+ ID string

+ KafkaVersion *string

+ LoggingInfo *ClusterSpecLoggingInfo

+ NumberOfBrokerNodes *int64

+ OpenMonitoring *ClusterSpecOpenMonitoring

+ Tags *map[string]string

+ TagsAll *map[string]string

+ Timeouts *base.ResourceTimeout

+ ZookeeperConnectString *string

+ func (in *ClusterSpecResource) DeepCopy() *ClusterSpecResource

+ func (in *ClusterSpecResource) DeepCopyInto(out *ClusterSpecResource)

+ type ClusterStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase status.Status

+ func (in *ClusterStatus) DeepCopy() *ClusterStatus

+ func (in *ClusterStatus) DeepCopyInto(out *ClusterStatus)

+ type Configuration struct

+ Spec ConfigurationSpec

+ Status ConfigurationStatus

+ 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 struct

+ Items []Configuration

+ func (in *ConfigurationList) DeepCopy() *ConfigurationList

+ func (in *ConfigurationList) DeepCopyInto(out *ConfigurationList)

+ func (in *ConfigurationList) DeepCopyObject() runtime.Object

+ type ConfigurationSpec struct

+ KubeformOutput *ConfigurationSpecResource

+ ProviderRef core.LocalObjectReference

+ Resource ConfigurationSpecResource

+ TerminationPolicy base.TerminationPolicy

+ UpdatePolicy base.UpdatePolicy

+ func (in *ConfigurationSpec) DeepCopy() *ConfigurationSpec

+ func (in *ConfigurationSpec) DeepCopyInto(out *ConfigurationSpec)

+ type ConfigurationSpecResource struct

+ Arn *string

+ Description *string

+ ID string

+ KafkaVersions []string

+ LatestRevision *int64

+ Name *string

+ ServerProperties *string

+ func (in *ConfigurationSpecResource) DeepCopy() *ConfigurationSpecResource

+ func (in *ConfigurationSpecResource) DeepCopyInto(out *ConfigurationSpecResource)

+ type ConfigurationStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase status.Status

+ func (in *ConfigurationStatus) DeepCopy() *ConfigurationStatus

+ func (in *ConfigurationStatus) DeepCopyInto(out *ConfigurationStatus)

+ type ScramSecretAssociation struct

+ Spec ScramSecretAssociationSpec

+ Status ScramSecretAssociationStatus

+ 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 struct

+ Items []ScramSecretAssociation

+ func (in *ScramSecretAssociationList) DeepCopy() *ScramSecretAssociationList

+ func (in *ScramSecretAssociationList) DeepCopyInto(out *ScramSecretAssociationList)

+ func (in *ScramSecretAssociationList) DeepCopyObject() runtime.Object

+ type ScramSecretAssociationSpec struct

+ KubeformOutput *ScramSecretAssociationSpecResource

+ ProviderRef core.LocalObjectReference

+ Resource ScramSecretAssociationSpecResource

+ TerminationPolicy base.TerminationPolicy

+ UpdatePolicy base.UpdatePolicy

+ func (in *ScramSecretAssociationSpec) DeepCopy() *ScramSecretAssociationSpec

+ func (in *ScramSecretAssociationSpec) DeepCopyInto(out *ScramSecretAssociationSpec)

+ type ScramSecretAssociationSpecResource struct

+ ClusterArn *string

+ ID string

+ SecretArnList []string

+ func (in *ScramSecretAssociationSpecResource) DeepCopy() *ScramSecretAssociationSpecResource

+ func (in *ScramSecretAssociationSpecResource) DeepCopyInto(out *ScramSecretAssociationSpecResource)

+ type ScramSecretAssociationStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase status.Status

+ func (in *ScramSecretAssociationStatus) DeepCopy() *ScramSecretAssociationStatus

+ func (in *ScramSecretAssociationStatus) DeepCopyInto(out *ScramSecretAssociationStatus)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL