v1beta1

package
v0.1.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 24, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Overview

Package v1beta1 contains API Schema definitions for the kafkamanagement v1beta1 API group +kubebuilder:object:generate=true +groupName=kafkamanagement.instaclustr.com

Index

Constants

This section is empty.

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "kafkamanagement.instaclustr.com", Version: "v1beta1"}

	// 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

This section is empty.

Types

type ACL 

type ACL struct {
	Principal      string `json:"principal"`
	PermissionType string `json:"permissionType"`
	Host           string `json:"host"`
	PatternType    string `json:"patternType"`
	ResourceName   string `json:"resourceName"`
	Operation      string `json:"operation"`
	ResourceType   string `json:"resourceType"`
}

func (*ACL) DeepCopy 

func (in *ACL) DeepCopy() *ACL

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ACL.

func (*ACL) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CSRTemplate added in v0.1.4 

type CSRTemplate struct {
	Country            string `json:"country"`
	Organization       string `json:"organization"`
	OrganizationalUnit string `json:"organizationalUnit"`
}

func (*CSRTemplate) DeepCopy added in v0.1.4 

func (in *CSRTemplate) DeepCopy() *CSRTemplate

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CSRTemplate.

func (*CSRTemplate) DeepCopyInto added in v0.1.4 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CSRTemplate) ToSubject added in v0.1.4 

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

type Connector 

type Connector struct {
	// Name of the connector. Could be one of [Mirror Connector, Checkpoint Connector].
	Name string `json:"name"`

	// Configuration of the connector.
	Config string `json:"config"`

	// Status of the connector.
	Status string `json:"status"`
}

func (*Connector) DeepCopy 

func (in *Connector) DeepCopy() *Connector

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Connector.

func (*Connector) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ExternalCluster 

type ExternalCluster struct {
	// Kafka connection properties string used to connect to external kafka cluster
	SourceConnectionProperties string `json:"sourceConnectionProperties"`
}

func (*ExternalCluster) DeepCopy 

func (in *ExternalCluster) DeepCopy() *ExternalCluster

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExternalCluster.

func (*ExternalCluster) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type KafkaACL 

type KafkaACL struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   KafkaACLSpec   `json:"spec,omitempty"`
	Status KafkaACLStatus `json:"status,omitempty"`
}

KafkaACL is the Schema for the kafkaacls API

func (*KafkaACL) DeepCopy 

func (in *KafkaACL) DeepCopy() *KafkaACL

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaACL.

func (*KafkaACL) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*KafkaACL) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*KafkaACL) Default added in v0.1.2 

func (r *KafkaACL) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*KafkaACL) GetJobID 

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

func (*KafkaACL) NewPatch 

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

func (*KafkaACL) SetupWebhookWithManager 

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

func (*KafkaACL) ValidateCreate 

func (kacl *KafkaACL) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*KafkaACL) ValidateDelete 

func (kacl *KafkaACL) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*KafkaACL) ValidateUpdate 

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

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type KafkaACLList 

type KafkaACLList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []KafkaACL `json:"items"`
}

KafkaACLList contains a list of KafkaACL

func (*KafkaACLList) DeepCopy 

func (in *KafkaACLList) DeepCopy() *KafkaACLList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaACLList.

func (*KafkaACLList) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*KafkaACLList) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type KafkaACLSpec 

type KafkaACLSpec struct {
	ACLs      []ACL  `json:"acls"`
	UserQuery string `json:"userQuery"`
	ClusterID string `json:"clusterId"`
}

KafkaACLSpec defines the desired state of KafkaACL

func (*KafkaACLSpec) DeepCopy 

func (in *KafkaACLSpec) DeepCopy() *KafkaACLSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaACLSpec.

func (*KafkaACLSpec) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type KafkaACLStatus 

type KafkaACLStatus struct {
	ID string `json:"id,omitempty"`
}

KafkaACLStatus defines the observed state of KafkaACL

func (*KafkaACLStatus) DeepCopy 

func (in *KafkaACLStatus) DeepCopy() *KafkaACLStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaACLStatus.

func (*KafkaACLStatus) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type KafkaUser 

type KafkaUser struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   KafkaUserSpec   `json:"spec,omitempty"`
	Status KafkaUserStatus `json:"status,omitempty"`
}

KafkaUser is the Schema for the kafkausers API

func (*KafkaUser) DeepCopy 

func (in *KafkaUser) DeepCopy() *KafkaUser

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaUser.

func (*KafkaUser) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*KafkaUser) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*KafkaUser) Default added in v0.1.2 

func (r *KafkaUser) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*KafkaUser) GetClusterEvents added in v0.1.3 

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

func (*KafkaUser) GetDeletionFinalizer added in v0.1.1 

func (ku *KafkaUser) GetDeletionFinalizer() string

func (*KafkaUser) GetID added in v0.1.1 

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

func (*KafkaUser) NewCertificateSecret added in v0.1.2 

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

func (*KafkaUser) NewPatch 

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

func (*KafkaUser) SetClusterEvents added in v0.1.3 

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

func (*KafkaUser) SetupWebhookWithManager added in v0.1.2 

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

func (*KafkaUser) ValidateCreate added in v0.1.2 

func (ku *KafkaUser) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*KafkaUser) ValidateDelete added in v0.1.2 

func (ku *KafkaUser) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*KafkaUser) ValidateUpdate added in v0.1.2 

func (ku *KafkaUser) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type KafkaUserList 

type KafkaUserList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []KafkaUser `json:"items"`
}

KafkaUserList contains a list of KafkaUser

func (*KafkaUserList) DeepCopy 

func (in *KafkaUserList) DeepCopy() *KafkaUserList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaUserList.

func (*KafkaUserList) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*KafkaUserList) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type KafkaUserSpec 

type KafkaUserSpec struct {
	// SecretRef references to the secret which stores user's credentials
	SecretRef            *Reference `json:"secretRef"`
	InitialPermissions   string     `json:"initialPermissions"`
	OverrideExistingUser bool       `json:"overrideExistingUser,omitempty"`
	SASLSCRAMMechanism   string     `json:"saslScramMechanism"`
	AuthMechanism        string     `json:"authMechanism"`
}

KafkaUserSpec defines the desired state of KafkaUser

func (*KafkaUserSpec) DeepCopy 

func (in *KafkaUserSpec) DeepCopy() *KafkaUserSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaUserSpec.

func (*KafkaUserSpec) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*KafkaUserSpec) ToInstAPI 

func (ks *KafkaUserSpec) ToInstAPI(clusterID string, username string, password string) *models.KafkaUser

type KafkaUserStatus 

type KafkaUserStatus struct {
	ClustersEvents map[string]string `json:"clustersEvents,omitempty"`
}

KafkaUserStatus defines the observed state of KafkaUser

func (*KafkaUserStatus) DeepCopy 

func (in *KafkaUserStatus) DeepCopy() *KafkaUserStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaUserStatus.

func (*KafkaUserStatus) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ManagedCluster 

type ManagedCluster struct {
	// Whether or not to connect to source cluster's private IP addresses
	UsePrivateIPs bool `json:"usePrivateIps"`

	// Source kafka cluster id
	SourceKafkaClusterID string `json:"sourceKafkaClusterId"`
}

func (*ManagedCluster) DeepCopy 

func (in *ManagedCluster) DeepCopy() *ManagedCluster

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ManagedCluster.

func (*ManagedCluster) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Mirror 

type Mirror struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   MirrorSpec   `json:"spec,omitempty"`
	Status MirrorStatus `json:"status,omitempty"`
}

Mirror is the Schema for the mirrors API

func (*Mirror) DeepCopy 

func (in *Mirror) DeepCopy() *Mirror

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Mirror.

func (*Mirror) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Mirror) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Mirror) Default added in v0.1.2 

func (r *Mirror) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*Mirror) GetJobID 

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

func (*Mirror) NewPatch 

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

func (*Mirror) SetupWebhookWithManager added in v0.1.2 

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

type MirrorList 

type MirrorList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Mirror `json:"items"`
}

MirrorList contains a list of Mirror

func (*MirrorList) DeepCopy 

func (in *MirrorList) DeepCopy() *MirrorList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MirrorList.

func (*MirrorList) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*MirrorList) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type MirrorSpec 

type MirrorSpec struct {

	// The latency in milliseconds above which this mirror will be considered out of sync. It can not be less than 1000ms
	// The suggested initial latency is 30000ms for connectors to be created.
	TargetLatency int32 `json:"targetLatency"`

	// ID of the kafka connect cluster
	KafkaConnectClusterID string `json:"kafkaConnectClusterId"`

	// Maximum number of tasks for Kafka Connect to use. Should be greater than 0
	MaxTasks int32 `json:"maxTasks"`

	// Details to connect to the source kafka cluster
	SourceCluster []*SourceCluster `json:"sourceCluster"`

	// Whether to rename topics as they are mirrored, by prefixing the sourceCluster.alias to the topic name
	RenameMirroredTopics bool `json:"renameMirroredTopics"`

	// Regex to select which topics to mirror
	TopicsRegex string `json:"topicsRegex"`
}

MirrorSpec defines the desired state of Mirror

func (*MirrorSpec) DeepCopy 

func (in *MirrorSpec) DeepCopy() *MirrorSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MirrorSpec.

func (*MirrorSpec) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type MirrorStatus 

type MirrorStatus struct {

	// Detailed list of Connectors for the mirror.
	Connectors []*Connector `json:"connectors,omitempty"`

	// Name of the mirror connector. The value of this property has the form: [source-cluster].[target-cluster].[random-string]
	ConnectorName string `json:"connectorName,omitempty"`

	// ID of the mirror
	ID string `json:"id,omitempty"`

	// Detailed list of Mirrored topics.
	MirroredTopics []*MirroredTopic `json:"mirroredTopics,omitempty"`

	// The latency in milliseconds above which this mirror will be considered out of sync.
	TargetLatency int32 `json:"targetLatency,omitempty"`

	// The overall status of this mirror.
	Status string `json:"status,omitempty"`
}

MirrorStatus defines the observed state of Mirror

func (*MirrorStatus) DeepCopy 

func (in *MirrorStatus) DeepCopy() *MirrorStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MirrorStatus.

func (*MirrorStatus) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*MirrorStatus) IsEqual 

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

type MirroredTopic 

type MirroredTopic struct {
	// Average latency in milliseconds for messages to travel from source to destination topics.
	AverageLatency resource.Quantity `json:"averageLatency"`

	// Average record rate for messages to travel from source to destination topics, it is 0 if there are no messages travelling in between.
	AverageRate resource.Quantity `json:"averageRate"`

	// Name of the mirrored topic.
	Name string `json:"name"`
}

func (*MirroredTopic) DeepCopy 

func (in *MirroredTopic) DeepCopy() *MirroredTopic

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MirroredTopic.

func (*MirroredTopic) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Reference added in v0.1.4 

type Reference = apiextensions.ObjectReference

+kubebuilder:object:generate:=false

type SourceCluster 

type SourceCluster struct {
	// Alias to use for the source kafka cluster. This will be used to rename topics if renameMirroredTopics is turned on
	Alias string `json:"alias"`

	// Details to connect to a Non-Instaclustr managed cluster. Cannot be provided if targeting an Instaclustr managed cluster
	ExternalCluster []*ExternalCluster `json:"externalCluster,omitempty"`

	// Details to connect to a Instaclustr managed cluster. Cannot be provided if targeting a non-Instaclustr managed cluster
	ManagedCluster []*ManagedCluster `json:"managedCluster,omitempty"`
}

func (*SourceCluster) DeepCopy 

func (in *SourceCluster) DeepCopy() *SourceCluster

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SourceCluster.

func (*SourceCluster) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Topic 

type Topic struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   TopicSpec   `json:"spec,omitempty"`
	Status TopicStatus `json:"status,omitempty"`
}

Topic is the Schema for the topics API

func (*Topic) DeepCopy 

func (in *Topic) DeepCopy() *Topic

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Topic.

func (*Topic) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Topic) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Topic) Default added in v0.1.2 

func (r *Topic) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*Topic) NewPatch 

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

func (*Topic) SetupWebhookWithManager added in v0.1.2 

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

type TopicList 

type TopicList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Topic `json:"items"`
}

TopicList contains a list of Topic

func (*TopicList) DeepCopy 

func (in *TopicList) DeepCopy() *TopicList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicList.

func (*TopicList) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*TopicList) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type TopicSpec 

type TopicSpec struct {
	Partitions        int32             `json:"partitions"`
	ReplicationFactor int32             `json:"replicationFactor"`
	TopicName         string            `json:"topic"`
	ClusterID         string            `json:"clusterId"`
	TopicConfigs      map[string]string `json:"configs,omitempty"`
}

TopicSpec defines the desired state of Topic

func (*TopicSpec) DeepCopy 

func (in *TopicSpec) DeepCopy() *TopicSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicSpec.

func (*TopicSpec) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*TopicSpec) TopicConfigsUpdateToInstAPI 

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

type TopicStatus 

type TopicStatus struct {

	// ID for the Kafka topic. The value of this property has the form: [cluster-id]_[kafka-topic]
	ID string `json:"id"`

	TopicConfigs map[string]string `json:"configs,omitempty"`
}

TopicStatus defines the observed state of Topic

func (*TopicStatus) DeepCopy 

func (in *TopicStatus) DeepCopy() *TopicStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicStatus.

func (*TopicStatus) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*TopicStatus) FromInstAPI 

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

type UserCertificate added in v0.1.4 

type UserCertificate struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   UserCertificateSpec   `json:"spec,omitempty"`
	Status UserCertificateStatus `json:"status,omitempty"`
}

UserCertificate is the Schema for the usercertificates API

func (*UserCertificate) DeepCopy added in v0.1.4 

func (in *UserCertificate) DeepCopy() *UserCertificate

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UserCertificate.

func (*UserCertificate) DeepCopyInto added in v0.1.4 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*UserCertificate) DeepCopyObject added in v0.1.4 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*UserCertificate) NewPatch added in v0.1.4 

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

func (*UserCertificate) SetupWebhookWithManager added in v0.1.4 

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

func (*UserCertificate) ValidateCreate added in v0.1.4 

func (cert *UserCertificate) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*UserCertificate) ValidateDelete added in v0.1.4 

func (cert *UserCertificate) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*UserCertificate) ValidateUpdate added in v0.1.4 

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

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type UserCertificateList added in v0.1.4 

type UserCertificateList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []UserCertificate `json:"items"`
}

UserCertificateList contains a list of UserCertificate

func (*UserCertificateList) DeepCopy added in v0.1.4 

func (in *UserCertificateList) DeepCopy() *UserCertificateList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UserCertificateList.

func (*UserCertificateList) DeepCopyInto added in v0.1.4 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*UserCertificateList) DeepCopyObject added in v0.1.4 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type UserCertificateSpec added in v0.1.4 

type UserCertificateSpec struct {
	// SecretRef references to the secret which stores pre-generated certificate request.
	// +kubebuilder:validation:XValidation:message="Cannot be changed after it is set",rule="self == oldSelf"
	SecretRef *apiextensions.ObjectFieldReference `json:"secretRef,omitempty"`

	// UserRef references to the KafkaUser resource to whom a certificate will be created.
	// +kubebuilder:validation:XValidation:message="Cannot be changed after it is set",rule="self == oldSelf"
	UserRef Reference `json:"userRef"`

	// ClusterRef references to the Kafka resource to whom a certificate will be created.
	// +kubebuilder:validation:XValidation:message="Cannot be changed after it is set",rule="self == oldSelf"
	ClusterRef Reference `json:"clusterRef"`

	// ValidPeriod is amount of month until a signed certificate is expired.
	// +kubebuilder:validation:Min=3
	// +kubebuilder:validation:Max=120
	// +kubebuilder:validation:XValidation:message="Cannot be changed after it is set",rule="self == oldSelf"
	ValidPeriod int `json:"validPeriod"`

	// CertificateRequestTemplate is a template for generating a CSR.
	// +kubebuilder:validation:XValidation:message="Cannot be changed after it is set",rule="self == oldSelf"
	CertificateRequestTemplate *CSRTemplate `json:"certificateRequestTemplate,omitempty"`
}

UserCertificateSpec defines the desired state of UserCertificateSpec

func (*UserCertificateSpec) DeepCopy added in v0.1.4 

func (in *UserCertificateSpec) DeepCopy() *UserCertificateSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UserCertificateSpec.

func (*UserCertificateSpec) DeepCopyInto added in v0.1.4 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type UserCertificateStatus added in v0.1.4 

type UserCertificateStatus struct {
	// CertID is a unique identifier of a certificate on Instaclustr.
	CertID string `json:"certId,omitempty"`

	// ExpiryDate is a date when a signed certificate is expired.
	ExpiryDate string `json:"expiryDate,omitempty"`

	// SignedCertSecretRef references to a secret which stores signed cert.
	SignedCertSecretRef Reference `json:"signedCertSecretRef,omitempty"`
}

UserCertificateStatus defines the observed state of UserCertificateStatus

func (*UserCertificateStatus) DeepCopy added in v0.1.4 

func (in *UserCertificateStatus) DeepCopy() *UserCertificateStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UserCertificateStatus.

func (*UserCertificateStatus) DeepCopyInto added in v0.1.4 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.