v1alpha1

package
v0.45.1 Latest Latest
Warning

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

 Go to latest Published: Apr 27, 2024 License: Apache-2.0 Imports: 38 Imported by: 1

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 (
	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 []api.NamedServiceTemplateSpec, alias api.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) 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 api.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) StatefulSetName 

func (k *ConnectCluster) StatefulSetName() string

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 *api.SecretReference `json:"authSecret,omitempty"`

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

	// Keystore encryption secret
	// +optional
	KeystoreCredSecret *api.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 []api.NamedServiceTemplateSpec `json:"serviceTemplates,omitempty"`

	// TerminationPolicy controls the delete operation for database
	// +optional
	TerminationPolicy api.TerminationPolicy `json:"terminationPolicy,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"`

	// TerminationPolicy controls the delete operation for Connector
	// +optional
	TerminationPolicy api.TerminationPolicy `json:"terminationPolicy,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.

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.