v1alpha1

package
v0.47.0-rc.2 Latest Latest
Warning

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

 Go to latest Published: Aug 2, 2024 License: Apache-2.0 Imports: 40 Imported by: 5

Documentation

Overview

+k8s:deepcopy-gen=package,register +k8s:openapi-gen=true +k8s:defaulter-gen=TypeMeta +groupName=kafka.kubedb.com

Index

Constants

View Source 
const (
	ResourceCodeConnectCluster     = "kcc"
	ResourceKindConnectCluster     = "ConnectCluster"
	ResourceSingularConnectCluster = "connectcluster"
	ResourcePluralConnectCluster   = "connectclusters"
)
View Source 
const (
	ResourceCodeConnector     = "kc"
	ResourceKindConnector     = "Connector"
	ResourceSingularConnector = "connector"
	ResourcePluralConnector   = "connectors"
)
View Source 
const (
	LabelRole = kafka.GroupName + "/role"
	RoleStats = "stats"

	ComponentKafka   = "kafka"
	DefaultStatsPath = "/metrics"
)
View Source 
const (
	ConnectClusterUser            = "connect"
	ConnectClusterContainerName   = "connect-cluster"
	ConnectClusterModeEnv         = "CONNECT_CLUSTER_MODE"
	ConnectClusterPrimaryPortName = "primary"
	ConnectClusterPortName        = "connect"
	ConnectClusterRESTPort        = 8083
	ConnectClusterUserEnv         = "CONNECT_CLUSTER_USER"
	ConnectClusterPasswordEnv     = "CONNECT_CLUSTER_PASSWORD"

	ConnectClusterOperatorVolumeConfig = "connect-operator-config"
	ConnectClusterCustomVolumeConfig   = "connect-custom-config"
	ConnectorPluginsVolumeName         = "connector-plugins"
	ConnectClusterAuthSecretVolumeName = "connect-cluster-auth"
	ConnectClusterOffsetFileDirName    = "connect-stand-offset"

	ConnectClusterGroupID                     = "group.id"
	ConnectClusterPluginPath                  = "plugin.path"
	ConnectClusterRestAdvertisedHostName      = "rest.advertised.host.name"
	ConnectClusterRestAdvertisedPort          = "rest.advertised.port"
	ConnectClusterOffsetStorage               = "offset.storage.file.filename"
	ConnectClusterKeyConverter                = "key.converter"
	ConnectClusterValueConverter              = "value.converter"
	ConnectClusterKeyConverterSchemasEnable   = "key.converter.schemas.enable"
	ConnectClusterValueConverterSchemasEnable = "value.converter.schemas.enable"
	ConnectClusterJsonConverterName           = "org.apache.kafka.connect.json.JsonConverter"
	ConnectClusterStatusStorageTopic          = "status.storage.topic"
	ConnectClusterConfigStorageTopic          = "config.storage.topic"
	ConnectClusterOffsetStorageTopic          = "offset.storage.topic"
	ConnectClusterBootstrapServers            = "bootstrap.servers"
	ConnectClusterStatusStorageTopicName      = "connect-status"
	ConnectClusterConfigStorageTopicName      = "connect-configs"
	ConnectClusterOffsetStorageTopicName      = "connect-offsets"

	ConnectClusterListeners               = "listeners"
	ConnectClusterServerCertsVolumeName   = "server-certs"
	KafkaClientCertVolumeName             = "kafka-client-ssl"
	KafkaClientKeystoreKey                = "client.keystore.jks"
	KafkaClientTruststoreKey              = "client.truststore.jks"
	ConnectClusterBasicAuthKey            = "rest.extension.classes"
	KafkaConnectRestAdvertisedListener    = "rest.advertised.listener"
	ConnectClusterKeyPassword             = "listeners.https.ssl.key.password"
	ConnectClusterKeystorePassword        = "listeners.https.ssl.keystore.password"
	ConnectClusterKeystoreLocation        = "listeners.https.ssl.keystore.location"
	ConnectClusterTruststoreLocation      = "listeners.https.ssl.truststore.location"
	ConnectClusterTruststorePassword      = "listeners.https.ssl.truststore.password"
	ConnectClusterClientAuthentication    = "listeners.https.ssl.client.authentication"
	ConnectClusterIdentificationAlgorithm = "listeners.https.ssl.endpoint.identification.algorithm"
	ConnectClusterBasicAuthValue          = "org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension"

	ConnectClusterOffsetFileDir        = "/var/log/connect"
	ConnectClusterServerCertVolumeDir  = "/var/private/ssl"
	ConnectClusterPluginPathDir        = "/opt/kafka/libs"
	ConnectClusterAuthSecretVolumePath = "/var/private/basic-auth"
	KafkaClientCertDir                 = "/var/private/kafka-client-ssl"
	ConnectClusterOffsetFileName       = "/var/log/connect/connect.offsets"
	ConnectorPluginsVolumeDir          = "/opt/kafka/libs/connector-plugins"
	ConnectClusterCustomConfigPath     = "/opt/kafka/config/connect-custom-config"
	ConnectClusterOperatorConfigPath   = "/opt/kafka/config/connect-operator-config"
	KafkaClientKeystoreLocation        = "/var/private/kafka-client-ssl/client.keystore.jks"
	KafkaClientTruststoreLocation      = "/var/private/kafka-client-ssl/client.truststore.jks"
)
View Source 
const (
	SchemaRegistryPrimaryPortName = "primary"
	SchemaRegistryPortName        = "registry"
	ApicurioRegistryRESTPort      = 8080
	SchemaRegistryContainerName   = "schema-registry"
	SchemaRegistryConfigFileName  = "application.properties"

	SchemaRegistryStorageBackendTypeMemory = "mem"
	SchemaRegistryStorageBackendTypeKafka  = "kafkasql"
	SchemaRegistryStorageBackendTypeSQL    = "sql"

	SchemaRegistryOperatorVolumeConfig = "registry-operator-config"
	SchemaRegistryOperatorConfigPath   = "/deployments/config"
)
View Source 
const (
	RestProxyPrimaryPortName      = "primary"
	RestProxyPortName             = "restproxy"
	RestProxyRESTPort             = 8082
	RestProxyContainerName        = "rest-proxy"
	RestProxyOperatorVolumeConfig = "rest-proxy-operator-config"
	RestProxyOperatorConfigPath   = "/opt/karapace/config"

	RestProxyKarapaceLogLevel          = "log_level"
	RestProxyKarapaceLogLevelWarning   = "WARNING"
	RestProxyKarapaceLogLevelInfo      = "INFO"
	RestProxyKarapaceLogLevelDebug     = "DEBUG"
	RestProxyKarapaceHostName          = "host"
	RestProxyKarapacePortName          = "port"
	RestProxyKafkaBootstrapURI         = "bootstrap_uri"
	RestProxyKafkaSecurityProtocolName = "security_protocol"
	RestProxyKafkaSASLMechanismName    = "sasl_mechanism"
	RestProxyKafkaSASLUsername         = "sasl_plain_username"
	RestProxyKafkaSASLPassword         = "sasl_plain_password"
	RestProxyKafkaSSLCAFile            = "ssl_cafile"
	RestProxyKafkaSSLCertFile          = "ssl_certfile"
	RestProxyKafkaSSLKeyFile           = "ssl_keyfile"
	RestProxyKafkaSSLCAFilePath        = "/var/private/kafka-client-ssl/ca.crt"
	RestProxyKafkaSSLCertFilePath      = "/var/private/kafka-client-ssl/tls.crt"
	RestProxyKafkaSSLKeyFilePath       = "/var/private/kafka-client-ssl/tls.key"
	RestProxyConfigFileName            = "rest.config.json"
)
View Source 
const (
	ResourceCodeRestProxy     = "krp"
	ResourceKindRestProxy     = "RestProxy"
	ResourceSingularRestProxy = "restproxy"
	ResourcePluralRestProxy   = "restproxies"
)
View Source 
const (
	ResourceCodeSchemaRegistry     = "ksr"
	ResourceKindSchemaRegistry     = "SchemaRegistry"
	ResourceSingularSchemaRegistry = "schemaregistry"
	ResourcePluralSchemaRegistry   = "schemaregistries"
)
View Source 
const (
	Finalizer = kafka.GroupName + "/finalizer"
)

Variables

View Source 
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
)
View Source 
var (
	DefaultClient client.Client
)
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: kafka.GroupName, Version: "v1alpha1"}

Functions

func GetOpenAPIDefinitions 

func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition

func Kind 

func Kind(kind string) schema.GroupKind

Kind takes an unqualified kind and returns a Group qualified GroupKind

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

func SetDefaultClient 

func SetDefaultClient(kc client.Client)

Types

type ConnectCluster 

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

	Spec   ConnectClusterSpec   `json:"spec,omitempty"`
	Status ConnectClusterStatus `json:"status,omitempty"`
}

+kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:resource:shortName=kcc,scope=Namespaced +kubebuilder:printcolumn:name="Type",type="string",JSONPath=".apiVersion" +kubebuilder:printcolumn:name="Version",type="string",JSONPath=".spec.version" +kubebuilder:printcolumn:name="Status",type="string",JSONPath=".status.phase" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp"

func (*ConnectCluster) AppBindingMeta 

func (k *ConnectCluster) AppBindingMeta() appcat.AppBindingMeta

func (*ConnectCluster) AsOwner 

func (k *ConnectCluster) AsOwner() *meta.OwnerReference

func (*ConnectCluster) CertSecretVolumeMountPath 

func (k *ConnectCluster) CertSecretVolumeMountPath(configDir string, cert string) string

returns CertSecretVolumeMountPath if configDir is "/opt/kafka/config", mountPath will be, "/opt/kafka/config/<alias>".

func (*ConnectCluster) CertificateName 

func (k *ConnectCluster) CertificateName(alias ConnectClusterCertificateAlias) string

CertificateName returns the default certificate name and/or certificate secret name for a certificate alias

func (*ConnectCluster) ConfigSecretName 

func (k *ConnectCluster) ConfigSecretName() string

func (*ConnectCluster) CustomResourceDefinition 

func (k *ConnectCluster) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

func (*ConnectCluster) DeepCopy 

func (in *ConnectCluster) DeepCopy() *ConnectCluster

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

func (*ConnectCluster) DeepCopyInto 

func (in *ConnectCluster) DeepCopyInto(out *ConnectCluster)

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

func (*ConnectCluster) DeepCopyObject 

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

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

func (*ConnectCluster) Default 

func (k *ConnectCluster) Default()

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

func (*ConnectCluster) DefaultKeystoreCredSecretName 

func (k *ConnectCluster) DefaultKeystoreCredSecretName() string

func (*ConnectCluster) DefaultUserCredSecretName 

func (k *ConnectCluster) DefaultUserCredSecretName(username string) string

func (*ConnectCluster) GetCertSecretName 

func (k *ConnectCluster) GetCertSecretName(alias ConnectClusterCertificateAlias) string

GetCertSecretName returns the secret name for a certificate alias if any, otherwise returns default certificate secret name for the given alias.

func (*ConnectCluster) GetConnectionScheme 

func (k *ConnectCluster) GetConnectionScheme() string

func (*ConnectCluster) GetPersistentSecrets 

func (k *ConnectCluster) GetPersistentSecrets() []string

func (*ConnectCluster) GetServiceTemplate 

func (k *ConnectCluster) GetServiceTemplate(templates []dbapi.NamedServiceTemplateSpec, alias dbapi.ServiceAlias) ofst.ServiceTemplateSpec

GetServiceTemplate returns a pointer to the desired serviceTemplate referred by "aliaS". Otherwise, it returns nil.

func (*ConnectCluster) GoverningServiceName 

func (k *ConnectCluster) GoverningServiceName() string

func (*ConnectCluster) KafkaClientCredentialsSecretName 

func (k *ConnectCluster) KafkaClientCredentialsSecretName() string

func (*ConnectCluster) OffshootLabels 

func (k *ConnectCluster) OffshootLabels() map[string]string

func (*ConnectCluster) OffshootName 

func (k *ConnectCluster) OffshootName() string

func (*ConnectCluster) OffshootSelectors 

func (k *ConnectCluster) OffshootSelectors(extraSelectors ...map[string]string) map[string]string

func (*ConnectCluster) Owner 

func (k *ConnectCluster) Owner() *meta.OwnerReference

Owner returns owner reference to resources

func (*ConnectCluster) PetSetName added in v0.47.0 

func (k *ConnectCluster) PetSetName() string

func (*ConnectCluster) PodControllerLabels 

func (k *ConnectCluster) PodControllerLabels(extraLabels ...map[string]string) map[string]string

func (*ConnectCluster) PodLabels 

func (k *ConnectCluster) PodLabels(extraLabels ...map[string]string) map[string]string

func (*ConnectCluster) ResourceFQN 

func (k *ConnectCluster) ResourceFQN() string

func (*ConnectCluster) ResourceKind 

func (k *ConnectCluster) ResourceKind() string

func (*ConnectCluster) ResourcePlural 

func (k *ConnectCluster) ResourcePlural() string

func (*ConnectCluster) ResourceShortCode 

func (k *ConnectCluster) ResourceShortCode() string

func (*ConnectCluster) ResourceSingular 

func (k *ConnectCluster) ResourceSingular() string

func (*ConnectCluster) ServiceLabels 

func (k *ConnectCluster) ServiceLabels(alias dbapi.ServiceAlias, extraLabels ...map[string]string) map[string]string

func (*ConnectCluster) ServiceName 

func (k *ConnectCluster) ServiceName() string

func (*ConnectCluster) SetDefaultEnvs 

func (k *ConnectCluster) SetDefaultEnvs()

func (*ConnectCluster) SetDefaults 

func (k *ConnectCluster) SetDefaults()

func (*ConnectCluster) SetHealthCheckerDefaults 

func (k *ConnectCluster) SetHealthCheckerDefaults()

func (*ConnectCluster) SetTLSDefaults 

func (k *ConnectCluster) SetTLSDefaults()

func (*ConnectCluster) StatsService 

func (k *ConnectCluster) StatsService() mona.StatsAccessor

func (*ConnectCluster) StatsServiceLabels 

func (k *ConnectCluster) StatsServiceLabels() map[string]string

func (*ConnectCluster) ValidateCreate 

func (k *ConnectCluster) ValidateCreate() (admission.Warnings, error)

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

func (*ConnectCluster) ValidateCreateOrUpdate 

func (k *ConnectCluster) ValidateCreateOrUpdate() field.ErrorList

func (*ConnectCluster) ValidateDelete 

func (k *ConnectCluster) ValidateDelete() (admission.Warnings, error)

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

func (*ConnectCluster) ValidateUpdate 

func (k *ConnectCluster) ValidateUpdate(old runtime.Object) (admission.Warnings, error)

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

type ConnectClusterApp 

type ConnectClusterApp struct {
	*ConnectCluster
}

func (*ConnectClusterApp) DeepCopy 

func (in *ConnectClusterApp) DeepCopy() *ConnectClusterApp

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

func (*ConnectClusterApp) DeepCopyInto 

func (in *ConnectClusterApp) DeepCopyInto(out *ConnectClusterApp)

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

func (ConnectClusterApp) Name 

func (r ConnectClusterApp) Name() string

func (ConnectClusterApp) Type 

func (r ConnectClusterApp) Type() appcat.AppType

type ConnectClusterCertificateAlias 

type ConnectClusterCertificateAlias string

+kubebuilder:validation:Enum=ca;transport;http;client;server 

const (
	ConnectClusterCACert        ConnectClusterCertificateAlias = "ca"
	ConnectClusterTransportCert ConnectClusterCertificateAlias = "transport"
	ConnectClusterHTTPCert      ConnectClusterCertificateAlias = "http"
	ConnectClusterClientCert    ConnectClusterCertificateAlias = "client"
	ConnectClusterServerCert    ConnectClusterCertificateAlias = "server"
)

type ConnectClusterList 

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

ConnectClusterList contains a list of ConnectCluster

func (*ConnectClusterList) DeepCopy 

func (in *ConnectClusterList) DeepCopy() *ConnectClusterList

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

func (*ConnectClusterList) DeepCopyInto 

func (in *ConnectClusterList) DeepCopyInto(out *ConnectClusterList)

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

func (*ConnectClusterList) DeepCopyObject 

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

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

type ConnectClusterNodeRoleType 

type ConnectClusterNodeRoleType string

+kubebuilder:validation:Enum=statndalone;distributed 

const (
	ConnectClusterNodeRoleStandalone  ConnectClusterNodeRoleType = "standalone"
	ConnectClusterNodeRoleDistributed ConnectClusterNodeRoleType = "distributed"
)

type ConnectClusterPhase 

type ConnectClusterPhase string

+kubebuilder:validation:Enum=Provisioning;Ready;NotReady;Critical;Unknown 

const (
	ConnectClusterPhaseProvisioning ConnectClusterPhase = "Provisioning"
	ConnectClusterPhaseReady        ConnectClusterPhase = "Ready"
	ConnectClusterPhaseNotReady     ConnectClusterPhase = "NotReady"
	ConnectClusterPhaseCritical     ConnectClusterPhase = "Critical"
	ConnectClusterPhaseUnknown      ConnectClusterPhase = "Unknown"
)

type ConnectClusterSpec 

type ConnectClusterSpec struct {
	// Version of ConnectCluster to be deployed.
	Version string `json:"version"`

	// Number of instances to deploy for a Kafka database.
	// +optional
	Replicas *int32 `json:"replicas,omitempty"`

	// Kafka app-binding reference
	// KafkaRef is a required field, where ConnectCluster will store its metadata
	KafkaRef *kmapi.ObjectReference `json:"kafkaRef"`

	// disable security. It disables authentication security of user.
	// If unset, default is false
	// +optional
	DisableSecurity bool `json:"disableSecurity,omitempty"`

	// kafka connect cluster authentication secret
	// +optional
	AuthSecret *dbapi.SecretReference `json:"authSecret,omitempty"`

	// To enable https
	EnableSSL bool `json:"enableSSL,omitempty"`

	// Keystore encryption secret
	// +optional
	KeystoreCredSecret *dbapi.SecretReference `json:"keystoreCredSecret,omitempty"`

	// TLS contains tls configurations
	// +optional
	TLS *kmapi.TLSConfig `json:"tls,omitempty"`

	// List of connector-plugins
	ConnectorPlugins []string `json:"connectorPlugins,omitempty"`

	// ConfigSecret is an optional field to provide custom configuration file for kafka connect cluster (i.e distributed.properties).
	// If specified, this file will be used as configuration file otherwise default configuration file will be used.
	// +optional
	ConfigSecret *core.LocalObjectReference `json:"configSecret,omitempty"`

	// PodTemplate is an optional configuration for pods used to expose database
	// +optional
	PodTemplate ofst.PodTemplateSpec `json:"podTemplate,omitempty"`

	// ServiceTemplates is an optional configuration for services used to expose database
	// +optional
	ServiceTemplates []dbapi.NamedServiceTemplateSpec `json:"serviceTemplates,omitempty"`

	// DeletionPolicy controls the delete operation for database
	// +optional
	DeletionPolicy dbapi.DeletionPolicy `json:"deletionPolicy,omitempty"`

	// HealthChecker defines attributes of the health checker
	// +optional
	// +kubebuilder:default={periodSeconds: 20, timeoutSeconds: 10, failureThreshold: 3}
	HealthChecker kmapi.HealthCheckSpec `json:"healthChecker"`

	// Monitor is used monitor database instance
	// +optional
	Monitor *mona.AgentSpec `json:"monitor,omitempty"`
}

ConnectClusterSpec defines the desired state of ConnectCluster

func (*ConnectClusterSpec) DeepCopy 

func (in *ConnectClusterSpec) DeepCopy() *ConnectClusterSpec

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

func (*ConnectClusterSpec) DeepCopyInto 

func (in *ConnectClusterSpec) DeepCopyInto(out *ConnectClusterSpec)

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

type ConnectClusterStatus 

type ConnectClusterStatus struct {
	// Specifies the current phase of the database
	// +optional
	Phase ConnectClusterPhase `json:"phase,omitempty"`
	// observedGeneration is the most recent generation observed for this resource. It corresponds to the
	// resource's generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// Conditions applied to the database, such as approval or denial.
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

ConnectClusterStatus defines the observed state of ConnectCluster

func (*ConnectClusterStatus) DeepCopy 

func (in *ConnectClusterStatus) DeepCopy() *ConnectClusterStatus

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

func (*ConnectClusterStatus) DeepCopyInto 

func (in *ConnectClusterStatus) DeepCopyInto(out *ConnectClusterStatus)

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

type Connector 

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

	Spec   ConnectorSpec   `json:"spec,omitempty"`
	Status ConnectorStatus `json:"status,omitempty"`
}

+kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:resource:shortName=kc,scope=Namespaced +kubebuilder:printcolumn:name="Type",type="string",JSONPath=".apiVersion" +kubebuilder:printcolumn:name="ConnectCluster",type="string",JSONPath=".spec.connectClusterRef.name" +kubebuilder:printcolumn:name="Status",type="string",JSONPath=".status.phase" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp"

func (*Connector) AsOwner 

func (k *Connector) AsOwner() *meta.OwnerReference

func (*Connector) CustomResourceDefinition 

func (_ *Connector) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

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.

func (*Connector) DeepCopyObject 

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

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

func (*Connector) Default 

func (k *Connector) Default()

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

func (*Connector) OffshootName 

func (k *Connector) OffshootName() string

func (*Connector) Owner 

func (k *Connector) Owner() *meta.OwnerReference

Owner returns owner reference to resources

func (*Connector) ResourceFQN 

func (k *Connector) ResourceFQN() string

func (*Connector) ResourceKind 

func (k *Connector) ResourceKind() string

func (*Connector) ResourcePlural 

func (k *Connector) ResourcePlural() string

func (*Connector) ResourceShortCode 

func (k *Connector) ResourceShortCode() string

func (*Connector) ResourceSingular 

func (k *Connector) ResourceSingular() string

func (*Connector) ValidateCreate 

func (k *Connector) ValidateCreate() (admission.Warnings, error)

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

func (*Connector) ValidateCreateOrUpdate 

func (k *Connector) ValidateCreateOrUpdate() error

func (*Connector) ValidateDelete 

func (k *Connector) ValidateDelete() (admission.Warnings, error)

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

func (*Connector) ValidateUpdate 

func (k *Connector) ValidateUpdate(old runtime.Object) (admission.Warnings, error)

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

type ConnectorList 

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

ConnectorList contains a list of Connector

func (*ConnectorList) DeepCopy 

func (in *ConnectorList) DeepCopy() *ConnectorList

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

func (*ConnectorList) DeepCopyInto 

func (in *ConnectorList) DeepCopyInto(out *ConnectorList)

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

func (*ConnectorList) DeepCopyObject 

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

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

type ConnectorPhase 

type ConnectorPhase string

+kubebuilder:validation:Enum=Pending;Unassigned;Running;Paused;Failed;Restarting;Stopped;Destroyed;Unknown 

const (
	ConnectorPhasePending    ConnectorPhase = "Pending"
	ConnectorPhaseUnassigned ConnectorPhase = "Unassigned"
	ConnectorPhaseRunning    ConnectorPhase = "Running"
	ConnectorPhasePaused     ConnectorPhase = "Paused"
	ConnectorPhaseFailed     ConnectorPhase = "Failed"
	ConnectorPhaseRestarting ConnectorPhase = "Restarting"
	ConnectorPhaseStopped    ConnectorPhase = "Stopped"
	ConnectorPhaseDestroyed  ConnectorPhase = "Destroyed"
	ConnectorPhaseUnknown    ConnectorPhase = "Unknown"
)

type ConnectorSpec 

type ConnectorSpec struct {
	// Kafka connect cluster app-binding reference
	// ConnectClusterRef is a required field, where Connector will add tasks to produce or consume data from kafka topics.
	ConnectClusterRef *kmapi.ObjectReference `json:"connectClusterRef"`

	// ConfigSecret is a required field to provide configuration file for Connector to create connectors for Kafka connect cluster(i.e connector.properties).
	ConfigSecret *core.LocalObjectReference `json:"configSecret"`

	// DeletionPolicy controls the delete operation for database
	// +optional
	DeletionPolicy dbapi.DeletionPolicy `json:"deletionPolicy,omitempty"`
}

ConnectorSpec defines the desired state of Connector

func (*ConnectorSpec) DeepCopy 

func (in *ConnectorSpec) DeepCopy() *ConnectorSpec

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

func (*ConnectorSpec) DeepCopyInto 

func (in *ConnectorSpec) DeepCopyInto(out *ConnectorSpec)

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

type ConnectorStatus 

type ConnectorStatus struct {
	// Specifies the current phase of the Connector
	// +optional
	Phase ConnectorPhase `json:"phase,omitempty"`
	// observedGeneration is the most recent generation observed for this resource. It corresponds to the
	// resource's generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// Conditions applied to the Connector, such as approval or denial.
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

ConnectorStatus defines the observed state of connectors

func (*ConnectorStatus) DeepCopy 

func (in *ConnectorStatus) DeepCopy() *ConnectorStatus

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

func (*ConnectorStatus) DeepCopyInto 

func (in *ConnectorStatus) DeepCopyInto(out *ConnectorStatus)

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

type RestProxy added in v0.47.0 

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

	Spec   RestProxySpec   `json:"spec,omitempty"`
	Status RestProxyStatus `json:"status,omitempty"`
}

+kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:resource:shortName=krp,scope=Namespaced +kubebuilder:printcolumn:name="Type",type="string",JSONPath=".apiVersion" +kubebuilder:printcolumn:name="Version",type="string",JSONPath=".spec.version" +kubebuilder:printcolumn:name="Kafka",type="string",JSONPath=".spec.kafkaRef.name" +kubebuilder:printcolumn:name="Status",type="string",JSONPath=".status.phase" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp"

func (*RestProxy) AppBindingMeta added in v0.47.0 

func (k *RestProxy) AppBindingMeta() appcat.AppBindingMeta

func (*RestProxy) AsOwner added in v0.47.0 

func (k *RestProxy) AsOwner() *meta.OwnerReference

func (*RestProxy) ConfigSecretName added in v0.47.0 

func (k *RestProxy) ConfigSecretName() string

func (*RestProxy) CustomResourceDefinition added in v0.47.0 

func (k *RestProxy) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

func (*RestProxy) DeepCopy added in v0.47.0 

func (in *RestProxy) DeepCopy() *RestProxy

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

func (*RestProxy) DeepCopyInto added in v0.47.0 

func (in *RestProxy) DeepCopyInto(out *RestProxy)

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

func (*RestProxy) DeepCopyObject added in v0.47.0 

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

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

func (*RestProxy) Default added in v0.47.0 

func (k *RestProxy) Default()

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

func (*RestProxy) GetConnectionScheme added in v0.47.0 

func (k *RestProxy) GetConnectionScheme() string

func (*RestProxy) GetPersistentSecrets added in v0.47.0 

func (k *RestProxy) GetPersistentSecrets() []string

func (*RestProxy) GetServiceTemplate added in v0.47.0 

func (k *RestProxy) GetServiceTemplate(templates []dbapi.NamedServiceTemplateSpec, alias dbapi.ServiceAlias) ofst.ServiceTemplateSpec

GetServiceTemplate returns a pointer to the desired serviceTemplate referred by "aliaS". Otherwise, it returns nil.

func (*RestProxy) GoverningServiceName added in v0.47.0 

func (k *RestProxy) GoverningServiceName() string

func (*RestProxy) KafkaClientCredentialsSecretName added in v0.47.0 

func (k *RestProxy) KafkaClientCredentialsSecretName() string

func (*RestProxy) OffshootLabels added in v0.47.0 

func (k *RestProxy) OffshootLabels() map[string]string

func (*RestProxy) OffshootName added in v0.47.0 

func (k *RestProxy) OffshootName() string

func (*RestProxy) OffshootSelectors added in v0.47.0 

func (k *RestProxy) OffshootSelectors(extraSelectors ...map[string]string) map[string]string

func (*RestProxy) Owner added in v0.47.0 

func (k *RestProxy) Owner() *meta.OwnerReference

Owner returns owner reference to resources

func (*RestProxy) PetSetName added in v0.47.0 

func (k *RestProxy) PetSetName() string

func (*RestProxy) PodControllerLabels added in v0.47.0 

func (k *RestProxy) PodControllerLabels(extraLabels ...map[string]string) map[string]string

func (*RestProxy) PodLabels added in v0.47.0 

func (k *RestProxy) PodLabels(extraLabels ...map[string]string) map[string]string

func (*RestProxy) ResourceFQN added in v0.47.0 

func (k *RestProxy) ResourceFQN() string

func (*RestProxy) ResourceKind added in v0.47.0 

func (k *RestProxy) ResourceKind() string

func (*RestProxy) ResourcePlural added in v0.47.0 

func (k *RestProxy) ResourcePlural() string

func (*RestProxy) ResourceShortCode added in v0.47.0 

func (k *RestProxy) ResourceShortCode() string

func (*RestProxy) ResourceSingular added in v0.47.0 

func (k *RestProxy) ResourceSingular() string

func (*RestProxy) ServiceLabels added in v0.47.0 

func (k *RestProxy) ServiceLabels(alias dbapi.ServiceAlias, extraLabels ...map[string]string) map[string]string

func (*RestProxy) ServiceName added in v0.47.0 

func (k *RestProxy) ServiceName() string

func (*RestProxy) SetDefaults added in v0.47.0 

func (k *RestProxy) SetDefaults()

func (*RestProxy) SetHealthCheckerDefaults added in v0.47.0 

func (k *RestProxy) SetHealthCheckerDefaults()

func (*RestProxy) ValidateCreate added in v0.47.0 

func (k *RestProxy) ValidateCreate() (admission.Warnings, error)

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

func (*RestProxy) ValidateCreateOrUpdate added in v0.47.0 

func (k *RestProxy) ValidateCreateOrUpdate() field.ErrorList

func (*RestProxy) ValidateDelete added in v0.47.0 

func (k *RestProxy) ValidateDelete() (admission.Warnings, error)

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

func (*RestProxy) ValidateUpdate added in v0.47.0 

func (k *RestProxy) ValidateUpdate(old runtime.Object) (admission.Warnings, error)

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

type RestProxyApp added in v0.47.0 

type RestProxyApp struct {
	*RestProxy
}

func (*RestProxyApp) DeepCopy added in v0.47.0 

func (in *RestProxyApp) DeepCopy() *RestProxyApp

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

func (*RestProxyApp) DeepCopyInto added in v0.47.0 

func (in *RestProxyApp) DeepCopyInto(out *RestProxyApp)

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

func (RestProxyApp) Name added in v0.47.0 

func (r RestProxyApp) Name() string

func (RestProxyApp) Type added in v0.47.0 

func (r RestProxyApp) Type() appcat.AppType

type RestProxyList added in v0.47.0 

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

RestProxyList contains a list of RestProxy

func (*RestProxyList) DeepCopy added in v0.47.0 

func (in *RestProxyList) DeepCopy() *RestProxyList

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

func (*RestProxyList) DeepCopyInto added in v0.47.0 

func (in *RestProxyList) DeepCopyInto(out *RestProxyList)

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

func (*RestProxyList) DeepCopyObject added in v0.47.0 

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

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

type RestProxyPhase added in v0.47.0 

type RestProxyPhase string

+kubebuilder:validation:Enum=Provisioning;Ready;NotReady;Critical;Unknown 

const (
	RestProxyPhaseProvisioning RestProxyPhase = "Provisioning"
	RestProxyPhaseReady        RestProxyPhase = "Ready"
	RestProxyPhaseNotReady     RestProxyPhase = "NotReady"
	RestProxyPhaseCritical     RestProxyPhase = "Critical"
	RestProxyPhaseUnknown      RestProxyPhase = "Unknown"
)

type RestProxySpec added in v0.47.0 

type RestProxySpec struct {
	// Version of RestProxy to be deployed.
	Version string `json:"version"`

	// Number of instances to deploy for a rest proxy.
	// +optional
	Replicas *int32 `json:"replicas,omitempty"`

	// Kafka app-binding reference
	// KafkaRef is a required field, where RestProxy will connect to Kafka
	KafkaRef *kmapi.ObjectReference `json:"kafkaRef"`

	// PodTemplate is an optional configuration for pods used to expose database
	// +optional
	PodTemplate ofst.PodTemplateSpec `json:"podTemplate,omitempty"`

	// ServiceTemplates is an optional configuration for services used to expose database
	// +optional
	ServiceTemplates []dbapi.NamedServiceTemplateSpec `json:"serviceTemplates,omitempty"`

	// DeletionPolicy controls the delete operation for database
	// +optional
	DeletionPolicy dbapi.DeletionPolicy `json:"deletionPolicy,omitempty"`

	// HealthChecker defines attributes of the health checker
	// +optional
	// +kubebuilder:default={periodSeconds: 10, timeoutSeconds: 10, failureThreshold: 3}
	HealthChecker kmapi.HealthCheckSpec `json:"healthChecker"`
}

RestProxySpec defines the desired state of RestProxy

func (*RestProxySpec) DeepCopy added in v0.47.0 

func (in *RestProxySpec) DeepCopy() *RestProxySpec

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

func (*RestProxySpec) DeepCopyInto added in v0.47.0 

func (in *RestProxySpec) DeepCopyInto(out *RestProxySpec)

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

type RestProxyStatus added in v0.47.0 

type RestProxyStatus struct {
	// Specifies the current phase of the database
	// +optional
	Phase RestProxyPhase `json:"phase,omitempty"`
	// observedGeneration is the most recent generation observed for this resource. It corresponds to the
	// resource's generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// Conditions applied to the database, such as approval or denial.
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

RestProxyStatus defines the observed state of RestProxy

func (*RestProxyStatus) DeepCopy added in v0.47.0 

func (in *RestProxyStatus) DeepCopy() *RestProxyStatus

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

func (*RestProxyStatus) DeepCopyInto added in v0.47.0 

func (in *RestProxyStatus) DeepCopyInto(out *RestProxyStatus)

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

type SchemaRegistry added in v0.46.0 

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

	Spec   SchemaRegistrySpec   `json:"spec,omitempty"`
	Status SchemaRegistryStatus `json:"status,omitempty"`
}

+kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:resource:shortName=ksr,scope=Namespaced +kubebuilder:printcolumn:name="Type",type="string",JSONPath=".apiVersion" +kubebuilder:printcolumn:name="Version",type="string",JSONPath=".spec.version" +kubebuilder:printcolumn:name="Status",type="string",JSONPath=".status.phase" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp"

func (*SchemaRegistry) AppBindingMeta added in v0.46.0 

func (k *SchemaRegistry) AppBindingMeta() appcat.AppBindingMeta

func (*SchemaRegistry) AsOwner added in v0.46.0 

func (k *SchemaRegistry) AsOwner() *meta.OwnerReference

func (*SchemaRegistry) ConfigSecretName added in v0.46.0 

func (k *SchemaRegistry) ConfigSecretName() string

func (*SchemaRegistry) CustomResourceDefinition added in v0.46.0 

func (k *SchemaRegistry) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

func (*SchemaRegistry) DeepCopy added in v0.46.0 

func (in *SchemaRegistry) DeepCopy() *SchemaRegistry

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

func (*SchemaRegistry) DeepCopyInto added in v0.46.0 

func (in *SchemaRegistry) DeepCopyInto(out *SchemaRegistry)

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

func (*SchemaRegistry) DeepCopyObject added in v0.46.0 

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

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

func (*SchemaRegistry) Default added in v0.46.0 

func (k *SchemaRegistry) Default()

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

func (*SchemaRegistry) GetConnectionScheme added in v0.46.0 

func (k *SchemaRegistry) GetConnectionScheme() string

func (*SchemaRegistry) GetPersistentSecrets added in v0.46.0 

func (k *SchemaRegistry) GetPersistentSecrets() []string

func (*SchemaRegistry) GetServiceTemplate added in v0.46.0 

func (k *SchemaRegistry) GetServiceTemplate(templates []dbapi.NamedServiceTemplateSpec, alias dbapi.ServiceAlias) ofst.ServiceTemplateSpec

GetServiceTemplate returns a pointer to the desired serviceTemplate referred by "aliaS". Otherwise, it returns nil.

func (*SchemaRegistry) GoverningServiceName added in v0.46.0 

func (k *SchemaRegistry) GoverningServiceName() string

func (*SchemaRegistry) KafkaClientCredentialsSecretName added in v0.46.0 

func (k *SchemaRegistry) KafkaClientCredentialsSecretName() string

func (*SchemaRegistry) OffshootLabels added in v0.46.0 

func (k *SchemaRegistry) OffshootLabels() map[string]string

func (*SchemaRegistry) OffshootName added in v0.46.0 

func (k *SchemaRegistry) OffshootName() string

func (*SchemaRegistry) OffshootSelectors added in v0.46.0 

func (k *SchemaRegistry) OffshootSelectors(extraSelectors ...map[string]string) map[string]string

func (*SchemaRegistry) Owner added in v0.46.0 

func (k *SchemaRegistry) Owner() *meta.OwnerReference

Owner returns owner reference to resources

func (*SchemaRegistry) PetSetName added in v0.47.0 

func (k *SchemaRegistry) PetSetName() string

func (*SchemaRegistry) PodControllerLabels added in v0.46.0 

func (k *SchemaRegistry) PodControllerLabels(extraLabels ...map[string]string) map[string]string

func (*SchemaRegistry) PodLabels added in v0.46.0 

func (k *SchemaRegistry) PodLabels(extraLabels ...map[string]string) map[string]string

func (*SchemaRegistry) ResourceFQN added in v0.46.0 

func (k *SchemaRegistry) ResourceFQN() string

func (*SchemaRegistry) ResourceKind added in v0.46.0 

func (k *SchemaRegistry) ResourceKind() string

func (*SchemaRegistry) ResourcePlural added in v0.46.0 

func (k *SchemaRegistry) ResourcePlural() string

func (*SchemaRegistry) ResourceShortCode added in v0.46.0 

func (k *SchemaRegistry) ResourceShortCode() string

func (*SchemaRegistry) ResourceSingular added in v0.46.0 

func (k *SchemaRegistry) ResourceSingular() string

func (*SchemaRegistry) ServiceLabels added in v0.46.0 

func (k *SchemaRegistry) ServiceLabels(alias dbapi.ServiceAlias, extraLabels ...map[string]string) map[string]string

func (*SchemaRegistry) ServiceName added in v0.46.0 

func (k *SchemaRegistry) ServiceName() string

func (*SchemaRegistry) SetDefaults added in v0.46.0 

func (k *SchemaRegistry) SetDefaults()

func (*SchemaRegistry) SetHealthCheckerDefaults added in v0.46.0 

func (k *SchemaRegistry) SetHealthCheckerDefaults()

func (*SchemaRegistry) ValidateCreate added in v0.46.0 

func (k *SchemaRegistry) ValidateCreate() (admission.Warnings, error)

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

func (*SchemaRegistry) ValidateCreateOrUpdate added in v0.46.0 

func (k *SchemaRegistry) ValidateCreateOrUpdate() field.ErrorList

func (*SchemaRegistry) ValidateDelete added in v0.46.0 

func (k *SchemaRegistry) ValidateDelete() (admission.Warnings, error)

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

func (*SchemaRegistry) ValidateUpdate added in v0.46.0 

func (k *SchemaRegistry) ValidateUpdate(old runtime.Object) (admission.Warnings, error)

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

type SchemaRegistryApp added in v0.46.0 

type SchemaRegistryApp struct {
	*SchemaRegistry
}

func (*SchemaRegistryApp) DeepCopy added in v0.46.0 

func (in *SchemaRegistryApp) DeepCopy() *SchemaRegistryApp

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

func (*SchemaRegistryApp) DeepCopyInto added in v0.46.0 

func (in *SchemaRegistryApp) DeepCopyInto(out *SchemaRegistryApp)

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

func (SchemaRegistryApp) Name added in v0.46.0 

func (r SchemaRegistryApp) Name() string

func (SchemaRegistryApp) Type added in v0.46.0 

func (r SchemaRegistryApp) Type() appcat.AppType

type SchemaRegistryList added in v0.46.0 

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

SchemaRegistryList contains a list of SchemaRegistry

func (*SchemaRegistryList) DeepCopy added in v0.46.0 

func (in *SchemaRegistryList) DeepCopy() *SchemaRegistryList

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

func (*SchemaRegistryList) DeepCopyInto added in v0.46.0 

func (in *SchemaRegistryList) DeepCopyInto(out *SchemaRegistryList)

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

func (*SchemaRegistryList) DeepCopyObject added in v0.46.0 

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

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

type SchemaRegistryPhase added in v0.46.0 

type SchemaRegistryPhase string

+kubebuilder:validation:Enum=Provisioning;Ready;NotReady;Critical;Unknown 

const (
	SchemaRegistryPhaseProvisioning SchemaRegistryPhase = "Provisioning"
	SchemaRegistryPhaseReady        SchemaRegistryPhase = "Ready"
	SchemaRegistryPhaseNotReady     SchemaRegistryPhase = "NotReady"
	SchemaRegistryPhaseCritical     SchemaRegistryPhase = "Critical"
	SchemaRegistryPhaseUnknown      SchemaRegistryPhase = "Unknown"
)

type SchemaRegistrySpec added in v0.46.0 

type SchemaRegistrySpec struct {
	// Version of SchemaRegistry to be deployed.
	Version string `json:"version"`

	// Number of instances to deploy for a schema registry.
	// +optional
	Replicas *int32 `json:"replicas,omitempty"`

	// Kafka app-binding reference
	// KafkaRef is an optional field, where SchemaRegistry will store its schema
	KafkaRef *kmapi.ObjectReference `json:"kafkaRef,omitempty"`

	// PodTemplate is an optional configuration for pods used to expose database
	// +optional
	PodTemplate ofst.PodTemplateSpec `json:"podTemplate,omitempty"`

	// ServiceTemplates is an optional configuration for services used to expose database
	// +optional
	ServiceTemplates []dbapi.NamedServiceTemplateSpec `json:"serviceTemplates,omitempty"`

	// DeletionPolicy controls the delete operation for database
	// +optional
	DeletionPolicy dbapi.DeletionPolicy `json:"deletionPolicy,omitempty"`

	// HealthChecker defines attributes of the health checker
	// +optional
	// +kubebuilder:default={periodSeconds: 20, timeoutSeconds: 10, failureThreshold: 3}
	HealthChecker kmapi.HealthCheckSpec `json:"healthChecker"`
}

SchemaRegistrySpec defines the desired state of SchemaRegistry

func (*SchemaRegistrySpec) DeepCopy added in v0.46.0 

func (in *SchemaRegistrySpec) DeepCopy() *SchemaRegistrySpec

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

func (*SchemaRegistrySpec) DeepCopyInto added in v0.46.0 

func (in *SchemaRegistrySpec) DeepCopyInto(out *SchemaRegistrySpec)

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

type SchemaRegistryStatus added in v0.46.0 

type SchemaRegistryStatus struct {
	// Specifies the current phase of the database
	// +optional
	Phase SchemaRegistryPhase `json:"phase,omitempty"`
	// observedGeneration is the most recent generation observed for this resource. It corresponds to the
	// resource's generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// Conditions applied to the database, such as approval or denial.
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

SchemaRegistryStatus defines the observed state of SchemaRegistry

func (*SchemaRegistryStatus) DeepCopy added in v0.46.0 

func (in *SchemaRegistryStatus) DeepCopy() *SchemaRegistryStatus

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

func (*SchemaRegistryStatus) DeepCopyInto added in v0.46.0 

func (in *SchemaRegistryStatus) DeepCopyInto(out *SchemaRegistryStatus)

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.