v1alpha1

package

Go to main page

Versions in this module

v0

v0.19.0

Apr 18, 2024

Changes in this version

+ type ClickhouseRole struct

+ Spec ClickhouseRoleSpec

+ Status ClickhouseRoleStatus

+ func (in *ClickhouseRole) AuthSecretRef() *AuthSecretReference

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

+ func (in *ClickhouseRole) DeepCopy() *ClickhouseRole

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

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

+ func (in *ClickhouseRole) NoSecret() bool

+ type ClickhouseRoleList struct

+ Items []ClickhouseRole

+ func (in *ClickhouseRoleList) DeepCopy() *ClickhouseRoleList

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

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

+ type ClickhouseRoleSpec struct

+ AuthSecretRef *AuthSecretReference

+ Role string

+ func (in *ClickhouseRoleSpec) DeepCopy() *ClickhouseRoleSpec

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

+ type ClickhouseRoleStatus struct

+ Conditions []metav1.Condition

+ func (in *ClickhouseRoleStatus) DeepCopy() *ClickhouseRoleStatus

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

+ type ProjectField struct

+ Project string

+ func (in *ProjectField) DeepCopy() *ProjectField

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

+ type ProjectServiceFields struct

+ func (in *ProjectServiceFields) DeepCopy() *ProjectServiceFields

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

+ type ServiceField struct

+ ServiceName string

+ func (in *ServiceField) DeepCopy() *ServiceField

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

v0.18.1

Apr 2, 2024

v0.18.0

Apr 2, 2024

Changes in this version

+ type ClickhouseDatabase struct

+ Spec ClickhouseDatabaseSpec

+ Status ClickhouseDatabaseStatus

+ func (*ClickhouseDatabase) NoSecret() bool

+ func (in *ClickhouseDatabase) AuthSecretRef() *AuthSecretReference

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

+ func (in *ClickhouseDatabase) DeepCopy() *ClickhouseDatabase

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

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

+ type ClickhouseDatabaseList struct

+ Items []ClickhouseDatabase

+ func (in *ClickhouseDatabaseList) DeepCopy() *ClickhouseDatabaseList

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

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

+ type ClickhouseDatabaseSpec struct

+ AuthSecretRef *AuthSecretReference

+ Project string

+ ServiceName string

+ func (in *ClickhouseDatabaseSpec) DeepCopy() *ClickhouseDatabaseSpec

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

+ type ClickhouseDatabaseStatus struct

+ Conditions []metav1.Condition

+ func (in *ClickhouseDatabaseStatus) DeepCopy() *ClickhouseDatabaseStatus

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

+ type KafkaSchemaRegistryACL struct

+ Spec KafkaSchemaRegistryACLSpec

+ Status KafkaSchemaRegistryACLStatus

+ func (in *KafkaSchemaRegistryACL) AuthSecretRef() *AuthSecretReference

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

+ func (in *KafkaSchemaRegistryACL) DeepCopy() *KafkaSchemaRegistryACL

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

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

+ func (in *KafkaSchemaRegistryACL) NoSecret() bool

+ type KafkaSchemaRegistryACLList struct

+ Items []KafkaSchemaRegistryACL

+ func (in *KafkaSchemaRegistryACLList) DeepCopy() *KafkaSchemaRegistryACLList

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

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

+ type KafkaSchemaRegistryACLSpec struct

+ AuthSecretRef *AuthSecretReference

+ Permission string

+ Project string

+ Resource string

+ ServiceName string

+ Username string

+ func (in *KafkaSchemaRegistryACLSpec) DeepCopy() *KafkaSchemaRegistryACLSpec

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

+ type KafkaSchemaRegistryACLStatus struct

+ ACLId string

+ Conditions []metav1.Condition

+ func (in *KafkaSchemaRegistryACLStatus) DeepCopy() *KafkaSchemaRegistryACLStatus

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

type KafkaTopicConfig

+ LocalRetentionBytes *int64

+ LocalRetentionMs *int64

+ RemoteStorageEnable *bool

v0.17.0

Feb 1, 2024

Changes in this version

type AivenManagedObject

+ NoSecret func() bool

type Cassandra

+ func (in *Cassandra) NoSecret() bool

type CassandraSpec

+ ConnInfoSecretTargetDisabled *bool

type Clickhouse

+ func (in *Clickhouse) NoSecret() bool

type ClickhouseSpec

+ ConnInfoSecretTargetDisabled *bool

type ClickhouseUser

+ func (in *ClickhouseUser) NoSecret() bool

type ClickhouseUserSpec

+ ConnInfoSecretTargetDisabled *bool

type ConnectionPool

+ func (in *ConnectionPool) NoSecret() bool

type ConnectionPoolSpec

+ ConnInfoSecretTargetDisabled *bool

type Database

+ func (*Database) NoSecret() bool

type Grafana

+ func (in *Grafana) NoSecret() bool

type GrafanaSpec

+ ConnInfoSecretTargetDisabled *bool

type Kafka

+ func (in *Kafka) NoSecret() bool

type KafkaACL

+ func (*KafkaACL) NoSecret() bool

type KafkaConnect

+ func (*KafkaConnect) NoSecret() bool

type KafkaConnector

+ func (*KafkaConnector) NoSecret() bool

type KafkaSchema

+ func (*KafkaSchema) NoSecret() bool

type KafkaSpec

+ ConnInfoSecretTargetDisabled *bool

type KafkaTopic

+ func (*KafkaTopic) NoSecret() bool

type MySQL

+ func (in *MySQL) NoSecret() bool

type MySQLSpec

+ ConnInfoSecretTargetDisabled *bool

type OpenSearch

+ func (in *OpenSearch) NoSecret() bool

type OpenSearchSpec

+ ConnInfoSecretTargetDisabled *bool

type PostgreSQL

+ func (in *PostgreSQL) NoSecret() bool

type PostgreSQLSpec

+ ConnInfoSecretTargetDisabled *bool

type Project

+ func (in *Project) NoSecret() bool

type ProjectSpec

+ ConnInfoSecretTargetDisabled *bool

type ProjectVPC

+ func (*ProjectVPC) NoSecret() bool

type Redis

+ func (in *Redis) NoSecret() bool

type RedisSpec

+ ConnInfoSecretTargetDisabled *bool

type ServiceCommonSpec

+ TechnicalEmails []ServiceTechEmail

type ServiceIntegration

+ func (*ServiceIntegration) NoSecret() bool

+ type ServiceTechEmail struct

+ Email string

+ func (in *ServiceTechEmail) DeepCopy() *ServiceTechEmail

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

type ServiceUser

+ func (in *ServiceUser) NoSecret() bool

type ServiceUserSpec

+ ConnInfoSecretTargetDisabled *bool

v0.16.1

Dec 15, 2023

v0.16.0

Dec 7, 2023

Changes in this version

+ type AivenManagedObject interface

+ AuthSecretRef func() *AuthSecretReference

+ Conditions func() *[]metav1.Condition

type Cassandra

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

type Clickhouse

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

type ClickhouseUser

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

type ConnectionPool

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

type Database

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

type Grafana

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

type Kafka

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

type KafkaACL

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

type KafkaConnect

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

type KafkaConnector

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

type KafkaSchema

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

type KafkaTopic

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

type MySQL

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

type OpenSearch

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

type PostgreSQL

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

type Project

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

type ProjectVPC

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

type Redis

+ func (in *Redis) Conditions() *[]metav1.Condition

type ServiceIntegration

+ func (in *ServiceIntegration) Conditions() *[]metav1.Condition

type ServiceUser

+ func (in *ServiceUser) Conditions() *[]metav1.Condition

v0.15.0

Nov 17, 2023

v0.14.0

Sep 21, 2023

v0.13.0

Aug 18, 2023

v0.12.3

Jul 13, 2023

v0.12.2

Jun 20, 2023

v0.12.1

Jun 20, 2023

v0.12.0

May 10, 2023

Changes in this version

type Cassandra

+ func (in *Cassandra) GetConnInfoSecretTarget() ConnInfoSecretTarget

type Clickhouse

+ func (in *Clickhouse) GetConnInfoSecretTarget() ConnInfoSecretTarget

type ClickhouseUser

+ func (in *ClickhouseUser) GetConnInfoSecretTarget() ConnInfoSecretTarget

type ConnInfoSecretTarget

+ Prefix string

type ConnectionPool

+ func (in *ConnectionPool) GetConnInfoSecretTarget() ConnInfoSecretTarget

type Grafana

+ func (in *Grafana) GetConnInfoSecretTarget() ConnInfoSecretTarget

type Kafka

+ func (in *Kafka) GetConnInfoSecretTarget() ConnInfoSecretTarget

type MySQL

+ func (in *MySQL) GetConnInfoSecretTarget() ConnInfoSecretTarget

type OpenSearch

+ func (in *OpenSearch) GetConnInfoSecretTarget() ConnInfoSecretTarget

type PostgreSQL

+ func (in *PostgreSQL) GetConnInfoSecretTarget() ConnInfoSecretTarget

type Project

+ func (in *Project) GetConnInfoSecretTarget() ConnInfoSecretTarget

type Redis

+ func (in *Redis) GetConnInfoSecretTarget() ConnInfoSecretTarget

type ServiceUser

+ func (in *ServiceUser) GetConnInfoSecretTarget() ConnInfoSecretTarget

v0.11.0

Apr 25, 2023

Changes in this version

+ func SetupWebhooks(mgr ctrl.Manager) error

type ConnInfoSecretTarget

+ Annotations map[string]string

+ Labels map[string]string

type ServiceIntegration

+ func (in *ServiceIntegration) GetUserConfig() (any, error)

type ServiceIntegrationSpec

+ DestinationProjectName string

+ SourceProjectName string

v0.10.0

Apr 17, 2023

v0.9.0

Mar 3, 2023

Changes in this version

type KafkaTopic

+ func (t *KafkaTopic) GetTopicName() string

type KafkaTopicSpec

+ TopicName string

type ServiceIntegrationSpec

+ ClickhouseKafkaUserConfig *clickhousekafkauserconfig.ClickhouseKafkaUserConfig

+ ClickhousePostgreSQLUserConfig *clickhousepostgresqluserconfig.ClickhousePostgresqlUserConfig

+ ExternalAWSCloudwatchMetricsUserConfig *externalawscloudwatchmetricsuserconfig.ExternalAwsCloudwatchMetricsUserConfig

+ KafkaMirrormakerUserConfig *kafkamirrormakeruserconfig.KafkaMirrormakerUserConfig

+ LogsUserConfig *logsuserconfig.LogsUserConfig

v0.8.0

Feb 15, 2023

Changes in this version

type ClickhouseSpec

+ DiskSpace string

type KafkaTopicConfig

+ MinCleanableDirtyRatio *float64

type ServiceCommonSpec

+ ServiceIntegrations []*ServiceIntegrationItem

+ type ServiceIntegrationItem struct

+ IntegrationType string

+ SourceServiceName string

+ func (in *ServiceIntegrationItem) DeepCopy() *ServiceIntegrationItem

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

v0.7.1

Jan 24, 2023

v0.7.0

Jan 23, 2023

Changes in this version

+ type Cassandra struct

+ Spec CassandraSpec

+ Status ServiceStatus

+ 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) 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 struct

+ Items []Cassandra

+ func (in *CassandraList) DeepCopy() *CassandraList

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

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

+ type CassandraSpec struct

+ AuthSecretRef AuthSecretReference

+ ConnInfoSecretTarget ConnInfoSecretTarget

+ DiskSpace string

+ UserConfig *cassandrauserconfig.CassandraUserConfig

+ func (in *CassandraSpec) DeepCopy() *CassandraSpec

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

+ type Grafana struct

+ Spec GrafanaSpec

+ Status ServiceStatus

+ 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) 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 struct

+ Items []Grafana

+ func (in *GrafanaList) DeepCopy() *GrafanaList

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

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

+ type GrafanaSpec struct

+ AuthSecretRef AuthSecretReference

+ ConnInfoSecretTarget ConnInfoSecretTarget

+ DiskSpace string

+ UserConfig *grafanauserconfig.GrafanaUserConfig

+ func (in *GrafanaSpec) DeepCopy() *GrafanaSpec

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

v0.6.0

Jan 16, 2023

Changes in this version

+ type MySQL struct

+ Spec MySQLSpec

+ Status ServiceStatus

+ 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) 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 struct

+ Items []MySQL

+ func (in *MySQLList) DeepCopy() *MySQLList

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

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

+ type MySQLSpec struct

+ AuthSecretRef AuthSecretReference

+ ConnInfoSecretTarget ConnInfoSecretTarget

+ DiskSpace string

+ UserConfig *mysqluserconfig.MysqlUserConfig

+ func (in *MySQLSpec) DeepCopy() *MySQLSpec

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

v0.5.2

Dec 9, 2022

v0.5.1

Nov 28, 2022

v0.5.0

Nov 22, 2022

Changes in this version

+ var ErrDeleteDependencies = errors.New("object has dependencies and cannot be deleted")

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

type AuthSecretReference

+ func (r AuthSecretReference) IsValid() bool

type Clickhouse

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

type Kafka

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

type KafkaConnect

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

type OpenSearch

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

type PostgreSQL

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

type ProjectVPC

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

type Redis

+ func (in *Redis) GetRefs() []*ResourceReferenceObject

+ type ResourceReference struct

+ Name string

+ Namespace string

+ func (in *ResourceReference) DeepCopy() *ResourceReference

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

+ func (in *ResourceReference) ProjectVPC(objNamespace string) *ResourceReferenceObject

+ type ResourceReferenceObject struct

+ GroupVersionKind schema.GroupVersionKind

+ NamespacedName types.NamespacedName

+ func (in *ResourceReferenceObject) DeepCopy() *ResourceReferenceObject

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

type ServiceCommonSpec

+ ProjectVPCRef *ResourceReference

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

+ func (in *ServiceCommonSpec) Validate() error

v0.4.0

Aug 4, 2022

Changes in this version

type ProjectSpec

+ Tags map[string]string

type ServiceCommonSpec

+ Tags map[string]string

v0.3.0

May 4, 2022

Changes in this version

+ func ConvertDiscSpace(v string) int

+ type Clickhouse struct

+ Spec ClickhouseSpec

+ Status ServiceStatus

+ func (in *Clickhouse) DeepCopy() *Clickhouse

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

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

+ func (o Clickhouse) AuthSecretRef() AuthSecretReference

+ func (r *Clickhouse) Default()

+ func (r *Clickhouse) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *Clickhouse) ValidateCreate() error

+ func (r *Clickhouse) ValidateDelete() error

+ func (r *Clickhouse) ValidateUpdate(old runtime.Object) error

+ type ClickhouseList struct

+ Items []Clickhouse

+ func (in *ClickhouseList) DeepCopy() *ClickhouseList

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

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

+ type ClickhouseSpec struct

+ AuthSecretRef AuthSecretReference

+ ConnInfoSecretTarget ConnInfoSecretTarget

+ UserConfig ClickhouseUserConfig

+ func (in *ClickhouseSpec) DeepCopy() *ClickhouseSpec

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

+ type ClickhouseUser struct

+ Spec ClickhouseUserSpec

+ Status ClickhouseUserStatus

+ func (in *ClickhouseUser) DeepCopy() *ClickhouseUser

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

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

+ func (r *ClickhouseUser) Default()

+ func (r *ClickhouseUser) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *ClickhouseUser) ValidateCreate() error

+ func (r *ClickhouseUser) ValidateDelete() error

+ func (r *ClickhouseUser) ValidateUpdate(old runtime.Object) error

+ func (u ClickhouseUser) AuthSecretRef() AuthSecretReference

+ type ClickhouseUserConfig struct

+ IpFilter []string

+ ProjectToForkFrom string

+ ServiceToForkFrom string

+ func (in *ClickhouseUserConfig) DeepCopy() *ClickhouseUserConfig

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

+ type ClickhouseUserList struct

+ Items []ClickhouseUser

+ func (in *ClickhouseUserList) DeepCopy() *ClickhouseUserList

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

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

+ type ClickhouseUserSpec struct

+ AuthSecretRef AuthSecretReference

+ Authentication string

+ ConnInfoSecretTarget ConnInfoSecretTarget

+ Project string

+ ServiceName string

+ func (in *ClickhouseUserSpec) DeepCopy() *ClickhouseUserSpec

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

+ type ClickhouseUserStatus struct

+ Conditions []metav1.Condition

+ UUID string

+ func (in *ClickhouseUserStatus) DeepCopy() *ClickhouseUserStatus

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

type KafkaSpec

+ DiskSpace string

+ Karapace *bool

+ type OpenSearch struct

+ Spec OpenSearchSpec

+ Status ServiceStatus

+ func (in *OpenSearch) DeepCopy() *OpenSearch

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

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

+ func (o OpenSearch) AuthSecretRef() AuthSecretReference

+ func (r *OpenSearch) Default()

+ func (r *OpenSearch) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *OpenSearch) ValidateCreate() error

+ func (r *OpenSearch) ValidateDelete() error

+ func (r *OpenSearch) ValidateUpdate(old runtime.Object) error

+ type OpenSearchIndexPatterns struct

+ MaxIndexCount *int64

+ Pattern string

+ func (in *OpenSearchIndexPatterns) DeepCopy() *OpenSearchIndexPatterns

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

+ type OpenSearchIndexTemplate struct

+ MappingNestedObjectsLimit *int64

+ NumberOfReplicas *int64

+ NumberOfShards *int64

+ func (in *OpenSearchIndexTemplate) DeepCopy() *OpenSearchIndexTemplate

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

+ type OpenSearchList struct

+ Items []OpenSearch

+ func (in *OpenSearchList) DeepCopy() *OpenSearchList

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

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

+ type OpenSearchPrivateAccess struct

+ Opensearch *bool

+ OpensearchDashboards *bool

+ Prometheus *bool

+ func (in *OpenSearchPrivateAccess) DeepCopy() *OpenSearchPrivateAccess

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

+ type OpenSearchPrivatelinkAccess struct

+ Opensearch *bool

+ OpensearchDashboards *bool

+ func (in *OpenSearchPrivatelinkAccess) DeepCopy() *OpenSearchPrivatelinkAccess

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

+ type OpenSearchPublicAccess struct

+ Opensearch *bool

+ OpensearchDashboards *bool

+ Prometheus *bool

+ func (in *OpenSearchPublicAccess) DeepCopy() *OpenSearchPublicAccess

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

+ type OpenSearchSpec struct

+ AuthSecretRef AuthSecretReference

+ ConnInfoSecretTarget ConnInfoSecretTarget

+ DiskSpace string

+ UserConfig OpenSearchUserConfig

+ func (in *OpenSearchSpec) DeepCopy() *OpenSearchSpec

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

+ type OpenSearchUserConfig struct

+ CustomDomain string

+ DisableReplicationFactorAdjustment *bool

+ IndexPatterns []OpenSearchIndexPatterns

+ IndexTemplate OpenSearchIndexTemplate

+ IpFilter []string

+ KeepIndexRefreshInterval *bool

+ MaxIndexCount *int64

+ Opensearch OpenSearchUserConfigOpenSearch

+ OpensearchDashboards OpensearchDashboards

+ OpensearchVersion string

+ PrivateAccess OpenSearchPrivateAccess

+ PrivatelinkAccess OpenSearchPrivatelinkAccess

+ ProjectToForkFrom string

+ PublicAccess OpenSearchPublicAccess

+ RecoveryBasebackupName string

+ ServiceToForkFrom string

+ StaticIps *bool

+ func (in *OpenSearchUserConfig) DeepCopy() *OpenSearchUserConfig

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

+ type OpenSearchUserConfigOpenSearch struct

+ ActionAutoCreateIndexEnabled *bool

+ ActionDestructiveRequiresName *bool

+ ClusterMaxShardsPerNode *int64

+ HttpMaxContentLength *int64

+ HttpMaxHeaderSize *int64

+ HttpMaxInitialLineLength *int64

+ IndicesFielddataCacheSize *int64

+ IndicesMemoryIndexBufferSize *int64

+ IndicesQueriesCacheSize *int64

+ IndicesQueryBoolMaxClauseCount *int64

+ ReindexRemoteWhitelist []string

+ SearchMaxBuckets *int64

+ ThreadPoolAnalyzeQueueSize *int64

+ ThreadPoolAnalyzeSize *int64

+ ThreadPoolForceMergeSize *int64

+ ThreadPoolGetQueueSize *int64

+ ThreadPoolGetSize *int64

+ ThreadPoolIndexSize *int64

+ ThreadPoolSearchQueueSize *int64

+ ThreadPoolSearchSize *int64

+ ThreadPoolSearchThrottledQueueSize *int64

+ ThreadPoolSearchThrottledSize *int64

+ ThreadPoolWriteQueueSize *int64

+ ThreadPoolWriteSize *int64

+ func (in *OpenSearchUserConfigOpenSearch) DeepCopy() *OpenSearchUserConfigOpenSearch

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

+ type OpensearchDashboards struct

+ Enabled *bool

+ MaxOldSpaceSize *int64

+ OpensearchRequestTimeout *int64

+ func (in *OpensearchDashboards) DeepCopy() *OpensearchDashboards

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

type PostgreSQLSpec

+ DiskSpace string

type RedisSpec

+ DiskSpace string

v0.2.0

Nov 17, 2021

Changes in this version

+ type Redis struct

+ Spec RedisSpec

+ Status ServiceStatus

+ func (in *Redis) DeepCopy() *Redis

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

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

+ func (r *Redis) Default()

+ func (r *Redis) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *Redis) ValidateCreate() error

+ func (r *Redis) ValidateDelete() error

+ func (r *Redis) ValidateUpdate(old runtime.Object) error

+ func (r Redis) AuthSecretRef() AuthSecretReference

+ type RedisList struct

+ Items []Redis

+ func (in *RedisList) DeepCopy() *RedisList

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

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

+ type RedisMigration struct

+ Dbname string

+ Host string

+ IgnoreDbs string

+ Password string

+ Port *int64

+ Ssl *bool

+ Username string

+ func (in *RedisMigration) DeepCopy() *RedisMigration

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

+ type RedisPrivateAccess struct

+ Prometheus *bool

+ Redis *bool

+ func (in *RedisPrivateAccess) DeepCopy() *RedisPrivateAccess

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

+ type RedisPrivatelinkAccess struct

+ Redis *bool

+ func (in *RedisPrivatelinkAccess) DeepCopy() *RedisPrivatelinkAccess

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

+ type RedisPublicAccess struct

+ Prometheus *bool

+ Redis *bool

+ func (in *RedisPublicAccess) DeepCopy() *RedisPublicAccess

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

+ type RedisSpec struct

+ AuthSecretRef AuthSecretReference

+ ConnInfoSecretTarget ConnInfoSecretTarget

+ UserConfig RedisUserConfig

+ func (in *RedisSpec) DeepCopy() *RedisSpec

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

+ type RedisUserConfig struct

+ IPFilter []string

+ Migration RedisMigration

+ PrivateAccess RedisPrivateAccess

+ PrivatelinkAccess RedisPrivatelinkAccess

+ ProjectToForkFrom string

+ PublicAccess RedisPublicAccess

+ RecoveryBasebackupName string

+ RedisAclChannelsDefault string

+ RedisIoThreads *int64

+ RedisLfuDecayTime *int64

+ RedisLfuLogFactor *int64

+ RedisMaxmemoryPolicy string

+ RedisNotifyKeyspaceEvents string

+ RedisNumberOfDatabases *int64

+ RedisPersistence string

+ RedisPubsubClientOutputBufferLimit *int64

+ RedisSsl *bool

+ RedisTimeout *int64

+ ServiceToForkFrom string

+ StaticIps *bool

+ func (in *RedisUserConfig) DeepCopy() *RedisUserConfig

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

v0.1.1

Sep 13, 2021

v0.1.0

Sep 10, 2021

Changes in this version

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var GroupVersion = schema.GroupVersion

+ var SchemeBuilder = &scheme.Builder

+ type AuthSecretReference struct

+ Key string

+ Name string

+ func (in *AuthSecretReference) DeepCopy() *AuthSecretReference

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

+ type ConnInfoSecretTarget struct

+ Name string

+ func (in *ConnInfoSecretTarget) DeepCopy() *ConnInfoSecretTarget

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

+ type ConnectionPool struct

+ Spec ConnectionPoolSpec

+ Status ConnectionPoolStatus

+ func (cp ConnectionPool) AuthSecretRef() AuthSecretReference

+ func (in *ConnectionPool) DeepCopy() *ConnectionPool

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

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

+ func (r *ConnectionPool) Default()

+ func (r *ConnectionPool) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *ConnectionPool) ValidateCreate() error

+ func (r *ConnectionPool) ValidateDelete() error

+ func (r *ConnectionPool) ValidateUpdate(old runtime.Object) error

+ type ConnectionPoolList struct

+ Items []ConnectionPool

+ func (in *ConnectionPoolList) DeepCopy() *ConnectionPoolList

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

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

+ type ConnectionPoolSpec struct

+ AuthSecretRef AuthSecretReference

+ ConnInfoSecretTarget ConnInfoSecretTarget

+ DatabaseName string

+ PoolMode string

+ PoolSize int

+ Project string

+ ServiceName string

+ Username string

+ func (in *ConnectionPoolSpec) DeepCopy() *ConnectionPoolSpec

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

+ type ConnectionPoolStatus struct

+ Conditions []metav1.Condition

+ func (in *ConnectionPoolStatus) DeepCopy() *ConnectionPoolStatus

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

+ type Database struct

+ Spec DatabaseSpec

+ Status DatabaseStatus

+ 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 struct

+ Items []Database

+ func (in *DatabaseList) DeepCopy() *DatabaseList

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

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

+ type DatabaseSpec struct

+ AuthSecretRef AuthSecretReference

+ LcCollate string

+ LcCtype string

+ Project string

+ ServiceName string

+ TerminationProtection bool

+ func (in *DatabaseSpec) DeepCopy() *DatabaseSpec

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

+ type DatabaseStatus struct

+ Conditions []metav1.Condition

+ func (in *DatabaseStatus) DeepCopy() *DatabaseStatus

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

+ type KafkServiceKafkaConnectUserConfig struct

+ ConnectorClientConfigOverridePolicy string

+ ConsumerAutoOffsetReset string

+ ConsumerFetchMaxBytes *int64

+ ConsumerIsolationLevel string

+ ConsumerMaxPartitionFetchBytes *int64

+ ConsumerMaxPollIntervalMs *int64

+ ConsumerMaxPollRecords *int64

+ OffsetFlushIntervalMs *int64

+ OffsetFlushTimeoutMs *int64

+ ProducerMaxRequestSize *int64

+ SessionTimeoutMs *int64

+ func (in *KafkServiceKafkaConnectUserConfig) DeepCopy() *KafkServiceKafkaConnectUserConfig

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

+ type Kafka struct

+ Spec KafkaSpec

+ Status ServiceStatus

+ func (in *Kafka) DeepCopy() *Kafka

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

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

+ func (kfk Kafka) AuthSecretRef() AuthSecretReference

+ func (r *Kafka) Default()

+ func (r *Kafka) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *Kafka) ValidateCreate() error

+ func (r *Kafka) ValidateDelete() error

+ func (r *Kafka) ValidateUpdate(old runtime.Object) error

+ type KafkaACL struct

+ Spec KafkaACLSpec

+ Status KafkaACLStatus

+ 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 struct

+ Items []KafkaACL

+ func (in *KafkaACLList) DeepCopy() *KafkaACLList

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

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

+ type KafkaACLSpec struct

+ AuthSecretRef AuthSecretReference

+ Permission string

+ Project string

+ ServiceName string

+ Topic string

+ Username string

+ func (in *KafkaACLSpec) DeepCopy() *KafkaACLSpec

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

+ type KafkaACLStatus struct

+ Conditions []metav1.Condition

+ ID string

+ func (in *KafkaACLStatus) DeepCopy() *KafkaACLStatus

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

+ type KafkaAuthenticationMethodsUserConfig struct

+ Certificate *bool

+ Sasl *bool

+ func (in *KafkaAuthenticationMethodsUserConfig) DeepCopy() *KafkaAuthenticationMethodsUserConfig

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

+ type KafkaConnect struct

+ Spec KafkaConnectSpec

+ Status ServiceStatus

+ func (in *KafkaConnect) DeepCopy() *KafkaConnect

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

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

+ func (kfkc KafkaConnect) AuthSecretRef() AuthSecretReference

+ func (r *KafkaConnect) Default()

+ func (r *KafkaConnect) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *KafkaConnect) ValidateCreate() error

+ func (r *KafkaConnect) ValidateDelete() error

+ func (r *KafkaConnect) ValidateUpdate(old runtime.Object) error

+ type KafkaConnectList struct

+ Items []KafkaConnect

+ func (in *KafkaConnectList) DeepCopy() *KafkaConnectList

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

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

+ type KafkaConnectPrivateAccessUserConfig struct

+ KafkaConnect *bool

+ Prometheus *bool

+ func (in *KafkaConnectPrivateAccessUserConfig) DeepCopy() *KafkaConnectPrivateAccessUserConfig

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

+ type KafkaConnectPublicAccessUserConfig struct

+ KafkaConnect *bool

+ Prometheus *bool

+ func (in *KafkaConnectPublicAccessUserConfig) DeepCopy() *KafkaConnectPublicAccessUserConfig

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

+ type KafkaConnectSpec struct

+ AuthSecretRef AuthSecretReference

+ UserConfig KafkaConnectUserConfig

+ func (in *KafkaConnectSpec) DeepCopy() *KafkaConnectSpec

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

+ type KafkaConnectUserConfig struct

+ ConnectorClientConfigOverridePolicy string

+ ConsumerAutoOffsetReset string

+ ConsumerFetchMaxBytes *int64

+ ConsumerIsolationLevel string

+ ConsumerMaxPartitionFetchBytes *int64

+ ConsumerMaxPollIntervalMs *int64

+ ConsumerMaxPollRecords *int64

+ OffsetFlushIntervalMs *int64

+ PrivateAccess KafkaConnectPrivateAccessUserConfig

+ ProducerMaxRequestSize *int64

+ PublicAccess KafkaConnectPublicAccessUserConfig

+ SessionTimeoutMs *int64

+ func (in *KafkaConnectUserConfig) DeepCopy() *KafkaConnectUserConfig

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

+ type KafkaConnector struct

+ Spec KafkaConnectorSpec

+ Status KafkaConnectorStatus

+ func (in *KafkaConnector) DeepCopy() *KafkaConnector

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

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

+ func (kfk KafkaConnector) AuthSecretRef() AuthSecretReference

+ 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 struct

+ Items []KafkaConnector

+ func (in *KafkaConnectorList) DeepCopy() *KafkaConnectorList

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

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

+ type KafkaConnectorPluginStatus struct

+ Author string

+ Class string

+ DocURL string

+ Title string

+ Type string

+ Version string

+ func (in *KafkaConnectorPluginStatus) DeepCopy() *KafkaConnectorPluginStatus

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

+ type KafkaConnectorSpec struct

+ AuthSecretRef AuthSecretReference

+ ConnectorClass string

+ Project string

+ ServiceName string

+ UserConfig map[string]string

+ func (in *KafkaConnectorSpec) DeepCopy() *KafkaConnectorSpec

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

+ type KafkaConnectorStatus struct

+ Conditions []metav1.Condition

+ PluginStatus KafkaConnectorPluginStatus

+ State string

+ TasksStatus KafkaConnectorTasksStatus

+ func (in *KafkaConnectorStatus) DeepCopy() *KafkaConnectorStatus

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

+ type KafkaConnectorTasksStatus struct

+ Failed uint

+ Paused uint

+ Running uint

+ StackTrace string

+ Total uint

+ Unassigned uint

+ Unknown uint

+ func (in *KafkaConnectorTasksStatus) DeepCopy() *KafkaConnectorTasksStatus

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

+ type KafkaList struct

+ Items []Kafka

+ func (in *KafkaList) DeepCopy() *KafkaList

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

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

+ type KafkaPrivateAccessUserConfig struct

+ Prometheus *bool

+ func (in *KafkaPrivateAccessUserConfig) DeepCopy() *KafkaPrivateAccessUserConfig

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

+ type KafkaPublicAccessUserConfig struct

+ Kafka *bool

+ KafkaConnect *bool

+ KafkaRest *bool

+ Prometheus *bool

+ SchemaRegistry *bool

+ func (in *KafkaPublicAccessUserConfig) DeepCopy() *KafkaPublicAccessUserConfig

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

+ type KafkaRestUserConfig struct

+ ConsumerEnableAutoCommit *bool

+ ConsumerRequestMaxBytes *int64

+ ConsumerRequestTimeoutMs *int64

+ CustomDomain string

+ ProducerAcks string

+ ProducerLingerMs *int64

+ PublicAccess KafkaPublicAccessUserConfig

+ SimpleconsumerPoolSizeMax *int64

+ func (in *KafkaRestUserConfig) DeepCopy() *KafkaRestUserConfig

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

+ type KafkaSchema struct

+ Spec KafkaSchemaSpec

+ Status KafkaSchemaStatus

+ func (in *KafkaSchema) DeepCopy() *KafkaSchema

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

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

+ func (kfks KafkaSchema) AuthSecretRef() AuthSecretReference

+ 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 struct

+ Items []KafkaSchema

+ func (in *KafkaSchemaList) DeepCopy() *KafkaSchemaList

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

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

+ type KafkaSchemaRegistryConfig struct

+ LeaderEligibility *bool

+ TopicName string

+ func (in *KafkaSchemaRegistryConfig) DeepCopy() *KafkaSchemaRegistryConfig

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

+ type KafkaSchemaSpec struct

+ AuthSecretRef AuthSecretReference

+ CompatibilityLevel string

+ Project string

+ Schema string

+ ServiceName string

+ SubjectName string

+ func (in *KafkaSchemaSpec) DeepCopy() *KafkaSchemaSpec

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

+ type KafkaSchemaStatus struct

+ Conditions []metav1.Condition

+ Version int

+ func (in *KafkaSchemaStatus) DeepCopy() *KafkaSchemaStatus

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

+ type KafkaSpec struct

+ AuthSecretRef AuthSecretReference

+ ConnInfoSecretTarget ConnInfoSecretTarget

+ UserConfig KafkaUserConfig

+ func (in *KafkaSpec) DeepCopy() *KafkaSpec

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

+ type KafkaSubKafkaUserConfig struct

+ AutoCreateTopicsEnable *bool

+ CompressionType string

+ ConnectionsMaxIdleMs *int64

+ DefaultReplicationFactor *int64

+ GroupMaxSessionTimeoutMs *int64

+ GroupMinSessionTimeoutMs *int64

+ LogCleanerDeleteRetentionMs *int64

+ LogCleanerMaxCompactionLagMs *int64

+ LogCleanerMinCleanableRatio *int64

+ LogCleanerMinCompactionLagMs *int64

+ LogCleanupPolicy string

+ LogFlushIntervalMessages *int64

+ LogFlushIntervalMs *int64

+ LogIndexIntervalBytes *int64

+ LogIndexSizeMaxBytes *int64

+ LogMessageDownconversionEnable *bool

+ LogMessageTimestampDifferenceMaxMs *int64

+ LogMessageTimestampType string

+ LogPreallocate *bool

+ LogRetentionBytes *int64

+ LogRetentionHours *int64

+ LogRetentionMs *int64

+ LogRollJitterMs *int64

+ LogRollMs *int64

+ LogSegmentBytes *int64

+ LogSegmentDeleteDelayMs *int64

+ MaxConnectionsPerIP *int64

+ MaxIncrementalFetchSessionCacheSlots *int64

+ MessageMaxBytes *int64

+ MinInsyncReplicas *int64

+ NumPartitions *int64

+ OffsetsRetentionMinutes *int64

+ ProducerPurgatoryPurgeIntervalRequests *int64

+ ReplicaFetchMaxBytes *int64

+ ReplicaFetchResponseMaxBytes *int64

+ SocketRequestMaxBytes *int64

+ func (in *KafkaSubKafkaUserConfig) DeepCopy() *KafkaSubKafkaUserConfig

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

+ type KafkaTopic struct

+ Spec KafkaTopicSpec

+ Status KafkaTopicStatus

+ func (in *KafkaTopic) DeepCopy() *KafkaTopic

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

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

+ func (kfkt KafkaTopic) AuthSecretRef() AuthSecretReference

+ func (r *KafkaTopic) Default()

+ func (r *KafkaTopic) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *KafkaTopic) ValidateCreate() error

+ func (r *KafkaTopic) ValidateDelete() error

+ func (r *KafkaTopic) ValidateUpdate(old runtime.Object) error

+ type KafkaTopicConfig struct

+ CleanupPolicy string

+ CompressionType string

+ DeleteRetentionMs *int64

+ FileDeleteDelayMs *int64

+ FlushMessages *int64

+ FlushMs *int64

+ IndexIntervalBytes *int64

+ MaxCompactionLagMs *int64

+ MaxMessageBytes *int64

+ MessageDownconversionEnable *bool

+ MessageFormatVersion string

+ MessageTimestampDifferenceMaxMs *int64

+ MessageTimestampType string

+ MinCompactionLagMs *int64

+ MinInsyncReplicas *int64

+ Preallocate *bool

+ RetentionBytes *int64

+ RetentionMs *int64

+ SegmentBytes *int64

+ SegmentIndexBytes *int64

+ SegmentJitterMs *int64

+ SegmentMs *int64

+ UncleanLeaderElectionEnable *bool

+ func (in *KafkaTopicConfig) DeepCopy() *KafkaTopicConfig

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

+ type KafkaTopicList struct

+ Items []KafkaTopic

+ func (in *KafkaTopicList) DeepCopy() *KafkaTopicList

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

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

+ type KafkaTopicSpec struct

+ AuthSecretRef AuthSecretReference

+ Config KafkaTopicConfig

+ Partitions int

+ Project string

+ Replication int

+ ServiceName string

+ Tags []KafkaTopicTag

+ TerminationProtection bool

+ func (in *KafkaTopicSpec) DeepCopy() *KafkaTopicSpec

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

+ type KafkaTopicStatus struct

+ Conditions []metav1.Condition

+ State string

+ func (in *KafkaTopicStatus) DeepCopy() *KafkaTopicStatus

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

+ type KafkaTopicTag struct

+ Key string

+ Value string

+ func (in *KafkaTopicTag) DeepCopy() *KafkaTopicTag

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

+ type KafkaUserConfig struct

+ IPFilter []string

+ Kafka KafkaSubKafkaUserConfig

+ KafkaAuthenticationMethods KafkaAuthenticationMethodsUserConfig

+ KafkaConnect *bool

+ KafkaConnectConfig KafkServiceKafkaConnectUserConfig

+ KafkaRest *bool

+ KafkaRestConfig KafkaRestUserConfig

+ KafkaVersion string

+ PrivateAccess KafkaPrivateAccessUserConfig

+ SchemaRegistry *bool

+ SchemaRegistryConfig KafkaSchemaRegistryConfig

+ func (in *KafkaUserConfig) DeepCopy() *KafkaUserConfig

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

+ type MigrationUserConfig struct

+ Dbname string

+ Host string

+ Password string

+ Port *int64

+ Ssl *bool

+ Username string

+ func (in *MigrationUserConfig) DeepCopy() *MigrationUserConfig

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

+ type PgLookoutUserConfig struct

+ MaxFailoverReplicationTimeLag *int64

+ func (in *PgLookoutUserConfig) DeepCopy() *PgLookoutUserConfig

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

+ type PgbouncerUserConfig struct

+ IgnoreStartupParameters []string

+ ServerResetQueryAlways *bool

+ func (in *PgbouncerUserConfig) DeepCopy() *PgbouncerUserConfig

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

+ type PostgreSQL struct

+ Spec PostgreSQLSpec

+ Status ServiceStatus

+ func (in *PostgreSQL) DeepCopy() *PostgreSQL

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

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

+ func (pg PostgreSQL) AuthSecretRef() AuthSecretReference

+ func (r *PostgreSQL) Default()

+ func (r *PostgreSQL) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *PostgreSQL) ValidateCreate() error

+ func (r *PostgreSQL) ValidateDelete() error

+ func (r *PostgreSQL) ValidateUpdate(old runtime.Object) error

+ type PostgreSQLList struct

+ Items []PostgreSQL

+ func (in *PostgreSQLList) DeepCopy() *PostgreSQLList

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

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

+ type PostgreSQLSpec struct

+ AuthSecretRef AuthSecretReference

+ ConnInfoSecretTarget ConnInfoSecretTarget

+ UserConfig PostgreSQLUserconfig

+ func (in *PostgreSQLSpec) DeepCopy() *PostgreSQLSpec

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

+ type PostgreSQLSubUserConfig struct

+ AutovacuumAnalyzeScaleFactor *int64

+ AutovacuumAnalyzeThreshold *int64

+ AutovacuumFreezeMaxAge *int64

+ AutovacuumMaxWorkers *int64

+ AutovacuumNaptime *int64

+ AutovacuumVacuumCostDelay *int64

+ AutovacuumVacuumCostLimit *int64

+ AutovacuumVacuumScaleFactor *int64

+ AutovacuumVacuumThreshold *int64

+ DeadlockTimeout *int64

+ IdleInTransactionSessionTimeout *int64

+ Jit *bool

+ LogAutovacuumMinDuration *int64

+ LogErrorVerbosity string

+ LogMinDurationStatement *int64

+ MaxFilesPerProcess *int64

+ MaxLocksPerTransaction *int64

+ MaxLogicalReplicationWorkers *int64

+ MaxParallelWorkers *int64

+ MaxParallelWorkersPerGather *int64

+ MaxPredLocksPerTransaction *int64

+ MaxPreparedTransactions *int64

+ MaxReplicationSlots *int64

+ MaxStackDepth *int64

+ MaxStandbyArchiveDelay *int64

+ MaxStandbyStreamingDelay *int64

+ MaxWalSenders *int64

+ MaxWorkerProcesses *int64

+ PgPartmanBgwInterval *int64

+ PgPartmanBgwRole string

+ PgStatStatementsTrack string

+ TempFileLimit *int64

+ Timezone string

+ TrackActivityQuerySize *int64

+ TrackCommitTimestamp string

+ TrackFunctions string

+ WalSenderTimeout *int64

+ WalWriterDelay *int64

+ func (in *PostgreSQLSubUserConfig) DeepCopy() *PostgreSQLSubUserConfig

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

+ type PostgreSQLUserconfig struct

+ AdminPassword string

+ AdminUsername string

+ BackupHour *int64

+ BackupMinute *int64

+ IPFilter []string

+ Migration MigrationUserConfig

+ Pg PostgreSQLSubUserConfig

+ PgServiceToForkFrom string

+ PgVersion string

+ Pgbouncer PgbouncerUserConfig

+ Pglookout PgLookoutUserConfig

+ PrivateAccess PrivateAccessUserConfig

+ PublicAccess PublicAccessUserConfig

+ RecoveryTargetTime string

+ ServiceToForkFrom string

+ SharedBuffersPercentage *int64

+ SynchronousReplication string

+ Timescaledb TimescaledbUserConfig

+ Variant string

+ WorkMem *int64

+ func (in *PostgreSQLUserconfig) DeepCopy() *PostgreSQLUserconfig

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

+ type PrivateAccessUserConfig struct

+ Pg *bool

+ Pgbouncer *bool

+ Prometheus *bool

+ func (in *PrivateAccessUserConfig) DeepCopy() *PrivateAccessUserConfig

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

+ type Project struct

+ Spec ProjectSpec

+ Status ProjectStatus

+ func (in *Project) DeepCopy() *Project

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

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

+ func (proj Project) AuthSecretRef() AuthSecretReference

+ func (r *Project) Default()

+ func (r *Project) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *Project) ValidateCreate() error

+ func (r *Project) ValidateDelete() error

+ func (r *Project) ValidateUpdate(old runtime.Object) error

+ type ProjectList struct

+ Items []Project

+ func (in *ProjectList) DeepCopy() *ProjectList

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

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

+ type ProjectSpec struct

+ AccountID string

+ AuthSecretRef AuthSecretReference

+ BillingAddress string

+ BillingCurrency string

+ BillingEmails []string

+ BillingExtraText string

+ BillingGroupID string

+ CardID string

+ Cloud string

+ ConnInfoSecretTarget ConnInfoSecretTarget

+ CopyFromProject string

+ CountryCode string

+ TechnicalEmails []string

+ func (in *ProjectSpec) DeepCopy() *ProjectSpec

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

+ type ProjectStatus struct

+ AvailableCredits string

+ Conditions []metav1.Condition

+ Country string

+ EstimatedBalance string

+ PaymentMethod string

+ VatID string

+ func (in *ProjectStatus) DeepCopy() *ProjectStatus

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

+ type ProjectVPC struct

+ Spec ProjectVPCSpec

+ Status ProjectVPCStatus

+ func (in *ProjectVPC) DeepCopy() *ProjectVPC

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

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

+ func (pvpc ProjectVPC) AuthSecretRef() AuthSecretReference

+ func (r *ProjectVPC) Default()

+ func (r *ProjectVPC) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *ProjectVPC) ValidateCreate() error

+ func (r *ProjectVPC) ValidateDelete() error

+ func (r *ProjectVPC) ValidateUpdate(old runtime.Object) error

+ type ProjectVPCList struct

+ Items []ProjectVPC

+ func (in *ProjectVPCList) DeepCopy() *ProjectVPCList

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

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

+ type ProjectVPCSpec struct

+ AuthSecretRef AuthSecretReference

+ CloudName string

+ NetworkCidr string

+ Project string

+ func (in *ProjectVPCSpec) DeepCopy() *ProjectVPCSpec

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

+ type ProjectVPCStatus struct

+ Conditions []metav1.Condition

+ ID string

+ State string

+ func (in *ProjectVPCStatus) DeepCopy() *ProjectVPCStatus

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

+ type PublicAccessUserConfig struct

+ Pg *bool

+ Pgbouncer *bool

+ Prometheus *bool

+ func (in *PublicAccessUserConfig) DeepCopy() *PublicAccessUserConfig

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

+ type ServiceCommonSpec struct

+ CloudName string

+ MaintenanceWindowDow string

+ MaintenanceWindowTime string

+ Plan string

+ Project string

+ ProjectVPCID string

+ TerminationProtection bool

+ func (in *ServiceCommonSpec) DeepCopy() *ServiceCommonSpec

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

+ type ServiceIntegration struct

+ Spec ServiceIntegrationSpec

+ Status ServiceIntegrationStatus

+ func (in *ServiceIntegration) DeepCopy() *ServiceIntegration

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

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

+ func (r *ServiceIntegration) Default()

+ func (r *ServiceIntegration) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *ServiceIntegration) ValidateCreate() error

+ func (r *ServiceIntegration) ValidateDelete() error

+ func (r *ServiceIntegration) ValidateUpdate(old runtime.Object) error

+ func (svcint ServiceIntegration) AuthSecretRef() AuthSecretReference

+ type ServiceIntegrationDatadogUserConfig struct

+ ExcludeConsumerGroups []string

+ ExcludeTopics []string

+ IncludeConsumerGroups []string

+ IncludeTopics []string

+ KafkaCustomMetrics []string

+ func (in *ServiceIntegrationDatadogUserConfig) DeepCopy() *ServiceIntegrationDatadogUserConfig

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

+ type ServiceIntegrationKafkaConnect struct

+ ConfigStorageTopic string

+ GroupID string

+ OffsetStorageTopic string

+ StatusStorageTopic string

+ func (in *ServiceIntegrationKafkaConnect) DeepCopy() *ServiceIntegrationKafkaConnect

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

+ type ServiceIntegrationKafkaConnectUserConfig struct

+ KafkaConnect ServiceIntegrationKafkaConnect

+ func (in *ServiceIntegrationKafkaConnectUserConfig) DeepCopy() *ServiceIntegrationKafkaConnectUserConfig

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

+ type ServiceIntegrationKafkaLogsUserConfig struct

+ KafkaTopic string

+ func (in *ServiceIntegrationKafkaLogsUserConfig) DeepCopy() *ServiceIntegrationKafkaLogsUserConfig

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

+ type ServiceIntegrationList struct

+ Items []ServiceIntegration

+ func (in *ServiceIntegrationList) DeepCopy() *ServiceIntegrationList

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

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

+ type ServiceIntegrationMetricsUserConfig struct

+ Database string

+ RetentionDays int

+ RoUsername string

+ Username string

+ func (in *ServiceIntegrationMetricsUserConfig) DeepCopy() *ServiceIntegrationMetricsUserConfig

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

+ type ServiceIntegrationSpec struct

+ AuthSecretRef AuthSecretReference

+ DatadogUserConfig ServiceIntegrationDatadogUserConfig

+ DestinationEndpointID string

+ DestinationServiceName string

+ IntegrationType string

+ KafkaConnectUserConfig ServiceIntegrationKafkaConnectUserConfig

+ KafkaLogsUserConfig ServiceIntegrationKafkaLogsUserConfig

+ MetricsUserConfig ServiceIntegrationMetricsUserConfig

+ Project string

+ SourceEndpointID string

+ SourceServiceName string

+ func (in *ServiceIntegrationSpec) DeepCopy() *ServiceIntegrationSpec

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

+ type ServiceIntegrationStatus struct

+ Conditions []metav1.Condition

+ ID string

+ func (in *ServiceIntegrationStatus) DeepCopy() *ServiceIntegrationStatus

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

+ type ServiceStatus struct

+ Conditions []metav1.Condition

+ State string

+ func (in *ServiceStatus) DeepCopy() *ServiceStatus

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

+ type ServiceUser struct

+ Spec ServiceUserSpec

+ Status ServiceUserStatus

+ func (in *ServiceUser) DeepCopy() *ServiceUser

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

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

+ func (r *ServiceUser) Default()

+ func (r *ServiceUser) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *ServiceUser) ValidateCreate() error

+ func (r *ServiceUser) ValidateDelete() error

+ func (r *ServiceUser) ValidateUpdate(old runtime.Object) error

+ func (svcusr ServiceUser) AuthSecretRef() AuthSecretReference

+ type ServiceUserList struct

+ Items []ServiceUser

+ func (in *ServiceUserList) DeepCopy() *ServiceUserList

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

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

+ type ServiceUserSpec struct

+ AuthSecretRef AuthSecretReference

+ Authentication string

+ ConnInfoSecretTarget ConnInfoSecretTarget

+ Project string

+ ServiceName string

+ func (in *ServiceUserSpec) DeepCopy() *ServiceUserSpec

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

+ type ServiceUserStatus struct

+ Conditions []metav1.Condition

+ Type string

+ func (in *ServiceUserStatus) DeepCopy() *ServiceUserStatus

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

+ type TimescaledbUserConfig struct

+ MaxBackgroundWorkers *int64

+ func (in *TimescaledbUserConfig) DeepCopy() *TimescaledbUserConfig

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

v0.1.0-rc.1

Sep 8, 2021

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