v1beta1

package

Go to main page

Versions in this module

v0

v0.1.5

Jan 24, 2024

v0.1.4

Jan 3, 2024

Changes in this version

+ type CSRTemplate struct

+ Country string

+ Organization string

+ OrganizationalUnit string

+ func (c *CSRTemplate) ToSubject() pkix.Name

+ func (in *CSRTemplate) DeepCopy() *CSRTemplate

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

+ type Reference = apiextensions.ObjectReference

+ type UserCertificate struct

+ Spec UserCertificateSpec

+ Status UserCertificateStatus

+ func (cert *UserCertificate) ValidateCreate() error

+ func (cert *UserCertificate) ValidateDelete() error

+ func (cert *UserCertificate) ValidateUpdate(old runtime.Object) error

+ func (csr *UserCertificate) NewPatch() client.Patch

+ func (in *UserCertificate) DeepCopy() *UserCertificate

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

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

+ func (r *UserCertificate) SetupWebhookWithManager(mgr ctrl.Manager) error

+ type UserCertificateList struct

+ Items []UserCertificate

+ func (in *UserCertificateList) DeepCopy() *UserCertificateList

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

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

+ type UserCertificateSpec struct

+ CertificateRequestTemplate *CSRTemplate

+ ClusterRef Reference

+ SecretRef *apiextensions.ObjectFieldReference

+ UserRef Reference

+ ValidPeriod int

+ func (in *UserCertificateSpec) DeepCopy() *UserCertificateSpec

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

+ type UserCertificateStatus struct

+ CertID string

+ ExpiryDate string

+ SignedCertSecretRef Reference

+ func (in *UserCertificateStatus) DeepCopy() *UserCertificateStatus

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

v0.1.3

Dec 7, 2023

Changes in this version

type KafkaUser

+ func (ku *KafkaUser) GetClusterEvents() map[string]string

+ func (ku *KafkaUser) SetClusterEvents(events map[string]string)

type KafkaUserSpec

+ AuthMechanism string

+ OverrideExistingUser bool

+ SASLSCRAMMechanism string

v0.1.2

Sep 15, 2023

Changes in this version

+ type Certificate struct

+ ExpiryDate string

+ ID string

+ SignedCertificate string

+ func (in *Certificate) DeepCopy() *Certificate

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

+ type CertificateRequest struct

+ AutoRenew bool

+ CSR string

+ ClusterID string

+ CommonName string

+ Country string

+ Organization string

+ OrganizationalUnit string

+ SecretName string

+ SecretNamespace string

+ ValidPeriod int

+ func (cr *CertificateRequest) ToInstAPI(username string) *models.CertificateRequest

+ func (in *CertificateRequest) DeepCopy() *CertificateRequest

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

type KafkaACL

+ func (r *KafkaACL) Default()

type KafkaUser

+ func (ku *KafkaUser) NewCertificateSecret(name, namespace string) *k8sCore.Secret

+ func (r *KafkaUser) Default()

+ func (r *KafkaUser) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *KafkaUser) ValidateCreate() error

+ func (r *KafkaUser) ValidateDelete() error

+ func (r *KafkaUser) ValidateUpdate(old runtime.Object) error

type KafkaUserSpec

+ CertificateRequests []*CertificateRequest

type Mirror

+ func (r *Mirror) Default()

+ func (r *Mirror) SetupWebhookWithManager(mgr ctrl.Manager) error

type Topic

+ func (r *Topic) Default()

+ func (r *Topic) SetupWebhookWithManager(mgr ctrl.Manager) error

v0.1.1

Jul 24, 2023

Changes in this version

type KafkaUser

+ func (ku *KafkaUser) GetDeletionFinalizer() string

+ func (ku *KafkaUser) GetDeletionUserFinalizer(clusterID string) string

+ func (ku *KafkaUser) GetID(clusterID, name string) string

type KafkaUserSpec

+ SecretRef *v1beta1.SecretReference

type KafkaUserStatus

+ ClustersEvents map[string]string

v0.1.0

Jul 13, 2023

v0.0.6

Jul 5, 2023

Changes in this version

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var GroupVersion = schema.GroupVersion

+ var SchemeBuilder = &scheme.Builder

+ type ACL struct

+ Host string

+ Operation string

+ PatternType string

+ PermissionType string

+ Principal string

+ ResourceName string

+ ResourceType string

+ func (in *ACL) DeepCopy() *ACL

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

+ type Connector struct

+ Config string

+ Name string

+ Status string

+ func (in *Connector) DeepCopy() *Connector

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

+ type ExternalCluster struct

+ SourceConnectionProperties string

+ func (in *ExternalCluster) DeepCopy() *ExternalCluster

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

+ type KafkaACL struct

+ Spec KafkaACLSpec

+ Status KafkaACLStatus

+ func (in *KafkaACL) DeepCopy() *KafkaACL

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

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

+ func (kacl *KafkaACL) GetJobID(jobName string) string

+ func (kacl *KafkaACL) NewPatch() client.Patch

+ func (kacl *KafkaACL) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (kacl *KafkaACL) ValidateCreate() error

+ func (kacl *KafkaACL) ValidateDelete() error

+ func (kacl *KafkaACL) ValidateUpdate(old runtime.Object) error

+ type KafkaACLList struct

+ Items []KafkaACL

+ func (in *KafkaACLList) DeepCopy() *KafkaACLList

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

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

+ type KafkaACLSpec struct

+ ACLs []ACL

+ ClusterID string

+ UserQuery string

+ func (in *KafkaACLSpec) DeepCopy() *KafkaACLSpec

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

+ type KafkaACLStatus struct

+ ID string

+ func (in *KafkaACLStatus) DeepCopy() *KafkaACLStatus

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

+ type KafkaUser struct

+ Spec KafkaUserSpec

+ Status KafkaUserStatus

+ func (in *KafkaUser) DeepCopy() *KafkaUser

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

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

+ func (ku *KafkaUser) GetJobID(jobName string) string

+ func (ku *KafkaUser) NewPatch() client.Patch

+ type KafkaUserList struct

+ Items []KafkaUser

+ func (in *KafkaUserList) DeepCopy() *KafkaUserList

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

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

+ type KafkaUserOptions struct

+ OverrideExistingUser bool

+ SASLSCRAMMechanism string

+ func (in *KafkaUserOptions) DeepCopy() *KafkaUserOptions

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

+ func (ko *KafkaUserOptions) ToInstAPI() *models.KafkaUserOptions

+ type KafkaUserSpec struct

+ ClusterID string

+ InitialPermissions string

+ KafkaUserSecretName string

+ KafkaUserSecretNamespace string

+ Options *KafkaUserOptions

+ func (in *KafkaUserSpec) DeepCopy() *KafkaUserSpec

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

+ func (ks *KafkaUserSpec) ToInstAPI() *models.KafkaUser

+ type KafkaUserStatus struct

+ ID string

+ func (in *KafkaUserStatus) DeepCopy() *KafkaUserStatus

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

+ type ManagedCluster struct

+ SourceKafkaClusterID string

+ UsePrivateIPs bool

+ func (in *ManagedCluster) DeepCopy() *ManagedCluster

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

+ type Mirror struct

+ Spec MirrorSpec

+ Status MirrorStatus

+ func (in *Mirror) DeepCopy() *Mirror

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

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

+ func (m *Mirror) GetJobID(jobName string) string

+ func (m *Mirror) NewPatch() client.Patch

+ type MirrorList struct

+ Items []Mirror

+ func (in *MirrorList) DeepCopy() *MirrorList

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

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

+ type MirrorSpec struct

+ KafkaConnectClusterID string

+ MaxTasks int32

+ RenameMirroredTopics bool

+ SourceCluster []*SourceCluster

+ TargetLatency int32

+ TopicsRegex string

+ func (in *MirrorSpec) DeepCopy() *MirrorSpec

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

+ type MirrorStatus struct

+ ConnectorName string

+ Connectors []*Connector

+ ID string

+ MirroredTopics []*MirroredTopic

+ Status string

+ TargetLatency int32

+ func (a *MirrorStatus) IsEqual(b *MirrorStatus) bool

+ func (in *MirrorStatus) DeepCopy() *MirrorStatus

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

+ type MirroredTopic struct

+ AverageLatency resource.Quantity

+ AverageRate resource.Quantity

+ Name string

+ func (in *MirroredTopic) DeepCopy() *MirroredTopic

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

+ type SourceCluster struct

+ Alias string

+ ExternalCluster []*ExternalCluster

+ ManagedCluster []*ManagedCluster

+ func (in *SourceCluster) DeepCopy() *SourceCluster

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

+ type Topic struct

+ Spec TopicSpec

+ Status TopicStatus

+ func (in *Topic) DeepCopy() *Topic

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

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

+ func (t *Topic) NewPatch() client.Patch

+ type TopicList struct

+ Items []Topic

+ func (in *TopicList) DeepCopy() *TopicList

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

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

+ type TopicSpec struct

+ ClusterID string

+ Partitions int32

+ ReplicationFactor int32

+ TopicConfigs map[string]string

+ TopicName string

+ func (in *TopicSpec) DeepCopy() *TopicSpec

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

+ func (ts *TopicSpec) TopicConfigsUpdateToInstAPI() *models.UpdateTopicConfigs

+ type TopicStatus struct

+ ID string

+ TopicConfigs map[string]string

+ func (in *TopicStatus) DeepCopy() *TopicStatus

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

+ func (ts *TopicStatus) FromInstAPI(body []byte) (TopicStatus, error)

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