v1alpha1

package
v0.34.0 Latest Latest
Warning

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

 Go to latest Published: Oct 21, 2025 License: Apache-2.0 Imports: 61 Imported by: 0

Documentation

Overview

+kubebuilder:object:generate=true +groupName=aiven.io +versionName=v1alpha1

Package v1alpha1 contains API Schema definitions for the v1alpha1 API group +kubebuilder:object:generate=true +groupName=aiven.io

Index

Constants

This section is empty.

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "aiven.io", Version: "v1alpha1"}

	// 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
)
View Source 
var ErrDeleteDependencies = errors.New("object has dependencies and cannot be deleted")

Functions

func ConvertDiskSpace added in v0.20.0 

func ConvertDiskSpace(v string) int

func ErrorSubstrChecker added in v0.5.0 

func ErrorSubstrChecker(substrings ...string) func(error) bool

ErrorSubstrChecker returns error checker for containing given substrings

func SetupWebhooks added in v0.11.0 

func SetupWebhooks(mgr ctrl.Manager) error

Types

type AivenManagedObject added in v0.16.0 

type AivenManagedObject interface {
	client.Object

	AuthSecretRef() *AuthSecretReference
	Conditions() *[]metav1.Condition
	GetObjectMeta() *metav1.ObjectMeta
	NoSecret() bool
}

+k8s:deepcopy-gen=false

type AlloyDBOmni added in v0.28.0 

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

	Spec   AlloyDBOmniSpec `json:"spec,omitempty"`
	Status ServiceStatus   `json:"status,omitempty"`
}

AlloyDBOmni is the Schema for the alloydbomni API. Info "Exposes secret keys": `ALLOYDBOMNI_HOST`, `ALLOYDBOMNI_PORT`, `ALLOYDBOMNI_DATABASE`, `ALLOYDBOMNI_USER`, `ALLOYDBOMNI_PASSWORD`, `ALLOYDBOMNI_SSLMODE`, `ALLOYDBOMNI_DATABASE_URI` Deprecated: End of life notice - Aiven for AlloyDB Omni is entering its end-of-life cycle. See https://aiven.io/docs/platform/reference/end-of-life for details. From 5 September 2025, you can no longer create new Aiven for AlloyDB Omni services. Existing services continue to operate until the end of life (EOL) date but you cannot change plans for these services. On 5 December 2025, all active Aiven for AlloyDB Omni services are powered off and deleted, making data from these services inaccessible. The recommended alternatives are Aiven for PostgreSQL®, Aiven for ClickHouse®, and Aiven for MySQL®. To ensure uninterrupted service, complete your migration before December 5, 2025. For further assistance, contact the Aiven support team at support@aiven.io or your account team. +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Region",type="string",JSONPath=".spec.cloudName" +kubebuilder:printcolumn:name="Plan",type="string",JSONPath=".spec.plan" +kubebuilder:printcolumn:name="State",type="string",JSONPath=".status.state"

func (*AlloyDBOmni) AuthSecretRef added in v0.28.0 

func (in *AlloyDBOmni) AuthSecretRef() *AuthSecretReference

func (*AlloyDBOmni) Conditions added in v0.28.0 

func (in *AlloyDBOmni) Conditions() *[]metav1.Condition

func (*AlloyDBOmni) DeepCopy added in v0.28.0 

func (in *AlloyDBOmni) DeepCopy() *AlloyDBOmni

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

func (*AlloyDBOmni) DeepCopyInto added in v0.28.0 

func (in *AlloyDBOmni) DeepCopyInto(out *AlloyDBOmni)

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

func (*AlloyDBOmni) DeepCopyObject added in v0.28.0 

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

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

func (*AlloyDBOmni) Default added in v0.28.0 

func (in *AlloyDBOmni) Default()

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

func (*AlloyDBOmni) GetConnInfoSecretTarget added in v0.28.0 

func (in *AlloyDBOmni) GetConnInfoSecretTarget() ConnInfoSecretTarget

func (*AlloyDBOmni) GetObjectMeta added in v0.31.0 

func (in *AlloyDBOmni) GetObjectMeta() *metav1.ObjectMeta

func (*AlloyDBOmni) GetRefs added in v0.28.0 

func (in *AlloyDBOmni) GetRefs() []*ResourceReferenceObject

func (*AlloyDBOmni) NoSecret added in v0.28.0 

func (in *AlloyDBOmni) NoSecret() bool

func (*AlloyDBOmni) SetupWebhookWithManager added in v0.28.0 

func (in *AlloyDBOmni) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*AlloyDBOmni) ValidateCreate added in v0.28.0 

func (in *AlloyDBOmni) ValidateCreate() error

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

func (*AlloyDBOmni) ValidateDelete added in v0.28.0 

func (in *AlloyDBOmni) ValidateDelete() error

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

func (*AlloyDBOmni) ValidateUpdate added in v0.28.0 

func (in *AlloyDBOmni) ValidateUpdate(_ runtime.Object) error

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

type AlloyDBOmniList added in v0.28.0 

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

AlloyDBOmniList contains a list of AlloyDBOmni instances

func (*AlloyDBOmniList) DeepCopy added in v0.28.0 

func (in *AlloyDBOmniList) DeepCopy() *AlloyDBOmniList

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

func (*AlloyDBOmniList) DeepCopyInto added in v0.28.0 

func (in *AlloyDBOmniList) DeepCopyInto(out *AlloyDBOmniList)

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

func (*AlloyDBOmniList) DeepCopyObject added in v0.28.0 

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

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

type AlloyDBOmniSpec added in v0.28.0 

type AlloyDBOmniSpec struct {
	ServiceCommonSpec `json:",inline"`

	// +kubebuilder:validation:Schemaless
	// +kubebuilder:validation:Type=string
	// Your [Google service account key](https://cloud.google.com/iam/docs/service-account-creds#key-types) in JSON format.
	ServiceAccountCredentials string `json:"serviceAccountCredentials,omitempty"`

	// AlloyDBOmni specific user configuration options
	UserConfig *alloydbomni.AlloydbomniUserConfig `json:"userConfig,omitempty"`
}

AlloyDBOmniSpec defines the desired state of AlloyDB Omni instance

func (*AlloyDBOmniSpec) DeepCopy added in v0.28.0 

func (in *AlloyDBOmniSpec) DeepCopy() *AlloyDBOmniSpec

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

func (*AlloyDBOmniSpec) DeepCopyInto added in v0.28.0 

func (in *AlloyDBOmniSpec) DeepCopyInto(out *AlloyDBOmniSpec)

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

type AuthSecretRefField added in v0.20.0 

type AuthSecretRefField struct {
	// Authentication reference to Aiven token in a secret
	AuthSecretRef *AuthSecretReference `json:"authSecretRef,omitempty"`
}

func (*AuthSecretRefField) DeepCopy added in v0.20.0 

func (in *AuthSecretRefField) DeepCopy() *AuthSecretRefField

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

func (*AuthSecretRefField) DeepCopyInto added in v0.20.0 

func (in *AuthSecretRefField) DeepCopyInto(out *AuthSecretRefField)

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

type AuthSecretReference 

type AuthSecretReference struct {
	// +kubebuilder:validation:MinLength=1
	Name string `json:"name"`
	// +kubebuilder:validation:MinLength=1
	Key string `json:"key"`
}

AuthSecretReference references a Secret containing an Aiven authentication token

func (*AuthSecretReference) DeepCopy 

func (in *AuthSecretReference) DeepCopy() *AuthSecretReference

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

func (*AuthSecretReference) DeepCopyInto 

func (in *AuthSecretReference) DeepCopyInto(out *AuthSecretReference)

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

type BaseServiceFields added in v0.20.0 

type BaseServiceFields struct {
	ProjectDependant `json:",inline"`

	// +kubebuilder:validation:MaxLength=128
	// Subscription plan.
	Plan string `json:"plan"`

	// +kubebuilder:validation:MaxLength=256
	// Cloud the service runs in.
	CloudName string `json:"cloudName,omitempty"`

	// +kubebuilder:validation:MaxLength=36
	// Identifier of the VPC the service should be in, if any.
	ProjectVPCID string `json:"projectVpcId,omitempty"`

	// ProjectVPCRef reference to ProjectVPC resource to use its ID as ProjectVPCID automatically
	ProjectVPCRef *ResourceReference `json:"projectVPCRef,omitempty"`

	// +kubebuilder:validation:Enum=monday;tuesday;wednesday;thursday;friday;saturday;sunday
	// Day of week when maintenance operations should be performed. One monday, tuesday, wednesday, etc.
	MaintenanceWindowDow service.DowType `json:"maintenanceWindowDow,omitempty"`

	// +kubebuilder:validation:MaxLength=8
	// Time of day when maintenance operations should be performed. UTC time in HH:mm:ss format.
	MaintenanceWindowTime string `json:"maintenanceWindowTime,omitempty"`

	// Prevent service from being deleted. It is recommended to have this enabled for all services.
	TerminationProtection *bool `json:"terminationProtection,omitempty"`

	// Tags are key-value pairs that allow you to categorize services.
	Tags map[string]string `json:"tags,omitempty"`

	// +kubebuilder:validation:MaxItems=1
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	// Service integrations to specify when creating a service. Not applied after initial service creation
	ServiceIntegrations []*ServiceIntegrationItem `json:"serviceIntegrations,omitempty"`

	// +kubebuilder:validation:MaxItems=10
	// Defines the email addresses that will receive alerts about upcoming maintenance updates or warnings about service instability.
	TechnicalEmails []ServiceTechEmail `json:"technicalEmails,omitempty"`

	// +kubebuilder:default=true
	// Determines the power state of the service. When `true` (default), the service is running.
	// When `false`, the service is powered off.
	// For more information please see [Aiven documentation](https://aiven.io/docs/platform/concepts/service-power-cycle).
	// Note that:
	// - When set to `false` the annotation `controllers.aiven.io/instance-is-running` is also set to `false`.
	// - Services cannot be created in a powered off state. The value is ignored during creation.
	// - It is highly recommended to not run dependent resources when the service is powered off.
	//   Creating a new resource or updating an existing resource that depends on a powered off service will result in an error.
	//   Existing resources will need to be manually recreated after the service is powered on.
	// - Existing secrets will not be updated or removed when the service is powered off.
	// - For Kafka services with backups: Topic configuration, schemas and connectors are all backed up, but not the data in topics. All topic data is lost on power off.
	// - For Kafka services without backups: Topic configurations including all topic data is lost on power off.
	Powered *bool `json:"powered,omitempty"`
}

func (*BaseServiceFields) DeepCopy added in v0.20.0 

func (in *BaseServiceFields) DeepCopy() *BaseServiceFields

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

func (*BaseServiceFields) DeepCopyInto added in v0.20.0 

func (in *BaseServiceFields) DeepCopyInto(out *BaseServiceFields)

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

func (*BaseServiceFields) GetRefs added in v0.20.0 

func (in *BaseServiceFields) GetRefs(namespace string) (refs []*ResourceReferenceObject)

GetRefs is inherited by kafka, pg, os, etc

func (*BaseServiceFields) Validate added in v0.20.0 

func (in *BaseServiceFields) Validate() error

Validate runs complex validation on ServiceCommonSpec

type Cassandra added in v0.7.0 

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

	Spec   CassandraSpec `json:"spec,omitempty"`
	Status ServiceStatus `json:"status,omitempty"`
}

Cassandra is the Schema for the cassandras API. Info "Exposes secret keys": `CASSANDRA_HOST`, `CASSANDRA_PORT`, `CASSANDRA_USER`, `CASSANDRA_PASSWORD`, `CASSANDRA_URI`, `CASSANDRA_HOSTS`, `CASSANDRA_CA_CERT` +kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:deprecatedversion:warning="EOL date **December 31, 2025**, see [end-of-life](https://aiven.io/docs/platform/reference/end-of-life). To ensure uninterrupted service, complete your migration out of Aiven for Apache Cassandra before December 31, 2025." +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Region",type="string",JSONPath=".spec.cloudName" +kubebuilder:printcolumn:name="Plan",type="string",JSONPath=".spec.plan" +kubebuilder:printcolumn:name="State",type="string",JSONPath=".status.state"

func (*Cassandra) AuthSecretRef added in v0.7.0 

func (in *Cassandra) AuthSecretRef() *AuthSecretReference

func (*Cassandra) Conditions added in v0.16.0 

func (in *Cassandra) Conditions() *[]metav1.Condition

func (*Cassandra) DeepCopy added in v0.7.0 

func (in *Cassandra) DeepCopy() *Cassandra

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

func (*Cassandra) DeepCopyInto added in v0.7.0 

func (in *Cassandra) DeepCopyInto(out *Cassandra)

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

func (*Cassandra) DeepCopyObject added in v0.7.0 

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

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

func (*Cassandra) Default added in v0.7.0 

func (in *Cassandra) Default()

func (*Cassandra) GetConnInfoSecretTarget added in v0.12.0 

func (in *Cassandra) GetConnInfoSecretTarget() ConnInfoSecretTarget

func (*Cassandra) GetObjectMeta added in v0.31.0 

func (in *Cassandra) GetObjectMeta() *metav1.ObjectMeta

func (*Cassandra) GetRefs added in v0.7.0 

func (in *Cassandra) GetRefs() []*ResourceReferenceObject

func (*Cassandra) NoSecret added in v0.17.0 

func (in *Cassandra) NoSecret() bool

func (*Cassandra) SetupWebhookWithManager added in v0.7.0 

func (in *Cassandra) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Cassandra) ValidateCreate added in v0.7.0 

func (in *Cassandra) ValidateCreate() error

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

func (*Cassandra) ValidateDelete added in v0.7.0 

func (in *Cassandra) ValidateDelete() error

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

func (*Cassandra) ValidateUpdate added in v0.7.0 

func (in *Cassandra) ValidateUpdate(_ runtime.Object) error

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

type CassandraList added in v0.7.0 

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

CassandraList contains a list of Cassandra

func (*CassandraList) DeepCopy added in v0.7.0 

func (in *CassandraList) DeepCopy() *CassandraList

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

func (*CassandraList) DeepCopyInto added in v0.7.0 

func (in *CassandraList) DeepCopyInto(out *CassandraList)

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

func (*CassandraList) DeepCopyObject added in v0.7.0 

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

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

type CassandraSpec added in v0.7.0 

type CassandraSpec struct {
	ServiceCommonSpec `json:",inline"`

	// Cassandra specific user configuration options
	UserConfig *cassandrauserconfig.CassandraUserConfig `json:"userConfig,omitempty"`
}

CassandraSpec defines the desired state of Cassandra

func (*CassandraSpec) DeepCopy added in v0.7.0 

func (in *CassandraSpec) DeepCopy() *CassandraSpec

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

func (*CassandraSpec) DeepCopyInto added in v0.7.0 

func (in *CassandraSpec) DeepCopyInto(out *CassandraSpec)

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

type Clickhouse added in v0.3.0 

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

	Spec   ClickhouseSpec `json:"spec,omitempty"`
	Status ServiceStatus  `json:"status,omitempty"`
}

Clickhouse is the Schema for the clickhouses API. Info "Exposes secret keys": `CLICKHOUSE_HOST`, `CLICKHOUSE_PORT`, `CLICKHOUSE_USER`, `CLICKHOUSE_PASSWORD` +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Region",type="string",JSONPath=".spec.cloudName" +kubebuilder:printcolumn:name="Plan",type="string",JSONPath=".spec.plan" +kubebuilder:printcolumn:name="State",type="string",JSONPath=".status.state"

func (*Clickhouse) AuthSecretRef added in v0.3.0 

func (in *Clickhouse) AuthSecretRef() *AuthSecretReference

func (*Clickhouse) Conditions added in v0.16.0 

func (in *Clickhouse) Conditions() *[]metav1.Condition

func (*Clickhouse) DeepCopy added in v0.3.0 

func (in *Clickhouse) DeepCopy() *Clickhouse

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

func (*Clickhouse) DeepCopyInto added in v0.3.0 

func (in *Clickhouse) DeepCopyInto(out *Clickhouse)

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

func (*Clickhouse) DeepCopyObject added in v0.3.0 

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

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

func (*Clickhouse) Default added in v0.3.0 

func (in *Clickhouse) Default()

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

func (*Clickhouse) GetConnInfoSecretTarget added in v0.12.0 

func (in *Clickhouse) GetConnInfoSecretTarget() ConnInfoSecretTarget

func (*Clickhouse) GetObjectMeta added in v0.31.0 

func (in *Clickhouse) GetObjectMeta() *metav1.ObjectMeta

func (*Clickhouse) GetRefs added in v0.5.0 

func (in *Clickhouse) GetRefs() []*ResourceReferenceObject

func (*Clickhouse) NoSecret added in v0.17.0 

func (in *Clickhouse) NoSecret() bool

func (*Clickhouse) SetupWebhookWithManager added in v0.3.0 

func (in *Clickhouse) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Clickhouse) ValidateCreate added in v0.3.0 

func (in *Clickhouse) ValidateCreate() error

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

func (*Clickhouse) ValidateDelete added in v0.3.0 

func (in *Clickhouse) ValidateDelete() error

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

func (*Clickhouse) ValidateUpdate added in v0.3.0 

func (in *Clickhouse) ValidateUpdate(_ runtime.Object) error

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

type ClickhouseDatabase added in v0.18.0 

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

	Spec   ClickhouseDatabaseSpec   `json:"spec,omitempty"`
	Status ClickhouseDatabaseStatus `json:"status,omitempty"`
}

ClickhouseDatabase is the Schema for the databases API +kubebuilder:printcolumn:name="Database name",type="string",JSONPath=".spec.databaseName" +kubebuilder:printcolumn:name="Service Name",type="string",JSONPath=".spec.serviceName" +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project"

func (*ClickhouseDatabase) AuthSecretRef added in v0.18.0 

func (in *ClickhouseDatabase) AuthSecretRef() *AuthSecretReference

func (*ClickhouseDatabase) Conditions added in v0.18.0 

func (in *ClickhouseDatabase) Conditions() *[]metav1.Condition

func (*ClickhouseDatabase) DeepCopy added in v0.18.0 

func (in *ClickhouseDatabase) DeepCopy() *ClickhouseDatabase

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

func (*ClickhouseDatabase) DeepCopyInto added in v0.18.0 

func (in *ClickhouseDatabase) DeepCopyInto(out *ClickhouseDatabase)

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

func (*ClickhouseDatabase) DeepCopyObject added in v0.18.0 

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

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

func (*ClickhouseDatabase) GetDatabaseName added in v0.21.0 

func (in *ClickhouseDatabase) GetDatabaseName() string

func (*ClickhouseDatabase) GetObjectMeta added in v0.31.0 

func (in *ClickhouseDatabase) GetObjectMeta() *metav1.ObjectMeta

func (*ClickhouseDatabase) NoSecret added in v0.18.0 

func (*ClickhouseDatabase) NoSecret() bool

type ClickhouseDatabaseList added in v0.18.0 

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

ClickhouseDatabaseList contains a list of ClickhouseDatabase

func (*ClickhouseDatabaseList) DeepCopy added in v0.18.0 

func (in *ClickhouseDatabaseList) DeepCopy() *ClickhouseDatabaseList

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

func (*ClickhouseDatabaseList) DeepCopyInto added in v0.18.0 

func (in *ClickhouseDatabaseList) DeepCopyInto(out *ClickhouseDatabaseList)

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

func (*ClickhouseDatabaseList) DeepCopyObject added in v0.18.0 

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

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

type ClickhouseDatabaseSpec added in v0.18.0 

type ClickhouseDatabaseSpec struct {
	ServiceDependant `json:",inline"`

	// Specifies the Clickhouse database name. Defaults to `metadata.name` if omitted.
	// Note: `metadata.name` is ASCII-only. For UTF-8 names, use `spec.databaseName`, but ASCII is advised for compatibility.
	// +kubebuilder:validation:MaxLength=63
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	DatabaseName string `json:"databaseName,omitempty"`
}

ClickhouseDatabaseSpec defines the desired state of ClickhouseDatabase +kubebuilder:validation:XValidation:rule="!has(oldSelf.databaseName) || has(self.databaseName)", message="databaseName is required once set"

func (*ClickhouseDatabaseSpec) DeepCopy added in v0.18.0 

func (in *ClickhouseDatabaseSpec) DeepCopy() *ClickhouseDatabaseSpec

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

func (*ClickhouseDatabaseSpec) DeepCopyInto added in v0.18.0 

func (in *ClickhouseDatabaseSpec) DeepCopyInto(out *ClickhouseDatabaseSpec)

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

type ClickhouseDatabaseStatus added in v0.18.0 

type ClickhouseDatabaseStatus struct {
	// Conditions represent the latest available observations of an ClickhouseDatabase state
	Conditions []metav1.Condition `json:"conditions"`
}

ClickhouseDatabaseStatus defines the observed state of ClickhouseDatabase

func (*ClickhouseDatabaseStatus) DeepCopy added in v0.18.0 

func (in *ClickhouseDatabaseStatus) DeepCopy() *ClickhouseDatabaseStatus

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

func (*ClickhouseDatabaseStatus) DeepCopyInto added in v0.18.0 

func (in *ClickhouseDatabaseStatus) DeepCopyInto(out *ClickhouseDatabaseStatus)

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

type ClickhouseGrant added in v0.21.0 

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

	Spec   ClickhouseGrantSpec   `json:"spec,omitempty"`
	Status ClickhouseGrantStatus `json:"status,omitempty"`
}

ClickhouseGrant is the Schema for the ClickhouseGrants API Warning: Due to the way ClickHouse operates, updating this resource first revokes the existing privileges. +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Service Name",type="string",JSONPath=".spec.serviceName"

func (*ClickhouseGrant) AuthSecretRef added in v0.21.0 

func (in *ClickhouseGrant) AuthSecretRef() *AuthSecretReference

func (*ClickhouseGrant) Conditions added in v0.21.0 

func (in *ClickhouseGrant) Conditions() *[]metav1.Condition

func (*ClickhouseGrant) DeepCopy added in v0.21.0 

func (in *ClickhouseGrant) DeepCopy() *ClickhouseGrant

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

func (*ClickhouseGrant) DeepCopyInto added in v0.21.0 

func (in *ClickhouseGrant) DeepCopyInto(out *ClickhouseGrant)

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

func (*ClickhouseGrant) DeepCopyObject added in v0.21.0 

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

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

func (*ClickhouseGrant) GetObjectMeta added in v0.31.0 

func (in *ClickhouseGrant) GetObjectMeta() *metav1.ObjectMeta

func (*ClickhouseGrant) NoSecret added in v0.21.0 

func (in *ClickhouseGrant) NoSecret() bool

type ClickhouseGrantList added in v0.21.0 

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

ClickhouseGrantList contains a list of ClickhouseGrant

func (*ClickhouseGrantList) DeepCopy added in v0.21.0 

func (in *ClickhouseGrantList) DeepCopy() *ClickhouseGrantList

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

func (*ClickhouseGrantList) DeepCopyInto added in v0.21.0 

func (in *ClickhouseGrantList) DeepCopyInto(out *ClickhouseGrantList)

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

func (*ClickhouseGrantList) DeepCopyObject added in v0.21.0 

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

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

type ClickhouseGrantSpec added in v0.21.0 

type ClickhouseGrantSpec struct {
	ServiceDependant `json:",inline,omitempty"`
	Grants           `json:",inline,omitempty"`
}

ClickhouseGrantSpec defines the desired state of ClickhouseGrant

func (*ClickhouseGrantSpec) CollectDatabases added in v0.21.0 

func (in *ClickhouseGrantSpec) CollectDatabases() []string

func (*ClickhouseGrantSpec) CollectGrantees added in v0.21.0 

func (in *ClickhouseGrantSpec) CollectGrantees() []string

func (*ClickhouseGrantSpec) CollectTables added in v0.21.0 

func (in *ClickhouseGrantSpec) CollectTables() []chUtils.DatabaseAndTable

func (*ClickhouseGrantSpec) DeepCopy added in v0.21.0 

func (in *ClickhouseGrantSpec) DeepCopy() *ClickhouseGrantSpec

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

func (*ClickhouseGrantSpec) DeepCopyInto added in v0.21.0 

func (in *ClickhouseGrantSpec) DeepCopyInto(out *ClickhouseGrantSpec)

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

type ClickhouseGrantStatus added in v0.21.0 

type ClickhouseGrantStatus struct {
	Conditions []metav1.Condition `json:"conditions"`
	// The previous applied grants to revoke. Do not edit
	State *Grants `json:"state,omitempty"`
}

ClickhouseGrantStatus defines the observed state of ClickhouseGrant

func (*ClickhouseGrantStatus) DeepCopy added in v0.21.0 

func (in *ClickhouseGrantStatus) DeepCopy() *ClickhouseGrantStatus

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

func (*ClickhouseGrantStatus) DeepCopyInto added in v0.21.0 

func (in *ClickhouseGrantStatus) DeepCopyInto(out *ClickhouseGrantStatus)

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

type ClickhouseList added in v0.3.0 

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

ClickhouseList contains a list of Clickhouse

func (*ClickhouseList) DeepCopy added in v0.3.0 

func (in *ClickhouseList) DeepCopy() *ClickhouseList

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

func (*ClickhouseList) DeepCopyInto added in v0.3.0 

func (in *ClickhouseList) DeepCopyInto(out *ClickhouseList)

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

func (*ClickhouseList) DeepCopyObject added in v0.3.0 

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

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

type ClickhouseRole added in v0.19.0 

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

	Spec   ClickhouseRoleSpec   `json:"spec,omitempty"`
	Status ClickhouseRoleStatus `json:"status,omitempty"`
}

ClickhouseRole is the Schema for the clickhouseroles API +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Service Name",type="string",JSONPath=".spec.serviceName" +kubebuilder:printcolumn:name="Role",type="string",JSONPath=".spec.role"

func (*ClickhouseRole) AuthSecretRef added in v0.19.0 

func (in *ClickhouseRole) AuthSecretRef() *AuthSecretReference

func (*ClickhouseRole) Conditions added in v0.19.0 

func (in *ClickhouseRole) Conditions() *[]metav1.Condition

func (*ClickhouseRole) DeepCopy added in v0.19.0 

func (in *ClickhouseRole) DeepCopy() *ClickhouseRole

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

func (*ClickhouseRole) DeepCopyInto added in v0.19.0 

func (in *ClickhouseRole) DeepCopyInto(out *ClickhouseRole)

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

func (*ClickhouseRole) DeepCopyObject added in v0.19.0 

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

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

func (*ClickhouseRole) GetObjectMeta added in v0.31.0 

func (in *ClickhouseRole) GetObjectMeta() *metav1.ObjectMeta

func (*ClickhouseRole) NoSecret added in v0.19.0 

func (in *ClickhouseRole) NoSecret() bool

type ClickhouseRoleList added in v0.19.0 

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

ClickhouseRoleList contains a list of ClickhouseRole

func (*ClickhouseRoleList) DeepCopy added in v0.19.0 

func (in *ClickhouseRoleList) DeepCopy() *ClickhouseRoleList

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

func (*ClickhouseRoleList) DeepCopyInto added in v0.19.0 

func (in *ClickhouseRoleList) DeepCopyInto(out *ClickhouseRoleList)

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

func (*ClickhouseRoleList) DeepCopyObject added in v0.19.0 

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

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

type ClickhouseRoleSpec added in v0.19.0 

type ClickhouseRoleSpec struct {
	ServiceDependant `json:",inline"`

	// +kubebuilder:validation:MaxLength=255
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	// The role that is to be created
	Role string `json:"role"`
}

ClickhouseRoleSpec defines the desired state of ClickhouseRole

func (*ClickhouseRoleSpec) DeepCopy added in v0.19.0 

func (in *ClickhouseRoleSpec) DeepCopy() *ClickhouseRoleSpec

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

func (*ClickhouseRoleSpec) DeepCopyInto added in v0.19.0 

func (in *ClickhouseRoleSpec) DeepCopyInto(out *ClickhouseRoleSpec)

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

type ClickhouseRoleStatus added in v0.19.0 

type ClickhouseRoleStatus struct {
	Conditions []metav1.Condition `json:"conditions"`
}

ClickhouseRoleStatus defines the observed state of ClickhouseRole

func (*ClickhouseRoleStatus) DeepCopy added in v0.19.0 

func (in *ClickhouseRoleStatus) DeepCopy() *ClickhouseRoleStatus

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

func (*ClickhouseRoleStatus) DeepCopyInto added in v0.19.0 

func (in *ClickhouseRoleStatus) DeepCopyInto(out *ClickhouseRoleStatus)

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

type ClickhouseSpec added in v0.3.0 

type ClickhouseSpec struct {
	ServiceCommonSpec `json:",inline"`

	// OpenSearch specific user configuration options
	UserConfig *clickhouseuserconfig.ClickhouseUserConfig `json:"userConfig,omitempty"`
}

ClickhouseSpec defines the desired state of Clickhouse

func (*ClickhouseSpec) DeepCopy added in v0.3.0 

func (in *ClickhouseSpec) DeepCopy() *ClickhouseSpec

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

func (*ClickhouseSpec) DeepCopyInto added in v0.3.0 

func (in *ClickhouseSpec) DeepCopyInto(out *ClickhouseSpec)

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

type ClickhouseUser added in v0.3.0 

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

	Spec   ClickhouseUserSpec   `json:"spec,omitempty"`
	Status ClickhouseUserStatus `json:"status,omitempty"`
}

ClickhouseUser is the Schema for the clickhouseusers API. Info "Exposes secret keys": `CLICKHOUSEUSER_HOST`, `CLICKHOUSEUSER_PORT`, `CLICKHOUSEUSER_USER`, `CLICKHOUSEUSER_PASSWORD` +kubebuilder:printcolumn:name="Username",type="string",JSONPath=".spec.username" +kubebuilder:printcolumn:name="Service Name",type="string",JSONPath=".spec.serviceName" +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Connection Information Secret",type="string",JSONPath=".spec.connInfoSecretTarget.name"

func (*ClickhouseUser) AuthSecretRef added in v0.3.0 

func (in *ClickhouseUser) AuthSecretRef() *AuthSecretReference

func (*ClickhouseUser) Conditions added in v0.16.0 

func (in *ClickhouseUser) Conditions() *[]metav1.Condition

func (*ClickhouseUser) DeepCopy added in v0.3.0 

func (in *ClickhouseUser) DeepCopy() *ClickhouseUser

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

func (*ClickhouseUser) DeepCopyInto added in v0.3.0 

func (in *ClickhouseUser) DeepCopyInto(out *ClickhouseUser)

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

func (*ClickhouseUser) DeepCopyObject added in v0.3.0 

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

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

func (*ClickhouseUser) GetConnInfoSecretSource added in v0.31.0 

func (in *ClickhouseUser) GetConnInfoSecretSource() *ConnInfoSecretSource

func (*ClickhouseUser) GetConnInfoSecretTarget added in v0.12.0 

func (in *ClickhouseUser) GetConnInfoSecretTarget() ConnInfoSecretTarget

func (*ClickhouseUser) GetObjectMeta added in v0.31.0 

func (in *ClickhouseUser) GetObjectMeta() *metav1.ObjectMeta

func (*ClickhouseUser) GetUsername added in v0.21.0 

func (in *ClickhouseUser) GetUsername() string

func (*ClickhouseUser) NoSecret added in v0.17.0 

func (in *ClickhouseUser) NoSecret() bool

type ClickhouseUserList added in v0.3.0 

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

ClickhouseUserList contains a list of ClickhouseUser

func (*ClickhouseUserList) DeepCopy added in v0.3.0 

func (in *ClickhouseUserList) DeepCopy() *ClickhouseUserList

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

func (*ClickhouseUserList) DeepCopyInto added in v0.3.0 

func (in *ClickhouseUserList) DeepCopyInto(out *ClickhouseUserList)

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

func (*ClickhouseUserList) DeepCopyObject added in v0.3.0 

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

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

type ClickhouseUserSpec added in v0.3.0 

type ClickhouseUserSpec struct {
	ServiceDependant `json:",inline"`
	SecretFields     `json:",inline"`

	// ConnInfoSecretSource allows specifying an existing secret to read credentials from.
	// The password from this secret will be used to modify the ClickHouse user credentials.
	// Password must be 8-256 characters long as per Aiven API requirements.
	// This can be used to set passwords for new users or modify passwords for existing users.
	// The source secret is watched for changes, and reconciliation will be automatically triggered
	// when the secret data is updated.
	ConnInfoSecretSource *ConnInfoSecretSource `json:"connInfoSecretSource,omitempty"`

	// Name of the Clickhouse user. Defaults to `metadata.name` if omitted.
	// Note: `metadata.name` is ASCII-only. For UTF-8 names, use `spec.username`, but ASCII is advised for compatibility.
	// +kubebuilder:validation:MaxLength=63
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	Username string `json:"username,omitempty"`
}

ClickhouseUserSpec defines the desired state of ClickhouseUser

func (*ClickhouseUserSpec) DeepCopy added in v0.3.0 

func (in *ClickhouseUserSpec) DeepCopy() *ClickhouseUserSpec

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

func (*ClickhouseUserSpec) DeepCopyInto added in v0.3.0 

func (in *ClickhouseUserSpec) DeepCopyInto(out *ClickhouseUserSpec)

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

type ClickhouseUserStatus added in v0.3.0 

type ClickhouseUserStatus struct {
	// Clickhouse user UUID
	UUID string `json:"uuid"`

	// Conditions represent the latest available observations of an ClickhouseUser state
	// +kubebuilder:validation:type=array
	Conditions []metav1.Condition `json:"conditions"`
}

ClickhouseUserStatus defines the observed state of ClickhouseUser

func (*ClickhouseUserStatus) DeepCopy added in v0.3.0 

func (in *ClickhouseUserStatus) DeepCopy() *ClickhouseUserStatus

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

func (*ClickhouseUserStatus) DeepCopyInto added in v0.3.0 

func (in *ClickhouseUserStatus) DeepCopyInto(out *ClickhouseUserStatus)

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

type ConnInfoSecretSource added in v0.31.0 

type ConnInfoSecretSource struct {
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:MinLength=1
	// Name of the secret resource to read connection parameters from
	Name string `json:"name"`
	// Namespace of the source secret. If not specified, defaults to the same namespace as the resource
	Namespace string `json:"namespace,omitempty"`
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:MinLength=1
	// Key in the secret containing the password to use for authentication
	PasswordKey string `json:"passwordKey"`
}

ConnInfoSecretSource contains information about existing secret to read connection parameters from. The source secret is watched for changes, and reconciliation will be automatically triggered when the secret data is updated.

func (*ConnInfoSecretSource) DeepCopy added in v0.31.0 

func (in *ConnInfoSecretSource) DeepCopy() *ConnInfoSecretSource

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

func (*ConnInfoSecretSource) DeepCopyInto added in v0.31.0 

func (in *ConnInfoSecretSource) DeepCopyInto(out *ConnInfoSecretSource)

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

type ConnInfoSecretTarget 

type ConnInfoSecretTarget struct {
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	// Name of the secret resource to be created. By default, it is equal to the resource name
	Name string `json:"name"`
	// +kubebuilder:pruning:PreserveUnknownFields
	// Annotations added to the secret
	Annotations map[string]string `json:"annotations,omitempty"`
	// +kubebuilder:pruning:PreserveUnknownFields
	// Labels added to the secret
	Labels map[string]string `json:"labels,omitempty"`
	// Prefix for the secret's keys.
	// Added "as is" without any transformations.
	// By default, is equal to the kind name in uppercase + underscore, e.g. `KAFKA_`, `REDIS_`, etc.
	Prefix string `json:"prefix,omitempty"`
}

ConnInfoSecretTarget contains information secret name

func (*ConnInfoSecretTarget) DeepCopy 

func (in *ConnInfoSecretTarget) DeepCopy() *ConnInfoSecretTarget

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

func (*ConnInfoSecretTarget) DeepCopyInto 

func (in *ConnInfoSecretTarget) DeepCopyInto(out *ConnInfoSecretTarget)

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

type ConnectionPool 

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

	Spec   ConnectionPoolSpec   `json:"spec,omitempty"`
	Status ConnectionPoolStatus `json:"status,omitempty"`
}

ConnectionPool is the Schema for the connectionpools API. Info "Exposes secret keys": `CONNECTIONPOOL_NAME`, `CONNECTIONPOOL_HOST`, `CONNECTIONPOOL_PORT`, `CONNECTIONPOOL_DATABASE`, `CONNECTIONPOOL_USER`, `CONNECTIONPOOL_PASSWORD`, `CONNECTIONPOOL_SSLMODE`, `CONNECTIONPOOL_DATABASE_URI`, `CONNECTIONPOOL_CA_CERT` +kubebuilder:printcolumn:name="Service Name",type="string",JSONPath=".spec.serviceName" +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Database",type="string",JSONPath=".spec.databaseName" +kubebuilder:printcolumn:name="Username",type="string",JSONPath=".spec.username" +kubebuilder:printcolumn:name="Pool Size",type="string",JSONPath=".spec.poolSize" +kubebuilder:printcolumn:name="Pool Mode",type="string",JSONPath=".spec.poolMode"

func (*ConnectionPool) AuthSecretRef 

func (in *ConnectionPool) AuthSecretRef() *AuthSecretReference

func (*ConnectionPool) Conditions added in v0.16.0 

func (in *ConnectionPool) Conditions() *[]metav1.Condition

func (*ConnectionPool) DeepCopy 

func (in *ConnectionPool) DeepCopy() *ConnectionPool

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

func (*ConnectionPool) DeepCopyInto 

func (in *ConnectionPool) DeepCopyInto(out *ConnectionPool)

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

func (*ConnectionPool) DeepCopyObject 

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

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

func (*ConnectionPool) Default 

func (in *ConnectionPool) Default()

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

func (*ConnectionPool) GetConnInfoSecretTarget added in v0.12.0 

func (in *ConnectionPool) GetConnInfoSecretTarget() ConnInfoSecretTarget

func (*ConnectionPool) GetObjectMeta added in v0.31.0 

func (in *ConnectionPool) GetObjectMeta() *metav1.ObjectMeta

func (*ConnectionPool) NoSecret added in v0.17.0 

func (in *ConnectionPool) NoSecret() bool

func (*ConnectionPool) SetupWebhookWithManager 

func (in *ConnectionPool) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*ConnectionPool) ValidateCreate 

func (in *ConnectionPool) ValidateCreate() error

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

func (*ConnectionPool) ValidateDelete 

func (in *ConnectionPool) ValidateDelete() error

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

func (*ConnectionPool) ValidateUpdate 

func (in *ConnectionPool) ValidateUpdate(_ runtime.Object) error

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

type ConnectionPoolList 

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

ConnectionPoolList contains a list of ConnectionPool

func (*ConnectionPoolList) DeepCopy 

func (in *ConnectionPoolList) DeepCopy() *ConnectionPoolList

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

func (*ConnectionPoolList) DeepCopyInto 

func (in *ConnectionPoolList) DeepCopyInto(out *ConnectionPoolList)

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

func (*ConnectionPoolList) DeepCopyObject 

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

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

type ConnectionPoolSpec 

type ConnectionPoolSpec struct {
	ServiceDependant `json:",inline"`
	SecretFields     `json:",inline"`

	// +kubebuilder:validation:MaxLength=40
	// Name of the database the pool connects to
	DatabaseName string `json:"databaseName"`

	// +kubebuilder:validation:MaxLength=64
	// Name of the service user used to connect to the database
	Username string `json:"username,omitempty"`

	// +kubebuilder:validation:Min=1
	// +kubebuilder:validation:Max=1000
	// Number of connections the pool may create towards the backend server
	PoolSize int `json:"poolSize,omitempty"`

	// +kubebuilder:validation:Enum=session;transaction;statement
	// Mode the pool operates in (session, transaction, statement)
	PoolMode postgresql.PoolModeType `json:"poolMode,omitempty"`
}

ConnectionPoolSpec defines the desired state of ConnectionPool

func (*ConnectionPoolSpec) DeepCopy 

func (in *ConnectionPoolSpec) DeepCopy() *ConnectionPoolSpec

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

func (*ConnectionPoolSpec) DeepCopyInto 

func (in *ConnectionPoolSpec) DeepCopyInto(out *ConnectionPoolSpec)

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

type ConnectionPoolStatus 

type ConnectionPoolStatus struct {
	// Conditions represent the latest available observations of an ConnectionPool state
	Conditions []metav1.Condition `json:"conditions"`
}

ConnectionPoolStatus defines the observed state of ConnectionPool

func (*ConnectionPoolStatus) DeepCopy 

func (in *ConnectionPoolStatus) DeepCopy() *ConnectionPoolStatus

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

func (*ConnectionPoolStatus) DeepCopyInto 

func (in *ConnectionPoolStatus) DeepCopyInto(out *ConnectionPoolStatus)

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

type Database 

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

	Spec   DatabaseSpec   `json:"spec,omitempty"`
	Status DatabaseStatus `json:"status,omitempty"`
}

Database is the Schema for the databases API +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Service Name",type="string",JSONPath=".spec.serviceName"

func (*Database) AuthSecretRef 

func (in *Database) AuthSecretRef() *AuthSecretReference

func (*Database) Conditions added in v0.16.0 

func (in *Database) Conditions() *[]metav1.Condition

func (*Database) DeepCopy 

func (in *Database) DeepCopy() *Database

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

func (*Database) DeepCopyInto 

func (in *Database) DeepCopyInto(out *Database)

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

func (*Database) DeepCopyObject 

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

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

func (*Database) Default 

func (in *Database) Default()

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

func (*Database) GetDatabaseName added in v0.28.0 

func (in *Database) GetDatabaseName() string

func (*Database) GetObjectMeta added in v0.31.0 

func (in *Database) GetObjectMeta() *metav1.ObjectMeta

func (*Database) NoSecret added in v0.17.0 

func (*Database) NoSecret() bool

func (*Database) SetupWebhookWithManager 

func (in *Database) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Database) ValidateCreate 

func (in *Database) ValidateCreate() error

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

func (*Database) ValidateDelete 

func (in *Database) ValidateDelete() error

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

func (*Database) ValidateUpdate 

func (in *Database) ValidateUpdate(_ runtime.Object) error

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

type DatabaseList 

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

DatabaseList contains a list of Database

func (*DatabaseList) DeepCopy 

func (in *DatabaseList) DeepCopy() *DatabaseList

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

func (*DatabaseList) DeepCopyInto 

func (in *DatabaseList) DeepCopyInto(out *DatabaseList)

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

func (*DatabaseList) DeepCopyObject 

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

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

type DatabaseSpec 

type DatabaseSpec struct {
	ServiceDependant `json:",inline"`

	// +kubebuilder:validation:MaxLength=128
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	// +kubebuilder:default=en_US.UTF-8
	// Default string sort order (LC_COLLATE) of the database. Default value: en_US.UTF-8
	LcCollate string `json:"lcCollate,omitempty"`

	// +kubebuilder:validation:MaxLength=128
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	// +kubebuilder:default=en_US.UTF-8
	// Default character classification (LC_CTYPE) of the database. Default value: en_US.UTF-8
	LcCtype string `json:"lcCtype,omitempty"`

	// It is a Kubernetes side deletion protections, which prevents the database
	// from being deleted by Kubernetes. It is recommended to enable this for any production
	// databases containing critical data.
	TerminationProtection *bool `json:"terminationProtection,omitempty"`

	// +kubebuilder:validation:MaxLength=40
	// +kubebuilder:validation:Pattern="^[a-zA-Z0-9_][a-zA-Z0-9_-]{0,39}$"
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	// DatabaseName is the name of the database to be created.
	DatabaseName string `json:"databaseName,omitempty"`
}

DatabaseSpec defines the desired state of Database +kubebuilder:validation:XValidation:rule="has(oldSelf.databaseName) == has(self.databaseName)",message="databaseName can only be set during resource creation."

func (*DatabaseSpec) DeepCopy 

func (in *DatabaseSpec) DeepCopy() *DatabaseSpec

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

func (*DatabaseSpec) DeepCopyInto 

func (in *DatabaseSpec) DeepCopyInto(out *DatabaseSpec)

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

type DatabaseStatus 

type DatabaseStatus struct {
	// Conditions represent the latest available observations of an Database state
	Conditions []metav1.Condition `json:"conditions"`
}

DatabaseStatus defines the observed state of Database

func (*DatabaseStatus) DeepCopy 

func (in *DatabaseStatus) DeepCopy() *DatabaseStatus

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

func (*DatabaseStatus) DeepCopyInto 

func (in *DatabaseStatus) DeepCopyInto(out *DatabaseStatus)

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

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

	Spec   FlinkSpec     `json:"spec,omitempty"`
	Status ServiceStatus `json:"status,omitempty"`
}

Flink is the Schema for the flinks API. Info "Exposes secret keys": `FLINK_HOST`, `FLINK_PORT`, `FLINK_USER`, `FLINK_PASSWORD`, `FLINK_URI`, `FLINK_HOSTS` +kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Region",type="string",JSONPath=".spec.cloudName" +kubebuilder:printcolumn:name="Plan",type="string",JSONPath=".spec.plan" +kubebuilder:printcolumn:name="State",type="string",JSONPath=".status.state"

func (*Flink) AuthSecretRef added in v0.26.0 

func (in *Flink) AuthSecretRef() *AuthSecretReference

func (*Flink) Conditions added in v0.26.0 

func (in *Flink) Conditions() *[]metav1.Condition

func (*Flink) DeepCopy added in v0.26.0 

func (in *Flink) DeepCopy() *Flink

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

func (*Flink) DeepCopyInto added in v0.26.0 

func (in *Flink) DeepCopyInto(out *Flink)

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

func (*Flink) DeepCopyObject added in v0.26.0 

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

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

func (*Flink) Default added in v0.26.0 

func (in *Flink) Default()

func (*Flink) GetConnInfoSecretTarget added in v0.26.0 

func (in *Flink) GetConnInfoSecretTarget() ConnInfoSecretTarget

func (*Flink) GetObjectMeta added in v0.31.0 

func (in *Flink) GetObjectMeta() *metav1.ObjectMeta

func (*Flink) GetRefs added in v0.26.0 

func (in *Flink) GetRefs() []*ResourceReferenceObject

func (*Flink) NoSecret added in v0.26.0 

func (in *Flink) NoSecret() bool

func (*Flink) SetupWebhookWithManager added in v0.26.0 

func (in *Flink) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Flink) ValidateCreate added in v0.26.0 

func (in *Flink) ValidateCreate() error

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

func (*Flink) ValidateDelete added in v0.26.0 

func (in *Flink) ValidateDelete() error

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

func (*Flink) ValidateUpdate added in v0.26.0 

func (in *Flink) ValidateUpdate(_ runtime.Object) error

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

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

FlinkList contains a list of Flink

func (*FlinkList) DeepCopy added in v0.26.0 

func (in *FlinkList) DeepCopy() *FlinkList

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

func (*FlinkList) DeepCopyInto added in v0.26.0 

func (in *FlinkList) DeepCopyInto(out *FlinkList)

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

func (*FlinkList) DeepCopyObject added in v0.26.0 

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

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

type FlinkSpec added in v0.26.0 

type FlinkSpec struct {
	ServiceCommonSpec `json:",inline"`

	// Cassandra specific user configuration options
	UserConfig *flinkuserconfig.FlinkUserConfig `json:"userConfig,omitempty"`
}

FlinkSpec defines the desired state of Flink

func (*FlinkSpec) DeepCopy added in v0.26.0 

func (in *FlinkSpec) DeepCopy() *FlinkSpec

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

func (*FlinkSpec) DeepCopyInto added in v0.26.0 

func (in *FlinkSpec) DeepCopyInto(out *FlinkSpec)

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

type Grafana added in v0.7.0 

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

	Spec   GrafanaSpec   `json:"spec,omitempty"`
	Status ServiceStatus `json:"status,omitempty"`
}

Grafana is the Schema for the grafanas API. Info "Exposes secret keys": `GRAFANA_HOST`, `GRAFANA_PORT`, `GRAFANA_USER`, `GRAFANA_PASSWORD`, `GRAFANA_URI`, `GRAFANA_HOSTS` +kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Region",type="string",JSONPath=".spec.cloudName" +kubebuilder:printcolumn:name="Plan",type="string",JSONPath=".spec.plan" +kubebuilder:printcolumn:name="State",type="string",JSONPath=".status.state"

func (*Grafana) AuthSecretRef added in v0.7.0 

func (in *Grafana) AuthSecretRef() *AuthSecretReference

func (*Grafana) Conditions added in v0.16.0 

func (in *Grafana) Conditions() *[]metav1.Condition

func (*Grafana) DeepCopy added in v0.7.0 

func (in *Grafana) DeepCopy() *Grafana

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

func (*Grafana) DeepCopyInto added in v0.7.0 

func (in *Grafana) DeepCopyInto(out *Grafana)

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

func (*Grafana) DeepCopyObject added in v0.7.0 

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

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

func (*Grafana) Default added in v0.7.0 

func (in *Grafana) Default()

func (*Grafana) GetConnInfoSecretTarget added in v0.12.0 

func (in *Grafana) GetConnInfoSecretTarget() ConnInfoSecretTarget

func (*Grafana) GetObjectMeta added in v0.31.0 

func (in *Grafana) GetObjectMeta() *metav1.ObjectMeta

func (*Grafana) GetRefs added in v0.7.0 

func (in *Grafana) GetRefs() []*ResourceReferenceObject

func (*Grafana) NoSecret added in v0.17.0 

func (in *Grafana) NoSecret() bool

func (*Grafana) SetupWebhookWithManager added in v0.7.0 

func (in *Grafana) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Grafana) ValidateCreate added in v0.7.0 

func (in *Grafana) ValidateCreate() error

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

func (*Grafana) ValidateDelete added in v0.7.0 

func (in *Grafana) ValidateDelete() error

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

func (*Grafana) ValidateUpdate added in v0.7.0 

func (in *Grafana) ValidateUpdate(_ runtime.Object) error

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

type GrafanaList added in v0.7.0 

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

GrafanaList contains a list of Grafana

func (*GrafanaList) DeepCopy added in v0.7.0 

func (in *GrafanaList) DeepCopy() *GrafanaList

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

func (*GrafanaList) DeepCopyInto added in v0.7.0 

func (in *GrafanaList) DeepCopyInto(out *GrafanaList)

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

func (*GrafanaList) DeepCopyObject added in v0.7.0 

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

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

type GrafanaSpec added in v0.7.0 

type GrafanaSpec struct {
	ServiceCommonSpec `json:",inline"`

	// Cassandra specific user configuration options
	UserConfig *grafanauserconfig.GrafanaUserConfig `json:"userConfig,omitempty"`
}

GrafanaSpec defines the desired state of Grafana

func (*GrafanaSpec) DeepCopy added in v0.7.0 

func (in *GrafanaSpec) DeepCopy() *GrafanaSpec

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

func (*GrafanaSpec) DeepCopyInto added in v0.7.0 

func (in *GrafanaSpec) DeepCopyInto(out *GrafanaSpec)

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

type Grantee added in v0.21.0 

type Grantee struct {
	User string `json:"user,omitempty"`
	Role string `json:"role,omitempty"`
}

Grantee represents a user or a role to which privileges or roles are granted. Warning "Ambiguity in the `GRANT` syntax": Due to [an ambiguity](https://github.com/aiven/ospo-tracker/issues/350) in the GRANT syntax in ClickHouse, users and roles should not share the same name. It is unclear whether a grant applies to the user or the role.

func (*Grantee) DeepCopy added in v0.21.0 

func (in *Grantee) DeepCopy() *Grantee

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

func (*Grantee) DeepCopyInto added in v0.21.0 

func (in *Grantee) DeepCopyInto(out *Grantee)

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

type Grants added in v0.24.0 

type Grants struct {
	// Configuration to grant a privilege. Privileges not in the manifest are revoked. Existing privileges are retained; new ones are granted.
	PrivilegeGrants []PrivilegeGrant `json:"privilegeGrants,omitempty"`
	// Configuration to grant a role. Role grants not in the manifest are revoked. Existing role grants are retained; new ones are granted.
	RoleGrants []RoleGrant `json:"roleGrants,omitempty"`
}

func (*Grants) BuildStatements added in v0.24.0 

func (in *Grants) BuildStatements(statementType chUtils.StatementType) []string

func (*Grants) DeepCopy added in v0.24.0 

func (in *Grants) DeepCopy() *Grants

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

func (*Grants) DeepCopyInto added in v0.24.0 

func (in *Grants) DeepCopyInto(out *Grants)

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

type Kafka 

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

	Spec   KafkaSpec     `json:"spec,omitempty"`
	Status ServiceStatus `json:"status,omitempty"`
}

Kafka is the Schema for the kafkas API. Info "Exposes secret keys": `KAFKA_HOST`, `KAFKA_PORT`, `KAFKA_USERNAME`, `KAFKA_PASSWORD`, `KAFKA_ACCESS_CERT`, `KAFKA_ACCESS_KEY`, `KAFKA_SASL_HOST`, `KAFKA_SASL_PORT`, `KAFKA_SCHEMA_REGISTRY_HOST`, `KAFKA_SCHEMA_REGISTRY_PORT`, `KAFKA_CONNECT_HOST`, `KAFKA_CONNECT_PORT`, `KAFKA_REST_HOST`, `KAFKA_REST_PORT`, `KAFKA_CA_CERT` +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Region",type="string",JSONPath=".spec.cloudName" +kubebuilder:printcolumn:name="Plan",type="string",JSONPath=".spec.plan" +kubebuilder:printcolumn:name="State",type="string",JSONPath=".status.state"

func (*Kafka) AuthSecretRef 

func (in *Kafka) AuthSecretRef() *AuthSecretReference

func (*Kafka) Conditions added in v0.16.0 

func (in *Kafka) Conditions() *[]metav1.Condition

func (*Kafka) DeepCopy 

func (in *Kafka) DeepCopy() *Kafka

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

func (*Kafka) DeepCopyInto 

func (in *Kafka) DeepCopyInto(out *Kafka)

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

func (*Kafka) DeepCopyObject 

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

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

func (*Kafka) Default 

func (in *Kafka) Default()

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

func (*Kafka) GetConnInfoSecretTarget added in v0.12.0 

func (in *Kafka) GetConnInfoSecretTarget() ConnInfoSecretTarget

func (*Kafka) GetObjectMeta added in v0.31.0 

func (in *Kafka) GetObjectMeta() *metav1.ObjectMeta

func (*Kafka) GetRefs added in v0.5.0 

func (in *Kafka) GetRefs() []*ResourceReferenceObject

func (*Kafka) NoSecret added in v0.17.0 

func (in *Kafka) NoSecret() bool

func (*Kafka) SetupWebhookWithManager 

func (in *Kafka) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Kafka) ValidateCreate 

func (in *Kafka) ValidateCreate() error

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

func (*Kafka) ValidateDelete 

func (in *Kafka) ValidateDelete() error

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

func (*Kafka) ValidateUpdate 

func (in *Kafka) ValidateUpdate(_ runtime.Object) error

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

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 +kubebuilder:printcolumn:name="Service Name",type="string",JSONPath=".spec.serviceName" +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Username",type="string",JSONPath=".spec.username" +kubebuilder:printcolumn:name="Permission",type="string",JSONPath=".spec.permission" +kubebuilder:printcolumn:name="Topic",type="string",JSONPath=".spec.topic"

func (*KafkaACL) AuthSecretRef 

func (in *KafkaACL) AuthSecretRef() *AuthSecretReference

func (*KafkaACL) Conditions added in v0.16.0 

func (in *KafkaACL) Conditions() *[]metav1.Condition

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 

func (in *KafkaACL) Default()

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

func (*KafkaACL) GetObjectMeta added in v0.31.0 

func (in *KafkaACL) GetObjectMeta() *metav1.ObjectMeta

func (*KafkaACL) NoSecret added in v0.17.0 

func (*KafkaACL) NoSecret() bool

func (*KafkaACL) SetupWebhookWithManager 

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

func (*KafkaACL) ValidateCreate 

func (in *KafkaACL) ValidateCreate() error

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

func (*KafkaACL) ValidateDelete 

func (in *KafkaACL) ValidateDelete() error

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

func (*KafkaACL) ValidateUpdate 

func (in *KafkaACL) ValidateUpdate(_ 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 {
	ServiceDependant `json:",inline"`

	// +kubebuilder:validation:Enum=admin;read;readwrite;write
	// Kafka permission to grant (admin, read, readwrite, write)
	Permission kafka.PermissionType `json:"permission"`

	// Topic name pattern for the ACL entry
	Topic string `json:"topic"`

	// Username pattern for the ACL entry
	Username string `json:"username"`
}

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 {
	// Conditions represent the latest available observations of an KafkaACL state
	Conditions []metav1.Condition `json:"conditions"`

	// Kafka ACL ID
	ID string `json:"id"`
}

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 KafkaConnect 

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

	Spec   KafkaConnectSpec `json:"spec,omitempty"`
	Status ServiceStatus    `json:"status,omitempty"`
}

KafkaConnect is the Schema for the kafkaconnects API +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Region",type="string",JSONPath=".spec.cloudName" +kubebuilder:printcolumn:name="Plan",type="string",JSONPath=".spec.plan" +kubebuilder:printcolumn:name="State",type="string",JSONPath=".status.state"

func (*KafkaConnect) AuthSecretRef 

func (in *KafkaConnect) AuthSecretRef() *AuthSecretReference

func (*KafkaConnect) Conditions added in v0.16.0 

func (in *KafkaConnect) Conditions() *[]metav1.Condition

func (*KafkaConnect) DeepCopy 

func (in *KafkaConnect) DeepCopy() *KafkaConnect

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

func (*KafkaConnect) DeepCopyInto 

func (in *KafkaConnect) DeepCopyInto(out *KafkaConnect)

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

func (*KafkaConnect) DeepCopyObject 

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

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

func (*KafkaConnect) Default 

func (in *KafkaConnect) Default()

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

func (*KafkaConnect) GetObjectMeta added in v0.31.0 

func (in *KafkaConnect) GetObjectMeta() *metav1.ObjectMeta

func (*KafkaConnect) GetRefs added in v0.5.0 

func (in *KafkaConnect) GetRefs() []*ResourceReferenceObject

func (*KafkaConnect) NoSecret added in v0.17.0 

func (*KafkaConnect) NoSecret() bool

func (*KafkaConnect) SetupWebhookWithManager 

func (in *KafkaConnect) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*KafkaConnect) ValidateCreate 

func (in *KafkaConnect) ValidateCreate() error

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

func (*KafkaConnect) ValidateDelete 

func (in *KafkaConnect) ValidateDelete() error

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

func (*KafkaConnect) ValidateUpdate 

func (in *KafkaConnect) ValidateUpdate(old runtime.Object) error

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

type KafkaConnectList 

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

KafkaConnectList contains a list of KafkaConnect

func (*KafkaConnectList) DeepCopy 

func (in *KafkaConnectList) DeepCopy() *KafkaConnectList

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

func (*KafkaConnectList) DeepCopyInto 

func (in *KafkaConnectList) DeepCopyInto(out *KafkaConnectList)

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

func (*KafkaConnectList) DeepCopyObject 

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

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

type KafkaConnectSpec 

type KafkaConnectSpec struct {
	BaseServiceFields `json:",inline"`

	// KafkaConnect specific user configuration options
	UserConfig *kafkaconnectuserconfig.KafkaConnectUserConfig `json:"userConfig,omitempty"`
}

KafkaConnectSpec defines the desired state of KafkaConnect

func (*KafkaConnectSpec) DeepCopy 

func (in *KafkaConnectSpec) DeepCopy() *KafkaConnectSpec

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

func (*KafkaConnectSpec) DeepCopyInto 

func (in *KafkaConnectSpec) DeepCopyInto(out *KafkaConnectSpec)

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

type KafkaConnector 

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

	Spec   KafkaConnectorSpec   `json:"spec,omitempty"`
	Status KafkaConnectorStatus `json:"status,omitempty"`
}

KafkaConnector is the Schema for the kafkaconnectors API +kubebuilder:printcolumn:name="Service Name",type="string",JSONPath=".spec.serviceName" +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Connector Class",type="string",JSONPath=".spec.connectorClass" +kubebuilder:printcolumn:name="State",type="string",JSONPath=".status.state" +kubebuilder:printcolumn:name="Tasks Total",type="integer",JSONPath=".status.tasksStatus.total" +kubebuilder:printcolumn:name="Tasks Running",type="integer",JSONPath=".status.tasksStatus.running"

func (*KafkaConnector) AuthSecretRef 

func (in *KafkaConnector) AuthSecretRef() *AuthSecretReference

func (*KafkaConnector) Conditions added in v0.16.0 

func (in *KafkaConnector) Conditions() *[]metav1.Condition

func (*KafkaConnector) DeepCopy 

func (in *KafkaConnector) DeepCopy() *KafkaConnector

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

func (*KafkaConnector) DeepCopyInto 

func (in *KafkaConnector) DeepCopyInto(out *KafkaConnector)

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

func (*KafkaConnector) DeepCopyObject 

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

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

func (*KafkaConnector) Default 

func (in *KafkaConnector) Default()

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

func (*KafkaConnector) GetObjectMeta added in v0.31.0 

func (in *KafkaConnector) GetObjectMeta() *metav1.ObjectMeta

func (*KafkaConnector) NoSecret added in v0.17.0 

func (*KafkaConnector) NoSecret() bool

func (*KafkaConnector) SetupWebhookWithManager 

func (in *KafkaConnector) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*KafkaConnector) ValidateCreate 

func (in *KafkaConnector) ValidateCreate() error

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

func (*KafkaConnector) ValidateDelete 

func (in *KafkaConnector) ValidateDelete() error

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

func (*KafkaConnector) ValidateUpdate 

func (in *KafkaConnector) ValidateUpdate(_ runtime.Object) error

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

type KafkaConnectorList 

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

KafkaConnectorList contains a list of KafkaConnector

func (*KafkaConnectorList) DeepCopy 

func (in *KafkaConnectorList) DeepCopy() *KafkaConnectorList

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

func (*KafkaConnectorList) DeepCopyInto 

func (in *KafkaConnectorList) DeepCopyInto(out *KafkaConnectorList)

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

func (*KafkaConnectorList) DeepCopyObject 

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

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

type KafkaConnectorPluginStatus 

type KafkaConnectorPluginStatus struct {
	Author  string `json:"author"`
	Class   string `json:"class"`
	DocURL  string `json:"docUrl"`
	Title   string `json:"title"`
	Type    string `json:"type"`
	Version string `json:"version"`
}

KafkaConnectorPluginStatus describes the observed state of a Kafka Connector Plugin

func (*KafkaConnectorPluginStatus) DeepCopy 

func (in *KafkaConnectorPluginStatus) DeepCopy() *KafkaConnectorPluginStatus

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

func (*KafkaConnectorPluginStatus) DeepCopyInto 

func (in *KafkaConnectorPluginStatus) DeepCopyInto(out *KafkaConnectorPluginStatus)

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

type KafkaConnectorSpec 

type KafkaConnectorSpec struct {
	ServiceDependant `json:",inline"`

	// +kubebuilder:validation:MaxLength=1024
	// The Java class of the connector.
	ConnectorClass string `json:"connectorClass"`

	// The connector-specific configuration
	// To build config values from secret the template function `{{ fromSecret "name" "key" }}`
	// is provided when interpreting the keys.
	// Where "name" is the name of the secret and "key" is the key in the secret
	// in the same namespace as the KafkaConnector.
	UserConfig map[string]string `json:"userConfig"`
}

KafkaConnectorSpec defines the desired state of KafkaConnector

func (*KafkaConnectorSpec) DeepCopy 

func (in *KafkaConnectorSpec) DeepCopy() *KafkaConnectorSpec

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

func (*KafkaConnectorSpec) DeepCopyInto 

func (in *KafkaConnectorSpec) DeepCopyInto(out *KafkaConnectorSpec)

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

type KafkaConnectorStatus 

type KafkaConnectorStatus struct {
	// Conditions represent the latest available observations of an kafka connector state
	Conditions []metav1.Condition `json:"conditions"`

	// Connector state
	State kafkaconnect.ServiceKafkaConnectConnectorStateType `json:"state"`

	// PluginStatus contains metadata about the configured connector plugin
	PluginStatus KafkaConnectorPluginStatus `json:"pluginStatus"`

	// TasksStatus contains metadata about the running tasks
	TasksStatus KafkaConnectorTasksStatus `json:"tasksStatus"`
}

KafkaConnectorStatus defines the observed state of KafkaConnector

func (*KafkaConnectorStatus) DeepCopy 

func (in *KafkaConnectorStatus) DeepCopy() *KafkaConnectorStatus

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

func (*KafkaConnectorStatus) DeepCopyInto 

func (in *KafkaConnectorStatus) DeepCopyInto(out *KafkaConnectorStatus)

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

type KafkaConnectorTasksStatus 

type KafkaConnectorTasksStatus struct {
	Total      uint   `json:"total"`
	Running    uint   `json:"running,omitempty"`
	Failed     uint   `json:"failed,omitempty"`
	Paused     uint   `json:"paused,omitempty"`
	Unassigned uint   `json:"unassigned,omitempty"`
	Unknown    uint   `json:"unknown,omitempty"`
	StackTrace string `json:"stackTrace,omitempty"`
}

KafkaConnectorTasksStatus describes the observed state of the Kafka Connector Tasks

func (*KafkaConnectorTasksStatus) DeepCopy 

func (in *KafkaConnectorTasksStatus) DeepCopy() *KafkaConnectorTasksStatus

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

func (*KafkaConnectorTasksStatus) DeepCopyInto 

func (in *KafkaConnectorTasksStatus) DeepCopyInto(out *KafkaConnectorTasksStatus)

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

type KafkaList 

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

KafkaList contains a list of Kafka

func (*KafkaList) DeepCopy 

func (in *KafkaList) DeepCopy() *KafkaList

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

func (*KafkaList) DeepCopyInto 

func (in *KafkaList) DeepCopyInto(out *KafkaList)

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

func (*KafkaList) DeepCopyObject 

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

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

type KafkaNativeACL added in v0.30.0 

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

	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	Spec   KafkaNativeACLSpec   `json:"spec,omitempty"`
	Status KafkaNativeACLStatus `json:"status,omitempty"`
}

KafkaNativeACL Creates and manages Kafka-native access control lists (ACLs) for an Aiven for Apache Kafka® service. ACLs control access to Kafka topics, consumer groups, clusters, and Schema Registry. Kafka-native ACLs provide advanced resource-level access control with fine-grained permissions, including ALLOW and DENY rules. For simplified topic-level control, you can use KafkaACL(./kafkaacl.md). +kubebuilder:printcolumn:name="Service Name",type="string",JSONPath=".spec.serviceName" +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Host",type="string",JSONPath=".spec.host" +kubebuilder:printcolumn:name="Operation",type="string",JSONPath=".spec.operation" +kubebuilder:printcolumn:name="PatternType",type="string",JSONPath=".spec.patternType" +kubebuilder:printcolumn:name="PermissionType",type="string",JSONPath=".spec.permissionType"

func (*KafkaNativeACL) AuthSecretRef added in v0.30.0 

func (in *KafkaNativeACL) AuthSecretRef() *AuthSecretReference

func (*KafkaNativeACL) Conditions added in v0.30.0 

func (in *KafkaNativeACL) Conditions() *[]metav1.Condition

func (*KafkaNativeACL) DeepCopy added in v0.30.0 

func (in *KafkaNativeACL) DeepCopy() *KafkaNativeACL

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

func (*KafkaNativeACL) DeepCopyInto added in v0.30.0 

func (in *KafkaNativeACL) DeepCopyInto(out *KafkaNativeACL)

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

func (*KafkaNativeACL) DeepCopyObject added in v0.30.0 

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

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

func (*KafkaNativeACL) GetObjectMeta added in v0.31.0 

func (in *KafkaNativeACL) GetObjectMeta() *metav1.ObjectMeta

func (*KafkaNativeACL) NoSecret added in v0.30.0 

func (in *KafkaNativeACL) NoSecret() bool

type KafkaNativeACLList added in v0.30.0 

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

KafkaNativeACLList contains a list of KafkaNativeACL

func (*KafkaNativeACLList) DeepCopy added in v0.30.0 

func (in *KafkaNativeACLList) DeepCopy() *KafkaNativeACLList

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

func (*KafkaNativeACLList) DeepCopyInto added in v0.30.0 

func (in *KafkaNativeACLList) DeepCopyInto(out *KafkaNativeACLList)

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

func (*KafkaNativeACLList) DeepCopyObject added in v0.30.0 

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

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

type KafkaNativeACLSpec added in v0.30.0 

type KafkaNativeACLSpec struct {
	ServiceDependant `json:",inline"`

	// +kubebuilder:validation:MaxLength=256
	// +kubebuilder:default="*"
	// The host or `*` for all hosts
	Host string `json:"host,omitempty"`

	// +kubebuilder:validation:Enum=All;Alter;AlterConfigs;ClusterAction;Create;CreateTokens;Delete;Describe;DescribeConfigs;DescribeTokens;IdempotentWrite;Read;Write
	// Kafka ACL operation represents an operation which an ACL grants or denies permission to perform
	Operation kafka.OperationType `json:"operation"`

	// +kubebuilder:validation:Enum=LITERAL;PREFIXED
	// Kafka ACL pattern type of resource name
	PatternType kafka.PatternType `json:"patternType"`

	// +kubebuilder:validation:Enum=ALLOW;DENY
	// Kafka ACL permission type
	PermissionType kafka.ServiceKafkaNativeAclPermissionType `json:"permissionType"`

	// +kubebuilder:validation:MaxLength=256
	// Principal is in 'PrincipalType:name' format
	Principal string `json:"principal"`

	// +kubebuilder:validation:MaxLength=256
	// Resource pattern used to match specified resources
	ResourceName string `json:"resourceName"`

	// +kubebuilder:validation:Enum=Cluster;DelegationToken;Group;Topic;TransactionalId;User
	// Kafka ACL resource type represents a type of resource which an ACL can be applied to
	ResourceType kafka.ResourceType `json:"resourceType"`
}

KafkaNativeACLSpec defines the desired state of KafkaNativeACL

func (*KafkaNativeACLSpec) DeepCopy added in v0.30.0 

func (in *KafkaNativeACLSpec) DeepCopy() *KafkaNativeACLSpec

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

func (*KafkaNativeACLSpec) DeepCopyInto added in v0.30.0 

func (in *KafkaNativeACLSpec) DeepCopyInto(out *KafkaNativeACLSpec)

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

type KafkaNativeACLStatus added in v0.30.0 

type KafkaNativeACLStatus struct {
	// Conditions represent the latest available observations of an KafkaNativeACL state
	Conditions []metav1.Condition `json:"conditions"`

	// Kafka-native ACL ID
	ID string `json:"id"`
}

KafkaNativeACLStatus defines the observed state of KafkaNativeACL

func (*KafkaNativeACLStatus) DeepCopy added in v0.30.0 

func (in *KafkaNativeACLStatus) DeepCopy() *KafkaNativeACLStatus

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

func (*KafkaNativeACLStatus) DeepCopyInto added in v0.30.0 

func (in *KafkaNativeACLStatus) DeepCopyInto(out *KafkaNativeACLStatus)

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

type KafkaSchema 

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

	Spec   KafkaSchemaSpec   `json:"spec,omitempty"`
	Status KafkaSchemaStatus `json:"status,omitempty"`
}

KafkaSchema is the Schema for the kafkaschemas API +kubebuilder:printcolumn:name="Service Name",type="string",JSONPath=".spec.serviceName" +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Subject",type="string",JSONPath=".spec.subjectName" +kubebuilder:printcolumn:name="Compatibility Level",type="string",JSONPath=".spec.compatibilityLevel" +kubebuilder:printcolumn:name="Version",type="number",JSONPath=".status.version"

func (*KafkaSchema) AuthSecretRef 

func (in *KafkaSchema) AuthSecretRef() *AuthSecretReference

func (*KafkaSchema) Conditions added in v0.16.0 

func (in *KafkaSchema) Conditions() *[]metav1.Condition

func (*KafkaSchema) DeepCopy 

func (in *KafkaSchema) DeepCopy() *KafkaSchema

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

func (*KafkaSchema) DeepCopyInto 

func (in *KafkaSchema) DeepCopyInto(out *KafkaSchema)

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

func (*KafkaSchema) DeepCopyObject 

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

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

func (*KafkaSchema) Default 

func (in *KafkaSchema) Default()

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

func (*KafkaSchema) GetObjectMeta added in v0.31.0 

func (in *KafkaSchema) GetObjectMeta() *metav1.ObjectMeta

func (*KafkaSchema) NoSecret added in v0.17.0 

func (*KafkaSchema) NoSecret() bool

func (*KafkaSchema) SetupWebhookWithManager 

func (in *KafkaSchema) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*KafkaSchema) ValidateCreate 

func (in *KafkaSchema) ValidateCreate() error

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

func (*KafkaSchema) ValidateDelete 

func (in *KafkaSchema) ValidateDelete() error

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

func (*KafkaSchema) ValidateUpdate 

func (in *KafkaSchema) ValidateUpdate(old runtime.Object) error

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

type KafkaSchemaList 

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

KafkaSchemaList contains a list of KafkaSchema

func (*KafkaSchemaList) DeepCopy 

func (in *KafkaSchemaList) DeepCopy() *KafkaSchemaList

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

func (*KafkaSchemaList) DeepCopyInto 

func (in *KafkaSchemaList) DeepCopyInto(out *KafkaSchemaList)

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

func (*KafkaSchemaList) DeepCopyObject 

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

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

type KafkaSchemaRegistryACL added in v0.18.0 

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

	Spec   KafkaSchemaRegistryACLSpec   `json:"spec,omitempty"`
	Status KafkaSchemaRegistryACLStatus `json:"status,omitempty"`
}

KafkaSchemaRegistryACL is the Schema for the kafkaschemaregistryacls API +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Service Name",type="string",JSONPath=".spec.serviceName" +kubebuilder:printcolumn:name="Resource",type="string",JSONPath=".spec.resource" +kubebuilder:printcolumn:name="Username",type="string",JSONPath=".spec.username" +kubebuilder:printcolumn:name="State",type="string",JSONPath=".status.state"

func (*KafkaSchemaRegistryACL) AuthSecretRef added in v0.18.0 

func (in *KafkaSchemaRegistryACL) AuthSecretRef() *AuthSecretReference

func (*KafkaSchemaRegistryACL) Conditions added in v0.18.0 

func (in *KafkaSchemaRegistryACL) Conditions() *[]metav1.Condition

func (*KafkaSchemaRegistryACL) DeepCopy added in v0.18.0 

func (in *KafkaSchemaRegistryACL) DeepCopy() *KafkaSchemaRegistryACL

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

func (*KafkaSchemaRegistryACL) DeepCopyInto added in v0.18.0 

func (in *KafkaSchemaRegistryACL) DeepCopyInto(out *KafkaSchemaRegistryACL)

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

func (*KafkaSchemaRegistryACL) DeepCopyObject added in v0.18.0 

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

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

func (*KafkaSchemaRegistryACL) GetObjectMeta added in v0.31.0 

func (in *KafkaSchemaRegistryACL) GetObjectMeta() *metav1.ObjectMeta

func (*KafkaSchemaRegistryACL) NoSecret added in v0.18.0 

func (in *KafkaSchemaRegistryACL) NoSecret() bool

type KafkaSchemaRegistryACLList added in v0.18.0 

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

KafkaSchemaRegistryACLList contains a list of KafkaSchemaRegistryACL

func (*KafkaSchemaRegistryACLList) DeepCopy added in v0.18.0 

func (in *KafkaSchemaRegistryACLList) DeepCopy() *KafkaSchemaRegistryACLList

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

func (*KafkaSchemaRegistryACLList) DeepCopyInto added in v0.18.0 

func (in *KafkaSchemaRegistryACLList) DeepCopyInto(out *KafkaSchemaRegistryACLList)

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

func (*KafkaSchemaRegistryACLList) DeepCopyObject added in v0.18.0 

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

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

type KafkaSchemaRegistryACLSpec added in v0.18.0 

type KafkaSchemaRegistryACLSpec struct {
	ServiceDependant `json:",inline"`

	// +kubebuilder:validation:Enum=schema_registry_read;schema_registry_write
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	Permission string `json:"permission"`

	// +kubebuilder:validation:MaxLength=249
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	// Resource name pattern for the Schema Registry ACL entry
	Resource string `json:"resource"`

	// +kubebuilder:validation:MaxLength=64
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	// Username pattern for the ACL entry
	Username string `json:"username"`
}

KafkaSchemaRegistryACLSpec defines the desired state of KafkaSchemaRegistryACL

func (*KafkaSchemaRegistryACLSpec) DeepCopy added in v0.18.0 

func (in *KafkaSchemaRegistryACLSpec) DeepCopy() *KafkaSchemaRegistryACLSpec

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

func (*KafkaSchemaRegistryACLSpec) DeepCopyInto added in v0.18.0 

func (in *KafkaSchemaRegistryACLSpec) DeepCopyInto(out *KafkaSchemaRegistryACLSpec)

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

type KafkaSchemaRegistryACLStatus added in v0.18.0 

type KafkaSchemaRegistryACLStatus struct {
	// Conditions represent the latest available observations of an KafkaSchemaRegistryACL state
	Conditions []metav1.Condition `json:"conditions"`

	// Kafka ACL ID
	ACLId string `json:"acl_id"`
}

KafkaSchemaRegistryACLStatus defines the observed state of KafkaSchemaRegistryACL

func (*KafkaSchemaRegistryACLStatus) DeepCopy added in v0.18.0 

func (in *KafkaSchemaRegistryACLStatus) DeepCopy() *KafkaSchemaRegistryACLStatus

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

func (*KafkaSchemaRegistryACLStatus) DeepCopyInto added in v0.18.0 

func (in *KafkaSchemaRegistryACLStatus) DeepCopyInto(out *KafkaSchemaRegistryACLStatus)

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

type KafkaSchemaSpec 

type KafkaSchemaSpec struct {
	ServiceDependant `json:",inline"`

	// +kubebuilder:validation:MaxLength=63
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	// Kafka Schema Subject name
	SubjectName string `json:"subjectName"`

	// Kafka Schema configuration should be a valid Avro Schema JSON format
	Schema string `json:"schema"`

	// +kubebuilder:validation:Enum=AVRO;JSON;PROTOBUF
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	// Schema type
	SchemaType kafkaschemaregistry.SchemaType `json:"schemaType,omitempty"`

	// +kubebuilder:validation:Enum=BACKWARD;BACKWARD_TRANSITIVE;FORWARD;FORWARD_TRANSITIVE;FULL;FULL_TRANSITIVE;NONE
	// Kafka Schemas compatibility level
	CompatibilityLevel kafkaschemaregistry.CompatibilityType `json:"compatibilityLevel,omitempty"`
}

KafkaSchemaSpec defines the desired state of KafkaSchema

func (*KafkaSchemaSpec) DeepCopy 

func (in *KafkaSchemaSpec) DeepCopy() *KafkaSchemaSpec

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

func (*KafkaSchemaSpec) DeepCopyInto 

func (in *KafkaSchemaSpec) DeepCopyInto(out *KafkaSchemaSpec)

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

type KafkaSchemaStatus 

type KafkaSchemaStatus struct {
	// Conditions represent the latest available observations of an KafkaSchema state
	Conditions []metav1.Condition `json:"conditions"`

	// Schema ID
	ID int `json:"id"`

	// Kafka Schema configuration version
	Version int `json:"version"`
}

KafkaSchemaStatus defines the observed state of KafkaSchema

func (*KafkaSchemaStatus) DeepCopy 

func (in *KafkaSchemaStatus) DeepCopy() *KafkaSchemaStatus

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

func (*KafkaSchemaStatus) DeepCopyInto 

func (in *KafkaSchemaStatus) DeepCopyInto(out *KafkaSchemaStatus)

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

type KafkaSpec 

type KafkaSpec struct {
	ServiceCommonSpec `json:",inline"`

	// Switch the service to use Karapace for schema registry and REST proxy
	Karapace *bool `json:"karapace,omitempty"`

	// Kafka specific user configuration options
	UserConfig *kafkauserconfig.KafkaUserConfig `json:"userConfig,omitempty"`
}

KafkaSpec defines the desired state of Kafka

func (*KafkaSpec) DeepCopy 

func (in *KafkaSpec) DeepCopy() *KafkaSpec

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

func (*KafkaSpec) DeepCopyInto 

func (in *KafkaSpec) DeepCopyInto(out *KafkaSpec)

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

type KafkaTopic 

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

	Spec   KafkaTopicSpec   `json:"spec,omitempty"`
	Status KafkaTopicStatus `json:"status,omitempty"`
}

KafkaTopic is the Schema for the kafkatopics API +kubebuilder:printcolumn:name="Service Name",type="string",JSONPath=".spec.serviceName" +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Partitions",type="string",JSONPath=".spec.partitions" +kubebuilder:printcolumn:name="Replication",type="string",JSONPath=".spec.replication"

func (*KafkaTopic) AuthSecretRef 

func (in *KafkaTopic) AuthSecretRef() *AuthSecretReference

func (*KafkaTopic) Conditions added in v0.16.0 

func (in *KafkaTopic) Conditions() *[]metav1.Condition

func (*KafkaTopic) DeepCopy 

func (in *KafkaTopic) DeepCopy() *KafkaTopic

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

func (*KafkaTopic) DeepCopyInto 

func (in *KafkaTopic) DeepCopyInto(out *KafkaTopic)

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

func (*KafkaTopic) DeepCopyObject 

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

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

func (*KafkaTopic) Default 

func (in *KafkaTopic) Default()

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

func (*KafkaTopic) GetObjectMeta added in v0.31.0 

func (in *KafkaTopic) GetObjectMeta() *metav1.ObjectMeta

func (*KafkaTopic) GetTopicName added in v0.9.0 

func (in *KafkaTopic) GetTopicName() string

GetTopicName returns topic name with a backward compatibility. metadata.Name is deprecated

func (*KafkaTopic) NoSecret added in v0.17.0 

func (*KafkaTopic) NoSecret() bool

func (*KafkaTopic) SetupWebhookWithManager 

func (in *KafkaTopic) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*KafkaTopic) ValidateCreate 

func (in *KafkaTopic) ValidateCreate() error

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

func (*KafkaTopic) ValidateDelete 

func (in *KafkaTopic) ValidateDelete() error

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

func (*KafkaTopic) ValidateUpdate 

func (in *KafkaTopic) ValidateUpdate(old runtime.Object) error

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

type KafkaTopicConfig 

type KafkaTopicConfig struct {
	// The retention policy to use on old segments. Possible values include 'delete', 'compact', or a comma-separated list of them. The default policy ('delete') will discard old segments when their retention time or size limit has been reached. The 'compact' setting will enable log compaction on the topic.
	CleanupPolicy kafkatopic.CleanupPolicyType `json:"cleanup_policy,omitempty"`

	// Specify the final compression type for a given topic. This configuration accepts the standard compression codecs ('gzip', 'snappy', 'lz4', 'zstd'). It additionally accepts 'uncompressed' which is equivalent to no compression; and 'producer' which means retain the original compression codec set by the producer.
	CompressionType kafkatopic.CompressionType `json:"compression_type,omitempty"`

	// The amount of time to retain delete tombstone markers for log compacted topics. This setting also gives a bound on the time in which a consumer must complete a read if they begin from offset 0 to ensure that they get a valid snapshot of the final stage (otherwise delete tombstones may be collected before they complete their scan).
	DeleteRetentionMs *int `json:"delete_retention_ms,omitempty"`

	// The time to wait before deleting a file from the filesystem.
	FileDeleteDelayMs *int `json:"file_delete_delay_ms,omitempty"`

	// This setting allows specifying an interval at which we will force an fsync of data written to the log. For example if this was set to 1 we would fsync after every message; if it were 5 we would fsync after every five messages. In general we recommend you not set this and use replication for durability and allow the operating system's background flush capabilities as it is more efficient.
	FlushMessages *int `json:"flush_messages,omitempty"`

	// This setting allows specifying a time interval at which we will force an fsync of data written to the log. For example if this was set to 1000 we would fsync after 1000 ms had passed. In general we recommend you not set this and use replication for durability and allow the operating system's background flush capabilities as it is more efficient.
	FlushMs *int `json:"flush_ms,omitempty"`

	// This setting controls how frequently Kafka adds an index entry to its offset index. The default setting ensures that we index a message roughly every 4096 bytes. More indexing allows reads to jump closer to the exact position in the log but makes the index larger. You probably don't need to change this.
	IndexIntervalBytes *int `json:"index_interval_bytes,omitempty"`

	// Indicates whether diskless should be enabled.
	DisklessEnable *bool `json:"diskless_enable,omitempty"`

	// This configuration controls the maximum bytes tiered storage will retain segment files locally before it will discard old log segments to free up space. If set to -2, the limit is equal to overall retention time. If set to -1, no limit is applied but it's possible only if overall retention is also -1.
	LocalRetentionBytes *int `json:"local_retention_bytes,omitempty"`

	// This configuration controls the maximum time tiered storage will retain segment files locally before it will discard old log segments to free up space. If set to -2, the time limit is equal to overall retention time. If set to -1, no time limit is applied but it's possible only if overall retention is also -1.
	LocalRetentionMs *int `json:"local_retention_ms,omitempty"`

	// The maximum time a message will remain ineligible for compaction in the log. Only applicable for logs that are being compacted.
	MaxCompactionLagMs *int `json:"max_compaction_lag_ms,omitempty"`

	// The largest record batch size allowed by Kafka (after compression if compression is enabled). If this is increased and there are consumers older than 0.10.2, the consumers' fetch size must also be increased so that the they can fetch record batches this large. In the latest message format version, records are always grouped into batches for efficiency. In previous message format versions, uncompressed records are not grouped into batches and this limit only applies to a single record in that case.
	MaxMessageBytes *int `json:"max_message_bytes,omitempty"`

	// This configuration controls whether down-conversion of message formats is enabled to satisfy consume requests. When set to false, broker will not perform down-conversion for consumers expecting an older message format. The broker responds with UNSUPPORTED_VERSION error for consume requests from such older clients. This configuration does not apply to any message format conversion that might be required for replication to followers.
	MessageDownconversionEnable *bool `json:"message_downconversion_enable,omitempty"`

	// Specify the message format version the broker will use to append messages to the logs. The value should be a valid ApiVersion. Some examples are: 0.8.2, 0.9.0.0, 0.10.0, check ApiVersion for more details. By setting a particular message format version, the user is certifying that all the existing messages on disk are smaller or equal than the specified version. Setting this value incorrectly will cause consumers with older versions to break as they will receive messages with a format that they don't understand.
	MessageFormatVersion kafkatopic.MessageFormatVersionType `json:"message_format_version,omitempty"`

	// The maximum difference allowed between the timestamp when a broker receives a message and the timestamp specified in the message. If message.timestamp.type=CreateTime, a message will be rejected if the difference in timestamp exceeds this threshold. This configuration is ignored if message.timestamp.type=LogAppendTime.
	MessageTimestampDifferenceMaxMs *int `json:"message_timestamp_difference_max_ms,omitempty"`

	// Define whether the timestamp in the message is message create time or log append time.
	MessageTimestampType kafkatopic.MessageTimestampType `json:"message_timestamp_type,omitempty"`

	// This configuration controls how frequently the log compactor will attempt to clean the log (assuming log compaction is enabled). By default we will avoid cleaning a log where more than 50% of the log has been compacted. This ratio bounds the maximum space wasted in the log by duplicates (at 50% at most 50% of the log could be duplicates). A higher ratio will mean fewer, more efficient cleanings but will mean more wasted space in the log. If the max.compaction.lag.ms or the min.compaction.lag.ms configurations are also specified, then the log compactor considers the log to be eligible for compaction as soon as either: (i) the dirty ratio threshold has been met and the log has had dirty (uncompacted) records for at least the min.compaction.lag.ms duration, or (ii) if the log has had dirty (uncompacted) records for at most the max.compaction.lag.ms period.
	MinCleanableDirtyRatio *float64 `json:"min_cleanable_dirty_ratio,omitempty"`

	// The minimum time a message will remain uncompacted in the log. Only applicable for logs that are being compacted.
	MinCompactionLagMs *int `json:"min_compaction_lag_ms,omitempty"`

	// When a producer sets acks to 'all' (or '-1'), this configuration specifies the minimum number of replicas that must acknowledge a write for the write to be considered successful. If this minimum cannot be met, then the producer will raise an exception (either NotEnoughReplicas or NotEnoughReplicasAfterAppend). When used together, min.insync.replicas and acks allow you to enforce greater durability guarantees. A typical scenario would be to create a topic with a replication factor of 3, set min.insync.replicas to 2, and produce with acks of 'all'. This will ensure that the producer raises an exception if a majority of replicas do not receive a write.
	MinInsyncReplicas *int `json:"min_insync_replicas,omitempty"`

	// True if we should preallocate the file on disk when creating a new log segment.
	Preallocate *bool `json:"preallocate,omitempty"`

	// Indicates whether tiered storage should be enabled.
	RemoteStorageEnable *bool `json:"remote_storage_enable,omitempty"`

	// This configuration controls the maximum size a partition (which consists of log segments) can grow to before we will discard old log segments to free up space if we are using the 'delete' retention policy. By default there is no size limit only a time limit. Since this limit is enforced at the partition level, multiply it by the number of partitions to compute the topic retention in bytes.
	RetentionBytes *int `json:"retention_bytes,omitempty"`

	// This configuration controls the maximum time we will retain a log before we will discard old log segments to free up space if we are using the 'delete' retention policy. This represents an SLA on how soon consumers must read their data. If set to -1, no time limit is applied.
	RetentionMs *int `json:"retention_ms,omitempty"`

	// This configuration controls the segment file size for the log. Retention and cleaning is always done a file at a time so a larger segment size means fewer files but less granular control over retention. Setting this to a very low value has consequences, and the Aiven management plane ignores values less than 10 megabytes.
	SegmentBytes *int `json:"segment_bytes,omitempty"`

	// This configuration controls the size of the index that maps offsets to file positions. We preallocate this index file and shrink it only after log rolls. You generally should not need to change this setting.
	SegmentIndexBytes *int `json:"segment_index_bytes,omitempty"`

	// The maximum random jitter subtracted from the scheduled segment roll time to avoid thundering herds of segment rolling
	SegmentJitterMs *int `json:"segment_jitter_ms,omitempty"`

	// This configuration controls the period of time after which Kafka will force the log to roll even if the segment file isn't full to ensure that retention can delete or compact old data. Setting this to a very low value has consequences, and the Aiven management plane ignores values less than 10 seconds.
	SegmentMs *int `json:"segment_ms,omitempty"`

	// Indicates whether to enable replicas not in the ISR set to be elected as leader as a last resort, even though doing so may result in data loss.
	UncleanLeaderElectionEnable *bool `json:"unclean_leader_election_enable,omitempty"`
}

func (*KafkaTopicConfig) DeepCopy 

func (in *KafkaTopicConfig) DeepCopy() *KafkaTopicConfig

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

func (*KafkaTopicConfig) DeepCopyInto 

func (in *KafkaTopicConfig) DeepCopyInto(out *KafkaTopicConfig)

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

type KafkaTopicList 

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

KafkaTopicList contains a list of KafkaTopic

func (*KafkaTopicList) DeepCopy 

func (in *KafkaTopicList) DeepCopy() *KafkaTopicList

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

func (*KafkaTopicList) DeepCopyInto 

func (in *KafkaTopicList) DeepCopyInto(out *KafkaTopicList)

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

func (*KafkaTopicList) DeepCopyObject 

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

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

type KafkaTopicSpec 

type KafkaTopicSpec struct {
	ServiceDependant `json:",inline"`

	// +kubebuilder:validation:MinLength=1
	// +kubebuilder:validation:MaxLength=249
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	// Topic name. If provided, is used instead of metadata.name.
	// This field supports additional characters, has a longer length,
	// and will replace metadata.name in future releases
	TopicName string `json:"topicName,omitempty"`

	// +kubebuilder:validation:Minimum=1
	// +kubebuilder:validation:Maximum=1000000
	// Number of partitions to create in the topic
	Partitions int `json:"partitions"`

	// +kubebuilder:validation:Minimum=2
	// Replication factor for the topic
	Replication int `json:"replication"`

	// Kafka topic tags
	Tags []KafkaTopicTag `json:"tags,omitempty"`

	// Kafka topic configuration
	Config *KafkaTopicConfig `json:"config,omitempty"`

	// It is a Kubernetes side deletion protections, which prevents the kafka topic
	// from being deleted by Kubernetes. It is recommended to enable this for any production
	// databases containing critical data.
	TerminationProtection *bool `json:"termination_protection,omitempty"`
}

KafkaTopicSpec defines the desired state of KafkaTopic

func (*KafkaTopicSpec) DeepCopy 

func (in *KafkaTopicSpec) DeepCopy() *KafkaTopicSpec

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

func (*KafkaTopicSpec) DeepCopyInto 

func (in *KafkaTopicSpec) DeepCopyInto(out *KafkaTopicSpec)

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

type KafkaTopicStatus 

type KafkaTopicStatus struct {
	// Conditions represent the latest available observations of an KafkaTopic state
	Conditions []metav1.Condition `json:"conditions"`

	// State represents the state of the kafka topic
	State kafkatopic.TopicStateType `json:"state"`
}

KafkaTopicStatus defines the observed state of KafkaTopic

func (*KafkaTopicStatus) DeepCopy 

func (in *KafkaTopicStatus) DeepCopy() *KafkaTopicStatus

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

func (*KafkaTopicStatus) DeepCopyInto 

func (in *KafkaTopicStatus) DeepCopyInto(out *KafkaTopicStatus)

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

type KafkaTopicTag 

type KafkaTopicTag struct {
	// +kubebuilder:validation:MinLength=1
	// +kubebuilder:validation:MaxLength=64
	// +kubebuilder:validation:Pattern="^[a-zA-Z0-9_-]+$"
	Key string `json:"key"`

	// +kubebuilder:validation:MaxLength=256
	// +kubebuilder:validation:Pattern="^[a-zA-Z0-9_-]+$"
	Value string `json:"value,omitempty"`
}

func (*KafkaTopicTag) DeepCopy 

func (in *KafkaTopicTag) DeepCopy() *KafkaTopicTag

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

func (*KafkaTopicTag) DeepCopyInto 

func (in *KafkaTopicTag) DeepCopyInto(out *KafkaTopicTag)

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

type MySQL added in v0.6.0 

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

	Spec   MySQLSpec     `json:"spec,omitempty"`
	Status ServiceStatus `json:"status,omitempty"`
}

MySQL is the Schema for the mysqls API. Info "Exposes secret keys": `MYSQL_HOST`, `MYSQL_PORT`, `MYSQL_DATABASE`, `MYSQL_USER`, `MYSQL_PASSWORD`, `MYSQL_SSL_MODE`, `MYSQL_URI`, `MYSQL_REPLICA_URI`, `MYSQL_CA_CERT` +kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Region",type="string",JSONPath=".spec.cloudName" +kubebuilder:printcolumn:name="Plan",type="string",JSONPath=".spec.plan" +kubebuilder:printcolumn:name="State",type="string",JSONPath=".status.state"

func (*MySQL) AuthSecretRef added in v0.6.0 

func (in *MySQL) AuthSecretRef() *AuthSecretReference

func (*MySQL) Conditions added in v0.16.0 

func (in *MySQL) Conditions() *[]metav1.Condition

func (*MySQL) DeepCopy added in v0.6.0 

func (in *MySQL) DeepCopy() *MySQL

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

func (*MySQL) DeepCopyInto added in v0.6.0 

func (in *MySQL) DeepCopyInto(out *MySQL)

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

func (*MySQL) DeepCopyObject added in v0.6.0 

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

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

func (*MySQL) Default added in v0.6.0 

func (in *MySQL) Default()

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

func (*MySQL) GetConnInfoSecretTarget added in v0.12.0 

func (in *MySQL) GetConnInfoSecretTarget() ConnInfoSecretTarget

func (*MySQL) GetObjectMeta added in v0.31.0 

func (in *MySQL) GetObjectMeta() *metav1.ObjectMeta

func (*MySQL) GetRefs added in v0.6.0 

func (in *MySQL) GetRefs() []*ResourceReferenceObject

func (*MySQL) NoSecret added in v0.17.0 

func (in *MySQL) NoSecret() bool

func (*MySQL) SetupWebhookWithManager added in v0.6.0 

func (in *MySQL) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*MySQL) ValidateCreate added in v0.6.0 

func (in *MySQL) ValidateCreate() error

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

func (*MySQL) ValidateDelete added in v0.6.0 

func (in *MySQL) ValidateDelete() error

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

func (*MySQL) ValidateUpdate added in v0.6.0 

func (in *MySQL) ValidateUpdate(_ runtime.Object) error

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

type MySQLList added in v0.6.0 

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

MySQLList contains a list of MySQL

func (*MySQLList) DeepCopy added in v0.6.0 

func (in *MySQLList) DeepCopy() *MySQLList

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

func (*MySQLList) DeepCopyInto added in v0.6.0 

func (in *MySQLList) DeepCopyInto(out *MySQLList)

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

func (*MySQLList) DeepCopyObject added in v0.6.0 

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

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

type MySQLSpec added in v0.6.0 

type MySQLSpec struct {
	ServiceCommonSpec `json:",inline"`

	// MySQL specific user configuration options
	UserConfig *mysqluserconfig.MysqlUserConfig `json:"userConfig,omitempty"`
}

MySQLSpec defines the desired state of MySQL

func (*MySQLSpec) DeepCopy added in v0.6.0 

func (in *MySQLSpec) DeepCopy() *MySQLSpec

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

func (*MySQLSpec) DeepCopyInto added in v0.6.0 

func (in *MySQLSpec) DeepCopyInto(out *MySQLSpec)

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

type OpenSearch added in v0.3.0 

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

	Spec   OpenSearchSpec `json:"spec,omitempty"`
	Status ServiceStatus  `json:"status,omitempty"`
}

OpenSearch is the Schema for the opensearches API. Info "Exposes secret keys": `OPENSEARCH_HOST`, `OPENSEARCH_PORT`, `OPENSEARCH_USER`, `OPENSEARCH_PASSWORD`, `OPENSEARCH_URI` +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Region",type="string",JSONPath=".spec.cloudName" +kubebuilder:printcolumn:name="Plan",type="string",JSONPath=".spec.plan" +kubebuilder:printcolumn:name="State",type="string",JSONPath=".status.state"

func (*OpenSearch) AuthSecretRef added in v0.3.0 

func (in *OpenSearch) AuthSecretRef() *AuthSecretReference

func (*OpenSearch) Conditions added in v0.16.0 

func (in *OpenSearch) Conditions() *[]metav1.Condition

func (*OpenSearch) DeepCopy added in v0.3.0 

func (in *OpenSearch) DeepCopy() *OpenSearch

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

func (*OpenSearch) DeepCopyInto added in v0.3.0 

func (in *OpenSearch) DeepCopyInto(out *OpenSearch)

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

func (*OpenSearch) DeepCopyObject added in v0.3.0 

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

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

func (*OpenSearch) Default added in v0.3.0 

func (in *OpenSearch) Default()

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

func (*OpenSearch) GetConnInfoSecretTarget added in v0.12.0 

func (in *OpenSearch) GetConnInfoSecretTarget() ConnInfoSecretTarget

func (*OpenSearch) GetObjectMeta added in v0.31.0 

func (in *OpenSearch) GetObjectMeta() *metav1.ObjectMeta

func (*OpenSearch) GetRefs added in v0.5.0 

func (in *OpenSearch) GetRefs() []*ResourceReferenceObject

func (*OpenSearch) NoSecret added in v0.17.0 

func (in *OpenSearch) NoSecret() bool

func (*OpenSearch) SetupWebhookWithManager added in v0.3.0 

func (in *OpenSearch) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*OpenSearch) ValidateCreate added in v0.3.0 

func (in *OpenSearch) ValidateCreate() error

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

func (*OpenSearch) ValidateDelete added in v0.3.0 

func (in *OpenSearch) ValidateDelete() error

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

func (*OpenSearch) ValidateUpdate added in v0.3.0 

func (in *OpenSearch) ValidateUpdate(_ runtime.Object) error

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

type OpenSearchList added in v0.3.0 

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

OpenSearchList contains a list of OpenSearch

func (*OpenSearchList) DeepCopy added in v0.3.0 

func (in *OpenSearchList) DeepCopy() *OpenSearchList

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

func (*OpenSearchList) DeepCopyInto added in v0.3.0 

func (in *OpenSearchList) DeepCopyInto(out *OpenSearchList)

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

func (*OpenSearchList) DeepCopyObject added in v0.3.0 

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

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

type OpenSearchSpec added in v0.3.0 

type OpenSearchSpec struct {
	ServiceCommonSpec `json:",inline"`

	// OpenSearch specific user configuration options
	UserConfig *opensearchuserconfig.OpensearchUserConfig `json:"userConfig,omitempty"`
}

OpenSearchSpec defines the desired state of OpenSearch

func (*OpenSearchSpec) DeepCopy added in v0.3.0 

func (in *OpenSearchSpec) DeepCopy() *OpenSearchSpec

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

func (*OpenSearchSpec) DeepCopyInto added in v0.3.0 

func (in *OpenSearchSpec) DeepCopyInto(out *OpenSearchSpec)

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

type PostgreSQL 

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

	Spec   PostgreSQLSpec `json:"spec,omitempty"`
	Status ServiceStatus  `json:"status,omitempty"`
}

PostgreSQL is the Schema for the postgresql API. Info "Exposes secret keys": `POSTGRESQL_HOST`, `POSTGRESQL_PORT`, `POSTGRESQL_DATABASE`, `POSTGRESQL_USER`, `POSTGRESQL_PASSWORD`, `POSTGRESQL_SSLMODE`, `POSTGRESQL_DATABASE_URI`, `POSTGRESQL_CA_CERT` +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Region",type="string",JSONPath=".spec.cloudName" +kubebuilder:printcolumn:name="Plan",type="string",JSONPath=".spec.plan" +kubebuilder:printcolumn:name="State",type="string",JSONPath=".status.state"

func (*PostgreSQL) AuthSecretRef 

func (in *PostgreSQL) AuthSecretRef() *AuthSecretReference

func (*PostgreSQL) Conditions added in v0.16.0 

func (in *PostgreSQL) Conditions() *[]metav1.Condition

func (*PostgreSQL) DeepCopy 

func (in *PostgreSQL) DeepCopy() *PostgreSQL

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

func (*PostgreSQL) DeepCopyInto 

func (in *PostgreSQL) DeepCopyInto(out *PostgreSQL)

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

func (*PostgreSQL) DeepCopyObject 

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

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

func (*PostgreSQL) Default 

func (in *PostgreSQL) Default()

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

func (*PostgreSQL) GetConnInfoSecretTarget added in v0.12.0 

func (in *PostgreSQL) GetConnInfoSecretTarget() ConnInfoSecretTarget

func (*PostgreSQL) GetObjectMeta added in v0.31.0 

func (in *PostgreSQL) GetObjectMeta() *metav1.ObjectMeta

func (*PostgreSQL) GetRefs added in v0.5.0 

func (in *PostgreSQL) GetRefs() []*ResourceReferenceObject

func (*PostgreSQL) NoSecret added in v0.17.0 

func (in *PostgreSQL) NoSecret() bool

func (*PostgreSQL) SetupWebhookWithManager 

func (in *PostgreSQL) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*PostgreSQL) ValidateCreate 

func (in *PostgreSQL) ValidateCreate() error

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

func (*PostgreSQL) ValidateDelete 

func (in *PostgreSQL) ValidateDelete() error

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

func (*PostgreSQL) ValidateUpdate 

func (in *PostgreSQL) ValidateUpdate(_ runtime.Object) error

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

type PostgreSQLList 

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

PostgreSQLList contains a list of PostgreSQL instances

func (*PostgreSQLList) DeepCopy 

func (in *PostgreSQLList) DeepCopy() *PostgreSQLList

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

func (*PostgreSQLList) DeepCopyInto 

func (in *PostgreSQLList) DeepCopyInto(out *PostgreSQLList)

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

func (*PostgreSQLList) DeepCopyObject 

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

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

type PostgreSQLSpec 

type PostgreSQLSpec struct {
	ServiceCommonSpec `json:",inline"`

	// PostgreSQL specific user configuration options
	UserConfig *pguserconfig.PgUserConfig `json:"userConfig,omitempty"`
}

PostgreSQLSpec defines the desired state of postgres instance

func (*PostgreSQLSpec) DeepCopy 

func (in *PostgreSQLSpec) DeepCopy() *PostgreSQLSpec

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

func (*PostgreSQLSpec) DeepCopyInto 

func (in *PostgreSQLSpec) DeepCopyInto(out *PostgreSQLSpec)

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

type PrivilegeGrant added in v0.21.0 

type PrivilegeGrant struct {
	// List of grantees (users or roles) to grant the privilege to.
	// +kubebuilder:validation:MinItems=1
	Grantees []Grantee `json:"grantees"`
	// The privileges to grant, i.e. `INSERT`, `SELECT`.
	// [See](https://clickhouse.com/docs/en/sql-reference/statements/grant#assigning-role-syntax).
	Privileges []string `json:"privileges"`
	// The database that the grant refers to.
	Database string `json:"database"`
	// The tables that the grant refers to. To grant a privilege on all tables in a database, omit this field instead of writing `table: "*"`.
	Table string `json:"table,omitempty"`
	// The column that the grant refers to.
	Columns []string `json:"columns,omitempty"`
	// If true, then the grantee (user or role) get the permission to execute the `GRANT` query.
	// Users can grant privileges of the same scope they have and less.
	// [See](https://clickhouse.com/docs/en/sql-reference/statements/grant#granting-privilege-syntax)
	WithGrantOption bool `json:"withGrantOption,omitempty"`
}

PrivilegeGrant represents the privileges to be granted to users or roles. [See](https://clickhouse.com/docs/en/sql-reference/statements/grant#granting-privilege-syntax). +kubebuilder:validation:XValidation:rule="!has(self.columns) || (has(self.columns) && has(self.table))",message="`table` must be set if `columns` are set"

func (*PrivilegeGrant) ConstructParts added in v0.21.0 

func (g *PrivilegeGrant) ConstructParts(t chUtils.StatementType) (string, string, string)

func (*PrivilegeGrant) DeepCopy added in v0.21.0 

func (in *PrivilegeGrant) DeepCopy() *PrivilegeGrant

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

func (*PrivilegeGrant) DeepCopyInto added in v0.21.0 

func (in *PrivilegeGrant) DeepCopyInto(out *PrivilegeGrant)

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

type Project 

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

	Spec   ProjectSpec   `json:"spec,omitempty"`
	Status ProjectStatus `json:"status,omitempty"`
}

Project is the Schema for the projects API. Info "Exposes secret keys": `PROJECT_CA_CERT` +kubebuilder:subresource:status

func (*Project) AuthSecretRef 

func (in *Project) AuthSecretRef() *AuthSecretReference

func (*Project) Conditions added in v0.16.0 

func (in *Project) Conditions() *[]metav1.Condition

func (*Project) DeepCopy 

func (in *Project) DeepCopy() *Project

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

func (*Project) DeepCopyInto 

func (in *Project) DeepCopyInto(out *Project)

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

func (*Project) DeepCopyObject 

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

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

func (*Project) Default 

func (in *Project) Default()

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

func (*Project) GetConnInfoSecretTarget added in v0.12.0 

func (in *Project) GetConnInfoSecretTarget() ConnInfoSecretTarget

func (*Project) GetObjectMeta added in v0.31.0 

func (in *Project) GetObjectMeta() *metav1.ObjectMeta

func (*Project) NoSecret added in v0.17.0 

func (in *Project) NoSecret() bool

func (*Project) SetupWebhookWithManager 

func (in *Project) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Project) ValidateCreate 

func (in *Project) ValidateCreate() error

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

func (*Project) ValidateDelete 

func (in *Project) ValidateDelete() error

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

func (*Project) ValidateUpdate 

func (in *Project) ValidateUpdate(_ runtime.Object) error

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

type ProjectDependant added in v0.20.0 

type ProjectDependant struct {
	ProjectField       `json:",inline"`
	AuthSecretRefField `json:",inline"`
}

func (*ProjectDependant) DeepCopy added in v0.20.0 

func (in *ProjectDependant) DeepCopy() *ProjectDependant

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

func (*ProjectDependant) DeepCopyInto added in v0.20.0 

func (in *ProjectDependant) DeepCopyInto(out *ProjectDependant)

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

type ProjectField added in v0.19.0 

type ProjectField struct {
	// +kubebuilder:validation:MaxLength=63
	// +kubebuilder:validation:Pattern="^[a-zA-Z0-9_-]+$"
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	// Identifies the project this resource belongs to
	Project string `json:"project"`
}

func (*ProjectField) DeepCopy added in v0.19.0 

func (in *ProjectField) DeepCopy() *ProjectField

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

func (*ProjectField) DeepCopyInto added in v0.19.0 

func (in *ProjectField) DeepCopyInto(out *ProjectField)

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

type ProjectList 

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

ProjectList contains a list of Project

func (*ProjectList) DeepCopy 

func (in *ProjectList) DeepCopy() *ProjectList

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

func (*ProjectList) DeepCopyInto 

func (in *ProjectList) DeepCopyInto(out *ProjectList)

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

func (*ProjectList) DeepCopyObject 

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

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

type ProjectSpec 

type ProjectSpec struct {
	AuthSecretRefField `json:",inline"`
	SecretFields       `json:",inline"`

	// +kubebuilder:validation:MaxLength=64
	// Credit card ID; The ID may be either last 4 digits of the card or the actual ID
	CardID string `json:"cardId,omitempty"`

	// +kubebuilder:validation:MaxLength=32
	// Account ID
	AccountID string `json:"accountId,omitempty"`

	// +kubebuilder:validation:MaxLength=1000
	// Billing name and address of the project
	BillingAddress string `json:"billingAddress,omitempty"`

	// +kubebuilder:validation:MaxItems=10
	// Billing contact emails of the project
	BillingEmails []string `json:"billingEmails,omitempty"`

	// +kubebuilder:validation:Enum=AUD;CAD;CHF;DKK;EUR;GBP;NOK;SEK;USD
	// Billing currency
	BillingCurrency project.BillingCurrencyType `json:"billingCurrency,omitempty"`

	// +kubebuilder:validation:MaxLength=1000
	// Extra text to be included in all project invoices, e.g. purchase order or cost center number
	BillingExtraText string `json:"billingExtraText,omitempty"`

	// +kubebuilder:validation:MaxLength=36
	// +kubebuilder:validation:MinLength=36
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	// BillingGroup ID
	BillingGroupID string `json:"billingGroupId,omitempty"`

	// +kubebuilder:validation:MinLength=2
	// +kubebuilder:validation:MaxLength=2
	// Billing country code of the project
	CountryCode string `json:"countryCode,omitempty"`

	// +kubebuilder:validation:MaxLength=256
	// Target cloud, example: aws-eu-central-1
	Cloud string `json:"cloud,omitempty"`

	// +kubebuilder:validation:MaxLength=63
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	// Project name from which to copy settings to the new project
	CopyFromProject string `json:"copyFromProject,omitempty"`

	// +kubebuilder:validation:MaxItems=10
	// Technical contact emails of the project
	TechnicalEmails []string `json:"technicalEmails,omitempty"`

	// Tags are key-value pairs that allow you to categorize projects
	Tags map[string]string `json:"tags,omitempty"`
}

ProjectSpec defines the desired state of Project

func (*ProjectSpec) DeepCopy 

func (in *ProjectSpec) DeepCopy() *ProjectSpec

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

func (*ProjectSpec) DeepCopyInto 

func (in *ProjectSpec) DeepCopyInto(out *ProjectSpec)

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

type ProjectStatus 

type ProjectStatus struct {
	// Conditions represent the latest available observations of an Project state
	Conditions []metav1.Condition `json:"conditions"`

	// +kubebuilder:validation:MaxLength=64
	// EU VAT Identification Number
	VatID string `json:"vatId,omitempty"`

	// Available credirs
	AvailableCredits string `json:"availableCredits,omitempty"`

	// Country name
	Country string `json:"country,omitempty"`

	// Estimated balance
	EstimatedBalance string `json:"estimatedBalance,omitempty"`

	// Payment method name
	PaymentMethod string `json:"paymentMethod,omitempty"`
}

ProjectStatus defines the observed state of Project

func (*ProjectStatus) DeepCopy 

func (in *ProjectStatus) DeepCopy() *ProjectStatus

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

func (*ProjectStatus) DeepCopyInto 

func (in *ProjectStatus) DeepCopyInto(out *ProjectStatus)

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

type ProjectVPC 

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

	Spec   ProjectVPCSpec   `json:"spec,omitempty"`
	Status ProjectVPCStatus `json:"status,omitempty"`
}

ProjectVPC is the Schema for the projectvpcs API +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Cloud",type="string",JSONPath=".spec.cloudName" +kubebuilder:printcolumn:name="Network CIDR",type="string",JSONPath=".spec.networkCidr" +kubebuilder:printcolumn:name="State",type="string",JSONPath=".status.state"

func FindProjectVPC added in v0.5.0 

func FindProjectVPC(refs []client.Object) *ProjectVPC

FindProjectVPC returns ProjectVPC from reference list

func (*ProjectVPC) AuthSecretRef 

func (in *ProjectVPC) AuthSecretRef() *AuthSecretReference

func (*ProjectVPC) Conditions added in v0.16.0 

func (in *ProjectVPC) Conditions() *[]metav1.Condition

func (*ProjectVPC) DeepCopy 

func (in *ProjectVPC) DeepCopy() *ProjectVPC

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

func (*ProjectVPC) DeepCopyInto 

func (in *ProjectVPC) DeepCopyInto(out *ProjectVPC)

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

func (*ProjectVPC) DeepCopyObject 

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

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

func (*ProjectVPC) GetObjectMeta added in v0.31.0 

func (in *ProjectVPC) GetObjectMeta() *metav1.ObjectMeta

func (*ProjectVPC) NoSecret added in v0.17.0 

func (*ProjectVPC) NoSecret() bool

type ProjectVPCList 

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

ProjectVPCList contains a list of ProjectVPC

func (*ProjectVPCList) DeepCopy 

func (in *ProjectVPCList) DeepCopy() *ProjectVPCList

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

func (*ProjectVPCList) DeepCopyInto 

func (in *ProjectVPCList) DeepCopyInto(out *ProjectVPCList)

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

func (*ProjectVPCList) DeepCopyObject 

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

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

type ProjectVPCSpec 

type ProjectVPCSpec struct {
	ProjectDependant `json:",inline"`

	// +kubebuilder:validation:MaxLength=256
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	// Cloud the VPC is in
	CloudName string `json:"cloudName"`

	// +kubebuilder:validation:MaxLength=36
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	// Network address range used by the VPC like 192.168.0.0/24
	NetworkCidr string `json:"networkCidr"`
}

ProjectVPCSpec defines the desired state of ProjectVPC

func (*ProjectVPCSpec) DeepCopy 

func (in *ProjectVPCSpec) DeepCopy() *ProjectVPCSpec

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

func (*ProjectVPCSpec) DeepCopyInto 

func (in *ProjectVPCSpec) DeepCopyInto(out *ProjectVPCSpec)

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

type ProjectVPCStatus 

type ProjectVPCStatus struct {
	// Conditions represent the latest available observations of an ProjectVPC state
	Conditions []metav1.Condition `json:"conditions"`

	// State of VPC
	State vpc.VpcStateType `json:"state"`

	// Project VPC id
	ID string `json:"id"`
}

ProjectVPCStatus defines the observed state of ProjectVPC

func (*ProjectVPCStatus) DeepCopy 

func (in *ProjectVPCStatus) DeepCopy() *ProjectVPCStatus

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

func (*ProjectVPCStatus) DeepCopyInto 

func (in *ProjectVPCStatus) DeepCopyInto(out *ProjectVPCStatus)

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

type Redis added in v0.2.0 

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

	Spec   RedisSpec     `json:"spec,omitempty"`
	Status ServiceStatus `json:"status,omitempty"`
}

Redis is the Schema for the redis API. Info "Exposes secret keys": `REDIS_HOST`, `REDIS_PORT`, `REDIS_USER`, `REDIS_PASSWORD`, `REDIS_SSL` +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Region",type="string",JSONPath=".spec.cloudName" +kubebuilder:printcolumn:name="Plan",type="string",JSONPath=".spec.plan" +kubebuilder:printcolumn:name="State",type="string",JSONPath=".status.state"

func (*Redis) AuthSecretRef added in v0.2.0 

func (in *Redis) AuthSecretRef() *AuthSecretReference

func (*Redis) Conditions added in v0.16.0 

func (in *Redis) Conditions() *[]metav1.Condition

func (*Redis) DeepCopy added in v0.2.0 

func (in *Redis) DeepCopy() *Redis

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

func (*Redis) DeepCopyInto added in v0.2.0 

func (in *Redis) DeepCopyInto(out *Redis)

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

func (*Redis) DeepCopyObject added in v0.2.0 

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

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

func (*Redis) Default added in v0.2.0 

func (in *Redis) Default()

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

func (*Redis) GetConnInfoSecretTarget added in v0.12.0 

func (in *Redis) GetConnInfoSecretTarget() ConnInfoSecretTarget

func (*Redis) GetObjectMeta added in v0.31.0 

func (in *Redis) GetObjectMeta() *metav1.ObjectMeta

func (*Redis) GetRefs added in v0.5.0 

func (in *Redis) GetRefs() []*ResourceReferenceObject

func (*Redis) NoSecret added in v0.17.0 

func (in *Redis) NoSecret() bool

func (*Redis) SetupWebhookWithManager added in v0.2.0 

func (in *Redis) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Redis) ValidateCreate added in v0.2.0 

func (in *Redis) ValidateCreate() error

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

func (*Redis) ValidateDelete added in v0.2.0 

func (in *Redis) ValidateDelete() error

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

func (*Redis) ValidateUpdate added in v0.2.0 

func (in *Redis) ValidateUpdate(_ runtime.Object) error

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

type RedisList added in v0.2.0 

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

RedisList contains a list of Redis

func (*RedisList) DeepCopy added in v0.2.0 

func (in *RedisList) DeepCopy() *RedisList

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

func (*RedisList) DeepCopyInto added in v0.2.0 

func (in *RedisList) DeepCopyInto(out *RedisList)

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

func (*RedisList) DeepCopyObject added in v0.2.0 

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

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

type RedisSpec added in v0.2.0 

type RedisSpec struct {
	ServiceCommonSpec `json:",inline"`

	// Redis specific user configuration options
	UserConfig *redisuserconfig.RedisUserConfig `json:"userConfig,omitempty"`
}

RedisSpec defines the desired state of Redis

func (*RedisSpec) DeepCopy added in v0.2.0 

func (in *RedisSpec) DeepCopy() *RedisSpec

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

func (*RedisSpec) DeepCopyInto added in v0.2.0 

func (in *RedisSpec) DeepCopyInto(out *RedisSpec)

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

type ResourceReference added in v0.5.0 

type ResourceReference struct {
	// +kubebuilder:validation:MinLength=1
	Name string `json:"name"`
	// +kubebuilder:validation:MinLength=1
	Namespace string `json:"namespace,omitempty"`
}

ResourceReference is a generic reference to another resource. Resource referring to another (dependency) won't start reconciliation until dependency is not ready

func (*ResourceReference) DeepCopy added in v0.5.0 

func (in *ResourceReference) DeepCopy() *ResourceReference

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

func (*ResourceReference) DeepCopyInto added in v0.5.0 

func (in *ResourceReference) DeepCopyInto(out *ResourceReference)

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

func (*ResourceReference) ProjectVPC added in v0.5.0 

func (in *ResourceReference) ProjectVPC(objNamespace string) *ResourceReferenceObject

ProjectVPC returns reference ProjectVPC kind

type ResourceReferenceObject added in v0.5.0 

type ResourceReferenceObject struct {
	GroupVersionKind schema.GroupVersionKind
	NamespacedName   types.NamespacedName
}

ResourceReferenceObject is a composite "key" to resource GroupVersionKind is for resource "type": GroupVersionKind{Group: "aiven.io", Version: "v1alpha1", Kind: "Kafka"} NamespacedName is for specific instance: NamespacedName{Name: "my-kafka", Namespace: "default"}

func (*ResourceReferenceObject) DeepCopy added in v0.5.0 

func (in *ResourceReferenceObject) DeepCopy() *ResourceReferenceObject

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

func (*ResourceReferenceObject) DeepCopyInto added in v0.5.0 

func (in *ResourceReferenceObject) DeepCopyInto(out *ResourceReferenceObject)

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

type RoleGrant added in v0.21.0 

type RoleGrant struct {
	// List of grantees (users or roles) to grant the privilege to.
	// +kubebuilder:validation:MinItems=1
	Grantees []Grantee `json:"grantees"`
	// List of roles to grant to the grantees.
	// +kubebuilder:validation:MinItems=1
	Roles []string `json:"roles"`
	// If true, the grant is executed with `ADMIN OPTION` privilege.
	// [See](https://clickhouse.com/docs/en/sql-reference/statements/grant#admin-option)
	WithAdminOption bool `json:"withAdminOption,omitempty"`
}

RoleGrant represents the roles to be assigned to users or roles. [See](https://clickhouse.com/docs/en/sql-reference/statements/grant#assigning-role-syntax)

func (*RoleGrant) ConstructParts added in v0.21.0 

func (g *RoleGrant) ConstructParts(t chUtils.StatementType) (string, string, string)

func (*RoleGrant) DeepCopy added in v0.21.0 

func (in *RoleGrant) DeepCopy() *RoleGrant

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

func (*RoleGrant) DeepCopyInto added in v0.21.0 

func (in *RoleGrant) DeepCopyInto(out *RoleGrant)

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

type SecretFields added in v0.20.0 

type SecretFields struct {
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="connInfoSecretTargetDisabled is immutable."
	// When true, the secret containing connection information will not be created, defaults to false. This field cannot be changed after resource creation.
	ConnInfoSecretTargetDisabled *bool `json:"connInfoSecretTargetDisabled,omitempty"`

	// Secret configuration.
	ConnInfoSecretTarget ConnInfoSecretTarget `json:"connInfoSecretTarget,omitempty"`
}

+kubebuilder:validation:XValidation:rule="has(oldSelf.connInfoSecretTargetDisabled) == has(self.connInfoSecretTargetDisabled)",message="connInfoSecretTargetDisabled can only be set during resource creation."

func (*SecretFields) DeepCopy added in v0.20.0 

func (in *SecretFields) DeepCopy() *SecretFields

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

func (*SecretFields) DeepCopyInto added in v0.20.0 

func (in *SecretFields) DeepCopyInto(out *SecretFields)

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

type ServiceCommonSpec 

type ServiceCommonSpec struct {
	BaseServiceFields `json:",inline"`
	SecretFields      `json:",inline"`

	// +kubebuilder:validation:Pattern="(?i)^[1-9][0-9]*(GiB|G)?$"
	// The disk space of the service, possible values depend on the service type, the cloud provider and the project.
	// Reducing will result in the service re-balancing.
	// The removal of this field does not change the value.
	DiskSpace string `json:"disk_space,omitempty"`
}

func (*ServiceCommonSpec) DeepCopy 

func (in *ServiceCommonSpec) DeepCopy() *ServiceCommonSpec

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

func (*ServiceCommonSpec) DeepCopyInto 

func (in *ServiceCommonSpec) DeepCopyInto(out *ServiceCommonSpec)

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

type ServiceDependant added in v0.20.0 

type ServiceDependant struct {
	ProjectDependant `json:",inline"`
	ServiceField     `json:",inline"`
}

func (*ServiceDependant) DeepCopy added in v0.20.0 

func (in *ServiceDependant) DeepCopy() *ServiceDependant

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

func (*ServiceDependant) DeepCopyInto added in v0.20.0 

func (in *ServiceDependant) DeepCopyInto(out *ServiceDependant)

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

type ServiceField added in v0.19.0 

type ServiceField struct {
	// +kubebuilder:validation:MaxLength=63
	// +kubebuilder:validation:Pattern="^[a-z][-a-z0-9]+$"
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	// Specifies the name of the service that this resource belongs to
	ServiceName string `json:"serviceName"`
}

func (*ServiceField) DeepCopy added in v0.19.0 

func (in *ServiceField) DeepCopy() *ServiceField

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

func (*ServiceField) DeepCopyInto added in v0.19.0 

func (in *ServiceField) DeepCopyInto(out *ServiceField)

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

type ServiceIntegration 

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

	Spec   ServiceIntegrationSpec   `json:"spec,omitempty"`
	Status ServiceIntegrationStatus `json:"status,omitempty"`
}

ServiceIntegration is the Schema for the serviceintegrations API.

info "Adoption of existing integrations": If a ServiceIntegration resource is created with configuration matching an existing Aiven integration (created outside the operator), the operator will adopt the existing integration. +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Type",type="string",JSONPath=".spec.integrationType" +kubebuilder:printcolumn:name="Source Service Name",type="string",JSONPath=".spec.sourceServiceName" +kubebuilder:printcolumn:name="Destination Service Name",type="string",JSONPath=".spec.destinationServiceName" +kubebuilder:printcolumn:name="Source Endpoint ID",type="string",JSONPath=".spec.sourceEndpointId" +kubebuilder:printcolumn:name="Destination Endpoint ID",type="string",JSONPath=".spec.destinationEndpointId"

func (*ServiceIntegration) AuthSecretRef 

func (in *ServiceIntegration) AuthSecretRef() *AuthSecretReference

func (*ServiceIntegration) Conditions added in v0.16.0 

func (in *ServiceIntegration) Conditions() *[]metav1.Condition

func (*ServiceIntegration) DeepCopy 

func (in *ServiceIntegration) DeepCopy() *ServiceIntegration

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

func (*ServiceIntegration) DeepCopyInto 

func (in *ServiceIntegration) DeepCopyInto(out *ServiceIntegration)

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

func (*ServiceIntegration) DeepCopyObject 

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

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

func (*ServiceIntegration) Default 

func (in *ServiceIntegration) Default()

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

func (*ServiceIntegration) GetObjectMeta added in v0.31.0 

func (in *ServiceIntegration) GetObjectMeta() *metav1.ObjectMeta

func (*ServiceIntegration) GetUserConfig added in v0.11.0 

func (in *ServiceIntegration) GetUserConfig() (any, error)

func (*ServiceIntegration) HasUserConfig added in v0.20.0 

func (in *ServiceIntegration) HasUserConfig() bool

func (*ServiceIntegration) NoSecret added in v0.17.0 

func (*ServiceIntegration) NoSecret() bool

func (*ServiceIntegration) SetupWebhookWithManager 

func (in *ServiceIntegration) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*ServiceIntegration) ValidateCreate 

func (in *ServiceIntegration) ValidateCreate() error

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

func (*ServiceIntegration) ValidateDelete 

func (in *ServiceIntegration) ValidateDelete() error

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

func (*ServiceIntegration) ValidateUpdate 

func (in *ServiceIntegration) ValidateUpdate(_ runtime.Object) error

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

type ServiceIntegrationEndpoint added in v0.20.0 

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

	Spec   ServiceIntegrationEndpointSpec   `json:"spec,omitempty"`
	Status ServiceIntegrationEndpointStatus `json:"status,omitempty"`
}

ServiceIntegrationEndpoint is the Schema for the serviceintegrationendpoints API +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Endpoint Name",type="string",JSONPath=".spec.endpointName" +kubebuilder:printcolumn:name="Endpoint Type",type="string",JSONPath=".spec.endpointType" +kubebuilder:printcolumn:name="ID",type="string",JSONPath=".status.id"

func (*ServiceIntegrationEndpoint) AuthSecretRef added in v0.20.0 

func (in *ServiceIntegrationEndpoint) AuthSecretRef() *AuthSecretReference

func (*ServiceIntegrationEndpoint) Conditions added in v0.20.0 

func (in *ServiceIntegrationEndpoint) Conditions() *[]metav1.Condition

func (*ServiceIntegrationEndpoint) DeepCopy added in v0.20.0 

func (in *ServiceIntegrationEndpoint) DeepCopy() *ServiceIntegrationEndpoint

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

func (*ServiceIntegrationEndpoint) DeepCopyInto added in v0.20.0 

func (in *ServiceIntegrationEndpoint) DeepCopyInto(out *ServiceIntegrationEndpoint)

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

func (*ServiceIntegrationEndpoint) DeepCopyObject added in v0.20.0 

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

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

func (*ServiceIntegrationEndpoint) Default added in v0.20.0 

func (in *ServiceIntegrationEndpoint) Default()

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

func (*ServiceIntegrationEndpoint) GetObjectMeta added in v0.31.0 

func (in *ServiceIntegrationEndpoint) GetObjectMeta() *metav1.ObjectMeta

func (*ServiceIntegrationEndpoint) GetUserConfig added in v0.20.0 

func (in *ServiceIntegrationEndpoint) GetUserConfig() (any, error)

func (*ServiceIntegrationEndpoint) HasUserConfig added in v0.20.0 

func (in *ServiceIntegrationEndpoint) HasUserConfig() bool

func (*ServiceIntegrationEndpoint) NoSecret added in v0.20.0 

func (*ServiceIntegrationEndpoint) NoSecret() bool

func (*ServiceIntegrationEndpoint) SetupWebhookWithManager added in v0.20.0 

func (in *ServiceIntegrationEndpoint) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*ServiceIntegrationEndpoint) ValidateCreate added in v0.20.0 

func (in *ServiceIntegrationEndpoint) ValidateCreate() error

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

func (*ServiceIntegrationEndpoint) ValidateDelete added in v0.20.0 

func (in *ServiceIntegrationEndpoint) ValidateDelete() error

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

func (*ServiceIntegrationEndpoint) ValidateUpdate added in v0.20.0 

func (in *ServiceIntegrationEndpoint) ValidateUpdate(_ runtime.Object) error

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

type ServiceIntegrationEndpointList added in v0.20.0 

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

ServiceIntegrationEndpointList contains a list of ServiceIntegrationEndpoint

func (*ServiceIntegrationEndpointList) DeepCopy added in v0.20.0 

func (in *ServiceIntegrationEndpointList) DeepCopy() *ServiceIntegrationEndpointList

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

func (*ServiceIntegrationEndpointList) DeepCopyInto added in v0.20.0 

func (in *ServiceIntegrationEndpointList) DeepCopyInto(out *ServiceIntegrationEndpointList)

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

func (*ServiceIntegrationEndpointList) DeepCopyObject added in v0.20.0 

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

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

type ServiceIntegrationEndpointSpec added in v0.20.0 

type ServiceIntegrationEndpointSpec struct {
	ProjectDependant `json:",inline"`

	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	// +kubebuilder:validation:Enum=autoscaler;datadog;external_aws_cloudwatch_logs;external_aws_cloudwatch_metrics;external_aws_s3;external_clickhouse;external_elasticsearch_logs;external_google_cloud_bigquery;external_google_cloud_logging;external_kafka;external_mysql;external_opensearch_logs;external_postgresql;external_redis;external_schema_registry;external_sumologic_logs;jolokia;prometheus;rsyslog
	// Type of the service integration endpoint
	EndpointType string `json:"endpointType"`

	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	// +kubebuilder:validation:MaxLength=36
	// Source endpoint for the integration (if any)
	EndpointName string `json:"endpointName,omitempty"`

	// Autoscaler configuration values
	Autoscaler *autoscaleruserconfig.AutoscalerUserConfig `json:"autoscaler,omitempty"`

	// Datadog configuration values
	Datadog *datadoguserconfig.DatadogUserConfig `json:"datadog,omitempty"`

	// ExternalAwsCloudwatchLogs configuration values
	ExternalAwsCloudwatchLogs *externalawscloudwatchlogsuserconfig.ExternalAwsCloudwatchLogsUserConfig `json:"externalAWSCloudwatchLogs,omitempty"`

	// ExternalAwsCloudwatchMetrics configuration values
	ExternalAwsCloudwatchMetrics *externalawscloudwatchmetricsuserconfig.ExternalAwsCloudwatchMetricsUserConfig `json:"externalAWSCloudwatchMetrics,omitempty"`

	// ExternalElasticsearchLogs configuration values
	ExternalElasticsearchLogs *externalelasticsearchlogsuserconfig.ExternalElasticsearchLogsUserConfig `json:"externalElasticsearchLogs,omitempty"`

	// ExternalGoogleCloudBigquery configuration values
	ExternalGoogleCloudBigquery *externalgooglecloudbigqueryuserconfig.ExternalGoogleCloudBigqueryUserConfig `json:"externalGoogleCloudBigquery,omitempty"`

	// ExternalGoogleCloudLogging configuration values
	ExternalGoogleCloudLogging *externalgooglecloudlogginguserconfig.ExternalGoogleCloudLoggingUserConfig `json:"externalGoogleCloudLogging,omitempty"`

	// ExternalKafka configuration values
	ExternalKafka *externalkafkauserconfig.ExternalKafkaUserConfig `json:"externalKafka,omitempty"`

	// ExternalOpensearchLogs configuration values
	ExternalOpensearchLogs *externalopensearchlogsuserconfig.ExternalOpensearchLogsUserConfig `json:"externalOpensearchLogs,omitempty"`

	// ExternalPostgresql configuration values
	ExternalPostgresql *externalpostgresqluserconfig.ExternalPostgresqlUserConfig `json:"externalPostgresql,omitempty"`

	// ExternalSchemaRegistry configuration values
	ExternalSchemaRegistry *externalschemaregistryuserconfig.ExternalSchemaRegistryUserConfig `json:"externalSchemaRegistry,omitempty"`

	// Jolokia configuration values
	Jolokia *jolokiauserconfig.JolokiaUserConfig `json:"jolokia,omitempty"`

	// Prometheus configuration values
	Prometheus *prometheususerconfig.PrometheusUserConfig `json:"prometheus,omitempty"`

	// Rsyslog configuration values
	Rsyslog *rsysloguserconfig.RsyslogUserConfig `json:"rsyslog,omitempty"`
}

ServiceIntegrationEndpointSpec defines the desired state of ServiceIntegrationEndpoint

func (*ServiceIntegrationEndpointSpec) DeepCopy added in v0.20.0 

func (in *ServiceIntegrationEndpointSpec) DeepCopy() *ServiceIntegrationEndpointSpec

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

func (*ServiceIntegrationEndpointSpec) DeepCopyInto added in v0.20.0 

func (in *ServiceIntegrationEndpointSpec) DeepCopyInto(out *ServiceIntegrationEndpointSpec)

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

type ServiceIntegrationEndpointStatus added in v0.20.0 

type ServiceIntegrationEndpointStatus struct {
	// Conditions represent the latest available observations of an ServiceIntegrationEndpoint state
	Conditions []metav1.Condition `json:"conditions"`

	// Service integration ID
	ID string `json:"id"`
}

ServiceIntegrationEndpointStatus defines the observed state of ServiceIntegrationEndpoint

func (*ServiceIntegrationEndpointStatus) DeepCopy added in v0.20.0 

func (in *ServiceIntegrationEndpointStatus) DeepCopy() *ServiceIntegrationEndpointStatus

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

func (*ServiceIntegrationEndpointStatus) DeepCopyInto added in v0.20.0 

func (in *ServiceIntegrationEndpointStatus) DeepCopyInto(out *ServiceIntegrationEndpointStatus)

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

type ServiceIntegrationItem added in v0.8.0 

type ServiceIntegrationItem struct {
	// +kubebuilder:validation:Enum=read_replica
	IntegrationType service.IntegrationType `json:"integrationType"`
	// +kubebuilder:validation:MinLength=1
	// +kubebuilder:validation:MaxLength=64
	SourceServiceName string `json:"sourceServiceName"`
}

Service integrations to specify when creating a service. Not applied after initial service creation

func (*ServiceIntegrationItem) DeepCopy added in v0.8.0 

func (in *ServiceIntegrationItem) DeepCopy() *ServiceIntegrationItem

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

func (*ServiceIntegrationItem) DeepCopyInto added in v0.8.0 

func (in *ServiceIntegrationItem) DeepCopyInto(out *ServiceIntegrationItem)

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

type ServiceIntegrationList 

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

ServiceIntegrationList contains a list of ServiceIntegration

func (*ServiceIntegrationList) DeepCopy 

func (in *ServiceIntegrationList) DeepCopy() *ServiceIntegrationList

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

func (*ServiceIntegrationList) DeepCopyInto 

func (in *ServiceIntegrationList) DeepCopyInto(out *ServiceIntegrationList)

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

func (*ServiceIntegrationList) DeepCopyObject 

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

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

type ServiceIntegrationSpec 

type ServiceIntegrationSpec struct {
	ProjectDependant `json:",inline"`

	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	// +kubebuilder:validation:Enum=alertmanager;autoscaler;caching;cassandra_cross_service_cluster;clickhouse_kafka;clickhouse_postgresql;dashboard;datadog;datasource;external_aws_cloudwatch_logs;external_aws_cloudwatch_metrics;external_elasticsearch_logs;external_google_cloud_logging;external_opensearch_logs;flink;flink_external_kafka;flink_external_postgresql;internal_connectivity;jolokia;kafka_connect;kafka_logs;kafka_mirrormaker;logs;m3aggregator;m3coordinator;metrics;opensearch_cross_cluster_replication;opensearch_cross_cluster_search;prometheus;read_replica;rsyslog;schema_registry_proxy;stresstester;thanosquery;thanosstore;vmalert
	// Type of the service integration accepted by Aiven API. Some values may not be supported by the operator
	IntegrationType service.IntegrationType `json:"integrationType"`

	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	// +kubebuilder:validation:MaxLength=36
	// Source endpoint for the integration (if any)
	SourceEndpointID string `json:"sourceEndpointID,omitempty"`

	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	// +kubebuilder:validation:MaxLength=64
	// Source service for the integration (if any)
	SourceServiceName string `json:"sourceServiceName,omitempty"`

	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	// +kubebuilder:validation:MaxLength=63
	// Source project for the integration (if any)
	SourceProjectName string `json:"sourceProjectName,omitempty"`

	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	// +kubebuilder:validation:MaxLength=36
	// Destination endpoint for the integration (if any)
	DestinationEndpointID string `json:"destinationEndpointId,omitempty"`

	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	// +kubebuilder:validation:MaxLength=64
	// Destination service for the integration (if any)
	DestinationServiceName string `json:"destinationServiceName,omitempty"`

	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
	// +kubebuilder:validation:MaxLength=63
	// Destination project for the integration (if any)
	DestinationProjectName string `json:"destinationProjectName,omitempty"`

	// Autoscaler specific user configuration options
	AutoscalerUserConfig *autoscalerintegration.AutoscalerUserConfig `json:"autoscaler,omitempty"`

	// Datadog specific user configuration options
	DatadogUserConfig *datadogintegration.DatadogUserConfig `json:"datadog,omitempty"`

	// Kafka Connect service configuration values
	KafkaConnectUserConfig *kafkaconnectintegration.KafkaConnectUserConfig `json:"kafkaConnect,omitempty"`

	// Kafka logs configuration values
	KafkaLogsUserConfig *kafkalogsintegration.KafkaLogsUserConfig `json:"kafkaLogs,omitempty"`

	// Metrics configuration values
	MetricsUserConfig *metricsintegration.MetricsUserConfig `json:"metrics,omitempty"`

	// Clickhouse PostgreSQL configuration values
	ClickhousePostgreSQLUserConfig *clickhousepostgresqluserconfig.ClickhousePostgresqlUserConfig `json:"clickhousePostgresql,omitempty"`

	// Clickhouse Kafka configuration values
	ClickhouseKafkaUserConfig *clickhousekafkauserconfig.ClickhouseKafkaUserConfig `json:"clickhouseKafka,omitempty"`

	// Kafka MirrorMaker configuration values
	KafkaMirrormakerUserConfig *kafkamirrormakeruserconfig.KafkaMirrormakerUserConfig `json:"kafkaMirrormaker,omitempty"`

	// Logs configuration values
	LogsUserConfig *logsuserconfig.LogsUserConfig `json:"logs,omitempty"`

	// External AWS CloudWatch Metrics integration Logs configuration values
	ExternalAWSCloudwatchMetricsUserConfig *externalawscloudwatchmetricsuserconfig.ExternalAwsCloudwatchMetricsUserConfig `json:"externalAWSCloudwatchMetrics,omitempty"`
}

ServiceIntegrationSpec defines the desired state of ServiceIntegration

func (*ServiceIntegrationSpec) DeepCopy 

func (in *ServiceIntegrationSpec) DeepCopy() *ServiceIntegrationSpec

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

func (*ServiceIntegrationSpec) DeepCopyInto 

func (in *ServiceIntegrationSpec) DeepCopyInto(out *ServiceIntegrationSpec)

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

type ServiceIntegrationStatus 

type ServiceIntegrationStatus struct {
	// Conditions represent the latest available observations of an ServiceIntegration state
	Conditions []metav1.Condition `json:"conditions"`

	// Service integration ID
	ID string `json:"id"`
}

ServiceIntegrationStatus defines the observed state of ServiceIntegration

func (*ServiceIntegrationStatus) DeepCopy 

func (in *ServiceIntegrationStatus) DeepCopy() *ServiceIntegrationStatus

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

func (*ServiceIntegrationStatus) DeepCopyInto 

func (in *ServiceIntegrationStatus) DeepCopyInto(out *ServiceIntegrationStatus)

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

type ServiceStatus 

type ServiceStatus struct {
	// Conditions represent the latest available observations of a service state
	Conditions []metav1.Condition `json:"conditions,omitempty"`

	// Service state
	State service.ServiceStateType `json:"state,omitempty"`
}

ServiceStatus defines the observed state of service

func (*ServiceStatus) DeepCopy 

func (in *ServiceStatus) DeepCopy() *ServiceStatus

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

func (*ServiceStatus) DeepCopyInto 

func (in *ServiceStatus) DeepCopyInto(out *ServiceStatus)

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

type ServiceTechEmail added in v0.17.0 

type ServiceTechEmail struct {
	// +kubebuilder:validation:Pattern="^[a-zA-Z0-9._%+-]+@[a-zA-Z0-9.-]+\\.[a-zA-Z]{2,}$"
	// Email address.
	Email string `json:"email"`
}

func (*ServiceTechEmail) DeepCopy added in v0.17.0 

func (in *ServiceTechEmail) DeepCopy() *ServiceTechEmail

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

func (*ServiceTechEmail) DeepCopyInto added in v0.17.0 

func (in *ServiceTechEmail) DeepCopyInto(out *ServiceTechEmail)

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

type ServiceUser 

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

	Spec   ServiceUserSpec   `json:"spec,omitempty"`
	Status ServiceUserStatus `json:"status,omitempty"`
}

ServiceUser is the Schema for the serviceusers API. Creates a service user for accessing Aiven services. The ServiceUser resource name becomes the username in Aiven. Built-in users like 'avnadmin' cannot be deleted but their passwords can be modified using connInfoSecretSource. Info "Exposes secret keys": `SERVICEUSER_HOST`, `SERVICEUSER_PORT`, `SERVICEUSER_USERNAME`, `SERVICEUSER_PASSWORD`, `SERVICEUSER_CA_CERT`, `SERVICEUSER_ACCESS_CERT`, `SERVICEUSER_ACCESS_KEY` +kubebuilder:printcolumn:name="Service Name",type="string",JSONPath=".spec.serviceName" +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Connection Information Secret",type="string",JSONPath=".spec.connInfoSecretTarget.name"

func (*ServiceUser) AuthSecretRef 

func (in *ServiceUser) AuthSecretRef() *AuthSecretReference

func (*ServiceUser) Conditions added in v0.16.0 

func (in *ServiceUser) Conditions() *[]metav1.Condition

func (*ServiceUser) DeepCopy 

func (in *ServiceUser) DeepCopy() *ServiceUser

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

func (*ServiceUser) DeepCopyInto 

func (in *ServiceUser) DeepCopyInto(out *ServiceUser)

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

func (*ServiceUser) DeepCopyObject 

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

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

func (*ServiceUser) Default 

func (in *ServiceUser) Default()

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

func (*ServiceUser) GetConnInfoSecretSource added in v0.31.0 

func (in *ServiceUser) GetConnInfoSecretSource() *ConnInfoSecretSource

func (*ServiceUser) GetConnInfoSecretTarget added in v0.12.0 

func (in *ServiceUser) GetConnInfoSecretTarget() ConnInfoSecretTarget

func (*ServiceUser) GetObjectMeta added in v0.31.0 

func (in *ServiceUser) GetObjectMeta() *metav1.ObjectMeta

func (*ServiceUser) NoSecret added in v0.17.0 

func (in *ServiceUser) NoSecret() bool

func (*ServiceUser) SetupWebhookWithManager 

func (in *ServiceUser) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*ServiceUser) ValidateCreate 

func (in *ServiceUser) ValidateCreate() error

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

func (*ServiceUser) ValidateDelete 

func (in *ServiceUser) ValidateDelete() error

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

func (*ServiceUser) ValidateUpdate 

func (in *ServiceUser) ValidateUpdate(_ runtime.Object) error

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

type ServiceUserList 

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

ServiceUserList contains a list of ServiceUser

func (*ServiceUserList) DeepCopy 

func (in *ServiceUserList) DeepCopy() *ServiceUserList

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

func (*ServiceUserList) DeepCopyInto 

func (in *ServiceUserList) DeepCopyInto(out *ServiceUserList)

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

func (*ServiceUserList) DeepCopyObject 

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

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

type ServiceUserSpec 

type ServiceUserSpec struct {
	ServiceDependant `json:",inline"`
	SecretFields     `json:",inline"`

	// ConnInfoSecretSource allows specifying an existing secret to read credentials from.
	// The password from this secret will be used to modify the service user credentials.
	// Password must be 8-256 characters long as per Aiven API requirements.
	// This can be used to set passwords for new users or modify passwords for existing users (e.g., avnadmin).
	// The source secret is watched for changes, and reconciliation will be automatically triggered
	// when the secret data is updated.
	ConnInfoSecretSource *ConnInfoSecretSource `json:"connInfoSecretSource,omitempty"`

	// +kubebuilder:validation:Enum=caching_sha2_password;mysql_native_password
	// Authentication details
	Authentication service.AuthenticationType `json:"authentication,omitempty"`
}

ServiceUserSpec defines the desired state of ServiceUser

func (*ServiceUserSpec) DeepCopy 

func (in *ServiceUserSpec) DeepCopy() *ServiceUserSpec

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

func (*ServiceUserSpec) DeepCopyInto 

func (in *ServiceUserSpec) DeepCopyInto(out *ServiceUserSpec)

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

type ServiceUserStatus 

type ServiceUserStatus struct {
	// Conditions represent the latest available observations of an ServiceUser state
	Conditions []metav1.Condition `json:"conditions"`

	// Type of the user account
	Type string `json:"type,omitempty"`
}

ServiceUserStatus defines the observed state of ServiceUser

func (*ServiceUserStatus) DeepCopy 

func (in *ServiceUserStatus) DeepCopy() *ServiceUserStatus

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

func (*ServiceUserStatus) DeepCopyInto 

func (in *ServiceUserStatus) DeepCopyInto(out *ServiceUserStatus)

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

type Valkey added in v0.27.0 

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

	Spec   ValkeySpec    `json:"spec,omitempty"`
	Status ServiceStatus `json:"status,omitempty"`
}

Valkey is the Schema for the valkeys API Info "Exposes secret keys": `VALKEY_HOST`, `VALKEY_PORT`, `VALKEY_USER`, `VALKEY_PASSWORD`, `VALKEY_SSL` +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Region",type="string",JSONPath=".spec.cloudName" +kubebuilder:printcolumn:name="Plan",type="string",JSONPath=".spec.plan" +kubebuilder:printcolumn:name="State",type="string",JSONPath=".status.state"

func (*Valkey) AuthSecretRef added in v0.27.0 

func (in *Valkey) AuthSecretRef() *AuthSecretReference

func (*Valkey) Conditions added in v0.27.0 

func (in *Valkey) Conditions() *[]metav1.Condition

func (*Valkey) DeepCopy added in v0.27.0 

func (in *Valkey) DeepCopy() *Valkey

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

func (*Valkey) DeepCopyInto added in v0.27.0 

func (in *Valkey) DeepCopyInto(out *Valkey)

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

func (*Valkey) DeepCopyObject added in v0.27.0 

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

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

func (*Valkey) Default added in v0.27.0 

func (in *Valkey) Default()

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

func (*Valkey) GetConnInfoSecretTarget added in v0.27.0 

func (in *Valkey) GetConnInfoSecretTarget() ConnInfoSecretTarget

func (*Valkey) GetObjectMeta added in v0.31.0 

func (in *Valkey) GetObjectMeta() *metav1.ObjectMeta

func (*Valkey) GetRefs added in v0.27.0 

func (in *Valkey) GetRefs() []*ResourceReferenceObject

func (*Valkey) NoSecret added in v0.27.0 

func (in *Valkey) NoSecret() bool

func (*Valkey) SetupWebhookWithManager added in v0.27.0 

func (in *Valkey) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Valkey) ValidateCreate added in v0.27.0 

func (in *Valkey) ValidateCreate() error

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

func (*Valkey) ValidateDelete added in v0.27.0 

func (in *Valkey) ValidateDelete() error

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

func (*Valkey) ValidateUpdate added in v0.27.0 

func (in *Valkey) ValidateUpdate(_ runtime.Object) error

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

type ValkeyList added in v0.27.0 

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

ValkeyList contains a list of Valkey

func (*ValkeyList) DeepCopy added in v0.27.0 

func (in *ValkeyList) DeepCopy() *ValkeyList

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

func (*ValkeyList) DeepCopyInto added in v0.27.0 

func (in *ValkeyList) DeepCopyInto(out *ValkeyList)

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

func (*ValkeyList) DeepCopyObject added in v0.27.0 

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

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

type ValkeySpec added in v0.27.0 

type ValkeySpec struct {
	ServiceCommonSpec `json:",inline"`

	// Valkey specific user configuration options
	UserConfig *valkeyuserconfig.ValkeyUserConfig `json:"userConfig,omitempty"`
}

ValkeySpec defines the desired state of Valkey

func (*ValkeySpec) DeepCopy added in v0.27.0 

func (in *ValkeySpec) DeepCopy() *ValkeySpec

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

func (*ValkeySpec) DeepCopyInto added in v0.27.0 

func (in *ValkeySpec) DeepCopyInto(out *ValkeySpec)

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

Source Files

View all Source files

Directories

Path Synopsis
userconfig
integration/autoscaler
integration/clickhouse_kafka
integration/clickhouse_postgresql
integration/datadog
integration/external_aws_cloudwatch_metrics
integration/kafka_connect
integration/kafka_logs
integration/kafka_mirrormaker
integration/logs
integration/metrics
integrationendpoints/autoscaler
integrationendpoints/datadog
integrationendpoints/external_aws_cloudwatch_logs
integrationendpoints/external_aws_cloudwatch_metrics
integrationendpoints/external_elasticsearch_logs
integrationendpoints/external_google_cloud_bigquery
integrationendpoints/external_google_cloud_logging
integrationendpoints/external_kafka
integrationendpoints/external_opensearch_logs
integrationendpoints/external_postgresql
integrationendpoints/external_schema_registry
integrationendpoints/jolokia
integrationendpoints/prometheus
integrationendpoints/rsyslog
service/alloydbomni
service/cassandra
service/clickhouse
service/flink
service/grafana
service/kafka
service/kafka_connect
service/mysql
service/opensearch
service/pg
service/redis
service/valkey

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.