v1alpha1

package

Go to main page

Versions in this module

v0

v0.46.0

Jun 4, 2024

Changes in this version

+ const ApicurioRegistryRESTPort

+ const ResourceCodeSchemaRegistry

+ const ResourceKindSchemaRegistry

+ const ResourcePluralSchemaRegistry

+ const ResourceSingularSchemaRegistry

+ const SchemaRegistryConfigFileName

+ const SchemaRegistryContainerName

+ const SchemaRegistryOperatorConfigPath

+ const SchemaRegistryOperatorVolumeConfig

+ const SchemaRegistryPortName

+ const SchemaRegistryPrimaryPortName

+ const SchemaRegistryStorageBackendTypeKafka

+ const SchemaRegistryStorageBackendTypeMemory

+ const SchemaRegistryStorageBackendTypeSQL

type ConnectClusterSpec

+ DeletionPolicy api.TerminationPolicy

type ConnectorSpec

+ DeletionPolicy api.TerminationPolicy

+ type SchemaRegistry struct

+ Spec SchemaRegistrySpec

+ Status SchemaRegistryStatus

+ func (in *SchemaRegistry) DeepCopy() *SchemaRegistry

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

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

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

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

+ func (k *SchemaRegistry) ConfigSecretName() string

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

+ func (k *SchemaRegistry) Default()

+ func (k *SchemaRegistry) GetConnectionScheme() string

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

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

+ func (k *SchemaRegistry) GoverningServiceName() string

+ func (k *SchemaRegistry) KafkaClientCredentialsSecretName() string

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

+ func (k *SchemaRegistry) OffshootName() string

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

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

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

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

+ func (k *SchemaRegistry) ResourceFQN() string

+ func (k *SchemaRegistry) ResourceKind() string

+ func (k *SchemaRegistry) ResourcePlural() string

+ func (k *SchemaRegistry) ResourceShortCode() string

+ func (k *SchemaRegistry) ResourceSingular() string

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

+ func (k *SchemaRegistry) ServiceName() string

+ func (k *SchemaRegistry) SetDefaults()

+ func (k *SchemaRegistry) SetHealthCheckerDefaults()

+ func (k *SchemaRegistry) StatefulSetName() string

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

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

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

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

+ type SchemaRegistryApp struct

+ func (in *SchemaRegistryApp) DeepCopy() *SchemaRegistryApp

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

+ func (r SchemaRegistryApp) Name() string

+ func (r SchemaRegistryApp) Type() appcat.AppType

+ type SchemaRegistryList struct

+ Items []SchemaRegistry

+ func (in *SchemaRegistryList) DeepCopy() *SchemaRegistryList

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

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

+ type SchemaRegistryPhase string

+ const SchemaRegistryPhaseCritical

+ const SchemaRegistryPhaseNotReady

+ const SchemaRegistryPhaseProvisioning

+ const SchemaRegistryPhaseReady

+ const SchemaRegistryPhaseUnknown

+ type SchemaRegistrySpec struct

+ DeletionPolicy api.TerminationPolicy

+ HealthChecker kmapi.HealthCheckSpec

+ KafkaRef *kmapi.ObjectReference

+ PodTemplate ofst.PodTemplateSpec

+ Replicas *int32

+ ServiceTemplates []api.NamedServiceTemplateSpec

+ Version string

+ func (in *SchemaRegistrySpec) DeepCopy() *SchemaRegistrySpec

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

+ type SchemaRegistryStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase SchemaRegistryPhase

+ func (in *SchemaRegistryStatus) DeepCopy() *SchemaRegistryStatus

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

v0.45.1

Apr 27, 2024

v0.45.0

Apr 26, 2024

v0.44.0

Mar 16, 2024

Changes in this version

type ConnectorPhase

+ const ConnectorPhaseDestroyed

+ const ConnectorPhaseFailed

+ const ConnectorPhaseRestarting

+ const ConnectorPhaseUnassigned

v0.43.0-rc.0

Mar 8, 2024

v0.42.1

Feb 22, 2024

v0.42.0

Feb 14, 2024

v0.41.0

Feb 1, 2024

Changes in this version

+ const ComponentKafka

+ const ConnectClusterAuthSecretVolumeName

+ const ConnectClusterAuthSecretVolumePath

+ const ConnectClusterBasicAuthKey

+ const ConnectClusterBasicAuthValue

+ const ConnectClusterBootstrapServers

+ const ConnectClusterClientAuthentication

+ const ConnectClusterConfigStorageTopic

+ const ConnectClusterConfigStorageTopicName

+ const ConnectClusterContainerName

+ const ConnectClusterCustomConfigPath

+ const ConnectClusterCustomVolumeConfig

+ const ConnectClusterGroupID

+ const ConnectClusterIdentificationAlgorithm

+ const ConnectClusterJsonConverterName

+ const ConnectClusterKeyConverter

+ const ConnectClusterKeyConverterSchemasEnable

+ const ConnectClusterKeyPassword

+ const ConnectClusterKeystoreLocation

+ const ConnectClusterKeystorePassword

+ const ConnectClusterListeners

+ const ConnectClusterModeEnv

+ const ConnectClusterOffsetFileDir

+ const ConnectClusterOffsetFileDirName

+ const ConnectClusterOffsetFileName

+ const ConnectClusterOffsetStorage

+ const ConnectClusterOffsetStorageTopic

+ const ConnectClusterOffsetStorageTopicName

+ const ConnectClusterOperatorConfigPath

+ const ConnectClusterOperatorVolumeConfig

+ const ConnectClusterPasswordEnv

+ const ConnectClusterPluginPath

+ const ConnectClusterPluginPathDir

+ const ConnectClusterPortName

+ const ConnectClusterPrimaryPortName

+ const ConnectClusterRESTPort

+ const ConnectClusterRestAdvertisedHostName

+ const ConnectClusterRestAdvertisedPort

+ const ConnectClusterServerCertVolumeDir

+ const ConnectClusterServerCertsVolumeName

+ const ConnectClusterStatusStorageTopic

+ const ConnectClusterStatusStorageTopicName

+ const ConnectClusterTruststoreLocation

+ const ConnectClusterTruststorePassword

+ const ConnectClusterUser

+ const ConnectClusterUserEnv

+ const ConnectClusterValueConverter

+ const ConnectClusterValueConverterSchemasEnable

+ const ConnectorPluginsVolumeDir

+ const ConnectorPluginsVolumeName

+ const DefaultStatsPath

+ const Finalizer

+ const KafkaClientCertDir

+ const KafkaClientCertVolumeName

+ const KafkaClientKeystoreKey

+ const KafkaClientKeystoreLocation

+ const KafkaClientTruststoreKey

+ const KafkaClientTruststoreLocation

+ const KafkaConnectRestAdvertisedListener

+ const LabelRole

+ const ResourceCodeConnectCluster

+ const ResourceCodeConnector

+ const ResourceKindConnectCluster

+ const ResourceKindConnector

+ const ResourcePluralConnectCluster

+ const ResourcePluralConnector

+ const ResourceSingularConnectCluster

+ const ResourceSingularConnector

+ const RoleStats

+ var AddToScheme = localSchemeBuilder.AddToScheme

+ var DefaultClient client.Client

+ var SchemeBuilder runtime.SchemeBuilder

+ var SchemeGroupVersion = schema.GroupVersion

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

+ func Kind(kind string) schema.GroupKind

+ func Resource(resource string) schema.GroupResource

+ func SetDefaultClient(kc client.Client)

+ type ConnectCluster struct

+ Spec ConnectClusterSpec

+ Status ConnectClusterStatus

+ func (in *ConnectCluster) DeepCopy() *ConnectCluster

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

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

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

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

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

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

+ func (k *ConnectCluster) ConfigSecretName() string

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

+ func (k *ConnectCluster) Default()

+ func (k *ConnectCluster) DefaultKeystoreCredSecretName() string

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

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

+ func (k *ConnectCluster) GetConnectionScheme() string

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

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

+ func (k *ConnectCluster) GoverningServiceName() string

+ func (k *ConnectCluster) KafkaClientCredentialsSecretName() string

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

+ func (k *ConnectCluster) OffshootName() string

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

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

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

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

+ func (k *ConnectCluster) ResourceFQN() string

+ func (k *ConnectCluster) ResourceKind() string

+ func (k *ConnectCluster) ResourcePlural() string

+ func (k *ConnectCluster) ResourceShortCode() string

+ func (k *ConnectCluster) ResourceSingular() string

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

+ func (k *ConnectCluster) ServiceName() string

+ func (k *ConnectCluster) SetDefaultEnvs()

+ func (k *ConnectCluster) SetDefaults()

+ func (k *ConnectCluster) SetHealthCheckerDefaults()

+ func (k *ConnectCluster) SetTLSDefaults()

+ func (k *ConnectCluster) StatefulSetName() string

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

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

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

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

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

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

+ type ConnectClusterApp struct

+ func (in *ConnectClusterApp) DeepCopy() *ConnectClusterApp

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

+ func (r ConnectClusterApp) Name() string

+ func (r ConnectClusterApp) Type() appcat.AppType

+ type ConnectClusterCertificateAlias string

+ const ConnectClusterCACert

+ const ConnectClusterClientCert

+ const ConnectClusterHTTPCert

+ const ConnectClusterServerCert

+ const ConnectClusterTransportCert

+ type ConnectClusterList struct

+ Items []ConnectCluster

+ func (in *ConnectClusterList) DeepCopy() *ConnectClusterList

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

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

+ type ConnectClusterNodeRoleType string

+ const ConnectClusterNodeRoleDistributed

+ const ConnectClusterNodeRoleStandalone

+ type ConnectClusterPhase string

+ const ConnectClusterPhaseCritical

+ const ConnectClusterPhaseNotReady

+ const ConnectClusterPhaseProvisioning

+ const ConnectClusterPhaseReady

+ const ConnectClusterPhaseUnknown

+ type ConnectClusterSpec struct

+ AuthSecret *api.SecretReference

+ ConfigSecret *core.LocalObjectReference

+ ConnectorPlugins []string

+ DisableSecurity bool

+ EnableSSL bool

+ HealthChecker kmapi.HealthCheckSpec

+ KafkaRef *kmapi.ObjectReference

+ KeystoreCredSecret *api.SecretReference

+ Monitor *mona.AgentSpec

+ PodTemplate ofst.PodTemplateSpec

+ Replicas *int32

+ ServiceTemplates []api.NamedServiceTemplateSpec

+ TLS *kmapi.TLSConfig

+ TerminationPolicy api.TerminationPolicy

+ Version string

+ func (in *ConnectClusterSpec) DeepCopy() *ConnectClusterSpec

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

+ type ConnectClusterStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase ConnectClusterPhase

+ func (in *ConnectClusterStatus) DeepCopy() *ConnectClusterStatus

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

+ type Connector struct

+ Spec ConnectorSpec

+ Status ConnectorStatus

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

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

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

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

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

+ func (k *Connector) Default()

+ func (k *Connector) OffshootName() string

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

+ func (k *Connector) ResourceFQN() string

+ func (k *Connector) ResourceKind() string

+ func (k *Connector) ResourcePlural() string

+ func (k *Connector) ResourceShortCode() string

+ func (k *Connector) ResourceSingular() string

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

+ func (k *Connector) ValidateCreateOrUpdate() error

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

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

+ type ConnectorList struct

+ Items []Connector

+ func (in *ConnectorList) DeepCopy() *ConnectorList

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

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

+ type ConnectorPhase string

+ const ConnectorPhasePaused

+ const ConnectorPhasePending

+ const ConnectorPhaseRunning

+ const ConnectorPhaseStopped

+ const ConnectorPhaseUnknown

+ type ConnectorSpec struct

+ ConfigSecret *core.LocalObjectReference

+ ConnectClusterRef *kmapi.ObjectReference

+ TerminationPolicy api.TerminationPolicy

+ func (in *ConnectorSpec) DeepCopy() *ConnectorSpec

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

+ type ConnectorStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase ConnectorPhase

+ func (in *ConnectorStatus) DeepCopy() *ConnectorStatus

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

v0.41.0-rc.1

Jan 28, 2024

v0.41.0-rc.0

Jan 27, 2024

v0.41.0-beta.1

Jan 20, 2024

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