v1alpha2

package

Go to main page

Versions in this module

v0

v0.49.0-rc.0

Nov 9, 2024

v0.48.1

Sep 30, 2024

v0.48.0

Sep 27, 2024

Changes in this version

+ const ResourceCodeCassandra

+ const ResourceKindCassandra

+ const ResourcePluralCassandra

+ const ResourceSingularCassandra

+ type Cassandra struct

+ Spec CassandraSpec

+ Status CassandraStatus

+ func (in *Cassandra) DeepCopy() *Cassandra

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

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

+ func (r *Cassandra) AppBindingMeta() appcat.AppBindingMeta

+ func (r *Cassandra) ConfigSecretName() string

+ func (r *Cassandra) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

+ func (r *Cassandra) Default()

+ func (r *Cassandra) DefaultUserCredSecretName(username string) string

+ func (r *Cassandra) Finalizer() string

+ func (r *Cassandra) GetAuthSecretName() string

+ func (r *Cassandra) GetConnectionScheme() string

+ func (r *Cassandra) GetSeed() string

+ func (r *Cassandra) GoverningServiceName() string

+ func (r *Cassandra) OffshootLabels() map[string]string

+ func (r *Cassandra) OffshootName() string

+ func (r *Cassandra) OffshootRackLabels(petSetName string) map[string]string

+ func (r *Cassandra) OffshootRackName(value string) string

+ func (r *Cassandra) OffshootRackPetSetName(rackName string) string

+ func (r *Cassandra) OffshootRackSelectors(petSetName string, extraSelectors ...map[string]string) map[string]string

+ func (r *Cassandra) OffshootSelectors(extraSelectors ...map[string]string) map[string]string

+ func (r *Cassandra) Owner() *meta.OwnerReference

+ func (r *Cassandra) PVCName(alias string) string

+ func (r *Cassandra) PetSetName() string

+ func (r *Cassandra) PodLabels(extraLabels ...map[string]string) map[string]string

+ func (r *Cassandra) PrimaryServiceDNS() string

+ func (r *Cassandra) RackGoverningServiceDNS(petSetName string, replicaNo int) string

+ func (r *Cassandra) RackGoverningServiceName(name string) string

+ func (r *Cassandra) RackPodLabels(petSetName string, labels map[string]string, extraLabels ...map[string]string) map[string]string

+ func (r *Cassandra) ResourceFQN() string

+ func (r *Cassandra) ResourceKind() string

+ func (r *Cassandra) ResourcePlural() string

+ func (r *Cassandra) ResourceSingular() string

+ func (r *Cassandra) ServiceName() string

+ func (r *Cassandra) SetDefaults()

+ func (r *Cassandra) SetHealthCheckerDefaults()

+ func (r *Cassandra) ValidateCreate() (admission.Warnings, error)

+ func (r *Cassandra) ValidateCreateOrUpdate() error

+ func (r *Cassandra) ValidateDelete() (admission.Warnings, error)

+ func (r *Cassandra) ValidateUpdate(old runtime.Object) (admission.Warnings, error)

+ func (r *Cassandra) ValidateVersion(db *Cassandra) error

+ type CassandraApp struct

+ func (in *CassandraApp) DeepCopy() *CassandraApp

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

+ func (r CassandraApp) Name() string

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

+ 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

+ AuthSecret *SecretReference

+ ConfigSecret *core.LocalObjectReference

+ DeletionPolicy TerminationPolicy

+ DisableSecurity bool

+ HealthChecker kmapi.HealthCheckSpec

+ PodTemplate *ofst.PodTemplateSpec

+ Replicas *int32

+ ServiceTemplates []NamedServiceTemplateSpec

+ Storage *core.PersistentVolumeClaimSpec

+ StorageType StorageType

+ Topology *Topology

+ Version string

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

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

+ type CassandraStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase DatabasePhase

+ func (in *CassandraStatus) DeepCopy() *CassandraStatus

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

type ClickHouse

+ func (c *ClickHouse) GetInternalAuthTokenName() string

+ func (c *ClickHouse) KeeperGoverningServiceName() string

+ func (c *ClickHouse) KeeperPodLabels(extraLabels ...map[string]string) map[string]string

+ func (c *ClickHouse) KeeperPrimaryServiceDNS() string

+ func (c *ClickHouse) KeeperServiceName() string

+ func (c *ClickHouse) OffshootClickHouseKeeperHostPort() (string, int32)

+ func (c *ClickHouse) OffshootInternalKeeperSecretName() string

+ func (c *ClickHouse) OffshootKeeperLabels() map[string]string

+ func (c *ClickHouse) OffshootKeeperName() string

+ func (c *ClickHouse) OffshootKeeperSelectors(extraSelectors ...map[string]string) map[string]string

+ func (c *ClickHouse) ServiceLabels(alias ServiceAlias, extraLabels ...map[string]string) map[string]string

+ func (c *ClickHouse) StatsService() mona.StatsAccessor

+ func (c *ClickHouse) StatsServiceLabels() map[string]string

+ func (r *ClickHouse) KeeperConfigSecretName() string

+ type ClickHouseKeeper struct

+ ExternallyManaged bool

+ Node *ClickHouseKeeperNode

+ Spec *ClickHouseKeeperSpec

+ func (in *ClickHouseKeeper) DeepCopy() *ClickHouseKeeper

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

+ type ClickHouseKeeperSpec struct

+ PodTemplate *ofst.PodTemplateSpec

+ Replicas *int32

+ Storage *core.PersistentVolumeClaimSpec

+ StorageType StorageType

+ func (in *ClickHouseKeeperSpec) DeepCopy() *ClickHouseKeeperSpec

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

type ClickHouseSpec

+ ConfigSecret *core.LocalObjectReference

+ Halted bool

+ Monitor *mona.AgentSpec

+ type ClickHouseStatsService struct

+ func (cs ClickHouseStatsService) GetNamespace() string

+ func (cs ClickHouseStatsService) Path() string

+ func (cs ClickHouseStatsService) Scheme() string

+ func (cs ClickHouseStatsService) ServiceMonitorAdditionalLabels() map[string]string

+ func (cs ClickHouseStatsService) ServiceMonitorName() string

+ func (cs ClickHouseStatsService) ServiceName() string

+ func (cs ClickHouseStatsService) TLSConfig() *promapi.TLSConfig

+ func (in *ClickHouseStatsService) DeepCopy() *ClickHouseStatsService

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

type DruidSpec

+ Init *InitSpec

type MSSQLServerSpec

+ ConfigSecret *core.LocalObjectReference

+ type RackSpec struct

+ Name string

+ PodTemplate *ofst.PodTemplateSpec

+ Replicas *int32

+ Storage *core.PersistentVolumeClaimSpec

+ StorageType StorageType

+ func (in *RackSpec) DeepCopy() *RackSpec

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

type Solr

+ func (s *Solr) CertSecretVolumeMountPath(configDir string, cert string) string

+ func (s *Solr) CertSecretVolumeName(alias SolrCertificateAlias) string

+ func (s *Solr) CertificateName(alias SolrCertificateAlias) string

+ func (s *Solr) ClientCertificateCN(alias SolrCertificateAlias) string

+ func (s *Solr) GetCertSecretName(alias SolrCertificateAlias) string

+ func (s *Solr) SetTLSDefaults()

+ type SolrCertificateAlias string

+ const SolrCACert

+ const SolrClientCert

+ const SolrHTTPCert

+ const SolrServerCert

+ const SolrTransportCert

type SolrSpec

+ ClientAuthSSL string

+ KeystoreSecret *core.LocalObjectReference

+ type Topology struct

+ Rack []RackSpec

+ func (in *Topology) DeepCopy() *Topology

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

v0.47.0

Aug 21, 2024

Changes in this version

+ func Convert_Slice_v1_Container_To_v1alpha2_CoordinatorSpec(in *[]corev1.Container, out *CoordinatorSpec, s conversion.Scope) error

+ func Convert_v1_Age_To_v1alpha2_Age(in *v1.Age, out *Age, s conversion.Scope) error

+ func Convert_v1_AllowedConsumers_To_v1alpha2_AllowedConsumers(in *v1.AllowedConsumers, out *AllowedConsumers, s conversion.Scope) error

+ func Convert_v1_ArbiterSpec_To_v1alpha2_ArbiterSpec(in *v1.ArbiterSpec, out *ArbiterSpec, s conversion.Scope) error

+ func Convert_v1_ArchiverRecovery_To_v1alpha2_ArchiverRecovery(in *v1.ArchiverRecovery, out *ArchiverRecovery, s conversion.Scope) error

+ func Convert_v1_Archiver_To_v1alpha2_Archiver(in *v1.Archiver, out *Archiver, s conversion.Scope) error

+ func Convert_v1_AutoOpsSpec_To_v1alpha2_AutoOpsSpec(in *v1.AutoOpsSpec, out *AutoOpsSpec, s conversion.Scope) error

+ func Convert_v1_ConnectionPoolConfig_To_v1alpha2_ConnectionPoolConfig(in *v1.ConnectionPoolConfig, out *ConnectionPoolConfig, s conversion.Scope) error

+ func Convert_v1_ConsumerNamespaces_To_v1alpha2_ConsumerNamespaces(in *v1.ConsumerNamespaces, out *ConsumerNamespaces, s conversion.Scope) error

+ func Convert_v1_Database_To_v1alpha2_Database(in *v1.Database, out *Database, s conversion.Scope) error

+ func Convert_v1_ElasticsearchClusterTopology_To_v1alpha2_ElasticsearchClusterTopology(in *v1.ElasticsearchClusterTopology, out *ElasticsearchClusterTopology, ...) error

+ func Convert_v1_ElasticsearchList_To_v1alpha2_ElasticsearchList(in *v1.ElasticsearchList, out *ElasticsearchList, s conversion.Scope) error

+ func Convert_v1_ElasticsearchNode_To_v1alpha2_ElasticsearchNode(in *v1.ElasticsearchNode, out *ElasticsearchNode, s conversion.Scope) error

+ func Convert_v1_ElasticsearchRoleMapSpec_To_v1alpha2_ElasticsearchRoleMapSpec(in *v1.ElasticsearchRoleMapSpec, out *ElasticsearchRoleMapSpec, ...) error

+ func Convert_v1_ElasticsearchSpec_To_v1alpha2_ElasticsearchSpec(in *v1.ElasticsearchSpec, out *ElasticsearchSpec, s conversion.Scope) error

+ func Convert_v1_ElasticsearchStatus_To_v1alpha2_ElasticsearchStatus(in *v1.ElasticsearchStatus, out *ElasticsearchStatus, s conversion.Scope) error

+ func Convert_v1_ElasticsearchUserSpec_To_v1alpha2_ElasticsearchUserSpec(in *v1.ElasticsearchUserSpec, out *ElasticsearchUserSpec, s conversion.Scope) error

+ func Convert_v1_Elasticsearch_To_v1alpha2_Elasticsearch(in *v1.Elasticsearch, out *Elasticsearch, s conversion.Scope) error

+ func Convert_v1_GitRepo_To_v1alpha2_GitRepo(in *v1.GitRepo, out *GitRepo, s conversion.Scope) error

+ func Convert_v1_InitSpec_To_v1alpha2_InitSpec(in *v1.InitSpec, out *InitSpec, s conversion.Scope) error

+ func Convert_v1_KafkaApp_To_v1alpha2_KafkaApp(in *v1.KafkaApp, out *KafkaApp, s conversion.Scope) error

+ func Convert_v1_KafkaBrokerCapacity_To_v1alpha2_KafkaBrokerCapacity(in *v1.KafkaBrokerCapacity, out *KafkaBrokerCapacity, s conversion.Scope) error

+ func Convert_v1_KafkaClusterTopology_To_v1alpha2_KafkaClusterTopology(in *v1.KafkaClusterTopology, out *KafkaClusterTopology, s conversion.Scope) error

+ func Convert_v1_KafkaCruiseControl_To_v1alpha2_KafkaCruiseControl(in *v1.KafkaCruiseControl, out *KafkaCruiseControl, s conversion.Scope) error

+ func Convert_v1_KafkaList_To_v1alpha2_KafkaList(in *v1.KafkaList, out *KafkaList, s conversion.Scope) error

+ func Convert_v1_KafkaNode_To_v1alpha2_KafkaNode(in *v1.KafkaNode, out *KafkaNode, s conversion.Scope) error

+ func Convert_v1_KafkaSpec_To_v1alpha2_KafkaSpec(in *v1.KafkaSpec, out *KafkaSpec, s conversion.Scope) error

+ func Convert_v1_KafkaStatus_To_v1alpha2_KafkaStatus(in *v1.KafkaStatus, out *KafkaStatus, s conversion.Scope) error

+ func Convert_v1_Kafka_To_v1alpha2_Kafka(in *v1.Kafka, out *Kafka, s conversion.Scope) error

+ func Convert_v1_KernelSettings_To_v1alpha2_KernelSettings(in *v1.KernelSettings, out *KernelSettings, s conversion.Scope) error

+ func Convert_v1_MariaDBList_To_v1alpha2_MariaDBList(in *v1.MariaDBList, out *MariaDBList, s conversion.Scope) error

+ func Convert_v1_MariaDBSpec_To_v1alpha2_MariaDBSpec(in *v1.MariaDBSpec, out *MariaDBSpec, s conversion.Scope) error

+ func Convert_v1_MariaDBStatus_To_v1alpha2_MariaDBStatus(in *v1.MariaDBStatus, out *MariaDBStatus, s conversion.Scope) error

+ func Convert_v1_MariaDB_To_v1alpha2_MariaDB(in *v1.MariaDB, out *MariaDB, s conversion.Scope) error

+ func Convert_v1_MemcachedList_To_v1alpha2_MemcachedList(in *v1.MemcachedList, out *MemcachedList, s conversion.Scope) error

+ func Convert_v1_MemcachedSpec_To_v1alpha2_MemcachedSpec(in *v1.MemcachedSpec, out *MemcachedSpec, s conversion.Scope) error

+ func Convert_v1_MemcachedStatus_To_v1alpha2_MemcachedStatus(in *v1.MemcachedStatus, out *MemcachedStatus, s conversion.Scope) error

+ func Convert_v1_Memcached_To_v1alpha2_Memcached(in *v1.Memcached, out *Memcached, s conversion.Scope) error

+ func Convert_v1_MongoArbiterNode_To_v1alpha2_MongoArbiterNode(in *v1.MongoArbiterNode, out *MongoArbiterNode, s conversion.Scope) error

+ func Convert_v1_MongoDBConfigNode_To_v1alpha2_MongoDBConfigNode(in *v1.MongoDBConfigNode, out *MongoDBConfigNode, s conversion.Scope) error

+ func Convert_v1_MongoDBList_To_v1alpha2_MongoDBList(in *v1.MongoDBList, out *MongoDBList, s conversion.Scope) error

+ func Convert_v1_MongoDBMongosNode_To_v1alpha2_MongoDBMongosNode(in *v1.MongoDBMongosNode, out *MongoDBMongosNode, s conversion.Scope) error

+ func Convert_v1_MongoDBNode_To_v1alpha2_MongoDBNode(in *v1.MongoDBNode, out *MongoDBNode, s conversion.Scope) error

+ func Convert_v1_MongoDBReplicaSet_To_v1alpha2_MongoDBReplicaSet(in *v1.MongoDBReplicaSet, out *MongoDBReplicaSet, s conversion.Scope) error

+ func Convert_v1_MongoDBShardNode_To_v1alpha2_MongoDBShardNode(in *v1.MongoDBShardNode, out *MongoDBShardNode, s conversion.Scope) error

+ func Convert_v1_MongoDBShardingTopology_To_v1alpha2_MongoDBShardingTopology(in *v1.MongoDBShardingTopology, out *MongoDBShardingTopology, ...) error

+ func Convert_v1_MongoDBSpec_To_v1alpha2_MongoDBSpec(in *v1.MongoDBSpec, out *MongoDBSpec, s conversion.Scope) error

+ func Convert_v1_MongoDBStatus_To_v1alpha2_MongoDBStatus(in *v1.MongoDBStatus, out *MongoDBStatus, s conversion.Scope) error

+ func Convert_v1_MongoDB_To_v1alpha2_MongoDB(in *v1.MongoDB, out *MongoDB, s conversion.Scope) error

+ func Convert_v1_MongoHiddenNode_To_v1alpha2_MongoHiddenNode(in *v1.MongoHiddenNode, out *MongoHiddenNode, s conversion.Scope) error

+ func Convert_v1_MySQLGroupSpec_To_v1alpha2_MySQLGroupSpec(in *v1.MySQLGroupSpec, out *MySQLGroupSpec, s conversion.Scope) error

+ func Convert_v1_MySQLInnoDBClusterSpec_To_v1alpha2_MySQLInnoDBClusterSpec(in *v1.MySQLInnoDBClusterSpec, out *MySQLInnoDBClusterSpec, s conversion.Scope) error

+ func Convert_v1_MySQLList_To_v1alpha2_MySQLList(in *v1.MySQLList, out *MySQLList, s conversion.Scope) error

+ func Convert_v1_MySQLRouterSpec_To_v1alpha2_MySQLRouterSpec(in *v1.MySQLRouterSpec, out *MySQLRouterSpec, s conversion.Scope) error

+ func Convert_v1_MySQLSpec_To_v1alpha2_MySQLSpec(in *v1.MySQLSpec, out *MySQLSpec, s conversion.Scope) error

+ func Convert_v1_MySQLStatus_To_v1alpha2_MySQLStatus(in *v1.MySQLStatus, out *MySQLStatus, s conversion.Scope) error

+ func Convert_v1_MySQLTopology_To_v1alpha2_MySQLTopology(in *v1.MySQLTopology, out *MySQLTopology, s conversion.Scope) error

+ func Convert_v1_MySQLUser_To_v1alpha2_MySQLUser(in *v1.MySQLUser, out *MySQLUser, s conversion.Scope) error

+ func Convert_v1_MySQL_To_v1alpha2_MySQL(in *v1.MySQL, out *MySQL, s conversion.Scope) error

+ func Convert_v1_NamedServiceTemplateSpec_To_v1alpha2_NamedServiceTemplateSpec(in *v1.NamedServiceTemplateSpec, out *NamedServiceTemplateSpec, ...) error

+ func Convert_v1_PerconaXtraDBList_To_v1alpha2_PerconaXtraDBList(in *v1.PerconaXtraDBList, out *PerconaXtraDBList, s conversion.Scope) error

+ func Convert_v1_PerconaXtraDBSpec_To_v1alpha2_PerconaXtraDBSpec(in *v1.PerconaXtraDBSpec, out *PerconaXtraDBSpec, s conversion.Scope) error

+ func Convert_v1_PerconaXtraDBStatus_To_v1alpha2_PerconaXtraDBStatus(in *v1.PerconaXtraDBStatus, out *PerconaXtraDBStatus, s conversion.Scope) error

+ func Convert_v1_PerconaXtraDB_To_v1alpha2_PerconaXtraDB(in *v1.PerconaXtraDB, out *PerconaXtraDB, s conversion.Scope) error

+ func Convert_v1_PgBouncerList_To_v1alpha2_PgBouncerList(in *v1.PgBouncerList, out *PgBouncerList, s conversion.Scope) error

+ func Convert_v1_PgBouncerSpec_To_v1alpha2_PgBouncerSpec(in *v1.PgBouncerSpec, out *PgBouncerSpec, s conversion.Scope) error

+ func Convert_v1_PgBouncerStatus_To_v1alpha2_PgBouncerStatus(in *v1.PgBouncerStatus, out *PgBouncerStatus, s conversion.Scope) error

+ func Convert_v1_PgBouncer_To_v1alpha2_PgBouncer(in *v1.PgBouncer, out *PgBouncer, s conversion.Scope) error

+ func Convert_v1_PodTemplateSpec_To_v2_PodTemplateSpec(in *ofstv1.PodTemplateSpec, out *ofstv2.PodTemplateSpec, s conversion.Scope) error

+ func Convert_v1_PostgreLeaderElectionConfig_To_v1alpha2_PostgreLeaderElectionConfig(in *v1.PostgreLeaderElectionConfig, out *PostgreLeaderElectionConfig, ...) error

+ func Convert_v1_PostgresList_To_v1alpha2_PostgresList(in *v1.PostgresList, out *PostgresList, s conversion.Scope) error

+ func Convert_v1_PostgresReplication_To_v1alpha2_PostgresReplication(in *v1.PostgresReplication, out *PostgresReplication, s conversion.Scope) error

+ func Convert_v1_PostgresSpec_To_v1alpha2_PostgresSpec(in *v1.PostgresSpec, out *PostgresSpec, s conversion.Scope) error

+ func Convert_v1_PostgresStatus_To_v1alpha2_PostgresStatus(in *v1.PostgresStatus, out *PostgresStatus, s conversion.Scope) error

+ func Convert_v1_Postgres_To_v1alpha2_Postgres(in *v1.Postgres, out *Postgres, s conversion.Scope) error

+ func Convert_v1_ProxySQLConfiguration_To_v1alpha2_ProxySQLConfiguration(in *v1.ProxySQLConfiguration, out *ProxySQLConfiguration, s conversion.Scope) error

+ func Convert_v1_ProxySQLList_To_v1alpha2_ProxySQLList(in *v1.ProxySQLList, out *ProxySQLList, s conversion.Scope) error

+ func Convert_v1_ProxySQLSpec_To_v1alpha2_ProxySQLSpec(in *v1.ProxySQLSpec, out *ProxySQLSpec, s conversion.Scope) error

+ func Convert_v1_ProxySQLStatus_To_v1alpha2_ProxySQLStatus(in *v1.ProxySQLStatus, out *ProxySQLStatus, s conversion.Scope) error

+ func Convert_v1_ProxySQL_To_v1alpha2_ProxySQL(in *v1.ProxySQL, out *ProxySQL, s conversion.Scope) error

+ func Convert_v1_RecoveryTarget_To_v1alpha2_RecoveryTarget(in *v1.RecoveryTarget, out *RecoveryTarget, s conversion.Scope) error

+ func Convert_v1_RedisClusterSpec_To_v1alpha2_RedisClusterSpec(in *v1.RedisClusterSpec, out *RedisClusterSpec, s conversion.Scope) error

+ func Convert_v1_RedisList_To_v1alpha2_RedisList(in *v1.RedisList, out *RedisList, s conversion.Scope) error

+ func Convert_v1_RedisSentinelList_To_v1alpha2_RedisSentinelList(in *v1.RedisSentinelList, out *RedisSentinelList, s conversion.Scope) error

+ func Convert_v1_RedisSentinelRef_To_v1alpha2_RedisSentinelRef(in *v1.RedisSentinelRef, out *RedisSentinelRef, s conversion.Scope) error

+ func Convert_v1_RedisSentinelSpec_To_v1alpha2_RedisSentinelSpec(in *v1.RedisSentinelSpec, out *RedisSentinelSpec, s conversion.Scope) error

+ func Convert_v1_RedisSentinelStatus_To_v1alpha2_RedisSentinelStatus(in *v1.RedisSentinelStatus, out *RedisSentinelStatus, s conversion.Scope) error

+ func Convert_v1_RedisSentinel_To_v1alpha2_RedisSentinel(in *v1.RedisSentinel, out *RedisSentinel, s conversion.Scope) error

+ func Convert_v1_RedisSpec_To_v1alpha2_RedisSpec(in *v1.RedisSpec, out *RedisSpec, s conversion.Scope) error

+ func Convert_v1_RedisStatus_To_v1alpha2_RedisStatus(in *v1.RedisStatus, out *RedisStatus, s conversion.Scope) error

+ func Convert_v1_Redis_To_v1alpha2_Redis(in *v1.Redis, out *Redis, s conversion.Scope) error

+ func Convert_v1_RemoteReplicaSpec_To_v1alpha2_RemoteReplicaSpec(in *v1.RemoteReplicaSpec, out *RemoteReplicaSpec, s conversion.Scope) error

+ func Convert_v1_ScriptSourceSpec_To_v1alpha2_ScriptSourceSpec(in *v1.ScriptSourceSpec, out *ScriptSourceSpec, s conversion.Scope) error

+ func Convert_v1_SecretReference_To_v1alpha2_SecretReference(in *v1.SecretReference, out *SecretReference, s conversion.Scope) error

+ func Convert_v1_SemiSyncSpec_To_v1alpha2_SemiSyncSpec(in *v1.SemiSyncSpec, out *SemiSyncSpec, s conversion.Scope) error

+ func Convert_v1_SystemUserSecretsSpec_To_v1alpha2_SystemUserSecretsSpec(in *v1.SystemUserSecretsSpec, out *SystemUserSecretsSpec, s conversion.Scope) error

+ func Convert_v1alpha2_Age_To_v1_Age(in *Age, out *v1.Age, s conversion.Scope) error

+ func Convert_v1alpha2_AllowedConsumers_To_v1_AllowedConsumers(in *AllowedConsumers, out *v1.AllowedConsumers, s conversion.Scope) error

+ func Convert_v1alpha2_ArbiterSpec_To_v1_ArbiterSpec(in *ArbiterSpec, out *v1.ArbiterSpec, s conversion.Scope) error

+ func Convert_v1alpha2_ArchiverRecovery_To_v1_ArchiverRecovery(in *ArchiverRecovery, out *v1.ArchiverRecovery, s conversion.Scope) error

+ func Convert_v1alpha2_Archiver_To_v1_Archiver(in *Archiver, out *v1.Archiver, s conversion.Scope) error

+ func Convert_v1alpha2_AutoOpsSpec_To_v1_AutoOpsSpec(in *AutoOpsSpec, out *v1.AutoOpsSpec, s conversion.Scope) error

+ func Convert_v1alpha2_ConnectionPoolConfig_To_v1_ConnectionPoolConfig(in *ConnectionPoolConfig, out *v1.ConnectionPoolConfig, s conversion.Scope) error

+ func Convert_v1alpha2_ConsumerNamespaces_To_v1_ConsumerNamespaces(in *ConsumerNamespaces, out *v1.ConsumerNamespaces, s conversion.Scope) error

+ func Convert_v1alpha2_CoordinatorSpec_To_Slice_v1_Container(in *CoordinatorSpec, out *[]corev1.Container, s conversion.Scope) error

+ func Convert_v1alpha2_Database_To_v1_Database(in *Database, out *v1.Database, s conversion.Scope) error

+ func Convert_v1alpha2_ElasticsearchClusterTopology_To_v1_ElasticsearchClusterTopology(in *ElasticsearchClusterTopology, out *v1.ElasticsearchClusterTopology, ...) error

+ func Convert_v1alpha2_ElasticsearchList_To_v1_ElasticsearchList(in *ElasticsearchList, out *v1.ElasticsearchList, s conversion.Scope) error

+ func Convert_v1alpha2_ElasticsearchNode_To_v1_ElasticsearchNode(in *ElasticsearchNode, out *v1.ElasticsearchNode, s conversion.Scope) error

+ func Convert_v1alpha2_ElasticsearchRoleMapSpec_To_v1_ElasticsearchRoleMapSpec(in *ElasticsearchRoleMapSpec, out *v1.ElasticsearchRoleMapSpec, ...) error

+ func Convert_v1alpha2_ElasticsearchSpec_To_v1_ElasticsearchSpec(in *ElasticsearchSpec, out *v1.ElasticsearchSpec, s conversion.Scope) error

+ func Convert_v1alpha2_ElasticsearchStatus_To_v1_ElasticsearchStatus(in *ElasticsearchStatus, out *v1.ElasticsearchStatus, s conversion.Scope) error

+ func Convert_v1alpha2_ElasticsearchUserSpec_To_v1_ElasticsearchUserSpec(in *ElasticsearchUserSpec, out *v1.ElasticsearchUserSpec, s conversion.Scope) error

+ func Convert_v1alpha2_Elasticsearch_To_v1_Elasticsearch(in *Elasticsearch, out *v1.Elasticsearch, s conversion.Scope) error

+ func Convert_v1alpha2_GitRepo_To_v1_GitRepo(in *GitRepo, out *v1.GitRepo, s conversion.Scope) error

+ func Convert_v1alpha2_InitSpec_To_v1_InitSpec(in *InitSpec, out *v1.InitSpec, s conversion.Scope) error

+ func Convert_v1alpha2_KafkaApp_To_v1_KafkaApp(in *KafkaApp, out *v1.KafkaApp, s conversion.Scope) error

+ func Convert_v1alpha2_KafkaBrokerCapacity_To_v1_KafkaBrokerCapacity(in *KafkaBrokerCapacity, out *v1.KafkaBrokerCapacity, s conversion.Scope) error

+ func Convert_v1alpha2_KafkaClusterTopology_To_v1_KafkaClusterTopology(in *KafkaClusterTopology, out *v1.KafkaClusterTopology, s conversion.Scope) error

+ func Convert_v1alpha2_KafkaCruiseControl_To_v1_KafkaCruiseControl(in *KafkaCruiseControl, out *v1.KafkaCruiseControl, s conversion.Scope) error

+ func Convert_v1alpha2_KafkaList_To_v1_KafkaList(in *KafkaList, out *v1.KafkaList, s conversion.Scope) error

+ func Convert_v1alpha2_KafkaNode_To_v1_KafkaNode(in *KafkaNode, out *v1.KafkaNode, s conversion.Scope) error

+ func Convert_v1alpha2_KafkaSpec_To_v1_KafkaSpec(in *KafkaSpec, out *v1.KafkaSpec, s conversion.Scope) error

+ func Convert_v1alpha2_KafkaStatus_To_v1_KafkaStatus(in *KafkaStatus, out *v1.KafkaStatus, s conversion.Scope) error

+ func Convert_v1alpha2_Kafka_To_v1_Kafka(in *Kafka, out *v1.Kafka, s conversion.Scope) error

+ func Convert_v1alpha2_KernelSettings_To_v1_KernelSettings(in *KernelSettings, out *v1.KernelSettings, s conversion.Scope) error

+ func Convert_v1alpha2_MariaDBList_To_v1_MariaDBList(in *MariaDBList, out *v1.MariaDBList, s conversion.Scope) error

+ func Convert_v1alpha2_MariaDBSpec_To_v1_MariaDBSpec(in *MariaDBSpec, out *v1.MariaDBSpec, s conversion.Scope) error

+ func Convert_v1alpha2_MariaDBStatus_To_v1_MariaDBStatus(in *MariaDBStatus, out *v1.MariaDBStatus, s conversion.Scope) error

+ func Convert_v1alpha2_MariaDB_To_v1_MariaDB(in *MariaDB, out *v1.MariaDB, s conversion.Scope) error

+ func Convert_v1alpha2_MemcachedList_To_v1_MemcachedList(in *MemcachedList, out *v1.MemcachedList, s conversion.Scope) error

+ func Convert_v1alpha2_MemcachedSpec_To_v1_MemcachedSpec(in *MemcachedSpec, out *v1.MemcachedSpec, s conversion.Scope) error

+ func Convert_v1alpha2_MemcachedStatus_To_v1_MemcachedStatus(in *MemcachedStatus, out *v1.MemcachedStatus, s conversion.Scope) error

+ func Convert_v1alpha2_Memcached_To_v1_Memcached(in *Memcached, out *v1.Memcached, s conversion.Scope) error

+ func Convert_v1alpha2_MongoArbiterNode_To_v1_MongoArbiterNode(in *MongoArbiterNode, out *v1.MongoArbiterNode, s conversion.Scope) error

+ func Convert_v1alpha2_MongoDBConfigNode_To_v1_MongoDBConfigNode(in *MongoDBConfigNode, out *v1.MongoDBConfigNode, s conversion.Scope) error

+ func Convert_v1alpha2_MongoDBList_To_v1_MongoDBList(in *MongoDBList, out *v1.MongoDBList, s conversion.Scope) error

+ func Convert_v1alpha2_MongoDBMongosNode_To_v1_MongoDBMongosNode(in *MongoDBMongosNode, out *v1.MongoDBMongosNode, s conversion.Scope) error

+ func Convert_v1alpha2_MongoDBNode_To_v1_MongoDBNode(in *MongoDBNode, out *v1.MongoDBNode, s conversion.Scope) error

+ func Convert_v1alpha2_MongoDBReplicaSet_To_v1_MongoDBReplicaSet(in *MongoDBReplicaSet, out *v1.MongoDBReplicaSet, s conversion.Scope) error

+ func Convert_v1alpha2_MongoDBShardNode_To_v1_MongoDBShardNode(in *MongoDBShardNode, out *v1.MongoDBShardNode, s conversion.Scope) error

+ func Convert_v1alpha2_MongoDBShardingTopology_To_v1_MongoDBShardingTopology(in *MongoDBShardingTopology, out *v1.MongoDBShardingTopology, ...) error

+ func Convert_v1alpha2_MongoDBSpec_To_v1_MongoDBSpec(in *MongoDBSpec, out *v1.MongoDBSpec, s conversion.Scope) error

+ func Convert_v1alpha2_MongoDBStatus_To_v1_MongoDBStatus(in *MongoDBStatus, out *v1.MongoDBStatus, s conversion.Scope) error

+ func Convert_v1alpha2_MongoDB_To_v1_MongoDB(in *MongoDB, out *v1.MongoDB, s conversion.Scope) error

+ func Convert_v1alpha2_MongoHiddenNode_To_v1_MongoHiddenNode(in *MongoHiddenNode, out *v1.MongoHiddenNode, s conversion.Scope) error

+ func Convert_v1alpha2_MySQLGroupSpec_To_v1_MySQLGroupSpec(in *MySQLGroupSpec, out *v1.MySQLGroupSpec, s conversion.Scope) error

+ func Convert_v1alpha2_MySQLInnoDBClusterSpec_To_v1_MySQLInnoDBClusterSpec(in *MySQLInnoDBClusterSpec, out *v1.MySQLInnoDBClusterSpec, s conversion.Scope) error

+ func Convert_v1alpha2_MySQLList_To_v1_MySQLList(in *MySQLList, out *v1.MySQLList, s conversion.Scope) error

+ func Convert_v1alpha2_MySQLRouterSpec_To_v1_MySQLRouterSpec(in *MySQLRouterSpec, out *v1.MySQLRouterSpec, s conversion.Scope) error

+ func Convert_v1alpha2_MySQLSpec_To_v1_MySQLSpec(in *MySQLSpec, out *v1.MySQLSpec, s conversion.Scope) error

+ func Convert_v1alpha2_MySQLStatus_To_v1_MySQLStatus(in *MySQLStatus, out *v1.MySQLStatus, s conversion.Scope) error

+ func Convert_v1alpha2_MySQLTopology_To_v1_MySQLTopology(in *MySQLTopology, out *v1.MySQLTopology, s conversion.Scope) error

+ func Convert_v1alpha2_MySQLUser_To_v1_MySQLUser(in *MySQLUser, out *v1.MySQLUser, s conversion.Scope) error

+ func Convert_v1alpha2_MySQL_To_v1_MySQL(in *MySQL, out *v1.MySQL, s conversion.Scope) error

+ func Convert_v1alpha2_NamedServiceTemplateSpec_To_v1_NamedServiceTemplateSpec(in *NamedServiceTemplateSpec, out *v1.NamedServiceTemplateSpec, ...) error

+ func Convert_v1alpha2_PerconaXtraDBList_To_v1_PerconaXtraDBList(in *PerconaXtraDBList, out *v1.PerconaXtraDBList, s conversion.Scope) error

+ func Convert_v1alpha2_PerconaXtraDBSpec_To_v1_PerconaXtraDBSpec(in *PerconaXtraDBSpec, out *v1.PerconaXtraDBSpec, s conversion.Scope) error

+ func Convert_v1alpha2_PerconaXtraDBStatus_To_v1_PerconaXtraDBStatus(in *PerconaXtraDBStatus, out *v1.PerconaXtraDBStatus, s conversion.Scope) error

+ func Convert_v1alpha2_PerconaXtraDB_To_v1_PerconaXtraDB(in *PerconaXtraDB, out *v1.PerconaXtraDB, s conversion.Scope) error

+ func Convert_v1alpha2_PgBouncerList_To_v1_PgBouncerList(in *PgBouncerList, out *v1.PgBouncerList, s conversion.Scope) error

+ func Convert_v1alpha2_PgBouncerSpec_To_v1_PgBouncerSpec(in *PgBouncerSpec, out *v1.PgBouncerSpec, s conversion.Scope) error

+ func Convert_v1alpha2_PgBouncerStatus_To_v1_PgBouncerStatus(in *PgBouncerStatus, out *v1.PgBouncerStatus, s conversion.Scope) error

+ func Convert_v1alpha2_PgBouncer_To_v1_PgBouncer(in *PgBouncer, out *v1.PgBouncer, s conversion.Scope) error

+ func Convert_v1alpha2_PostgreLeaderElectionConfig_To_v1_PostgreLeaderElectionConfig(in *PostgreLeaderElectionConfig, out *v1.PostgreLeaderElectionConfig, ...) error

+ func Convert_v1alpha2_PostgresList_To_v1_PostgresList(in *PostgresList, out *v1.PostgresList, s conversion.Scope) error

+ func Convert_v1alpha2_PostgresReplication_To_v1_PostgresReplication(in *PostgresReplication, out *v1.PostgresReplication, s conversion.Scope) error

+ func Convert_v1alpha2_PostgresSpec_To_v1_PostgresSpec(in *PostgresSpec, out *v1.PostgresSpec, s conversion.Scope) error

+ func Convert_v1alpha2_PostgresStatus_To_v1_PostgresStatus(in *PostgresStatus, out *v1.PostgresStatus, s conversion.Scope) error

+ func Convert_v1alpha2_Postgres_To_v1_Postgres(in *Postgres, out *v1.Postgres, s conversion.Scope) error

+ func Convert_v1alpha2_ProxySQLConfiguration_To_v1_ProxySQLConfiguration(in *ProxySQLConfiguration, out *v1.ProxySQLConfiguration, s conversion.Scope) error

+ func Convert_v1alpha2_ProxySQLList_To_v1_ProxySQLList(in *ProxySQLList, out *v1.ProxySQLList, s conversion.Scope) error

+ func Convert_v1alpha2_ProxySQLSpec_To_v1_ProxySQLSpec(in *ProxySQLSpec, out *v1.ProxySQLSpec, s conversion.Scope) error

+ func Convert_v1alpha2_ProxySQLStatus_To_v1_ProxySQLStatus(in *ProxySQLStatus, out *v1.ProxySQLStatus, s conversion.Scope) error

+ func Convert_v1alpha2_ProxySQL_To_v1_ProxySQL(in *ProxySQL, out *v1.ProxySQL, s conversion.Scope) error

+ func Convert_v1alpha2_RecoveryTarget_To_v1_RecoveryTarget(in *RecoveryTarget, out *v1.RecoveryTarget, s conversion.Scope) error

+ func Convert_v1alpha2_RedisClusterSpec_To_v1_RedisClusterSpec(in *RedisClusterSpec, out *v1.RedisClusterSpec, s conversion.Scope) error

+ func Convert_v1alpha2_RedisList_To_v1_RedisList(in *RedisList, out *v1.RedisList, s conversion.Scope) error

+ func Convert_v1alpha2_RedisSentinelList_To_v1_RedisSentinelList(in *RedisSentinelList, out *v1.RedisSentinelList, s conversion.Scope) error

+ func Convert_v1alpha2_RedisSentinelRef_To_v1_RedisSentinelRef(in *RedisSentinelRef, out *v1.RedisSentinelRef, s conversion.Scope) error

+ func Convert_v1alpha2_RedisSentinelSpec_To_v1_RedisSentinelSpec(in *RedisSentinelSpec, out *v1.RedisSentinelSpec, s conversion.Scope) error

+ func Convert_v1alpha2_RedisSentinelStatus_To_v1_RedisSentinelStatus(in *RedisSentinelStatus, out *v1.RedisSentinelStatus, s conversion.Scope) error

+ func Convert_v1alpha2_RedisSentinel_To_v1_RedisSentinel(in *RedisSentinel, out *v1.RedisSentinel, s conversion.Scope) error

+ func Convert_v1alpha2_RedisSpec_To_v1_RedisSpec(in *RedisSpec, out *v1.RedisSpec, s conversion.Scope) error

+ func Convert_v1alpha2_RedisStatus_To_v1_RedisStatus(in *RedisStatus, out *v1.RedisStatus, s conversion.Scope) error

+ func Convert_v1alpha2_Redis_To_v1_Redis(in *Redis, out *v1.Redis, s conversion.Scope) error

+ func Convert_v1alpha2_RemoteReplicaSpec_To_v1_RemoteReplicaSpec(in *RemoteReplicaSpec, out *v1.RemoteReplicaSpec, s conversion.Scope) error

+ func Convert_v1alpha2_ScriptSourceSpec_To_v1_ScriptSourceSpec(in *ScriptSourceSpec, out *v1.ScriptSourceSpec, s conversion.Scope) error

+ func Convert_v1alpha2_SecretReference_To_v1_SecretReference(in *SecretReference, out *v1.SecretReference, s conversion.Scope) error

+ func Convert_v1alpha2_SemiSyncSpec_To_v1_SemiSyncSpec(in *SemiSyncSpec, out *v1.SemiSyncSpec, s conversion.Scope) error

+ func Convert_v1alpha2_SystemUserSecretsSpec_To_v1_SystemUserSecretsSpec(in *SystemUserSecretsSpec, out *v1.SystemUserSecretsSpec, s conversion.Scope) error

+ func Convert_v2_PodTemplateSpec_To_v1_PodTemplateSpec(in *ofstv2.PodTemplateSpec, out *ofstv1.PodTemplateSpec, s conversion.Scope) error

+ func RegisterConversions(s *runtime.Scheme) error

type ClickHouse

+ func (c *ClickHouse) ReplicasAreReady(lister pslister.PetSetLister) (bool, string, error)

type Druid

+ func (d *Druid) GetAppBinding(name string, namespace string) (*appcat.AppBinding, error)

+ func (d *Druid) GetDefaultPVC() *core.PersistentVolumeClaimSpec

+ func (d *Druid) GetInitConfigMapName() string

+ func (d *Druid) GetMetadataStorageName() string

+ func (d *Druid) GetZooKeeperName() string

+ func (d *Druid) SetDefaultsToMetadataStorage()

+ func (d *Druid) SetDefaultsToZooKeeperRef()

+ func (d *Druid) SetMetadataStorageObjectRef()

+ func (d *Druid) SetZooKeeperObjectRef()

type Elasticsearch

+ func (dst *Elasticsearch) ConvertFrom(srcRaw rtconv.Hub) error

+ func (src *Elasticsearch) ConvertTo(dstRaw rtconv.Hub) error

type EtcdSpec

+ DeletionPolicy TerminationPolicy

type FerretDB

+ func (f *FerretDB) GetExternalBackendClientSecretName() string

+ func (f *FerretDB) GetPersistentSecrets() []string

+ func (f *FerretDB) GetSSLModeFromAppBinding(apb *appcat.AppBinding) (PostgresSSLMode, error)

+ func (f *FerretDB) GetSecretVolumeName(secretName string) string

type FerretDBBackend

+ PostgresRef *kmapi.ObjectReference

+ Version *string

type Kafka

+ func (dst *Kafka) ConvertFrom(srcRaw rtconv.Hub) error

+ func (src *Kafka) ConvertTo(dstRaw rtconv.Hub) error

type KafkaSpec

+ Halted bool

type MSSQLServer

+ func (m MSSQLServer) StatsService() mona.StatsAccessor

+ func (m MSSQLServer) StatsServiceLabels() map[string]string

type MSSQLServerSpec

+ Archiver *Archiver

+ Monitor *mona.AgentSpec

type MariaDB

+ func (dst *MariaDB) ConvertFrom(srcRaw rtconv.Hub) error

+ func (src *MariaDB) ConvertTo(dstRaw rtconv.Hub) error

type Memcached

+ func (dst *Memcached) ConvertFrom(srcRaw rtconv.Hub) error

+ func (src *Memcached) ConvertTo(dstRaw rtconv.Hub) error

type MetadataStorage

+ ExternallyManaged bool

+ LinkedDB string

+ Version *string

type MongoDB

+ func (dst *MongoDB) ConvertFrom(srcRaw rtconv.Hub) error

+ func (src *MongoDB) ConvertTo(dstRaw rtconv.Hub) error

type MySQL

+ func (dst *MySQL) ConvertFrom(srcRaw rtconv.Hub) error

+ func (src *MySQL) ConvertTo(dstRaw rtconv.Hub) error

type PerconaXtraDB

+ func (dst *PerconaXtraDB) ConvertFrom(srcRaw rtconv.Hub) error

+ func (src *PerconaXtraDB) ConvertTo(dstRaw rtconv.Hub) error

type PgBouncer

+ func (dst *PgBouncer) ConvertFrom(srcRaw rtconv.Hub) error

+ func (src *PgBouncer) ConvertTo(dstRaw rtconv.Hub) error

type PgBouncerSpec

+ Halted bool

type PgBouncerTerminationPolicy

+ const PgBouncerDeletionPolicyHalt

type Postgres

+ func (dst *Postgres) ConvertFrom(srcRaw rtconv.Hub) error

+ func (src *Postgres) ConvertTo(dstRaw rtconv.Hub) error

type ProxySQL

+ func (dst *ProxySQL) ConvertFrom(srcRaw rtconv.Hub) error

+ func (src *ProxySQL) ConvertTo(dstRaw rtconv.Hub) error

type ProxySQLSpec

+ Halted bool

type RabbitMQ

+ func (r *RabbitMQ) DashboardServiceName() string

+ func (r *RabbitMQ) IsProtocolDisabled(protocol RabbitMQProtocol) bool

+ type RabbitMQProtocol string

+ const RabbitmqProtocolAMQP

+ const RabbitmqProtocolHTTP

+ const RabbitmqProtocolMQTT

+ const RabbitmqProtocolSTOMP

+ const RabbitmqProtocolWEBMQTT

+ const RabbitmqProtocolWEBSTOMP

type RabbitMQSpec

+ DisabledProtocols []RabbitMQProtocol

type Redis

+ func (dst *Redis) ConvertFrom(srcRaw rtconv.Hub) error

+ func (src *Redis) ConvertTo(dstRaw rtconv.Hub) error

type RedisSentinel

+ func (dst *RedisSentinel) ConvertFrom(srcRaw rtconv.Hub) error

+ func (src *RedisSentinel) ConvertTo(dstRaw rtconv.Hub) error

type ServiceAlias

+ const DashboardServiceAlias

type ZookeeperRef

+ ExternallyManaged bool

+ Version *string

v0.47.0-rc.3

Aug 14, 2024

v0.47.0-rc.2

Aug 2, 2024

v0.47.0-rc.1

Jul 11, 2024

v0.47.0-rc.0

Jul 3, 2024

v0.46.0

Jun 4, 2024

Changes in this version

+ const BackendSecretResourceVersion

+ const ClickHouseCluster

+ const ClickHouseClusterConfigDir

+ const ClickHouseClusterConfigFile

+ const ClickHouseClusterConfigVolName

+ const ClickHouseConfigDir

+ const ClickHouseConfigVolName

+ const ClickHouseContainerName

+ const ClickHouseDataDir

+ const ClickHouseDefaultHTTP

+ const ClickHouseDefaultStorageSize

+ const ClickHouseDefaultTLS

+ const ClickHouseHealthCheckerDatabase

+ const ClickHouseHealthCheckerTable

+ const ClickHouseInitContainerName

+ const ClickHouseKeeperFileConfig

+ const ClickHouseKeeperPort

+ const ClickHouseMacrosFileName

+ const ClickHouseNativeTCP

+ const ClickHouseNativeTLS

+ const ClickHouseServerConfigFile

+ const ClickHouseStandalone

+ const ClickHouseTempClusterConfigVolName

+ const ClickHouseTempConfigDir

+ const ClickHouseTempDir

+ const ClickHouseUserConfigDir

+ const ClickHouseVolumeData

+ const ClickhousePromethues

+ const KafkaKeystoreType

+ const KafkaTruststoreType

+ const KafkaTruststoreTypeJKS

+ const LabelPetSet

+ const MSSQLVolumeMountPathCACerts

+ const MSSQLVolumeMountPathSecurityCACertificates

+ const MSSQLVolumeMountPathTLS

+ const MSSQLVolumeNameCACerts

+ const MSSQLVolumeNameSecurityCACertificates

+ const MSSQLVolumeNameTLS

+ const MemcachedConfigKey

+ const MemcachedConfigVolumePath

+ const MemcachedContainerName

+ const PetSetTypeStandalone

+ const PgpoolCustomConfigFile

+ const PgpoolDatabasePortName

+ const PgpoolPcpPort

+ const PgpoolPcpPortName

+ const PgpoolPrimaryServicePortName

+ const RabbitMQDefaultSSLListenerKey

+ const RabbitMQDefaultTLSListenerVal

+ const RabbitMQSSLOptionsCAKey

+ const RabbitMQSSLOptionsCertKey

+ const RabbitMQSSLOptionsFailIfNoPeerKey

+ const RabbitMQSSLOptionsPrivateKey

+ const RabbitMQSSLOptionsVerifyKey

+ const ResourceCodeClickHouse

+ const ResourceKindClickHouse

+ const ResourcePluralClickHouse

+ const ResourceSingularClickHouse

+ type ClickHouse struct

+ Spec ClickHouseSpec

+ Status ClickHouseStatus

+ func (c *ClickHouse) AppBindingMeta() appcat.AppBindingMeta

+ func (c *ClickHouse) ClusterGoverningServiceDNS(petSetName string, replicaNo int) string

+ func (c *ClickHouse) ClusterGoverningServiceName(name string) string

+ func (c *ClickHouse) ClusterPodLabels(petSetName string, labels map[string]string, extraLabels ...map[string]string) map[string]string

+ func (c *ClickHouse) DefaultUserCredSecretName(username string) string

+ func (c *ClickHouse) Finalizer() string

+ func (c *ClickHouse) GetAuthSecretName() string

+ func (c *ClickHouse) GetConnectionScheme() string

+ func (c *ClickHouse) GoverningServiceName() string

+ func (c *ClickHouse) OffshootClusterLabels(petSetName string) map[string]string

+ func (c *ClickHouse) OffshootClusterName(value string) string

+ func (c *ClickHouse) OffshootClusterPetSetName(clusterName string, shardNo int) string

+ func (c *ClickHouse) OffshootClusterSelectors(petSetName string, extraSelectors ...map[string]string) map[string]string

+ func (c *ClickHouse) OffshootLabels() map[string]string

+ func (c *ClickHouse) OffshootName() string

+ func (c *ClickHouse) OffshootSelectors(extraSelectors ...map[string]string) map[string]string

+ func (c *ClickHouse) Owner() *meta.OwnerReference

+ func (c *ClickHouse) PVCName(alias string) string

+ func (c *ClickHouse) PetSetName() string

+ func (c *ClickHouse) PodLabels(extraLabels ...map[string]string) map[string]string

+ func (c *ClickHouse) PrimaryServiceDNS() string

+ func (c *ClickHouse) ResourceFQN() string

+ func (c *ClickHouse) ResourceKind() string

+ func (c *ClickHouse) ResourcePlural() string

+ func (c *ClickHouse) ResourceSingular() string

+ func (c *ClickHouse) ServiceName() string

+ func (c *ClickHouse) SetDefaults()

+ func (c *ClickHouse) SetHealthCheckerDefaults()

+ func (in *ClickHouse) DeepCopy() *ClickHouse

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

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

+ func (r *ClickHouse) ConfigSecretName() string

+ func (r *ClickHouse) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

+ func (r *ClickHouse) Default()

+ func (r *ClickHouse) ValidateCreate() (admission.Warnings, error)

+ func (r *ClickHouse) ValidateCreateOrUpdate() error

+ func (r *ClickHouse) ValidateDelete() (admission.Warnings, error)

+ func (r *ClickHouse) ValidateUpdate(old runtime.Object) (admission.Warnings, error)

+ func (r *ClickHouse) ValidateVersion(db *ClickHouse) error

+ type ClickHouseKeeperConfig struct

+ Node ClickHouseKeeperNode

+ func (in *ClickHouseKeeperConfig) DeepCopy() *ClickHouseKeeperConfig

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

+ type ClickHouseKeeperNode struct

+ Host string

+ Port int32

+ func (in *ClickHouseKeeperNode) DeepCopy() *ClickHouseKeeperNode

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

+ 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

+ AuthSecret *SecretReference

+ ClusterTopology *ClusterTopology

+ DeletionPolicy TerminationPolicy

+ DisableSecurity bool

+ HealthChecker kmapi.HealthCheckSpec

+ PodTemplate *ofst.PodTemplateSpec

+ Replicas *int32

+ ServiceTemplates []NamedServiceTemplateSpec

+ Storage *core.PersistentVolumeClaimSpec

+ StorageType StorageType

+ Version string

+ func (in *ClickHouseSpec) DeepCopy() *ClickHouseSpec

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

+ type ClickHouseStatus struct

+ Conditions []kmapi.Condition

+ Gateway *Gateway

+ ObservedGeneration int64

+ Phase DatabasePhase

+ func (in *ClickHouseStatus) DeepCopy() *ClickHouseStatus

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

+ type ClickhouseApp struct

+ func (in *ClickhouseApp) DeepCopy() *ClickhouseApp

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

+ func (r ClickhouseApp) Name() string

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

+ type ClusterSpec struct

+ Name string

+ PodTemplate *ofst.PodTemplateSpec

+ Replicas *int32

+ Shards *int32

+ Storage *core.PersistentVolumeClaimSpec

+ StorageType StorageType

+ func (in *ClusterSpec) DeepCopy() *ClusterSpec

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

+ type ClusterTopology struct

+ ClickHouseKeeper *ClickHouseKeeperConfig

+ Cluster []ClusterSpec

+ func (in *ClusterTopology) DeepCopy() *ClusterTopology

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

+ type Database struct

+ DatabaseName string

+ DatabaseRef appcat.AppReference

+ SyncUsers bool

+ func (in *Database) DeepCopy() *Database

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

type Druid

+ func (d *Druid) GetNodeSpec(nodeType DruidNodeRoleType) (*DruidNode, *DruidDataNode)

+ type DruidDataNode struct

+ EphemeralStorage *core.EmptyDirVolumeSource

+ Storage *core.PersistentVolumeClaimSpec

+ StorageType StorageType

+ func (in *DruidDataNode) DeepCopy() *DruidDataNode

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

type DruidSpec

+ DeletionPolicy TerminationPolicy

type FerretDBSpec

+ DeletionPolicy TerminationPolicy

type KafkaSpec

+ DeletionPolicy TerminationPolicy

type MSSQLServer

+ func (m *MSSQLServer) AvailabilityGroupName() string

+ func (m *MSSQLServer) CAProviderClassName() string

+ func (m *MSSQLServer) CertificateName(alias MSSQLServerCertificateAlias) string

+ func (m *MSSQLServer) DbmLoginSecretName() string

+ func (m *MSSQLServer) EndpointCertSecretName() string

+ func (m *MSSQLServer) GetCertSecretName(alias MSSQLServerCertificateAlias) string

+ func (m *MSSQLServer) MasterKeySecretName() string

+ func (m *MSSQLServer) ReplicasAreReady(lister pslister.PetSetLister) (bool, string, error)

+ func (m *MSSQLServer) SecretName(alias MSSQLServerCertificateAlias) string

+ func (m *MSSQLServer) SetTLSDefaults()

+ func (m *MSSQLServer) SetTLSDefaultsForInternalAuth()

+ type MSSQLServerAvailabilityGroupSpec struct

+ Databases []string

+ func (in *MSSQLServerAvailabilityGroupSpec) DeepCopy() *MSSQLServerAvailabilityGroupSpec

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

+ type MSSQLServerCertificateAlias string

+ const MSSQLServerClientCert

+ const MSSQLServerEndpointCert

+ const MSSQLServerServerCert

+ type MSSQLServerLeaderElectionConfig struct

+ ElectionTick int32

+ HeartbeatTick int32

+ Period metav1.Duration

+ TransferLeadershipInterval *metav1.Duration

+ TransferLeadershipTimeout *metav1.Duration

+ func (in *MSSQLServerLeaderElectionConfig) DeepCopy() *MSSQLServerLeaderElectionConfig

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

+ type MSSQLServerMode string

+ const MSSQLServerModeAvailabilityGroup

+ const MSSQLServerModeRemoteReplica

type MSSQLServerSpec

+ DeletionPolicy TerminationPolicy

+ TLS *SQLServerTLSConfig

+ type MSSQLServerTopology struct

+ AvailabilityGroup *MSSQLServerAvailabilityGroupSpec

+ Mode *MSSQLServerMode

+ func (in *MSSQLServerTopology) DeepCopy() *MSSQLServerTopology

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

type Memcached

+ func (m Memcached) ConfigSecretName() string

+ func (m Memcached) CustomConfigSecretName() string

type PgBouncerSpec

+ Database Database

type Pgpool

+ func (p *Pgpool) AppBindingMeta() appcat.AppBindingMeta

type PgpoolSpec

+ DeletionPolicy TerminationPolicy

type RabbitMQSpec

+ DeletionPolicy TerminationPolicy

+ type SQLServerTLSConfig struct

+ ClientTLS bool

+ func (in *SQLServerTLSConfig) DeepCopy() *SQLServerTLSConfig

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

type SinglestoreNode

+ ConfigSecret *core.LocalObjectReference

type SinglestoreSpec

+ DeletionPolicy TerminationPolicy

type SolrSpec

+ DeletionPolicy TerminationPolicy

type ZooKeeperSpec

+ DeletionPolicy TerminationPolicy

v0.45.1

Apr 27, 2024

v0.45.0

Apr 26, 2024

Changes in this version

+ const AGPrimaryReplicaReadyCondition

+ const DruidEmitterPrometheusDimensionMapPath

+ const DruidExporterPort

+ const EnvAcceptEula

+ const EnvMSSQLAgentEnabled

+ const EnvMSSQLEnableHADR

+ const EnvMSSQLSAPassword

+ const EnvMSSQLSAUsername

+ const EnvPgpoolExporterConnectionString

+ const MSSQLContainerName

+ const MSSQLCoordinatorContainerName

+ const MSSQLCoordinatorPort

+ const MSSQLDatabaseMirroringEndpointPort

+ const MSSQLDatabasePodPrimary

+ const MSSQLDatabasePodSecondary

+ const MSSQLDatabasePort

+ const MSSQLDatabasePortName

+ const MSSQLDbmLoginSecretName

+ const MSSQLEndpointCertsSecretName

+ const MSSQLInitContainerName

+ const MSSQLInternalTLSCrt

+ const MSSQLInternalTLSKey

+ const MSSQLMasterKeySecretName

+ const MSSQLPrimaryServicePortName

+ const MSSQLSAUser

+ const MSSQLSecondaryServiceAlias

+ const MSSQLSecondaryServicePortName

+ const MSSQLVolumeMountPathCerts

+ const MSSQLVolumeMountPathData

+ const MSSQLVolumeMountPathEndpointCert

+ const MSSQLVolumeMountPathInitScript

+ const MSSQLVolumeNameCerts

+ const MSSQLVolumeNameData

+ const MSSQLVolumeNameEndpointCert

+ const MSSQLVolumeNameInitScript

+ const MemcachedShardKey

+ const MySQLCustomConfigFile

+ const PgpoolExporterTlsVolumeMountPath

+ const PgpoolExporterTlsVolumeName

+ const PgpoolRootUser

+ const PgpoolTlsVolumeMountPath

+ const PgpoolTlsVolumeName

+ const PostgresCustomConfigFile

+ const RabbitMQFederationManagementPlugin

+ const RabbitMQFederationPlugin

+ const RabbitMQShovelManagementPlugin

+ const RabbitMQShovelPlugin

+ const RabbitMQWebDispatchPlugin

+ const ResourceCodeMSSQLServer

+ const ResourceKindMSSQLServer

+ const ResourcePluralMSSQLServer

+ const ResourceSingularMSSQLServer

+ const SinglestoreTLSConfigCustom

+ const SinglestoreTLSConfigFalse

+ const SinglestoreTLSConfigPreferred

+ const SinglestoreTLSConfigSkipVerify

+ const SinglestoreTLSConfigTrue

+ const SinglestoreVolumeMountPathTLS

+ const SinglestoreVolumeNameTLS

+ const SolrExporterPort

+ var DefaultResourcesMemoryIntensiveDruid = core.ResourceRequirements

+ type InternalAuthentication struct

+ EndpointCert *kmapi.TLSConfig

+ func (in *InternalAuthentication) DeepCopy() *InternalAuthentication

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

+ type MSSQLAvailabilityGroupSpec struct

+ Databases []string

+ func (in *MSSQLAvailabilityGroupSpec) DeepCopy() *MSSQLAvailabilityGroupSpec

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

+ type MSSQLLeaderElectionConfig struct

+ ElectionTick int32

+ HeartbeatTick int32

+ Period metav1.Duration

+ TransferLeadershipInterval *metav1.Duration

+ TransferLeadershipTimeout *metav1.Duration

+ func (in *MSSQLLeaderElectionConfig) DeepCopy() *MSSQLLeaderElectionConfig

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

+ type MSSQLMode string

+ const MSSQLModeAvailabilityGroup

+ const MSSQLModeRemoteReplica

+ type MSSQLServer struct

+ Spec MSSQLServerSpec

+ Status MSSQLServerStatus

+ func (in *MSSQLServer) DeepCopy() *MSSQLServer

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

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

+ func (m *MSSQLServer) AppBindingMeta() appcat.AppBindingMeta

+ func (m *MSSQLServer) ConfigSecretName() string

+ func (m *MSSQLServer) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

+ func (m *MSSQLServer) Default()

+ func (m *MSSQLServer) DefaultUserCredSecretName(username string) string

+ func (m *MSSQLServer) GetNameSpacedName() string

+ func (m *MSSQLServer) GetPersistentSecrets() []string

+ func (m *MSSQLServer) GoverningServiceName() string

+ func (m *MSSQLServer) IsAvailabilityGroup() bool

+ func (m *MSSQLServer) IsStandalone() bool

+ func (m *MSSQLServer) OffshootLabels() map[string]string

+ func (m *MSSQLServer) OffshootName() string

+ func (m *MSSQLServer) OffshootSelectors(extraSelectors ...map[string]string) map[string]string

+ func (m *MSSQLServer) Owner() *meta.OwnerReference

+ func (m *MSSQLServer) PVCName(alias string) string

+ func (m *MSSQLServer) PetSetName() string

+ func (m *MSSQLServer) PodControllerLabel(podTemplate *ofst.PodTemplateSpec) map[string]string

+ func (m *MSSQLServer) PodControllerLabels(extraLabels ...map[string]string) map[string]string

+ func (m *MSSQLServer) PodLabel(podTemplate *ofst.PodTemplateSpec) map[string]string

+ func (m *MSSQLServer) PodLabels(extraLabels ...map[string]string) map[string]string

+ func (m *MSSQLServer) PrimaryServiceDNS() string

+ func (m *MSSQLServer) ResourceFQN() string

+ func (m *MSSQLServer) ResourceKind() string

+ func (m *MSSQLServer) ResourcePlural() string

+ func (m *MSSQLServer) SecondaryServiceName() string

+ func (m *MSSQLServer) ServiceAccountName() string

+ func (m *MSSQLServer) ServiceLabels(alias ServiceAlias, extraLabels ...map[string]string) map[string]string

+ func (m *MSSQLServer) ServiceName() string

+ func (m *MSSQLServer) SetDefaults()

+ func (m *MSSQLServer) ValidateCreate() (admission.Warnings, error)

+ func (m *MSSQLServer) ValidateCreateOrUpdate() field.ErrorList

+ func (m *MSSQLServer) ValidateDelete() (admission.Warnings, error)

+ func (m *MSSQLServer) ValidateUpdate(old runtime.Object) (admission.Warnings, error)

+ func (m MSSQLServer) GetAuthSecretName() string

+ func (m MSSQLServer) SetHealthCheckerDefaults()

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

+ type MSSQLServerApp struct

+ func (in *MSSQLServerApp) DeepCopy() *MSSQLServerApp

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

+ func (m MSSQLServerApp) Name() string

+ func (m MSSQLServerApp) Type() appcat.AppType

+ type MSSQLServerList struct

+ Items []MSSQLServer

+ func (in *MSSQLServerList) DeepCopy() *MSSQLServerList

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

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

+ type MSSQLServerSpec struct

+ AuthSecret *SecretReference

+ Coordinator CoordinatorSpec

+ Halted bool

+ HealthChecker kmapi.HealthCheckSpec

+ Init *InitSpec

+ InternalAuth *InternalAuthentication

+ LeaderElection *MSSQLLeaderElectionConfig

+ PodPlacementPolicy *core.LocalObjectReference

+ PodTemplate *ofst.PodTemplateSpec

+ Replicas *int32

+ ServiceTemplates []NamedServiceTemplateSpec

+ Storage *core.PersistentVolumeClaimSpec

+ StorageType StorageType

+ TerminationPolicy TerminationPolicy

+ Topology *MSSQLTopology

+ Version string

+ func (in *MSSQLServerSpec) DeepCopy() *MSSQLServerSpec

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

+ type MSSQLServerStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase DatabasePhase

+ func (in *MSSQLServerStatus) DeepCopy() *MSSQLServerStatus

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

+ type MSSQLTopology struct

+ AvailabilityGroup *MSSQLAvailabilityGroupSpec

+ Mode *MSSQLMode

+ func (in *MSSQLTopology) DeepCopy() *MSSQLTopology

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

type Memcached

+ func (m *Memcached) SetHealthCheckerDefaults()

+ func (m Memcached) Address() string

type MemcachedSpec

+ HealthChecker kmapi.HealthCheckSpec

type NamedURL

+ Port ofst.GatewayPort

type Pgpool

+ func (p *Pgpool) CertificateName(alias PgpoolCertificateAlias) string

+ func (p *Pgpool) GetCertSecretName(alias PgpoolCertificateAlias) string

+ func (p *Pgpool) GetSSLMODE(appBinding *appcat.AppBinding) (PgpoolSSLMode, error)

+ func (p *Pgpool) IsBackendTLSEnabled() (bool, error)

+ func (p *Pgpool) SetTLSDefaults()

+ func (p *Pgpool) TLSSecretName() string

+ type PgpoolCertificateAlias string

+ const PgpoolClientCert

+ const PgpoolMetricsExporterCert

+ const PgpoolServerCert

+ type PgpoolClientAuthMode string

+ const PgpoolClientAuthModeCert

+ const PgpoolClientAuthModeMD5

+ const PgpoolClientAuthModeScram

+ type PgpoolSSLMode string

+ const PgpoolSSLModeAllow

+ const PgpoolSSLModeDisable

+ const PgpoolSSLModePrefer

+ const PgpoolSSLModeRequire

+ const PgpoolSSLModeVerifyCA

+ const PgpoolSSLModeVerifyFull

type PgpoolSpec

+ ClientAuthMode PgpoolClientAuthMode

+ SSLMode PgpoolSSLMode

+ TLS *kmapi.TLSConfig

type Singlestore

+ func (s *Singlestore) GetCertSecretName(alias SinglestoreCertificateAlias) string

v0.44.0

Mar 16, 2024

Changes in this version

+ const DruidBrokersConfigFile

+ const DruidBrokersJVMConfigFile

+ const DruidCommonConfigFile

+ const DruidCoordinatorsConfigFile

+ const DruidCoordinatorsJVMConfigFile

+ const DruidEmitter

+ const DruidEmitterLoggingLogLevel

+ const DruidEmitterPrometheus

+ const DruidEmitterPrometheusPortKey

+ const DruidEmitterPrometheusPortVal

+ const DruidEmitterPrometheusStrategy

+ const DruidExtensionPrometheusEmitter

+ const DruidHistoricalsConfigFile

+ const DruidHistoricalsJVMConfigFile

+ const DruidMetricsJVMMonitor

+ const DruidMetricsQueryCountStatsMonitor

+ const DruidMetricsServiceStatusMonitor

+ const DruidMiddleManagersConfigFile

+ const DruidMiddleManagersJVMConfigFile

+ const DruidMonitoringHistoricalMetricsMonitor

+ const DruidMonitoringMonitorsKey

+ const DruidMonitoringQueryCountStatsMonitor

+ const DruidMonitoringSegmentsStatsMonitor

+ const DruidMonitoringSysMonitor

+ const DruidMonitoringTaskCountStatsMonitor

+ const DruidMonitoringWorkerTaskCountsStatsMonitor

+ const DruidPortBrokers

+ const DruidPortCoordinators

+ const DruidPortHistoricals

+ const DruidPortMiddleManagers

+ const DruidPortOverlords

+ const DruidPortRouters

+ const DruidRoutersConfigFile

+ const DruidRoutersJVMConfigFile

+ const DruidVolumeCommonConfig

+ const EnvPgpoolExporterDatabase

+ const EnvPgpoolSSLMode

+ const EnvPgpoolService

+ const EnvPgpoolServicePort

+ const PetSetTypeAggregator

+ const PetSetTypeLeaf

+ const PgpoolDefaultSSLMode

+ const PgpoolDefaultServicePort

+ const PgpoolExporterContainerName

+ const PgpoolExporterDatabase

+ const PgpoolMonitoringDefaultServicePort

+ const ResourceKindPetSet

+ const SinglestoreExporterPort

+ const SinglestoreStudioPort

+ const SinglestoreStudioPortName

+ const SolrCloudZKCredentialsInjectorKey

+ const SolrCloudZKCredentialsInjectorValue

+ const SolrZkDigest

+ const SolrZkReadonlyDigest

+ var DefaultResourcesCoreAndMemoryIntensiveSolr = core.ResourceRequirements

+ var DefaultResourcesMemoryIntensiveSDB = core.ResourceRequirements

+ func GetDatabasePodsByPetSetLister(db metav1.Object, psLister pslister.PetSetLister, pods []core.Pod) ([]core.Pod, error)

type Druid

+ func (d *Druid) PetSetName(nodeRole DruidNodeRoleType) string

+ func (d *Druid) StatsService() mona.StatsAccessor

+ func (d *Druid) StatsServiceLabels() map[string]string

+ func (r *Druid) Finalizer() string

type DruidNode

+ PodPlacementPolicy *core.LocalObjectReference

type DruidSpec

+ Monitor *mona.AgentSpec

+ ZookeeperRef *ZookeeperRef

+ type DruidStatsService struct

+ func (in *DruidStatsService) DeepCopy() *DruidStatsService

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

+ func (ks DruidStatsService) GetNamespace() string

+ func (ks DruidStatsService) Path() string

+ func (ks DruidStatsService) Scheme() string

+ func (ks DruidStatsService) ServiceMonitorAdditionalLabels() map[string]string

+ func (ks DruidStatsService) ServiceMonitorName() string

+ func (ks DruidStatsService) ServiceName() string

+ func (ks DruidStatsService) TLSConfig() *promapi.TLSConfig

type DruidStatus

+ Gateway *Gateway

type ElasticsearchStatus

+ Gateway *Gateway

type EtcdStatus

+ Gateway *Gateway

type FerretDB

+ func (r *FerretDB) PetSetName() string

+ type FerretDBBackend struct

+ ExternallyManaged bool

+ LinkedDB string

+ Postgres *PostgresRef

+ func (in *FerretDBBackend) DeepCopy() *FerretDBBackend

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

type FerretDBSpec

+ PodPlacementPolicy *core.LocalObjectReference

type FerretDBStatus

+ Gateway *Gateway

+ type Gateway struct

+ Hostname string

+ IP string

+ Name string

+ Namespace string

+ Services []NamedServiceStatus

+ UI []NamedURL

+ func (in *Gateway) DeepCopy() *Gateway

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

type KafkaStatus

+ Gateway *Gateway

type MariaDBSpec

+ Archiver *Archiver

type MariaDBStatus

+ Gateway *Gateway

type MemcachedStatus

+ Gateway *Gateway

type MongoDBStatus

+ Gateway *Gateway

type MySQLStatus

+ Gateway *Gateway

+ type NamedServiceStatus struct

+ Alias ServiceAlias

+ Ports []ofst.ServicePort

+ func (in *NamedServiceStatus) DeepCopy() *NamedServiceStatus

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

+ type NamedURL struct

+ Alias string

+ HelmRelease *core.LocalObjectReference

+ URL string

+ func (in *NamedURL) DeepCopy() *NamedURL

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

type PerconaXtraDBStatus

+ Gateway *Gateway

type PgBouncerStatus

+ Gateway *Gateway

type Pgpool

+ func (p *Pgpool) PetSetName() string

+ func (p *Pgpool) ServiceLabels(alias ServiceAlias, extraLabels ...map[string]string) map[string]string

+ func (p Pgpool) StatsService() mona.StatsAccessor

+ func (p Pgpool) StatsServiceLabels() map[string]string

type PgpoolSpec

+ Monitor *mona.AgentSpec

+ PodPlacementPolicy *core.LocalObjectReference

+ PostgresRef *kmapi.ObjectReference

+ type PgpoolStatsService struct

+ func (in *PgpoolStatsService) DeepCopy() *PgpoolStatsService

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

+ func (p PgpoolStatsService) GetNamespace() string

+ func (p PgpoolStatsService) Path() string

+ func (p PgpoolStatsService) Scheme() string

+ func (p PgpoolStatsService) ServiceMonitorAdditionalLabels() map[string]string

+ func (p PgpoolStatsService) ServiceMonitorName() string

+ func (p PgpoolStatsService) ServiceName() string

+ func (p PgpoolStatsService) TLSConfig() *promapi.TLSConfig

type PgpoolStatus

+ Gateway *Gateway

type Postgres

+ func (p *Postgres) SetDefaultReplicationMode(postgresVersion *catalog.PostgresVersion)

+ type PostgresReplication struct

+ MaxSlotWALKeepSizeInMegaBytes *int32

+ WALLimitPolicy WALLimitPolicy

+ WalKeepSegment *int32

+ WalKeepSizeInMegaBytes *int32

+ func (in *PostgresReplication) DeepCopy() *PostgresReplication

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

type PostgresSpec

+ Replication *PostgresReplication

type PostgresStatus

+ Gateway *Gateway

type ProxySQLStatus

+ Gateway *Gateway

type RabbitMQ

+ func (r *RabbitMQ) PetSetName() string

type RabbitMQSpec

+ PodPlacementPolicy *core.LocalObjectReference

type RabbitMQStatus

+ Gateway *Gateway

type RedisStatus

+ Gateway *Gateway

type Singlestore

+ func (s *Singlestore) AggregatorPetSet() string

+ func (s *Singlestore) LeafPetSet() string

+ func (s *Singlestore) PetSetName() string

+ func (s Singlestore) StatsService() mona.StatsAccessor

+ func (s Singlestore) StatsServiceLabels() map[string]string

type SinglestoreNode

+ PodPlacementPolicy *core.LocalObjectReference

type SinglestoreSpec

+ Monitor *mona.AgentSpec

+ PodPlacementPolicy *core.LocalObjectReference

type SinglestoreStatus

+ Gateway *Gateway

type Solr

+ func (s *Solr) PetSetName(suffix string) string

+ func (s *Solr) ServiceLabels(alias ServiceAlias, extraLabels ...map[string]string) map[string]string

+ func (s *Solr) StatsService() mona.StatsAccessor

+ func (s *Solr) StatsServiceLabels() map[string]string

type SolrNode

+ PodPlacementPolicy *core.LocalObjectReference

type SolrSpec

+ Monitor *mona.AgentSpec

+ PodPlacementPolicy *core.LocalObjectReference

+ ZookeeperDigestReadonlySecret *core.LocalObjectReference

+ ZookeeperDigestSecret *core.LocalObjectReference

type SolrStatus

+ Gateway *Gateway

+ type WALLimitPolicy string

+ const ReplicationSlot

+ const WALKeepSegment

+ const WALKeepSize

type ZooKeeper

+ func (z *ZooKeeper) PetSetName() string

+ func (z *ZooKeeper) StatsService() mona.StatsAccessor

+ func (z *ZooKeeper) StatsServiceLabels() map[string]string

type ZooKeeperSpec

+ Monitor *mona.AgentSpec

+ PodPlacementPolicy *core.LocalObjectReference

type ZooKeeperStatus

+ Gateway *Gateway

+ type ZookeeperRef struct

+ PathsBase string

+ func (in *ZookeeperRef) DeepCopy() *ZookeeperRef

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

v0.43.0-rc.0

Mar 8, 2024

v0.42.1

Feb 22, 2024

v0.42.0

Feb 14, 2024

Changes in this version

+ const DruidContainerName

+ const DruidInitContainerName

+ const EnvRedisMajorRedisVersion

+ const EnvRedisMode

+ const EnvZooKeeperJVMFLags

+ const EnvZooKeeperJaasFilePath

+ const PgpoolConfigSecretMountPath

+ const PgpoolConfigVolumeName

+ const PgpoolContainerName

+ const RabbitMQExporterPort

+ const RedisCoordinatorContainerName

+ const RedisInitContainerName

+ const RedisInitVolumeName

+ const RedisInitVolumePath

+ const RedisSentinelInitContainerName

+ const StatefulSetTypeAggregator

+ const ZooKeeperJaasFilePath

+ const ZooKeeperSASLAuthLoginConfig

type RabbitMQSpec

+ Monitor *mona.AgentSpec

type ZooKeeperSpec

+ AdminServerPort int32

v0.41.0

Feb 1, 2024

Changes in this version

+ const ConfigSecretMountPath

+ const ConfigVolumeName

+ const ContainerName

+ const ContribLibs

+ const DatabasePodAggregator

+ const DatabasePodLeaf

+ const DatabasePodMaster

+ const DistLibs

+ const DruidAuthAuthenticationChain

+ const DruidAuthAuthenticationChainValueBasic

+ const DruidAuthAuthenticatorBasicAuthorizerName

+ const DruidAuthAuthenticatorBasicCredentialsValidatorType

+ const DruidAuthAuthenticatorBasicInitialAdminPassword

+ const DruidAuthAuthenticatorBasicInitialAdminPasswordEnvConfig

+ const DruidAuthAuthenticatorBasicInitialInternalClientPassword

+ const DruidAuthAuthenticatorBasicSkipOnFailure

+ const DruidAuthAuthenticatorBasicType

+ const DruidAuthAuthenticatorBasicTypeValue

+ const DruidAuthAuthorizerBasicType

+ const DruidAuthAuthorizers

+ const DruidAuthEscalatorAuthorizerName

+ const DruidAuthEscalatorInternalClientPassword

+ const DruidAuthEscalatorInternalClientUsername

+ const DruidAuthEscalatorType

+ const DruidBrokerHTTPNumOfConnections

+ const DruidCConfigDirMySQLMetadata

+ const DruidCacheSizeInBytes

+ const DruidConfigDirBrokers

+ const DruidConfigDirCommon

+ const DruidConfigDirCoordinatorOverlord

+ const DruidConfigDirHistoricals

+ const DruidConfigDirMiddleManagers

+ const DruidConfigDirRouters

+ const DruidConfigFileNameBrokers

+ const DruidConfigFileNameCommon

+ const DruidConfigFileNameCoordinators

+ const DruidConfigFileNameHistoricals

+ const DruidConfigFileNameJVM

+ const DruidConfigFileNameMiddleManagers

+ const DruidConfigFileNameRouters

+ const DruidCoordinatorAsOverlord

+ const DruidCoordinatorAsOverlordOverlordService

+ const DruidCoordinatorKillAuditLogOn

+ const DruidCoordinatorPeriod

+ const DruidCoordinatorStartDelay

+ const DruidCustomConfigDir

+ const DruidDeepStorageBaseKey

+ const DruidDeepStorageBucket

+ const DruidDeepStorageTypeKey

+ const DruidDeepStorageTypeS3

+ const DruidEnableLookupSyncOnStartup

+ const DruidExtensionAvro

+ const DruidExtensionAzure

+ const DruidExtensionBasicSecurity

+ const DruidExtensionDataSketches

+ const DruidExtensionGoogle

+ const DruidExtensionHDFS

+ const DruidExtensionKafkaIndexingService

+ const DruidExtensionKubernetes

+ const DruidExtensionLoadList

+ const DruidExtensionLoadListKey

+ const DruidExtensionMultiStageQuery

+ const DruidExtensionMySQLMetadataStorage

+ const DruidExtensionPostgreSQLMetadataStorage

+ const DruidExtensionS3

+ const DruidHealthDataOne

+ const DruidHealthDataZero

+ const DruidHistoricalCachePopulateCache

+ const DruidHistoricalCacheUseCache

+ const DruidHistoricalsSegmentCacheDir

+ const DruidHistoricalsSegmentCacheDropSegmentDelayMillis

+ const DruidHistoricalsSegmentCacheLocations

+ const DruidIndexerAuditLogEnabled

+ const DruidIndexerForkPropertyDruidProcessingBufferSizeBytes

+ const DruidIndexerLogsKillDelay

+ const DruidIndexerLogsKillDurationToRetain

+ const DruidIndexerLogsKillEnables

+ const DruidIndexerLogsKillInitialDelay

+ const DruidIndexerLogsS3Bucket

+ const DruidIndexerLogsS3Prefix

+ const DruidIndexerLogsType

+ const DruidIndexerQueueStartDelay

+ const DruidIndexerStorageType

+ const DruidIndexerTaskBaseTaskDir

+ const DruidIndexerTaskBaseTaskDirValue

+ const DruidInitContainer

+ const DruidMainConfigDir

+ const DruidMainContainer

+ const DruidManagerSegmentsPollDuration

+ const DruidMetadataStorageConnectURIPrefixMySQL

+ const DruidMetadataStorageConnectURIPrefixPostgreSQL

+ const DruidMetadataStorageConnectorConnectURI

+ const DruidMetadataStorageConnectorPassword

+ const DruidMetadataStorageConnectorPasswordEnvConfig

+ const DruidMetadataStorageConnectorUser

+ const DruidMetadataStorageCreateTables

+ const DruidMetadataStorageTypeKey

+ const DruidMiddleManagersVolumeBaseTaskDir

+ const DruidMillisToWaitBeforeDeleting

+ const DruidOperatorConfigDir

+ const DruidPlaintextPort

+ const DruidProcessingBufferSizeBytes

+ const DruidProcessingNumOfMergeBuffers

+ const DruidProcessingNumOfThreads

+ const DruidRouterHTTPNumOfConnections

+ const DruidRouterHTTPNumOfMaxThreads

+ const DruidS3AccessKey

+ const DruidS3EnablePathStyleAccess

+ const DruidS3EndpointSigningRegion

+ const DruidS3EndpointURL

+ const DruidS3SecretKey

+ const DruidSQLEnable

+ const DruidSegmentCacheLocationsDefaultValue

+ const DruidServerHTTPNumOfThreads

+ const DruidService

+ const DruidServiceNameOverlords

+ const DruidUserAdmin

+ const DruidVolumeConfigCommon

+ const DruidVolumeConfigFileNodes

+ const DruidVolumeConfigNodes

+ const DruidVolumeCustomConfig

+ const DruidVolumeHistoricalsSegmentCache

+ const DruidVolumeMainConfig

+ const DruidVolumeMiddleManagersBaseTaskDir

+ const DruidVolumeMySQLMetadataStorage

+ const DruidVolumeOperatorConfig

+ const DruidWorkerBaseTaskDirSize

+ const DruidWorkerCapacity

+ const DruidWorkerTaskBaseTaskDir

+ const DruidWorkerTaskBaseTaskDirKey

+ const DruidZKPathsBase

+ const DruidZKServiceCompress

+ const DruidZKServiceHost

+ const DruidZKServicePasswordEnvConfig

+ const DruidZKServicePasswordKey

+ const DruidZKServiceUserKey

+ const EnvDruidAdminPassword

+ const EnvDruidCoordinatorAsOverlord

+ const EnvDruidMetdataStoragePassword

+ const EnvDruidZKServicePassword

+ const EnvEnablePoolPasswd

+ const EnvFerretDBCAPath

+ const EnvFerretDBCertPath

+ const EnvFerretDBHandler

+ const EnvFerretDBKeyPath

+ const EnvFerretDBPassword

+ const EnvFerretDBPgURL

+ const EnvFerretDBTLSPort

+ const EnvFerretDBUser

+ const EnvPgpoolPasswordEncryptionMethod

+ const EnvPgpoolPcpPassword

+ const EnvPgpoolPcpUser

+ const EnvPostgresUsername

+ const EnvSkipPasswdEncryption

+ const EnvZooKeeperAdminServerHost

+ const EnvZooKeeperAdminServerPort

+ const EnvZooKeeperClientHost

+ const EnvZooKeeperClientPort

+ const EnvZooKeeperClusterName

+ const EnvZooKeeperClusterSize

+ const EnvZooKeeperDomain

+ const EnvZooKeeperLeaderPort

+ const EnvZooKeeperPassword

+ const EnvZooKeeperQuorumPort

+ const EnvZooKeeperUser

+ const FerretDBContainerName

+ const FerretDBDefaultPort

+ const FerretDBMainImage

+ const FerretDBMetricsPath

+ const FerretDBMetricsPort

+ const FerretDBServerPath

+ const FerretDBTLSPort

+ const FerretDBUser

+ const KubeDBZooKeeperRoleBindingName

+ const KubeDBZooKeeperRoleName

+ const PgpoolAuthUsername

+ const RabbitMQAMQPPort

+ const RabbitMQCertDir

+ const RabbitMQClusterNameKey

+ const RabbitMQConfigDir

+ const RabbitMQConfigFileName

+ const RabbitMQConfigVolName

+ const RabbitMQContainerName

+ const RabbitMQCustomConfigDir

+ const RabbitMQDataDir

+ const RabbitMQDefaultPasswordKey

+ const RabbitMQDefaultPasswordVal

+ const RabbitMQDefaultTCPListenerKey

+ const RabbitMQDefaultTCPListenerVal

+ const RabbitMQDefaultUserKey

+ const RabbitMQDefaultUserVal

+ const RabbitMQDiskFreeLimitKey

+ const RabbitMQDiskFreeLimitVal

+ const RabbitMQEnabledPluginsFileName

+ const RabbitMQHealthCheckerQueueName

+ const RabbitMQInitContainerName

+ const RabbitMQInterNodePort

+ const RabbitMQK8sAddressTypeKey

+ const RabbitMQK8sAddressTypeVal

+ const RabbitMQK8sHostKey

+ const RabbitMQK8sHostVal

+ const RabbitMQK8sSvcNameKey

+ const RabbitMQLogConsoleKey

+ const RabbitMQLogConsoleLevelKey

+ const RabbitMQLogConsoleLevelVal

+ const RabbitMQLogConsoleVal

+ const RabbitMQLogFileLevelKey

+ const RabbitMQLogFileLevelVal

+ const RabbitMQLoopBackUserKey

+ const RabbitMQLoopBackUserVal

+ const RabbitMQManagementPlugin

+ const RabbitMQManagementUIPort

+ const RabbitMQNodeCleanupWarningKey

+ const RabbitMQNodeCleanupWarningVal

+ const RabbitMQPartitionHandingKey

+ const RabbitMQPartitionHandingVal

+ const RabbitMQPeerDiscoveryKey

+ const RabbitMQPeerDiscoveryPort

+ const RabbitMQPeerDiscoveryVal

+ const RabbitMQPeerdiscoveryPlugin

+ const RabbitMQPluginsDir

+ const RabbitMQPluginsVolName

+ const RabbitMQQueueMasterLocatorKey

+ const RabbitMQQueueMasterLocatorVal

+ const RabbitMQTempConfigDir

+ const RabbitMQTempConfigVolName

+ const RabbitMQVolumeConfig

+ const RabbitMQVolumeCustomConfig

+ const RabbitMQVolumeData

+ const RabbitMQVolumeTempConfig

+ const ResourceCodeDruid

+ const ResourceCodeFerretDB

+ const ResourceCodePgpool

+ const ResourceCodeRabbitmq

+ const ResourceCodeSinglestore

+ const ResourceCodeSolr

+ const ResourceCodeZooKeeper

+ const ResourceKindDruid

+ const ResourceKindFerretDB

+ const ResourceKindPgpool

+ const ResourceKindRabbitmq

+ const ResourceKindSinglestore

+ const ResourceKindSolr

+ const ResourceKindZooKeeper

+ const ResourcePluralDruid

+ const ResourcePluralFerretDB

+ const ResourcePluralPgpool

+ const ResourcePluralRabbitmq

+ const ResourcePluralSinglestore

+ const ResourcePluralSolr

+ const ResourcePluralZooKeeper

+ const ResourceSingularDruid

+ const ResourceSingularFerretDB

+ const ResourceSingularPgpool

+ const ResourceSingularRabbitmq

+ const ResourceSingularSinglestore

+ const ResourceSingularSolr

+ const ResourceSingularZooKeeper

+ const SecurityJSON

+ const ShardHandlerFactoryConnTimeoutKey

+ const ShardHandlerFactoryConnTimeoutValue

+ const ShardHandlerFactorySocketTimeoutKey

+ const ShardHandlerFactorySocketTimeoutValue

+ const SinglestoreContainerName

+ const SinglestoreCoordinatorContainerName

+ const SinglestoreDatabaseHealth

+ const SinglestoreDatabasePort

+ const SinglestoreDatabasePortName

+ const SinglestoreInitContainerName

+ const SinglestorePrimaryServicePortName

+ const SinglestoreRootPassword

+ const SinglestoreRootUser

+ const SinglestoreRootUserName

+ const SinglestoreTableHealth

+ const SinglestoreVolmeNameInitScript

+ const SinglestoreVolumeMountPathCustomConfig

+ const SinglestoreVolumeMountPathData

+ const SinglestoreVolumeMountPathInitScript

+ const SinglestoreVolumeMountPathUserInitScript

+ const SinglestoreVolumeNameCustomConfig

+ const SinglestoreVolumeNameData

+ const SinglestoreVolumeNameUserInitScript

+ const SolrAdmin

+ const SolrCloudDistribUpdateConnTimeoutKey

+ const SolrCloudDistribUpdateConnTimeoutValue

+ const SolrCloudDistribUpdateSoTimeoutKey

+ const SolrCloudDistribUpdateSoTimeoutValue

+ const SolrCloudGenericCoreNodeNamesKey

+ const SolrCloudGenericCoreNodeNamesValue

+ const SolrCloudHostContextKey

+ const SolrCloudHostContextValue

+ const SolrCloudHostKey

+ const SolrCloudHostPortKey

+ const SolrCloudHostPortValue

+ const SolrCloudHostValue

+ const SolrCloudZKAclProviderKey

+ const SolrCloudZKAclProviderValue

+ const SolrCloudZKClientTimeoutKey

+ const SolrCloudZKClientTimeoutValue

+ const SolrCloudZKCredentialProviderKey

+ const SolrCloudZKCredentialProviderValue

+ const SolrConfAllowPathsKey

+ const SolrConfAllowPathsValue

+ const SolrConfMaxBooleanClausesKey

+ const SolrConfMaxBooleanClausesValue

+ const SolrConfShardHandlerFactoryKey

+ const SolrConfSolrCloudKey

+ const SolrContainerName

+ const SolrCustomConfigDir

+ const SolrDataDir

+ const SolrHomeDir

+ const SolrInitContainerName

+ const SolrKeysAllowPathsKey

+ const SolrKeysAllowPathsValue

+ const SolrKeysHostPortKey

+ const SolrKeysHostPortValue

+ const SolrKeysMaxBooleanClausesKey

+ const SolrKeysMaxBooleanClausesValue

+ const SolrKeysShardLibValue

+ const SolrKeysSharedLibKey

+ const SolrPortName

+ const SolrRestPort

+ const SolrSecretKey

+ const SolrSecurityConfigDir

+ const SolrTempConfigDir

+ const SolrVolumeAuthConfig

+ const SolrVolumeConfig

+ const SolrVolumeCustomConfig

+ const SolrVolumeData

+ const SolrVolumeDefaultConfig

+ const StatefulSetTypeLeaf

+ const StatefulSetTypeMasterAggregator

+ const SyncPeriod

+ const SysPropLibPlaceholder

+ const ZooKeeperAdminServerPort

+ const ZooKeeperAdminServerPortName

+ const ZooKeeperClientPort

+ const ZooKeeperClientPortName

+ const ZooKeeperConfigFileName

+ const ZooKeeperConfigVolumeName

+ const ZooKeeperConfigVolumePath

+ const ZooKeeperContainerName

+ const ZooKeeperData

+ const ZooKeeperDataVolumeName

+ const ZooKeeperDataVolumePath

+ const ZooKeeperInitContainerName

+ const ZooKeeperLeaderElectionPort

+ const ZooKeeperLeaderElectionPortName

+ const ZooKeeperLog4jPropertiesFileName

+ const ZooKeeperLog4jQuietPropertiesFileName

+ const ZooKeeperMetricsPort

+ const ZooKeeperMetricsPortName

+ const ZooKeeperNode

+ const ZooKeeperQuorumPort

+ const ZooKeeperQuorumPortName

+ const ZooKeeperScriptVolumeName

+ const ZooKeeperScriptVolumePath

+ const ZooKeeperSuperUsername

+ var DefaultResourcesCPUIntensive = core.ResourceRequirements

+ var DefaultResourcesMemoryIntensive = core.ResourceRequirements

+ var PgpoolForbiddenEnvVars = []string

+ var PgpoolReservedVolumes = []string

+ var PgpoolReservedVolumesMountPaths = []string

+ func FerretDBValidateEnvVar(envs []core.EnvVar, forbiddenEnvs []string, resourceType string) error

+ func PgpoolGetMainContainerEnvs(p *Pgpool) []core.EnvVar

+ func PgpoolValidateVersion(p *Pgpool) error

+ func PgpoolValidateVolumes(p *Pgpool) error

+ func PgpoolValidateVolumesMountPaths(podTemplate *ofst.PodTemplateSpec) error

+ type Backend struct

+ ExternallyManaged bool

+ LinkedDB string

+ Postgres *PostgresRef

+ func (in *Backend) DeepCopy() *Backend

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

+ type DeepStorageSpec struct

+ ConfigSecret *core.LocalObjectReference

+ Type *string

+ func (in *DeepStorageSpec) DeepCopy() *DeepStorageSpec

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

+ type Druid struct

+ Spec DruidSpec

+ Status DruidStatus

+ func (d *Druid) AddDruidExtensionLoadList(druidExtensionLoadList string, extension string) string

+ func (d *Druid) AppBindingMeta() appcat.AppBindingMeta

+ func (d *Druid) BrokersServiceName() string

+ func (d *Druid) ConfigSecretName() string

+ func (d *Druid) CoordinatorsServiceName() string

+ func (d *Druid) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

+ func (d *Druid) Default()

+ func (d *Druid) DefaultUserCredSecretName(username string) string

+ func (d *Druid) DruidNodeContainerPort(nodeRole DruidNodeRoleType) int32

+ func (d *Druid) DruidNodeRoleString(nodeRole DruidNodeRoleType) string

+ func (d *Druid) DruidNodeRoleStringSingular(nodeRole DruidNodeRoleType) string

+ func (d *Druid) GetConnectionScheme() string

+ func (d *Druid) GetDruidSegmentCacheConfig() string

+ func (d *Druid) GetDruidStorageSize(storageSize string) string

+ func (d *Druid) GetMetadataStorageConnectURI(appbinding *appcat.AppBinding, metadataStorageType DruidMetadataStorageType) string

+ func (d *Druid) GetMetadataStorageType(metadataStorage string) DruidMetadataStorageType

+ func (d *Druid) GetPersistentSecrets() []string

+ func (d *Druid) GetZKServiceHost(appbinding *appcat.AppBinding) string

+ func (d *Druid) GoverningServiceName() string

+ func (d *Druid) OffShootLabels() map[string]string

+ func (d *Druid) OffShootName() string

+ func (d *Druid) OffShootSelectors(extraSelectors ...map[string]string) map[string]string

+ func (d *Druid) OffshootSelectors(extraSelectors ...map[string]string) map[string]string

+ func (d *Druid) OverlordsServiceName() string

+ func (d *Druid) Owner() *meta.OwnerReference

+ func (d *Druid) PVCName(alias string) string

+ func (d *Druid) PodControllerLabels(extraLabels ...map[string]string) map[string]string

+ func (d *Druid) PodLabels(extraLebels ...map[string]string) map[string]string

+ func (d *Druid) ReplicasAreReady(lister appslister.StatefulSetLister) (bool, string, error)

+ func (d *Druid) ResourceFQN() string

+ func (d *Druid) ResourceKind() string

+ func (d *Druid) ResourcePlural() string

+ func (d *Druid) ResourceSingular() string

+ func (d *Druid) RoutersServiceName() string

+ func (d *Druid) ServiceAccountName() string

+ func (d *Druid) ServiceLabels(alias ServiceAlias, extraLabels ...map[string]string) map[string]string

+ func (d *Druid) ServiceName() string

+ func (d *Druid) SetDefaults()

+ func (d *Druid) SetHealthCheckerDefaults()

+ func (d *Druid) StatefulSetName(nodeRole DruidNodeRoleType) string

+ func (d *Druid) ValidateCreate() (admission.Warnings, error)

+ func (d *Druid) ValidateDelete() (admission.Warnings, error)

+ func (d *Druid) ValidateUpdate(old runtime.Object) (admission.Warnings, error)

+ func (d Druid) OffshootLabels() map[string]string

+ func (in *Druid) DeepCopy() *Druid

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

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

+ type DruidApp struct

+ func (d DruidApp) Name() string

+ func (d DruidApp) Type() appcat.AppType

+ func (in *DruidApp) DeepCopy() *DruidApp

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

+ type DruidClusterTopology struct

+ Brokers *DruidNode

+ Coordinators *DruidNode

+ Historicals *DruidNode

+ MiddleManagers *DruidNode

+ Overlords *DruidNode

+ Routers *DruidNode

+ func (in *DruidClusterTopology) DeepCopy() *DruidClusterTopology

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

+ type DruidDeepStorageType string

+ const DruidDeepStorageAzure

+ const DruidDeepStorageGoogle

+ const DruidDeepStorageHDFS

+ const DruidDeepStorageS3

+ type DruidList struct

+ Items []Druid

+ func (in *DruidList) DeepCopy() *DruidList

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

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

+ type DruidMetadataStorageType string

+ const DruidMetadataStorageMySQL

+ const DruidMetadataStoragePostgreSQL

+ type DruidNode struct

+ NodeSelector map[string]string

+ PodTemplate ofst.PodTemplateSpec

+ Replicas *int32

+ Storage *core.PersistentVolumeClaimSpec

+ Suffix string

+ Tolerations []core.Toleration

+ func (in *DruidNode) DeepCopy() *DruidNode

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

+ type DruidNodeRoleType string

+ const DruidNodeRoleBrokers

+ const DruidNodeRoleCoordinators

+ const DruidNodeRoleHistoricals

+ const DruidNodeRoleMiddleManagers

+ const DruidNodeRoleOverlords

+ const DruidNodeRoleRouters

+ type DruidPhase string

+ const DruidPhaseCritical

+ const DruidPhaseNotReady

+ const DruidPhaseProvisioning

+ const DruidPhaseReady

+ type DruidSpec struct

+ AuthSecret *core.LocalObjectReference

+ ConfigSecret *core.LocalObjectReference

+ DeepStorage *DeepStorageSpec

+ DisableSecurity *bool

+ Halted bool

+ HealthChecker kmapi.HealthCheckSpec

+ MetadataStorage *MetadataStorage

+ PodTemplate ofst.PodTemplateSpec

+ ServiceTemplates []NamedServiceTemplateSpec

+ StorageType StorageType

+ TerminationPolicy TerminationPolicy

+ Topology *DruidClusterTopology

+ Version string

+ ZooKeeper *ZooKeeperRef

+ func (in *DruidSpec) DeepCopy() *DruidSpec

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

+ type DruidStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase DruidPhase

+ func (in *DruidStatus) DeepCopy() *DruidStatus

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

+ type FerretDB struct

+ Spec FerretDBSpec

+ Status FerretDBStatus

+ func (f *FerretDB) AppBindingMeta() appcat.AppBindingMeta

+ func (f *FerretDB) AsOwner() *meta.OwnerReference

+ func (f *FerretDB) CertificateName(alias FerretDBCertificateAlias) string

+ func (f *FerretDB) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

+ func (f *FerretDB) Default()

+ func (f *FerretDB) GetAuthSecretName() string

+ func (f *FerretDB) GetCertSecretName(alias FerretDBCertificateAlias) string

+ func (f *FerretDB) OffshootLabels() map[string]string

+ func (f *FerretDB) OffshootName() string

+ func (f *FerretDB) OffshootSelectors() map[string]string

+ func (f *FerretDB) PgBackendName() string

+ func (f *FerretDB) PodControllerLabels(podControllerLabels map[string]string, extraLabels ...map[string]string) map[string]string

+ func (f *FerretDB) PodLabels(podTemplateLabels map[string]string, extraLabels ...map[string]string) map[string]string

+ func (f *FerretDB) ReplicasAreReady(lister appslister.StatefulSetLister) (bool, string, error)

+ func (f *FerretDB) ResourceFQN() string

+ func (f *FerretDB) ResourceKind() string

+ func (f *FerretDB) ResourcePlural() string

+ func (f *FerretDB) ServiceLabels(alias ServiceAlias, extraLabels ...map[string]string) map[string]string

+ func (f *FerretDB) ServiceName() string

+ func (f *FerretDB) SetDefaults()

+ func (f *FerretDB) SetHealthCheckerDefaults()

+ func (f *FerretDB) SetTLSDefaults()

+ func (f *FerretDB) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (f *FerretDB) StatsService() mona.StatsAccessor

+ func (f *FerretDB) StatsServiceLabels() map[string]string

+ func (f *FerretDB) ValidateCreate() (admission.Warnings, error)

+ func (f *FerretDB) ValidateCreateOrUpdate() field.ErrorList

+ func (f *FerretDB) ValidateDelete() (admission.Warnings, error)

+ func (f *FerretDB) ValidateUpdate(old runtime.Object) (admission.Warnings, error)

+ func (in *FerretDB) DeepCopy() *FerretDB

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

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

+ type FerretDBApp struct

+ func (f FerretDBApp) Name() string

+ func (f FerretDBApp) Type() appcat.AppType

+ func (in *FerretDBApp) DeepCopy() *FerretDBApp

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

+ type FerretDBCertificateAlias string

+ const FerretDBClientCert

+ const FerretDBServerCert

+ type FerretDBList struct

+ Items []FerretDB

+ func (in *FerretDBList) DeepCopy() *FerretDBList

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

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

+ type FerretDBSpec struct

+ AuthSecret *SecretReference

+ Backend *Backend

+ Halted bool

+ HealthChecker kmapi.HealthCheckSpec

+ Monitor *mona.AgentSpec

+ PodTemplate *ofst.PodTemplateSpec

+ Replicas *int32

+ SSLMode SSLMode

+ ServiceTemplates []NamedServiceTemplateSpec

+ Storage *core.PersistentVolumeClaimSpec

+ StorageType StorageType

+ TLS *kmapi.TLSConfig

+ TerminationPolicy TerminationPolicy

+ Version string

+ func (in *FerretDBSpec) DeepCopy() *FerretDBSpec

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

+ type FerretDBStatsService struct

+ func (fs FerretDBStatsService) Path() string

+ func (fs FerretDBStatsService) Scheme() string

+ func (fs FerretDBStatsService) ServiceMonitorAdditionalLabels() map[string]string

+ func (fs FerretDBStatsService) ServiceMonitorName() string

+ func (fs FerretDBStatsService) ServiceName() string

+ func (fs FerretDBStatsService) TLSConfig() *v1.TLSConfig

+ func (in *FerretDBStatsService) DeepCopy() *FerretDBStatsService

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

+ type FerretDBStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase DatabasePhase

+ func (in *FerretDBStatus) DeepCopy() *FerretDBStatus

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

type Kafka

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

+ func (k *Kafka) ReplicasAreReady(lister appslister.StatefulSetLister) (bool, string, error)

+ type MetadataStorage struct

+ CreateTables *bool

+ Name *string

+ Namespace *string

+ Type *string

+ func (in *MetadataStorage) DeepCopy() *MetadataStorage

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

+ type Pgpool struct

+ Spec PgpoolSpec

+ Status PgpoolStatus

+ func (in *Pgpool) DeepCopy() *Pgpool

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

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

+ func (p *Pgpool) ConfigSecretName() string

+ func (p *Pgpool) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

+ func (p *Pgpool) Default()

+ func (p *Pgpool) GetAuthSecretName() string

+ func (p *Pgpool) GetNameSpacedName() string

+ func (p *Pgpool) GetPersistentSecrets() []string

+ func (p *Pgpool) GoverningServiceName() string

+ func (p *Pgpool) OffshootLabels() map[string]string

+ func (p *Pgpool) OffshootName() string

+ func (p *Pgpool) OffshootSelectors(extraSelectors ...map[string]string) map[string]string

+ func (p *Pgpool) Owner() *meta.OwnerReference

+ func (p *Pgpool) PodControllerLabels(extraLabels ...map[string]string) map[string]string

+ func (p *Pgpool) PodLabels(extraLabels ...map[string]string) map[string]string

+ func (p *Pgpool) PrimaryServiceDNS() string

+ func (p *Pgpool) ReplicasAreReady(lister appslister.StatefulSetLister) (bool, string, error)

+ func (p *Pgpool) ResourceFQN() string

+ func (p *Pgpool) ResourceKind() string

+ func (p *Pgpool) ResourcePlural() string

+ func (p *Pgpool) ResourceShortCode() string

+ func (p *Pgpool) ResourceSingular() string

+ func (p *Pgpool) ServiceAccountName() string

+ func (p *Pgpool) ServiceName() string

+ func (p *Pgpool) SetDefaults()

+ func (p *Pgpool) SetHealthCheckerDefaults()

+ func (p *Pgpool) SetSecurityContext(ppVersion *catalog.PgpoolVersion)

+ func (p *Pgpool) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (p *Pgpool) StatefulSetName() string

+ func (p *Pgpool) ValidateCreate() (admission.Warnings, error)

+ func (p *Pgpool) ValidateCreateOrUpdate() field.ErrorList

+ func (p *Pgpool) ValidateDelete() (admission.Warnings, error)

+ func (p *Pgpool) ValidateEnvVar(envs []core.EnvVar, forbiddenEnvs []string, resourceType string) error

+ func (p *Pgpool) ValidateHealth(health *kmapi.HealthCheckSpec) error

+ func (p *Pgpool) ValidateUpdate(old runtime.Object) (admission.Warnings, error)

+ type PgpoolConfiguration struct

+ PgpoolConfig *runtime.RawExtension

+ func (in *PgpoolConfiguration) DeepCopy() *PgpoolConfiguration

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

+ type PgpoolList struct

+ Items []Pgpool

+ func (in *PgpoolList) DeepCopy() *PgpoolList

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

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

+ type PgpoolSpec struct

+ AuthSecret *SecretReference

+ Backend *core.LocalObjectReference

+ ConfigSecret *core.LocalObjectReference

+ HealthChecker kmapi.HealthCheckSpec

+ InitConfiguration *PgpoolConfiguration

+ PodTemplate *ofst.PodTemplateSpec

+ Replicas *int32

+ ServiceTemplates []NamedServiceTemplateSpec

+ SyncUsers bool

+ TerminationPolicy TerminationPolicy

+ Version string

+ func (in *PgpoolSpec) DeepCopy() *PgpoolSpec

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

+ type PgpoolStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase DatabasePhase

+ func (in *PgpoolStatus) DeepCopy() *PgpoolStatus

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

+ type PostgresRef struct

+ Service *PostgresServiceRef

+ URL *string

+ Version *string

+ func (in *PostgresRef) DeepCopy() *PostgresRef

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

+ type PostgresServiceRef struct

+ Name string

+ Namespace string

+ PgPort int32

+ func (in *PostgresServiceRef) DeepCopy() *PostgresServiceRef

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

+ type RabbitMQ struct

+ Spec RabbitMQSpec

+ Status RabbitMQStatus

+ func (in *RabbitMQ) DeepCopy() *RabbitMQ

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

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

+ func (r *RabbitMQ) AppBindingMeta() appcat.AppBindingMeta

+ func (r *RabbitMQ) AsOwner() *meta.OwnerReference

+ func (r *RabbitMQ) CertSecretVolumeMountPath(configDir string, cert string) string

+ func (r *RabbitMQ) CertSecretVolumeName(alias RabbitMQCertificateAlias) string

+ func (r *RabbitMQ) CertificateName(alias RabbitMQCertificateAlias) string

+ func (r *RabbitMQ) ClientCertificateCN(alias RabbitMQCertificateAlias) string

+ func (r *RabbitMQ) ConfigSecretName() string

+ func (r *RabbitMQ) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

+ func (r *RabbitMQ) Default()

+ func (r *RabbitMQ) DefaultErlangCookieSecretName() string

+ func (r *RabbitMQ) DefaultPodRoleBindingName() string

+ func (r *RabbitMQ) DefaultPodRoleName() string

+ func (r *RabbitMQ) DefaultUserCredSecretName(username string) string

+ func (r *RabbitMQ) Finalizer() string

+ func (r *RabbitMQ) GetAuthSecretName() string

+ func (r *RabbitMQ) GetCertSecretName(alias RabbitMQCertificateAlias) string

+ func (r *RabbitMQ) GetConnectionScheme() string

+ func (r *RabbitMQ) GetPersistentSecrets() []string

+ func (r *RabbitMQ) GoverningServiceName() string

+ func (r *RabbitMQ) OffshootLabels() map[string]string

+ func (r *RabbitMQ) OffshootName() string

+ func (r *RabbitMQ) OffshootSelectors(extraSelectors ...map[string]string) map[string]string

+ func (r *RabbitMQ) Owner() *meta.OwnerReference

+ func (r *RabbitMQ) PVCName(alias string) string

+ func (r *RabbitMQ) PodControllerLabels(extraLabels ...map[string]string) map[string]string

+ func (r *RabbitMQ) PodLabels(extraLabels ...map[string]string) map[string]string

+ func (r *RabbitMQ) ReplicasAreReady(lister appslister.StatefulSetLister) (bool, string, error)

+ func (r *RabbitMQ) ResourceFQN() string

+ func (r *RabbitMQ) ResourceKind() string

+ func (r *RabbitMQ) ResourcePlural() string

+ func (r *RabbitMQ) ResourceShortCode() string

+ func (r *RabbitMQ) ResourceSingular() string

+ func (r *RabbitMQ) ServiceAccountName() string

+ func (r *RabbitMQ) ServiceLabels(alias ServiceAlias, extraLabels ...map[string]string) map[string]string

+ func (r *RabbitMQ) ServiceName() string

+ func (r *RabbitMQ) SetDefaults()

+ func (r *RabbitMQ) SetHealthCheckerDefaults()

+ func (r *RabbitMQ) SetTLSDefaults()

+ func (r *RabbitMQ) StandbyServiceName() string

+ func (r *RabbitMQ) StatefulSetName() string

+ func (r *RabbitMQ) StatsService() mona.StatsAccessor

+ func (r *RabbitMQ) StatsServiceLabels() map[string]string

+ func (r *RabbitMQ) ValidateCreate() (admission.Warnings, error)

+ func (r *RabbitMQ) ValidateCreateOrUpdate() error

+ func (r *RabbitMQ) ValidateDelete() (admission.Warnings, error)

+ func (r *RabbitMQ) ValidateUpdate(old runtime.Object) (admission.Warnings, error)

+ func (r *RabbitMQ) ValidateVersion(db *RabbitMQ) error

+ type RabbitMQCertificateAlias string

+ const RabbitmqCACert

+ const RabbitmqClientCert

+ const RabbitmqServerCert

+ type RabbitMQList struct

+ Items []RabbitMQ

+ func (in *RabbitMQList) DeepCopy() *RabbitMQList

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

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

+ type RabbitMQPhase string

+ const RabbitmqCritical

+ const RabbitmqNotReady

+ const RabbitmqProvisioning

+ const RabbitmqReady

+ type RabbitMQSpec struct

+ AuthSecret *SecretReference

+ ConfigSecret *core.LocalObjectReference

+ DisableSecurity bool

+ EnableSSL bool

+ Halted bool

+ HealthChecker kmapi.HealthCheckSpec

+ PodTemplate ofst.PodTemplateSpec

+ Replicas *int32

+ ServiceTemplates []NamedServiceTemplateSpec

+ Storage *core.PersistentVolumeClaimSpec

+ StorageType StorageType

+ TLS *kmapi.TLSConfig

+ TerminationPolicy TerminationPolicy

+ Version string

+ func (in *RabbitMQSpec) DeepCopy() *RabbitMQSpec

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

+ type RabbitMQStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase RabbitMQPhase

+ func (in *RabbitMQStatus) DeepCopy() *RabbitMQStatus

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

+ type RabbitmqApp struct

+ func (in *RabbitmqApp) DeepCopy() *RabbitmqApp

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

+ func (r RabbitmqApp) Name() string

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

+ type RabbitmqStatsService struct

+ func (in *RabbitmqStatsService) DeepCopy() *RabbitmqStatsService

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

+ func (ks RabbitmqStatsService) GetNamespace() string

+ func (ks RabbitmqStatsService) Path() string

+ func (ks RabbitmqStatsService) Scheme() string

+ func (ks RabbitmqStatsService) ServiceMonitorAdditionalLabels() map[string]string

+ func (ks RabbitmqStatsService) ServiceMonitorName() string

+ func (ks RabbitmqStatsService) ServiceName() string

+ func (ks RabbitmqStatsService) TLSConfig() *promapi.TLSConfig

+ type Singlestore struct

+ Spec SinglestoreSpec

+ Status SinglestoreStatus

+ func (in *Singlestore) DeepCopy() *Singlestore

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

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

+ func (s *Singlestore) AggregatorStatefulSet() string

+ func (s *Singlestore) AppBindingMeta() appcat.AppBindingMeta

+ func (s *Singlestore) CertificateName(alias SinglestoreCertificateAlias) string

+ func (s *Singlestore) ConfigSecretName() string

+ func (s *Singlestore) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

+ func (s *Singlestore) Default()

+ func (s *Singlestore) DefaultUserCredSecretName(username string) string

+ func (s *Singlestore) GetAuthSecretName() string

+ func (s *Singlestore) GetNameSpacedName() string

+ func (s *Singlestore) GetPersistentSecrets() []string

+ func (s *Singlestore) GoverningServiceName() string

+ func (s *Singlestore) IsClustering() bool

+ func (s *Singlestore) IsStandalone() bool

+ func (s *Singlestore) LeafStatefulSet() string

+ func (s *Singlestore) OffshootLabels() map[string]string

+ func (s *Singlestore) OffshootName() string

+ func (s *Singlestore) OffshootSelectors(extraSelectors ...map[string]string) map[string]string

+ func (s *Singlestore) Owner() *meta.OwnerReference

+ func (s *Singlestore) PVCName(alias string) string

+ func (s *Singlestore) PodControllerLabel(podTemplate *ofst.PodTemplateSpec) map[string]string

+ func (s *Singlestore) PodControllerLabels(extraLabels ...map[string]string) map[string]string

+ func (s *Singlestore) PodLabel(podTemplate *ofst.PodTemplateSpec) map[string]string

+ func (s *Singlestore) PodLabels(extraLabels ...map[string]string) map[string]string

+ func (s *Singlestore) PrimaryServiceDNS() string

+ func (s *Singlestore) ReplicasAreReady(lister appslister.StatefulSetLister) (bool, string, error)

+ func (s *Singlestore) ResourceFQN() string

+ func (s *Singlestore) ResourceKind() string

+ func (s *Singlestore) ResourcePlural() string

+ func (s *Singlestore) ResourceShortCode() string

+ func (s *Singlestore) ResourceSingular() string

+ func (s *Singlestore) ServiceAccountName() string

+ func (s *Singlestore) ServiceLabels(alias ServiceAlias, extraLabels ...map[string]string) map[string]string

+ func (s *Singlestore) ServiceName() string

+ func (s *Singlestore) SetDefaults()

+ func (s *Singlestore) SetHealthCheckerDefaults()

+ func (s *Singlestore) SetTLSDefaults()

+ func (s *Singlestore) StandbyServiceName() string

+ func (s *Singlestore) StatefulSetName() string

+ func (s *Singlestore) ValidateCreate() (admission.Warnings, error)

+ func (s *Singlestore) ValidateCreateOrUpdate() field.ErrorList

+ func (s *Singlestore) ValidateDelete() (admission.Warnings, error)

+ func (s *Singlestore) ValidateUpdate(old runtime.Object) (admission.Warnings, error)

+ type SinglestoreCertificateAlias string

+ const SinglestoreClientCert

+ const SinglestoreServerCert

+ type SinglestoreList struct

+ Items []Singlestore

+ func (in *SinglestoreList) DeepCopy() *SinglestoreList

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

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

+ type SinglestoreNode struct

+ PodTemplate *ofst.PodTemplateSpec

+ Replicas *int32

+ Storage *core.PersistentVolumeClaimSpec

+ Suffix string

+ func (in *SinglestoreNode) DeepCopy() *SinglestoreNode

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

+ type SinglestoreSpec struct

+ AuthSecret *SecretReference

+ ConfigSecret *core.LocalObjectReference

+ EnableSSL bool

+ Halted bool

+ HealthChecker kmapi.HealthCheckSpec

+ Init *InitSpec

+ LicenseSecret *SecretReference

+ PodTemplate *ofst.PodTemplateSpec

+ Replicas *int32

+ ServiceTemplates []NamedServiceTemplateSpec

+ Storage *core.PersistentVolumeClaimSpec

+ StorageType StorageType

+ TLS *kmapi.TLSConfig

+ TerminationPolicy TerminationPolicy

+ Topology *SinglestoreTopology

+ Version string

+ func (in *SinglestoreSpec) DeepCopy() *SinglestoreSpec

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

+ type SinglestoreStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase DatabasePhase

+ func (in *SinglestoreStatus) DeepCopy() *SinglestoreStatus

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

+ type SinglestoreTopology struct

+ Aggregator *SinglestoreNode

+ Leaf *SinglestoreNode

+ func (in *SinglestoreTopology) DeepCopy() *SinglestoreTopology

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

+ type Solr struct

+ Spec SolrSpec

+ Status SolrStatus

+ func (in *Solr) DeepCopy() *Solr

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

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

+ func (s *Solr) AppBindingMeta() appcat.AppBindingMeta

+ func (s *Solr) Append(opt map[string]string) string

+ func (s *Solr) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

+ func (s *Solr) Default()

+ func (s *Solr) DefaultPodRoleBindingName() string

+ func (s *Solr) DefaultPodRoleName() string

+ func (s *Solr) GetConnectionScheme() string

+ func (s *Solr) GetPersistentSecrets() []string

+ func (s *Solr) GoverningServiceName() string

+ func (s *Solr) Merge(opt map[string]string) map[string]string

+ func (s *Solr) OffshootLabels() map[string]string

+ func (s *Solr) OffshootName() string

+ func (s *Solr) OffshootSelectors(extraSelectors ...map[string]string) map[string]string

+ func (s *Solr) OverseerDiscoveryServiceName() string

+ func (s *Solr) Owner() *meta.OwnerReference

+ func (s *Solr) PVCName(alias string) string

+ func (s *Solr) PodControllerLabels(extraLabels ...map[string]string) map[string]string

+ func (s *Solr) PodLabels(extraLabels ...map[string]string) map[string]string

+ func (s *Solr) ReplicasAreReady(lister appslister.StatefulSetLister) (bool, string, error)

+ func (s *Solr) ResourceFQN() string

+ func (s *Solr) ResourceKind() string

+ func (s *Solr) ResourcePlural() string

+ func (s *Solr) ServiceAccountName() string

+ func (s *Solr) ServiceName() string

+ func (s *Solr) SetDefaults(slVersion *catalog.SolrVersion)

+ func (s *Solr) SetHealthCheckerDefaults()

+ func (s *Solr) SolrSecretKey() string

+ func (s *Solr) SolrSecretName(suffix string) string

+ func (s *Solr) StatefulsetName(suffix string) string

+ func (s *Solr) ValidateCreate() (admission.Warnings, error)

+ func (s *Solr) ValidateCreateOrUpdate() field.ErrorList

+ func (s *Solr) ValidateDelete() (admission.Warnings, error)

+ func (s *Solr) ValidateUpdate(old runtime.Object) (admission.Warnings, error)

+ type SolrApp struct

+ func (in *SolrApp) DeepCopy() *SolrApp

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

+ func (s SolrApp) Name() string

+ func (s SolrApp) Type() appcat.AppType

+ type SolrClusterTopology struct

+ Coordinator *SolrNode

+ Data *SolrNode

+ Overseer *SolrNode

+ func (in *SolrClusterTopology) DeepCopy() *SolrClusterTopology

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

+ type SolrList struct

+ Items []Solr

+ func (in *SolrList) DeepCopy() *SolrList

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

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

+ type SolrNode struct

+ NodeSelector map[string]string

+ PodTemplate ofst.PodTemplateSpec

+ Replicas *int32

+ Storage *core.PersistentVolumeClaimSpec

+ Suffix string

+ Tolerations []core.Toleration

+ func (in *SolrNode) DeepCopy() *SolrNode

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

+ type SolrNodeRoleType string

+ const SolrNodeRoleCoordinator

+ const SolrNodeRoleData

+ const SolrNodeRoleOverseer

+ const SolrNodeRoleSet

+ type SolrSpec struct

+ AuthConfigSecret *core.LocalObjectReference

+ AuthSecret *core.LocalObjectReference

+ ConfigSecret *core.LocalObjectReference

+ DisableSecurity bool

+ EnableSSL bool

+ HealthChecker kmapi.HealthCheckSpec

+ PodTemplate ofst.PodTemplateSpec

+ Replicas *int32

+ ServiceTemplates []NamedServiceTemplateSpec

+ SolrModules []string

+ SolrOpts []string

+ Storage *core.PersistentVolumeClaimSpec

+ StorageType StorageType

+ TLS *kmapi.TLSConfig

+ TerminationPolicy TerminationPolicy

+ Topology *SolrClusterTopology

+ Version string

+ ZookeeperRef *core.LocalObjectReference

+ func (in *SolrSpec) DeepCopy() *SolrSpec

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

+ type SolrStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase DatabasePhase

+ func (in *SolrStatus) DeepCopy() *SolrStatus

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

+ type ZooKeeper struct

+ Spec ZooKeeperSpec

+ Status ZooKeeperStatus

+ func (in *ZooKeeper) DeepCopy() *ZooKeeper

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

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

+ func (z *ZooKeeper) Address() string

+ func (z *ZooKeeper) AdminServerServiceName() string

+ func (z *ZooKeeper) AppBindingMeta() appcat.AppBindingMeta

+ func (z *ZooKeeper) ConfigSecretName() string

+ func (z *ZooKeeper) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

+ func (z *ZooKeeper) Default()

+ func (z *ZooKeeper) GetAuthSecretName() string

+ func (z *ZooKeeper) GetConnectionScheme() string

+ func (z *ZooKeeper) GetPersistentSecrets() []string

+ func (z *ZooKeeper) GoverningServiceName() string

+ func (z *ZooKeeper) OffshootLabels() map[string]string

+ func (z *ZooKeeper) OffshootName() string

+ func (z *ZooKeeper) OffshootSelectors(extraSelectors ...map[string]string) map[string]string

+ func (z *ZooKeeper) Owner() *meta.OwnerReference

+ func (z *ZooKeeper) PVCName(alias string) string

+ func (z *ZooKeeper) PodControllerLabels(extraLabels ...map[string]string) map[string]string

+ func (z *ZooKeeper) PodLabels(extraLabels ...map[string]string) map[string]string

+ func (z *ZooKeeper) ReplicasAreReady(lister appslister.StatefulSetLister) (bool, string, error)

+ func (z *ZooKeeper) ResourceFQN() string

+ func (z *ZooKeeper) ResourceKind() string

+ func (z *ZooKeeper) ResourcePlural() string

+ func (z *ZooKeeper) ResourceShortCode() string

+ func (z *ZooKeeper) ResourceSingular() string

+ func (z *ZooKeeper) ServiceAccountName() string

+ func (z *ZooKeeper) ServiceLabels(alias ServiceAlias, extraLabels ...map[string]string) map[string]string

+ func (z *ZooKeeper) ServiceName() string

+ func (z *ZooKeeper) SetDefaults()

+ func (z *ZooKeeper) SetHealthCheckerDefaults()

+ func (z *ZooKeeper) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (z *ZooKeeper) StatefulSetName() string

+ func (z *ZooKeeper) ValidateCreate() (admission.Warnings, error)

+ func (z *ZooKeeper) ValidateCreateOrUpdate() (admission.Warnings, error)

+ func (z *ZooKeeper) ValidateDelete() (admission.Warnings, error)

+ func (z *ZooKeeper) ValidateUpdate(old runtime.Object) (admission.Warnings, error)

+ type ZooKeeperApp struct

+ func (in *ZooKeeperApp) DeepCopy() *ZooKeeperApp

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

+ func (z ZooKeeperApp) Name() string

+ func (z ZooKeeperApp) Type() appcat.AppType

+ type ZooKeeperList struct

+ Items []ZooKeeper

+ func (in *ZooKeeperList) DeepCopy() *ZooKeeperList

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

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

+ type ZooKeeperRef struct

+ Name *string

+ Namespace string

+ PathsBase string

+ func (in *ZooKeeperRef) DeepCopy() *ZooKeeperRef

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

+ type ZooKeeperSpec struct

+ AuthSecret *SecretReference

+ ConfigSecret *core.LocalObjectReference

+ DisableAuth bool

+ Halted bool

+ HealthChecker kmapi.HealthCheckSpec

+ PodTemplate ofst.PodTemplateSpec

+ Replicas *int32

+ ServiceTemplates []NamedServiceTemplateSpec

+ Storage *core.PersistentVolumeClaimSpec

+ TerminationPolicy TerminationPolicy

+ Version string

+ func (in *ZooKeeperSpec) DeepCopy() *ZooKeeperSpec

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

+ type ZooKeeperStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase DatabasePhase

+ func (in *ZooKeeperStatus) DeepCopy() *ZooKeeperStatus

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

v0.41.0-rc.1

Jan 28, 2024

v0.41.0-rc.0

Jan 27, 2024

v0.41.0-beta.1

Jan 20, 2024

v0.41.0-beta.0

Jan 8, 2024

v0.40.1

Feb 22, 2024

v0.40.0

Dec 27, 2023

Changes in this version

+ var DefaultInitContainerResource = core.ResourceRequirements

type MySQLSpec

+ Archiver *Archiver

v0.39.0

Dec 19, 2023

Changes in this version

type ArbiterSpec

+ NodeSelector map[string]string

+ Tolerations []core.Toleration

type ElasticsearchNode

+ NodeSelector map[string]string

+ Tolerations []core.Toleration

type KafkaNode

+ NodeSelector map[string]string

+ Tolerations []core.Toleration

v0.38.0

Dec 8, 2023

Changes in this version

+ const DropCapabilityALL

+ const GitSecretMountPath

+ const GitSecretVolume

+ const GitSyncContainerName

+ const IPS_LOCK

+ const InitFromGit

+ const InitFromGitMountPath

+ const KafkaBrokerMaxID

+ const KafkaLocalRESTPort

+ const KafkaPortNameLocal

+ const PostgresInitContainerName

+ const SYS_RESOURCE

+ var DefaultClient client.Client

+ func DefaultArbiter(computeOnly bool) core.ResourceRequirements

+ func SetDefaultClient(kc client.Client)

+ type ArbiterSpec struct

+ Resources core.ResourceRequirements

+ func (in *ArbiterSpec) DeepCopy() *ArbiterSpec

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

+ type Archiver struct

+ Pause bool

+ Ref kmapi.ObjectReference

+ func (in *Archiver) DeepCopy() *Archiver

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

+ type ArchiverRecovery struct

+ EncryptionSecret *kmapi.ObjectReference

+ FullDBRepository *kmapi.ObjectReference

+ ManifestRepository *kmapi.ObjectReference

+ RecoveryTimestamp metav1.Time

+ func (in *ArchiverRecovery) DeepCopy() *ArchiverRecovery

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

type Elasticsearch

+ func (e *Elasticsearch) SetMetricsExporterDefaults(esVersion *catalog.ElasticsearchVersion)

type InitSpec

+ Archiver *ArchiverRecovery

type KafkaListenerType

+ const KafkaListenerLocal

type KernelSettings

+ DisableDefaults bool

type MongoDBSpec

+ Archiver *Archiver

type Postgres

+ func (p *Postgres) SetArbiterDefault()

type PostgresSpec

+ Arbiter *ArbiterSpec

v0.38.0-rc.1

Dec 1, 2023

v0.38.0-rc.0

Nov 29, 2023

v0.37.0

Nov 2, 2023

v0.36.0

Oct 9, 2023

Changes in this version

+ const KafkaControllerMaxID

+ const KafkaExternalRESTPort

+ const KafkaPortNameExternal

type KafkaListenerType

+ const KafkaListenerExternal

type MySQL

+ func (m *MySQL) IsRemoteReplica() bool

type MySQLMode

+ const MySQLModeRemoteReplica

type MySQLTopology

+ RemoteReplica *RemoteReplicaSpec

+ type PostgreSQLMode string

+ const PostgreSQLModeCluster

+ const PostgreSQLModeRemoteReplica

+ const PostgreSQLModeStandAlone

type Postgres

+ func (m *Postgres) IsRemoteReplica() bool

type PostgresSpec

+ Mode *PostgreSQLMode

+ RemoteReplica *RemoteReplicaSpec

+ type RemoteReplicaSpec struct

+ SourceRef core.ObjectReference

+ func (in *RemoteReplicaSpec) DeepCopy() *RemoteReplicaSpec

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

v0.35.1

Sep 27, 2023

v0.35.0

Aug 18, 2023

Changes in this version

+ const KafkaAdminTopicConfigProvider

+ const KafkaAutoCreateTopicEnable

+ const KafkaBootstrapServers

+ const KafkaBrokerCustomConfigFileName

+ const KafkaBrokerFailureDetection

+ const KafkaCCBootstrapServers

+ const KafkaCCBrokerFailureDetectionEnabled

+ const KafkaCCCapacityConfig

+ const KafkaCCCustomConfigDir

+ const KafkaCCDefaultInNetwork

+ const KafkaCCDefaultOutNetwork

+ const KafkaCCKubernetesMode

+ const KafkaCCMetricReporter

+ const KafkaCCMetricReporterSaslMechanism

+ const KafkaCCMetricReporterSecurityProtocol

+ const KafkaCCMetricSamplerClass

+ const KafkaCCMetricTopicAutoCreate

+ const KafkaCCMetricTopicNumPartition

+ const KafkaCCMetricTopicReplica

+ const KafkaCCMetricsSampler

+ const KafkaCCMinSamplesPerBrokerWindow

+ const KafkaCCSampleLoadingThreadsNum

+ const KafkaCCTempConfigDir

+ const KafkaCCTwoStepVerificationEnabled

+ const KafkaCapacityConfigFile

+ const KafkaCapacityConfigPath

+ const KafkaClientID

+ const KafkaControllerCustomConfigFileName

+ const KafkaCruiseControlBrokerSetConfigFileName

+ const KafkaCruiseControlCapacityConfigFileName

+ const KafkaCruiseControlClusterConfigFileName

+ const KafkaCruiseControlConfigFileName

+ const KafkaCruiseControlListenerPort

+ const KafkaCruiseControlLog4jConfigFileName

+ const KafkaCruiseControlRESTPort

+ const KafkaCruiseControlUIConfigFileName

+ const KafkaCustomConfigDir

+ const KafkaJMXMetricReporter

+ const KafkaLogCleanerBackoffMS

+ const KafkaLogCleanerMinLagSec

+ const KafkaMetricReporters

+ const KafkaMetricSamplingInterval

+ const KafkaNodeRolesCruiseControl

+ const KafkaOffSetTopicReplica

+ const KafkaPartitionMetricsWindow

+ const KafkaPartitionMetricsWindowNum

+ const KafkaPortNameCruiseControlListener

+ const KafkaPortNameCruiseControlREST

+ const KafkaSampleStoreTopicReplicationFactor

+ const KafkaServerCustomConfigFileName

+ const KafkaTopicConfigProviderClass

+ const KafkaTransactionSateLogMinISR

+ const KafkaTransactionStateLogReplica

+ const KafkaTwoStepVerification

+ const KafkaVolumeCustomConfig

type Elasticsearch

+ func (e *Elasticsearch) AsOwner() *metav1.OwnerReference

type Etcd

+ func (e *Etcd) AsOwner() *metav1.OwnerReference

+ type GitRepo struct

+ Args []string

+ AuthSecret *core.LocalObjectReference

+ Env []core.EnvVar

+ Resources core.ResourceRequirements

+ SecurityContext *core.SecurityContext

+ func (in *GitRepo) DeepCopy() *GitRepo

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

type Kafka

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

+ func (k *Kafka) CruiseControlConfigSecretName() string

+ func (k *Kafka) GetCruiseControlClientID() string

+ func (k *Kafka) GoverningServiceNameCruiseControl() string

+ type KafkaBrokerCapacity struct

+ InBoundNetwork string

+ OutBoundNetwork string

+ func (in *KafkaBrokerCapacity) DeepCopy() *KafkaBrokerCapacity

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

+ type KafkaCruiseControl struct

+ BrokerCapacity *KafkaBrokerCapacity

+ ConfigSecret *SecretReference

+ PodTemplate ofst.PodTemplateSpec

+ Replicas *int32

+ Resources core.ResourceRequirements

+ Suffix string

+ func (in *KafkaCruiseControl) DeepCopy() *KafkaCruiseControl

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

type KafkaListenerType

+ const KafkaListenerCC

type KafkaSpec

+ ConfigSecret *core.LocalObjectReference

+ CruiseControl *KafkaCruiseControl

type MariaDB

+ func (m *MariaDB) AsOwner() *metav1.OwnerReference

type Memcached

+ func (m *Memcached) AsOwner() *metav1.OwnerReference

type MongoDB

+ func (m *MongoDB) AsOwner() *metav1.OwnerReference

type MySQL

+ func (m *MySQL) AsOwner() *metav1.OwnerReference

type PerconaXtraDB

+ func (p *PerconaXtraDB) AsOwner() *metav1.OwnerReference

type PgBouncer

+ func (p *PgBouncer) AsOwner() *metav1.OwnerReference

type Postgres

+ func (p *Postgres) AsOwner() *metav1.OwnerReference

type ProxySQL

+ func (p *ProxySQL) AsOwner() *metav1.OwnerReference

type Redis

+ func (r *Redis) AsOwner() *metav1.OwnerReference

type RedisSentinel

+ func (rs *RedisSentinel) AsOwner() *metav1.OwnerReference

type ScriptSourceSpec

+ Git *GitRepo

v0.34.0

Jun 17, 2023

Changes in this version

+ const LabelProxySQLLoadBalanceStandalone

v0.34.0-rc.0

Jun 13, 2023

v0.33.1

Apr 7, 2023

v0.33.0

Apr 3, 2023

Changes in this version

type Kafka

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

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

type KafkaSpec

+ Monitor *mona.AgentSpec

type MongoDB

+ func (m *MongoDB) GetEntryCommand(mgVersion *v1alpha1.MongoDBVersion) string

v0.32.0

Feb 28, 2023

Changes in this version

+ const ElasticsearchOpenSearchSecurityConfigDirV2

+ func UsesAcmeIssuer(kc client.Client, ns string, issuerRef core.TypedLocalObjectReference) (bool, error)

+ type GaleraWsrepSSTMethod string

+ const GaleraWsrepSSTMethodMariabackup

+ const GaleraWsrepSSTMethodRsync

type MariaDBSpec

+ WsrepSSTMethod GaleraWsrepSSTMethod

type PgBouncer

+ func (p *PgBouncer) SetSecurityContext(pgBouncerVersion *catalog.PgBouncerVersion)

v0.31.0

Jan 29, 2023

v0.30.1

Jan 17, 2023

v0.30.0

Dec 24, 2022

Changes in this version

+ const EnvKafkaPassword

+ const EnvKafkaUser

+ const KafkaAdvertisedListeners

+ const KafkaBrokerClientPortName

+ const KafkaBrokerListener

+ const KafkaCertDir

+ const KafkaClientAuthConfigFileName

+ const KafkaClusterID

+ const KafkaConfigDir

+ const KafkaConfigFileName

+ const KafkaContainerName

+ const KafkaControllerClientPortName

+ const KafkaControllerListener

+ const KafkaControllerListenersName

+ const KafkaControllerNodeCount

+ const KafkaControllerQuorumVoters

+ const KafkaControllerRESTPort

+ const KafkaDataDir

+ const KafkaDataDirName

+ const KafkaEnabledSASLMechanisms

+ const KafkaEndpointVerifyAlgo

+ const KafkaGracefulShutdownTimeout

+ const KafkaInterBrokerListener

+ const KafkaInternalRESTPort

+ const KafkaKeyPassword

+ const KafkaKeystoreDefaultPass

+ const KafkaKeystoreLocation

+ const KafkaKeystorePassword

+ const KafkaKeystorePasswordKey

+ const KafkaListenerPLAINTEXTProtocol

+ const KafkaListenerSASLProtocol

+ const KafkaListenerSASLSSLProtocol

+ const KafkaListenerSecurityProtocolMap

+ const KafkaListeners

+ const KafkaMechanismControllerProtocol

+ const KafkaMetaDataDir

+ const KafkaMetadataDirName

+ const KafkaNodeRole

+ const KafkaNodeRoleSet

+ const KafkaNodeRolesBrokers

+ const KafkaNodeRolesCombined

+ const KafkaNodeRolesController

+ const KafkaPortNameController

+ const KafkaPortNameInternal

+ const KafkaPortNameREST

+ const KafkaRESTPort

+ const KafkaSASLInterBrokerProtocol

+ const KafkaSASLJAASConfig

+ const KafkaSASLMechanism

+ const KafkaSASLPLAINConfigKey

+ const KafkaSASLPlainMechanism

+ const KafkaSASLSSLConfigKey

+ const KafkaSSLPropertiesFileName

+ const KafkaSecurityProtocol

+ const KafkaServerKeystoreKey

+ const KafkaServerTruststoreKey

+ const KafkaServiceName

+ const KafkaStandbyServiceSuffix

+ const KafkaTempConfigDir

+ const KafkaTopicDeletionThresholdOffset

+ const KafkaTopicNameHealth

+ const KafkaTruststoreLocation

+ const KafkaTruststorePassword

+ const KafkaTruststorePasswordKey

+ const KafkaUserAdmin

+ const KafkaVolumeConfig

+ const KafkaVolumeData

+ const KafkaVolumeTempConfig

+ const PgBouncerDefaultIgnoreStartupParameters

+ const PgBouncerDefaultPoolMode

+ const ProxySQLContainerName

+ const ResourceCodeKafka

+ const ResourceKindKafka

+ const ResourcePluralKafka

+ const ResourceSingularKafka

+ type Kafka struct

+ Spec KafkaSpec

+ Status KafkaStatus

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

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

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

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

+ func (k *Kafka) BrokerNodeSelectors() map[string]string

+ func (k *Kafka) BrokerServiceLabels() map[string]string

+ func (k *Kafka) BrokerStatefulSetName() string

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

+ func (k *Kafka) CertSecretVolumeName(alias KafkaCertificateAlias) string

+ func (k *Kafka) CertificateName(alias KafkaCertificateAlias) string

+ func (k *Kafka) ClientCertificateCN(alias KafkaCertificateAlias) string

+ func (k *Kafka) CombinedStatefulSetName() string

+ func (k *Kafka) ConfigSecretName(role KafkaNodeRoleType) string

+ func (k *Kafka) ControllerNodeSelectors() map[string]string

+ func (k *Kafka) ControllerServiceLabels() map[string]string

+ func (k *Kafka) ControllerStatefulSetName() string

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

+ func (k *Kafka) Default()

+ func (k *Kafka) DefaultKeystoreCredSecretName() string

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

+ func (k *Kafka) GetCertSecretName(alias KafkaCertificateAlias) string

+ func (k *Kafka) GetConnectionScheme() string

+ func (k *Kafka) GoverningServiceName() string

+ func (k *Kafka) GoverningServiceNameBroker() string

+ func (k *Kafka) GoverningServiceNameController() string

+ func (k *Kafka) NodeRoleSpecificLabelKey(role KafkaNodeRoleType) string

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

+ func (k *Kafka) OffshootName() string

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

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

+ func (k *Kafka) PVCName(alias string) string

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

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

+ func (k *Kafka) ResourceFQN() string

+ func (k *Kafka) ResourceKind() string

+ func (k *Kafka) ResourcePlural() string

+ func (k *Kafka) ResourceShortCode() string

+ func (k *Kafka) ResourceSingular() string

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

+ func (k *Kafka) ServiceName() string

+ func (k *Kafka) SetDefaults()

+ func (k *Kafka) SetHealthCheckerDefaults()

+ func (k *Kafka) SetTLSDefaults()

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

+ func (k *Kafka) StandbyServiceName() string

+ func (k *Kafka) StatefulSetName() string

+ func (k *Kafka) ValidateCreate() error

+ func (k *Kafka) ValidateCreateOrUpdate() error

+ func (k *Kafka) ValidateDelete() error

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

+ type KafkaApp struct

+ func (in *KafkaApp) DeepCopy() *KafkaApp

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

+ func (r KafkaApp) Name() string

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

+ type KafkaCertificateAlias string

+ const KafkaCACert

+ const KafkaClientCert

+ const KafkaHTTPCert

+ const KafkaServerCert

+ const KafkaTransportCert

+ type KafkaClusterTopology struct

+ Broker *KafkaNode

+ Controller *KafkaNode

+ func (in *KafkaClusterTopology) DeepCopy() *KafkaClusterTopology

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

+ func (kfTopology *KafkaClusterTopology) ToMap() map[KafkaNodeRoleType]KafkaNode

+ type KafkaList struct

+ Items []Kafka

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

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

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

+ type KafkaListenerType string

+ const KafkaListenerBroker

+ const KafkaListenerController

+ const KafkaListenerInternal

+ type KafkaNode struct

+ Replicas *int32

+ Resources core.ResourceRequirements

+ Storage *core.PersistentVolumeClaimSpec

+ Suffix string

+ func (in *KafkaNode) DeepCopy() *KafkaNode

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

+ type KafkaNodeRoleType string

+ const KafkaNodeRoleBroker

+ const KafkaNodeRoleCombined

+ const KafkaNodeRoleController

+ type KafkaPhase string

+ const KafkaPhaseCritical

+ const KafkaPhaseNotReady

+ const KafkaPhaseProvisioning

+ const KafkaPhaseReady

+ type KafkaSpec struct

+ AuthSecret *SecretReference

+ DisableSecurity bool

+ EnableSSL bool

+ HealthChecker kmapi.HealthCheckSpec

+ KeystoreCredSecret *SecretReference

+ PodTemplate ofst.PodTemplateSpec

+ Replicas *int32

+ ServiceTemplates []NamedServiceTemplateSpec

+ Storage *core.PersistentVolumeClaimSpec

+ StorageType StorageType

+ TLS *kmapi.TLSConfig

+ TerminationPolicy TerminationPolicy

+ Topology *KafkaClusterTopology

+ Version string

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

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

+ type KafkaStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase KafkaPhase

+ func (in *KafkaStatus) DeepCopy() *KafkaStatus

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

type PgBouncer

+ func (p PgBouncer) GetBackendSecretName() string

type PgBouncerSpec

+ AuthSecret *SecretReference

+ ConfigSecret *core.LocalObjectReference

type PostgreLeaderElectionConfig

+ TransferLeadershipInterval *metav1.Duration

+ TransferLeadershipTimeout *metav1.Duration

v0.30.0-rc.1

Dec 23, 2022

v0.30.0-rc.0

Dec 12, 2022

v0.29.1

Oct 20, 2022

Changes in this version

+ const MySQLRootUser

+ const PostgresRootUser

+ const ProxySQLAuthUsername

+ const ProxySQLConfigSecretKey

+ const ProxySQLMonitorUsername

+ const SharedBuffersGbAsKiloByte

+ const SharedBuffersMbAsKiloByte

v0.29.0

Oct 15, 2022

Changes in this version

+ const NodeTypeHidden

+ const PostgresContainerName

+ const RedisNodeFlagMaster

+ const RedisNodeFlagNoAddr

+ const RedisNodeFlagSlave

+ const RedisSentinelContainerName

+ const RedisSentinelTLSVolumeName

+ const RedisSentinelTLSVolumePath

+ type Age struct

+ LastUpdateTimestamp metav1.Time

+ func (in *Age) DeepCopy() *Age

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

type Elasticsearch

+ func (e Elasticsearch) GetAuthSecretName() string

type ElasticsearchStatus

+ AuthSecret *Age

type Etcd

+ func (e Etcd) GetAuthSecretName() string

type EtcdStatus

+ AuthSecret *Age

type MariaDBStatus

+ AuthSecret *Age

type MongoDB

+ func (m MongoDB) GetAuthSecretName() string

+ func (m MongoDB) GetCorrespondingHiddenStsName(replStsName string) string

+ func (m MongoDB) GetCorrespondingReplicaStsNameFromHidden(hiddenStsName string) string

+ func (m MongoDB) HiddenNodeLabels() map[string]string

+ func (m MongoDB) HiddenNodeName() string

+ func (m MongoDB) HiddenNodeSelectors() map[string]string

+ func (m MongoDB) HiddenNodeShardLabels(nodeNum int32) map[string]string

+ func (m MongoDB) HiddenNodeShardSelectors(nodeNum int32) map[string]string

+ func (m MongoDB) HiddenShardNodeName(nodeNum int32) string

+ func (m MongoDB) HostAddressOnlyCoreMembers() string

+ func (m MongoDB) HostsOnlyCoreMembers() []string

+ func (m MongoDB) OffshootLabelsWhenOthers() map[string]string

+ func (m MongoDB) OffshootSelectorsWhenOthers() map[string]string

+ func (m MongoDB) ShardDSNOnlyCoreMembers(nodeNum int32) string

+ func (m MongoDB) ShardHostsOnlyCoreMembers(nodeNum int32) []string

+ func (m MongoDB) ShardLabelsWhenOthers(nodeNum int32) map[string]string

+ func (m MongoDB) ShardSelectorsWhenOthers(nodeNum int32) map[string]string

type MongoDBSpec

+ Hidden *MongoHiddenNode

type MongoDBStatus

+ AuthSecret *Age

+ type MongoHiddenNode struct

+ ConfigSecret *core.LocalObjectReference

+ PodTemplate ofst.PodTemplateSpec

+ Replicas int32

+ Storage core.PersistentVolumeClaimSpec

+ func (in *MongoHiddenNode) DeepCopy() *MongoHiddenNode

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

type MongoShellScriptName

+ const ScriptNameHidden

type MySQLStatus

+ AuthSecret *Age

type PerconaXtraDB

+ func (p PerconaXtraDB) GetMonitorSecretName() string

+ func (p PerconaXtraDB) GetReplicationSecretName() string

type PerconaXtraDBStatus

+ AuthSecret *Age

type PgBouncer

+ func (p PgBouncer) GetAuthSecretName() string

type Postgres

+ func (p Postgres) GetAuthSecretName() string

type PostgresStatus

+ AuthSecret *Age

type ProxySQL

+ func (p ProxySQL) GetAuthSecretName() string

type ProxySQLStatus

+ AuthSecret *Age

type Redis

+ func (r Redis) GetAuthSecretName() string

type RedisSentinel

+ func (r RedisSentinel) Address() string

+ func (rs RedisSentinel) GetAuthSecretName() string

type RedisSentinelStatus

+ AuthSecret *Age

type RedisStatus

+ AuthSecret *Age

+ type SecretReference struct

+ ExternallyManaged bool

+ func (in *SecretReference) DeepCopy() *SecretReference

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

v0.29.0-rc.0

Oct 10, 2022

v0.28.3

Aug 24, 2022

Changes in this version

+ const PerconaXtraDBMySQLUserGroupID

v0.28.2

Aug 16, 2022

Changes in this version

+ const MySQLVolumeMountPathUserInitScript

+ const MySQLVolumeNameUserInitScript

v0.28.1

Aug 8, 2022

v0.28.0

Aug 4, 2022

Changes in this version

+ const CACert

+ const DataRestoreInterrupted

+ const DatabaseReadAccess

+ const DatabaseReadAccessCheckFailed

+ const DatabaseReadAccessCheckSucceeded

+ const DatabaseWriteAccess

+ const DatabaseWriteAccessCheckFailed

+ const DatabaseWriteAccessCheckSucceeded

+ const ElasticsearchTempDir

+ const ElasticsearchVolumeConfig

+ const ElasticsearchVolumeCustomConfig

+ const ElasticsearchVolumeData

+ const ElasticsearchVolumeSecureSettings

+ const ElasticsearchVolumeSecurityConfig

+ const ElasticsearchVolumeTemp

+ const ElasticsearchVolumeTempConfig

+ const MariaDBCertMountPath

+ const MariaDBClientTLSVolumeName

+ const MariaDBDataVolumeName

+ const MariaDBExporterConfigFileName

+ const MariaDBExporterTLSVolumeName

+ const MariaDBGaleraClusterPrimaryComponent

+ const MariaDBMetricsExporterConfigPath

+ const MariaDBMetricsExporterTLSVolumeName

+ const MariaDBServerTLSVolumeName

+ const MySQLContainerName

+ const MySQLCoordinatorClientPort

+ const MySQLCoordinatorPort

+ const MySQLCoordinatorStatus

+ const MySQLInitContainerName

+ const MySQLRouterInitContainerName

+ const MySQLVolumeMountPathCustomConfig

+ const MySQLVolumeMountPathData

+ const MySQLVolumeMountPathExporterTLS

+ const MySQLVolumeMountPathInitScript

+ const MySQLVolumeMountPathInitialScript

+ const MySQLVolumeMountPathSourceCA

+ const MySQLVolumeMountPathTLS

+ const MySQLVolumeMountPathTemp

+ const MySQLVolumeNameCustomConfig

+ const MySQLVolumeNameData

+ const MySQLVolumeNameExporterTLS

+ const MySQLVolumeNameInitScript

+ const MySQLVolumeNameInitialScript

+ const MySQLVolumeNameSourceCA

+ const MySQLVolumeNameTLS

+ const MySQLVolumeNameTemp

+ const PerconaXtraDBCertMountPath

+ const PerconaXtraDBClientTLSVolumeName

+ const PerconaXtraDBContainerName

+ const PerconaXtraDBCoordinatorContainerName

+ const PerconaXtraDBCustomConfigVolumeName

+ const PerconaXtraDBDataVolumeName

+ const PerconaXtraDBExporterConfigFileName

+ const PerconaXtraDBExporterTLSVolumeName

+ const PerconaXtraDBGaleraClusterPrimaryComponent

+ const PerconaXtraDBInitContainerName

+ const PerconaXtraDBInitDBVolumeName

+ const PerconaXtraDBInitScriptVolumeMountPath

+ const PerconaXtraDBInitScriptVolumeName

+ const PerconaXtraDBMetricsExporterConfigPath

+ const PerconaXtraDBMetricsExporterTLSVolumeName

+ const PerconaXtraDBRunScriptVolumeMountPath

+ const PerconaXtraDBRunScriptVolumeName

+ const PerconaXtraDBServerTLSVolumeName

+ const PerconaXtraDBTLSConfigCustom

+ const PostgresCustomConfigDir

+ const PostgresCustomConfigVolumeName

+ const PostgresDataDir

+ const PostgresDataVolumeName

+ const PostgresInitDir

+ const PostgresInitVolumeName

+ const PostgresRoleScriptsDir

+ const PostgresRoleScriptsVolumeName

+ const PostgresRunScriptsDir

+ const PostgresRunScriptsVolumeName

+ const PostgresSharedMemoryDir

+ const PostgresSharedMemoryVolumeName

+ const PostgresSharedScriptsDir

+ const PostgresSharedScriptsVolumeName

+ const PostgresSharedTlsVolumeMountPath

+ const PostgresSharedTlsVolumeName

+ const RedisConfigVolumeName

+ const RedisConfigVolumePath

+ const RedisContainerName

+ const RedisDataVolumeName

+ const RedisDataVolumePath

+ const RedisExporterTLSVolumeName

+ const RedisTLSVolumeName

+ const RedisTLSVolumePath

+ var DefaultResourcesElasticSearch = core.ResourceRequirements

+ type AutoOpsSpec struct

+ Disabled bool

+ func (in *AutoOpsSpec) DeepCopy() *AutoOpsSpec

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

type Elasticsearch

+ func (e *Elasticsearch) SetHealthCheckerDefaults()

type ElasticsearchNodeRoleType

+ const ElasticsearchNodeRoleTypeCombined

type ElasticsearchSpec

+ AutoOps AutoOpsSpec

+ HealthChecker HealthCheckSpec

+ type HealthCheckSpec struct

+ DisableWriteCheck bool

+ FailureThreshold *int32

+ PeriodSeconds *int32

+ TimeoutSeconds *int32

+ func (in *HealthCheckSpec) DeepCopy() *HealthCheckSpec

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

type MariaDB

+ func (m *MariaDB) CertFilePath(certAlias MariaDBCertificateAlias, certFileName string) string

+ func (m *MariaDB) CertMountPath(alias MariaDBCertificateAlias) string

+ func (m *MariaDB) SetHealthCheckerDefaults()

type MariaDBCertificateAlias

+ const MariaDBExporterCert

type MariaDBSpec

+ AutoOps AutoOpsSpec

+ HealthChecker HealthCheckSpec

type MongoDB

+ func (m *MongoDB) GetURL(stsName string) string

+ func (m *MongoDB) SetHealthCheckerDefaults()

type MongoDBSpec

+ AutoOps AutoOpsSpec

+ HealthChecker HealthCheckSpec

type MySQL

+ func (m *MySQL) GetCertSecretName(alias MySQLCertificateAlias) string

+ func (m *MySQL) SetHealthCheckerDefaults()

type MySQLSpec

+ AutoOps AutoOpsSpec

+ HealthChecker HealthCheckSpec

+ type MySQLUser struct

+ Active *int

+ Attributes string

+ Backend *int

+ Comment string

+ DefaultHostgroup int

+ DefaultSchema string

+ FastForward int

+ Frontend *int

+ MaxConnections *int32

+ SchemaLocked int

+ TransactionPersistent *int

+ UseSSL int

+ Username string

+ func (in *MySQLUser) DeepCopy() *MySQLUser

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

type PerconaXtraDB

+ func (p *PerconaXtraDB) AuthSecretName() string

+ func (p *PerconaXtraDB) CertFilePath(certAlias PerconaXtraDBCertificateAlias, certFileName string) string

+ func (p *PerconaXtraDB) CertMountPath(alias PerconaXtraDBCertificateAlias) string

+ func (p *PerconaXtraDB) CertificateName(alias PerconaXtraDBCertificateAlias) string

+ func (p *PerconaXtraDB) GetCertSecretName(alias PerconaXtraDBCertificateAlias) string

+ func (p *PerconaXtraDB) MonitorSecretName() string

+ func (p *PerconaXtraDB) ReplicationSecretName() string

+ func (p *PerconaXtraDB) SetHealthCheckerDefaults()

+ func (p *PerconaXtraDB) SetTLSDefaults()

+ func (p PerconaXtraDB) PrimaryServiceDNS() string

type PerconaXtraDBCertificateAlias

+ const PerconaXtraDBClientCert

+ const PerconaXtraDBExporterCert

type PerconaXtraDBSpec

+ AllowedSchemas *AllowedConsumers

+ AutoOps AutoOpsSpec

+ Coordinator CoordinatorSpec

+ HealthChecker HealthCheckSpec

+ RequireSSL bool

+ SystemUserSecrets *SystemUserSecretsSpec

type PgBouncer

+ func (p *PgBouncer) SetHealthCheckerDefaults()

type PgBouncerSpec

+ AutoOps AutoOpsSpec

+ HealthChecker HealthCheckSpec

type Postgres

+ func (m *Postgres) SetHealthCheckerDefaults()

type PostgresSpec

+ AutoOps AutoOpsSpec

+ HealthChecker HealthCheckSpec

type ProxySQL

+ func (p *ProxySQL) SetHealthCheckerDefaults()

+ type ProxySQLConfiguration struct

+ AdminVariables *runtime.RawExtension

+ MySQLQueryRules []*runtime.RawExtension

+ MySQLUsers []MySQLUser

+ MySQLVariables *runtime.RawExtension

+ func (in *ProxySQLConfiguration) DeepCopy() *ProxySQLConfiguration

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

type ProxySQLSpec

+ AutoOps AutoOpsSpec

+ HealthChecker HealthCheckSpec

+ InitConfiguration *ProxySQLConfiguration

+ SyncUsers bool

type Redis

+ func (r *Redis) SetHealthCheckerDefaults()

type RedisSentinel

+ func (rs *RedisSentinel) SetHealthCheckerDefaults()

type RedisSentinelSpec

+ AutoOps AutoOpsSpec

+ HealthChecker HealthCheckSpec

type RedisSpec

+ AutoOps AutoOpsSpec

+ HealthChecker HealthCheckSpec

+ type SystemUserSecretsSpec struct

+ MonitorUserSecret *core.LocalObjectReference

+ ReplicationUserSecret *core.LocalObjectReference

+ func (in *SystemUserSecretsSpec) DeepCopy() *SystemUserSecretsSpec

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

v0.28.0-rc.1

Aug 3, 2022

v0.28.0-rc.0

Aug 2, 2022

v0.27.1

Jun 6, 2022

Changes in this version

+ const SharedBuffersGbAsByte

+ const SharedBuffersMbAsByte

v0.27.0

May 19, 2022

Changes in this version

+ const DatabaseHealthCheckPaused

+ const InternalUsersCredentialSyncFailed

+ const InternalUsersCredentialsSyncedSuccessfully

+ const InternalUsersSynced

+ const MongoDBInitialDirectoryName

+ const MongoDBInitialDirectoryPath

+ const MongoDBTypeLabelKey

+ const MySQLCoordinatorContainerName

+ const NodeTypeArbiter

+ const NodeTypeReplica

+ const NodeTypeStandalone

+ const PgBouncerCACrt

+ const PgBouncerClientCrt

+ const PgBouncerClientKey

+ const PgBouncerTLSCrt

+ const PgBouncerTLSKey

+ const PgBouncerUpstreamServerClientCert

+ const PgBouncerUpstreamServerClientKey

+ const ProxySQLBackendSSLMountPath

+ const ProxySQLClusterAdmin

+ const ProxySQLClusterPasswordField

+ const ProxySQLFrontendSSLMountPath

+ const ProxySQLTLSConfigCustom

+ const ProxySQLTLSConfigSkipVerify

+ const RaftMetricsExporterPort

+ const RaftMetricsExporterPortName

type DatabasePhase

+ const DatabasePhaseUnknown

type ElasticsearchCertificateAlias

+ const ElasticsearchClientCert

type ElasticsearchInternalUser

+ const ElasticsearchInternalUserApmSystem

+ const ElasticsearchInternalUserBeatsSystem

+ const ElasticsearchInternalUserKibanaSystem

+ const ElasticsearchInternalUserLogstashSystem

+ const ElasticsearchInternalUserRemoteMonitoringUser

type ElasticsearchUserSpec

+ Email string

+ FullName string

+ Metadata map[string]string

+ Roles []string

+ type ErrantTransactionRecoveryPolicy string

+ const ErrantTransactionRecoveryPolicyClone

+ const ErrantTransactionRecoveryPolicyPseudoTransaction

+ type MongoArbiterNode struct

+ ConfigSecret *core.LocalObjectReference

+ PodTemplate ofst.PodTemplateSpec

+ func (in *MongoArbiterNode) DeepCopy() *MongoArbiterNode

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

type MongoDB

+ func (m MongoDB) ArbiterLabels() map[string]string

+ func (m MongoDB) ArbiterNodeName() string

+ func (m MongoDB) ArbiterSelectors() map[string]string

+ func (m MongoDB) ArbiterShardLabels(nodeNum int32) map[string]string

+ func (m MongoDB) ArbiterShardNodeName(nodeNum int32) string

+ func (m MongoDB) ArbiterShardSelectors(nodeNum int32) map[string]string

+ func (m MongoDB) GetCorrespondingArbiterStsName(replStsName string) string

+ func (m MongoDB) GetCorrespondingReplicaStsName(arbStsName string) string

+ func (m MongoDB) GetShardNumber(shardName string) int

+ func (m MongoDB) OffshootLabelsWhenArbiter() map[string]string

+ func (m MongoDB) OffshootSelectorsWhenArbiter() map[string]string

+ func (m MongoDB) ShardLabelsWhenArbiter(nodeNum int32) map[string]string

+ func (m MongoDB) ShardSelectorsWhenArbiter(nodeNum int32) map[string]string

type MongoDBSpec

+ Arbiter *MongoArbiterNode

+ type MongoShellScriptName string

+ const ScriptNameArbiter

+ const ScriptNameCommon

+ const ScriptNameConfig

+ const ScriptNameInstall

+ const ScriptNameMongos

+ const ScriptNameReplicaset

+ const ScriptNameShard

type MySQL

+ func (m *MySQL) IsSemiSync() bool

type MySQLMode

+ const MySQLModeSemiSync

type MySQLTopology

+ SemiSync *SemiSyncSpec

type PgBouncer

+ func (p *PgBouncer) GetCertSecretName(alias PgBouncerCertificateAlias) string

+ func (p *PgBouncer) GetPersistentSecrets() []string

+ type PgBouncerClientAuthMode string

+ const PgBouncerClientAuthModeAny

+ const PgBouncerClientAuthModeCert

+ const PgBouncerClientAuthModeHba

+ const PgBouncerClientAuthModeMD5

+ const PgBouncerClientAuthModePam

+ const PgBouncerClientAuthModePlain

+ const PgBouncerClientAuthModeScram

+ const PgBouncerClientAuthModeTrust

+ type PgBouncerSSLMode string

+ const PgBouncerSSLModeAllow

+ const PgBouncerSSLModeDisable

+ const PgBouncerSSLModePrefer

+ const PgBouncerSSLModeRequire

+ const PgBouncerSSLModeVerifyCA

+ const PgBouncerSSLModeVerifyFull

type PgBouncerSpec

+ SSLMode PgBouncerSSLMode

+ TerminationPolicy PgBouncerTerminationPolicy

+ type PgBouncerTerminationPolicy string

+ const PgBouncerTerminationPolicyDelete

+ const PgBouncerTerminationPolicyDoNotTerminate

+ const PgBouncerTerminationPolicyWipeOut

type ProxySQL

+ func (m *ProxySQL) CertificateName(alias ProxySQLCertificateAlias) string

+ func (m *ProxySQL) GetCertSecretName(alias ProxySQLCertificateAlias) string

+ func (m *ProxySQL) IsCluster() bool

+ func (m *ProxySQL) SetTLSDefaults()

type ProxySQLCertificateAlias

+ const ProxySQLClientCert

type ProxySQLSpec

+ Storage *core.PersistentVolumeClaimSpec

+ StorageType StorageType

+ TerminationPolicy TerminationPolicy

+ type SemiSyncSpec struct

+ ErrantTransactionRecoveryPolicy *ErrantTransactionRecoveryPolicy

+ SourceTimeout metav1.Duration

+ SourceWaitForReplicaCount int

+ func (in *SemiSyncSpec) DeepCopy() *SemiSyncSpec

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

v0.26.0

Mar 28, 2022

v0.25.0

Feb 18, 2022

Changes in this version

+ const ElasticsearchJavaOptsEnv

+ const ElasticsearchOpenSearchJavaOptsEnv

+ const MariaDBContainerName

+ const MongoDBConfigurationJSFile

+ type AllowedConsumers struct

+ Namespaces *ConsumerNamespaces

+ Selector *metav1.LabelSelector

+ func (in *AllowedConsumers) DeepCopy() *AllowedConsumers

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

+ type ConsumerNamespaces struct

+ From *FromNamespaces

+ Selector *metav1.LabelSelector

+ func (in *ConsumerNamespaces) DeepCopy() *ConsumerNamespaces

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

type ElasticsearchNode

+ HeapSizePercentage *int32

type ElasticsearchSpec

+ HeapSizePercentage *int32

+ type FromNamespaces string

+ const NamespacesFromAll

+ const NamespacesFromSame

+ const NamespacesFromSelector

type MariaDBSpec

+ AllowedSchemas *AllowedConsumers

type MongoDBConfigNode

+ EphemeralStorage *core.EmptyDirVolumeSource

type MongoDBShardNode

+ EphemeralStorage *core.EmptyDirVolumeSource

type MongoDBSpec

+ AllowedSchemas *AllowedConsumers

+ EphemeralStorage *core.EmptyDirVolumeSource

type MySQL

+ func (m *MySQL) IsReadReplica() bool

+ func (m MySQL) GetNameSpacedName() string

+ func (m MySQL) StandbyServiceDNS() string

+ type MySQLMode string

+ const MySQLModeGroupReplication

+ const MySQLModeInnoDBCluster

+ const MySQLModeReadReplica

+ type MySQLReadReplicaSpec struct

+ SourceRef core.ObjectReference

+ func (in *MySQLReadReplicaSpec) DeepCopy() *MySQLReadReplicaSpec

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

type MySQLSpec

+ AllowedReadReplicas *AllowedConsumers

+ AllowedSchemas *AllowedConsumers

+ type MySQLTopology struct

+ Group *MySQLGroupSpec

+ InnoDBCluster *MySQLInnoDBClusterSpec

+ Mode *MySQLMode

+ ReadReplica *MySQLReadReplicaSpec

+ func (in *MySQLTopology) DeepCopy() *MySQLTopology

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

type PostgresSpec

+ AllowedSchemas *AllowedConsumers

+ EnforceFsGroup bool

type RedisSentinelSpec

+ DisableAuth bool

type RedisSpec

+ AllowedSchemas *AllowedConsumers

+ DisableAuth bool

v0.24.0

Nov 22, 2021

Changes in this version

+ func GetDatabasePods(db metav1.Object, stsLister appslister.StatefulSetLister, pods []core.Pod) ([]core.Pod, error)

v0.23.0

Nov 16, 2021

Changes in this version

+ const ComponentConnectionPooler

+ const DefaultConfigKey

+ const ElasticsearchOpenSearchConfigDir

+ const ElasticsearchOpenSearchDataDir

+ const ElasticsearchOpenSearchReadallMonitorRole

+ const ElasticsearchOpenSearchSecurityConfigDir

+ const MongoDBReplicaSetConfig

+ const MySQLComponentDB

+ const MySQLComponentKey

+ const MySQLComponentRouter

+ const MySQLReplicationUser

+ const MySQLRouterConfigDirectoryName

+ const MySQLRouterConfigDirectoryPath

+ const MySQLRouterContainerName

+ const MySQLRouterInitScriptDirectoryName

+ const MySQLRouterInitScriptDirectoryPath

+ const MySQLRouterReadOnlyPort

+ const MySQLRouterReadOnlyPortName

+ const MySQLRouterReadWritePort

+ const MySQLRouterReadWritePortName

+ const MySQLRouterTLSDirectoryName

+ const MySQLRouterTLSDirectoryPath

+ const RedisConfigKey

+ const ServerReady

type Elasticsearch

+ func (e Elasticsearch) PodControllerLabels(extraLabels ...map[string]string) map[string]string

+ func (e Elasticsearch) PodLabels(extraLabels ...map[string]string) map[string]string

+ func (e Elasticsearch) ServiceLabels(alias ServiceAlias, extraLabels ...map[string]string) map[string]string

type Etcd

+ func (e Etcd) PodControllerLabels() map[string]string

+ func (e Etcd) PodLabels() map[string]string

+ func (e Etcd) ServiceLabels(alias ServiceAlias, extraLabels ...map[string]string) map[string]string

type MariaDB

+ func (m MariaDB) PodControllerLabels() map[string]string

+ func (m MariaDB) PodLabels() map[string]string

+ func (m MariaDB) ServiceLabels(alias ServiceAlias, extraLabels ...map[string]string) map[string]string

type Memcached

+ func (m Memcached) PodControllerLabels() map[string]string

+ func (m Memcached) PodLabels() map[string]string

+ func (m Memcached) ServiceLabels(alias ServiceAlias, extraLabels ...map[string]string) map[string]string

type MongoDB

+ func (m MongoDB) PodControllerLabels(podControllerLabels map[string]string, extraLabels ...map[string]string) map[string]string

+ func (m MongoDB) PodLabels(podTemplateLabels map[string]string, extraLabels ...map[string]string) map[string]string

+ func (m MongoDB) ServiceLabels(alias ServiceAlias, extraLabels ...map[string]string) map[string]string

type MySQL

+ func (m *MySQL) GetRouterName() string

+ func (m *MySQL) IsInnoDBCluster() bool

+ func (m MySQL) PodControllerLabels() map[string]string

+ func (m MySQL) PodLabels() map[string]string

+ func (m MySQL) RouterOffshootLabels() map[string]string

+ func (m MySQL) RouterOffshootSelectors() map[string]string

+ func (m MySQL) RouterPodControllerLabels() map[string]string

+ func (m MySQL) RouterPodLabels() map[string]string

+ func (m MySQL) ServiceLabels(alias ServiceAlias, extraLabels ...map[string]string) map[string]string

type MySQLCertificateAlias

+ const MySQLRouterCert

type MySQLClusterMode

+ const MySQLClusterModeGroupReplication

+ const MySQLClusterModeInnoDBCluster

type MySQLClusterTopology

+ InnoDBCluster *MySQLInnoDBClusterSpec

+ type MySQLInnoDBClusterSpec struct

+ Mode *MySQLGroupMode

+ Router MySQLRouterSpec

+ func (*MySQLInnoDBClusterSpec) Descriptor() ([]byte, []int)

+ func (*MySQLInnoDBClusterSpec) ProtoMessage()

+ func (in *MySQLInnoDBClusterSpec) DeepCopy() *MySQLInnoDBClusterSpec

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

+ func (m *MySQLInnoDBClusterSpec) Marshal() (dAtA []byte, err error)

+ func (m *MySQLInnoDBClusterSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *MySQLInnoDBClusterSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MySQLInnoDBClusterSpec) Reset()

+ func (m *MySQLInnoDBClusterSpec) Size() (n int)

+ func (m *MySQLInnoDBClusterSpec) Unmarshal(dAtA []byte) error

+ func (m *MySQLInnoDBClusterSpec) XXX_DiscardUnknown()

+ func (m *MySQLInnoDBClusterSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MySQLInnoDBClusterSpec) XXX_Merge(src proto.Message)

+ func (m *MySQLInnoDBClusterSpec) XXX_Size() int

+ func (m *MySQLInnoDBClusterSpec) XXX_Unmarshal(b []byte) error

+ func (this *MySQLInnoDBClusterSpec) String() string

+ type MySQLRouterSpec struct

+ PodTemplate *ofst.PodTemplateSpec

+ Replicas *int32

+ func (*MySQLRouterSpec) Descriptor() ([]byte, []int)

+ func (*MySQLRouterSpec) ProtoMessage()

+ func (in *MySQLRouterSpec) DeepCopy() *MySQLRouterSpec

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

+ func (m *MySQLRouterSpec) Marshal() (dAtA []byte, err error)

+ func (m *MySQLRouterSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *MySQLRouterSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MySQLRouterSpec) Reset()

+ func (m *MySQLRouterSpec) Size() (n int)

+ func (m *MySQLRouterSpec) Unmarshal(dAtA []byte) error

+ func (m *MySQLRouterSpec) XXX_DiscardUnknown()

+ func (m *MySQLRouterSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MySQLRouterSpec) XXX_Merge(src proto.Message)

+ func (m *MySQLRouterSpec) XXX_Size() int

+ func (m *MySQLRouterSpec) XXX_Unmarshal(b []byte) error

+ func (this *MySQLRouterSpec) String() string

type PerconaXtraDB

+ func (p PerconaXtraDB) PodControllerLabels() map[string]string

+ func (p PerconaXtraDB) PodLabels() map[string]string

+ func (p PerconaXtraDB) ServiceLabels(alias ServiceAlias, extraLabels ...map[string]string) map[string]string

type PgBouncer

+ func (p PgBouncer) PodControllerLabels() map[string]string

+ func (p PgBouncer) PodLabels() map[string]string

+ func (p PgBouncer) ServiceLabels(alias ServiceAlias, extraLabels ...map[string]string) map[string]string

type Postgres

+ func (p Postgres) PodControllerLabels() map[string]string

+ func (p Postgres) PodLabels() map[string]string

+ func (p Postgres) ServiceLabels(alias ServiceAlias, extraLabels ...map[string]string) map[string]string

type ProxySQL

+ func (p ProxySQL) PodControllerLabels() map[string]string

+ func (p ProxySQL) PodLabels() map[string]string

+ func (p ProxySQL) ServiceLabels(alias ServiceAlias, extraLabels ...map[string]string) map[string]string

type Redis

+ func (r Redis) CustomConfigSecretName() string

+ func (r Redis) PodControllerLabels(extraLabels ...map[string]string) map[string]string

+ func (r Redis) PodLabels(extraLabels ...map[string]string) map[string]string

+ func (r Redis) ServiceLabels(alias ServiceAlias, extraLabels ...map[string]string) map[string]string

type RedisSentinel

+ func (rs RedisSentinel) PodControllerLabels() map[string]string

+ func (rs RedisSentinel) PodLabels() map[string]string

+ func (rs RedisSentinel) ServiceLabels(alias ServiceAlias, extraLabels ...map[string]string) map[string]string

v0.22.0

Sep 24, 2021

Changes in this version

+ const RedisScriptVolumeName

+ const RedisScriptVolumePath

+ const RedisSentinelPort

+ const RedisSentinelPortName

+ const ResourceCodeRedisSentinel

+ const ResourceKindRedisSentinel

+ const ResourcePluralRedisSentinel

+ const ResourceSingularRedisSentinel

type Redis

+ func (r Redis) StandbyServiceName() string

type RedisMode

+ const RedisModeSentinel

+ type RedisSentinel struct

+ Spec RedisSentinelSpec

+ Status RedisSentinelStatus

+ func (*RedisSentinel) Descriptor() ([]byte, []int)

+ func (*RedisSentinel) ProtoMessage()

+ func (in *RedisSentinel) DeepCopy() *RedisSentinel

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

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

+ func (m *RedisSentinel) Marshal() (dAtA []byte, err error)

+ func (m *RedisSentinel) MarshalTo(dAtA []byte) (int, error)

+ func (m *RedisSentinel) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RedisSentinel) Reset()

+ func (m *RedisSentinel) Size() (n int)

+ func (m *RedisSentinel) Unmarshal(dAtA []byte) error

+ func (m *RedisSentinel) XXX_DiscardUnknown()

+ func (m *RedisSentinel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RedisSentinel) XXX_Merge(src proto.Message)

+ func (m *RedisSentinel) XXX_Size() int

+ func (m *RedisSentinel) XXX_Unmarshal(b []byte) error

+ func (r *RedisSentinel) GetPersistentSecrets() []string

+ func (rs *RedisSentinel) CertificateName(alias RedisCertificateAlias) string

+ func (rs *RedisSentinel) GetCertSecretName(alias RedisCertificateAlias) string

+ func (rs *RedisSentinel) ReplicasAreReady(lister appslister.StatefulSetLister) (bool, string, error)

+ func (rs *RedisSentinel) SetDefaults(topology *core_util.Topology)

+ func (rs *RedisSentinel) SetTLSDefaults()

+ func (rs RedisSentinel) AppBindingMeta() appcat.AppBindingMeta

+ func (rs RedisSentinel) ConfigSecretName() string

+ func (rs RedisSentinel) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

+ func (rs RedisSentinel) GoverningServiceName() string

+ func (rs RedisSentinel) OffshootLabels() map[string]string

+ func (rs RedisSentinel) OffshootName() string

+ func (rs RedisSentinel) OffshootSelectors() map[string]string

+ func (rs RedisSentinel) ResourceFQN() string

+ func (rs RedisSentinel) ResourceKind() string

+ func (rs RedisSentinel) ResourcePlural() string

+ func (rs RedisSentinel) ResourceShortCode() string

+ func (rs RedisSentinel) ResourceSingular() string

+ func (rs RedisSentinel) StatsService() mona.StatsAccessor

+ func (rs RedisSentinel) StatsServiceLabels() map[string]string

+ func (this *RedisSentinel) String() string

+ type RedisSentinelList struct

+ Items []RedisSentinel

+ func (*RedisSentinelList) Descriptor() ([]byte, []int)

+ func (*RedisSentinelList) ProtoMessage()

+ func (in *RedisSentinelList) DeepCopy() *RedisSentinelList

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

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

+ func (m *RedisSentinelList) Marshal() (dAtA []byte, err error)

+ func (m *RedisSentinelList) MarshalTo(dAtA []byte) (int, error)

+ func (m *RedisSentinelList) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RedisSentinelList) Reset()

+ func (m *RedisSentinelList) Size() (n int)

+ func (m *RedisSentinelList) Unmarshal(dAtA []byte) error

+ func (m *RedisSentinelList) XXX_DiscardUnknown()

+ func (m *RedisSentinelList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RedisSentinelList) XXX_Merge(src proto.Message)

+ func (m *RedisSentinelList) XXX_Size() int

+ func (m *RedisSentinelList) XXX_Unmarshal(b []byte) error

+ func (this *RedisSentinelList) String() string

+ type RedisSentinelRef struct

+ Name string

+ Namespace string

+ func (*RedisSentinelRef) Descriptor() ([]byte, []int)

+ func (*RedisSentinelRef) ProtoMessage()

+ func (in *RedisSentinelRef) DeepCopy() *RedisSentinelRef

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

+ func (m *RedisSentinelRef) Marshal() (dAtA []byte, err error)

+ func (m *RedisSentinelRef) MarshalTo(dAtA []byte) (int, error)

+ func (m *RedisSentinelRef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RedisSentinelRef) Reset()

+ func (m *RedisSentinelRef) Size() (n int)

+ func (m *RedisSentinelRef) Unmarshal(dAtA []byte) error

+ func (m *RedisSentinelRef) XXX_DiscardUnknown()

+ func (m *RedisSentinelRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RedisSentinelRef) XXX_Merge(src proto.Message)

+ func (m *RedisSentinelRef) XXX_Size() int

+ func (m *RedisSentinelRef) XXX_Unmarshal(b []byte) error

+ func (this *RedisSentinelRef) String() string

+ type RedisSentinelSpec struct

+ AuthSecret *core.LocalObjectReference

+ Halted bool

+ Monitor *mona.AgentSpec

+ PodTemplate ofst.PodTemplateSpec

+ Replicas *int32

+ ServiceTemplates []NamedServiceTemplateSpec

+ Storage *core.PersistentVolumeClaimSpec

+ StorageType StorageType

+ TLS *kmapi.TLSConfig

+ TerminationPolicy TerminationPolicy

+ Version string

+ func (*RedisSentinelSpec) Descriptor() ([]byte, []int)

+ func (*RedisSentinelSpec) ProtoMessage()

+ func (in *RedisSentinelSpec) DeepCopy() *RedisSentinelSpec

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

+ func (m *RedisSentinelSpec) Marshal() (dAtA []byte, err error)

+ func (m *RedisSentinelSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *RedisSentinelSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RedisSentinelSpec) Reset()

+ func (m *RedisSentinelSpec) Size() (n int)

+ func (m *RedisSentinelSpec) Unmarshal(dAtA []byte) error

+ func (m *RedisSentinelSpec) XXX_DiscardUnknown()

+ func (m *RedisSentinelSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RedisSentinelSpec) XXX_Merge(src proto.Message)

+ func (m *RedisSentinelSpec) XXX_Size() int

+ func (m *RedisSentinelSpec) XXX_Unmarshal(b []byte) error

+ func (this *RedisSentinelSpec) String() string

+ type RedisSentinelStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase DatabasePhase

+ func (*RedisSentinelStatus) Descriptor() ([]byte, []int)

+ func (*RedisSentinelStatus) ProtoMessage()

+ func (in *RedisSentinelStatus) DeepCopy() *RedisSentinelStatus

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

+ func (m *RedisSentinelStatus) Marshal() (dAtA []byte, err error)

+ func (m *RedisSentinelStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *RedisSentinelStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RedisSentinelStatus) Reset()

+ func (m *RedisSentinelStatus) Size() (n int)

+ func (m *RedisSentinelStatus) Unmarshal(dAtA []byte) error

+ func (m *RedisSentinelStatus) XXX_DiscardUnknown()

+ func (m *RedisSentinelStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RedisSentinelStatus) XXX_Merge(src proto.Message)

+ func (m *RedisSentinelStatus) XXX_Size() int

+ func (m *RedisSentinelStatus) XXX_Unmarshal(b []byte) error

+ func (this *RedisSentinelStatus) String() string

type RedisSpec

+ SentinelRef *RedisSentinelRef

v0.21.0

Sep 9, 2021

Changes in this version

+ const EnvPostgresPassword

+ const EnvPostgresUser

+ const MariaDBCoordinatorContainerName

+ const MariaDBInitDBVolumeName

+ const MariaDBInitScriptVolumeMountPath

+ const MariaDBInitScriptVolumeName

+ const MariaDBRunScriptVolumeMountPath

+ const MariaDBRunScriptVolumeName

+ var CoordinatorDefaultResources = core.ResourceRequirements

+ type CoordinatorSpec struct

+ Resources core.ResourceRequirements

+ SecurityContext *core.SecurityContext

+ func (*CoordinatorSpec) Descriptor() ([]byte, []int)

+ func (*CoordinatorSpec) ProtoMessage()

+ func (in *CoordinatorSpec) DeepCopy() *CoordinatorSpec

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

+ func (m *CoordinatorSpec) Marshal() (dAtA []byte, err error)

+ func (m *CoordinatorSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *CoordinatorSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CoordinatorSpec) Reset()

+ func (m *CoordinatorSpec) Size() (n int)

+ func (m *CoordinatorSpec) Unmarshal(dAtA []byte) error

+ func (m *CoordinatorSpec) XXX_DiscardUnknown()

+ func (m *CoordinatorSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CoordinatorSpec) XXX_Merge(src proto.Message)

+ func (m *CoordinatorSpec) XXX_Size() int

+ func (m *CoordinatorSpec) XXX_Unmarshal(b []byte) error

+ func (this *CoordinatorSpec) String() string

type MariaDBCertificateAlias

+ const MariaDBClientCert

type MariaDBSpec

+ Coordinator CoordinatorSpec

type MongoDBSpec

+ Coordinator CoordinatorSpec

type MySQLSpec

+ Coordinator CoordinatorSpec

type PostgresSpec

+ Coordinator CoordinatorSpec

type RedisSpec

+ Coordinator CoordinatorSpec

v0.20.0

Aug 23, 2021

Changes in this version

+ const ElasticsearchPerformanceAnalyzerPort

+ const ElasticsearchPerformanceAnalyzerPortName

+ const ElasticsearchSecureSettingsDir

+ const EnvRedisPassword

+ const EnvRedisUser

type ElasticsearchSpec

+ SecureConfigSecret *core.LocalObjectReference

type PostgreLeaderElectionConfig

+ Resources core.ResourceRequirements

type Redis

+ func (r *Redis) GetCertSecretName(alias RedisCertificateAlias) string

v0.19.0

Jun 23, 2021

Changes in this version

+ const HealthCheckInterval

+ const MariaDBCustomConfigVolumeName

+ const MariaDBInitContainerName

+ const MariaDBTLSConfigCustom

+ const PostgresPgCoordinatorStatus

+ const PostgresPgCoordinatorStatusPause

+ const PostgresPgCoordinatorStatusResume

+ const PostgresPgCoordinatorStatusResumeNonTransferable

+ var DefaultResources = core.ResourceRequirements

+ func ConvertBytesInMB(value int64) string

+ func GetSharedBufferSizeForPostgres(resource *resource.Quantity) string

+ func Round(val float64, roundOn float64, places int) (newVal float64)

type Elasticsearch

+ func (e *Elasticsearch) CoordinatingStatefulSetName() string

+ func (e *Elasticsearch) DataColdStatefulSetName() string

+ func (e *Elasticsearch) DataContentStatefulSetName() string

+ func (e *Elasticsearch) DataFrozenStatefulSetName() string

+ func (e *Elasticsearch) DataHotStatefulSetName() string

+ func (e *Elasticsearch) DataWarmStatefulSetName() string

+ func (e *Elasticsearch) MLStatefulSetName() string

+ func (e *Elasticsearch) TransformStatefulSetName() string

+ func (e Elasticsearch) NodeRoleSpecificLabelKey(roleType ElasticsearchNodeRoleType) string

+ func (e Elasticsearch) NodeRoleSpecificSelectors(roleType ElasticsearchNodeRoleType) map[string]string

type ElasticsearchClusterTopology

+ Coordinating *ElasticsearchNode

+ DataCold *ElasticsearchNode

+ DataContent *ElasticsearchNode

+ DataFrozen *ElasticsearchNode

+ DataHot *ElasticsearchNode

+ DataWarm *ElasticsearchNode

+ ML *ElasticsearchNode

+ Transform *ElasticsearchNode

+ func (esTopology *ElasticsearchClusterTopology) ToMap() map[ElasticsearchNodeRoleType]ElasticsearchNode

+ type ElasticsearchNodeRoleType string

+ const ElasticsearchNodeRoleTypeCoordinating

+ const ElasticsearchNodeRoleTypeData

+ const ElasticsearchNodeRoleTypeDataCold

+ const ElasticsearchNodeRoleTypeDataContent

+ const ElasticsearchNodeRoleTypeDataFrozen

+ const ElasticsearchNodeRoleTypeDataHot

+ const ElasticsearchNodeRoleTypeDataWarm

+ const ElasticsearchNodeRoleTypeIngest

+ const ElasticsearchNodeRoleTypeML

+ const ElasticsearchNodeRoleTypeMaster

+ const ElasticsearchNodeRoleTypeRemoteClusterClient

+ const ElasticsearchNodeRoleTypeTransform

type MariaDB

+ func (m *MariaDB) AuthSecretName() string

+ func (m *MariaDB) InlineConfigSecretName() string

type MySQLClusterMode

+ const InnoDBClusterModeGroup

v0.19.0-rc.0

Jun 22, 2021

v0.18.0

Apr 15, 2021

Changes in this version

+ type AddressType string

+ const AddressTypeDNS

+ const AddressTypeIP

+ const AddressTypeIPv4

+ const AddressTypeIPv6

+ func (a AddressType) IsIP() bool

type Elasticsearch

+ func (e *Elasticsearch) GetCertSecretName(alias ElasticsearchCertificateAlias) string

type MariaDB

+ func (m *MariaDB) GetCertSecretName(alias MariaDBCertificateAlias) string

type MongoDB

+ func (m *MongoDB) GetCertSecretName(alias MongoDBCertificateAlias, stsName string) string

type MySQLSpec

+ UseAddressType AddressType

type Postgres

+ func (p *Postgres) GetCertSecretName(alias PostgresCertificateAlias) string

v0.17.1

Mar 17, 2021

Changes in this version

+ const ElasticsearchOpendistroInternalUserFileName

+ const ElasticsearchOpendistroRolesMappingFileName

+ const ElasticsearchSearchGuardInternalUserFileName

+ const ElasticsearchSearchGuardRolesMappingFileName

type Elasticsearch

+ func (e *Elasticsearch) DefaultUserCredSecretName(userName string) string

+ func (e *Elasticsearch) GetUserCredSecretName(username string) (string, error)

type ElasticsearchUserSpec

+ SecretName string

v0.17.0

Mar 10, 2021

Changes in this version

+ const PostgresCoordinatorClientPort

+ const PostgresCoordinatorClientPortName

+ const PostgresCoordinatorContainerName

+ const PostgresCoordinatorPort

+ const PostgresCoordinatorPortName

+ const PostgresCurrentWalLSN

+ const PostgresCurrentXlogLocation

+ const PostgresDefaultUsername

+ const PostgresKeyFileSecretSuffix

+ const PostgresLastWalReceivePostion

+ const PostgresLastWalReplayLSN

+ const PostgresLastXlogReceiveLocation

+ const PostgresLastXlogReplayLocation

+ const PostgresPEMSecretSuffix

+ const PostgresRunScriptMountPath

+ const PostgresRunScriptVolumeName

+ const PostgresUID

+ const PostgresWalLSNDiff

+ const PostgresXlogLocationDiff

type Elasticsearch

+ func (e *Elasticsearch) InitialMasterNodes() []string

type MariaDB

+ func (m *MariaDB) CertificateName(alias MariaDBCertificateAlias) string

+ func (m *MariaDB) MustCertSecretName(alias MariaDBCertificateAlias) string

+ func (m *MariaDB) SetTLSDefaults()

+ func (m MariaDB) PrimaryServiceDNS() string

type MariaDBSpec

+ RequireSSL bool

+ type PostgreLeaderElectionConfig struct

+ ElectionTick int32

+ HeartbeatTick int32

+ LeaseDurationSeconds int32

+ MaximumLagBeforeFailover uint64

+ Period metav1.Duration

+ RenewDeadlineSeconds int32

+ RetryPeriodSeconds int32

+ func (*PostgreLeaderElectionConfig) Descriptor() ([]byte, []int)

+ func (*PostgreLeaderElectionConfig) ProtoMessage()

+ func (in *PostgreLeaderElectionConfig) DeepCopy() *PostgreLeaderElectionConfig

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

+ func (m *PostgreLeaderElectionConfig) Marshal() (dAtA []byte, err error)

+ func (m *PostgreLeaderElectionConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *PostgreLeaderElectionConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PostgreLeaderElectionConfig) Reset()

+ func (m *PostgreLeaderElectionConfig) Size() (n int)

+ func (m *PostgreLeaderElectionConfig) Unmarshal(dAtA []byte) error

+ func (m *PostgreLeaderElectionConfig) XXX_DiscardUnknown()

+ func (m *PostgreLeaderElectionConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PostgreLeaderElectionConfig) XXX_Merge(src proto.Message)

+ func (m *PostgreLeaderElectionConfig) XXX_Size() int

+ func (m *PostgreLeaderElectionConfig) XXX_Unmarshal(b []byte) error

+ func (this *PostgreLeaderElectionConfig) String() string

type Postgres

+ func (p *Postgres) CertificateName(alias PostgresCertificateAlias) string

+ func (p *Postgres) MustCertSecretName(alias PostgresCertificateAlias) string

+ func (p *Postgres) SetTLSDefaults()

type PostgresCertificateAlias

+ const PostgresClientCert

+ type PostgresClientAuthMode string

+ const ClientAuthModeCert

+ const ClientAuthModeMD5

+ const ClientAuthModeScram

+ type PostgresSSLMode string

+ const PostgresSSLModeAllow

+ const PostgresSSLModeDisable

+ const PostgresSSLModePrefer

+ const PostgresSSLModeRequire

+ const PostgresSSLModeVerifyCA

+ const PostgresSSLModeVerifyFull

type PostgresSpec

+ ClientAuthMode PostgresClientAuthMode

+ SSLMode PostgresSSLMode

v0.16.2

Jan 23, 2021

v0.16.1

Jan 14, 2021

Changes in this version

+ const MongoDBInitialConfigDirectoryName

v0.16.0

Jan 14, 2021

Changes in this version

+ const DBExporterTLSVolume

+ const DBTLSVolume

+ const DefaultVolumeClaimTemplateName

+ const ElasticsearchDataNodeSuffix

+ const ElasticsearchIngestNodeSuffix

+ const ElasticsearchMasterNodeSuffix

+ const MongoDBAuthSecretSuffix

+ const MongoDBCertDirectoryName

+ const MongoDBClientCertDirectoryName

+ const MongoDBClientCertDirectoryPath

+ const MongoDBConfigDirectoryPath

+ const MongoDBDataDirectoryName

+ const MongoDBDataDirectoryPath

+ const MongoDBDefaultVolumeClaimTemplateName

+ const MongoDBInitScriptDirectoryName

+ const MongoDBInitScriptDirectoryPath

+ const MongoDBInitialConfigDirectoryPath

+ const MongoDBInitialKeyDirectoryName

+ const MongoDBInitialKeyDirectoryPath

+ const MongoDBKeyForKeyFile

+ const MongoDBServerCertDirectoryName

+ const MongoDBServerCertDirectoryPath

+ const MongoDBWorkDirectoryName

+ const MongoDBWorkDirectoryPath

+ const MongodbUser

+ const NodeTypeConfig

+ const NodeTypeMongos

+ const NodeTypeShard

+ var DefaultResourceLimits = core.ResourceList

+ func MySQLExporterTLSArg() string

+ func MySQLRequireSSLArg() string

+ func SetDefaultResourceLimits(req *core.ResourceRequirements, defaultLimits core.ResourceList)

type Elasticsearch

+ func (e Elasticsearch) DataSelectors() map[string]string

+ func (e Elasticsearch) IngestSelectors() map[string]string

+ func (e Elasticsearch) MasterSelectors() map[string]string

+ func (e Elasticsearch) ResourceFQN() string

type ElasticsearchNode

+ Suffix string

type ElasticsearchSpec

+ KernelSettings *KernelSettings

type Etcd

+ func (e Etcd) ResourceFQN() string

+ type KernelSettings struct

+ Privileged bool

+ Sysctls []core.Sysctl

+ func (*KernelSettings) Descriptor() ([]byte, []int)

+ func (*KernelSettings) ProtoMessage()

+ func (in *KernelSettings) DeepCopy() *KernelSettings

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

+ func (m *KernelSettings) Marshal() (dAtA []byte, err error)

+ func (m *KernelSettings) MarshalTo(dAtA []byte) (int, error)

+ func (m *KernelSettings) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *KernelSettings) Reset()

+ func (m *KernelSettings) Size() (n int)

+ func (m *KernelSettings) Unmarshal(dAtA []byte) error

+ func (m *KernelSettings) XXX_DiscardUnknown()

+ func (m *KernelSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *KernelSettings) XXX_Merge(src proto.Message)

+ func (m *KernelSettings) XXX_Size() int

+ func (m *KernelSettings) XXX_Unmarshal(b []byte) error

+ func (this *KernelSettings) String() string

type MariaDB

+ func (m MariaDB) ResourceFQN() string

type Memcached

+ func (m Memcached) ResourceFQN() string

type MongoDB

+ func (m *MongoDB) ConfigSecretName(nodeType string) string

+ func (m MongoDB) ResourceFQN() string

type MySQL

+ func (m *MySQL) MySQLTLSArgs() []string

+ func (m MySQL) Hosts() []string

+ func (m MySQL) PrimaryServiceDNS() string

+ func (m MySQL) ResourceFQN() string

type PerconaXtraDB

+ func (p PerconaXtraDB) ResourceFQN() string

type PgBouncer

+ func (p PgBouncer) ResourceFQN() string

type Postgres

+ func (p Postgres) ResourceFQN() string

type ProxySQL

+ func (p ProxySQL) ResourceFQN() string

type Redis

+ func (r Redis) Address() string

+ func (r Redis) ResourceFQN() string

v0.16.0-rc.0

Jan 3, 2021

v0.15.2

Dec 10, 2020

Changes in this version

type Elasticsearch

+ func (e *Elasticsearch) CombinedStatefulSetName() string

+ func (e *Elasticsearch) DataStatefulSetName() string

+ func (e *Elasticsearch) IngestStatefulSetName() string

+ func (e *Elasticsearch) MasterStatefulSetName() string

v0.15.1

Nov 12, 2020

Changes in this version

+ const DefaultCPURequest

+ const DefaultMemoryRequest

+ const MariaDBClusterCustomConfigMountPath

+ const MariaDBClusterRecommendedVersion

+ const MariaDBCustomConfigMountPath

+ const MariaDBDataLostFoundPath

+ const MariaDBDataMountPath

+ const MariaDBDefaultClusterSize

+ const MariaDBInitDBMountPath

+ const MariaDBKey

+ const MariaDBMaxClusterNameLength

+ const MariaDBStandaloneReplicas

type MariaDB

+ func (m MariaDB) ClusterName() string

+ func (m MariaDB) GetAuthSecretName() string

+ func (m MariaDB) IsCluster() bool

+ func (m MariaDB) PeerName(idx int) string

v0.15.0

Nov 11, 2020

Changes in this version

+ const DatabasePodPrimary

+ const DatabasePodStandby

+ const DefaultCPULimit

+ const DefaultMemoryLimit

+ const ElasticsearchContainerName

+ const ElasticsearchExporterContainerName

+ const ElasticsearchInitConfigMergerContainerName

+ const ElasticsearchInitSysctlContainerName

+ const ReplicationModeDetectorContainerName

+ func GetServiceTemplate(templates []NamedServiceTemplateSpec, alias ServiceAlias) ofst.ServiceTemplateSpec

+ func HasServiceTemplate(templates []NamedServiceTemplateSpec, alias ServiceAlias) bool

type Elasticsearch

+ func (e *Elasticsearch) MasterDiscoveryServiceName() string

type ElasticsearchSpec

+ ServiceTemplates []NamedServiceTemplateSpec

type EtcdSpec

+ ServiceTemplates []NamedServiceTemplateSpec

type MariaDBSpec

+ ServiceTemplates []NamedServiceTemplateSpec

type MemcachedSpec

+ ServiceTemplates []NamedServiceTemplateSpec

type MongoDBSpec

+ ServiceTemplates []NamedServiceTemplateSpec

type MySQLSpec

+ ServiceTemplates []NamedServiceTemplateSpec

+ type NamedServiceTemplateSpec struct

+ Alias ServiceAlias

+ ServiceTemplate ofst.ServiceTemplateSpec

+ func (*NamedServiceTemplateSpec) Descriptor() ([]byte, []int)

+ func (*NamedServiceTemplateSpec) ProtoMessage()

+ func (in *NamedServiceTemplateSpec) DeepCopy() *NamedServiceTemplateSpec

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

+ func (m *NamedServiceTemplateSpec) Marshal() (dAtA []byte, err error)

+ func (m *NamedServiceTemplateSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *NamedServiceTemplateSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *NamedServiceTemplateSpec) Reset()

+ func (m *NamedServiceTemplateSpec) Size() (n int)

+ func (m *NamedServiceTemplateSpec) Unmarshal(dAtA []byte) error

+ func (m *NamedServiceTemplateSpec) XXX_DiscardUnknown()

+ func (m *NamedServiceTemplateSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *NamedServiceTemplateSpec) XXX_Merge(src proto.Message)

+ func (m *NamedServiceTemplateSpec) XXX_Size() int

+ func (m *NamedServiceTemplateSpec) XXX_Unmarshal(b []byte) error

+ func (this *NamedServiceTemplateSpec) String() string

type PerconaXtraDBSpec

+ ServiceTemplates []NamedServiceTemplateSpec

type PgBouncerSpec

+ ServiceTemplates []NamedServiceTemplateSpec

type PostgresSpec

+ ServiceTemplates []NamedServiceTemplateSpec

type ProxySQLSpec

+ ServiceTemplates []NamedServiceTemplateSpec

type RedisSpec

+ ServiceTemplates []NamedServiceTemplateSpec

+ type ServiceAlias string

+ const PrimaryServiceAlias

+ const StandbyServiceAlias

+ const StatsServiceAlias

v0.14.1

Nov 7, 2020

v0.14.0

Oct 27, 2020

Changes in this version

+ const AllReplicasAreReady

+ const ComponentDatabase

+ const ContainerExporterName

+ const DBCustomConfigName

+ const DataRestoreStartedByExternalInitializer

+ const DatabaseAcceptingConnection

+ const DatabaseAcceptingConnectionRequest

+ const DatabaseDataRestoreStarted

+ const DatabaseDataRestored

+ const DatabaseHalted

+ const DatabaseHaltedSuccessfully

+ const DatabaseNamePrefix

+ const DatabaseNotAcceptingConnectionRequest

+ const DatabasePaused

+ const DatabaseProvisioned

+ const DatabaseProvisioningStarted

+ const DatabaseProvisioningStartedSuccessfully

+ const DatabaseReady

+ const DatabaseReplicaReady

+ const DatabaseSuccessfullyProvisioned

+ const DatabaseSuccessfullyRestored

+ const DefaultPasswordLength

+ const DefaultStatsPath

+ const ElasticsearchConfigDir

+ const ElasticsearchCustomConfigDir

+ const ElasticsearchDataDir

+ const ElasticsearchDataNodePrefix

+ const ElasticsearchIngestNodePrefix

+ const ElasticsearchKey

+ const ElasticsearchMasterNodePrefix

+ const ElasticsearchMaxHeapSize

+ const ElasticsearchMetricsPort

+ const ElasticsearchMetricsPortName

+ const ElasticsearchMinHeapSize

+ const ElasticsearchNodeAffinityTemplateVar

+ const ElasticsearchNodeRoleData

+ const ElasticsearchNodeRoleIngest

+ const ElasticsearchNodeRoleMaster

+ const ElasticsearchNodeRoleSet

+ const ElasticsearchOpendistroReadallMonitorRole

+ const ElasticsearchOpendistroSecurityConfigDir

+ const ElasticsearchRestPort

+ const ElasticsearchRestPortName

+ const ElasticsearchSearchGuardReadallMonitorRoleV6

+ const ElasticsearchSearchGuardReadallMonitorRoleV7

+ const ElasticsearchSearchGuardSecurityConfigDir

+ const ElasticsearchStatusGreen

+ const ElasticsearchStatusRed

+ const ElasticsearchStatusYellow

+ const ElasticsearchTempConfigDir

+ const ElasticsearchTransportPort

+ const ElasticsearchTransportPortName

+ const EtcdKey

+ const FailedToRestoreData

+ const KubeDBOrganization

+ const LabelDatabaseKind

+ const LabelDatabaseName

+ const LabelProxySQLLoadBalance

+ const LabelProxySQLName

+ const LabelRole

+ const LocalHost

+ const LocalHostIP

+ const MemcachedDatabasePort

+ const MemcachedDatabasePortName

+ const MemcachedKey

+ const MemcachedPrimaryServicePortName

+ const MongoCertDirectory

+ const MongoClientFileName

+ const MongoDBConfigDirectoryName

+ const MongoDBConfigLabelKey

+ const MongoDBContainerName

+ const MongoDBCustomConfigFile

+ const MongoDBDatabasePort

+ const MongoDBDatabasePortName

+ const MongoDBInitBootstrapContainerName

+ const MongoDBInitInstallContainerName

+ const MongoDBKey

+ const MongoDBKeyFileSecretSuffix

+ const MongoDBMongosLabelKey

+ const MongoDBPrimaryServicePortName

+ const MongoDBRootUsername

+ const MongoDBShardAffinityTemplateVar

+ const MongoDBShardLabelKey

+ const MongoPemFileName

+ const MySQLContainerReplicationModeDetectorName

+ const MySQLDatabasePort

+ const MySQLDatabasePortName

+ const MySQLDefaultBaseServerID

+ const MySQLDefaultGroupSize

+ const MySQLGRRecommendedVersion

+ const MySQLGroupComPort

+ const MySQLKey

+ const MySQLLabelRole

+ const MySQLMaxBaseServerID

+ const MySQLMaxGroupMembers

+ const MySQLMetricsExporterConfigSecretSuffix

+ const MySQLName

+ const MySQLPodPrimary

+ const MySQLPodStandby

+ const MySQLPrimaryServicePortName

+ const MySQLRootPassword

+ const MySQLRootUserName

+ const MySQLStandbyServicePortName

+ const MySQLTLSConfigCustom

+ const MySQLTLSConfigFalse

+ const MySQLTLSConfigPreferred

+ const MySQLTLSConfigSkipVerify

+ const MySQLTLSConfigTrue

+ const PerconaXtraDBClusterCustomConfigMountPath

+ const PerconaXtraDBClusterRecommendedVersion

+ const PerconaXtraDBCustomConfigMountPath

+ const PerconaXtraDBDataLostFoundPath

+ const PerconaXtraDBDataMountPath

+ const PerconaXtraDBDefaultClusterSize

+ const PerconaXtraDBInitDBMountPath

+ const PerconaXtraDBKey

+ const PerconaXtraDBMaxClusterNameLength

+ const PerconaXtraDBStandaloneReplicas

+ const PgBouncerAdminUsername

+ const PgBouncerConfigFile

+ const PgBouncerDatabasePort

+ const PgBouncerDatabasePortName

+ const PgBouncerPrimaryServicePortName

+ const PgBouncerUpstreamServerCA

+ const PostgresDatabasePort

+ const PostgresDatabasePortName

+ const PostgresKey

+ const PostgresLabelRole

+ const PostgresPodPrimary

+ const PostgresPodStandby

+ const PostgresPrimaryServicePortName

+ const PostgresStandbyServicePortName

+ const ProxySQLAdminPort

+ const ProxySQLAdminPortName

+ const ProxySQLCustomConfigMountPath

+ const ProxySQLDataMountPath

+ const ProxySQLDatabasePort

+ const ProxySQLDatabasePortName

+ const ProxySQLKey

+ const ProxySQLPrimaryServicePortName

+ const ReadinessCheckFailed

+ const ReadinessCheckSucceeded

+ const RedisDatabasePort

+ const RedisDatabasePortName

+ const RedisGossipPort

+ const RedisGossipPortName

+ const RedisKey

+ const RedisKeyFileSecretSuffix

+ const RedisPEMSecretSuffix

+ const RedisPrimaryServicePortName

+ const RedisRootUsername

+ const RedisShardAffinityTemplateVar

+ const RedisShardKey

+ const ResourceCodeElasticsearch

+ const ResourceCodeEtcd

+ const ResourceCodeMariaDB

+ const ResourceCodeMemcached

+ const ResourceCodeMongoDB

+ const ResourceCodeMySQL

+ const ResourceCodePerconaXtraDB

+ const ResourceCodePgBouncer

+ const ResourceCodePostgres

+ const ResourceCodeProxySQL

+ const ResourceCodeRedis

+ const ResourceKindElasticsearch

+ const ResourceKindEtcd

+ const ResourceKindMariaDB

+ const ResourceKindMemcached

+ const ResourceKindMongoDB

+ const ResourceKindMySQL

+ const ResourceKindPerconaXtraDB

+ const ResourceKindPgBouncer

+ const ResourceKindPostgres

+ const ResourceKindProxySQL

+ const ResourceKindRedis

+ const ResourceKindStatefulSet

+ const ResourcePluralElasticsearch

+ const ResourcePluralEtcd

+ const ResourcePluralMariaDB

+ const ResourcePluralMemcached

+ const ResourcePluralMongoDB

+ const ResourcePluralMySQL

+ const ResourcePluralPerconaXtraDB

+ const ResourcePluralPgBouncer

+ const ResourcePluralPostgres

+ const ResourcePluralProxySQL

+ const ResourcePluralRedis

+ const ResourceSingularElasticsearch

+ const ResourceSingularEtcd

+ const ResourceSingularMariaDB

+ const ResourceSingularMemcached

+ const ResourceSingularMongoDB

+ const ResourceSingularMySQL

+ const ResourceSingularPerconaXtraDB

+ const ResourceSingularPgBouncer

+ const ResourceSingularPostgres

+ const ResourceSingularProxySQL

+ const ResourceSingularRedis

+ const RoleStats

+ const SomeReplicasAreNotReady

+ const TLSCACertFileName

+ const TLSCAKeyFileName

+ var AddToScheme = localSchemeBuilder.AddToScheme

+ var ErrIntOverflowGenerated = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthGenerated = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group")

+ var SchemeBuilder runtime.SchemeBuilder

+ var SchemeGroupVersion = schema.GroupVersion

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

+ func Kind(kind string) schema.GroupKind

+ func Resource(resource string) schema.GroupResource

+ type ClusterAuthMode string

+ const ClusterAuthModeKeyFile

+ const ClusterAuthModeSendKeyFile

+ const ClusterAuthModeSendX509

+ const ClusterAuthModeX509

+ type ConnectionPoolConfig struct

+ AdminUsers []string

+ AuthType string

+ AuthUser string

+ DefaultPoolSize *int64

+ IgnoreStartupParameters string

+ MaxClientConnections *int64

+ MaxDBConnections *int64

+ MaxUserConnections *int64

+ MinPoolSize *int64

+ PoolMode string

+ Port *int32

+ ReservePoolSize *int64

+ ReservePoolTimeoutSeconds *int64

+ StatsPeriodSeconds *int64

+ func (*ConnectionPoolConfig) Descriptor() ([]byte, []int)

+ func (*ConnectionPoolConfig) ProtoMessage()

+ func (in *ConnectionPoolConfig) DeepCopy() *ConnectionPoolConfig

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

+ func (m *ConnectionPoolConfig) Marshal() (dAtA []byte, err error)

+ func (m *ConnectionPoolConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *ConnectionPoolConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ConnectionPoolConfig) Reset()

+ func (m *ConnectionPoolConfig) Size() (n int)

+ func (m *ConnectionPoolConfig) Unmarshal(dAtA []byte) error

+ func (m *ConnectionPoolConfig) XXX_DiscardUnknown()

+ func (m *ConnectionPoolConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ConnectionPoolConfig) XXX_Merge(src proto.Message)

+ func (m *ConnectionPoolConfig) XXX_Size() int

+ func (m *ConnectionPoolConfig) XXX_Unmarshal(b []byte) error

+ func (this *ConnectionPoolConfig) String() string

+ type DatabasePhase string

+ const DatabasePhaseCritical

+ const DatabasePhaseDataRestoring

+ const DatabasePhaseHalted

+ const DatabasePhaseNotReady

+ const DatabasePhaseProvisioning

+ const DatabasePhaseReady

+ type Databases struct

+ Alias string

+ AuthSecretRef *core.LocalObjectReference

+ DatabaseName string

+ DatabaseRef appcat.AppReference

+ func (*Databases) Descriptor() ([]byte, []int)

+ func (*Databases) ProtoMessage()

+ func (in *Databases) DeepCopy() *Databases

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

+ func (m *Databases) Marshal() (dAtA []byte, err error)

+ func (m *Databases) MarshalTo(dAtA []byte) (int, error)

+ func (m *Databases) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Databases) Reset()

+ func (m *Databases) Size() (n int)

+ func (m *Databases) Unmarshal(dAtA []byte) error

+ func (m *Databases) XXX_DiscardUnknown()

+ func (m *Databases) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Databases) XXX_Merge(src proto.Message)

+ func (m *Databases) XXX_Size() int

+ func (m *Databases) XXX_Unmarshal(b []byte) error

+ func (this *Databases) String() string

+ type Elasticsearch struct

+ Spec ElasticsearchSpec

+ Status ElasticsearchStatus

+ func (*Elasticsearch) Descriptor() ([]byte, []int)

+ func (*Elasticsearch) ProtoMessage()

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

+ func (e *Elasticsearch) CertSecretVolumeMountPath(configDir string, alias ElasticsearchCertificateAlias) string

+ func (e *Elasticsearch) CertSecretVolumeName(alias ElasticsearchCertificateAlias) string

+ func (e *Elasticsearch) CertificateName(alias ElasticsearchCertificateAlias) string

+ func (e *Elasticsearch) ClientCertificateCN(alias ElasticsearchCertificateAlias) string

+ func (e *Elasticsearch) ConfigSecretName() string

+ func (e *Elasticsearch) GetConnectionScheme() string

+ func (e *Elasticsearch) GetConnectionURL() string

+ func (e *Elasticsearch) GetMatchExpressions() []metav1.LabelSelectorRequirement

+ func (e *Elasticsearch) GetPersistentSecrets() []string

+ func (e *Elasticsearch) MasterServiceName() string

+ func (e *Elasticsearch) MustCertSecretName(alias ElasticsearchCertificateAlias) string

+ func (e *Elasticsearch) ReplicasAreReady(lister appslister.StatefulSetLister) (bool, string, error)

+ func (e *Elasticsearch) SetDefaults(esVersion *v1alpha1.ElasticsearchVersion, topology *core_util.Topology)

+ func (e *Elasticsearch) SetTLSDefaults(esVersion *v1alpha1.ElasticsearchVersion)

+ func (e *Elasticsearch) UserCredSecretName(userName string) string

+ func (e Elasticsearch) AppBindingMeta() appcat.AppBindingMeta

+ func (e Elasticsearch) GoverningServiceName() string

+ func (e Elasticsearch) OffshootLabels() map[string]string

+ func (e Elasticsearch) OffshootName() string

+ func (e Elasticsearch) OffshootSelectors() map[string]string

+ func (e Elasticsearch) ResourceKind() string

+ func (e Elasticsearch) ResourcePlural() string

+ func (e Elasticsearch) ResourceShortCode() string

+ func (e Elasticsearch) ResourceSingular() string

+ func (e Elasticsearch) ServiceName() string

+ func (e Elasticsearch) StatsService() mona.StatsAccessor

+ func (e Elasticsearch) StatsServiceLabels() map[string]string

+ func (in *Elasticsearch) DeepCopy() *Elasticsearch

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

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

+ func (m *Elasticsearch) Marshal() (dAtA []byte, err error)

+ func (m *Elasticsearch) MarshalTo(dAtA []byte) (int, error)

+ func (m *Elasticsearch) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Elasticsearch) Reset()

+ func (m *Elasticsearch) Size() (n int)

+ func (m *Elasticsearch) Unmarshal(dAtA []byte) error

+ func (m *Elasticsearch) XXX_DiscardUnknown()

+ func (m *Elasticsearch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Elasticsearch) XXX_Merge(src proto.Message)

+ func (m *Elasticsearch) XXX_Size() int

+ func (m *Elasticsearch) XXX_Unmarshal(b []byte) error

+ func (this *Elasticsearch) String() string

+ type ElasticsearchCertificateAlias string

+ const ElasticsearchAdminCert

+ const ElasticsearchArchiverCert

+ const ElasticsearchCACert

+ const ElasticsearchHTTPCert

+ const ElasticsearchMetricsExporterCert

+ const ElasticsearchTransportCert

+ type ElasticsearchClusterTopology struct

+ Data ElasticsearchNode

+ Ingest ElasticsearchNode

+ Master ElasticsearchNode

+ func (*ElasticsearchClusterTopology) Descriptor() ([]byte, []int)

+ func (*ElasticsearchClusterTopology) ProtoMessage()

+ func (in *ElasticsearchClusterTopology) DeepCopy() *ElasticsearchClusterTopology

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

+ func (m *ElasticsearchClusterTopology) Marshal() (dAtA []byte, err error)

+ func (m *ElasticsearchClusterTopology) MarshalTo(dAtA []byte) (int, error)

+ func (m *ElasticsearchClusterTopology) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ElasticsearchClusterTopology) Reset()

+ func (m *ElasticsearchClusterTopology) Size() (n int)

+ func (m *ElasticsearchClusterTopology) Unmarshal(dAtA []byte) error

+ func (m *ElasticsearchClusterTopology) XXX_DiscardUnknown()

+ func (m *ElasticsearchClusterTopology) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ElasticsearchClusterTopology) XXX_Merge(src proto.Message)

+ func (m *ElasticsearchClusterTopology) XXX_Size() int

+ func (m *ElasticsearchClusterTopology) XXX_Unmarshal(b []byte) error

+ func (this *ElasticsearchClusterTopology) String() string

+ type ElasticsearchInternalUser string

+ const ElasticsearchInternalUserAdmin

+ const ElasticsearchInternalUserElastic

+ const ElasticsearchInternalUserKibanaro

+ const ElasticsearchInternalUserKibanaserver

+ const ElasticsearchInternalUserLogstash

+ const ElasticsearchInternalUserMetricsExporter

+ const ElasticsearchInternalUserReadall

+ const ElasticsearchInternalUserSnapshotrestore

+ type ElasticsearchList struct

+ Items []Elasticsearch

+ func (*ElasticsearchList) Descriptor() ([]byte, []int)

+ func (*ElasticsearchList) ProtoMessage()

+ func (in *ElasticsearchList) DeepCopy() *ElasticsearchList

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

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

+ func (m *ElasticsearchList) Marshal() (dAtA []byte, err error)

+ func (m *ElasticsearchList) MarshalTo(dAtA []byte) (int, error)

+ func (m *ElasticsearchList) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ElasticsearchList) Reset()

+ func (m *ElasticsearchList) Size() (n int)

+ func (m *ElasticsearchList) Unmarshal(dAtA []byte) error

+ func (m *ElasticsearchList) XXX_DiscardUnknown()

+ func (m *ElasticsearchList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ElasticsearchList) XXX_Merge(src proto.Message)

+ func (m *ElasticsearchList) XXX_Size() int

+ func (m *ElasticsearchList) XXX_Unmarshal(b []byte) error

+ func (this *ElasticsearchList) String() string

+ type ElasticsearchNode struct

+ MaxUnavailable *intstr.IntOrString

+ Prefix string

+ Replicas *int32

+ Resources core.ResourceRequirements

+ Storage *core.PersistentVolumeClaimSpec

+ func (*ElasticsearchNode) Descriptor() ([]byte, []int)

+ func (*ElasticsearchNode) ProtoMessage()

+ func (in *ElasticsearchNode) DeepCopy() *ElasticsearchNode

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

+ func (m *ElasticsearchNode) Marshal() (dAtA []byte, err error)

+ func (m *ElasticsearchNode) MarshalTo(dAtA []byte) (int, error)

+ func (m *ElasticsearchNode) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ElasticsearchNode) Reset()

+ func (m *ElasticsearchNode) Size() (n int)

+ func (m *ElasticsearchNode) Unmarshal(dAtA []byte) error

+ func (m *ElasticsearchNode) XXX_DiscardUnknown()

+ func (m *ElasticsearchNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ElasticsearchNode) XXX_Merge(src proto.Message)

+ func (m *ElasticsearchNode) XXX_Size() int

+ func (m *ElasticsearchNode) XXX_Unmarshal(b []byte) error

+ func (this *ElasticsearchNode) String() string

+ type ElasticsearchRoleMapSpec struct

+ AndBackendRoles []string

+ BackendRoles []string

+ Hidden bool

+ Hosts []string

+ Reserved bool

+ Users []string

+ func (*ElasticsearchRoleMapSpec) Descriptor() ([]byte, []int)

+ func (*ElasticsearchRoleMapSpec) ProtoMessage()

+ func (in *ElasticsearchRoleMapSpec) DeepCopy() *ElasticsearchRoleMapSpec

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

+ func (m *ElasticsearchRoleMapSpec) Marshal() (dAtA []byte, err error)

+ func (m *ElasticsearchRoleMapSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *ElasticsearchRoleMapSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ElasticsearchRoleMapSpec) Reset()

+ func (m *ElasticsearchRoleMapSpec) Size() (n int)

+ func (m *ElasticsearchRoleMapSpec) Unmarshal(dAtA []byte) error

+ func (m *ElasticsearchRoleMapSpec) XXX_DiscardUnknown()

+ func (m *ElasticsearchRoleMapSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ElasticsearchRoleMapSpec) XXX_Merge(src proto.Message)

+ func (m *ElasticsearchRoleMapSpec) XXX_Size() int

+ func (m *ElasticsearchRoleMapSpec) XXX_Unmarshal(b []byte) error

+ func (this *ElasticsearchRoleMapSpec) String() string

+ type ElasticsearchSpec struct

+ AuthSecret *core.LocalObjectReference

+ ConfigSecret *core.LocalObjectReference

+ DisableSecurity bool

+ EnableSSL bool

+ Halted bool

+ Init *InitSpec

+ InternalUsers map[string]ElasticsearchUserSpec

+ MaxUnavailable *intstr.IntOrString

+ Monitor *mona.AgentSpec

+ PodTemplate ofst.PodTemplateSpec

+ Replicas *int32

+ RolesMapping map[string]ElasticsearchRoleMapSpec

+ ServiceTemplate ofst.ServiceTemplateSpec

+ Storage *core.PersistentVolumeClaimSpec

+ StorageType StorageType

+ TLS *kmapi.TLSConfig

+ TerminationPolicy TerminationPolicy

+ Topology *ElasticsearchClusterTopology

+ Version string

+ func (*ElasticsearchSpec) Descriptor() ([]byte, []int)

+ func (*ElasticsearchSpec) ProtoMessage()

+ func (in *ElasticsearchSpec) DeepCopy() *ElasticsearchSpec

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

+ func (m *ElasticsearchSpec) Marshal() (dAtA []byte, err error)

+ func (m *ElasticsearchSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *ElasticsearchSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ElasticsearchSpec) Reset()

+ func (m *ElasticsearchSpec) Size() (n int)

+ func (m *ElasticsearchSpec) Unmarshal(dAtA []byte) error

+ func (m *ElasticsearchSpec) XXX_DiscardUnknown()

+ func (m *ElasticsearchSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ElasticsearchSpec) XXX_Merge(src proto.Message)

+ func (m *ElasticsearchSpec) XXX_Size() int

+ func (m *ElasticsearchSpec) XXX_Unmarshal(b []byte) error

+ func (this *ElasticsearchSpec) String() string

+ type ElasticsearchStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase DatabasePhase

+ func (*ElasticsearchStatus) Descriptor() ([]byte, []int)

+ func (*ElasticsearchStatus) ProtoMessage()

+ func (in *ElasticsearchStatus) DeepCopy() *ElasticsearchStatus

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

+ func (m *ElasticsearchStatus) Marshal() (dAtA []byte, err error)

+ func (m *ElasticsearchStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *ElasticsearchStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ElasticsearchStatus) Reset()

+ func (m *ElasticsearchStatus) Size() (n int)

+ func (m *ElasticsearchStatus) Unmarshal(dAtA []byte) error

+ func (m *ElasticsearchStatus) XXX_DiscardUnknown()

+ func (m *ElasticsearchStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ElasticsearchStatus) XXX_Merge(src proto.Message)

+ func (m *ElasticsearchStatus) XXX_Size() int

+ func (m *ElasticsearchStatus) XXX_Unmarshal(b []byte) error

+ func (this *ElasticsearchStatus) String() string

+ type ElasticsearchUserSpec struct

+ Attributes map[string]string

+ BackendRoles []string

+ Description string

+ Hash string

+ Hidden bool

+ OpendistroSecurityRoles []string

+ Reserved bool

+ SearchGuardRoles []string

+ func (*ElasticsearchUserSpec) Descriptor() ([]byte, []int)

+ func (*ElasticsearchUserSpec) ProtoMessage()

+ func (in *ElasticsearchUserSpec) DeepCopy() *ElasticsearchUserSpec

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

+ func (m *ElasticsearchUserSpec) Marshal() (dAtA []byte, err error)

+ func (m *ElasticsearchUserSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *ElasticsearchUserSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ElasticsearchUserSpec) Reset()

+ func (m *ElasticsearchUserSpec) Size() (n int)

+ func (m *ElasticsearchUserSpec) Unmarshal(dAtA []byte) error

+ func (m *ElasticsearchUserSpec) XXX_DiscardUnknown()

+ func (m *ElasticsearchUserSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ElasticsearchUserSpec) XXX_Merge(src proto.Message)

+ func (m *ElasticsearchUserSpec) XXX_Size() int

+ func (m *ElasticsearchUserSpec) XXX_Unmarshal(b []byte) error

+ func (this *ElasticsearchUserSpec) String() string

+ type Etcd struct

+ Spec EtcdSpec

+ Status EtcdStatus

+ func (*Etcd) Descriptor() ([]byte, []int)

+ func (*Etcd) ProtoMessage()

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

+ func (e *Etcd) ReplicasAreReady(lister appslister.StatefulSetLister) (bool, string, error)

+ func (e *Etcd) SetDefaults()

+ func (e Etcd) ClientServiceName() string

+ func (e Etcd) OffshootLabels() map[string]string

+ func (e Etcd) OffshootName() string

+ func (e Etcd) OffshootSelectors() map[string]string

+ func (e Etcd) PeerServiceName() string

+ func (e Etcd) ResourceKind() string

+ func (e Etcd) ResourcePlural() string

+ func (e Etcd) ResourceShortCode() string

+ func (e Etcd) ResourceSingular() string

+ func (e Etcd) StatsService() mona.StatsAccessor

+ func (e Etcd) StatsServiceLabels() map[string]string

+ func (in *Etcd) DeepCopy() *Etcd

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

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

+ func (m *Etcd) Marshal() (dAtA []byte, err error)

+ func (m *Etcd) MarshalTo(dAtA []byte) (int, error)

+ func (m *Etcd) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Etcd) Reset()

+ func (m *Etcd) Size() (n int)

+ func (m *Etcd) Unmarshal(dAtA []byte) error

+ func (m *Etcd) XXX_DiscardUnknown()

+ func (m *Etcd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Etcd) XXX_Merge(src proto.Message)

+ func (m *Etcd) XXX_Size() int

+ func (m *Etcd) XXX_Unmarshal(b []byte) error

+ func (r Etcd) AppBindingMeta() appcat.AppBindingMeta

+ func (this *Etcd) String() string

+ type EtcdList struct

+ Items []Etcd

+ func (*EtcdList) Descriptor() ([]byte, []int)

+ func (*EtcdList) ProtoMessage()

+ func (in *EtcdList) DeepCopy() *EtcdList

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

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

+ func (m *EtcdList) Marshal() (dAtA []byte, err error)

+ func (m *EtcdList) MarshalTo(dAtA []byte) (int, error)

+ func (m *EtcdList) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EtcdList) Reset()

+ func (m *EtcdList) Size() (n int)

+ func (m *EtcdList) Unmarshal(dAtA []byte) error

+ func (m *EtcdList) XXX_DiscardUnknown()

+ func (m *EtcdList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EtcdList) XXX_Merge(src proto.Message)

+ func (m *EtcdList) XXX_Size() int

+ func (m *EtcdList) XXX_Unmarshal(b []byte) error

+ func (this *EtcdList) String() string

+ type EtcdSpec struct

+ AuthSecret *core.LocalObjectReference

+ Halted bool

+ Init *InitSpec

+ Monitor *mona.AgentSpec

+ PodTemplate ofst.PodTemplateSpec

+ Replicas *int32

+ ServiceTemplate ofst.ServiceTemplateSpec

+ Storage *core.PersistentVolumeClaimSpec

+ StorageType StorageType

+ TLS *TLSPolicy

+ TerminationPolicy TerminationPolicy

+ Version string

+ func (*EtcdSpec) Descriptor() ([]byte, []int)

+ func (*EtcdSpec) ProtoMessage()

+ func (e *EtcdSpec) GetPersistentSecrets() []string

+ func (in *EtcdSpec) DeepCopy() *EtcdSpec

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

+ func (m *EtcdSpec) Marshal() (dAtA []byte, err error)

+ func (m *EtcdSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *EtcdSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EtcdSpec) Reset()

+ func (m *EtcdSpec) Size() (n int)

+ func (m *EtcdSpec) Unmarshal(dAtA []byte) error

+ func (m *EtcdSpec) XXX_DiscardUnknown()

+ func (m *EtcdSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EtcdSpec) XXX_Merge(src proto.Message)

+ func (m *EtcdSpec) XXX_Size() int

+ func (m *EtcdSpec) XXX_Unmarshal(b []byte) error

+ func (this *EtcdSpec) String() string

+ type EtcdStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase DatabasePhase

+ func (*EtcdStatus) Descriptor() ([]byte, []int)

+ func (*EtcdStatus) ProtoMessage()

+ func (in *EtcdStatus) DeepCopy() *EtcdStatus

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

+ func (m *EtcdStatus) Marshal() (dAtA []byte, err error)

+ func (m *EtcdStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *EtcdStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EtcdStatus) Reset()

+ func (m *EtcdStatus) Size() (n int)

+ func (m *EtcdStatus) Unmarshal(dAtA []byte) error

+ func (m *EtcdStatus) XXX_DiscardUnknown()

+ func (m *EtcdStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EtcdStatus) XXX_Merge(src proto.Message)

+ func (m *EtcdStatus) XXX_Size() int

+ func (m *EtcdStatus) XXX_Unmarshal(b []byte) error

+ func (this *EtcdStatus) String() string

+ type InitSpec struct

+ Initialized bool

+ PostgresWAL *PostgresWALSourceSpec

+ Script *ScriptSourceSpec

+ WaitForInitialRestore bool

+ func (*InitSpec) Descriptor() ([]byte, []int)

+ func (*InitSpec) ProtoMessage()

+ func (in *InitSpec) DeepCopy() *InitSpec

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

+ func (m *InitSpec) Marshal() (dAtA []byte, err error)

+ func (m *InitSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *InitSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *InitSpec) Reset()

+ func (m *InitSpec) Size() (n int)

+ func (m *InitSpec) Unmarshal(dAtA []byte) error

+ func (m *InitSpec) XXX_DiscardUnknown()

+ func (m *InitSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *InitSpec) XXX_Merge(src proto.Message)

+ func (m *InitSpec) XXX_Size() int

+ func (m *InitSpec) XXX_Unmarshal(b []byte) error

+ func (this *InitSpec) String() string

+ type LeaderElectionConfig struct

+ LeaseDurationSeconds int32

+ RenewDeadlineSeconds int32

+ RetryPeriodSeconds int32

+ func (*LeaderElectionConfig) Descriptor() ([]byte, []int)

+ func (*LeaderElectionConfig) ProtoMessage()

+ func (in *LeaderElectionConfig) DeepCopy() *LeaderElectionConfig

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

+ func (m *LeaderElectionConfig) Marshal() (dAtA []byte, err error)

+ func (m *LeaderElectionConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *LeaderElectionConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LeaderElectionConfig) Reset()

+ func (m *LeaderElectionConfig) Size() (n int)

+ func (m *LeaderElectionConfig) Unmarshal(dAtA []byte) error

+ func (m *LeaderElectionConfig) XXX_DiscardUnknown()

+ func (m *LeaderElectionConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LeaderElectionConfig) XXX_Merge(src proto.Message)

+ func (m *LeaderElectionConfig) XXX_Size() int

+ func (m *LeaderElectionConfig) XXX_Unmarshal(b []byte) error

+ func (this *LeaderElectionConfig) String() string

+ type LoadBalanceMode string

+ const LoadBalanceModeGalera

+ const LoadBalanceModeGroupReplication

+ type MariaDB struct

+ Spec MariaDBSpec

+ Status MariaDBStatus

+ func (*MariaDB) Descriptor() ([]byte, []int)

+ func (*MariaDB) ProtoMessage()

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

+ func (in *MariaDB) DeepCopy() *MariaDB

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

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

+ func (m *MariaDB) Marshal() (dAtA []byte, err error)

+ func (m *MariaDB) MarshalTo(dAtA []byte) (int, error)

+ func (m *MariaDB) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MariaDB) ReplicasAreReady(lister appslister.StatefulSetLister) (bool, string, error)

+ func (m *MariaDB) Reset()

+ func (m *MariaDB) SetDefaults()

+ func (m *MariaDB) Size() (n int)

+ func (m *MariaDB) Unmarshal(dAtA []byte) error

+ func (m *MariaDB) XXX_DiscardUnknown()

+ func (m *MariaDB) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MariaDB) XXX_Merge(src proto.Message)

+ func (m *MariaDB) XXX_Size() int

+ func (m *MariaDB) XXX_Unmarshal(b []byte) error

+ func (m MariaDB) AppBindingMeta() appcat.AppBindingMeta

+ func (m MariaDB) GoverningServiceName() string

+ func (m MariaDB) OffshootLabels() map[string]string

+ func (m MariaDB) OffshootName() string

+ func (m MariaDB) OffshootSelectors() map[string]string

+ func (m MariaDB) ResourceKind() string

+ func (m MariaDB) ResourcePlural() string

+ func (m MariaDB) ResourceShortCode() string

+ func (m MariaDB) ResourceSingular() string

+ func (m MariaDB) ServiceName() string

+ func (m MariaDB) StatsService() mona.StatsAccessor

+ func (m MariaDB) StatsServiceLabels() map[string]string

+ func (this *MariaDB) String() string

+ type MariaDBCertificateAlias string

+ const MariaDBArchiverCert

+ const MariaDBMetricsExporterCert

+ const MariaDBServerCert

+ type MariaDBList struct

+ Items []MariaDB

+ func (*MariaDBList) Descriptor() ([]byte, []int)

+ func (*MariaDBList) ProtoMessage()

+ func (in *MariaDBList) DeepCopy() *MariaDBList

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

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

+ func (m *MariaDBList) Marshal() (dAtA []byte, err error)

+ func (m *MariaDBList) MarshalTo(dAtA []byte) (int, error)

+ func (m *MariaDBList) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MariaDBList) Reset()

+ func (m *MariaDBList) Size() (n int)

+ func (m *MariaDBList) Unmarshal(dAtA []byte) error

+ func (m *MariaDBList) XXX_DiscardUnknown()

+ func (m *MariaDBList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MariaDBList) XXX_Merge(src proto.Message)

+ func (m *MariaDBList) XXX_Size() int

+ func (m *MariaDBList) XXX_Unmarshal(b []byte) error

+ func (this *MariaDBList) String() string

+ type MariaDBSpec struct

+ AuthSecret *core.LocalObjectReference

+ ConfigSecret *core.LocalObjectReference

+ Halted bool

+ Init *InitSpec

+ Monitor *mona.AgentSpec

+ PodTemplate ofst.PodTemplateSpec

+ Replicas *int32

+ ServiceTemplate ofst.ServiceTemplateSpec

+ Storage *core.PersistentVolumeClaimSpec

+ StorageType StorageType

+ TLS *kmapi.TLSConfig

+ TerminationPolicy TerminationPolicy

+ Version string

+ func (*MariaDBSpec) Descriptor() ([]byte, []int)

+ func (*MariaDBSpec) ProtoMessage()

+ func (in *MariaDBSpec) DeepCopy() *MariaDBSpec

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

+ func (m *MariaDBSpec) GetPersistentSecrets() []string

+ func (m *MariaDBSpec) Marshal() (dAtA []byte, err error)

+ func (m *MariaDBSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *MariaDBSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MariaDBSpec) Reset()

+ func (m *MariaDBSpec) Size() (n int)

+ func (m *MariaDBSpec) Unmarshal(dAtA []byte) error

+ func (m *MariaDBSpec) XXX_DiscardUnknown()

+ func (m *MariaDBSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MariaDBSpec) XXX_Merge(src proto.Message)

+ func (m *MariaDBSpec) XXX_Size() int

+ func (m *MariaDBSpec) XXX_Unmarshal(b []byte) error

+ func (this *MariaDBSpec) String() string

+ type MariaDBStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase DatabasePhase

+ func (*MariaDBStatus) Descriptor() ([]byte, []int)

+ func (*MariaDBStatus) ProtoMessage()

+ func (in *MariaDBStatus) DeepCopy() *MariaDBStatus

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

+ func (m *MariaDBStatus) Marshal() (dAtA []byte, err error)

+ func (m *MariaDBStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *MariaDBStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MariaDBStatus) Reset()

+ func (m *MariaDBStatus) Size() (n int)

+ func (m *MariaDBStatus) Unmarshal(dAtA []byte) error

+ func (m *MariaDBStatus) XXX_DiscardUnknown()

+ func (m *MariaDBStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MariaDBStatus) XXX_Merge(src proto.Message)

+ func (m *MariaDBStatus) XXX_Size() int

+ func (m *MariaDBStatus) XXX_Unmarshal(b []byte) error

+ func (this *MariaDBStatus) String() string

+ type MemberSecret struct

+ PeerSecret string

+ ServerSecret string

+ func (*MemberSecret) Descriptor() ([]byte, []int)

+ func (*MemberSecret) ProtoMessage()

+ func (in *MemberSecret) DeepCopy() *MemberSecret

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

+ func (m *MemberSecret) Marshal() (dAtA []byte, err error)

+ func (m *MemberSecret) MarshalTo(dAtA []byte) (int, error)

+ func (m *MemberSecret) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MemberSecret) Reset()

+ func (m *MemberSecret) Size() (n int)

+ func (m *MemberSecret) Unmarshal(dAtA []byte) error

+ func (m *MemberSecret) XXX_DiscardUnknown()

+ func (m *MemberSecret) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MemberSecret) XXX_Merge(src proto.Message)

+ func (m *MemberSecret) XXX_Size() int

+ func (m *MemberSecret) XXX_Unmarshal(b []byte) error

+ func (this *MemberSecret) String() string

+ type Memcached struct

+ Spec MemcachedSpec

+ Status MemcachedStatus

+ func (*Memcached) Descriptor() ([]byte, []int)

+ func (*Memcached) ProtoMessage()

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

+ func (in *Memcached) DeepCopy() *Memcached

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

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

+ func (m *Memcached) Marshal() (dAtA []byte, err error)

+ func (m *Memcached) MarshalTo(dAtA []byte) (int, error)

+ func (m *Memcached) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Memcached) ReplicasAreReady(lister appslister.StatefulSetLister) (bool, string, error)

+ func (m *Memcached) Reset()

+ func (m *Memcached) SetDefaults()

+ func (m *Memcached) Size() (n int)

+ func (m *Memcached) Unmarshal(dAtA []byte) error

+ func (m *Memcached) XXX_DiscardUnknown()

+ func (m *Memcached) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Memcached) XXX_Merge(src proto.Message)

+ func (m *Memcached) XXX_Size() int

+ func (m *Memcached) XXX_Unmarshal(b []byte) error

+ func (m Memcached) AppBindingMeta() appcat.AppBindingMeta

+ func (m Memcached) GoverningServiceName() string

+ func (m Memcached) OffshootLabels() map[string]string

+ func (m Memcached) OffshootName() string

+ func (m Memcached) OffshootSelectors() map[string]string

+ func (m Memcached) ResourceKind() string

+ func (m Memcached) ResourcePlural() string

+ func (m Memcached) ResourceShortCode() string

+ func (m Memcached) ResourceSingular() string

+ func (m Memcached) ServiceName() string

+ func (m Memcached) StatsService() mona.StatsAccessor

+ func (m Memcached) StatsServiceLabels() map[string]string

+ func (this *Memcached) String() string

+ type MemcachedCertificateAlias string

+ const MemcachedMetricsExporterCert

+ const MemcachedServerCert

+ type MemcachedList struct

+ Items []Memcached

+ func (*MemcachedList) Descriptor() ([]byte, []int)

+ func (*MemcachedList) ProtoMessage()

+ func (in *MemcachedList) DeepCopy() *MemcachedList

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

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

+ func (m *MemcachedList) Marshal() (dAtA []byte, err error)

+ func (m *MemcachedList) MarshalTo(dAtA []byte) (int, error)

+ func (m *MemcachedList) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MemcachedList) Reset()

+ func (m *MemcachedList) Size() (n int)

+ func (m *MemcachedList) Unmarshal(dAtA []byte) error

+ func (m *MemcachedList) XXX_DiscardUnknown()

+ func (m *MemcachedList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MemcachedList) XXX_Merge(src proto.Message)

+ func (m *MemcachedList) XXX_Size() int

+ func (m *MemcachedList) XXX_Unmarshal(b []byte) error

+ func (this *MemcachedList) String() string

+ type MemcachedSpec struct

+ ConfigSecret *core.LocalObjectReference

+ DataVolume *core.VolumeSource

+ Halted bool

+ Monitor *mona.AgentSpec

+ PodTemplate ofst.PodTemplateSpec

+ Replicas *int32

+ ServiceTemplate ofst.ServiceTemplateSpec

+ TLS *kmapi.TLSConfig

+ TerminationPolicy TerminationPolicy

+ Version string

+ func (*MemcachedSpec) Descriptor() ([]byte, []int)

+ func (*MemcachedSpec) ProtoMessage()

+ func (in *MemcachedSpec) DeepCopy() *MemcachedSpec

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

+ func (m *MemcachedSpec) GetPersistentSecrets() []string

+ func (m *MemcachedSpec) Marshal() (dAtA []byte, err error)

+ func (m *MemcachedSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *MemcachedSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MemcachedSpec) Reset()

+ func (m *MemcachedSpec) Size() (n int)

+ func (m *MemcachedSpec) Unmarshal(dAtA []byte) error

+ func (m *MemcachedSpec) XXX_DiscardUnknown()

+ func (m *MemcachedSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MemcachedSpec) XXX_Merge(src proto.Message)

+ func (m *MemcachedSpec) XXX_Size() int

+ func (m *MemcachedSpec) XXX_Unmarshal(b []byte) error

+ func (this *MemcachedSpec) String() string

+ type MemcachedStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase DatabasePhase

+ func (*MemcachedStatus) Descriptor() ([]byte, []int)

+ func (*MemcachedStatus) ProtoMessage()

+ func (in *MemcachedStatus) DeepCopy() *MemcachedStatus

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

+ func (m *MemcachedStatus) Marshal() (dAtA []byte, err error)

+ func (m *MemcachedStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *MemcachedStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MemcachedStatus) Reset()

+ func (m *MemcachedStatus) Size() (n int)

+ func (m *MemcachedStatus) Unmarshal(dAtA []byte) error

+ func (m *MemcachedStatus) XXX_DiscardUnknown()

+ func (m *MemcachedStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MemcachedStatus) XXX_Merge(src proto.Message)

+ func (m *MemcachedStatus) XXX_Size() int

+ func (m *MemcachedStatus) XXX_Unmarshal(b []byte) error

+ func (this *MemcachedStatus) String() string

+ type MongoDB struct

+ Spec MongoDBSpec

+ Status MongoDBStatus

+ func (*MongoDB) Descriptor() ([]byte, []int)

+ func (*MongoDB) ProtoMessage()

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

+ func (in *MongoDB) DeepCopy() *MongoDB

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

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

+ func (m *MongoDB) CertificateName(alias MongoDBCertificateAlias, stsName string) string

+ func (m *MongoDB) GetDefaultLivenessProbeSpec(mgVersion *v1alpha1.MongoDBVersion) *core.Probe

+ func (m *MongoDB) GetDefaultReadinessProbeSpec(mgVersion *v1alpha1.MongoDBVersion) *core.Probe

+ func (m *MongoDB) KeyFileRequired() bool

+ func (m *MongoDB) Marshal() (dAtA []byte, err error)

+ func (m *MongoDB) MarshalTo(dAtA []byte) (int, error)

+ func (m *MongoDB) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MongoDB) MustCertSecretName(alias MongoDBCertificateAlias, stsName string) string

+ func (m *MongoDB) ReplicasAreReady(lister appslister.StatefulSetLister) (bool, string, error)

+ func (m *MongoDB) Reset()

+ func (m *MongoDB) SetDefaults(mgVersion *v1alpha1.MongoDBVersion, topology *core_util.Topology)

+ func (m *MongoDB) SetTLSDefaults()

+ func (m *MongoDB) Size() (n int)

+ func (m *MongoDB) Unmarshal(dAtA []byte) error

+ func (m *MongoDB) XXX_DiscardUnknown()

+ func (m *MongoDB) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MongoDB) XXX_Merge(src proto.Message)

+ func (m *MongoDB) XXX_Size() int

+ func (m *MongoDB) XXX_Unmarshal(b []byte) error

+ func (m MongoDB) AppBindingMeta() appcat.AppBindingMeta

+ func (m MongoDB) ConfigSvrDSN() string

+ func (m MongoDB) ConfigSvrHosts() []string

+ func (m MongoDB) ConfigSvrLabels() map[string]string

+ func (m MongoDB) ConfigSvrNodeName() string

+ func (m MongoDB) ConfigSvrRepSetName() string

+ func (m MongoDB) ConfigSvrSelectors() map[string]string

+ func (m MongoDB) GoverningServiceName(name string) string

+ func (m MongoDB) HostAddress() string

+ func (m MongoDB) Hosts() []string

+ func (m MongoDB) MongosHosts() []string

+ func (m MongoDB) MongosLabels() map[string]string

+ func (m MongoDB) MongosNodeName() string

+ func (m MongoDB) MongosSelectors() map[string]string

+ func (m MongoDB) OffshootLabels() map[string]string

+ func (m MongoDB) OffshootName() string

+ func (m MongoDB) OffshootSelectors() map[string]string

+ func (m MongoDB) RepSetName() string

+ func (m MongoDB) ResourceKind() string

+ func (m MongoDB) ResourcePlural() string

+ func (m MongoDB) ResourceShortCode() string

+ func (m MongoDB) ResourceSingular() string

+ func (m MongoDB) ServiceName() string

+ func (m MongoDB) ShardCommonNodeName() string

+ func (m MongoDB) ShardDSN(nodeNum int32) string

+ func (m MongoDB) ShardHosts(nodeNum int32) []string

+ func (m MongoDB) ShardLabels(nodeNum int32) map[string]string

+ func (m MongoDB) ShardNodeName(nodeNum int32) string

+ func (m MongoDB) ShardNodeTemplate() string

+ func (m MongoDB) ShardRepSetName(nodeNum int32) string

+ func (m MongoDB) ShardSelectors(nodeNum int32) map[string]string

+ func (m MongoDB) StatsService() mona.StatsAccessor

+ func (m MongoDB) StatsServiceLabels() map[string]string

+ func (this *MongoDB) String() string

+ type MongoDBCertificateAlias string

+ const MongoDBClientCert

+ const MongoDBMetricsExporterCert

+ const MongoDBServerCert

+ type MongoDBConfigNode struct

+ Storage *core.PersistentVolumeClaimSpec

+ func (*MongoDBConfigNode) Descriptor() ([]byte, []int)

+ func (*MongoDBConfigNode) ProtoMessage()

+ func (in *MongoDBConfigNode) DeepCopy() *MongoDBConfigNode

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

+ func (m *MongoDBConfigNode) Marshal() (dAtA []byte, err error)

+ func (m *MongoDBConfigNode) MarshalTo(dAtA []byte) (int, error)

+ func (m *MongoDBConfigNode) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MongoDBConfigNode) Reset()

+ func (m *MongoDBConfigNode) Size() (n int)

+ func (m *MongoDBConfigNode) Unmarshal(dAtA []byte) error

+ func (m *MongoDBConfigNode) XXX_DiscardUnknown()

+ func (m *MongoDBConfigNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MongoDBConfigNode) XXX_Merge(src proto.Message)

+ func (m *MongoDBConfigNode) XXX_Size() int

+ func (m *MongoDBConfigNode) XXX_Unmarshal(b []byte) error

+ func (this *MongoDBConfigNode) String() string

+ type MongoDBList struct

+ Items []MongoDB

+ func (*MongoDBList) Descriptor() ([]byte, []int)

+ func (*MongoDBList) ProtoMessage()

+ func (in *MongoDBList) DeepCopy() *MongoDBList

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

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

+ func (m *MongoDBList) Marshal() (dAtA []byte, err error)

+ func (m *MongoDBList) MarshalTo(dAtA []byte) (int, error)

+ func (m *MongoDBList) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MongoDBList) Reset()

+ func (m *MongoDBList) Size() (n int)

+ func (m *MongoDBList) Unmarshal(dAtA []byte) error

+ func (m *MongoDBList) XXX_DiscardUnknown()

+ func (m *MongoDBList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MongoDBList) XXX_Merge(src proto.Message)

+ func (m *MongoDBList) XXX_Size() int

+ func (m *MongoDBList) XXX_Unmarshal(b []byte) error

+ func (this *MongoDBList) String() string

+ type MongoDBMongosNode struct

+ func (*MongoDBMongosNode) Descriptor() ([]byte, []int)

+ func (*MongoDBMongosNode) ProtoMessage()

+ func (in *MongoDBMongosNode) DeepCopy() *MongoDBMongosNode

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

+ func (m *MongoDBMongosNode) Marshal() (dAtA []byte, err error)

+ func (m *MongoDBMongosNode) MarshalTo(dAtA []byte) (int, error)

+ func (m *MongoDBMongosNode) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MongoDBMongosNode) Reset()

+ func (m *MongoDBMongosNode) Size() (n int)

+ func (m *MongoDBMongosNode) Unmarshal(dAtA []byte) error

+ func (m *MongoDBMongosNode) XXX_DiscardUnknown()

+ func (m *MongoDBMongosNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MongoDBMongosNode) XXX_Merge(src proto.Message)

+ func (m *MongoDBMongosNode) XXX_Size() int

+ func (m *MongoDBMongosNode) XXX_Unmarshal(b []byte) error

+ func (this *MongoDBMongosNode) String() string

+ type MongoDBNode struct

+ ConfigSecret *core.LocalObjectReference

+ PodTemplate ofst.PodTemplateSpec

+ Prefix string

+ Replicas int32

+ func (*MongoDBNode) Descriptor() ([]byte, []int)

+ func (*MongoDBNode) ProtoMessage()

+ func (in *MongoDBNode) DeepCopy() *MongoDBNode

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

+ func (m *MongoDBNode) Marshal() (dAtA []byte, err error)

+ func (m *MongoDBNode) MarshalTo(dAtA []byte) (int, error)

+ func (m *MongoDBNode) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MongoDBNode) Reset()

+ func (m *MongoDBNode) Size() (n int)

+ func (m *MongoDBNode) Unmarshal(dAtA []byte) error

+ func (m *MongoDBNode) XXX_DiscardUnknown()

+ func (m *MongoDBNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MongoDBNode) XXX_Merge(src proto.Message)

+ func (m *MongoDBNode) XXX_Size() int

+ func (m *MongoDBNode) XXX_Unmarshal(b []byte) error

+ func (this *MongoDBNode) String() string

+ type MongoDBReplicaSet struct

+ Name string

+ func (*MongoDBReplicaSet) Descriptor() ([]byte, []int)

+ func (*MongoDBReplicaSet) ProtoMessage()

+ func (in *MongoDBReplicaSet) DeepCopy() *MongoDBReplicaSet

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

+ func (m *MongoDBReplicaSet) Marshal() (dAtA []byte, err error)

+ func (m *MongoDBReplicaSet) MarshalTo(dAtA []byte) (int, error)

+ func (m *MongoDBReplicaSet) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MongoDBReplicaSet) Reset()

+ func (m *MongoDBReplicaSet) Size() (n int)

+ func (m *MongoDBReplicaSet) Unmarshal(dAtA []byte) error

+ func (m *MongoDBReplicaSet) XXX_DiscardUnknown()

+ func (m *MongoDBReplicaSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MongoDBReplicaSet) XXX_Merge(src proto.Message)

+ func (m *MongoDBReplicaSet) XXX_Size() int

+ func (m *MongoDBReplicaSet) XXX_Unmarshal(b []byte) error

+ func (this *MongoDBReplicaSet) String() string

+ type MongoDBShardNode struct

+ Shards int32

+ Storage *core.PersistentVolumeClaimSpec

+ func (*MongoDBShardNode) Descriptor() ([]byte, []int)

+ func (*MongoDBShardNode) ProtoMessage()

+ func (in *MongoDBShardNode) DeepCopy() *MongoDBShardNode

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

+ func (m *MongoDBShardNode) Marshal() (dAtA []byte, err error)

+ func (m *MongoDBShardNode) MarshalTo(dAtA []byte) (int, error)

+ func (m *MongoDBShardNode) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MongoDBShardNode) Reset()

+ func (m *MongoDBShardNode) Size() (n int)

+ func (m *MongoDBShardNode) Unmarshal(dAtA []byte) error

+ func (m *MongoDBShardNode) XXX_DiscardUnknown()

+ func (m *MongoDBShardNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MongoDBShardNode) XXX_Merge(src proto.Message)

+ func (m *MongoDBShardNode) XXX_Size() int

+ func (m *MongoDBShardNode) XXX_Unmarshal(b []byte) error

+ func (this *MongoDBShardNode) String() string

+ type MongoDBShardingTopology struct

+ ConfigServer MongoDBConfigNode

+ Mongos MongoDBMongosNode

+ Shard MongoDBShardNode

+ func (*MongoDBShardingTopology) Descriptor() ([]byte, []int)

+ func (*MongoDBShardingTopology) ProtoMessage()

+ func (in *MongoDBShardingTopology) DeepCopy() *MongoDBShardingTopology

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

+ func (m *MongoDBShardingTopology) Marshal() (dAtA []byte, err error)

+ func (m *MongoDBShardingTopology) MarshalTo(dAtA []byte) (int, error)

+ func (m *MongoDBShardingTopology) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MongoDBShardingTopology) Reset()

+ func (m *MongoDBShardingTopology) Size() (n int)

+ func (m *MongoDBShardingTopology) Unmarshal(dAtA []byte) error

+ func (m *MongoDBShardingTopology) XXX_DiscardUnknown()

+ func (m *MongoDBShardingTopology) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MongoDBShardingTopology) XXX_Merge(src proto.Message)

+ func (m *MongoDBShardingTopology) XXX_Size() int

+ func (m *MongoDBShardingTopology) XXX_Unmarshal(b []byte) error

+ func (this *MongoDBShardingTopology) String() string

+ type MongoDBSpec struct

+ AuthSecret *core.LocalObjectReference

+ ClusterAuthMode ClusterAuthMode

+ ConfigSecret *core.LocalObjectReference

+ Halted bool

+ Init *InitSpec

+ KeyFileSecret *core.LocalObjectReference

+ Monitor *mona.AgentSpec

+ PodTemplate *ofst.PodTemplateSpec

+ ReplicaSet *MongoDBReplicaSet

+ Replicas *int32

+ SSLMode SSLMode

+ ServiceTemplate ofst.ServiceTemplateSpec

+ ShardTopology *MongoDBShardingTopology

+ Storage *core.PersistentVolumeClaimSpec

+ StorageEngine StorageEngine

+ StorageType StorageType

+ TLS *kmapi.TLSConfig

+ TerminationPolicy TerminationPolicy

+ Version string

+ func (*MongoDBSpec) Descriptor() ([]byte, []int)

+ func (*MongoDBSpec) ProtoMessage()

+ func (in *MongoDBSpec) DeepCopy() *MongoDBSpec

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

+ func (m *MongoDBSpec) GetPersistentSecrets() []string

+ func (m *MongoDBSpec) Marshal() (dAtA []byte, err error)

+ func (m *MongoDBSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *MongoDBSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MongoDBSpec) Reset()

+ func (m *MongoDBSpec) SetSecurityContext(podTemplate *ofst.PodTemplateSpec)

+ func (m *MongoDBSpec) Size() (n int)

+ func (m *MongoDBSpec) Unmarshal(dAtA []byte) error

+ func (m *MongoDBSpec) XXX_DiscardUnknown()

+ func (m *MongoDBSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MongoDBSpec) XXX_Merge(src proto.Message)

+ func (m *MongoDBSpec) XXX_Size() int

+ func (m *MongoDBSpec) XXX_Unmarshal(b []byte) error

+ func (this *MongoDBSpec) String() string

+ type MongoDBStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase DatabasePhase

+ func (*MongoDBStatus) Descriptor() ([]byte, []int)

+ func (*MongoDBStatus) ProtoMessage()

+ func (in *MongoDBStatus) DeepCopy() *MongoDBStatus

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

+ func (m *MongoDBStatus) Marshal() (dAtA []byte, err error)

+ func (m *MongoDBStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *MongoDBStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MongoDBStatus) Reset()

+ func (m *MongoDBStatus) Size() (n int)

+ func (m *MongoDBStatus) Unmarshal(dAtA []byte) error

+ func (m *MongoDBStatus) XXX_DiscardUnknown()

+ func (m *MongoDBStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MongoDBStatus) XXX_Merge(src proto.Message)

+ func (m *MongoDBStatus) XXX_Size() int

+ func (m *MongoDBStatus) XXX_Unmarshal(b []byte) error

+ func (this *MongoDBStatus) String() string

+ type MySQL struct

+ Spec MySQLSpec

+ Status MySQLStatus

+ func (*MySQL) Descriptor() ([]byte, []int)

+ func (*MySQL) ProtoMessage()

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

+ func (in *MySQL) DeepCopy() *MySQL

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

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

+ func (m *MySQL) CertificateName(alias MySQLCertificateAlias) string

+ func (m *MySQL) Marshal() (dAtA []byte, err error)

+ func (m *MySQL) MarshalTo(dAtA []byte) (int, error)

+ func (m *MySQL) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MySQL) MustCertSecretName(alias MySQLCertificateAlias) string

+ func (m *MySQL) ReplicasAreReady(lister appslister.StatefulSetLister) (bool, string, error)

+ func (m *MySQL) Reset()

+ func (m *MySQL) SetDefaults()

+ func (m *MySQL) SetTLSDefaults()

+ func (m *MySQL) Size() (n int)

+ func (m *MySQL) Unmarshal(dAtA []byte) error

+ func (m *MySQL) UsesGroupReplication() bool

+ func (m *MySQL) XXX_DiscardUnknown()

+ func (m *MySQL) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MySQL) XXX_Merge(src proto.Message)

+ func (m *MySQL) XXX_Size() int

+ func (m *MySQL) XXX_Unmarshal(b []byte) error

+ func (m MySQL) AppBindingMeta() appcat.AppBindingMeta

+ func (m MySQL) GetAuthSecretName() string

+ func (m MySQL) GoverningServiceName() string

+ func (m MySQL) OffshootLabels() map[string]string

+ func (m MySQL) OffshootName() string

+ func (m MySQL) OffshootSelectors() map[string]string

+ func (m MySQL) PeerName(idx int) string

+ func (m MySQL) ResourceKind() string

+ func (m MySQL) ResourcePlural() string

+ func (m MySQL) ResourceShortCode() string

+ func (m MySQL) ResourceSingular() string

+ func (m MySQL) ServiceName() string

+ func (m MySQL) StandbyServiceName() string

+ func (m MySQL) StatsService() mona.StatsAccessor

+ func (m MySQL) StatsServiceLabels() map[string]string

+ func (this *MySQL) String() string

+ type MySQLCertificateAlias string

+ const MySQLClientCert

+ const MySQLMetricsExporterCert

+ const MySQLServerCert

+ type MySQLClusterMode string

+ const MySQLClusterModeGroup

+ type MySQLClusterTopology struct

+ Group *MySQLGroupSpec

+ Mode *MySQLClusterMode

+ func (*MySQLClusterTopology) Descriptor() ([]byte, []int)

+ func (*MySQLClusterTopology) ProtoMessage()

+ func (in *MySQLClusterTopology) DeepCopy() *MySQLClusterTopology

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

+ func (m *MySQLClusterTopology) Marshal() (dAtA []byte, err error)

+ func (m *MySQLClusterTopology) MarshalTo(dAtA []byte) (int, error)

+ func (m *MySQLClusterTopology) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MySQLClusterTopology) Reset()

+ func (m *MySQLClusterTopology) Size() (n int)

+ func (m *MySQLClusterTopology) Unmarshal(dAtA []byte) error

+ func (m *MySQLClusterTopology) XXX_DiscardUnknown()

+ func (m *MySQLClusterTopology) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MySQLClusterTopology) XXX_Merge(src proto.Message)

+ func (m *MySQLClusterTopology) XXX_Size() int

+ func (m *MySQLClusterTopology) XXX_Unmarshal(b []byte) error

+ func (this *MySQLClusterTopology) String() string

+ type MySQLGroupMode string

+ const MySQLGroupModeMultiPrimary

+ const MySQLGroupModeSinglePrimary

+ type MySQLGroupSpec struct

+ BaseServerID *int64

+ Mode *MySQLGroupMode

+ Name string

+ func (*MySQLGroupSpec) Descriptor() ([]byte, []int)

+ func (*MySQLGroupSpec) ProtoMessage()

+ func (in *MySQLGroupSpec) DeepCopy() *MySQLGroupSpec

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

+ func (m *MySQLGroupSpec) Marshal() (dAtA []byte, err error)

+ func (m *MySQLGroupSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *MySQLGroupSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MySQLGroupSpec) Reset()

+ func (m *MySQLGroupSpec) Size() (n int)

+ func (m *MySQLGroupSpec) Unmarshal(dAtA []byte) error

+ func (m *MySQLGroupSpec) XXX_DiscardUnknown()

+ func (m *MySQLGroupSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MySQLGroupSpec) XXX_Merge(src proto.Message)

+ func (m *MySQLGroupSpec) XXX_Size() int

+ func (m *MySQLGroupSpec) XXX_Unmarshal(b []byte) error

+ func (this *MySQLGroupSpec) String() string

+ type MySQLList struct

+ Items []MySQL

+ func (*MySQLList) Descriptor() ([]byte, []int)

+ func (*MySQLList) ProtoMessage()

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

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

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

+ func (m *MySQLList) Marshal() (dAtA []byte, err error)

+ func (m *MySQLList) MarshalTo(dAtA []byte) (int, error)

+ func (m *MySQLList) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MySQLList) Reset()

+ func (m *MySQLList) Size() (n int)

+ func (m *MySQLList) Unmarshal(dAtA []byte) error

+ func (m *MySQLList) XXX_DiscardUnknown()

+ func (m *MySQLList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MySQLList) XXX_Merge(src proto.Message)

+ func (m *MySQLList) XXX_Size() int

+ func (m *MySQLList) XXX_Unmarshal(b []byte) error

+ func (this *MySQLList) String() string

+ type MySQLSpec struct

+ AuthSecret *core.LocalObjectReference

+ ConfigSecret *core.LocalObjectReference

+ Halted bool

+ Init *InitSpec

+ Monitor *mona.AgentSpec

+ PodTemplate ofst.PodTemplateSpec

+ Replicas *int32

+ RequireSSL bool

+ ServiceTemplate ofst.ServiceTemplateSpec

+ Storage *core.PersistentVolumeClaimSpec

+ StorageType StorageType

+ TLS *kmapi.TLSConfig

+ TerminationPolicy TerminationPolicy

+ Topology *MySQLClusterTopology

+ Version string

+ func (*MySQLSpec) Descriptor() ([]byte, []int)

+ func (*MySQLSpec) ProtoMessage()

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

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

+ func (m *MySQLSpec) GetPersistentSecrets() []string

+ func (m *MySQLSpec) Marshal() (dAtA []byte, err error)

+ func (m *MySQLSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *MySQLSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MySQLSpec) Reset()

+ func (m *MySQLSpec) Size() (n int)

+ func (m *MySQLSpec) Unmarshal(dAtA []byte) error

+ func (m *MySQLSpec) XXX_DiscardUnknown()

+ func (m *MySQLSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MySQLSpec) XXX_Merge(src proto.Message)

+ func (m *MySQLSpec) XXX_Size() int

+ func (m *MySQLSpec) XXX_Unmarshal(b []byte) error

+ func (this *MySQLSpec) String() string

+ type MySQLStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase DatabasePhase

+ func (*MySQLStatus) Descriptor() ([]byte, []int)

+ func (*MySQLStatus) ProtoMessage()

+ func (in *MySQLStatus) DeepCopy() *MySQLStatus

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

+ func (m *MySQLStatus) Marshal() (dAtA []byte, err error)

+ func (m *MySQLStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *MySQLStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MySQLStatus) Reset()

+ func (m *MySQLStatus) Size() (n int)

+ func (m *MySQLStatus) Unmarshal(dAtA []byte) error

+ func (m *MySQLStatus) XXX_DiscardUnknown()

+ func (m *MySQLStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MySQLStatus) XXX_Merge(src proto.Message)

+ func (m *MySQLStatus) XXX_Size() int

+ func (m *MySQLStatus) XXX_Unmarshal(b []byte) error

+ func (this *MySQLStatus) String() string

+ type PerconaXtraDB struct

+ Spec PerconaXtraDBSpec

+ Status PerconaXtraDBStatus

+ func (*PerconaXtraDB) Descriptor() ([]byte, []int)

+ func (*PerconaXtraDB) ProtoMessage()

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

+ func (in *PerconaXtraDB) DeepCopy() *PerconaXtraDB

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

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

+ func (m *PerconaXtraDB) Marshal() (dAtA []byte, err error)

+ func (m *PerconaXtraDB) MarshalTo(dAtA []byte) (int, error)

+ func (m *PerconaXtraDB) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PerconaXtraDB) Reset()

+ func (m *PerconaXtraDB) Size() (n int)

+ func (m *PerconaXtraDB) Unmarshal(dAtA []byte) error

+ func (m *PerconaXtraDB) XXX_DiscardUnknown()

+ func (m *PerconaXtraDB) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PerconaXtraDB) XXX_Merge(src proto.Message)

+ func (m *PerconaXtraDB) XXX_Size() int

+ func (m *PerconaXtraDB) XXX_Unmarshal(b []byte) error

+ func (p *PerconaXtraDB) ReplicasAreReady(lister appslister.StatefulSetLister) (bool, string, error)

+ func (p *PerconaXtraDB) SetDefaults()

+ func (p PerconaXtraDB) AppBindingMeta() appcat.AppBindingMeta

+ func (p PerconaXtraDB) ClusterName() string

+ func (p PerconaXtraDB) GetAuthSecretName() string

+ func (p PerconaXtraDB) GoverningServiceName() string

+ func (p PerconaXtraDB) IsCluster() bool

+ func (p PerconaXtraDB) OffshootLabels() map[string]string

+ func (p PerconaXtraDB) OffshootName() string

+ func (p PerconaXtraDB) OffshootSelectors() map[string]string

+ func (p PerconaXtraDB) PeerName(idx int) string

+ func (p PerconaXtraDB) ResourceKind() string

+ func (p PerconaXtraDB) ResourcePlural() string

+ func (p PerconaXtraDB) ResourceShortCode() string

+ func (p PerconaXtraDB) ResourceSingular() string

+ func (p PerconaXtraDB) ServiceName() string

+ func (p PerconaXtraDB) StatsService() mona.StatsAccessor

+ func (p PerconaXtraDB) StatsServiceLabels() map[string]string

+ func (this *PerconaXtraDB) String() string

+ type PerconaXtraDBCertificateAlias string

+ const PerconaXtraDBArchiverCert

+ const PerconaXtraDBMetricsExporterCert

+ const PerconaXtraDBServerCert

+ type PerconaXtraDBList struct

+ Items []PerconaXtraDB

+ func (*PerconaXtraDBList) Descriptor() ([]byte, []int)

+ func (*PerconaXtraDBList) ProtoMessage()

+ func (in *PerconaXtraDBList) DeepCopy() *PerconaXtraDBList

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

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

+ func (m *PerconaXtraDBList) Marshal() (dAtA []byte, err error)

+ func (m *PerconaXtraDBList) MarshalTo(dAtA []byte) (int, error)

+ func (m *PerconaXtraDBList) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PerconaXtraDBList) Reset()

+ func (m *PerconaXtraDBList) Size() (n int)

+ func (m *PerconaXtraDBList) Unmarshal(dAtA []byte) error

+ func (m *PerconaXtraDBList) XXX_DiscardUnknown()

+ func (m *PerconaXtraDBList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PerconaXtraDBList) XXX_Merge(src proto.Message)

+ func (m *PerconaXtraDBList) XXX_Size() int

+ func (m *PerconaXtraDBList) XXX_Unmarshal(b []byte) error

+ func (this *PerconaXtraDBList) String() string

+ type PerconaXtraDBSpec struct

+ AuthSecret *core.LocalObjectReference

+ ConfigSecret *core.LocalObjectReference

+ Halted bool

+ Init *InitSpec

+ Monitor *mona.AgentSpec

+ PodTemplate ofst.PodTemplateSpec

+ Replicas *int32

+ ServiceTemplate ofst.ServiceTemplateSpec

+ Storage *core.PersistentVolumeClaimSpec

+ StorageType StorageType

+ TLS *kmapi.TLSConfig

+ TerminationPolicy TerminationPolicy

+ Version string

+ func (*PerconaXtraDBSpec) Descriptor() ([]byte, []int)

+ func (*PerconaXtraDBSpec) ProtoMessage()

+ func (in *PerconaXtraDBSpec) DeepCopy() *PerconaXtraDBSpec

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

+ func (m *PerconaXtraDBSpec) Marshal() (dAtA []byte, err error)

+ func (m *PerconaXtraDBSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *PerconaXtraDBSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PerconaXtraDBSpec) Reset()

+ func (m *PerconaXtraDBSpec) Size() (n int)

+ func (m *PerconaXtraDBSpec) Unmarshal(dAtA []byte) error

+ func (m *PerconaXtraDBSpec) XXX_DiscardUnknown()

+ func (m *PerconaXtraDBSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PerconaXtraDBSpec) XXX_Merge(src proto.Message)

+ func (m *PerconaXtraDBSpec) XXX_Size() int

+ func (m *PerconaXtraDBSpec) XXX_Unmarshal(b []byte) error

+ func (p *PerconaXtraDBSpec) GetPersistentSecrets() []string

+ func (this *PerconaXtraDBSpec) String() string

+ type PerconaXtraDBStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase DatabasePhase

+ func (*PerconaXtraDBStatus) Descriptor() ([]byte, []int)

+ func (*PerconaXtraDBStatus) ProtoMessage()

+ func (in *PerconaXtraDBStatus) DeepCopy() *PerconaXtraDBStatus

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

+ func (m *PerconaXtraDBStatus) Marshal() (dAtA []byte, err error)

+ func (m *PerconaXtraDBStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *PerconaXtraDBStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PerconaXtraDBStatus) Reset()

+ func (m *PerconaXtraDBStatus) Size() (n int)

+ func (m *PerconaXtraDBStatus) Unmarshal(dAtA []byte) error

+ func (m *PerconaXtraDBStatus) XXX_DiscardUnknown()

+ func (m *PerconaXtraDBStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PerconaXtraDBStatus) XXX_Merge(src proto.Message)

+ func (m *PerconaXtraDBStatus) XXX_Size() int

+ func (m *PerconaXtraDBStatus) XXX_Unmarshal(b []byte) error

+ func (this *PerconaXtraDBStatus) String() string

+ type PgBouncer struct

+ Spec PgBouncerSpec

+ Status PgBouncerStatus

+ func (*PgBouncer) Descriptor() ([]byte, []int)

+ func (*PgBouncer) ProtoMessage()

+ func (in *PgBouncer) DeepCopy() *PgBouncer

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

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

+ func (m *PgBouncer) Marshal() (dAtA []byte, err error)

+ func (m *PgBouncer) MarshalTo(dAtA []byte) (int, error)

+ func (m *PgBouncer) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PgBouncer) Reset()

+ func (m *PgBouncer) Size() (n int)

+ func (m *PgBouncer) Unmarshal(dAtA []byte) error

+ func (m *PgBouncer) XXX_DiscardUnknown()

+ func (m *PgBouncer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PgBouncer) XXX_Merge(src proto.Message)

+ func (m *PgBouncer) XXX_Size() int

+ func (m *PgBouncer) XXX_Unmarshal(b []byte) error

+ func (p *PgBouncer) CertificateName(alias PgBouncerCertificateAlias) string

+ func (p *PgBouncer) MustCertSecretName(alias PgBouncerCertificateAlias) string

+ func (p *PgBouncer) ReplicasAreReady(lister appslister.StatefulSetLister) (bool, string, error)

+ func (p *PgBouncer) SetDefaults()

+ func (p *PgBouncer) SetTLSDefaults()

+ func (p PgBouncer) AppBindingMeta() appcat.AppBindingMeta

+ func (p PgBouncer) AuthSecretName() string

+ func (p PgBouncer) ConfigSecretName() string

+ func (p PgBouncer) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

+ func (p PgBouncer) GoverningServiceName() string

+ func (p PgBouncer) OffshootLabels() map[string]string

+ func (p PgBouncer) OffshootName() string

+ func (p PgBouncer) OffshootSelectors() map[string]string

+ func (p PgBouncer) ReplicasServiceName() string

+ func (p PgBouncer) ResourceKind() string

+ func (p PgBouncer) ResourcePlural() string

+ func (p PgBouncer) ResourceShortCode() string

+ func (p PgBouncer) ResourceSingular() string

+ func (p PgBouncer) ServiceName() string

+ func (p PgBouncer) StatsService() mona.StatsAccessor

+ func (p PgBouncer) StatsServiceLabels() map[string]string

+ func (this *PgBouncer) String() string

+ type PgBouncerCertificateAlias string

+ const PgBouncerClientCert

+ const PgBouncerMetricsExporterCert

+ const PgBouncerServerCert

+ type PgBouncerList struct

+ Items []PgBouncer

+ func (*PgBouncerList) Descriptor() ([]byte, []int)

+ func (*PgBouncerList) ProtoMessage()

+ func (in *PgBouncerList) DeepCopy() *PgBouncerList

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

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

+ func (m *PgBouncerList) Marshal() (dAtA []byte, err error)

+ func (m *PgBouncerList) MarshalTo(dAtA []byte) (int, error)

+ func (m *PgBouncerList) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PgBouncerList) Reset()

+ func (m *PgBouncerList) Size() (n int)

+ func (m *PgBouncerList) Unmarshal(dAtA []byte) error

+ func (m *PgBouncerList) XXX_DiscardUnknown()

+ func (m *PgBouncerList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PgBouncerList) XXX_Merge(src proto.Message)

+ func (m *PgBouncerList) XXX_Size() int

+ func (m *PgBouncerList) XXX_Unmarshal(b []byte) error

+ func (this *PgBouncerList) String() string

+ type PgBouncerSpec struct

+ ConnectionPool *ConnectionPoolConfig

+ Databases []Databases

+ Monitor *mona.AgentSpec

+ PodTemplate ofst.PodTemplateSpec

+ Replicas *int32

+ ServiceTemplate ofst.ServiceTemplateSpec

+ TLS *kmapi.TLSConfig

+ UserListSecretRef *core.LocalObjectReference

+ Version string

+ func (*PgBouncerSpec) Descriptor() ([]byte, []int)

+ func (*PgBouncerSpec) ProtoMessage()

+ func (in *PgBouncerSpec) DeepCopy() *PgBouncerSpec

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

+ func (m *PgBouncerSpec) Marshal() (dAtA []byte, err error)

+ func (m *PgBouncerSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *PgBouncerSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PgBouncerSpec) Reset()

+ func (m *PgBouncerSpec) Size() (n int)

+ func (m *PgBouncerSpec) Unmarshal(dAtA []byte) error

+ func (m *PgBouncerSpec) XXX_DiscardUnknown()

+ func (m *PgBouncerSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PgBouncerSpec) XXX_Merge(src proto.Message)

+ func (m *PgBouncerSpec) XXX_Size() int

+ func (m *PgBouncerSpec) XXX_Unmarshal(b []byte) error

+ func (this *PgBouncerSpec) String() string

+ type PgBouncerStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase DatabasePhase

+ func (*PgBouncerStatus) Descriptor() ([]byte, []int)

+ func (*PgBouncerStatus) ProtoMessage()

+ func (in *PgBouncerStatus) DeepCopy() *PgBouncerStatus

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

+ func (m *PgBouncerStatus) Marshal() (dAtA []byte, err error)

+ func (m *PgBouncerStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *PgBouncerStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PgBouncerStatus) Reset()

+ func (m *PgBouncerStatus) Size() (n int)

+ func (m *PgBouncerStatus) Unmarshal(dAtA []byte) error

+ func (m *PgBouncerStatus) XXX_DiscardUnknown()

+ func (m *PgBouncerStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PgBouncerStatus) XXX_Merge(src proto.Message)

+ func (m *PgBouncerStatus) XXX_Size() int

+ func (m *PgBouncerStatus) XXX_Unmarshal(b []byte) error

+ func (this *PgBouncerStatus) String() string

+ type Postgres struct

+ Spec PostgresSpec

+ Status PostgresStatus

+ func (*Postgres) Descriptor() ([]byte, []int)

+ func (*Postgres) ProtoMessage()

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

+ func (in *Postgres) DeepCopy() *Postgres

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

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

+ func (m *Postgres) Marshal() (dAtA []byte, err error)

+ func (m *Postgres) MarshalTo(dAtA []byte) (int, error)

+ func (m *Postgres) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Postgres) Reset()

+ func (m *Postgres) Size() (n int)

+ func (m *Postgres) Unmarshal(dAtA []byte) error

+ func (m *Postgres) XXX_DiscardUnknown()

+ func (m *Postgres) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Postgres) XXX_Merge(src proto.Message)

+ func (m *Postgres) XXX_Size() int

+ func (m *Postgres) XXX_Unmarshal(b []byte) error

+ func (p *Postgres) ReplicasAreReady(lister appslister.StatefulSetLister) (bool, string, error)

+ func (p *Postgres) SetDefaults()

+ func (p Postgres) AppBindingMeta() appcat.AppBindingMeta

+ func (p Postgres) GoverningServiceName() string

+ func (p Postgres) OffshootLabels() map[string]string

+ func (p Postgres) OffshootName() string

+ func (p Postgres) OffshootSelectors() map[string]string

+ func (p Postgres) ResourceKind() string

+ func (p Postgres) ResourcePlural() string

+ func (p Postgres) ResourceShortCode() string

+ func (p Postgres) ResourceSingular() string

+ func (p Postgres) ServiceName() string

+ func (p Postgres) StandbyServiceName() string

+ func (p Postgres) StatsService() mona.StatsAccessor

+ func (p Postgres) StatsServiceLabels() map[string]string

+ func (this *Postgres) String() string

+ type PostgresArchiverSpec struct

+ Storage *store.Backend

+ func (*PostgresArchiverSpec) Descriptor() ([]byte, []int)

+ func (*PostgresArchiverSpec) ProtoMessage()

+ func (in *PostgresArchiverSpec) DeepCopy() *PostgresArchiverSpec

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

+ func (m *PostgresArchiverSpec) Marshal() (dAtA []byte, err error)

+ func (m *PostgresArchiverSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *PostgresArchiverSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PostgresArchiverSpec) Reset()

+ func (m *PostgresArchiverSpec) Size() (n int)

+ func (m *PostgresArchiverSpec) Unmarshal(dAtA []byte) error

+ func (m *PostgresArchiverSpec) XXX_DiscardUnknown()

+ func (m *PostgresArchiverSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PostgresArchiverSpec) XXX_Merge(src proto.Message)

+ func (m *PostgresArchiverSpec) XXX_Size() int

+ func (m *PostgresArchiverSpec) XXX_Unmarshal(b []byte) error

+ func (this *PostgresArchiverSpec) String() string

+ type PostgresCertificateAlias string

+ const PostgresArchiverCert

+ const PostgresMetricsExporterCert

+ const PostgresServerCert

+ type PostgresList struct

+ Items []Postgres

+ func (*PostgresList) Descriptor() ([]byte, []int)

+ func (*PostgresList) ProtoMessage()

+ func (in *PostgresList) DeepCopy() *PostgresList

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

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

+ func (m *PostgresList) Marshal() (dAtA []byte, err error)

+ func (m *PostgresList) MarshalTo(dAtA []byte) (int, error)

+ func (m *PostgresList) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PostgresList) Reset()

+ func (m *PostgresList) Size() (n int)

+ func (m *PostgresList) Unmarshal(dAtA []byte) error

+ func (m *PostgresList) XXX_DiscardUnknown()

+ func (m *PostgresList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PostgresList) XXX_Merge(src proto.Message)

+ func (m *PostgresList) XXX_Size() int

+ func (m *PostgresList) XXX_Unmarshal(b []byte) error

+ func (this *PostgresList) String() string

+ type PostgresSpec struct

+ Archiver *PostgresArchiverSpec

+ AuthSecret *core.LocalObjectReference

+ ConfigSecret *core.LocalObjectReference

+ Halted bool

+ Init *InitSpec

+ LeaderElection *LeaderElectionConfig

+ Monitor *mona.AgentSpec

+ PodTemplate ofst.PodTemplateSpec

+ ReplicaServiceTemplate ofst.ServiceTemplateSpec

+ Replicas *int32

+ ServiceTemplate ofst.ServiceTemplateSpec

+ StandbyMode *PostgresStandbyMode

+ Storage *core.PersistentVolumeClaimSpec

+ StorageType StorageType

+ StreamingMode *PostgresStreamingMode

+ TLS *kmapi.TLSConfig

+ TerminationPolicy TerminationPolicy

+ Version string

+ func (*PostgresSpec) Descriptor() ([]byte, []int)

+ func (*PostgresSpec) ProtoMessage()

+ func (e *PostgresSpec) GetPersistentSecrets() []string

+ func (in *PostgresSpec) DeepCopy() *PostgresSpec

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

+ func (m *PostgresSpec) Marshal() (dAtA []byte, err error)

+ func (m *PostgresSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *PostgresSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PostgresSpec) Reset()

+ func (m *PostgresSpec) Size() (n int)

+ func (m *PostgresSpec) Unmarshal(dAtA []byte) error

+ func (m *PostgresSpec) XXX_DiscardUnknown()

+ func (m *PostgresSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PostgresSpec) XXX_Merge(src proto.Message)

+ func (m *PostgresSpec) XXX_Size() int

+ func (m *PostgresSpec) XXX_Unmarshal(b []byte) error

+ func (this *PostgresSpec) String() string

+ type PostgresStandbyMode string

+ const HotPostgresStandbyMode

+ const WarmPostgresStandbyMode

+ type PostgresStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase DatabasePhase

+ func (*PostgresStatus) Descriptor() ([]byte, []int)

+ func (*PostgresStatus) ProtoMessage()

+ func (in *PostgresStatus) DeepCopy() *PostgresStatus

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

+ func (m *PostgresStatus) Marshal() (dAtA []byte, err error)

+ func (m *PostgresStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *PostgresStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PostgresStatus) Reset()

+ func (m *PostgresStatus) Size() (n int)

+ func (m *PostgresStatus) Unmarshal(dAtA []byte) error

+ func (m *PostgresStatus) XXX_DiscardUnknown()

+ func (m *PostgresStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PostgresStatus) XXX_Merge(src proto.Message)

+ func (m *PostgresStatus) XXX_Size() int

+ func (m *PostgresStatus) XXX_Unmarshal(b []byte) error

+ func (this *PostgresStatus) String() string

+ type PostgresStreamingMode string

+ const AsynchronousPostgresStreamingMode

+ const SynchronousPostgresStreamingMode

+ type PostgresWALSourceSpec struct

+ BackupName string

+ PITR *RecoveryTarget

+ func (*PostgresWALSourceSpec) Descriptor() ([]byte, []int)

+ func (*PostgresWALSourceSpec) ProtoMessage()

+ func (in *PostgresWALSourceSpec) DeepCopy() *PostgresWALSourceSpec

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

+ func (m *PostgresWALSourceSpec) Marshal() (dAtA []byte, err error)

+ func (m *PostgresWALSourceSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *PostgresWALSourceSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PostgresWALSourceSpec) Reset()

+ func (m *PostgresWALSourceSpec) Size() (n int)

+ func (m *PostgresWALSourceSpec) Unmarshal(dAtA []byte) error

+ func (m *PostgresWALSourceSpec) XXX_DiscardUnknown()

+ func (m *PostgresWALSourceSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PostgresWALSourceSpec) XXX_Merge(src proto.Message)

+ func (m *PostgresWALSourceSpec) XXX_Size() int

+ func (m *PostgresWALSourceSpec) XXX_Unmarshal(b []byte) error

+ func (this *PostgresWALSourceSpec) String() string

+ type ProxySQL struct

+ Spec ProxySQLSpec

+ Status ProxySQLStatus

+ func (*ProxySQL) Descriptor() ([]byte, []int)

+ func (*ProxySQL) ProtoMessage()

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

+ func (in *ProxySQL) DeepCopy() *ProxySQL

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

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

+ func (m *ProxySQL) Marshal() (dAtA []byte, err error)

+ func (m *ProxySQL) MarshalTo(dAtA []byte) (int, error)

+ func (m *ProxySQL) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ProxySQL) Reset()

+ func (m *ProxySQL) Size() (n int)

+ func (m *ProxySQL) Unmarshal(dAtA []byte) error

+ func (m *ProxySQL) XXX_DiscardUnknown()

+ func (m *ProxySQL) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ProxySQL) XXX_Merge(src proto.Message)

+ func (m *ProxySQL) XXX_Size() int

+ func (m *ProxySQL) XXX_Unmarshal(b []byte) error

+ func (p *ProxySQL) ReplicasAreReady(lister appslister.StatefulSetLister) (bool, string, error)

+ func (p *ProxySQL) SetDefaults()

+ func (p ProxySQL) AppBindingMeta() appcat.AppBindingMeta

+ func (p ProxySQL) GoverningServiceName() string

+ func (p ProxySQL) OffshootLabels() map[string]string

+ func (p ProxySQL) OffshootName() string

+ func (p ProxySQL) OffshootSelectors() map[string]string

+ func (p ProxySQL) ResourceKind() string

+ func (p ProxySQL) ResourcePlural() string

+ func (p ProxySQL) ResourceShortCode() string

+ func (p ProxySQL) ResourceSingular() string

+ func (p ProxySQL) ServiceName() string

+ func (p ProxySQL) StatsService() mona.StatsAccessor

+ func (p ProxySQL) StatsServiceLabels() map[string]string

+ func (this *ProxySQL) String() string

+ type ProxySQLBackendSpec struct

+ Ref *core.TypedLocalObjectReference

+ Replicas *int32

+ func (*ProxySQLBackendSpec) Descriptor() ([]byte, []int)

+ func (*ProxySQLBackendSpec) ProtoMessage()

+ func (in *ProxySQLBackendSpec) DeepCopy() *ProxySQLBackendSpec

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

+ func (m *ProxySQLBackendSpec) Marshal() (dAtA []byte, err error)

+ func (m *ProxySQLBackendSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *ProxySQLBackendSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ProxySQLBackendSpec) Reset()

+ func (m *ProxySQLBackendSpec) Size() (n int)

+ func (m *ProxySQLBackendSpec) Unmarshal(dAtA []byte) error

+ func (m *ProxySQLBackendSpec) XXX_DiscardUnknown()

+ func (m *ProxySQLBackendSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ProxySQLBackendSpec) XXX_Merge(src proto.Message)

+ func (m *ProxySQLBackendSpec) XXX_Size() int

+ func (m *ProxySQLBackendSpec) XXX_Unmarshal(b []byte) error

+ func (this *ProxySQLBackendSpec) String() string

+ type ProxySQLCertificateAlias string

+ const ProxySQLArchiverCert

+ const ProxySQLMetricsExporterCert

+ const ProxySQLServerCert

+ type ProxySQLList struct

+ Items []ProxySQL

+ func (*ProxySQLList) Descriptor() ([]byte, []int)

+ func (*ProxySQLList) ProtoMessage()

+ func (in *ProxySQLList) DeepCopy() *ProxySQLList

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

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

+ func (m *ProxySQLList) Marshal() (dAtA []byte, err error)

+ func (m *ProxySQLList) MarshalTo(dAtA []byte) (int, error)

+ func (m *ProxySQLList) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ProxySQLList) Reset()

+ func (m *ProxySQLList) Size() (n int)

+ func (m *ProxySQLList) Unmarshal(dAtA []byte) error

+ func (m *ProxySQLList) XXX_DiscardUnknown()

+ func (m *ProxySQLList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ProxySQLList) XXX_Merge(src proto.Message)

+ func (m *ProxySQLList) XXX_Size() int

+ func (m *ProxySQLList) XXX_Unmarshal(b []byte) error

+ func (this *ProxySQLList) String() string

+ type ProxySQLSpec struct

+ AuthSecret *core.LocalObjectReference

+ Backend *ProxySQLBackendSpec

+ ConfigSecret *core.LocalObjectReference

+ Mode *LoadBalanceMode

+ Monitor *mona.AgentSpec

+ PodTemplate ofst.PodTemplateSpec

+ Replicas *int32

+ ServiceTemplate ofst.ServiceTemplateSpec

+ TLS *kmapi.TLSConfig

+ Version string

+ func (*ProxySQLSpec) Descriptor() ([]byte, []int)

+ func (*ProxySQLSpec) ProtoMessage()

+ func (in *ProxySQLSpec) DeepCopy() *ProxySQLSpec

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

+ func (m *ProxySQLSpec) Marshal() (dAtA []byte, err error)

+ func (m *ProxySQLSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *ProxySQLSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ProxySQLSpec) Reset()

+ func (m *ProxySQLSpec) Size() (n int)

+ func (m *ProxySQLSpec) Unmarshal(dAtA []byte) error

+ func (m *ProxySQLSpec) XXX_DiscardUnknown()

+ func (m *ProxySQLSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ProxySQLSpec) XXX_Merge(src proto.Message)

+ func (m *ProxySQLSpec) XXX_Size() int

+ func (m *ProxySQLSpec) XXX_Unmarshal(b []byte) error

+ func (p *ProxySQLSpec) GetPersistentSecrets() []string

+ func (this *ProxySQLSpec) String() string

+ type ProxySQLStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase DatabasePhase

+ func (*ProxySQLStatus) Descriptor() ([]byte, []int)

+ func (*ProxySQLStatus) ProtoMessage()

+ func (in *ProxySQLStatus) DeepCopy() *ProxySQLStatus

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

+ func (m *ProxySQLStatus) Marshal() (dAtA []byte, err error)

+ func (m *ProxySQLStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *ProxySQLStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ProxySQLStatus) Reset()

+ func (m *ProxySQLStatus) Size() (n int)

+ func (m *ProxySQLStatus) Unmarshal(dAtA []byte) error

+ func (m *ProxySQLStatus) XXX_DiscardUnknown()

+ func (m *ProxySQLStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ProxySQLStatus) XXX_Merge(src proto.Message)

+ func (m *ProxySQLStatus) XXX_Size() int

+ func (m *ProxySQLStatus) XXX_Unmarshal(b []byte) error

+ func (this *ProxySQLStatus) String() string

+ type RecoveryTarget struct

+ TargetInclusive *bool

+ TargetTime string

+ TargetTimeline string

+ TargetXID string

+ func (*RecoveryTarget) Descriptor() ([]byte, []int)

+ func (*RecoveryTarget) ProtoMessage()

+ func (in *RecoveryTarget) DeepCopy() *RecoveryTarget

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

+ func (m *RecoveryTarget) Marshal() (dAtA []byte, err error)

+ func (m *RecoveryTarget) MarshalTo(dAtA []byte) (int, error)

+ func (m *RecoveryTarget) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RecoveryTarget) Reset()

+ func (m *RecoveryTarget) Size() (n int)

+ func (m *RecoveryTarget) Unmarshal(dAtA []byte) error

+ func (m *RecoveryTarget) XXX_DiscardUnknown()

+ func (m *RecoveryTarget) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RecoveryTarget) XXX_Merge(src proto.Message)

+ func (m *RecoveryTarget) XXX_Size() int

+ func (m *RecoveryTarget) XXX_Unmarshal(b []byte) error

+ func (this *RecoveryTarget) String() string

+ type Redis struct

+ Spec RedisSpec

+ Status RedisStatus

+ func (*Redis) Descriptor() ([]byte, []int)

+ func (*Redis) ProtoMessage()

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

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

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

+ func (m *Redis) Marshal() (dAtA []byte, err error)

+ func (m *Redis) MarshalTo(dAtA []byte) (int, error)

+ func (m *Redis) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Redis) Reset()

+ func (m *Redis) Size() (n int)

+ func (m *Redis) Unmarshal(dAtA []byte) error

+ func (m *Redis) XXX_DiscardUnknown()

+ func (m *Redis) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Redis) XXX_Merge(src proto.Message)

+ func (m *Redis) XXX_Size() int

+ func (m *Redis) XXX_Unmarshal(b []byte) error

+ func (r *Redis) CertificateName(alias RedisCertificateAlias) string

+ func (r *Redis) MustCertSecretName(alias RedisCertificateAlias) string

+ func (r *Redis) ReplicasAreReady(lister appslister.StatefulSetLister) (bool, string, error)

+ func (r *Redis) SetDefaults(topology *core_util.Topology)

+ func (r *Redis) SetTLSDefaults()

+ func (r Redis) AppBindingMeta() appcat.AppBindingMeta

+ func (r Redis) BaseNameForShard() string

+ func (r Redis) ConfigSecretName() string

+ func (r Redis) CustomResourceDefinition() *apiextensions.CustomResourceDefinition

+ func (r Redis) GoverningServiceName() string

+ func (r Redis) OffshootLabels() map[string]string

+ func (r Redis) OffshootName() string

+ func (r Redis) OffshootSelectors() map[string]string

+ func (r Redis) ResourceKind() string

+ func (r Redis) ResourcePlural() string

+ func (r Redis) ResourceShortCode() string

+ func (r Redis) ResourceSingular() string

+ func (r Redis) ServiceName() string

+ func (r Redis) ShardNodeTemplate() string

+ func (r Redis) StatefulSetNameWithShard(i int) string

+ func (r Redis) StatsService() mona.StatsAccessor

+ func (r Redis) StatsServiceLabels() map[string]string

+ func (this *Redis) String() string

+ type RedisCertificateAlias string

+ const RedisClientCert

+ const RedisMetricsExporterCert

+ const RedisServerCert

+ type RedisClusterSpec struct

+ Master *int32

+ Replicas *int32

+ func (*RedisClusterSpec) Descriptor() ([]byte, []int)

+ func (*RedisClusterSpec) ProtoMessage()

+ func (in *RedisClusterSpec) DeepCopy() *RedisClusterSpec

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

+ func (m *RedisClusterSpec) Marshal() (dAtA []byte, err error)

+ func (m *RedisClusterSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *RedisClusterSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RedisClusterSpec) Reset()

+ func (m *RedisClusterSpec) Size() (n int)

+ func (m *RedisClusterSpec) Unmarshal(dAtA []byte) error

+ func (m *RedisClusterSpec) XXX_DiscardUnknown()

+ func (m *RedisClusterSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RedisClusterSpec) XXX_Merge(src proto.Message)

+ func (m *RedisClusterSpec) XXX_Size() int

+ func (m *RedisClusterSpec) XXX_Unmarshal(b []byte) error

+ func (this *RedisClusterSpec) String() string

+ type RedisList struct

+ Items []Redis

+ func (*RedisList) Descriptor() ([]byte, []int)

+ func (*RedisList) ProtoMessage()

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

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

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

+ func (m *RedisList) Marshal() (dAtA []byte, err error)

+ func (m *RedisList) MarshalTo(dAtA []byte) (int, error)

+ func (m *RedisList) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RedisList) Reset()

+ func (m *RedisList) Size() (n int)

+ func (m *RedisList) Unmarshal(dAtA []byte) error

+ func (m *RedisList) XXX_DiscardUnknown()

+ func (m *RedisList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RedisList) XXX_Merge(src proto.Message)

+ func (m *RedisList) XXX_Size() int

+ func (m *RedisList) XXX_Unmarshal(b []byte) error

+ func (this *RedisList) String() string

+ type RedisMode string

+ const RedisModeCluster

+ const RedisModeStandalone

+ type RedisSpec struct

+ AuthSecret *core.LocalObjectReference

+ Cluster *RedisClusterSpec

+ ConfigSecret *core.LocalObjectReference

+ Halted bool

+ Init *InitSpec

+ Mode RedisMode

+ Monitor *mona.AgentSpec

+ PodTemplate ofst.PodTemplateSpec

+ Replicas *int32

+ ServiceTemplate ofst.ServiceTemplateSpec

+ Storage *core.PersistentVolumeClaimSpec

+ StorageType StorageType

+ TLS *kmapi.TLSConfig

+ TerminationPolicy TerminationPolicy

+ Version string

+ func (*RedisSpec) Descriptor() ([]byte, []int)

+ func (*RedisSpec) ProtoMessage()

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

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

+ func (m *RedisSpec) Marshal() (dAtA []byte, err error)

+ func (m *RedisSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *RedisSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RedisSpec) Reset()

+ func (m *RedisSpec) Size() (n int)

+ func (m *RedisSpec) Unmarshal(dAtA []byte) error

+ func (m *RedisSpec) XXX_DiscardUnknown()

+ func (m *RedisSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RedisSpec) XXX_Merge(src proto.Message)

+ func (m *RedisSpec) XXX_Size() int

+ func (m *RedisSpec) XXX_Unmarshal(b []byte) error

+ func (r *RedisSpec) GetPersistentSecrets() []string

+ func (this *RedisSpec) String() string

+ type RedisStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase DatabasePhase

+ func (*RedisStatus) Descriptor() ([]byte, []int)

+ func (*RedisStatus) ProtoMessage()

+ func (in *RedisStatus) DeepCopy() *RedisStatus

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

+ func (m *RedisStatus) Marshal() (dAtA []byte, err error)

+ func (m *RedisStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *RedisStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RedisStatus) Reset()

+ func (m *RedisStatus) Size() (n int)

+ func (m *RedisStatus) Unmarshal(dAtA []byte) error

+ func (m *RedisStatus) XXX_DiscardUnknown()

+ func (m *RedisStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RedisStatus) XXX_Merge(src proto.Message)

+ func (m *RedisStatus) XXX_Size() int

+ func (m *RedisStatus) XXX_Unmarshal(b []byte) error

+ func (this *RedisStatus) String() string

+ type SSLMode string

+ const SSLModeAllowSSL

+ const SSLModeDisabled

+ const SSLModePreferSSL

+ const SSLModeRequireSSL

+ type ScriptSourceSpec struct

+ ScriptPath string

+ func (*ScriptSourceSpec) Descriptor() ([]byte, []int)

+ func (*ScriptSourceSpec) ProtoMessage()

+ func (in *ScriptSourceSpec) DeepCopy() *ScriptSourceSpec

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

+ func (m *ScriptSourceSpec) Marshal() (dAtA []byte, err error)

+ func (m *ScriptSourceSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *ScriptSourceSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ScriptSourceSpec) Reset()

+ func (m *ScriptSourceSpec) Size() (n int)

+ func (m *ScriptSourceSpec) Unmarshal(dAtA []byte) error

+ func (m *ScriptSourceSpec) XXX_DiscardUnknown()

+ func (m *ScriptSourceSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ScriptSourceSpec) XXX_Merge(src proto.Message)

+ func (m *ScriptSourceSpec) XXX_Size() int

+ func (m *ScriptSourceSpec) XXX_Unmarshal(b []byte) error

+ func (this *ScriptSourceSpec) String() string

+ type StorageEngine string

+ const StorageEngineInMemory

+ const StorageEngineWiredTiger

+ type StorageType string

+ const StorageTypeDurable

+ const StorageTypeEphemeral

+ type TLSPolicy struct

+ Member *MemberSecret

+ OperatorSecret string

+ func (*TLSPolicy) Descriptor() ([]byte, []int)

+ func (*TLSPolicy) ProtoMessage()

+ func (in *TLSPolicy) DeepCopy() *TLSPolicy

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

+ func (m *TLSPolicy) Marshal() (dAtA []byte, err error)

+ func (m *TLSPolicy) MarshalTo(dAtA []byte) (int, error)

+ func (m *TLSPolicy) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TLSPolicy) Reset()

+ func (m *TLSPolicy) Size() (n int)

+ func (m *TLSPolicy) Unmarshal(dAtA []byte) error

+ func (m *TLSPolicy) XXX_DiscardUnknown()

+ func (m *TLSPolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TLSPolicy) XXX_Merge(src proto.Message)

+ func (m *TLSPolicy) XXX_Size() int

+ func (m *TLSPolicy) XXX_Unmarshal(b []byte) error

+ func (this *TLSPolicy) String() string

+ type TerminationPolicy string

+ const TerminationPolicyDelete

+ const TerminationPolicyDoNotTerminate

+ const TerminationPolicyHalt

+ const TerminationPolicyWipeOut

v0.14.0-rc.2

Oct 27, 2020

v0.14.0-rc.1

Oct 27, 2020

v0.14.0-beta.6

Oct 27, 2020

v0.14.0-beta.5

Oct 26, 2020

v0.14.0-beta.4

Oct 24, 2020

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