Versions in this module Expand all Collapse all v0 v0.12.0 Aug 26, 2021 Changes in this version + const CACertKey + const CAPrivateKeyKey + const ClientCertKey + const ClientPrivateKeyKey + const CoreCACertKey + const KafkaAccessTypeRead + const KafkaAccessTypeWrite + const KafkaPatternTypeAny + const KafkaPatternTypeDefault + const KafkaPatternTypeLiteral + const KafkaPatternTypeMatch + const KafkaPatternTypePrefixed + const PasswordKey + const PeerCertKey + const PeerPrivateKeyKey + const TLSJKSKeyStore + const TLSJKSTrustStore + const TopicStateCreated + const UserStateCreated + var AddToScheme = SchemeBuilder.AddToScheme + var GroupVersion = schema.GroupVersion + var SchemeBuilder = &scheme.Builder + type ClusterReference struct + Name string + Namespace string + func (in *ClusterReference) DeepCopy() *ClusterReference + func (in *ClusterReference) DeepCopyInto(out *ClusterReference) + type KafkaAccessType string + type KafkaPatternType string + type KafkaTopic struct + Spec KafkaTopicSpec + Status KafkaTopicStatus + func (in *KafkaTopic) DeepCopy() *KafkaTopic + func (in *KafkaTopic) DeepCopyInto(out *KafkaTopic) + func (in *KafkaTopic) DeepCopyObject() runtime.Object + type KafkaTopicList struct + Items []KafkaTopic + func (in *KafkaTopicList) DeepCopy() *KafkaTopicList + func (in *KafkaTopicList) DeepCopyInto(out *KafkaTopicList) + func (in *KafkaTopicList) DeepCopyObject() runtime.Object + type KafkaTopicSpec struct + ClusterRef ClusterReference + Config map[string]string + Name string + Partitions int32 + ReplicationFactor int32 + func (in *KafkaTopicSpec) DeepCopy() *KafkaTopicSpec + func (in *KafkaTopicSpec) DeepCopyInto(out *KafkaTopicSpec) + type KafkaTopicStatus struct + State TopicState + func (in *KafkaTopicStatus) DeepCopy() *KafkaTopicStatus + func (in *KafkaTopicStatus) DeepCopyInto(out *KafkaTopicStatus) + type KafkaUser struct + Spec KafkaUserSpec + Status KafkaUserStatus + func (in *KafkaUser) DeepCopy() *KafkaUser + func (in *KafkaUser) DeepCopyInto(out *KafkaUser) + func (in *KafkaUser) DeepCopyObject() runtime.Object + type KafkaUserList struct + Items []KafkaUser + func (in *KafkaUserList) DeepCopy() *KafkaUserList + func (in *KafkaUserList) DeepCopyInto(out *KafkaUserList) + func (in *KafkaUserList) DeepCopyObject() runtime.Object + type KafkaUserSpec struct + Annotations map[string]string + ClusterRef ClusterReference + CreateCert *bool + DNSNames []string + IncludeJKS bool + PKIBackendSpec *PKIBackendSpec + SecretName string + TopicGrants []UserTopicGrant + func (in *KafkaUserSpec) DeepCopy() *KafkaUserSpec + func (in *KafkaUserSpec) DeepCopyInto(out *KafkaUserSpec) + func (spec *KafkaUserSpec) GetAnnotations() map[string]string + func (spec *KafkaUserSpec) GetIfCertShouldBeCreated() bool + type KafkaUserStatus struct + ACLs []string + State UserState + func (in *KafkaUserStatus) DeepCopy() *KafkaUserStatus + func (in *KafkaUserStatus) DeepCopyInto(out *KafkaUserStatus) + type PKIBackendSpec struct + IssuerRef *cmmeta.ObjectReference + PKIBackend string + SignerName string + func (in *PKIBackendSpec) DeepCopy() *PKIBackendSpec + func (in *PKIBackendSpec) DeepCopyInto(out *PKIBackendSpec) + type TopicState string + type UserState string + type UserTopicGrant struct + AccessType KafkaAccessType + PatternType KafkaPatternType + TopicName string + func (in *UserTopicGrant) DeepCopy() *UserTopicGrant + func (in *UserTopicGrant) DeepCopyInto(out *UserTopicGrant)