Documentation
¶
Overview ¶
+kubebuilder:object:generate=true +groupName=aiven.io +versionName=v1alpha1
Package v1alpha1 contains API Schema definitions for the k8s-operator v1alpha1 API group +kubebuilder:object:generate=true +groupName=aiven.io
Index ¶
- Variables
- func ConvertDiscSpace(v string) int
- type AuthSecretReference
- type Clickhouse
- func (o Clickhouse) AuthSecretRef() AuthSecretReference
- func (in *Clickhouse) DeepCopy() *Clickhouse
- func (in *Clickhouse) DeepCopyInto(out *Clickhouse)
- func (in *Clickhouse) DeepCopyObject() runtime.Object
- func (r *Clickhouse) Default()
- func (r *Clickhouse) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *Clickhouse) ValidateCreate() error
- func (r *Clickhouse) ValidateDelete() error
- func (r *Clickhouse) ValidateUpdate(old runtime.Object) error
- type ClickhouseList
- type ClickhouseSpec
- type ClickhouseUser
- func (u ClickhouseUser) AuthSecretRef() AuthSecretReference
- func (in *ClickhouseUser) DeepCopy() *ClickhouseUser
- func (in *ClickhouseUser) DeepCopyInto(out *ClickhouseUser)
- func (in *ClickhouseUser) DeepCopyObject() runtime.Object
- func (r *ClickhouseUser) Default()
- func (r *ClickhouseUser) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *ClickhouseUser) ValidateCreate() error
- func (r *ClickhouseUser) ValidateDelete() error
- func (r *ClickhouseUser) ValidateUpdate(old runtime.Object) error
- type ClickhouseUserConfig
- type ClickhouseUserList
- type ClickhouseUserSpec
- type ClickhouseUserStatus
- type ConnInfoSecretTarget
- type ConnectionPool
- func (cp ConnectionPool) AuthSecretRef() AuthSecretReference
- func (in *ConnectionPool) DeepCopy() *ConnectionPool
- func (in *ConnectionPool) DeepCopyInto(out *ConnectionPool)
- func (in *ConnectionPool) DeepCopyObject() runtime.Object
- func (r *ConnectionPool) Default()
- func (r *ConnectionPool) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *ConnectionPool) ValidateCreate() error
- func (r *ConnectionPool) ValidateDelete() error
- func (r *ConnectionPool) ValidateUpdate(old runtime.Object) error
- type ConnectionPoolList
- type ConnectionPoolSpec
- type ConnectionPoolStatus
- type Database
- func (db Database) AuthSecretRef() AuthSecretReference
- func (in *Database) DeepCopy() *Database
- func (in *Database) DeepCopyInto(out *Database)
- func (in *Database) DeepCopyObject() runtime.Object
- func (r *Database) Default()
- func (r *Database) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *Database) ValidateCreate() error
- func (r *Database) ValidateDelete() error
- func (r *Database) ValidateUpdate(old runtime.Object) error
- type DatabaseList
- type DatabaseSpec
- type DatabaseStatus
- type KafkServiceKafkaConnectUserConfig
- type Kafka
- func (kfk Kafka) AuthSecretRef() AuthSecretReference
- func (in *Kafka) DeepCopy() *Kafka
- func (in *Kafka) DeepCopyInto(out *Kafka)
- func (in *Kafka) DeepCopyObject() runtime.Object
- func (r *Kafka) Default()
- func (r *Kafka) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *Kafka) ValidateCreate() error
- func (r *Kafka) ValidateDelete() error
- func (r *Kafka) ValidateUpdate(old runtime.Object) error
- type KafkaACL
- func (acl KafkaACL) AuthSecretRef() AuthSecretReference
- func (in *KafkaACL) DeepCopy() *KafkaACL
- func (in *KafkaACL) DeepCopyInto(out *KafkaACL)
- func (in *KafkaACL) DeepCopyObject() runtime.Object
- func (r *KafkaACL) Default()
- func (r *KafkaACL) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *KafkaACL) ValidateCreate() error
- func (r *KafkaACL) ValidateDelete() error
- func (r *KafkaACL) ValidateUpdate(old runtime.Object) error
- type KafkaACLList
- type KafkaACLSpec
- type KafkaACLStatus
- type KafkaAuthenticationMethodsUserConfig
- type KafkaConnect
- func (kfkc KafkaConnect) AuthSecretRef() AuthSecretReference
- func (in *KafkaConnect) DeepCopy() *KafkaConnect
- func (in *KafkaConnect) DeepCopyInto(out *KafkaConnect)
- func (in *KafkaConnect) DeepCopyObject() runtime.Object
- func (r *KafkaConnect) Default()
- func (r *KafkaConnect) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *KafkaConnect) ValidateCreate() error
- func (r *KafkaConnect) ValidateDelete() error
- func (r *KafkaConnect) ValidateUpdate(old runtime.Object) error
- type KafkaConnectList
- type KafkaConnectPrivateAccessUserConfig
- type KafkaConnectPublicAccessUserConfig
- type KafkaConnectSpec
- type KafkaConnectUserConfig
- type KafkaConnector
- func (kfk KafkaConnector) AuthSecretRef() AuthSecretReference
- func (in *KafkaConnector) DeepCopy() *KafkaConnector
- func (in *KafkaConnector) DeepCopyInto(out *KafkaConnector)
- func (in *KafkaConnector) DeepCopyObject() runtime.Object
- func (r *KafkaConnector) Default()
- func (r *KafkaConnector) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *KafkaConnector) ValidateCreate() error
- func (r *KafkaConnector) ValidateDelete() error
- func (r *KafkaConnector) ValidateUpdate(old runtime.Object) error
- type KafkaConnectorList
- type KafkaConnectorPluginStatus
- type KafkaConnectorSpec
- type KafkaConnectorStatus
- type KafkaConnectorTasksStatus
- type KafkaList
- type KafkaPrivateAccessUserConfig
- type KafkaPublicAccessUserConfig
- type KafkaRestUserConfig
- type KafkaSchema
- func (kfks KafkaSchema) AuthSecretRef() AuthSecretReference
- func (in *KafkaSchema) DeepCopy() *KafkaSchema
- func (in *KafkaSchema) DeepCopyInto(out *KafkaSchema)
- func (in *KafkaSchema) DeepCopyObject() runtime.Object
- func (r *KafkaSchema) Default()
- func (r *KafkaSchema) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *KafkaSchema) ValidateCreate() error
- func (r *KafkaSchema) ValidateDelete() error
- func (r *KafkaSchema) ValidateUpdate(old runtime.Object) error
- type KafkaSchemaList
- type KafkaSchemaRegistryConfig
- type KafkaSchemaSpec
- type KafkaSchemaStatus
- type KafkaSpec
- type KafkaSubKafkaUserConfig
- type KafkaTopic
- func (kfkt KafkaTopic) AuthSecretRef() AuthSecretReference
- func (in *KafkaTopic) DeepCopy() *KafkaTopic
- func (in *KafkaTopic) DeepCopyInto(out *KafkaTopic)
- func (in *KafkaTopic) DeepCopyObject() runtime.Object
- func (r *KafkaTopic) Default()
- func (r *KafkaTopic) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *KafkaTopic) ValidateCreate() error
- func (r *KafkaTopic) ValidateDelete() error
- func (r *KafkaTopic) ValidateUpdate(old runtime.Object) error
- type KafkaTopicConfig
- type KafkaTopicList
- type KafkaTopicSpec
- type KafkaTopicStatus
- type KafkaTopicTag
- type KafkaUserConfig
- type MigrationUserConfig
- type OpenSearch
- func (o OpenSearch) AuthSecretRef() AuthSecretReference
- func (in *OpenSearch) DeepCopy() *OpenSearch
- func (in *OpenSearch) DeepCopyInto(out *OpenSearch)
- func (in *OpenSearch) DeepCopyObject() runtime.Object
- func (r *OpenSearch) Default()
- func (r *OpenSearch) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *OpenSearch) ValidateCreate() error
- func (r *OpenSearch) ValidateDelete() error
- func (r *OpenSearch) ValidateUpdate(old runtime.Object) error
- type OpenSearchIndexPatterns
- type OpenSearchIndexTemplate
- type OpenSearchList
- type OpenSearchPrivateAccess
- type OpenSearchPrivatelinkAccess
- type OpenSearchPublicAccess
- type OpenSearchSpec
- type OpenSearchUserConfig
- type OpenSearchUserConfigOpenSearch
- type OpensearchDashboards
- type PgLookoutUserConfig
- type PgbouncerUserConfig
- type PostgreSQL
- func (pg PostgreSQL) AuthSecretRef() AuthSecretReference
- func (in *PostgreSQL) DeepCopy() *PostgreSQL
- func (in *PostgreSQL) DeepCopyInto(out *PostgreSQL)
- func (in *PostgreSQL) DeepCopyObject() runtime.Object
- func (r *PostgreSQL) Default()
- func (r *PostgreSQL) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *PostgreSQL) ValidateCreate() error
- func (r *PostgreSQL) ValidateDelete() error
- func (r *PostgreSQL) ValidateUpdate(old runtime.Object) error
- type PostgreSQLList
- type PostgreSQLSpec
- type PostgreSQLSubUserConfig
- type PostgreSQLUserconfig
- type PrivateAccessUserConfig
- type Project
- func (proj Project) AuthSecretRef() AuthSecretReference
- func (in *Project) DeepCopy() *Project
- func (in *Project) DeepCopyInto(out *Project)
- func (in *Project) DeepCopyObject() runtime.Object
- func (r *Project) Default()
- func (r *Project) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *Project) ValidateCreate() error
- func (r *Project) ValidateDelete() error
- func (r *Project) ValidateUpdate(old runtime.Object) error
- type ProjectList
- type ProjectSpec
- type ProjectStatus
- type ProjectVPC
- func (pvpc ProjectVPC) AuthSecretRef() AuthSecretReference
- func (in *ProjectVPC) DeepCopy() *ProjectVPC
- func (in *ProjectVPC) DeepCopyInto(out *ProjectVPC)
- func (in *ProjectVPC) DeepCopyObject() runtime.Object
- func (r *ProjectVPC) Default()
- func (r *ProjectVPC) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *ProjectVPC) ValidateCreate() error
- func (r *ProjectVPC) ValidateDelete() error
- func (r *ProjectVPC) ValidateUpdate(old runtime.Object) error
- type ProjectVPCList
- type ProjectVPCSpec
- type ProjectVPCStatus
- type PublicAccessUserConfig
- type Redis
- func (r Redis) AuthSecretRef() AuthSecretReference
- func (in *Redis) DeepCopy() *Redis
- func (in *Redis) DeepCopyInto(out *Redis)
- func (in *Redis) DeepCopyObject() runtime.Object
- func (r *Redis) Default()
- func (r *Redis) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *Redis) ValidateCreate() error
- func (r *Redis) ValidateDelete() error
- func (r *Redis) ValidateUpdate(old runtime.Object) error
- type RedisList
- type RedisMigration
- type RedisPrivateAccess
- type RedisPrivatelinkAccess
- type RedisPublicAccess
- type RedisSpec
- type RedisUserConfig
- type ServiceCommonSpec
- type ServiceIntegration
- func (svcint ServiceIntegration) AuthSecretRef() AuthSecretReference
- func (in *ServiceIntegration) DeepCopy() *ServiceIntegration
- func (in *ServiceIntegration) DeepCopyInto(out *ServiceIntegration)
- func (in *ServiceIntegration) DeepCopyObject() runtime.Object
- func (r *ServiceIntegration) Default()
- func (r *ServiceIntegration) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *ServiceIntegration) ValidateCreate() error
- func (r *ServiceIntegration) ValidateDelete() error
- func (r *ServiceIntegration) ValidateUpdate(old runtime.Object) error
- type ServiceIntegrationDatadogUserConfig
- type ServiceIntegrationKafkaConnect
- type ServiceIntegrationKafkaConnectUserConfig
- type ServiceIntegrationKafkaLogsUserConfig
- type ServiceIntegrationList
- type ServiceIntegrationMetricsUserConfig
- type ServiceIntegrationSpec
- type ServiceIntegrationStatus
- type ServiceStatus
- type ServiceUser
- func (svcusr ServiceUser) AuthSecretRef() AuthSecretReference
- func (in *ServiceUser) DeepCopy() *ServiceUser
- func (in *ServiceUser) DeepCopyInto(out *ServiceUser)
- func (in *ServiceUser) DeepCopyObject() runtime.Object
- func (r *ServiceUser) Default()
- func (r *ServiceUser) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *ServiceUser) ValidateCreate() error
- func (r *ServiceUser) ValidateDelete() error
- func (r *ServiceUser) ValidateUpdate(old runtime.Object) error
- type ServiceUserList
- type ServiceUserSpec
- type ServiceUserStatus
- type TimescaledbUserConfig
Constants ¶
This section is empty.
Variables ¶
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 )
Functions ¶
func ConvertDiscSpace ¶ added in v0.3.0
Types ¶
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 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
func (Clickhouse) AuthSecretRef ¶ added in v0.3.0
func (o Clickhouse) AuthSecretRef() AuthSecretReference
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 (r *Clickhouse) Default()
Default implements webhook.Defaulter so a webhook will be registered for the type
func (*Clickhouse) SetupWebhookWithManager ¶ added in v0.3.0
func (r *Clickhouse) SetupWebhookWithManager(mgr ctrl.Manager) error
func (*Clickhouse) ValidateCreate ¶ added in v0.3.0
func (r *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 (r *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 (r *Clickhouse) ValidateUpdate(old runtime.Object) error
ValidateUpdate implements webhook.Validator so a webhook will be registered for the type
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 ClickhouseSpec ¶ added in v0.3.0
type ClickhouseSpec struct {
ServiceCommonSpec `json:",inline"`
// Authentication reference to Aiven token in a secret
AuthSecretRef AuthSecretReference `json:"authSecretRef"`
// Information regarding secret creation
ConnInfoSecretTarget ConnInfoSecretTarget `json:"connInfoSecretTarget,omitempty"`
// OpenSearch specific user configuration options
UserConfig 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 +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 (u ClickhouseUser) AuthSecretRef() AuthSecretReference
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) Default ¶ added in v0.3.0
func (r *ClickhouseUser) Default()
Default implements webhook.Defaulter so a webhook will be registered for the type
func (*ClickhouseUser) SetupWebhookWithManager ¶ added in v0.3.0
func (r *ClickhouseUser) SetupWebhookWithManager(mgr ctrl.Manager) error
func (*ClickhouseUser) ValidateCreate ¶ added in v0.3.0
func (r *ClickhouseUser) ValidateCreate() error
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*ClickhouseUser) ValidateDelete ¶ added in v0.3.0
func (r *ClickhouseUser) ValidateDelete() error
ValidateDelete implements webhook.Validator so a webhook will be registered for the type
func (*ClickhouseUser) ValidateUpdate ¶ added in v0.3.0
func (r *ClickhouseUser) ValidateUpdate(old runtime.Object) error
ValidateUpdate implements webhook.Validator so a webhook will be registered for the type
type ClickhouseUserConfig ¶ added in v0.3.0
type ClickhouseUserConfig struct {
// Glob pattern and number of indexes matching that pattern to be kept Allows you to create glob style patterns and set a max number of indexes matching this pattern you want to keep. Creating indexes exceeding this value will cause the oldest one to get deleted. You could for example create a pattern looking like 'logs.?' and then create index logs.1, logs.2 etc, it will delete logs.1 once you create logs.6. Do note 'logs.?' does not apply to logs.10. Note: Setting max_index_count to 0 will do nothing and the pattern gets ignored.
// IP filter Allow incoming connections from CIDR address block, e.g. '10.20.0.0/16'
IpFilter []string `json:"ip_filter,omitempty"`
// +kubebuilder:validation:MaxLength=63
// Name of another project to fork a service from. This has effect only when a new service is being created.
ProjectToForkFrom string `json:"project_to_fork_from,omitempty"`
// +kubebuilder:validation:MaxLength=63
// Name of another service to fork from. This has effect only when a new service is being created.
ServiceToForkFrom string `json:"service_to_fork_from,omitempty"`
}
func (*ClickhouseUserConfig) DeepCopy ¶ added in v0.3.0
func (in *ClickhouseUserConfig) DeepCopy() *ClickhouseUserConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClickhouseUserConfig.
func (*ClickhouseUserConfig) DeepCopyInto ¶ added in v0.3.0
func (in *ClickhouseUserConfig) DeepCopyInto(out *ClickhouseUserConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
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 {
// +kubebuilder:validation:MaxLength=63
// +kubebuilder:validation:Format="^[a-zA-Z0-9_-]*$"
// Project to link the user to
Project string `json:"project"`
// +kubebuilder:validation:MaxLength=63
// Service to link the user to
ServiceName string `json:"serviceName"`
// +kubebuilder:validation:Enum=caching_sha2_password;mysql_native_password
// Authentication details
Authentication string `json:"authentication,omitempty"`
// Information regarding secret creation
ConnInfoSecretTarget ConnInfoSecretTarget `json:"connInfoSecretTarget,omitempty"`
// Authentication reference to Aiven token in a secret
AuthSecretRef AuthSecretReference `json:"authSecretRef"`
}
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 ConnInfoSecretTarget ¶
type ConnInfoSecretTarget struct {
// Name of the Secret resource to be created
Name string `json:"name"`
}
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 +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 (cp ConnectionPool) AuthSecretRef() AuthSecretReference
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 (r *ConnectionPool) Default()
Default implements webhook.Defaulter so a webhook will be registered for the type
func (*ConnectionPool) SetupWebhookWithManager ¶
func (r *ConnectionPool) SetupWebhookWithManager(mgr ctrl.Manager) error
func (*ConnectionPool) ValidateCreate ¶
func (r *ConnectionPool) ValidateCreate() error
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*ConnectionPool) ValidateDelete ¶
func (r *ConnectionPool) ValidateDelete() error
ValidateDelete implements webhook.Validator so a webhook will be registered for the type
func (*ConnectionPool) ValidateUpdate ¶
func (r *ConnectionPool) ValidateUpdate(old 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 {
// +kubebuilder:validation:MaxLength=63
// +kubebuilder:validation:Format="^[a-zA-Z0-9_-]*$"
// Target project.
Project string `json:"project"`
// +kubebuilder:validation:MaxLength=63
// Service name.
ServiceName string `json:"serviceName"`
// +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"`
// +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 string `json:"poolMode,omitempty"`
// Information regarding secret creation
ConnInfoSecretTarget ConnInfoSecretTarget `json:"connInfoSecretTarget,omitempty"`
// Authentication reference to Aiven token in a secret
AuthSecretRef AuthSecretReference `json:"authSecretRef"`
}
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="Service Name",type="string",JSONPath=".spec.serviceName" +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project"
func (Database) AuthSecretRef ¶
func (db Database) AuthSecretRef() AuthSecretReference
func (*Database) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Database.
func (*Database) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Database) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Database) Default ¶
func (r *Database) Default()
Default implements webhook.Defaulter so a webhook will be registered for the type
func (*Database) SetupWebhookWithManager ¶
func (*Database) ValidateCreate ¶
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*Database) ValidateDelete ¶
ValidateDelete 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 {
// +kubebuilder:validation:MaxLength=63
// +kubebuilder:validation:Format="^[a-zA-Z0-9_-]*$"
// Project to link the database to
Project string `json:"project"`
// +kubebuilder:validation:MaxLength=63
// PostgreSQL service to link the database to
ServiceName string `json:"serviceName"`
// +kubebuilder:validation:MaxLength=128
// Default string sort order (LC_COLLATE) of the database. Default value: en_US.UTF-8
LcCollate string `json:"lcCollate,omitempty"`
// +kubebuilder:validation:MaxLength=128
// 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"`
// Authentication reference to Aiven token in a secret
AuthSecretRef AuthSecretReference `json:"authSecretRef"`
}
DatabaseSpec defines the desired state of Database
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 KafkServiceKafkaConnectUserConfig ¶
type KafkServiceKafkaConnectUserConfig struct {
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=10000
// The maximum number of records returned by a single poll The maximum number of records returned in a single call to poll() (defaults to 500).
ConsumerMaxPollRecords *int64 `json:"consumer_max_poll_records,omitempty"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=2147483647
// Offset flush timeout Maximum number of milliseconds to wait for records to flush and partition offset data to be committed to offset storage before cancelling the process and restoring the offset data to be committed in a future attempt (defaults to 5000).
OffsetFlushTimeoutMs *int64 `json:"offset_flush_timeout_ms,omitempty"`
// +kubebuilder:validation:Enum=None;All
// Client config override policy Defines what client configurations can be overridden by the connector. Default is None
ConnectorClientConfigOverridePolicy string `json:"connector_client_config_override_policy,omitempty"`
// +kubebuilder:validation:Minimum=1048576
// +kubebuilder:validation:Maximum=104857600
// The maximum amount of data the server should return for a fetch request Records are fetched in batches by the consumer, and if the first record batch in the first non-empty partition of the fetch is larger than this value, the record batch will still be returned to ensure that the consumer can make progress. As such, this is not a absolute maximum.
ConsumerFetchMaxBytes *int64 `json:"consumer_fetch_max_bytes,omitempty"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=2147483647
// The maximum delay between polls when using consumer group management The maximum delay in milliseconds between invocations of poll() when using consumer group management (defaults to 300000).
ConsumerMaxPollIntervalMs *int64 `json:"consumer_max_poll_interval_ms,omitempty"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=100000000
// The interval at which to try committing offsets for tasks The interval at which to try committing offsets for tasks (defaults to 60000).
OffsetFlushIntervalMs *int64 `json:"offset_flush_interval_ms,omitempty"`
// +kubebuilder:validation:Minimum=131072
// +kubebuilder:validation:Maximum=10485760
// The maximum size of a request in bytes This setting will limit the number of record batches the producer will send in a single request to avoid sending huge requests.
ProducerMaxRequestSize *int64 `json:"producer_max_request_size,omitempty"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=2147483647
// The timeout used to detect failures when using Kafka’s group management facilities The timeout in milliseconds used to detect failures when using Kafka’s group management facilities (defaults to 10000).
SessionTimeoutMs *int64 `json:"session_timeout_ms,omitempty"`
// +kubebuilder:validation:Enum=earliest;latest
// Consumer auto offset reset What to do when there is no initial offset in Kafka or if the current offset does not exist any more on the server. Default is earliest
ConsumerAutoOffsetReset string `json:"consumer_auto_offset_reset,omitempty"`
// +kubebuilder:validation:Enum=read_uncommitted;read_committed
// Consumer isolation level Transaction read isolation level. read_uncommitted is the default, but read_committed can be used if consume-exactly-once behavior is desired.
ConsumerIsolationLevel string `json:"consumer_isolation_level,omitempty"`
// +kubebuilder:validation:Minimum=1048576
// +kubebuilder:validation:Maximum=104857600
// The maximum amount of data per-partition the server will return. Records are fetched in batches by the consumer.If the first record batch in the first non-empty partition of the fetch is larger than this limit, the batch will still be returned to ensure that the consumer can make progress.
ConsumerMaxPartitionFetchBytes *int64 `json:"consumer_max_partition_fetch_bytes,omitempty"`
}
func (*KafkServiceKafkaConnectUserConfig) DeepCopy ¶
func (in *KafkServiceKafkaConnectUserConfig) DeepCopy() *KafkServiceKafkaConnectUserConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkServiceKafkaConnectUserConfig.
func (*KafkServiceKafkaConnectUserConfig) DeepCopyInto ¶
func (in *KafkServiceKafkaConnectUserConfig) DeepCopyInto(out *KafkServiceKafkaConnectUserConfig)
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 +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 (kfk Kafka) AuthSecretRef() AuthSecretReference
func (*Kafka) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Kafka.
func (*Kafka) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Kafka) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Kafka) Default ¶
func (r *Kafka) Default()
Default implements webhook.Defaulter so a webhook will be registered for the type
func (*Kafka) SetupWebhookWithManager ¶
func (*Kafka) ValidateCreate ¶
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*Kafka) ValidateDelete ¶
ValidateDelete 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 (acl KafkaACL) AuthSecretRef() AuthSecretReference
func (*KafkaACL) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaACL.
func (*KafkaACL) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KafkaACL) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*KafkaACL) Default ¶
func (r *KafkaACL) Default()
Default implements webhook.Defaulter so a webhook will be registered for the type
func (*KafkaACL) SetupWebhookWithManager ¶
func (*KafkaACL) ValidateCreate ¶
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*KafkaACL) ValidateDelete ¶
ValidateDelete 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 {
// +kubebuilder:validation:MaxLength=63
// +kubebuilder:validation:Format="^[a-zA-Z0-9_-]*$"
// Project to link the Kafka ACL to
Project string `json:"project"`
// +kubebuilder:validation:MaxLength=63
// Service to link the Kafka ACL to
ServiceName string `json:"serviceName"`
// +kubebuilder:validation:Enum=admin;read;readwrite;write
// Kafka permission to grant (admin, read, readwrite, write)
Permission string `json:"permission"`
// Topic name pattern for the ACL entry
Topic string `json:"topic"`
// Username pattern for the ACL entry
Username string `json:"username"`
// Authentication reference to Aiven token in a secret
AuthSecretRef AuthSecretReference `json:"authSecretRef"`
}
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 KafkaAuthenticationMethodsUserConfig ¶
type KafkaAuthenticationMethodsUserConfig struct {
// Enable certificate/SSL authentication
Certificate *bool `json:"certificate,omitempty"`
// Enable SASL authentication
Sasl *bool `json:"sasl,omitempty"`
}
func (*KafkaAuthenticationMethodsUserConfig) DeepCopy ¶
func (in *KafkaAuthenticationMethodsUserConfig) DeepCopy() *KafkaAuthenticationMethodsUserConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaAuthenticationMethodsUserConfig.
func (*KafkaAuthenticationMethodsUserConfig) DeepCopyInto ¶
func (in *KafkaAuthenticationMethodsUserConfig) DeepCopyInto(out *KafkaAuthenticationMethodsUserConfig)
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="State",type="string",JSONPath=".status.state"
func (KafkaConnect) AuthSecretRef ¶
func (kfkc KafkaConnect) AuthSecretRef() AuthSecretReference
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 (r *KafkaConnect) Default()
Default implements webhook.Defaulter so a webhook will be registered for the type
func (*KafkaConnect) SetupWebhookWithManager ¶
func (r *KafkaConnect) SetupWebhookWithManager(mgr ctrl.Manager) error
func (*KafkaConnect) ValidateCreate ¶
func (r *KafkaConnect) ValidateCreate() error
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*KafkaConnect) ValidateDelete ¶
func (r *KafkaConnect) ValidateDelete() error
ValidateDelete implements webhook.Validator so a webhook will be registered for the type
func (*KafkaConnect) ValidateUpdate ¶
func (r *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 KafkaConnectPrivateAccessUserConfig ¶
type KafkaConnectPrivateAccessUserConfig struct {
// Allow clients to connect to kafka_connect with a DNS name that always resolves to the service's private IP addresses. Only available in certain network locations
KafkaConnect *bool `json:"kafka_connect,omitempty"`
// Allow clients to connect to prometheus with a DNS name that always resolves to the service's private IP addresses. Only available in certain network locations
Prometheus *bool `json:"prometheus,omitempty"`
}
func (*KafkaConnectPrivateAccessUserConfig) DeepCopy ¶
func (in *KafkaConnectPrivateAccessUserConfig) DeepCopy() *KafkaConnectPrivateAccessUserConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaConnectPrivateAccessUserConfig.
func (*KafkaConnectPrivateAccessUserConfig) DeepCopyInto ¶
func (in *KafkaConnectPrivateAccessUserConfig) DeepCopyInto(out *KafkaConnectPrivateAccessUserConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KafkaConnectPublicAccessUserConfig ¶
type KafkaConnectPublicAccessUserConfig struct {
// Allow clients to connect to kafka_connect from the public internet for service nodes that are in a project VPC or another type of private network
KafkaConnect *bool `json:"kafka_connect,omitempty"`
// Allow clients to connect to prometheus from the public internet for service nodes that are in a project VPC or another type of private network
Prometheus *bool `json:"prometheus,omitempty"`
}
func (*KafkaConnectPublicAccessUserConfig) DeepCopy ¶
func (in *KafkaConnectPublicAccessUserConfig) DeepCopy() *KafkaConnectPublicAccessUserConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaConnectPublicAccessUserConfig.
func (*KafkaConnectPublicAccessUserConfig) DeepCopyInto ¶
func (in *KafkaConnectPublicAccessUserConfig) DeepCopyInto(out *KafkaConnectPublicAccessUserConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KafkaConnectSpec ¶
type KafkaConnectSpec struct {
ServiceCommonSpec `json:",inline"`
// Authentication reference to Aiven token in a secret
AuthSecretRef AuthSecretReference `json:"authSecretRef"`
// PostgreSQL specific user configuration options
UserConfig 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 KafkaConnectUserConfig ¶
type KafkaConnectUserConfig struct {
// Defines what client configurations can be overridden by the connector. Default is None
ConnectorClientConfigOverridePolicy string `json:"connector_client_config_override_policy,omitempty"`
// What to do when there is no initial offset in Kafka or if the current offset does not exist any more on the server. Default is earliest
ConsumerAutoOffsetReset string `json:"consumer_auto_offset_reset,omitempty"`
// Records are fetched in batches by the consumer, and if the first record batch in the first non-empty partition of the fetch is larger than this value, the record batch will still be returned to ensure that the consumer can make progress. As such, this is not a absolute maximum.
ConsumerFetchMaxBytes *int64 `json:"consumer_fetch_max_bytes,omitempty"`
// Transaction read isolation level. read_uncommitted is the default, but read_committed can be used if consume-exactly-once behavior is desired.
ConsumerIsolationLevel string `json:"consumer_isolation_level,omitempty"`
// Records are fetched in batches by the consumer.If the first record batch in the first non-empty partition of the fetch is larger than this limit, the batch will still be returned to ensure that the consumer can make progress.
ConsumerMaxPartitionFetchBytes *int64 `json:"consumer_max_partition_fetch_bytes,omitempty"`
// The maximum delay in milliseconds between invocations of poll() when using consumer group management (defaults to 300000).
ConsumerMaxPollIntervalMs *int64 `json:"consumer_max_poll_interval_ms,omitempty"`
// The maximum number of records returned in a single call to poll() (defaults to 500).
ConsumerMaxPollRecords *int64 `json:"consumer_max_poll_records,omitempty"`
// The interval at which to try committing offsets for tasks (defaults to 60000).
OffsetFlushIntervalMs *int64 `json:"offset_flush_interval_ms,omitempty"`
// This setting will limit the number of record batches the producer will send in a single request to avoid sending huge requests.
ProducerMaxRequestSize *int64 `json:"producer_max_request_size,omitempty"`
// The timeout in milliseconds used to detect failures when using Kafka’s group management facilities (defaults to 10000).
SessionTimeoutMs *int64 `json:"session_timeout_ms,omitempty"`
// Allow access to selected service ports from private networks
PrivateAccess KafkaConnectPrivateAccessUserConfig `json:"private_access,omitempty"`
// Allow access to selected service ports from the public Internet
PublicAccess KafkaConnectPublicAccessUserConfig `json:"public_access,omitempty"`
}
func (*KafkaConnectUserConfig) DeepCopy ¶
func (in *KafkaConnectUserConfig) DeepCopy() *KafkaConnectUserConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaConnectUserConfig.
func (*KafkaConnectUserConfig) DeepCopyInto ¶
func (in *KafkaConnectUserConfig) DeepCopyInto(out *KafkaConnectUserConfig)
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 (kfk KafkaConnector) AuthSecretRef() AuthSecretReference
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 (r *KafkaConnector) Default()
Default implements webhook.Defaulter so a webhook will be registered for the type
func (*KafkaConnector) SetupWebhookWithManager ¶
func (r *KafkaConnector) SetupWebhookWithManager(mgr ctrl.Manager) error
func (*KafkaConnector) ValidateCreate ¶
func (r *KafkaConnector) ValidateCreate() error
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*KafkaConnector) ValidateDelete ¶
func (r *KafkaConnector) ValidateDelete() error
ValidateDelete implements webhook.Validator so a webhook will be registered for the type
func (*KafkaConnector) ValidateUpdate ¶
func (r *KafkaConnector) ValidateUpdate(old 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 {
// +kubebuilder:validation:MaxLength=63
// +kubebuilder:validation:Format="^[a-zA-Z0-9_-]*$"
// Target project.
Project string `json:"project"`
// +kubebuilder:validation:MaxLength=63
// Service name.
ServiceName string `json:"serviceName"`
// Authentication reference to Aiven token in a secret
AuthSecretRef AuthSecretReference `json:"authSecretRef"`
// +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
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 string `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 ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaList.
func (*KafkaList) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KafkaList) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type KafkaPrivateAccessUserConfig ¶
type KafkaPrivateAccessUserConfig struct {
// Allow clients to connect to prometheus with a DNS name that always resolves to the service's private IP addresses. Only available in certain network locations
Prometheus *bool `json:"prometheus,omitempty"`
}
func (*KafkaPrivateAccessUserConfig) DeepCopy ¶
func (in *KafkaPrivateAccessUserConfig) DeepCopy() *KafkaPrivateAccessUserConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaPrivateAccessUserConfig.
func (*KafkaPrivateAccessUserConfig) DeepCopyInto ¶
func (in *KafkaPrivateAccessUserConfig) DeepCopyInto(out *KafkaPrivateAccessUserConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KafkaPublicAccessUserConfig ¶
type KafkaPublicAccessUserConfig struct {
// Allow clients to connect to prometheus from the public internet for service nodes that are in a project VPC or another type of private network
Prometheus *bool `json:"prometheus,omitempty"`
// Allow clients to connect to schema_registry from the public internet for service nodes that are in a project VPC or another type of private network
SchemaRegistry *bool `json:"schema_registry,omitempty"`
// Allow clients to connect to kafka from the public internet for service nodes that are in a project VPC or another type of private network
Kafka *bool `json:"kafka,omitempty"`
// Allow clients to connect to kafka_connect from the public internet for service nodes that are in a project VPC or another type of private network
KafkaConnect *bool `json:"kafka_connect,omitempty"`
// Allow clients to connect to kafka_rest from the public internet for service nodes that are in a project VPC or another type of private network
KafkaRest *bool `json:"kafka_rest,omitempty"`
}
func (*KafkaPublicAccessUserConfig) DeepCopy ¶
func (in *KafkaPublicAccessUserConfig) DeepCopy() *KafkaPublicAccessUserConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaPublicAccessUserConfig.
func (*KafkaPublicAccessUserConfig) DeepCopyInto ¶
func (in *KafkaPublicAccessUserConfig) DeepCopyInto(out *KafkaPublicAccessUserConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KafkaRestUserConfig ¶
type KafkaRestUserConfig struct {
// +kubebuilder:validation:Minimum=0
// +kubebuilder:validation:Maximum=671088640
// consumer.request.max.bytes Maximum number of bytes in unencoded message keys and values by a single request
ConsumerRequestMaxBytes *int64 `json:"consumer_request_max_bytes,omitempty"`
// +kubebuilder:validation:Minimum=1000
// +kubebuilder:validation:Maximum=30000
// +kubebuilder:validation:Enum=1000;15000;30000
// consumer.request.timeout.ms The maximum total time to wait for messages for a request if the maximum number of messages has not yet been reached
ConsumerRequestTimeoutMs *int64 `json:"consumer_request_timeout_ms,omitempty"`
// +kubebuilder:validation:Enum=all;-1;0;1
// producer.acks The number of acknowledgments the producer requires the leader to have received before considering a request complete. If set to 'all' or '-1', the leader will wait for the full set of in-sync replicas to acknowledge the record.
ProducerAcks string `json:"producer_acks,omitempty"`
// +kubebuilder:validation:Minimum=0
// +kubebuilder:validation:Maximum=5000
// producer.linger.ms Wait for up to the given delay to allow batching records together
ProducerLingerMs *int64 `json:"producer_linger_ms,omitempty"`
// +kubebuilder:validation:Minimum=10
// +kubebuilder:validation:Maximum=250
// simpleconsumer.pool.size.max Maximum number of SimpleConsumers that can be instantiated per broker
SimpleconsumerPoolSizeMax *int64 `json:"simpleconsumer_pool_size_max,omitempty"`
// consumer.enable.auto.commit If true the consumer's offset will be periodically committed to Kafka in the background
ConsumerEnableAutoCommit *bool `json:"consumer_enable_auto_commit,omitempty"`
// Allow access to selected service ports from the public Internet
PublicAccess KafkaPublicAccessUserConfig `json:"public_access,omitempty"`
// +kubebuilder:validation:MaxLength=255
// Custom domain Serve the web frontend using a custom CNAME pointing to the Aiven DNS name
CustomDomain string `json:"custom_domain,omitempty"`
}
func (*KafkaRestUserConfig) DeepCopy ¶
func (in *KafkaRestUserConfig) DeepCopy() *KafkaRestUserConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaRestUserConfig.
func (*KafkaRestUserConfig) DeepCopyInto ¶
func (in *KafkaRestUserConfig) DeepCopyInto(out *KafkaRestUserConfig)
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 (kfks KafkaSchema) AuthSecretRef() AuthSecretReference
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 (r *KafkaSchema) Default()
Default implements webhook.Defaulter so a webhook will be registered for the type
func (*KafkaSchema) SetupWebhookWithManager ¶
func (r *KafkaSchema) SetupWebhookWithManager(mgr ctrl.Manager) error
func (*KafkaSchema) ValidateCreate ¶
func (r *KafkaSchema) ValidateCreate() error
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*KafkaSchema) ValidateDelete ¶
func (r *KafkaSchema) ValidateDelete() error
ValidateDelete implements webhook.Validator so a webhook will be registered for the type
func (*KafkaSchema) ValidateUpdate ¶
func (r *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 KafkaSchemaRegistryConfig ¶
type KafkaSchemaRegistryConfig struct {
// leader_eligibility If true, Karapace / Schema Registry on the service nodes can participate in leader election. It might be needed to disable this when the schemas topic is replicated to a secondary cluster and Karapace / Schema Registry there must not participate in leader election. Defaults to 'true'.
LeaderEligibility *bool `json:"leader_eligibility,omitempty"`
// +kubebuilder:validation:MaxLength=249
// topic_name The durable single partition topic that acts as the durable log for the data. This topic must be compacted to avoid losing data due to retention policy. Please note that changing this configuration in an existing Schema Registry / Karapace setup leads to previous schemas being inaccessible, data encoded with them potentially unreadable and schema ID sequence put out of order. It's only possible to do the switch while Schema Registry / Karapace is disabled. Defaults to '_schemas'.
TopicName string `json:"topic_name,omitempty"`
}
func (*KafkaSchemaRegistryConfig) DeepCopy ¶
func (in *KafkaSchemaRegistryConfig) DeepCopy() *KafkaSchemaRegistryConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaSchemaRegistryConfig.
func (*KafkaSchemaRegistryConfig) DeepCopyInto ¶
func (in *KafkaSchemaRegistryConfig) DeepCopyInto(out *KafkaSchemaRegistryConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KafkaSchemaSpec ¶
type KafkaSchemaSpec struct {
// +kubebuilder:validation:MaxLength=63
// +kubebuilder:validation:Format="^[a-zA-Z0-9_-]*$"
// Project to link the Kafka Schema to
Project string `json:"project"`
// +kubebuilder:validation:MaxLength=63
// Service to link the Kafka Schema to
ServiceName string `json:"serviceName"`
// +kubebuilder:validation:MaxLength=63
// 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=BACKWARD;BACKWARD_TRANSITIVE;FORWARD;FORWARD_TRANSITIVE;FULL;FULL_TRANSITIVE;NONE
// Kafka Schemas compatibility level
CompatibilityLevel string `json:"compatibilityLevel,omitempty"`
// Authentication reference to Aiven token in a secret
AuthSecretRef AuthSecretReference `json:"authSecretRef"`
}
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"`
// 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"`
// +kubebuilder:validation:Format="^[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.
DiskSpace string `json:"disk_space,omitempty"`
// Authentication reference to Aiven token in a secret
AuthSecretRef AuthSecretReference `json:"authSecretRef"`
// Information regarding secret creation
ConnInfoSecretTarget ConnInfoSecretTarget `json:"connInfoSecretTarget,omitempty"`
// Switch the service to use Karapace for schema registry and REST proxy
Karapace *bool `json:"karapace,omitempty"`
// Kafka specific user configuration options
UserConfig KafkaUserConfig `json:"userConfig,omitempty"`
}
KafkaSpec defines the desired state of Kafka
func (*KafkaSpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaSpec.
func (*KafkaSpec) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KafkaSubKafkaUserConfig ¶
type KafkaSubKafkaUserConfig struct {
// +kubebuilder:validation:Minimum=0
// +kubebuilder:validation:Maximum=100001200
// message.max.bytes The maximum size of message that the server can receive.
MessageMaxBytes *int64 `json:"message_max_bytes,omitempty"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=10
// default.replication.factor Replication factor for autocreated topics
DefaultReplicationFactor *int64 `json:"default_replication_factor,omitempty"`
// +kubebuilder:validation:Minimum=0
// +kubebuilder:validation:Maximum=1
// log.cleaner.min.cleanable.ratio Controls log compactor frequency. Larger value means more frequent compactions but also more space wasted for logs. Consider setting log.cleaner.max.compaction.lag.ms to enforce compactions sooner, instead of setting a very high value for this option.
LogCleanerMinCleanableRatio *int64 `json:"log_cleaner_min_cleanable_ratio,omitempty"`
// +kubebuilder:validation:Minimum=0
// +kubebuilder:validation:Maximum=104857600
// log.index.interval.bytes The interval with which Kafka adds an entry to the offset index
LogIndexIntervalBytes *int64 `json:"log_index_interval_bytes,omitempty"`
// +kubebuilder:validation:Minimum=0
// +kubebuilder:validation:Maximum=3600000
// log.segment.delete.delay.ms The amount of time to wait before deleting a file from the filesystem
LogSegmentDeleteDelayMs *int64 `json:"log_segment_delete_delay_ms,omitempty"`
// +kubebuilder:validation:Minimum=1000
// +kubebuilder:validation:Maximum=10000
// max.incremental.fetch.session.cache.slots The maximum number of incremental fetch sessions that the broker will maintain.
MaxIncrementalFetchSessionCacheSlots *int64 `json:"max_incremental_fetch_session_cache_slots,omitempty"`
// +kubebuilder:validation:Minimum=10485760
// +kubebuilder:validation:Maximum=209715200
// socket.request.max.bytes The maximum number of bytes in a socket request (defaults to 104857600).
SocketRequestMaxBytes *int64 `json:"socket_request_max_bytes,omitempty"`
// +kubebuilder:validation:Minimum=0
// +kubebuilder:validation:Maximum=315569260000
// log.cleaner.delete.retention.ms How long are delete records retained?
LogCleanerDeleteRetentionMs *int64 `json:"log_cleaner_delete_retention_ms,omitempty"`
// +kubebuilder:validation:Minimum=1048576
// +kubebuilder:validation:Maximum=104857600
// log.index.size.max.bytes The maximum size in bytes of the offset index
LogIndexSizeMaxBytes *int64 `json:"log_index_size_max_bytes,omitempty"`
// +kubebuilder:validation:Minimum=0
// log.roll.jitter.ms The maximum jitter to subtract from logRollTimeMillis (in milliseconds). If not set, the value in log.roll.jitter.hours is used
LogRollJitterMs *int64 `json:"log_roll_jitter_ms,omitempty"`
// +kubebuilder:validation:Minimum=256
// +kubebuilder:validation:Maximum=2147483647
// max.connections.per.ip The maximum number of connections allowed from each ip address (defaults to 2147483647).
MaxConnectionsPerIP *int64 `json:"max_connections_per_ip,omitempty"`
// +kubebuilder:validation:Minimum=10485760
// +kubebuilder:validation:Maximum=1048576000
// replica.fetch.response.max.bytes Maximum bytes expected for the entire fetch response (defaults to 10485760). Records are fetched in batches, and if the first record batch in the first non-empty partition of the fetch is larger than this value, the record batch will still be returned to ensure that progress can be made. As such, this is not an absolute maximum.
ReplicaFetchResponseMaxBytes *int64 `json:"replica_fetch_response_max_bytes,omitempty"`
// auto.create.topics.enable Enable auto creation of topics
AutoCreateTopicsEnable *bool `json:"auto_create_topics_enable,omitempty"`
// +kubebuilder:validation:Minimum=0
// log.flush.interval.ms The maximum time in ms that a message in any topic is kept in memory before flushed to disk. If not set, the value in log.flush.scheduler.interval.ms is used
LogFlushIntervalMs *int64 `json:"log_flush_interval_ms,omitempty"`
// log.message.downconversion.enable This configuration controls whether down-conversion of message formats is enabled to satisfy consume requests.
LogMessageDownconversionEnable *bool `json:"log_message_downconversion_enable,omitempty"`
// +kubebuilder:validation:Minimum=1
// log.roll.ms The maximum time before a new log segment is rolled out (in milliseconds).
LogRollMs *int64 `json:"log_roll_ms,omitempty"`
// +kubebuilder:validation:Minimum=0
// log.cleaner.min.compaction.lag.ms The minimum time a message will remain uncompacted in the log. Only applicable for logs that are being compacted.
LogCleanerMinCompactionLagMs *int64 `json:"log_cleaner_min_compaction_lag_ms,omitempty"`
// +kubebuilder:validation:Minimum=0
// log.message.timestamp.difference.max.ms The maximum difference allowed between the timestamp when a broker receives a message and the timestamp specified in the message
LogMessageTimestampDifferenceMaxMs *int64 `json:"log_message_timestamp_difference_max_ms,omitempty"`
// +kubebuilder:validation:Enum=CreateTime;LogAppendTime
// log.message.timestamp.type Define whether the timestamp in the message is message create time or log append time.
LogMessageTimestampType string `json:"log_message_timestamp_type,omitempty"`
// log.retention.ms The number of milliseconds to keep a log file before deleting it (in milliseconds), If not set, the value in log.retention.minutes is used. If set to -1, no time limit is applied.
LogRetentionMs *int64 `json:"log_retention_ms,omitempty"`
// +kubebuilder:validation:Minimum=0
// +kubebuilder:validation:Maximum=60000
// group.min.session.timeout.ms The minimum allowed session timeout for registered consumers. Longer timeouts give consumers more time to process messages in between heartbeats at the cost of a longer time to detect failures.
GroupMinSessionTimeoutMs *int64 `json:"group_min_session_timeout_ms,omitempty"`
// +kubebuilder:validation:Minimum=10485760
// +kubebuilder:validation:Maximum=1073741824
// log.segment.bytes The maximum size of a single log file
LogSegmentBytes *int64 `json:"log_segment_bytes,omitempty"`
// +kubebuilder:validation:Enum=gzip;snappy;lz4;zstd;uncompressed;producer
// compression.type 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 string `json:"compression_type,omitempty"`
// +kubebuilder:validation:Minimum=0
// +kubebuilder:validation:Maximum=1800000
// group.max.session.timeout.ms The maximum allowed session timeout for registered consumers. Longer timeouts give consumers more time to process messages in between heartbeats at the cost of a longer time to detect failures.
GroupMaxSessionTimeoutMs *int64 `json:"group_max_session_timeout_ms,omitempty"`
// +kubebuilder:validation:Minimum=1
// log.flush.interval.messages The number of messages accumulated on a log partition before messages are flushed to disk
LogFlushIntervalMessages *int64 `json:"log_flush_interval_messages,omitempty"`
// log.preallocate Should pre allocate file when create new segment?
LogPreallocate *bool `json:"log_preallocate,omitempty"`
// log.retention.bytes The maximum size of the log before deleting messages
LogRetentionBytes *int64 `json:"log_retention_bytes,omitempty"`
// +kubebuilder:validation:Minimum=30000
// log.cleaner.max.compaction.lag.ms The maximum amount of time message will remain uncompacted. Only applicable for logs that are being compacted
LogCleanerMaxCompactionLagMs *int64 `json:"log_cleaner_max_compaction_lag_ms,omitempty"`
// +kubebuilder:validation:Maximum=2147483647
// log.retention.hours The number of hours to keep a log file before deleting it
LogRetentionHours *int64 `json:"log_retention_hours,omitempty"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=7
// min.insync.replicas When a producer sets acks to 'all' (or '-1'), min.insync.replicas specifies the minimum number of replicas that must acknowledge a write for the write to be considered successful.
MinInsyncReplicas *int64 `json:"min_insync_replicas,omitempty"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=1000
// num.partitions Number of partitions for autocreated topics
NumPartitions *int64 `json:"num_partitions,omitempty"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=2147483647
// offsets.retention.minutes Log retention window in minutes for offsets topic
OffsetsRetentionMinutes *int64 `json:"offsets_retention_minutes,omitempty"`
// +kubebuilder:validation:Minimum=1000
// +kubebuilder:validation:Maximum=3600000
// connections.max.idle.ms Idle connections timeout: the server socket processor threads close the connections that idle for longer than this.
ConnectionsMaxIdleMs *int64 `json:"connections_max_idle_ms,omitempty"`
// +kubebuilder:validation:Enum=compact;delete
// log.cleanup.policy The default cleanup policy for segments beyond the retention window
LogCleanupPolicy string `json:"log_cleanup_policy,omitempty"`
// +kubebuilder:validation:Minimum=10
// +kubebuilder:validation:Maximum=10000
// producer.purgatory.purge.interval.requests The purge interval (in number of requests) of the producer request purgatory(defaults to 1000).
ProducerPurgatoryPurgeIntervalRequests *int64 `json:"producer_purgatory_purge_interval_requests,omitempty"`
// +kubebuilder:validation:Minimum=1048576
// +kubebuilder:validation:Maximum=104857600
// replica.fetch.max.bytes The number of bytes of messages to attempt to fetch for each partition (defaults to 1048576). This is not an absolute maximum, if the first record batch in the first non-empty partition of the fetch is larger than this value, the record batch will still be returned to ensure that progress can be made.
ReplicaFetchMaxBytes *int64 `json:"replica_fetch_max_bytes,omitempty"`
}
func (*KafkaSubKafkaUserConfig) DeepCopy ¶
func (in *KafkaSubKafkaUserConfig) DeepCopy() *KafkaSubKafkaUserConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaSubKafkaUserConfig.
func (*KafkaSubKafkaUserConfig) DeepCopyInto ¶
func (in *KafkaSubKafkaUserConfig) DeepCopyInto(out *KafkaSubKafkaUserConfig)
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 (kfkt KafkaTopic) AuthSecretRef() AuthSecretReference
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 (r *KafkaTopic) Default()
Default implements webhook.Defaulter so a webhook will be registered for the type
func (*KafkaTopic) SetupWebhookWithManager ¶
func (r *KafkaTopic) SetupWebhookWithManager(mgr ctrl.Manager) error
func (*KafkaTopic) ValidateCreate ¶
func (r *KafkaTopic) ValidateCreate() error
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*KafkaTopic) ValidateDelete ¶
func (r *KafkaTopic) ValidateDelete() error
ValidateDelete implements webhook.Validator so a webhook will be registered for the type
func (*KafkaTopic) ValidateUpdate ¶
func (r *KafkaTopic) ValidateUpdate(old runtime.Object) error
ValidateUpdate implements webhook.Validator so a webhook will be registered for the type
type KafkaTopicConfig ¶
type KafkaTopicConfig struct {
// cleanup.policy value
CleanupPolicy string `json:"cleanup_policy,omitempty"`
// compression.type value
CompressionType string `json:"compression_type,omitempty"`
// delete.retention.ms value
DeleteRetentionMs *int64 `json:"delete_retention_ms,omitempty"`
// file.delete.delay.ms value
FileDeleteDelayMs *int64 `json:"file_delete_delay_ms,omitempty"`
// flush.messages value
FlushMessages *int64 `json:"flush_messages,omitempty"`
// flush.ms value
FlushMs *int64 `json:"flush_ms,omitempty"`
// index.interval.bytes value
IndexIntervalBytes *int64 `json:"index_interval_bytes,omitempty"`
// max.compaction.lag.ms value
MaxCompactionLagMs *int64 `json:"max_compaction_lag_ms,omitempty"`
// max.message.bytes value
MaxMessageBytes *int64 `json:"max_message_bytes,omitempty"`
// message.downconversion.enable value
MessageDownconversionEnable *bool `json:"message_downconversion_enable,omitempty"`
// message.format.version value
MessageFormatVersion string `json:"message_format_version,omitempty"`
// message.timestamp.difference.max.ms value
MessageTimestampDifferenceMaxMs *int64 `json:"message_timestamp_difference_max_ms,omitempty"`
// message.timestamp.type value
MessageTimestampType string `json:"message_timestamp_type,omitempty"`
// min.compaction.lag.ms value
MinCompactionLagMs *int64 `json:"min_compaction_lag_ms,omitempty"`
// min.insync.replicas value
MinInsyncReplicas *int64 `json:"min_insync_replicas,omitempty"`
// preallocate value
Preallocate *bool `json:"preallocate,omitempty"`
// retention.bytes value
RetentionBytes *int64 `json:"retention_bytes,omitempty"`
// retention.ms value
RetentionMs *int64 `json:"retention_ms,omitempty"`
// segment.bytes value
SegmentBytes *int64 `json:"segment_bytes,omitempty"`
// segment.index.bytes value
SegmentIndexBytes *int64 `json:"segment_index_bytes,omitempty"`
// segment.jitter.ms value
SegmentJitterMs *int64 `json:"segment_jitter_ms,omitempty"`
// segment.ms value
SegmentMs *int64 `json:"segment_ms,omitempty"`
// unclean.leader.election.enable value
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 {
// +kubebuilder:validation:MaxLength=63
// +kubebuilder:validation:Format="^[a-zA-Z0-9_-]*$"
// Target project.
Project string `json:"project"`
// +kubebuilder:validation:MaxLength=63
// Service name.
ServiceName string `json:"serviceName"`
// +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"`
// Authentication reference to Aiven token in a secret
AuthSecretRef AuthSecretReference `json:"authSecretRef"`
}
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 string `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:Format="^[a-zA-Z0-9_-]*$"
Key string `json:"key"`
// +kubebuilder:validation:MaxLength=256
// +kubebuilder:validation:Format="^[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 KafkaUserConfig ¶
type KafkaUserConfig struct {
// Kafka major version
KafkaVersion string `json:"kafka_version,omitempty"`
// Enable Schema-Registry service
SchemaRegistry *bool `json:"schema_registry,omitempty"`
// Kafka broker configuration values
Kafka KafkaSubKafkaUserConfig `json:"kafka,omitempty"`
// Kafka Connect configuration values
KafkaConnectConfig KafkServiceKafkaConnectUserConfig `json:"kafka_connect_user_config,omitempty"`
// Allow access to selected service ports from private networks
PrivateAccess KafkaPrivateAccessUserConfig `json:"private_access,omitempty"`
// Schema Registry configuration
SchemaRegistryConfig KafkaSchemaRegistryConfig `json:"schema_registry_config,omitempty"`
// IP filter Allow incoming connections from CIDR address block, e.g. '10.20.0.0/16'
IPFilter []string `json:"ip_filter,omitempty"`
// Kafka authentication methods
KafkaAuthenticationMethods KafkaAuthenticationMethodsUserConfig `json:"kafka_authentication_methods,omitempty"`
// Enable Kafka Connect service
KafkaConnect *bool `json:"kafka_connect,omitempty"`
// Enable Kafka-REST service
KafkaRest *bool `json:"kafka_rest,omitempty"`
// Kafka REST configuration
KafkaRestConfig KafkaRestUserConfig `json:"kafka_rest_config,omitempty"`
}
func (*KafkaUserConfig) DeepCopy ¶
func (in *KafkaUserConfig) DeepCopy() *KafkaUserConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaUserConfig.
func (*KafkaUserConfig) DeepCopyInto ¶
func (in *KafkaUserConfig) DeepCopyInto(out *KafkaUserConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type MigrationUserConfig ¶
type MigrationUserConfig struct {
// +kubebuilder:validation:MaxLength=255
// Hostname or IP address of the server where to migrate data from
Host string `json:"host,omitempty"`
// +kubebuilder:validation:MaxLength=256
// Password for authentication with the server where to migrate data from
Password string `json:"password,omitempty"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=65535
// Port number of the server where to migrate data from
Port *int64 `json:"port,omitempty"`
// The server where to migrate data from is secured with SSL
Ssl *bool `json:"ssl,omitempty"`
// +kubebuilder:validation:MaxLength=256
// User name for authentication with the server where to migrate data from
Username string `json:"username,omitempty"`
// +kubebuilder:validation:MaxLength=63
// Database name for bootstrapping the initial connection
Dbname string `json:"dbname,omitempty"`
}
func (*MigrationUserConfig) DeepCopy ¶
func (in *MigrationUserConfig) DeepCopy() *MigrationUserConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MigrationUserConfig.
func (*MigrationUserConfig) DeepCopyInto ¶
func (in *MigrationUserConfig) DeepCopyInto(out *MigrationUserConfig)
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
func (OpenSearch) AuthSecretRef ¶ added in v0.3.0
func (o OpenSearch) AuthSecretRef() AuthSecretReference
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 (r *OpenSearch) Default()
Default implements webhook.Defaulter so a webhook will be registered for the type
func (*OpenSearch) SetupWebhookWithManager ¶ added in v0.3.0
func (r *OpenSearch) SetupWebhookWithManager(mgr ctrl.Manager) error
func (*OpenSearch) ValidateCreate ¶ added in v0.3.0
func (r *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 (r *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 (r *OpenSearch) ValidateUpdate(old runtime.Object) error
ValidateUpdate implements webhook.Validator so a webhook will be registered for the type
type OpenSearchIndexPatterns ¶ added in v0.3.0
type OpenSearchIndexPatterns struct {
// +kubebuilder:validation:Minimum=0
// Maximum number of indexes to keep
MaxIndexCount *int64 `json:"max_index_count,omitempty"`
// +kubebuilder:validation:MaxLength=1024
// Must consist of alpha-numeric characters, dashes, underscores, dots and glob characters (* and ?)
Pattern string `json:"pattern,omitempty"`
}
func (*OpenSearchIndexPatterns) DeepCopy ¶ added in v0.3.0
func (in *OpenSearchIndexPatterns) DeepCopy() *OpenSearchIndexPatterns
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OpenSearchIndexPatterns.
func (*OpenSearchIndexPatterns) DeepCopyInto ¶ added in v0.3.0
func (in *OpenSearchIndexPatterns) DeepCopyInto(out *OpenSearchIndexPatterns)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type OpenSearchIndexTemplate ¶ added in v0.3.0
type OpenSearchIndexTemplate struct {
// +kubebuilder:validation:Minimum=0
// +kubebuilder:validation:Maximum=29
// index.number_of_replicas The number of replicas each primary shard has.
NumberOfReplicas *int64 `json:"number_of_replicas,omitempty"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=1024
// index.number_of_shards The number of primary shards that an index should have.
NumberOfShards *int64 `json:"number_of_shards,omitempty"`
// +kubebuilder:validation:Minimum=0
// +kubebuilder:validation:Maximum=100000
// index.mapping.nested_objects.limit The maximum number of nested JSON objects that a single document can contain across all nested types. This limit helps to prevent out of memory errors when a document contains too many nested objects. Default is 10000.
MappingNestedObjectsLimit *int64 `json:"mapping_nested_objects_limit,omitempty"`
}
func (*OpenSearchIndexTemplate) DeepCopy ¶ added in v0.3.0
func (in *OpenSearchIndexTemplate) DeepCopy() *OpenSearchIndexTemplate
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OpenSearchIndexTemplate.
func (*OpenSearchIndexTemplate) DeepCopyInto ¶ added in v0.3.0
func (in *OpenSearchIndexTemplate) DeepCopyInto(out *OpenSearchIndexTemplate)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
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 OpenSearchPrivateAccess ¶ added in v0.3.0
type OpenSearchPrivateAccess struct {
// Allow clients to connect to opensearch with a DNS name that always resolves to the service's private IP addresses. Only available in certain network locations
Opensearch *bool `json:"opensearch,omitempty"`
// Allow clients to connect to opensearch_dashboards with a DNS name that always resolves to the service's private IP addresses. Only available in certain network locations
OpensearchDashboards *bool `json:"opensearch_dashboards,omitempty"`
// Allow clients to connect to prometheus with a DNS name that always resolves to the service's private IP addresses. Only available in certain network locations
Prometheus *bool `json:"prometheus,omitempty"`
}
func (*OpenSearchPrivateAccess) DeepCopy ¶ added in v0.3.0
func (in *OpenSearchPrivateAccess) DeepCopy() *OpenSearchPrivateAccess
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OpenSearchPrivateAccess.
func (*OpenSearchPrivateAccess) DeepCopyInto ¶ added in v0.3.0
func (in *OpenSearchPrivateAccess) DeepCopyInto(out *OpenSearchPrivateAccess)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type OpenSearchPrivatelinkAccess ¶ added in v0.3.0
type OpenSearchPrivatelinkAccess struct {
// Enable opensearch
Opensearch *bool `json:"opensearch,omitempty"`
// Enable opensearch_dashboards
OpensearchDashboards *bool `json:"opensearch_dashboards,omitempty"`
}
func (*OpenSearchPrivatelinkAccess) DeepCopy ¶ added in v0.3.0
func (in *OpenSearchPrivatelinkAccess) DeepCopy() *OpenSearchPrivatelinkAccess
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OpenSearchPrivatelinkAccess.
func (*OpenSearchPrivatelinkAccess) DeepCopyInto ¶ added in v0.3.0
func (in *OpenSearchPrivatelinkAccess) DeepCopyInto(out *OpenSearchPrivatelinkAccess)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type OpenSearchPublicAccess ¶ added in v0.3.0
type OpenSearchPublicAccess struct {
// Allow clients to connect to opensearch_dashboards from the public internet for service nodes that are in a project VPC or another type of private network
OpensearchDashboards *bool `json:"opensearch_dashboards,omitempty"`
// Allow clients to connect to prometheus from the public internet for service nodes that are in a project VPC or another type of private network
Prometheus *bool `json:"prometheus,omitempty"`
// Allow clients to connect to opensearch from the public internet for service nodes that are in a project VPC or another type of private network
Opensearch *bool `json:"opensearch,omitempty"`
}
func (*OpenSearchPublicAccess) DeepCopy ¶ added in v0.3.0
func (in *OpenSearchPublicAccess) DeepCopy() *OpenSearchPublicAccess
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OpenSearchPublicAccess.
func (*OpenSearchPublicAccess) DeepCopyInto ¶ added in v0.3.0
func (in *OpenSearchPublicAccess) DeepCopyInto(out *OpenSearchPublicAccess)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type OpenSearchSpec ¶ added in v0.3.0
type OpenSearchSpec struct {
ServiceCommonSpec `json:",inline"`
// +kubebuilder:validation:Format="^[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.
DiskSpace string `json:"disk_space,omitempty"`
// Authentication reference to Aiven token in a secret
AuthSecretRef AuthSecretReference `json:"authSecretRef"`
// Information regarding secret creation
ConnInfoSecretTarget ConnInfoSecretTarget `json:"connInfoSecretTarget,omitempty"`
// OpenSearch specific user configuration options
UserConfig 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 OpenSearchUserConfig ¶ added in v0.3.0
type OpenSearchUserConfig struct {
// OpenSearch major version
OpensearchVersion string `json:"opensearch_version,omitempty"`
// OpenSearch Dashboards settings
OpensearchDashboards OpensearchDashboards `json:"opensearch_dashboards,omitempty"`
// +kubebuilder:validation:Format="^[a-zA-Z0-9-_:.]+$"
// +kubebuilder:validation:MaxLength=128
// Name of the basebackup to restore in forked service
RecoveryBasebackupName string `json:"recovery_basebackup_name,omitempty"`
// Allow access to selected service components through Privatelink
PrivatelinkAccess OpenSearchPrivatelinkAccess `json:"privatelink_access,omitempty"`
// Static IP addresses Use static public IP addresses
StaticIps *bool `json:"static_ips,omitempty"`
// Allow access to selected service ports from the public Internet
PublicAccess OpenSearchPublicAccess `json:"public_access,omitempty"`
// +kubebuilder:validation:MaxLength=255
// Custom domain Serve the web frontend using a custom CNAME pointing to the Aiven DNS name
CustomDomain string `json:"custom_domain,omitempty"`
// Allows you to create glob style patterns and set a max number of indexes matching this pattern you want to keep. Creating indexes exceeding this value will cause the oldest one to get deleted. You could for example create a pattern looking like 'logs.?' and then create index logs.1, logs.2 etc, it will delete logs.1 once you create logs.6. Do note 'logs.?' does not apply to logs.10. Note: Setting max_index_count to 0 will do nothing and the pattern gets ignored.
IndexPatterns []OpenSearchIndexPatterns `json:"index_patterns,omitempty"`
// Glob pattern and number of indexes matching that pattern to be kept Allows you to create glob style patterns and set a max number of indexes matching this pattern you want to keep. Creating indexes exceeding this value will cause the oldest one to get deleted. You could for example create a pattern looking like 'logs.?' and then create index logs.1, logs.2 etc, it will delete logs.1 once you create logs.6. Do note 'logs.?' does not apply to logs.10. Note: Setting max_index_count to 0 will do nothing and the pattern gets ignored.
// IP filter Allow incoming connections from CIDR address block, e.g. '10.20.0.0/16'
IpFilter []string `json:"ip_filter,omitempty"`
// Allow access to selected service ports from private networks
PrivateAccess OpenSearchPrivateAccess `json:"private_access,omitempty"`
// Template settings for all new indexes
IndexTemplate OpenSearchIndexTemplate `json:"index_template,omitempty"`
// OpenSearch settings
Opensearch OpenSearchUserConfigOpenSearch `json:"opensearch,omitempty"`
// +kubebuilder:validation:Minimum=0
// Maximum index count Maximum number of indexes to keep before deleting the oldest one
MaxIndexCount *int64 `json:"max_index_count,omitempty"`
// +kubebuilder:validation:MaxLength=63
// Name of another project to fork a service from. This has effect only when a new service is being created.
ProjectToForkFrom string `json:"project_to_fork_from,omitempty"`
// +kubebuilder:validation:MaxLength=63
// Name of another service to fork from. This has effect only when a new service is being created.
ServiceToForkFrom string `json:"service_to_fork_from,omitempty"`
// Disable replication factor adjustment DEPRECATED: Disable automatic replication factor adjustment for multi-node services. By default, Aiven ensures all indexes are replicated at least to two nodes. Note: Due to potential data loss in case of losing a service node, this setting can no longer be activated.
DisableReplicationFactorAdjustment *bool `json:"disable_replication_factor_adjustment,omitempty"`
// Don't reset index.refresh_interval to the default value Aiven automation resets index.refresh_interval to default value for every index to be sure that indices are always visible to search. If it doesn't fit your case, you can disable this by setting up this flag to true.
KeepIndexRefreshInterval *bool `json:"keep_index_refresh_interval,omitempty"`
}
func (*OpenSearchUserConfig) DeepCopy ¶ added in v0.3.0
func (in *OpenSearchUserConfig) DeepCopy() *OpenSearchUserConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OpenSearchUserConfig.
func (*OpenSearchUserConfig) DeepCopyInto ¶ added in v0.3.0
func (in *OpenSearchUserConfig) DeepCopyInto(out *OpenSearchUserConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type OpenSearchUserConfigOpenSearch ¶ added in v0.3.0
type OpenSearchUserConfigOpenSearch struct {
// +kubebuilder:validation:Minimum=10
// +kubebuilder:validation:Maximum=2000
// analyze thread pool queue size for the thread pool queue. See documentation for exact details.
ThreadPoolAnalyzeQueueSize *int64 `json:"thread_pool_analyze_queue_size,omitempty"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=128
// analyze thread pool size for the thread pool. See documentation for exact details. Do note this may have maximum value depending on CPU count - value is automatically lowered if set to higher than maximum value.
ThreadPoolAnalyzeSize *int64 `json:"thread_pool_analyze_size,omitempty"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=128
// force_merge thread pool size for the thread pool. See documentation for exact details. Do note this may have maximum value depending on CPU count - value is automatically lowered if set to higher than maximum value.
ThreadPoolForceMergeSize *int64 `json:"thread_pool_force_merge_size,omitempty"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=128
// get thread pool size for the thread pool. See documentation for exact details. Do note this may have maximum value depending on CPU count - value is automatically lowered if set to higher than maximum value.
ThreadPoolGetSize *int64 `json:"thread_pool_get_size,omitempty"`
// +kubebuilder:validation:Minimum=10
// +kubebuilder:validation:Maximum=2000
// search_throttled thread pool queue size for the thread pool queue. See documentation for exact details.
ThreadPoolSearchThrottledQueueSize *int64 `json:"thread_pool_search_throttled_queue_size,omitempty"`
// +kubebuilder:validation:Minimum=10
// +kubebuilder:validation:Maximum=2000
// write thread pool queue size for the thread pool queue. See documentation for exact details.
ThreadPoolWriteQueueSize *int64 `json:"thread_pool_write_queue_size,omitempty"`
// reindex_remote_whitelist Whitelisted addresses for reindexing. Changing this value will cause all OpenSearch instances to restart.
// Address (hostname:port or IP:port)
ReindexRemoteWhitelist []string `json:"reindex_remote_whitelist,omitempty"`
// +kubebuilder:validation:Minimum=3
// +kubebuilder:validation:Maximum=100
// indices.fielddata.cache.size Relative amount. Maximum amount of heap memory used for field data cache. This is an expert setting; decreasing the value too much will increase overhead of loading field data; too much memory used for field data cache will decrease amount of heap available for other operations.
IndicesFielddataCacheSize *int64 `json:"indices_fielddata_cache_size,omitempty"`
// +kubebuilder:validation:Minimum=64
// +kubebuilder:validation:Maximum=4096
// indices.query.bool.max_clause_count Maximum number of clauses Lucene BooleanQuery can have. The default value (1024) is relatively high, and increasing it may cause performance issues. Investigate other approaches first before increasing this value.
IndicesQueryBoolMaxClauseCount *int64 `json:"indices_query_bool_max_clause_count,omitempty"`
// +kubebuilder:validation:Minimum=10
// +kubebuilder:validation:Maximum=2000
// get thread pool queue size for the thread pool queue. See documentation for exact details.
ThreadPoolGetQueueSize *int64 `json:"thread_pool_get_queue_size,omitempty"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=128
// index thread pool size for the thread pool. See documentation for exact details. Do note this may have maximum value depending on CPU count - value is automatically lowered if set to higher than maximum value.
ThreadPoolIndexSize *int64 `json:"thread_pool_index_size,omitempty"`
// +kubebuilder:validation:Minimum=10
// +kubebuilder:validation:Maximum=2000
// search thread pool queue size for the thread pool queue. See documentation for exact details.
ThreadPoolSearchQueueSize *int64 `json:"thread_pool_search_queue_size,omitempty"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=128
// write thread pool size for the thread pool. See documentation for exact details. Do note this may have maximum value depending on CPU count - value is automatically lowered if set to higher than maximum value.
ThreadPoolWriteSize *int64 `json:"thread_pool_write_size,omitempty"`
// +kubebuilder:validation:Minimum=1024
// +kubebuilder:validation:Maximum=262144
// http.max_header_size The max size of allowed headers, in bytes
HttpMaxHeaderSize *int64 `json:"http_max_header_size,omitempty"`
// +kubebuilder:validation:Minimum=3
// +kubebuilder:validation:Maximum=40
// indices.memory.index_buffer_size Percentage value. Default is 10%. Total amount of heap used for indexing buffer, before writing segments to disk. This is an expert setting. Too low value will slow down indexing; too high value will increase indexing performance but causes performance issues for query performance.
IndicesMemoryIndexBufferSize *int64 `json:"indices_memory_index_buffer_size,omitempty"`
// +kubebuilder:validation:Minimum=3
// +kubebuilder:validation:Maximum=40
// indices.queries.cache.size Percentage value. Default is 10%. Maximum amount of heap used for query cache. This is an expert setting. Too low value will decrease query performance and increase performance for other operations; too high value will cause issues with other OpenSearch functionality.
IndicesQueriesCacheSize *int64 `json:"indices_queries_cache_size,omitempty"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=128
// search thread pool size for the thread pool. See documentation for exact details. Do note this may have maximum value depending on CPU count - value is automatically lowered if set to higher than maximum value.
ThreadPoolSearchSize *int64 `json:"thread_pool_search_size,omitempty"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=128
// search_throttled thread pool size for the thread pool. See documentation for exact details. Do note this may have maximum value depending on CPU count - value is automatically lowered if set to higher than maximum value.
ThreadPoolSearchThrottledSize *int64 `json:"thread_pool_search_throttled_size,omitempty"`
// +kubebuilder:validation:Minimum=1024
// +kubebuilder:validation:Maximum=65536
// http.max_initial_line_length The max length of an HTTP URL, in bytes
HttpMaxInitialLineLength *int64 `json:"http_max_initial_line_length,omitempty"`
// Require explicit index names when deleting
ActionDestructiveRequiresName *bool `json:"action_destructive_requires_name,omitempty"`
// +kubebuilder:validation:Minimum=100
// +kubebuilder:validation:Maximum=10000
// cluster.max_shards_per_node Controls the number of shards allowed in the cluster per data node
ClusterMaxShardsPerNode *int64 `json:"cluster_max_shards_per_node,omitempty"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=2147483647
// http.max_content_length Maximum content length for HTTP requests to the OpenSearch HTTP API, in bytes.
HttpMaxContentLength *int64 `json:"http_max_content_length,omitempty"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=20000
// search.max_buckets Maximum number of aggregation buckets allowed in a single response. OpenSearch default value is used when this is not defined.
SearchMaxBuckets *int64 `json:"search_max_buckets,omitempty"`
// action.auto_create_index Explicitly allow or block automatic creation of indices. Defaults to true
ActionAutoCreateIndexEnabled *bool `json:"action_auto_create_index_enabled,omitempty"`
}
func (*OpenSearchUserConfigOpenSearch) DeepCopy ¶ added in v0.3.0
func (in *OpenSearchUserConfigOpenSearch) DeepCopy() *OpenSearchUserConfigOpenSearch
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OpenSearchUserConfigOpenSearch.
func (*OpenSearchUserConfigOpenSearch) DeepCopyInto ¶ added in v0.3.0
func (in *OpenSearchUserConfigOpenSearch) DeepCopyInto(out *OpenSearchUserConfigOpenSearch)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type OpensearchDashboards ¶ added in v0.3.0
type OpensearchDashboards struct {
// Enable or disable OpenSearch Dashboards
Enabled *bool `json:"enabled,omitempty"`
// +kubebuilder:validation:Minimum=64
// +kubebuilder:validation:Maximum=1024
// max_old_space_size Limits the maximum amount of memory (in MiB) the OpenSearch Dashboards process can use. This sets the max_old_space_size option of the nodejs running the OpenSearch Dashboards. Note: the memory reserved by OpenSearch Dashboards is not available for OpenSearch.
MaxOldSpaceSize *int64 `json:"max_old_space_size,omitempty"`
// +kubebuilder:validation:Minimum=5000
// +kubebuilder:validation:Maximum=120000
// Timeout in milliseconds for requests made by OpenSearch Dashboards towards OpenSearch
OpensearchRequestTimeout *int64 `json:"opensearch_request_timeout,omitempty"`
}
func (*OpensearchDashboards) DeepCopy ¶ added in v0.3.0
func (in *OpensearchDashboards) DeepCopy() *OpensearchDashboards
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OpensearchDashboards.
func (*OpensearchDashboards) DeepCopyInto ¶ added in v0.3.0
func (in *OpensearchDashboards) DeepCopyInto(out *OpensearchDashboards)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PgLookoutUserConfig ¶
type PgLookoutUserConfig struct {
// +kubebuilder:validation:Minimum=10
// max_failover_replication_time_lag Number of seconds of master unavailability before triggering database failover to standby
MaxFailoverReplicationTimeLag *int64 `json:"max_failover_replication_time_lag,omitempty"`
}
func (*PgLookoutUserConfig) DeepCopy ¶
func (in *PgLookoutUserConfig) DeepCopy() *PgLookoutUserConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PgLookoutUserConfig.
func (*PgLookoutUserConfig) DeepCopyInto ¶
func (in *PgLookoutUserConfig) DeepCopyInto(out *PgLookoutUserConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PgbouncerUserConfig ¶
type PgbouncerUserConfig struct {
// List of parameters to ignore when given in startup packet
IgnoreStartupParameters []string `json:"ignore_startup_parameters,omitempty"`
// Run server_reset_query (DISCARD ALL) in all pooling modes
ServerResetQueryAlways *bool `json:"server_reset_query_always,omitempty"`
}
func (*PgbouncerUserConfig) DeepCopy ¶
func (in *PgbouncerUserConfig) DeepCopy() *PgbouncerUserConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PgbouncerUserConfig.
func (*PgbouncerUserConfig) DeepCopyInto ¶
func (in *PgbouncerUserConfig) DeepCopyInto(out *PgbouncerUserConfig)
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 +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 (pg PostgreSQL) AuthSecretRef() AuthSecretReference
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 (r *PostgreSQL) Default()
Default implements webhook.Defaulter so a webhook will be registered for the type
func (*PostgreSQL) SetupWebhookWithManager ¶
func (r *PostgreSQL) SetupWebhookWithManager(mgr ctrl.Manager) error
func (*PostgreSQL) ValidateCreate ¶
func (r *PostgreSQL) ValidateCreate() error
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*PostgreSQL) ValidateDelete ¶
func (r *PostgreSQL) ValidateDelete() error
ValidateDelete implements webhook.Validator so a webhook will be registered for the type
func (*PostgreSQL) ValidateUpdate ¶
func (r *PostgreSQL) ValidateUpdate(old 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"`
// +kubebuilder:validation:Format="^[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.
DiskSpace string `json:"disk_space,omitempty"`
// Authentication reference to Aiven token in a secret
AuthSecretRef AuthSecretReference `json:"authSecretRef"`
// Information regarding secret creation
ConnInfoSecretTarget ConnInfoSecretTarget `json:"connInfoSecretTarget,omitempty"`
// PostgreSQL specific user configuration options
UserConfig PostgreSQLUserconfig `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 PostgreSQLSubUserConfig ¶
type PostgreSQLSubUserConfig struct {
// +kubebuilder:validation:Maximum=86400000
// log_min_duration_statement Log statements that take more than this number of milliseconds to run, -1 disables
LogMinDurationStatement *int64 `json:"log_min_duration_statement,omitempty"`
// +kubebuilder:validation:Minimum=8
// +kubebuilder:validation:Maximum=64
// max_replication_slots PostgreSQL maximum replication slots
MaxReplicationSlots *int64 `json:"max_replication_slots,omitempty"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=43200000
// max_standby_streaming_delay Max standby streaming delay in milliseconds
MaxStandbyStreamingDelay *int64 `json:"max_standby_streaming_delay,omitempty"`
// +kubebuilder:validation:Minimum=3600
// +kubebuilder:validation:Maximum=604800
// pg_partman_bgw.interval Sets the time interval to run pg_partman's scheduled tasks
PgPartmanBgwInterval *int64 `json:"pg_partman_bgw.interval,omitempty"`
// +kubebuilder:validation:Enum=all;top;none
// pg_stat_statements.track Controls which statements are counted. Specify top to track top-level statements (those issued directly by clients), all to also track nested statements (such as statements invoked within functions), or none to disable statement statistics collection. The default value is top.
PgStatStatementsTrack string `json:"pg_stat_statements.track,omitempty"`
// +kubebuilder:validation:Minimum=0
// +kubebuilder:validation:Maximum=2147483647
// autovacuum_vacuum_threshold Specifies the minimum number of updated or deleted tuples needed to trigger a VACUUM in any one table. The default is 50 tuples
AutovacuumVacuumThreshold *int64 `json:"autovacuum_vacuum_threshold,omitempty"`
// jit Controls system-wide use of Just-in-Time Compilation (JIT).
Jit *bool `json:"jit,omitempty"`
// +kubebuilder:validation:Minimum=0
// +kubebuilder:validation:Maximum=10000
// max_prepared_transactions PostgreSQL maximum prepared transactions
MaxPreparedTransactions *int64 `json:"max_prepared_transactions,omitempty"`
// +kubebuilder:validation:Minimum=200000000
// +kubebuilder:validation:Maximum=1500000000
// autovacuum_freeze_max_age Specifies the maximum age (in transactions) that a table's pg_class.relfrozenxid field can attain before a VACUUM operation is forced to prevent transaction ID wraparound within the table. Note that the system will launch autovacuum processes to prevent wraparound even when autovacuum is otherwise disabled. This parameter will cause the server to be restarted.
AutovacuumFreezeMaxAge *int64 `json:"autovacuum_freeze_max_age,omitempty"`
// +kubebuilder:validation:Minimum=0
// +kubebuilder:validation:Maximum=604800000
// idle_in_transaction_session_timeout Time out sessions with open transactions after this number of milliseconds
IdleInTransactionSessionTimeout *int64 `json:"idle_in_transaction_session_timeout,omitempty"`
// +kubebuilder:validation:Minimum=5000
// +kubebuilder:validation:Maximum=600000
// wal_sender_timeout Terminate replication connections that are inactive for longer than this amount of time, in milliseconds.
WalSenderTimeout *int64 `json:"wal_sender_timeout,omitempty"`
// +kubebuilder:validation:Minimum=64
// +kubebuilder:validation:Maximum=640
// max_pred_locks_per_transaction PostgreSQL maximum predicate locks per transaction
MaxPredLocksPerTransaction *int64 `json:"max_pred_locks_per_transaction,omitempty"`
// +kubebuilder:validation:MaxLength=64
// timezone PostgreSQL service timezone
Timezone string `json:"timezone,omitempty"`
// +kubebuilder:validation:Minimum=8
// +kubebuilder:validation:Maximum=64
// max_wal_senders PostgreSQL maximum WAL senders
MaxWalSenders *int64 `json:"max_wal_senders,omitempty"`
// +kubebuilder:validation:Minimum=1024
// +kubebuilder:validation:Maximum=10240
// track_activity_query_size Specifies the number of bytes reserved to track the currently executing command for each active session.
TrackActivityQuerySize *int64 `json:"track_activity_query_size,omitempty"`
// +kubebuilder:validation:Minimum=1000
// +kubebuilder:validation:Maximum=4096
// max_files_per_process PostgreSQL maximum number of files that can be open per process
MaxFilesPerProcess *int64 `json:"max_files_per_process,omitempty"`
// +kubebuilder:validation:Minimum=0
// +kubebuilder:validation:Maximum=96
// max_parallel_workers_per_gather Sets the maximum number of workers that can be started by a single Gather or Gather Merge node
MaxParallelWorkersPerGather *int64 `json:"max_parallel_workers_per_gather,omitempty"`
// +kubebuilder:validation:Minimum=0
// +kubebuilder:validation:Maximum=1
// autovacuum_vacuum_scale_factor Specifies a fraction of the table size to add to autovacuum_vacuum_threshold when deciding whether to trigger a VACUUM. The default is 0.2 (20% of table size)
AutovacuumVacuumScaleFactor *int64 `json:"autovacuum_vacuum_scale_factor,omitempty"`
// +kubebuilder:validation:Maximum=2147483647
// log_autovacuum_min_duration Causes each action executed by autovacuum to be logged if it ran for at least the specified number of milliseconds. Setting this to zero logs all autovacuum actions. Minus-one (the default) disables logging autovacuum actions.
LogAutovacuumMinDuration *int64 `json:"log_autovacuum_min_duration,omitempty"`
// +kubebuilder:validation:Minimum=64
// +kubebuilder:validation:Maximum=640
// max_locks_per_transaction PostgreSQL maximum locks per transaction
MaxLocksPerTransaction *int64 `json:"max_locks_per_transaction,omitempty"`
// +kubebuilder:validation:Minimum=2097152
// +kubebuilder:validation:Maximum=6291456
// max_stack_depth Maximum depth of the stack in bytes
MaxStackDepth *int64 `json:"max_stack_depth,omitempty"`
// +kubebuilder:validation:Minimum=8
// +kubebuilder:validation:Maximum=96
// max_worker_processes Sets the maximum number of background processes that the system can support
MaxWorkerProcesses *int64 `json:"max_worker_processes,omitempty"`
// +kubebuilder:validation:Format="^[_A-Za-z0-9][-._A-Za-z0-9]{0,63}$"
// +kubebuilder:validation:MaxLength=64
// pg_partman_bgw.role Controls which role to use for pg_partman's scheduled background tasks.
PgPartmanBgwRole string `json:"pg_partman_bgw.role,omitempty"`
// +kubebuilder:validation:Minimum=0
// +kubebuilder:validation:Maximum=1
// autovacuum_analyze_scale_factor Specifies a fraction of the table size to add to autovacuum_analyze_threshold when deciding whether to trigger an ANALYZE. The default is 0.2 (20% of table size)
AutovacuumAnalyzeScaleFactor *int64 `json:"autovacuum_analyze_scale_factor,omitempty"`
// +kubebuilder:validation:Maximum=10000
// autovacuum_vacuum_cost_limit Specifies the cost limit value that will be used in automatic VACUUM operations. If -1 is specified (which is the default), the regular vacuum_cost_limit value will be used.
AutovacuumVacuumCostLimit *int64 `json:"autovacuum_vacuum_cost_limit,omitempty"`
// +kubebuilder:validation:Maximum=2147483647
// temp_file_limit PostgreSQL temporary file limit in KiB, -1 for unlimited
TempFileLimit *int64 `json:"temp_file_limit,omitempty"`
// +kubebuilder:validation:Enum=all;pl;none
// track_functions Enables tracking of function call counts and time used.
TrackFunctions string `json:"track_functions,omitempty"`
// +kubebuilder:validation:Minimum=0
// +kubebuilder:validation:Maximum=96
// max_parallel_workers Sets the maximum number of workers that the system can support for parallel queries
MaxParallelWorkers *int64 `json:"max_parallel_workers,omitempty"`
// +kubebuilder:validation:Enum=off;on
// track_commit_timestamp Record commit time of transactions.
TrackCommitTimestamp string `json:"track_commit_timestamp,omitempty"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=43200000
// max_standby_archive_delay Max standby archive delay in milliseconds
MaxStandbyArchiveDelay *int64 `json:"max_standby_archive_delay,omitempty"`
// +kubebuilder:validation:Minimum=10
// +kubebuilder:validation:Maximum=200
// wal_writer_delay WAL flush interval in milliseconds. Note that setting this value to lower than the default 200ms may negatively impact performance
WalWriterDelay *int64 `json:"wal_writer_delay,omitempty"`
// +kubebuilder:validation:Minimum=0
// +kubebuilder:validation:Maximum=2147483647
// autovacuum_analyze_threshold Specifies the minimum number of inserted, updated or deleted tuples needed to trigger an ANALYZE in any one table. The default is 50 tuples.
AutovacuumAnalyzeThreshold *int64 `json:"autovacuum_analyze_threshold,omitempty"`
// +kubebuilder:validation:Minimum=0
// +kubebuilder:validation:Maximum=86400
// autovacuum_naptime Specifies the minimum delay between autovacuum runs on any given database. The delay is measured in seconds, and the default is one minute
AutovacuumNaptime *int64 `json:"autovacuum_naptime,omitempty"`
// +kubebuilder:validation:Minimum=500
// +kubebuilder:validation:Maximum=1800000
// deadlock_timeout This is the amount of time, in milliseconds, to wait on a lock before checking to see if there is a deadlock condition.
DeadlockTimeout *int64 `json:"deadlock_timeout,omitempty"`
// +kubebuilder:validation:Enum=TERSE;DEFAULT;VERBOSE
// log_error_verbosity Controls the amount of detail written in the server log for each message that is logged.
LogErrorVerbosity string `json:"log_error_verbosity,omitempty"`
// +kubebuilder:validation:Minimum=4
// +kubebuilder:validation:Maximum=64
// max_logical_replication_workers PostgreSQL maximum logical replication workers (taken from the pool of max_parallel_workers)
MaxLogicalReplicationWorkers *int64 `json:"max_logical_replication_workers,omitempty"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=20
// autovacuum_max_workers Specifies the maximum number of autovacuum processes (other than the autovacuum launcher) that may be running at any one time. The default is three. This parameter can only be set at server start.
AutovacuumMaxWorkers *int64 `json:"autovacuum_max_workers,omitempty"`
// +kubebuilder:validation:Maximum=100
// autovacuum_vacuum_cost_delay Specifies the cost delay value that will be used in automatic VACUUM operations. If -1 is specified, the regular vacuum_cost_delay value will be used. The default value is 20 milliseconds
AutovacuumVacuumCostDelay *int64 `json:"autovacuum_vacuum_cost_delay,omitempty"`
}
func (*PostgreSQLSubUserConfig) DeepCopy ¶
func (in *PostgreSQLSubUserConfig) DeepCopy() *PostgreSQLSubUserConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PostgreSQLSubUserConfig.
func (*PostgreSQLSubUserConfig) DeepCopyInto ¶
func (in *PostgreSQLSubUserConfig) DeepCopyInto(out *PostgreSQLSubUserConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PostgreSQLUserconfig ¶
type PostgreSQLUserconfig struct {
// PostgreSQL major version
PgVersion string `json:"pg_version,omitempty"`
// +kubebuilder:validation:Minimum=0
// +kubebuilder:validation:Maximum=59
// The minute of an hour when backup for the service is started. New backup is only started if previous backup has already completed.
BackupMinute *int64 `json:"backup_minute,omitempty"`
// +kubebuilder:validation:MaxLength=63
// Name of the PostgreSQL Service from which to fork (deprecated, use service_to_fork_from). This has effect only when a new service is being created.
PgServiceToForkFrom string `json:"pg_service_to_fork_from,omitempty"`
// +kubebuilder:validation:Minimum=0
// +kubebuilder:validation:Maximum=23
// The hour of day (in UTC) when backup for the service is started. New backup is only started if previous backup has already completed.
BackupHour *int64 `json:"backup_hour,omitempty"`
// PGLookout settings
Pglookout PgLookoutUserConfig `json:"pglookout,omitempty"`
// +kubebuilder:validation:Maximum=60
// shared_buffers_percentage Percentage of total RAM that the database server uses for shared memory buffers. Valid range is 20-60 (float), which corresponds to 20% - 60%. This setting adjusts the shared_buffers configuration value. The absolute maximum is 12 GB.
SharedBuffersPercentage *int64 `json:"shared_buffers_percentage,omitempty"`
// +kubebuilder:validation:Enum=quorum;off
// Synchronous replication type. Note that the service plan also needs to support synchronous replication.
SynchronousReplication string `json:"synchronous_replication,omitempty"`
// TimescaleDB extension configuration values
Timescaledb TimescaledbUserConfig `json:"timescaledb,omitempty"`
// +kubebuilder:validation:Format="^[a-zA-Z0-9-_]+$"
// +kubebuilder:validation:MaxLength=256
// Custom password for admin user. Defaults to random string. This must be set only when a new service is being created.
AdminPassword string `json:"admin_password,omitempty"`
// IP filter Allow incoming connections from CIDR address block, e.g. '10.20.0.0/16'
IPFilter []string `json:"ip_filter,omitempty"`
// PGBouncer connection pooling settings
Pgbouncer PgbouncerUserConfig `json:"pgbouncer,omitempty"`
// +kubebuilder:validation:MaxLength=32
// Recovery target time when forking a service. This has effect only when a new service is being created.
RecoveryTargetTime string `json:"recovery_target_time,omitempty"`
// +kubebuilder:validation:Format="^[_A-Za-z0-9][-._A-Za-z0-9]{0,63}$"
// +kubebuilder:validation:MaxLength=64
// Custom username for admin user. This must be set only when a new service is being created.
AdminUsername string `json:"admin_username,omitempty"`
// Migrate data from existing server
Migration MigrationUserConfig `json:"migration,omitempty"`
// Allow access to selected service ports from private networks
PrivateAccess PrivateAccessUserConfig `json:"private_access,omitempty"`
// Allow access to selected service ports from the public Internet
PublicAccess PublicAccessUserConfig `json:"public_access,omitempty"`
// +kubebuilder:validation:MaxLength=63
// Name of another service to fork from. This has effect only when a new service is being created.
ServiceToForkFrom string `json:"service_to_fork_from,omitempty"`
// +kubebuilder:validation:Enum=aiven;timescale
// Variant of the PostgreSQL service, may affect the features that are exposed by default
Variant string `json:"variant,omitempty"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=1024
// work_mem Sets the maximum amount of memory to be used by a query operation (such as a sort or hash table) before writing to temporary disk files, in MB. Default is 1MB + 0.075% of total RAM (up to 32MB).
WorkMem *int64 `json:"work_mem,omitempty"`
// postgresql.conf configuration values
Pg PostgreSQLSubUserConfig `json:"pg,omitempty"`
}
func (*PostgreSQLUserconfig) DeepCopy ¶
func (in *PostgreSQLUserconfig) DeepCopy() *PostgreSQLUserconfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PostgreSQLUserconfig.
func (*PostgreSQLUserconfig) DeepCopyInto ¶
func (in *PostgreSQLUserconfig) DeepCopyInto(out *PostgreSQLUserconfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PrivateAccessUserConfig ¶
type PrivateAccessUserConfig struct {
// Allow clients to connect to pg with a DNS name that always resolves to the service's private IP addresses. Only available in certain network locations
Pg *bool `json:"pg,omitempty"`
// Allow clients to connect to pgbouncer with a DNS name that always resolves to the service's private IP addresses. Only available in certain network locations
Pgbouncer *bool `json:"pgbouncer,omitempty"`
// Allow clients to connect to prometheus with a DNS name that always resolves to the service's private IP addresses. Only available in certain network locations
Prometheus *bool `json:"prometheus,omitempty"`
}
func (*PrivateAccessUserConfig) DeepCopy ¶
func (in *PrivateAccessUserConfig) DeepCopy() *PrivateAccessUserConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PrivateAccessUserConfig.
func (*PrivateAccessUserConfig) DeepCopyInto ¶
func (in *PrivateAccessUserConfig) DeepCopyInto(out *PrivateAccessUserConfig)
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 +kubebuilder:subresource:status
func (Project) AuthSecretRef ¶
func (proj Project) AuthSecretRef() AuthSecretReference
func (*Project) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Project.
func (*Project) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Project) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Project) Default ¶
func (r *Project) Default()
Default implements webhook.Defaulter so a webhook will be registered for the type
func (*Project) SetupWebhookWithManager ¶
func (*Project) ValidateCreate ¶
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*Project) ValidateDelete ¶
ValidateDelete implements webhook.Validator so a webhook will be registered for the type
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 {
// +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 string `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
// 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
// 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"`
// Information regarding secret creation
ConnInfoSecretTarget ConnInfoSecretTarget `json:"connInfoSecretTarget,omitempty"`
// Tags are key-value pairs that allow you to categorize projects
Tags map[string]string `json:"tags,omitempty"`
// Authentication reference to Aiven token in a secret
AuthSecretRef AuthSecretReference `json:"authSecretRef"`
}
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 (ProjectVPC) AuthSecretRef ¶
func (pvpc ProjectVPC) AuthSecretRef() AuthSecretReference
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) Default ¶
func (r *ProjectVPC) Default()
Default implements webhook.Defaulter so a webhook will be registered for the type
func (*ProjectVPC) SetupWebhookWithManager ¶
func (r *ProjectVPC) SetupWebhookWithManager(mgr ctrl.Manager) error
func (*ProjectVPC) ValidateCreate ¶
func (r *ProjectVPC) ValidateCreate() error
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*ProjectVPC) ValidateDelete ¶
func (r *ProjectVPC) ValidateDelete() error
ValidateDelete implements webhook.Validator so a webhook will be registered for the type
func (*ProjectVPC) ValidateUpdate ¶
func (r *ProjectVPC) ValidateUpdate(old runtime.Object) error
ValidateUpdate implements webhook.Validator so a webhook will be registered for the type
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 {
// +kubebuilder:validation:MaxLength=63
// +kubebuilder:validation:Format="^[a-zA-Z0-9_-]*$"
// The project the VPC belongs to
Project string `json:"project"`
// +kubebuilder:validation:MaxLength=256
// Cloud the VPC is in
CloudName string `json:"cloudName"`
// +kubebuilder:validation:MaxLength=36
// Network address range used by the VPC like 192.168.0.0/24
NetworkCidr string `json:"networkCidr"`
// Authentication reference to Aiven token in a secret
AuthSecretRef AuthSecretReference `json:"authSecretRef"`
}
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 string `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 PublicAccessUserConfig ¶
type PublicAccessUserConfig struct {
// Allow clients to connect to pg from the public internet for service nodes that are in a project VPC or another type of private network
Pg *bool `json:"pg,omitempty"`
// Allow clients to connect to pgbouncer from the public internet for service nodes that are in a project VPC or another type of private network
Pgbouncer *bool `json:"pgbouncer,omitempty"`
// Allow clients to connect to prometheus from the public internet for service nodes that are in a project VPC or another type of private network
Prometheus *bool `json:"prometheus,omitempty"`
}
func (*PublicAccessUserConfig) DeepCopy ¶
func (in *PublicAccessUserConfig) DeepCopy() *PublicAccessUserConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PublicAccessUserConfig.
func (*PublicAccessUserConfig) DeepCopyInto ¶
func (in *PublicAccessUserConfig) DeepCopyInto(out *PublicAccessUserConfig)
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 +kubebuilder:subresource:status
func (Redis) AuthSecretRef ¶ added in v0.2.0
func (r Redis) AuthSecretRef() AuthSecretReference
func (*Redis) DeepCopy ¶ added in v0.2.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Redis.
func (*Redis) DeepCopyInto ¶ added in v0.2.0
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
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Redis) Default ¶ added in v0.2.0
func (r *Redis) Default()
Default implements webhook.Defaulter so a webhook will be registered for the type
func (*Redis) SetupWebhookWithManager ¶ added in v0.2.0
func (*Redis) ValidateCreate ¶ added in v0.2.0
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*Redis) ValidateDelete ¶ added in v0.2.0
ValidateDelete 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
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RedisList.
func (*RedisList) DeepCopyInto ¶ added in v0.2.0
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
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type RedisMigration ¶ added in v0.2.0
type RedisMigration struct {
// +kubebuilder:validation:MaxLength=2048
// Comma-separated list of databases, which should be ignored during migration (supported by MySQL only at the moment)
IgnoreDbs string `json:"ignore_dbs,omitempty"`
// +kubebuilder:validation:MaxLength=256
// Password for authentication with the server where to migrate data from
Password string `json:"password,omitempty"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=65535
// Port number of the server where to migrate data from
Port *int64 `json:"port,omitempty"`
// The server where to migrate data from is secured with SSL
Ssl *bool `json:"ssl,omitempty"`
// +kubebuilder:validation:MaxLength=256
// User name for authentication with the server where to migrate data from
Username string `json:"username,omitempty"`
// +kubebuilder:validation:MaxLength=63
// Database name for bootstrapping the initial connection
Dbname string `json:"dbname,omitempty"`
// +kubebuilder:validation:MaxLength=255
// Hostname or IP address of the server where to migrate data from
Host string `json:"host,omitempty"`
}
func (*RedisMigration) DeepCopy ¶ added in v0.2.0
func (in *RedisMigration) DeepCopy() *RedisMigration
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RedisMigration.
func (*RedisMigration) DeepCopyInto ¶ added in v0.2.0
func (in *RedisMigration) DeepCopyInto(out *RedisMigration)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RedisPrivateAccess ¶ added in v0.2.0
type RedisPrivateAccess struct {
// Allow clients to connect to prometheus with a DNS name that always resolves to the service's private IP addresses. Only available in certain network locations
Prometheus *bool `json:"prometheus,omitempty"`
// Allow clients to connect to redis with a DNS name that always resolves to the service's private IP addresses. Only available in certain network locations
Redis *bool `json:"redis,omitempty"`
}
func (*RedisPrivateAccess) DeepCopy ¶ added in v0.2.0
func (in *RedisPrivateAccess) DeepCopy() *RedisPrivateAccess
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RedisPrivateAccess.
func (*RedisPrivateAccess) DeepCopyInto ¶ added in v0.2.0
func (in *RedisPrivateAccess) DeepCopyInto(out *RedisPrivateAccess)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RedisPrivatelinkAccess ¶ added in v0.2.0
type RedisPrivatelinkAccess struct {
// Enable redis
Redis *bool `json:"redis,omitempty"`
}
func (*RedisPrivatelinkAccess) DeepCopy ¶ added in v0.2.0
func (in *RedisPrivatelinkAccess) DeepCopy() *RedisPrivatelinkAccess
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RedisPrivatelinkAccess.
func (*RedisPrivatelinkAccess) DeepCopyInto ¶ added in v0.2.0
func (in *RedisPrivatelinkAccess) DeepCopyInto(out *RedisPrivatelinkAccess)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RedisPublicAccess ¶ added in v0.2.0
type RedisPublicAccess struct {
// Allow clients to connect to prometheus from the public internet for service nodes that are in a project VPC or another type of private network
Prometheus *bool `json:"prometheus,omitempty"`
// Allow clients to connect to redis from the public internet for service nodes that are in a project VPC or another type of private network
Redis *bool `json:"redis,omitempty"`
}
func (*RedisPublicAccess) DeepCopy ¶ added in v0.2.0
func (in *RedisPublicAccess) DeepCopy() *RedisPublicAccess
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RedisPublicAccess.
func (*RedisPublicAccess) DeepCopyInto ¶ added in v0.2.0
func (in *RedisPublicAccess) DeepCopyInto(out *RedisPublicAccess)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RedisSpec ¶ added in v0.2.0
type RedisSpec struct {
ServiceCommonSpec `json:",inline"`
// 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.
DiskSpace string `json:"disk_space,omitempty"`
// Authentication reference to Aiven token in a secret
AuthSecretRef AuthSecretReference `json:"authSecretRef"`
// Information regarding secret creation
ConnInfoSecretTarget ConnInfoSecretTarget `json:"connInfoSecretTarget,omitempty"`
// Redis specific user configuration options
UserConfig RedisUserConfig `json:"userConfig,omitempty"`
}
RedisSpec defines the desired state of Redis
func (*RedisSpec) DeepCopy ¶ added in v0.2.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RedisSpec.
func (*RedisSpec) DeepCopyInto ¶ added in v0.2.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RedisUserConfig ¶ added in v0.2.0
type RedisUserConfig struct {
// Migrate data from existing server
Migration RedisMigration `json:"migration,omitempty"`
// Allow access to selected service ports from the public internet
PublicAccess RedisPublicAccess `json:"public_access,omitempty"`
// Allow access to selected service ports from private networks
PrivateAccess RedisPrivateAccess `json:"private_access,omitempty"`
// Allow access to selected service components through Privatelink
PrivatelinkAccess RedisPrivatelinkAccess `json:"privatelink_access,omitempty"`
// +kubebuilder:validation:MaxLength=63
// Name of another service to fork from. This has effect only when a new service is being created.
ServiceToForkFrom string `json:"service_to_fork_from,omitempty"`
// IP filter Allow incoming connections from CIDR address block, e.g. '10.20.0.0/16'
IPFilter []string `json:"ip_filter,omitempty"`
// +kubebuilder:validation:MaxLength=63
// Name of another project to fork a service from. This has effect only when a new service is being created.
ProjectToForkFrom string `json:"project_to_fork_from,omitempty"`
// +kubebuilder:validation:Enum=allchannels;resetchannels
// Default ACL for pub/sub channels used when Redis user is created Determines default pub/sub channels' ACL for new users if ACL is not supplied. When this option is not defined, all_channels is assumed to keep backward compatibility. This option doesn't affect Redis configuration acl-pubsub-default.
RedisAclChannelsDefault string `json:"redis_acl_channels_default,omitempty"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=120
// LFU maxmemory-policy counter decay time in minutes
RedisLfuDecayTime *int64 `json:"redis_lfu_decay_time,omitempty"`
// +kubebuilder:validation:Minimum=0
// +kubebuilder:validation:Maximum=100
// Counter logarithm factor for volatile-lfu and allkeys-lfu maxmemory-policies
RedisLfuLogFactor *int64 `json:"redis_lfu_log_factor,omitempty"`
// +kubebuilder:validation:Enum=off;rdb
// Redis persistence When persistence is 'rdb', Redis does RDB dumps each 10 minutes if any key is changed. Also RDB dumps are done according to backup schedule for backup purposes. When persistence is 'off', no RDB dumps and backups are done, so data can be lost at any moment if service is restarted for any reason, or if service is powered off. Also service can't be forked.
RedisPersistence string `json:"redis_persistence,omitempty"`
// +kubebuilder:validation:Minimum=32
// +kubebuilder:validation:Maximum=512
// Pub/sub client output buffer hard limit in MB Set output buffer limit for pub / sub clients in MB. The value is the hard limit, the soft limit is 1/4 of the hard limit. When setting the limit, be mindful of the available memory in the selected service plan.
RedisPubsubClientOutputBufferLimit *int64 `json:"redis_pubsub_client_output_buffer_limit,omitempty"`
// Static IP addresses Use static public IP addresses
StaticIps *bool `json:"static_ips,omitempty"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=32
// Redis IO thread count
RedisIoThreads *int64 `json:"redis_io_threads,omitempty"`
// +kubebuilder:validation:Minimum=0
// +kubebuilder:validation:Maximum=31536000
// Redis idle connection timeout
RedisTimeout *int64 `json:"redis_timeout,omitempty"`
// +kubebuilder:validation:Format="^[a-zA-Z0-9-_:.]+$"
// +kubebuilder:validation:MaxLength=128
// Name of the basebackup to restore in forked service
RecoveryBasebackupName string `json:"recovery_basebackup_name,omitempty"`
// +kubebuilder:validation:Enum=noeviction;allkeys-lru;volatile-lru;allkeys-random;volatile-random;volatile-ttl;volatile-lfu;allkeys-lfu
// Redis maxmemory-policy
RedisMaxmemoryPolicy string `json:"redis_maxmemory_policy,omitempty"`
// +kubebuilder:validation:MaxLength=32
// Set notify-keyspace-events option
RedisNotifyKeyspaceEvents string `json:"redis_notify_keyspace_events,omitempty"`
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=128
// Number of redis databases Set number of redis databases. Changing this will cause a restart of redis service.
RedisNumberOfDatabases *int64 `json:"redis_number_of_databases,omitempty"`
// Require SSL to access Redis
RedisSsl *bool `json:"redis_ssl,omitempty"`
}
func (*RedisUserConfig) DeepCopy ¶ added in v0.2.0
func (in *RedisUserConfig) DeepCopy() *RedisUserConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RedisUserConfig.
func (*RedisUserConfig) DeepCopyInto ¶ added in v0.2.0
func (in *RedisUserConfig) DeepCopyInto(out *RedisUserConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServiceCommonSpec ¶
type ServiceCommonSpec struct {
// +kubebuilder:validation:MaxLength=63
// +kubebuilder:validation:Format="^[a-zA-Z0-9_-]*$"
// Target project.
Project string `json:"project"`
// +kubebuilder:validation:MaxLength=128
// Subscription plan.
Plan string `json:"plan,omitempty"`
// +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"`
// +kubebuilder:validation:Enum=monday;tuesday;wednesday;thursday;friday;saturday;sunday;never
// Day of week when maintenance operations should be performed. One monday, tuesday, wednesday, etc.
MaintenanceWindowDow string `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"`
}
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 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 +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 (svcint ServiceIntegration) AuthSecretRef() AuthSecretReference
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 (r *ServiceIntegration) Default()
Default implements webhook.Defaulter so a webhook will be registered for the type
func (*ServiceIntegration) SetupWebhookWithManager ¶
func (r *ServiceIntegration) SetupWebhookWithManager(mgr ctrl.Manager) error
func (*ServiceIntegration) ValidateCreate ¶
func (r *ServiceIntegration) ValidateCreate() error
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*ServiceIntegration) ValidateDelete ¶
func (r *ServiceIntegration) ValidateDelete() error
ValidateDelete implements webhook.Validator so a webhook will be registered for the type
func (*ServiceIntegration) ValidateUpdate ¶
func (r *ServiceIntegration) ValidateUpdate(old runtime.Object) error
ValidateUpdate implements webhook.Validator so a webhook will be registered for the type
type ServiceIntegrationDatadogUserConfig ¶
type ServiceIntegrationDatadogUserConfig struct {
// Consumer groups to exclude
ExcludeConsumerGroups []string `json:"exclude_consumer_groups,omitempty"`
// List of topics to exclude
ExcludeTopics []string `json:"exclude_topics,omitempty"`
// Consumer groups to include
IncludeConsumerGroups []string `json:"include_consumer_groups,omitempty"`
// Topics to include
IncludeTopics []string `json:"include_topics,omitempty"`
// List of custom metrics
KafkaCustomMetrics []string `json:"kafka_custom_metrics,omitempty"`
}
func (*ServiceIntegrationDatadogUserConfig) DeepCopy ¶
func (in *ServiceIntegrationDatadogUserConfig) DeepCopy() *ServiceIntegrationDatadogUserConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceIntegrationDatadogUserConfig.
func (*ServiceIntegrationDatadogUserConfig) DeepCopyInto ¶
func (in *ServiceIntegrationDatadogUserConfig) DeepCopyInto(out *ServiceIntegrationDatadogUserConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServiceIntegrationKafkaConnect ¶
type ServiceIntegrationKafkaConnect struct {
// +kubebuilder:validation:MaxLength=249
// The name of the topic where connector and task configuration data are stored. This must be the same for all workers with the same group_id.
ConfigStorageTopic string `json:"config_storage_topic,omitempty"`
// +kubebuilder:validation:MaxLength=249
// A unique string that identifies the Connect cluster group this worker belongs to.
GroupID string `json:"group_id,omitempty"`
// +kubebuilder:validation:MaxLength=249
// The name of the topic where connector and task configuration offsets are stored. This must be the same for all workers with the same group_id.
OffsetStorageTopic string `json:"offset_storage_topic,omitempty"`
// +kubebuilder:validation:MaxLength=249
// The name of the topic where connector and task configuration status updates are stored.This must be the same for all workers with the same group_id.
StatusStorageTopic string `json:"status_storage_topic,omitempty"`
}
func (*ServiceIntegrationKafkaConnect) DeepCopy ¶
func (in *ServiceIntegrationKafkaConnect) DeepCopy() *ServiceIntegrationKafkaConnect
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceIntegrationKafkaConnect.
func (*ServiceIntegrationKafkaConnect) DeepCopyInto ¶
func (in *ServiceIntegrationKafkaConnect) DeepCopyInto(out *ServiceIntegrationKafkaConnect)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServiceIntegrationKafkaConnectUserConfig ¶
type ServiceIntegrationKafkaConnectUserConfig struct {
KafkaConnect ServiceIntegrationKafkaConnect `json:"kafka_connect,omitempty"`
}
func (*ServiceIntegrationKafkaConnectUserConfig) DeepCopy ¶
func (in *ServiceIntegrationKafkaConnectUserConfig) DeepCopy() *ServiceIntegrationKafkaConnectUserConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceIntegrationKafkaConnectUserConfig.
func (*ServiceIntegrationKafkaConnectUserConfig) DeepCopyInto ¶
func (in *ServiceIntegrationKafkaConnectUserConfig) DeepCopyInto(out *ServiceIntegrationKafkaConnectUserConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServiceIntegrationKafkaLogsUserConfig ¶
type ServiceIntegrationKafkaLogsUserConfig struct {
// +kubebuilder:validation:MaxLength=63
// +kubebuilder:validation:MinLength=1
// Topic name
KafkaTopic string `json:"kafka_topic,omitempty"`
}
func (*ServiceIntegrationKafkaLogsUserConfig) DeepCopy ¶
func (in *ServiceIntegrationKafkaLogsUserConfig) DeepCopy() *ServiceIntegrationKafkaLogsUserConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceIntegrationKafkaLogsUserConfig.
func (*ServiceIntegrationKafkaLogsUserConfig) DeepCopyInto ¶
func (in *ServiceIntegrationKafkaLogsUserConfig) DeepCopyInto(out *ServiceIntegrationKafkaLogsUserConfig)
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 ServiceIntegrationMetricsUserConfig ¶
type ServiceIntegrationMetricsUserConfig struct {
// +kubebuilder:validation:Format="^[_A-Za-z0-9][-_A-Za-z0-9]{0,39}$"
// +kubebuilder:validation:MaxLength=40
// Name of the database where to store metric datapoints. Only affects PostgreSQL destinations
Database string `json:"database,omitempty"`
// +kubebuilder:validation:Max=10000
// Number of days to keep old metrics. Only affects PostgreSQL destinations. Set to 0 for no automatic cleanup. Defaults to 30 days.
RetentionDays int `json:"retention_days,omitempty"`
// +kubebuilder:validation:Format="^[_A-Za-z0-9][-._A-Za-z0-9]{0,39}$"
// +kubebuilder:validation:MaxLength=40
// Name of a user that can be used to read metrics. This will be used for Grafana integration (if enabled) to prevent Grafana users from making undesired changes. Only affects PostgreSQL destinations. Defaults to 'metrics_reader'. Note that this must be the same for all metrics integrations that write data to the same PostgreSQL service.
RoUsername string `json:"ro_username,omitempty"`
// +kubebuilder:validation:Format="^[_A-Za-z0-9][-._A-Za-z0-9]{0,39}$"
// +kubebuilder:validation:MaxLength=40
// Name of the user used to write metrics. Only affects PostgreSQL destinations. Defaults to 'metrics_writer'. Note that this must be the same for all metrics integrations that write data to the same PostgreSQL service.
Username string `json:"username,omitempty"`
}
func (*ServiceIntegrationMetricsUserConfig) DeepCopy ¶
func (in *ServiceIntegrationMetricsUserConfig) DeepCopy() *ServiceIntegrationMetricsUserConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceIntegrationMetricsUserConfig.
func (*ServiceIntegrationMetricsUserConfig) DeepCopyInto ¶
func (in *ServiceIntegrationMetricsUserConfig) DeepCopyInto(out *ServiceIntegrationMetricsUserConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServiceIntegrationSpec ¶
type ServiceIntegrationSpec struct {
// +kubebuilder:validation:MaxLength=63
// +kubebuilder:validation:Format="^[a-zA-Z0-9_-]*$"
// Project the integration belongs to
Project string `json:"project"`
// +kubebuilder:validation:Enum=datadog;kafka_logs;kafka_connect;metrics;dashboard;rsyslog;read_replica;schema_registry_proxy;signalfx;jolokia;internal_connectivity;external_google_cloud_logging;datasource
// Type of the service integration
IntegrationType string `json:"integrationType"`
// Source endpoint for the integration (if any)
SourceEndpointID string `json:"sourceEndpointID,omitempty"`
// Source service for the integration (if any)
SourceServiceName string `json:"sourceServiceName,omitempty"`
// Destination endpoint for the integration (if any)
DestinationEndpointID string `json:"destinationEndpointId,omitempty"`
// Destination service for the integration (if any)
DestinationServiceName string `json:"destinationServiceName,omitempty"`
// Datadog specific user configuration options
DatadogUserConfig ServiceIntegrationDatadogUserConfig `json:"datadog,omitempty"`
// Kafka Connect service configuration values
KafkaConnectUserConfig ServiceIntegrationKafkaConnectUserConfig `json:"kafkaConnect,omitempty"`
// Kafka logs configuration values
KafkaLogsUserConfig ServiceIntegrationKafkaLogsUserConfig `json:"kafkaLogs,omitempty"`
// Metrics configuration values
MetricsUserConfig ServiceIntegrationMetricsUserConfig `json:"metrics,omitempty"`
// Authentication reference to Aiven token in a secret
AuthSecretRef AuthSecretReference `json:"authSecretRef"`
}
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"`
// Service state
State string `json:"state"`
}
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 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 +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 (svcusr ServiceUser) AuthSecretRef() AuthSecretReference
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 (r *ServiceUser) Default()
Default implements webhook.Defaulter so a webhook will be registered for the type
func (*ServiceUser) SetupWebhookWithManager ¶
func (r *ServiceUser) SetupWebhookWithManager(mgr ctrl.Manager) error
func (*ServiceUser) ValidateCreate ¶
func (r *ServiceUser) ValidateCreate() error
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*ServiceUser) ValidateDelete ¶
func (r *ServiceUser) ValidateDelete() error
ValidateDelete implements webhook.Validator so a webhook will be registered for the type
func (*ServiceUser) ValidateUpdate ¶
func (r *ServiceUser) ValidateUpdate(old 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 {
// +kubebuilder:validation:MaxLength=63
// +kubebuilder:validation:Format="^[a-zA-Z0-9_-]*$"
// Project to link the user to
Project string `json:"project"`
// +kubebuilder:validation:MaxLength=63
// Service to link the user to
ServiceName string `json:"serviceName"`
// +kubebuilder:validation:Enum=caching_sha2_password;mysql_native_password
// Authentication details
Authentication string `json:"authentication,omitempty"`
// Information regarding secret creation
ConnInfoSecretTarget ConnInfoSecretTarget `json:"connInfoSecretTarget,omitempty"`
// Authentication reference to Aiven token in a secret
AuthSecretRef AuthSecretReference `json:"authSecretRef"`
}
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 TimescaledbUserConfig ¶
type TimescaledbUserConfig struct {
// +kubebuilder:validation:Minimum=1
// +kubebuilder:validation:Maximum=4096
// timescaledb.max_background_workers The number of background workers for timescaledb operations. You should configure this setting to the sum of your number of databases and the total number of concurrent background workers you want running at any given point in time.
MaxBackgroundWorkers *int64 `json:"max_background_workers,omitempty"`
}
func (*TimescaledbUserConfig) DeepCopy ¶
func (in *TimescaledbUserConfig) DeepCopy() *TimescaledbUserConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TimescaledbUserConfig.
func (*TimescaledbUserConfig) DeepCopyInto ¶
func (in *TimescaledbUserConfig) DeepCopyInto(out *TimescaledbUserConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
Source Files
¶
- clickhouse_types.go
- clickhouse_webhook.go
- clickhouseuser_types.go
- clickhouseuser_webhook.go
- common.go
- connectionpool_types.go
- connectionpool_webhook.go
- database_types.go
- database_webhook.go
- doc.go
- groupversion_info.go
- kafka_types.go
- kafka_webhook.go
- kafkaacl_types.go
- kafkaacl_webhook.go
- kafkaconnect_types.go
- kafkaconnect_webhook.go
- kafkaconnector_types.go
- kafkaconnector_webhook.go
- kafkaschema_types.go
- kafkaschema_webhook.go
- kafkatopic_types.go
- kafkatopic_webhook.go
- opensearch_types.go
- opensearch_webhook.go
- postgresql_types.go
- postgresql_webhook.go
- project_types.go
- project_webhook.go
- projectvpc_types.go
- projectvpc_webhook.go
- redis_types.go
- redis_webhook.go
- serviceintegration_types.go
- serviceintegration_webhook.go
- serviceuser_types.go
- serviceuser_webhook.go
- zz_generated.deepcopy.go