Documentation ¶
Overview ¶
+kubebuilder:object:generate=true +groupName=aiven.io +versionName=v1alpha1
Index ¶
- Variables
- func ConvertDiscSpace(v string) int
- func ErrorSubstrChecker(substrings ...string) func(error) bool
- func SetupWebhooks(mgr ctrl.Manager) error
- type AuthSecretReference
- type Cassandra
- func (in *Cassandra) AuthSecretRef() *AuthSecretReference
- func (in *Cassandra) DeepCopy() *Cassandra
- func (in *Cassandra) DeepCopyInto(out *Cassandra)
- func (in *Cassandra) DeepCopyObject() runtime.Object
- func (in *Cassandra) Default()
- func (in *Cassandra) GetConnInfoSecretTarget() ConnInfoSecretTarget
- func (in *Cassandra) GetRefs() []*ResourceReferenceObject
- func (in *Cassandra) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (in *Cassandra) ValidateCreate() error
- func (in *Cassandra) ValidateDelete() error
- func (in *Cassandra) ValidateUpdate(old runtime.Object) error
- type CassandraList
- type CassandraSpec
- type Clickhouse
- func (in *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 (in *Clickhouse) GetConnInfoSecretTarget() ConnInfoSecretTarget
- func (in *Clickhouse) GetRefs() []*ResourceReferenceObject
- 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 (in *ClickhouseUser) GetConnInfoSecretTarget() ConnInfoSecretTarget
- 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 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 (in *ConnectionPool) GetConnInfoSecretTarget() ConnInfoSecretTarget
- 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 Grafana
- func (in *Grafana) AuthSecretRef() *AuthSecretReference
- func (in *Grafana) DeepCopy() *Grafana
- func (in *Grafana) DeepCopyInto(out *Grafana)
- func (in *Grafana) DeepCopyObject() runtime.Object
- func (in *Grafana) Default()
- func (in *Grafana) GetConnInfoSecretTarget() ConnInfoSecretTarget
- func (in *Grafana) GetRefs() []*ResourceReferenceObject
- func (in *Grafana) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (in *Grafana) ValidateCreate() error
- func (in *Grafana) ValidateDelete() error
- func (in *Grafana) ValidateUpdate(old runtime.Object) error
- type GrafanaList
- type GrafanaSpec
- type Kafka
- func (in *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 (in *Kafka) GetConnInfoSecretTarget() ConnInfoSecretTarget
- func (in *Kafka) GetRefs() []*ResourceReferenceObject
- 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 KafkaConnect
- func (in *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 (in *KafkaConnect) GetRefs() []*ResourceReferenceObject
- 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 KafkaConnectSpec
- 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 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 KafkaSchemaSpec
- type KafkaSchemaStatus
- type KafkaSpec
- type KafkaTopic
- func (t *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 (t *KafkaTopic) GetTopicName() string
- 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 MySQL
- func (in *MySQL) AuthSecretRef() *AuthSecretReference
- func (in *MySQL) DeepCopy() *MySQL
- func (in *MySQL) DeepCopyInto(out *MySQL)
- func (in *MySQL) DeepCopyObject() runtime.Object
- func (in *MySQL) Default()
- func (in *MySQL) GetConnInfoSecretTarget() ConnInfoSecretTarget
- func (in *MySQL) GetRefs() []*ResourceReferenceObject
- func (in *MySQL) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (in *MySQL) ValidateCreate() error
- func (in *MySQL) ValidateDelete() error
- func (in *MySQL) ValidateUpdate(old runtime.Object) error
- type MySQLList
- type MySQLSpec
- type OpenSearch
- func (in *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 (in *OpenSearch) GetConnInfoSecretTarget() ConnInfoSecretTarget
- func (in *OpenSearch) GetRefs() []*ResourceReferenceObject
- 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 OpenSearchList
- type OpenSearchSpec
- type PostgreSQL
- func (in *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 (in *PostgreSQL) GetConnInfoSecretTarget() ConnInfoSecretTarget
- func (in *PostgreSQL) GetRefs() []*ResourceReferenceObject
- 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 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 (in *Project) GetConnInfoSecretTarget() ConnInfoSecretTarget
- 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
- type ProjectVPCList
- type ProjectVPCSpec
- type ProjectVPCStatus
- type Redis
- func (in *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 (in *Redis) GetConnInfoSecretTarget() ConnInfoSecretTarget
- func (in *Redis) GetRefs() []*ResourceReferenceObject
- 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 RedisSpec
- type ResourceReference
- type ResourceReferenceObject
- type ServiceCommonSpec
- type ServiceIntegration
- func (in *ServiceIntegration) AuthSecretRef() *AuthSecretReference
- func (in *ServiceIntegration) DeepCopy() *ServiceIntegration
- func (in *ServiceIntegration) DeepCopyInto(out *ServiceIntegration)
- func (in *ServiceIntegration) DeepCopyObject() runtime.Object
- func (in *ServiceIntegration) Default()
- func (in *ServiceIntegration) GetUserConfig() (any, error)
- func (in *ServiceIntegration) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (in *ServiceIntegration) ValidateCreate() error
- func (in *ServiceIntegration) ValidateDelete() error
- func (in *ServiceIntegration) ValidateUpdate(old runtime.Object) error
- type ServiceIntegrationItem
- type ServiceIntegrationList
- 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 (in *ServiceUser) GetConnInfoSecretTarget() ConnInfoSecretTarget
- 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
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 )
var ErrDeleteDependencies = errors.New("object has dependencies and cannot be deleted")
Functions ¶
func ConvertDiscSpace ¶ added in v0.3.0
func ErrorSubstrChecker ¶ added in v0.5.0
ErrorSubstrChecker returns error checker for containing given substrings
func SetupWebhooks ¶ added in v0.11.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 Cassandra ¶ added in v0.7.0
type Cassandra struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec CassandraSpec `json:"spec,omitempty"` Status ServiceStatus `json:"status,omitempty"` }
Cassandra is the Schema for the cassandras API +kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Region",type="string",JSONPath=".spec.cloudName" +kubebuilder:printcolumn:name="Plan",type="string",JSONPath=".spec.plan" +kubebuilder:printcolumn:name="State",type="string",JSONPath=".status.state"
func (*Cassandra) AuthSecretRef ¶ added in v0.7.0
func (in *Cassandra) AuthSecretRef() *AuthSecretReference
func (*Cassandra) DeepCopy ¶ added in v0.7.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Cassandra.
func (*Cassandra) DeepCopyInto ¶ added in v0.7.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Cassandra) DeepCopyObject ¶ added in v0.7.0
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Cassandra) GetConnInfoSecretTarget ¶ added in v0.12.0
func (in *Cassandra) GetConnInfoSecretTarget() ConnInfoSecretTarget
func (*Cassandra) GetRefs ¶ added in v0.7.0
func (in *Cassandra) GetRefs() []*ResourceReferenceObject
func (*Cassandra) SetupWebhookWithManager ¶ added in v0.7.0
func (*Cassandra) ValidateCreate ¶ added in v0.7.0
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*Cassandra) ValidateDelete ¶ added in v0.7.0
ValidateDelete implements webhook.Validator so a webhook will be registered for the type
type CassandraList ¶ added in v0.7.0
type CassandraList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Cassandra `json:"items"` }
CassandraList contains a list of Cassandra
func (*CassandraList) DeepCopy ¶ added in v0.7.0
func (in *CassandraList) DeepCopy() *CassandraList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CassandraList.
func (*CassandraList) DeepCopyInto ¶ added in v0.7.0
func (in *CassandraList) DeepCopyInto(out *CassandraList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*CassandraList) DeepCopyObject ¶ added in v0.7.0
func (in *CassandraList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type CassandraSpec ¶ added in v0.7.0
type CassandraSpec struct { ServiceCommonSpec `json:",inline"` // +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,omitempty"` // Information regarding secret creation. // Exposed keys: `CASSANDRA_HOST`, `CASSANDRA_PORT`, `CASSANDRA_USER`, `CASSANDRA_PASSWORD`, `CASSANDRA_URI`, `CASSANDRA_HOSTS` ConnInfoSecretTarget ConnInfoSecretTarget `json:"connInfoSecretTarget,omitempty"` // Cassandra specific user configuration options UserConfig *cassandrauserconfig.CassandraUserConfig `json:"userConfig,omitempty"` }
CassandraSpec defines the desired state of Cassandra
func (*CassandraSpec) DeepCopy ¶ added in v0.7.0
func (in *CassandraSpec) DeepCopy() *CassandraSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CassandraSpec.
func (*CassandraSpec) DeepCopyInto ¶ added in v0.7.0
func (in *CassandraSpec) DeepCopyInto(out *CassandraSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Clickhouse ¶ added in v0.3.0
type Clickhouse struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec ClickhouseSpec `json:"spec,omitempty"` Status ServiceStatus `json:"status,omitempty"` }
Clickhouse is the Schema for the clickhouses API
func (*Clickhouse) AuthSecretRef ¶ added in v0.3.0
func (in *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) GetConnInfoSecretTarget ¶ added in v0.12.0
func (in *Clickhouse) GetConnInfoSecretTarget() ConnInfoSecretTarget
func (*Clickhouse) GetRefs ¶ added in v0.5.0
func (in *Clickhouse) GetRefs() []*ResourceReferenceObject
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"` // +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,omitempty"` // Information regarding secret creation. // Exposed keys: `CLICKHOUSE_HOST`, `CLICKHOUSE_PORT`, `CLICKHOUSE_USER`, `CLICKHOUSE_PASSWORD` ConnInfoSecretTarget ConnInfoSecretTarget `json:"connInfoSecretTarget,omitempty"` // OpenSearch specific user configuration options UserConfig *clickhouseuserconfig.ClickhouseUserConfig `json:"userConfig,omitempty"` }
ClickhouseSpec defines the desired state of Clickhouse
func (*ClickhouseSpec) DeepCopy ¶ added in v0.3.0
func (in *ClickhouseSpec) DeepCopy() *ClickhouseSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClickhouseSpec.
func (*ClickhouseSpec) DeepCopyInto ¶ added in v0.3.0
func (in *ClickhouseSpec) DeepCopyInto(out *ClickhouseSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClickhouseUser ¶ added in v0.3.0
type ClickhouseUser struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec ClickhouseUserSpec `json:"spec,omitempty"` Status ClickhouseUserStatus `json:"status,omitempty"` }
ClickhouseUser is the Schema for the clickhouseusers API +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) GetConnInfoSecretTarget ¶ added in v0.12.0
func (in *ClickhouseUser) GetConnInfoSecretTarget() ConnInfoSecretTarget
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 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_-]*$" // +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable" // Project to link the user to Project string `json:"project"` // +kubebuilder:validation:MaxLength=63 // +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable" // Service to link the user to ServiceName string `json:"serviceName"` // Information regarding secret creation. // Exposed keys: `CLICKHOUSEUSER_HOST`, `CLICKHOUSEUSER_PORT`, `CLICKHOUSEUSER_USER`, `CLICKHOUSEUSER_PASSWORD` ConnInfoSecretTarget ConnInfoSecretTarget `json:"connInfoSecretTarget,omitempty"` // Authentication reference to Aiven token in a secret AuthSecretRef *AuthSecretReference `json:"authSecretRef,omitempty"` }
ClickhouseUserSpec defines the desired state of ClickhouseUser
func (*ClickhouseUserSpec) DeepCopy ¶ added in v0.3.0
func (in *ClickhouseUserSpec) DeepCopy() *ClickhouseUserSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClickhouseUserSpec.
func (*ClickhouseUserSpec) DeepCopyInto ¶ added in v0.3.0
func (in *ClickhouseUserSpec) DeepCopyInto(out *ClickhouseUserSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClickhouseUserStatus ¶ added in v0.3.0
type ClickhouseUserStatus struct { // Clickhouse user UUID UUID string `json:"uuid"` // Conditions represent the latest available observations of an ClickhouseUser state // +kubebuilder:validation:type=array Conditions []metav1.Condition `json:"conditions"` }
ClickhouseUserStatus defines the observed state of ClickhouseUser
func (*ClickhouseUserStatus) DeepCopy ¶ added in v0.3.0
func (in *ClickhouseUserStatus) DeepCopy() *ClickhouseUserStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClickhouseUserStatus.
func (*ClickhouseUserStatus) DeepCopyInto ¶ added in v0.3.0
func (in *ClickhouseUserStatus) DeepCopyInto(out *ClickhouseUserStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConnInfoSecretTarget ¶
type ConnInfoSecretTarget struct { // Name of the secret resource to be created. By default, is equal to the resource name Name string `json:"name"` // +kubebuilder:pruning:PreserveUnknownFields // Annotations added to the secret Annotations map[string]string `json:"annotations,omitempty"` // +kubebuilder:pruning:PreserveUnknownFields // Labels added to the secret Labels map[string]string `json:"labels,omitempty"` // Prefix for the secret's keys. // Added "as is" without any transformations. // By default, is equal to the kind name in uppercase + underscore, e.g. `KAFKA_`, `REDIS_`, etc. Prefix string `json:"prefix,omitempty"` }
ConnInfoSecretTarget contains information secret name
func (*ConnInfoSecretTarget) DeepCopy ¶
func (in *ConnInfoSecretTarget) DeepCopy() *ConnInfoSecretTarget
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnInfoSecretTarget.
func (*ConnInfoSecretTarget) DeepCopyInto ¶
func (in *ConnInfoSecretTarget) DeepCopyInto(out *ConnInfoSecretTarget)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConnectionPool ¶
type ConnectionPool struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec ConnectionPoolSpec `json:"spec,omitempty"` Status ConnectionPoolStatus `json:"status,omitempty"` }
ConnectionPool is the Schema for the connectionpools API +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) GetConnInfoSecretTarget ¶ added in v0.12.0
func (in *ConnectionPool) GetConnInfoSecretTarget() ConnInfoSecretTarget
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. // Exposed keys: `CONNECTIONPOOL_HOST`, `CONNECTIONPOOL_PORT`, `CONNECTIONPOOL_DATABASE`, `CONNECTIONPOOL_USER`, `CONNECTIONPOOL_PASSWORD`, `CONNECTIONPOOL_SSLMODE`, `CONNECTIONPOOL_DATABASE_URI` ConnInfoSecretTarget ConnInfoSecretTarget `json:"connInfoSecretTarget,omitempty"` // Authentication reference to Aiven token in a secret AuthSecretRef *AuthSecretReference `json:"authSecretRef,omitempty"` }
ConnectionPoolSpec defines the desired state of ConnectionPool
func (*ConnectionPoolSpec) DeepCopy ¶
func (in *ConnectionPoolSpec) DeepCopy() *ConnectionPoolSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectionPoolSpec.
func (*ConnectionPoolSpec) DeepCopyInto ¶
func (in *ConnectionPoolSpec) DeepCopyInto(out *ConnectionPoolSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConnectionPoolStatus ¶
type ConnectionPoolStatus struct { // Conditions represent the latest available observations of an ConnectionPool state Conditions []metav1.Condition `json:"conditions"` }
ConnectionPoolStatus defines the observed state of ConnectionPool
func (*ConnectionPoolStatus) DeepCopy ¶
func (in *ConnectionPoolStatus) DeepCopy() *ConnectionPoolStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectionPoolStatus.
func (*ConnectionPoolStatus) DeepCopyInto ¶
func (in *ConnectionPoolStatus) DeepCopyInto(out *ConnectionPoolStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Database ¶
type Database struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec DatabaseSpec `json:"spec,omitempty"` Status DatabaseStatus `json:"status,omitempty"` }
Database is the Schema for the databases API +kubebuilder:printcolumn:name="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,omitempty"` }
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 Grafana ¶ added in v0.7.0
type Grafana struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec GrafanaSpec `json:"spec,omitempty"` Status ServiceStatus `json:"status,omitempty"` }
Grafana is the Schema for the grafanas API +kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Region",type="string",JSONPath=".spec.cloudName" +kubebuilder:printcolumn:name="Plan",type="string",JSONPath=".spec.plan" +kubebuilder:printcolumn:name="State",type="string",JSONPath=".status.state"
func (*Grafana) AuthSecretRef ¶ added in v0.7.0
func (in *Grafana) AuthSecretRef() *AuthSecretReference
func (*Grafana) DeepCopy ¶ added in v0.7.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Grafana.
func (*Grafana) DeepCopyInto ¶ added in v0.7.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Grafana) DeepCopyObject ¶ added in v0.7.0
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Grafana) GetConnInfoSecretTarget ¶ added in v0.12.0
func (in *Grafana) GetConnInfoSecretTarget() ConnInfoSecretTarget
func (*Grafana) GetRefs ¶ added in v0.7.0
func (in *Grafana) GetRefs() []*ResourceReferenceObject
func (*Grafana) SetupWebhookWithManager ¶ added in v0.7.0
func (*Grafana) ValidateCreate ¶ added in v0.7.0
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*Grafana) ValidateDelete ¶ added in v0.7.0
ValidateDelete implements webhook.Validator so a webhook will be registered for the type
type GrafanaList ¶ added in v0.7.0
type GrafanaList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Grafana `json:"items"` }
GrafanaList contains a list of Grafana
func (*GrafanaList) DeepCopy ¶ added in v0.7.0
func (in *GrafanaList) DeepCopy() *GrafanaList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GrafanaList.
func (*GrafanaList) DeepCopyInto ¶ added in v0.7.0
func (in *GrafanaList) DeepCopyInto(out *GrafanaList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*GrafanaList) DeepCopyObject ¶ added in v0.7.0
func (in *GrafanaList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type GrafanaSpec ¶ added in v0.7.0
type GrafanaSpec struct { ServiceCommonSpec `json:",inline"` // +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,omitempty"` // Information regarding secret creation. // Exposed keys: `GRAFANA_HOST`, `GRAFANA_PORT`, `GRAFANA_USER`, `GRAFANA_PASSWORD`, `GRAFANA_URI`, `GRAFANA_HOSTS` ConnInfoSecretTarget ConnInfoSecretTarget `json:"connInfoSecretTarget,omitempty"` // Cassandra specific user configuration options UserConfig *grafanauserconfig.GrafanaUserConfig `json:"userConfig,omitempty"` }
GrafanaSpec defines the desired state of Grafana
func (*GrafanaSpec) DeepCopy ¶ added in v0.7.0
func (in *GrafanaSpec) DeepCopy() *GrafanaSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GrafanaSpec.
func (*GrafanaSpec) DeepCopyInto ¶ added in v0.7.0
func (in *GrafanaSpec) DeepCopyInto(out *GrafanaSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type 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 (in *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) GetConnInfoSecretTarget ¶ added in v0.12.0
func (in *Kafka) GetConnInfoSecretTarget() ConnInfoSecretTarget
func (*Kafka) GetRefs ¶ added in v0.5.0
func (in *Kafka) GetRefs() []*ResourceReferenceObject
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,omitempty"` }
KafkaACLSpec defines the desired state of KafkaACL
func (*KafkaACLSpec) DeepCopy ¶
func (in *KafkaACLSpec) DeepCopy() *KafkaACLSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaACLSpec.
func (*KafkaACLSpec) DeepCopyInto ¶
func (in *KafkaACLSpec) DeepCopyInto(out *KafkaACLSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KafkaACLStatus ¶
type KafkaACLStatus struct { // Conditions represent the latest available observations of an KafkaACL state Conditions []metav1.Condition `json:"conditions"` // Kafka ACL ID ID string `json:"id"` }
KafkaACLStatus defines the observed state of KafkaACL
func (*KafkaACLStatus) DeepCopy ¶
func (in *KafkaACLStatus) DeepCopy() *KafkaACLStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaACLStatus.
func (*KafkaACLStatus) DeepCopyInto ¶
func (in *KafkaACLStatus) DeepCopyInto(out *KafkaACLStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KafkaConnect ¶
type KafkaConnect struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec KafkaConnectSpec `json:"spec,omitempty"` Status ServiceStatus `json:"status,omitempty"` }
KafkaConnect is the Schema for the kafkaconnects API +kubebuilder:printcolumn:name="State",type="string",JSONPath=".status.state"
func (*KafkaConnect) AuthSecretRef ¶
func (in *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) GetRefs ¶ added in v0.5.0
func (in *KafkaConnect) GetRefs() []*ResourceReferenceObject
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 KafkaConnectSpec ¶
type KafkaConnectSpec struct { ServiceCommonSpec `json:",inline"` // Authentication reference to Aiven token in a secret AuthSecretRef *AuthSecretReference `json:"authSecretRef,omitempty"` // KafkaConnect specific user configuration options UserConfig *kafkaconnectuserconfig.KafkaConnectUserConfig `json:"userConfig,omitempty"` }
KafkaConnectSpec defines the desired state of KafkaConnect
func (*KafkaConnectSpec) DeepCopy ¶
func (in *KafkaConnectSpec) DeepCopy() *KafkaConnectSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaConnectSpec.
func (*KafkaConnectSpec) DeepCopyInto ¶
func (in *KafkaConnectSpec) DeepCopyInto(out *KafkaConnectSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KafkaConnector ¶
type KafkaConnector struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec KafkaConnectorSpec `json:"spec,omitempty"` Status KafkaConnectorStatus `json:"status,omitempty"` }
KafkaConnector is the Schema for the kafkaconnectors API +kubebuilder:printcolumn:name="Service Name",type="string",JSONPath=".spec.serviceName" +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Connector Class",type="string",JSONPath=".spec.connectorClass" +kubebuilder:printcolumn:name="State",type="string",JSONPath=".status.state" +kubebuilder:printcolumn:name="Tasks Total",type="integer",JSONPath=".status.tasksStatus.total" +kubebuilder:printcolumn:name="Tasks Running",type="integer",JSONPath=".status.tasksStatus.running"
func (KafkaConnector) AuthSecretRef ¶
func (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,omitempty"` // +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 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 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,omitempty"` }
KafkaSchemaSpec defines the desired state of KafkaSchema
func (*KafkaSchemaSpec) DeepCopy ¶
func (in *KafkaSchemaSpec) DeepCopy() *KafkaSchemaSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaSchemaSpec.
func (*KafkaSchemaSpec) DeepCopyInto ¶
func (in *KafkaSchemaSpec) DeepCopyInto(out *KafkaSchemaSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KafkaSchemaStatus ¶
type KafkaSchemaStatus struct { // Conditions represent the latest available observations of an KafkaSchema state Conditions []metav1.Condition `json:"conditions"` // 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,omitempty"` // Information regarding secret creation. // Exposed keys: `KAFKA_HOST`, `KAFKA_PORT`, `KAFKA_USERNAME`, `KAFKA_PASSWORD`, `KAFKA_ACCESS_CERT`, `KAFKA_ACCESS_KEY`, `KAFKA_SASL_HOST`, `KAFKA_SASL_PORT`, `KAFKA_SCHEMA_REGISTRY_HOST`, `KAFKA_SCHEMA_REGISTRY_PORT`, `KAFKA_CONNECT_HOST`, `KAFKA_CONNECT_PORT`, `KAFKA_REST_HOST`, `KAFKA_REST_PORT` 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.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 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 (t *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) GetTopicName ¶ added in v0.9.0
func (t *KafkaTopic) GetTopicName() string
GetTopicName returns topic name with a backward compatibility. metadata.Name is deprecated
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.cleanable.dirty.ratio value MinCleanableDirtyRatio *float64 `json:"min_cleanable_dirty_ratio,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"` }
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:MinLength=1 // +kubebuilder:validation:MaxLength=249 // +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable" // Topic name. If provided, is used instead of metadata.name. // This field supports additional characters, has a longer length, // and will replace metadata.name in future releases TopicName string `json:"topicName,omitempty"` // +kubebuilder:validation:Minimum=1 // +kubebuilder:validation:Maximum=1000000 // Number of partitions to create in the topic Partitions int `json:"partitions"` // +kubebuilder:validation:Minimum=2 // Replication factor for the topic Replication int `json:"replication"` // Kafka topic tags Tags []KafkaTopicTag `json:"tags,omitempty"` // Kafka topic configuration Config KafkaTopicConfig `json:"config,omitempty"` // It is a Kubernetes side deletion protections, which prevents the kafka topic // from being deleted by Kubernetes. It is recommended to enable this for any production // databases containing critical data. TerminationProtection *bool `json:"termination_protection,omitempty"` // Authentication reference to Aiven token in a secret AuthSecretRef *AuthSecretReference `json:"authSecretRef,omitempty"` }
KafkaTopicSpec defines the desired state of KafkaTopic
func (*KafkaTopicSpec) DeepCopy ¶
func (in *KafkaTopicSpec) DeepCopy() *KafkaTopicSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaTopicSpec.
func (*KafkaTopicSpec) DeepCopyInto ¶
func (in *KafkaTopicSpec) DeepCopyInto(out *KafkaTopicSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KafkaTopicStatus ¶
type KafkaTopicStatus struct { // Conditions represent the latest available observations of an KafkaTopic state Conditions []metav1.Condition `json:"conditions"` // State represents the state of the kafka topic State 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 MySQL ¶ added in v0.6.0
type MySQL struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec MySQLSpec `json:"spec,omitempty"` Status ServiceStatus `json:"status,omitempty"` }
MySQL is the Schema for the mysqls API +kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Region",type="string",JSONPath=".spec.cloudName" +kubebuilder:printcolumn:name="Plan",type="string",JSONPath=".spec.plan" +kubebuilder:printcolumn:name="State",type="string",JSONPath=".status.state"
func (*MySQL) AuthSecretRef ¶ added in v0.6.0
func (in *MySQL) AuthSecretRef() *AuthSecretReference
func (*MySQL) DeepCopy ¶ added in v0.6.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MySQL.
func (*MySQL) DeepCopyInto ¶ added in v0.6.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*MySQL) DeepCopyObject ¶ added in v0.6.0
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*MySQL) Default ¶ added in v0.6.0
func (in *MySQL) Default()
Default implements webhook.Defaulter so a webhook will be registered for the type
func (*MySQL) GetConnInfoSecretTarget ¶ added in v0.12.0
func (in *MySQL) GetConnInfoSecretTarget() ConnInfoSecretTarget
func (*MySQL) GetRefs ¶ added in v0.6.0
func (in *MySQL) GetRefs() []*ResourceReferenceObject
func (*MySQL) SetupWebhookWithManager ¶ added in v0.6.0
func (*MySQL) ValidateCreate ¶ added in v0.6.0
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*MySQL) ValidateDelete ¶ added in v0.6.0
ValidateDelete implements webhook.Validator so a webhook will be registered for the type
type MySQLList ¶ added in v0.6.0
type MySQLList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []MySQL `json:"items"` }
MySQLList contains a list of MySQL
func (*MySQLList) DeepCopy ¶ added in v0.6.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MySQLList.
func (*MySQLList) DeepCopyInto ¶ added in v0.6.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*MySQLList) DeepCopyObject ¶ added in v0.6.0
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type MySQLSpec ¶ added in v0.6.0
type MySQLSpec struct { ServiceCommonSpec `json:",inline"` // +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,omitempty"` // Information regarding secret creation. // Exposed keys: `MYSQL_HOST`, `MYSQL_PORT`, `MYSQL_DATABASE`, `MYSQL_USER`, `MYSQL_PASSWORD`, `MYSQL_SSL_MODE`, `MYSQL_URI`, `MYSQL_REPLICA_URI` ConnInfoSecretTarget ConnInfoSecretTarget `json:"connInfoSecretTarget,omitempty"` // MySQL specific user configuration options UserConfig *mysqluserconfig.MysqlUserConfig `json:"userConfig,omitempty"` }
MySQLSpec defines the desired state of MySQL
func (*MySQLSpec) DeepCopy ¶ added in v0.6.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MySQLSpec.
func (*MySQLSpec) DeepCopyInto ¶ added in v0.6.0
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 (in *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) GetConnInfoSecretTarget ¶ added in v0.12.0
func (in *OpenSearch) GetConnInfoSecretTarget() ConnInfoSecretTarget
func (*OpenSearch) GetRefs ¶ added in v0.5.0
func (in *OpenSearch) GetRefs() []*ResourceReferenceObject
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 OpenSearchList ¶ added in v0.3.0
type OpenSearchList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []OpenSearch `json:"items"` }
OpenSearchList contains a list of OpenSearch
func (*OpenSearchList) DeepCopy ¶ added in v0.3.0
func (in *OpenSearchList) DeepCopy() *OpenSearchList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OpenSearchList.
func (*OpenSearchList) DeepCopyInto ¶ added in v0.3.0
func (in *OpenSearchList) DeepCopyInto(out *OpenSearchList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*OpenSearchList) DeepCopyObject ¶ added in v0.3.0
func (in *OpenSearchList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type OpenSearchSpec ¶ added in v0.3.0
type OpenSearchSpec struct { ServiceCommonSpec `json:",inline"` // +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,omitempty"` // Information regarding secret creation. // Exposed keys: `OPENSEARCH_HOST`, `OPENSEARCH_PORT`, `OPENSEARCH_USER`, `OPENSEARCH_PASSWORD` ConnInfoSecretTarget ConnInfoSecretTarget `json:"connInfoSecretTarget,omitempty"` // OpenSearch specific user configuration options UserConfig *opensearchuserconfig.OpensearchUserConfig `json:"userConfig,omitempty"` }
OpenSearchSpec defines the desired state of OpenSearch
func (*OpenSearchSpec) DeepCopy ¶ added in v0.3.0
func (in *OpenSearchSpec) DeepCopy() *OpenSearchSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OpenSearchSpec.
func (*OpenSearchSpec) DeepCopyInto ¶ added in v0.3.0
func (in *OpenSearchSpec) DeepCopyInto(out *OpenSearchSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PostgreSQL ¶
type PostgreSQL struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec PostgreSQLSpec `json:"spec,omitempty"` Status ServiceStatus `json:"status,omitempty"` }
PostgreSQL is the Schema for the postgresql API +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Region",type="string",JSONPath=".spec.cloudName" +kubebuilder:printcolumn:name="Plan",type="string",JSONPath=".spec.plan" +kubebuilder:printcolumn:name="State",type="string",JSONPath=".status.state"
func (*PostgreSQL) AuthSecretRef ¶
func (in *PostgreSQL) AuthSecretRef() *AuthSecretReference
func (*PostgreSQL) 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) GetConnInfoSecretTarget ¶ added in v0.12.0
func (in *PostgreSQL) GetConnInfoSecretTarget() ConnInfoSecretTarget
func (*PostgreSQL) GetRefs ¶ added in v0.5.0
func (in *PostgreSQL) GetRefs() []*ResourceReferenceObject
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,omitempty"` // Information regarding secret creation. // Exposed keys: `POSTGRESQL_HOST`, `POSTGRESQL_PORT`, `POSTGRESQL_DATABASE`, `POSTGRESQL_USER`, `POSTGRESQL_PASSWORD`, `POSTGRESQL_SSLMODE`, `POSTGRESQL_DATABASE_URI` ConnInfoSecretTarget ConnInfoSecretTarget `json:"connInfoSecretTarget,omitempty"` // PostgreSQL specific user configuration options UserConfig *pguserconfig.PgUserConfig `json:"userConfig,omitempty"` }
PostgreSQLSpec defines the desired state of postgres instance
func (*PostgreSQLSpec) DeepCopy ¶
func (in *PostgreSQLSpec) DeepCopy() *PostgreSQLSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PostgreSQLSpec.
func (*PostgreSQLSpec) DeepCopyInto ¶
func (in *PostgreSQLSpec) DeepCopyInto(out *PostgreSQLSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type 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) GetConnInfoSecretTarget ¶ added in v0.12.0
func (in *Project) GetConnInfoSecretTarget() ConnInfoSecretTarget
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. // Exposed keys: `PROJECT_CA_CERT` 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,omitempty"` }
ProjectSpec defines the desired state of Project
func (*ProjectSpec) DeepCopy ¶
func (in *ProjectSpec) DeepCopy() *ProjectSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ProjectSpec.
func (*ProjectSpec) DeepCopyInto ¶
func (in *ProjectSpec) DeepCopyInto(out *ProjectSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ProjectStatus ¶
type ProjectStatus struct { // Conditions represent the latest available observations of an Project state Conditions []metav1.Condition `json:"conditions"` // +kubebuilder:validation:MaxLength=64 // EU VAT Identification Number VatID string `json:"vatId,omitempty"` // Available credirs AvailableCredits string `json:"availableCredits,omitempty"` // Country name Country string `json:"country,omitempty"` // Estimated balance EstimatedBalance string `json:"estimatedBalance,omitempty"` // Payment method name PaymentMethod string `json:"paymentMethod,omitempty"` }
ProjectStatus defines the observed state of Project
func (*ProjectStatus) DeepCopy ¶
func (in *ProjectStatus) DeepCopy() *ProjectStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ProjectStatus.
func (*ProjectStatus) DeepCopyInto ¶
func (in *ProjectStatus) DeepCopyInto(out *ProjectStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ProjectVPC ¶
type ProjectVPC struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec ProjectVPCSpec `json:"spec,omitempty"` Status ProjectVPCStatus `json:"status,omitempty"` }
ProjectVPC is the Schema for the projectvpcs API +kubebuilder:printcolumn:name="Project",type="string",JSONPath=".spec.project" +kubebuilder:printcolumn:name="Cloud",type="string",JSONPath=".spec.cloudName" +kubebuilder:printcolumn:name="Network CIDR",type="string",JSONPath=".spec.networkCidr" +kubebuilder:printcolumn:name="State",type="string",JSONPath=".status.state"
func FindProjectVPC ¶ added in v0.5.0
func FindProjectVPC(refs []client.Object) *ProjectVPC
FindProjectVPC returns ProjectVPC from reference list
func (ProjectVPC) AuthSecretRef ¶
func (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.
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_-]*$" // +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable" // The project the VPC belongs to Project string `json:"project"` // +kubebuilder:validation:MaxLength=256 // +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable" // Cloud the VPC is in CloudName string `json:"cloudName"` // +kubebuilder:validation:MaxLength=36 // +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable" // Network address range used by the VPC like 192.168.0.0/24 NetworkCidr string `json:"networkCidr"` // Authentication reference to Aiven token in a secret AuthSecretRef *AuthSecretReference `json:"authSecretRef,omitempty"` }
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 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 (in *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) GetConnInfoSecretTarget ¶ added in v0.12.0
func (in *Redis) GetConnInfoSecretTarget() ConnInfoSecretTarget
func (*Redis) GetRefs ¶ added in v0.5.0
func (in *Redis) GetRefs() []*ResourceReferenceObject
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 RedisSpec ¶ added in v0.2.0
type RedisSpec 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,omitempty"` // Information regarding secret creation. // Exposed keys: `REDIS_HOST`, `REDIS_PORT`, `REDIS_USER`, `REDIS_PASSWORD` ConnInfoSecretTarget ConnInfoSecretTarget `json:"connInfoSecretTarget,omitempty"` // Redis specific user configuration options UserConfig *redisuserconfig.RedisUserConfig `json:"userConfig,omitempty"` }
RedisSpec defines the desired state of Redis
func (*RedisSpec) DeepCopy ¶ added in v0.2.0
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 ResourceReference ¶ added in v0.5.0
type ResourceReference struct { // +kubebuilder:validation:MinLength=1 Name string `json:"name"` // +kubebuilder:validation:MinLength=1 Namespace string `json:"namespace,omitempty"` }
ResourceReference is a generic reference to another resource. Resource referring to another (dependency) won't start reconciliation until dependency is not ready
func (*ResourceReference) DeepCopy ¶ added in v0.5.0
func (in *ResourceReference) DeepCopy() *ResourceReference
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceReference.
func (*ResourceReference) DeepCopyInto ¶ added in v0.5.0
func (in *ResourceReference) DeepCopyInto(out *ResourceReference)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ResourceReference) ProjectVPC ¶ added in v0.5.0
func (in *ResourceReference) ProjectVPC(objNamespace string) *ResourceReferenceObject
ProjectVPC returns reference ProjectVPC kind
type ResourceReferenceObject ¶ added in v0.5.0
type ResourceReferenceObject struct { GroupVersionKind schema.GroupVersionKind NamespacedName types.NamespacedName }
ResourceReferenceObject is a composite "key" to resource GroupVersionKind is for resource "type": GroupVersionKind{Group: "aiven.io", Version: "v1alpha1", Kind: "Kafka"} NamespacedName is for specific instance: NamespacedName{Name: "my-kafka", Namespace: "default"}
func (*ResourceReferenceObject) DeepCopy ¶ added in v0.5.0
func (in *ResourceReferenceObject) DeepCopy() *ResourceReferenceObject
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceReferenceObject.
func (*ResourceReferenceObject) DeepCopyInto ¶ added in v0.5.0
func (in *ResourceReferenceObject) DeepCopyInto(out *ResourceReferenceObject)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServiceCommonSpec ¶
type ServiceCommonSpec struct { // +kubebuilder:validation:MaxLength=63 // +kubebuilder:validation:Format="^[a-zA-Z0-9_-]*$" // +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable" // Target project. Project string `json:"project"` // +kubebuilder:validation:MaxLength=128 // Subscription plan. Plan string `json:"plan"` // +kubebuilder:validation:MaxLength=256 // Cloud the service runs in. CloudName string `json:"cloudName,omitempty"` // +kubebuilder:validation:MaxLength=36 // +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable" // Identifier of the VPC the service should be in, if any. ProjectVPCID string `json:"projectVpcId,omitempty"` // +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable" // ProjectVPCRef reference to ProjectVPC resource to use its ID as ProjectVPCID automatically ProjectVPCRef *ResourceReference `json:"projectVPCRef,omitempty"` // +kubebuilder:validation:Enum=monday;tuesday;wednesday;thursday;friday;saturday;sunday // Day of week when maintenance operations should be performed. One monday, tuesday, wednesday, etc. MaintenanceWindowDow 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"` // +kubebuilder:validation:MaxItems=1 // +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable" // Service integrations to specify when creating a service. Not applied after initial service creation ServiceIntegrations []*ServiceIntegrationItem `json:"serviceIntegrations,omitempty"` }
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.
func (*ServiceCommonSpec) GetRefs ¶ added in v0.5.0
func (in *ServiceCommonSpec) GetRefs(namespace string) (refs []*ResourceReferenceObject)
GetRefs is inherited by kafka, pg, os, etc
func (*ServiceCommonSpec) Validate ¶ added in v0.5.0
func (in *ServiceCommonSpec) Validate() error
Validate runs complex validation on ServiceCommonSpec
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 (in *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 (in *ServiceIntegration) Default()
Default implements webhook.Defaulter so a webhook will be registered for the type
func (*ServiceIntegration) GetUserConfig ¶ added in v0.11.0
func (in *ServiceIntegration) GetUserConfig() (any, error)
func (*ServiceIntegration) SetupWebhookWithManager ¶
func (in *ServiceIntegration) SetupWebhookWithManager(mgr ctrl.Manager) error
func (*ServiceIntegration) ValidateCreate ¶
func (in *ServiceIntegration) ValidateCreate() error
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*ServiceIntegration) ValidateDelete ¶
func (in *ServiceIntegration) ValidateDelete() error
ValidateDelete implements webhook.Validator so a webhook will be registered for the type
func (*ServiceIntegration) ValidateUpdate ¶
func (in *ServiceIntegration) ValidateUpdate(old runtime.Object) error
ValidateUpdate implements webhook.Validator so a webhook will be registered for the type
type ServiceIntegrationItem ¶ added in v0.8.0
type ServiceIntegrationItem struct { // +kubebuilder:validation:Enum=read_replica IntegrationType string `json:"integrationType"` // +kubebuilder:validation:MinLength=1 // +kubebuilder:validation:MaxLength=64 SourceServiceName string `json:"sourceServiceName"` }
Service integrations to specify when creating a service. Not applied after initial service creation
func (*ServiceIntegrationItem) DeepCopy ¶ added in v0.8.0
func (in *ServiceIntegrationItem) DeepCopy() *ServiceIntegrationItem
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceIntegrationItem.
func (*ServiceIntegrationItem) DeepCopyInto ¶ added in v0.8.0
func (in *ServiceIntegrationItem) DeepCopyInto(out *ServiceIntegrationItem)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServiceIntegrationList ¶
type ServiceIntegrationList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []ServiceIntegration `json:"items"` }
ServiceIntegrationList contains a list of ServiceIntegration
func (*ServiceIntegrationList) DeepCopy ¶
func (in *ServiceIntegrationList) DeepCopy() *ServiceIntegrationList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceIntegrationList.
func (*ServiceIntegrationList) DeepCopyInto ¶
func (in *ServiceIntegrationList) DeepCopyInto(out *ServiceIntegrationList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ServiceIntegrationList) DeepCopyObject ¶
func (in *ServiceIntegrationList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ServiceIntegrationSpec ¶
type ServiceIntegrationSpec struct { // +kubebuilder:validation:MaxLength=63 // +kubebuilder:validation:Format="^[a-zA-Z0-9_-]*$" // +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable" // Project the integration belongs to Project string `json:"project"` // +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable" // +kubebuilder:validation:Enum=alertmanager;autoscaler;caching;cassandra_cross_service_cluster;clickhouse_kafka;clickhouse_postgresql;dashboard;datadog;datasource;external_aws_cloudwatch_logs;external_aws_cloudwatch_metrics;external_elasticsearch_logs;external_google_cloud_logging;external_opensearch_logs;flink;flink_external_kafka;internal_connectivity;jolokia;kafka_connect;kafka_logs;kafka_mirrormaker;logs;m3aggregator;m3coordinator;metrics;opensearch_cross_cluster_replication;opensearch_cross_cluster_search;prometheus;read_replica;rsyslog;schema_registry_proxy;stresstester;thanosquery;thanosstore;vmalert // Type of the service integration accepted by Aiven API. Some values may not be supported by the operator IntegrationType string `json:"integrationType"` // +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable" // +kubebuilder:validation:MaxLength=36 // Source endpoint for the integration (if any) SourceEndpointID string `json:"sourceEndpointID,omitempty"` // +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable" // +kubebuilder:validation:MaxLength=64 // Source service for the integration (if any) SourceServiceName string `json:"sourceServiceName,omitempty"` // +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable" // +kubebuilder:validation:MaxLength=63 // Source project for the integration (if any) SourceProjectName string `json:"sourceProjectName,omitempty"` // +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable" // +kubebuilder:validation:MaxLength=36 // Destination endpoint for the integration (if any) DestinationEndpointID string `json:"destinationEndpointId,omitempty"` // +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable" // +kubebuilder:validation:MaxLength=64 // Destination service for the integration (if any) DestinationServiceName string `json:"destinationServiceName,omitempty"` // +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable" // +kubebuilder:validation:MaxLength=63 // Destination project for the integration (if any) DestinationProjectName string `json:"destinationProjectName,omitempty"` // Datadog specific user configuration options DatadogUserConfig *datadogintegration.DatadogUserConfig `json:"datadog,omitempty"` // Kafka Connect service configuration values KafkaConnectUserConfig *kafkaconnectintegration.KafkaConnectUserConfig `json:"kafkaConnect,omitempty"` // Kafka logs configuration values KafkaLogsUserConfig *kafkalogsintegration.KafkaLogsUserConfig `json:"kafkaLogs,omitempty"` // Metrics configuration values MetricsUserConfig *metricsintegration.MetricsUserConfig `json:"metrics,omitempty"` // Clickhouse PostgreSQL configuration values ClickhousePostgreSQLUserConfig *clickhousepostgresqluserconfig.ClickhousePostgresqlUserConfig `json:"clickhousePostgresql,omitempty"` // Clickhouse Kafka configuration values ClickhouseKafkaUserConfig *clickhousekafkauserconfig.ClickhouseKafkaUserConfig `json:"clickhouseKafka,omitempty"` // Kafka MirrorMaker configuration values KafkaMirrormakerUserConfig *kafkamirrormakeruserconfig.KafkaMirrormakerUserConfig `json:"kafkaMirrormaker,omitempty"` // Logs configuration values LogsUserConfig *logsuserconfig.LogsUserConfig `json:"logs,omitempty"` // External AWS CloudWatch Metrics integration Logs configuration values ExternalAWSCloudwatchMetricsUserConfig *externalawscloudwatchmetricsuserconfig.ExternalAwsCloudwatchMetricsUserConfig `json:"externalAWSCloudwatchMetrics,omitempty"` // Authentication reference to Aiven token in a secret AuthSecretRef *AuthSecretReference `json:"authSecretRef,omitempty"` }
ServiceIntegrationSpec defines the desired state of ServiceIntegration
func (*ServiceIntegrationSpec) DeepCopy ¶
func (in *ServiceIntegrationSpec) DeepCopy() *ServiceIntegrationSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceIntegrationSpec.
func (*ServiceIntegrationSpec) DeepCopyInto ¶
func (in *ServiceIntegrationSpec) DeepCopyInto(out *ServiceIntegrationSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServiceIntegrationStatus ¶
type ServiceIntegrationStatus struct { // Conditions represent the latest available observations of an ServiceIntegration state Conditions []metav1.Condition `json:"conditions"` // Service integration ID ID string `json:"id"` }
ServiceIntegrationStatus defines the observed state of ServiceIntegration
func (*ServiceIntegrationStatus) DeepCopy ¶
func (in *ServiceIntegrationStatus) DeepCopy() *ServiceIntegrationStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceIntegrationStatus.
func (*ServiceIntegrationStatus) DeepCopyInto ¶
func (in *ServiceIntegrationStatus) DeepCopyInto(out *ServiceIntegrationStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServiceStatus ¶
type ServiceStatus struct { // Conditions represent the latest available observations of a service state Conditions []metav1.Condition `json:"conditions,omitempty"` // Service state State string `json:"state,omitempty"` }
ServiceStatus defines the observed state of service
func (*ServiceStatus) DeepCopy ¶
func (in *ServiceStatus) DeepCopy() *ServiceStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceStatus.
func (*ServiceStatus) DeepCopyInto ¶
func (in *ServiceStatus) DeepCopyInto(out *ServiceStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type 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) GetConnInfoSecretTarget ¶ added in v0.12.0
func (in *ServiceUser) GetConnInfoSecretTarget() ConnInfoSecretTarget
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. // Exposed keys: `SERVICEUSER_HOST`, `SERVICEUSER_PORT`, `SERVICEUSER_USERNAME`, `SERVICEUSER_PASSWORD`, `SERVICEUSER_CA_CERT`, `SERVICEUSER_ACCESS_CERT`, `SERVICEUSER_ACCESS_KEY` ConnInfoSecretTarget ConnInfoSecretTarget `json:"connInfoSecretTarget,omitempty"` // Authentication reference to Aiven token in a secret AuthSecretRef *AuthSecretReference `json:"authSecretRef,omitempty"` }
ServiceUserSpec defines the desired state of ServiceUser
func (*ServiceUserSpec) DeepCopy ¶
func (in *ServiceUserSpec) DeepCopy() *ServiceUserSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceUserSpec.
func (*ServiceUserSpec) DeepCopyInto ¶
func (in *ServiceUserSpec) DeepCopyInto(out *ServiceUserSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServiceUserStatus ¶
type ServiceUserStatus struct { // Conditions represent the latest available observations of an ServiceUser state Conditions []metav1.Condition `json:"conditions"` // Type of the user account Type string `json:"type,omitempty"` }
ServiceUserStatus defines the observed state of ServiceUser
func (*ServiceUserStatus) DeepCopy ¶
func (in *ServiceUserStatus) DeepCopy() *ServiceUserStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceUserStatus.
func (*ServiceUserStatus) DeepCopyInto ¶
func (in *ServiceUserStatus) DeepCopyInto(out *ServiceUserStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
Source Files ¶
- cassandra_types.go
- cassandra_webhook.go
- 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
- grafana_types.go
- grafana_webhook.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
- mysql_types.go
- mysql_webhook.go
- opensearch_types.go
- opensearch_webhook.go
- postgresql_types.go
- postgresql_webhook.go
- project_types.go
- project_webhook.go
- projectvpc_types.go
- redis_types.go
- redis_webhook.go
- serviceintegration_types.go
- serviceintegration_webhook.go
- serviceuser_types.go
- serviceuser_webhook.go
- setup_webhooks.go
- zz_generated.deepcopy.go