v1

Dec 9, 2025

Changes in this version

+ const PoolerAuthDBName

type Cluster

+ func (cluster *Cluster) GetMetricsQueriesTTL() metav1.Duration

type ClusterSpec

+ PodSecurityContext *corev1.PodSecurityContext

+ SecurityContext *corev1.SecurityContext

type DatabaseSpec

+ FDWs []FDWSpec

+ Servers []ServerSpec

type DatabaseStatus

+ FDWs []DatabaseObjectStatus

+ Servers []DatabaseObjectStatus

+ type FDWSpec struct

+ Handler string

+ Options []OptionSpec

+ Owner string

+ Usages []UsageSpec

+ Validator string

+ func (in *FDWSpec) DeepCopy() *FDWSpec

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

type Import

+ PgRestoreDataOptions []string

+ PgRestorePostdataOptions []string

+ PgRestorePredataOptions []string

type MonitoringConfiguration

+ MetricsQueriesTTL *metav1.Duration

+ type OptionSpec struct

+ Ensure EnsureOption

+ Name string

+ Value string

+ func (in *OptionSpec) DeepCopy() *OptionSpec

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

type PgBouncerSpec

+ ClientCASecret *LocalObjectReference

+ ClientTLSSecret *LocalObjectReference

+ ServerCASecret *LocalObjectReference

+ ServerTLSSecret *LocalObjectReference

type Pooler

+ func (in *Pooler) GetClientCASecretNameOrDefault(cluster *Cluster) string

+ func (in *Pooler) GetClientTLSSecretNameOrDefault(cluster *Cluster) string

+ func (in *Pooler) GetServerCASecretNameOrDefault(cluster *Cluster) string

+ func (in *Pooler) GetServerTLSSecretName() string

type PoolerSecrets

+ ClientTLS SecretVersion

+ type ServerSpec struct

+ FdwName string

+ Options []OptionSpec

+ Usages []UsageSpec

+ func (in *ServerSpec) DeepCopy() *ServerSpec

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

type SynchronousReplicaConfiguration

+ FailoverQuorum bool

+ type UsageSpec struct

+ Name string

+ Type UsageSpecType

+ func (in *UsageSpec) DeepCopy() *UsageSpec

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

+ type UsageSpecType string

+ const GrantUsageSpecType

+ const RevokeUsageSpecType

Oct 23, 2025

Changes in this version

type BackupMethod

+ func (b BackupMethod) IsManagedByInstance() bool

+ func (b BackupMethod) IsManagedByOperator() bool

Aug 12, 2025

Changes in this version

+ const MissingWALArchivePlugin

+ const PhaseFailurePlugin

type Cluster

+ func (cluster *Cluster) GetInstanceEnabledPluginNames() (result []string)

+ func (cluster *Cluster) GetJobEnabledPluginNames() (result []string)

+ func (cluster *Cluster) IsFailoverQuorumActive() (bool, error)

+ type ExtensionConfiguration struct

+ DynamicLibraryPath []string

+ ExtensionControlPath []string

+ ImageVolumeSource corev1.ImageVolumeSource

+ LdLibraryPath []string

+ Name string

+ func (in *ExtensionConfiguration) DeepCopy() *ExtensionConfiguration

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

+ type FailoverQuorum struct

+ Status FailoverQuorumStatus

+ func (in *FailoverQuorum) DeepCopy() *FailoverQuorum

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

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

+ type FailoverQuorumList struct

+ Items []FailoverQuorum

+ func (in *FailoverQuorumList) DeepCopy() *FailoverQuorumList

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

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

+ type FailoverQuorumStatus struct

+ Method string

+ Primary string

+ StandbyNames []string

+ StandbyNumber int

+ func (in *FailoverQuorumStatus) DeepCopy() *FailoverQuorumStatus

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

+ type IsolationCheckConfiguration struct

+ ConnectionTimeout int

+ Enabled *bool

+ RequestTimeout int

+ func NewLivenessPingerConfigFromAnnotations(annotations map[string]string) (*IsolationCheckConfiguration, error)

+ func (in *IsolationCheckConfiguration) DeepCopy() *IsolationCheckConfiguration

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

+ type LivenessProbe struct

+ IsolationCheck *IsolationCheckConfiguration

+ func (in *LivenessProbe) DeepCopy() *LivenessProbe

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

type PostgresConfiguration

+ Extensions []ExtensionConfiguration

type ReplicationSlotsHAConfiguration

+ SynchronizeLogicalDecoding bool

Oct 23, 2025

Changes in this version

type BackupStatus

+ MajorVersion int

May 23, 2025

Changes in this version

+ const PhaseMajorUpgrade

type ClusterStatus

+ PGDataImageInfo *ImageInfo

+ type DatabaseObjectSpec struct

+ Ensure EnsureOption

+ Name string

+ func (dbObject DatabaseObjectSpec) GetEnsure() EnsureOption

+ func (dbObject DatabaseObjectSpec) GetName() string

+ func (in *DatabaseObjectSpec) DeepCopy() *DatabaseObjectSpec

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

+ type DatabaseObjectStatus struct

+ Applied bool

+ Message string

+ Name string

+ func (in *DatabaseObjectStatus) DeepCopy() *DatabaseObjectStatus

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

type DatabaseSpec

+ Extensions []ExtensionSpec

+ Schemas []SchemaSpec

type DatabaseStatus

+ Extensions []DatabaseObjectStatus

+ Schemas []DatabaseObjectStatus

+ type ExtensionSpec struct

+ Schema string

+ Version string

+ func (in *ExtensionSpec) DeepCopy() *ExtensionSpec

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

+ type ImageInfo struct

+ Image string

+ MajorVersion int

+ func (in *ImageInfo) DeepCopy() *ImageInfo

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

type InstanceReportedState

+ IP string

+ type ProbeStrategyType string

+ const ProbeStrategyPgIsReady

+ const ProbeStrategyQuery

+ const ProbeStrategyStreaming

+ type ProbeWithStrategy struct

+ MaximumLag *resource.Quantity

+ Type ProbeStrategyType

+ func (in *ProbeWithStrategy) DeepCopy() *ProbeWithStrategy

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

+ func (p *ProbeWithStrategy) ApplyInto(k8sProbe *corev1.Probe)

+ type SchemaSpec struct

+ Owner string

+ func (in *SchemaSpec) DeepCopy() *SchemaSpec

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

Jul 25, 2025

Changes in this version

type Backup

+ func (backup *Backup) GetOnlineOrDefault(cluster *Cluster) bool

type ClusterConditionType

+ const ConditionConsistentSystemID

type ClusterStatus

+ SystemID string

type Pooler

+ func (in *Pooler) GetResourcesRequirements() corev1.ResourceRequirements

May 23, 2025

Changes in this version

type Backup

+ func (backup *Backup) GetVolumeSnapshotDeadline() time.Duration

Feb 28, 2025

Changes in this version

type Database

+ func (db *Database) SetStatusObservedGeneration(obsGeneration int64)

type Publication

+ func (pub *Publication) SetStatusObservedGeneration(obsGeneration int64)

type Subscription

+ func (sub *Subscription) SetStatusObservedGeneration(obsGeneration int64)

Dec 23, 2024

Changes in this version

+ const DatabaseKind

+ const PhaseUpgradeDelayed

+ const PublicationKind

+ const SubscriptionKind

+ func GetExternalClustersEnabledPluginNames(externalClusters []ExternalCluster) (result []string)

type BackupStatus

+ PluginMetadata map[string]string

type BootstrapInitDB

+ BuiltinLocale string

+ IcuLocale string

+ IcuRules string

+ Locale string

+ LocaleProvider string

type Cluster

+ func (cluster *Cluster) EnsureGVKIsPresent()

+ func (cluster *Cluster) GetRecoverySourcePlugin() *PluginConfiguration

+ type DataDurabilityLevel string

+ const DataDurabilityLevelPreferred

+ const DataDurabilityLevelRequired

+ type Database struct

+ Spec DatabaseSpec

+ Status DatabaseStatus

+ func (db *Database) GetClusterRef() corev1.LocalObjectReference

+ func (db *Database) GetManagedObjectName() string

+ func (db *Database) GetName() string

+ func (db *Database) GetStatusMessage() string

+ func (db *Database) HasReconciliations() bool

+ func (db *Database) SetAsFailed(err error)

+ func (db *Database) SetAsReady()

+ func (db *Database) SetAsUnknown(err error)

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

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

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

+ type DatabaseList struct

+ Items []Database

+ func (dbList *DatabaseList) MustHaveManagedResourceExclusivity(reference *Database) error

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

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

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

+ type DatabaseReclaimPolicy string

+ const DatabaseReclaimDelete

+ const DatabaseReclaimRetain

+ type DatabaseSpec struct

+ AllowConnections *bool

+ BuiltinLocale string

+ ClusterRef corev1.LocalObjectReference

+ CollationVersion string

+ ConnectionLimit *int

+ Encoding string

+ Ensure EnsureOption

+ IcuLocale string

+ IcuRules string

+ IsTemplate *bool

+ LcCollate string

+ LcCtype string

+ Locale string

+ LocaleProvider string

+ Name string

+ Owner string

+ ReclaimPolicy DatabaseReclaimPolicy

+ Tablespace string

+ Template string

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

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

+ type DatabaseStatus struct

+ Applied *bool

+ Message string

+ ObservedGeneration int64

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

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

type ExternalCluster

+ PluginConfiguration *PluginConfiguration

type Import

+ PgDumpExtraOptions []string

+ PgRestoreExtraOptions []string

type PluginConfiguration

+ Enabled *bool

+ func (config *PluginConfiguration) IsEnabled() bool

type PluginStatus

+ RestoreJobHookCapabilities []string

+ type Publication struct

+ Spec PublicationSpec

+ Status PublicationStatus

+ func (in *Publication) DeepCopy() *Publication

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

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

+ func (pub *Publication) GetClusterRef() corev1.LocalObjectReference

+ func (pub *Publication) GetManagedObjectName() string

+ func (pub *Publication) GetName() string

+ func (pub *Publication) GetStatusMessage() string

+ func (pub *Publication) HasReconciliations() bool

+ func (pub *Publication) SetAsFailed(err error)

+ func (pub *Publication) SetAsReady()

+ func (pub *Publication) SetAsUnknown(err error)

+ type PublicationList struct

+ Items []Publication

+ func (in *PublicationList) DeepCopy() *PublicationList

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

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

+ func (pub *PublicationList) MustHaveManagedResourceExclusivity(reference *Publication) error

+ type PublicationReclaimPolicy string

+ const PublicationReclaimDelete

+ const PublicationReclaimRetain

+ type PublicationSpec struct

+ ClusterRef corev1.LocalObjectReference

+ DBName string

+ Name string

+ Parameters map[string]string

+ ReclaimPolicy PublicationReclaimPolicy

+ Target PublicationTarget

+ func (in *PublicationSpec) DeepCopy() *PublicationSpec

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

+ type PublicationStatus struct

+ Applied *bool

+ Message string

+ ObservedGeneration int64

+ func (in *PublicationStatus) DeepCopy() *PublicationStatus

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

+ type PublicationTarget struct

+ AllTables bool

+ Objects []PublicationTargetObject

+ func (in *PublicationTarget) DeepCopy() *PublicationTarget

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

+ type PublicationTargetObject struct

+ Table *PublicationTargetTable

+ TablesInSchema string

+ func (in *PublicationTargetObject) DeepCopy() *PublicationTargetObject

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

+ type PublicationTargetTable struct

+ Columns []string

+ Name string

+ Only bool

+ Schema string

+ func (in *PublicationTargetTable) DeepCopy() *PublicationTargetTable

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

+ type Subscription struct

+ Spec SubscriptionSpec

+ Status SubscriptionStatus

+ func (in *Subscription) DeepCopy() *Subscription

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

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

+ func (sub *Subscription) GetClusterRef() corev1.LocalObjectReference

+ func (sub *Subscription) GetManagedObjectName() string

+ func (sub *Subscription) GetName() string

+ func (sub *Subscription) GetStatusMessage() string

+ func (sub *Subscription) HasReconciliations() bool

+ func (sub *Subscription) SetAsFailed(err error)

+ func (sub *Subscription) SetAsReady()

+ func (sub *Subscription) SetAsUnknown(err error)

+ type SubscriptionList struct

+ Items []Subscription

+ func (in *SubscriptionList) DeepCopy() *SubscriptionList

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

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

+ func (pub *SubscriptionList) MustHaveManagedResourceExclusivity(reference *Subscription) error

+ type SubscriptionReclaimPolicy string

+ const SubscriptionReclaimDelete

+ const SubscriptionReclaimRetain

+ type SubscriptionSpec struct

+ ClusterRef corev1.LocalObjectReference

+ DBName string

+ ExternalClusterName string

+ Name string

+ Parameters map[string]string

+ PublicationDBName string

+ PublicationName string

+ ReclaimPolicy SubscriptionReclaimPolicy

+ func (in *SubscriptionSpec) DeepCopy() *SubscriptionSpec

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

+ type SubscriptionStatus struct

+ Applied *bool

+ Message string

+ ObservedGeneration int64

+ func (in *SubscriptionStatus) DeepCopy() *SubscriptionStatus

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

type SynchronousReplicaConfiguration

+ DataDurability DataDurabilityLevel

Feb 28, 2025

Changes in this version

+ const DefaultPostgresGID

+ const DefaultPostgresUID

+ const PoolerTypeR

+ var SchemeGroupVersion = schema.GroupVersion

type Cluster

+ func (cluster *Cluster) GetEnabledWALArchivePluginName() string

type PluginConfiguration

+ IsWALArchiver *bool

type SynchronizeReplicasConfiguration

+ func (r *SynchronizeReplicasConfiguration) ValidateRegex() []error

Dec 23, 2024

Changes in this version

+ func GetPluginConfigurationEnabledPluginNames(pluginList []PluginConfiguration) (result []string)

Aug 22, 2024

Changes in this version

+ const MissingWALDiskSpaceExitCode

+ const PhaseCannotCreateClusterObjects

+ const PhaseReplicaClusterPromotion

+ const PhaseUnknownPlugin

+ const ServiceUpdateStrategyPatch

+ const ServiceUpdateStrategyReplace

+ const SynchronousReplicaConfigurationMethodAny

+ const SynchronousReplicaConfigurationMethodFirst

type BootstrapInitDB

+ PostInitSQLRefs *SQLRefs

+ PostInitTemplateSQLRefs *SQLRefs

type Cluster

+ func (cluster *Cluster) GetServerCASecretObjectKey() types.NamespacedName

+ func (cluster *Cluster) IsMetricsTLSEnabled() bool

+ func (cluster *Cluster) IsReadOnlyServiceEnabled() bool

+ func (cluster *Cluster) IsReadServiceEnabled() bool

+ func (cluster *Cluster) IsReadWriteServiceEnabled() bool

+ func (cluster *Cluster) ShouldInitDBRunPostInitSQLRefs() bool

+ func (cluster *Cluster) ShouldInitDBRunPostInitTemplateSQLRefs() bool

+ func (cluster *Cluster) ShouldPromoteFromReplicaCluster() bool

+ type ClusterMonitoringTLSConfiguration struct

+ Enabled bool

+ func (in *ClusterMonitoringTLSConfiguration) DeepCopy() *ClusterMonitoringTLSConfiguration

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

type ClusterStatus

+ DemotionToken string

+ LastPromotionToken string

type DataBackupConfiguration

+ func (cfg *DataBackupConfiguration) AppendAdditionalCommandArgs(options []string) []string

type ManagedConfiguration

+ Services *ManagedServices

+ type ManagedService struct

+ SelectorType ServiceSelectorType

+ ServiceTemplate ServiceTemplateSpec

+ UpdateStrategy ServiceUpdateStrategy

+ func (in *ManagedService) DeepCopy() *ManagedService

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

+ type ManagedServices struct

+ Additional []ManagedService

+ DisabledDefaultServices []ServiceSelectorType

+ func (in *ManagedServices) DeepCopy() *ManagedServices

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

type Metadata

+ Name string

type MonitoringConfiguration

+ TLSConfig *ClusterMonitoringTLSConfiguration

type PluginConfigurationList

+ func (pluginList PluginConfigurationList) GetNames() (result []string)

type PluginStatus

+ Status string

type PodTopologyLabels

+ func (topologyLabels PodTopologyLabels) MatchesTopology(instanceTopology PodTopologyLabels) bool

type PostgresConfiguration

+ Synchronous *SynchronousReplicaConfiguration

type ReplicaClusterConfiguration

+ MinApplyDelay *metav1.Duration

+ Primary string

+ PromotionToken string

+ Self string

+ type SQLRefs struct

+ ConfigMapRefs []ConfigMapKeySelector

+ SecretRefs []SecretKeySelector

+ func (in *SQLRefs) DeepCopy() *SQLRefs

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

+ func (s *SQLRefs) HasElements() bool

+ type ServiceSelectorType string

+ const ServiceSelectorTypeR

+ const ServiceSelectorTypeRO

+ const ServiceSelectorTypeRW

+ type ServiceUpdateStrategy string

+ type SynchronousReplicaConfiguration struct

+ MaxStandbyNamesFromCluster *int

+ Method SynchronousReplicaConfigurationMethod

+ Number int

+ StandbyNamesPost []string

+ StandbyNamesPre []string

+ func (in *SynchronousReplicaConfiguration) DeepCopy() *SynchronousReplicaConfiguration

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

+ type SynchronousReplicaConfigurationMethod string

+ func (s SynchronousReplicaConfigurationMethod) ToPostgreSQLConfigurationKeyword() string

type WalBackupConfiguration

+ ArchiveAdditionalCommandArgs []string

+ RestoreAdditionalCommandArgs []string

+ func (cfg *WalBackupConfiguration) AppendArchiveAdditionalCommandArgs(options []string) []string

+ func (cfg *WalBackupConfiguration) AppendRestoreAdditionalCommandArgs(options []string) []string

Dec 23, 2024

Changes in this version

type ClusterSpec

+ Probes *ProbesConfiguration

+ type Probe struct

+ FailureThreshold int32

+ InitialDelaySeconds int32

+ PeriodSeconds int32

+ SuccessThreshold int32

+ TerminationGracePeriodSeconds *int64

+ TimeoutSeconds int32

+ func (in *Probe) DeepCopy() *Probe

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

+ func (p *Probe) ApplyInto(k8sProbe *corev1.Probe)

+ type ProbesConfiguration struct

+ Liveness *Probe

+ Readiness *Probe

+ Startup *Probe

+ func (in *ProbesConfiguration) DeepCopy() *ProbesConfiguration

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

Oct 16, 2024

Changes in this version

+ const PodFailed

+ const PodHealthy

+ const PodReplicating

+ func ListStatusPods(podList []corev1.Pod) map[PodStatus][]string

type Backup

+ func (backup *Backup) EnsureGVKIsPresent()

+ type PodStatus string

type RecoveryTarget

+ func (target *RecoveryTarget) GetBackupID() string

+ func (target *RecoveryTarget) GetTargetLSN() string

+ func (target *RecoveryTarget) GetTargetTLI() string

+ func (target *RecoveryTarget) GetTargetTime() string

Apr 24, 2024

Changes in this version

+ const PhaseImageCatalogError

+ var ClusterImageCatalogKind = "ClusterImageCatalog"

+ var ImageCatalogKind = "ImageCatalog"

type BackupMethod

+ const BackupMethodPlugin

+ type BackupPluginConfiguration struct

+ Name string

+ Parameters map[string]string

+ func (configuration *BackupPluginConfiguration) IsEmpty() bool

+ func (in *BackupPluginConfiguration) DeepCopy() *BackupPluginConfiguration

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

type BackupSpec

+ PluginConfiguration *BackupPluginConfiguration

+ type CatalogImage struct

+ Image string

+ Major int

+ func (in *CatalogImage) DeepCopy() *CatalogImage

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

type Cluster

+ func (cluster *Cluster) GetEnablePDB() bool

+ func (cluster *Cluster) GetPostgresqlMajorVersion() (int, error)

+ func (cluster *Cluster) GetWALPluginNames() (result []string)

+ func (cluster *Cluster) LoadPluginClient(ctx context.Context) (client.Client, error)

+ func (cluster *Cluster) LoadSelectedPluginsClient(ctx context.Context, pluginNames []string) (client.Client, error)

+ func (cluster *Cluster) SetInContext(ctx context.Context) context.Context

+ type ClusterImageCatalog struct

+ Spec ImageCatalogSpec

+ func (c *ClusterImageCatalog) GetObjectMeta() *metav1.ObjectMeta

+ func (c *ClusterImageCatalog) GetSpec() *ImageCatalogSpec

+ func (in *ClusterImageCatalog) DeepCopy() *ClusterImageCatalog

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

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

+ type ClusterImageCatalogList struct

+ Items []ClusterImageCatalog

+ func (in *ClusterImageCatalogList) DeepCopy() *ClusterImageCatalogList

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

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

type ClusterSpec

+ EnablePDB *bool

+ ImageCatalogRef *ImageCatalogRef

+ Plugins PluginConfigurationList

type ClusterStatus

+ Image string

+ PluginStatus []PluginStatus

+ SwitchReplicaClusterStatus SwitchReplicaClusterStatus

+ type GenericImageCatalog interface

+ GetObjectMeta func() *metav1.ObjectMeta

+ GetSpec func() *ImageCatalogSpec

+ type ImageCatalog struct

+ Spec ImageCatalogSpec

+ func (c *ImageCatalog) GetObjectMeta() *metav1.ObjectMeta

+ func (c *ImageCatalog) GetSpec() *ImageCatalogSpec

+ func (in *ImageCatalog) DeepCopy() *ImageCatalog

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

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

+ type ImageCatalogList struct

+ Items []ImageCatalog

+ func (in *ImageCatalogList) DeepCopy() *ImageCatalogList

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

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

+ type ImageCatalogRef struct

+ Major int

+ func (in *ImageCatalogRef) DeepCopy() *ImageCatalogRef

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

+ type ImageCatalogSpec struct

+ Images []CatalogImage

+ func (in *ImageCatalogSpec) DeepCopy() *ImageCatalogSpec

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

+ func (spec *ImageCatalogSpec) FindImageForMajor(major int) (string, bool)

+ type PluginConfiguration struct

+ Name string

+ Parameters map[string]string

+ func (in *PluginConfiguration) DeepCopy() *PluginConfiguration

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

+ type PluginConfigurationList []PluginConfiguration

+ func (in PluginConfigurationList) DeepCopy() PluginConfigurationList

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

+ type PluginStatus struct

+ BackupCapabilities []string

+ Capabilities []string

+ Name string

+ OperatorCapabilities []string

+ Version string

+ WALCapabilities []string

+ func (in *PluginStatus) DeepCopy() *PluginStatus

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

type PoolerSpec

+ ServiceTemplate *ServiceTemplateSpec

type ReplicationSlotsConfiguration

+ SynchronizeReplicas *SynchronizeReplicasConfiguration

+ func (r *ReplicationSlotsConfiguration) GetEnabled() bool

type ScheduledBackupSpec

+ PluginConfiguration *BackupPluginConfiguration

+ type ServiceTemplateSpec struct

+ ObjectMeta Metadata

+ Spec corev1.ServiceSpec

+ func (in *ServiceTemplateSpec) DeepCopy() *ServiceTemplateSpec

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

+ type SwitchReplicaClusterStatus struct

+ InProgress bool

+ func (in *SwitchReplicaClusterStatus) DeepCopy() *SwitchReplicaClusterStatus

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

+ type SynchronizeReplicasConfiguration struct

+ Enabled *bool

+ ExcludePatterns []string

+ func (in *SynchronizeReplicasConfiguration) DeepCopy() *SynchronizeReplicasConfiguration

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

+ func (r *SynchronizeReplicasConfiguration) GetEnabled() bool

+ func (r *SynchronizeReplicasConfiguration) IsExcludedByUser(slotName string) (bool, error)

Dec 21, 2023

Changes in this version

+ const TablespaceVolumeInfix

type BackupSnapshotElementStatus

+ TablespaceName string

type Cluster

+ func (cluster *Cluster) ContainsTablespaces() bool

+ func (cluster *Cluster) GetTablespaceConfiguration(name string) *TablespaceConfiguration

type ClusterSpec

+ Tablespaces []TablespaceConfiguration

type ClusterStatus

+ TablespacesStatus []TablespaceState

type DataSource

+ TablespaceStorage map[string]corev1.TypedLocalObjectReference

+ type DatabaseRoleRef struct

+ Name string

+ func (in *DatabaseRoleRef) DeepCopy() *DatabaseRoleRef

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

+ type TablespaceConfiguration struct

+ Name string

+ Owner DatabaseRoleRef

+ Storage StorageConfiguration

+ Temporary bool

+ func (in *TablespaceConfiguration) DeepCopy() *TablespaceConfiguration

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

+ type TablespaceState struct

+ Error string

+ Name string

+ Owner string

+ State TablespaceStatus

+ func (in *TablespaceState) DeepCopy() *TablespaceState

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

+ type TablespaceStatus string

+ const TablespaceStatusPendingReconciliation

+ const TablespaceStatusReconciled

type VolumeSnapshotConfiguration

+ TablespaceClassName map[string]string

Jun 12, 2024

Changes in this version

type Cluster

+ func (cluster *Cluster) GetRestartTimeout() int32

type ClusterSpec

+ LivenessProbeTimeout *int32

Mar 14, 2024

Changes in this version

+ const PhaseArchitectureBinaryMissing

+ type AvailableArchitecture struct

+ GoArch string

+ Hash string

+ func (in *AvailableArchitecture) DeepCopy() *AvailableArchitecture

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

type BarmanObjectStoreConfiguration

+ func (cfg *BarmanObjectStoreConfiguration) AppendAdditionalCommandArgs(options []string) []string

type ClusterStatus

+ AvailableArchitectures []AvailableArchitecture

+ func (status *ClusterStatus) GetAvailableArchitecture(archName string) *AvailableArchitecture

type DataBackupConfiguration

+ AdditionalCommandArgs []string

Dec 21, 2023

Changes in this version

type Cluster

+ func (cluster *Cluster) UpdateBackupTimes(backupMethod BackupMethod, firstRecoverabilityPoint *time.Time, ...)

type ClusterStatus

+ FirstRecoverabilityPointByMethod map[BackupMethod]metav1.Time

+ LastSuccessfulBackupByMethod map[BackupMethod]metav1.Time

Nov 3, 2023

Changes in this version

+ const BackupPhaseFinalizing

+ const VolumeSnapshotKind

type Backup

+ func (backup *Backup) GetVolumeSnapshotConfiguration(clusterConfig VolumeSnapshotConfiguration) VolumeSnapshotConfiguration

type BackupSpec

+ Online *bool

+ OnlineConfiguration *OnlineConfiguration

type BackupStatus

+ BackupLabelFile []byte

+ Online *bool

+ TablespaceMapFile []byte

+ func (backupStatus *BackupStatus) GetOnline() bool

+ func (backupStatus *BackupStatus) SetAsFinalizing()

+ type OnlineConfiguration struct

+ ImmediateCheckpoint *bool

+ WaitForArchive *bool

+ func (in *OnlineConfiguration) DeepCopy() *OnlineConfiguration

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

+ func (o OnlineConfiguration) GetImmediateCheckpoint() bool

+ func (o OnlineConfiguration) GetWaitForArchive() bool

type ScheduledBackupSpec

+ Online *bool

+ OnlineConfiguration *OnlineConfiguration

type VolumeSnapshotConfiguration

+ Online *bool

+ OnlineConfiguration OnlineConfiguration

+ func (configuration *VolumeSnapshotConfiguration) GetOnline() bool

Oct 11, 2023

Changes in this version

+ var BackupStartingCondition = &metav1.Condition

+ var BackupSucceededCondition = &metav1.Condition

+ var BuildClusterBackupFailedCondition = func(err error) *metav1.Condition

type Backup

+ func (backup *Backup) GetAssignedInstance(ctx context.Context, cli client.Client) (*corev1.Pod, error)

+ func (backup *Backup) IsCompletedVolumeSnapshot() bool

type BackupConfiguration

+ VolumeSnapshot *VolumeSnapshotConfiguration

type BackupList

+ func (list *BackupList) CanExecuteBackup(backupName string) bool

+ func (list *BackupList) SortByName()

+ func (list *BackupList) SortByReverseCreationTime()

+ func (list BackupList) GetPendingBackupNames() []string

+ type BackupMethod string

+ const BackupMethodBarmanObjectStore

+ const BackupMethodVolumeSnapshot

+ type BackupSnapshotElementStatus struct

+ Name string

+ Type string

+ func (in *BackupSnapshotElementStatus) DeepCopy() *BackupSnapshotElementStatus

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

+ type BackupSnapshotStatus struct

+ Elements []BackupSnapshotElementStatus

+ func (in *BackupSnapshotStatus) DeepCopy() *BackupSnapshotStatus

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

+ func (snapshotStatus *BackupSnapshotStatus) SetSnapshotElements(snapshots []volumesnapshot.VolumeSnapshot)

type BackupSpec

+ Method BackupMethod

type BackupStatus

+ BackupSnapshotStatus BackupSnapshotStatus

+ Method BackupMethod

+ func (backupStatus *BackupStatus) SetAsStarted(targetPod *corev1.Pod, method BackupMethod)

type Cluster

+ func (cluster *Cluster) GetSmartShutdownTimeout() int32

type ClusterSpec

+ SmartShutdownTimeout int32

type ScheduledBackupSpec

+ Method BackupMethod

+ type SnapshotOwnerReference string

+ const ShapshotOwnerReferenceNone

+ const SnapshotOwnerReferenceBackup

+ const SnapshotOwnerReferenceCluster

+ type VolumeSnapshotConfiguration struct

+ Annotations map[string]string

+ ClassName string

+ Labels map[string]string

+ SnapshotOwnerReference SnapshotOwnerReference

+ WalClassName string

+ func (in *VolumeSnapshotConfiguration) DeepCopy() *VolumeSnapshotConfiguration

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

Feb 2, 2024

Changes in this version

type ClusterSpec

+ EphemeralVolumeSource *corev1.EphemeralVolumeSource

type Pooler

+ func (in *Pooler) IsAutomatedIntegration() bool

type PostgresConfiguration

+ PgIdent []string

Dec 21, 2023

Changes in this version

type Cluster

+ func (cluster *Cluster) GetExternalClusterSecrets() *stringset.Data

type MonitoringConfiguration

+ PodMonitorMetricRelabelConfigs []*monitoringv1.RelabelConfig

+ PodMonitorRelabelConfigs []*monitoringv1.RelabelConfig

type PoolerMonitoringConfiguration

+ PodMonitorMetricRelabelConfigs []*monitoringv1.RelabelConfig

+ PodMonitorRelabelConfigs []*monitoringv1.RelabelConfig

type PostgresConfiguration

+ EnableAlterSystem bool

type SecretsResourceVersion

+ ExternalClusterSecretVersions map[string]string

+ func (secretResourceVersion *SecretsResourceVersion) SetExternalClusterSecretVersion(secretName string, version *string)

Jun 12, 2023

Changes in this version

type RoleConfiguration

+ DisablePassword bool

Apr 27, 2023

Changes in this version

type Cluster

+ func (cluster *Cluster) ContainsManagedRolesConfiguration() bool

+ func (cluster *Cluster) UsesSecretInManagedRoles(secretName string) bool

type ClusterSpec

+ Managed *ManagedConfiguration

type ClusterStatus

+ ManagedRolesStatus ManagedRoles

+ type EnsureOption string

+ const EnsureAbsent

+ const EnsurePresent

+ type ManagedConfiguration struct

+ Roles []RoleConfiguration

+ func (in *ManagedConfiguration) DeepCopy() *ManagedConfiguration

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

+ type ManagedRoles struct

+ ByStatus map[RoleStatus][]string

+ CannotReconcile map[string][]string

+ PasswordStatus map[string]PasswordState

+ func (in *ManagedRoles) DeepCopy() *ManagedRoles

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

+ type PasswordState struct

+ SecretResourceVersion string

+ TransactionID int64

+ func (in *PasswordState) DeepCopy() *PasswordState

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

+ type RoleConfiguration struct

+ BypassRLS bool

+ Comment string

+ ConnectionLimit int64

+ CreateDB bool

+ CreateRole bool

+ Ensure EnsureOption

+ InRoles []string

+ Inherit *bool

+ Login bool

+ Name string

+ PasswordSecret *LocalObjectReference

+ Replication bool

+ Superuser bool

+ ValidUntil *metav1.Time

+ func (in *RoleConfiguration) DeepCopy() *RoleConfiguration

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

+ func (roleConfiguration *RoleConfiguration) GetRoleInherit() bool

+ func (roleConfiguration *RoleConfiguration) GetRoleSecretsName() string

+ type RoleStatus string

+ const RoleStatusNotManaged

+ const RoleStatusPendingReconciliation

+ const RoleStatusReconciled

+ const RoleStatusReserved

type SecretsResourceVersion

+ ManagedRoleSecretVersions map[string]string

+ func (secretResourceVersion *SecretsResourceVersion) SetManagedRoleSecretVersion(secret string, version *string)

Oct 11, 2023

Changes in this version

+ const DefaultStartupDelay

+ const PhaseWaitingForInstancesToBeActive

type Cluster

+ func (cluster *Cluster) GetCoredumpFilter() string

+ func (cluster *Cluster) GetSmartStopDelay() int32

+ func (cluster *Cluster) IsInplaceRestartPhase() bool

type ClusterSpec

+ EphemeralVolumesSizeLimit *EphemeralVolumesSizeLimitConfiguration

+ SmartStopDelay int32

+ type EphemeralVolumesSizeLimitConfiguration struct

+ Shm *resource.Quantity

+ TemporaryData *resource.Quantity

+ func (e *EphemeralVolumesSizeLimitConfiguration) GetShmLimit() *resource.Quantity

+ func (e *EphemeralVolumesSizeLimitConfiguration) GetTemporaryDataLimit() *resource.Quantity

+ func (in *EphemeralVolumesSizeLimitConfiguration) DeepCopy() *EphemeralVolumesSizeLimitConfiguration

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

Jul 27, 2023

Changes in this version

type Cluster

+ func (cluster *Cluster) SetInheritedData(obj *metav1.ObjectMeta)

type ClusterSpec

+ PriorityClassName string

type Topology

+ NodesUsed int32

Mar 20, 2023

Changes in this version

type BackupSpec

+ Target BackupTarget

type ScheduledBackupSpec

+ Target BackupTarget

Feb 14, 2023

Changes in this version

+ const BackupTargetPrimary

+ const BackupTargetStandby

+ const DefaultBackupTarget

type BackupConfiguration

+ Target BackupTarget

+ type BackupTarget string

type ClusterSpec

+ FailoverDelay int32

type ClusterStatus

+ CurrentPrimaryFailingSinceTimestamp string

Jun 12, 2023

Changes in this version

type BootstrapRecovery

+ VolumeSnapshots *DataSource

type ClusterSpec

+ SchedulerName string

+ TopologySpreadConstraints []corev1.TopologySpreadConstraint

+ type DataSource struct

+ Storage corev1.TypedLocalObjectReference

+ WalStorage *corev1.TypedLocalObjectReference

+ func (in *DataSource) DeepCopy() *DataSource

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

type Import

+ SchemaOnly bool

+ type PoolerMonitoringConfiguration struct

+ EnablePodMonitor bool

+ func (in *PoolerMonitoringConfiguration) DeepCopy() *PoolerMonitoringConfiguration

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

type PoolerSpec

+ DeploymentStrategy *appsv1.DeploymentStrategy

+ Monitoring *PoolerMonitoringConfiguration

Apr 27, 2023

Changes in this version

type Cluster

+ func (cluster *Cluster) GetSeccompProfile() *corev1.SeccompProfile

type ClusterSpec

+ SeccompProfile *corev1.SeccompProfile

type ConditionReason

+ const DetachedVolume

type ReplicationSlotsHAConfiguration

+ func (r *ReplicationSlotsHAConfiguration) GetEnabled() bool

Mar 20, 2023

Changes in this version

type BackupStatus

+ BackupName string

type Cluster

+ func (cluster *Cluster) ShouldForceLegacyBackup() bool

type ClusterStatus

+ LastFailedBackup string

+ LastSuccessfulBackup string

Feb 14, 2023

Changes in this version

+ const NewWalReason

type Cluster

+ func (cluster *Cluster) ShouldCreateProjectedVolume() bool

type ClusterSpec

+ Env []corev1.EnvVar

+ EnvFrom []corev1.EnvFromSource

+ ProjectedVolumeTemplate *corev1.ProjectedVolumeSource

Dec 21, 2022

Changes in this version

type AffinityConfiguration

+ NodeAffinity *corev1.NodeAffinity

type ClusterSpec

+ ServiceAccountTemplate *ServiceAccountTemplate

+ type Metadata struct

+ Annotations map[string]string

+ Labels map[string]string

+ func (in *Metadata) DeepCopy() *Metadata

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

+ type ServiceAccountTemplate struct

+ Metadata Metadata

+ func (in *ServiceAccountTemplate) DeepCopy() *ServiceAccountTemplate

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

+ func (st *ServiceAccountTemplate) MergeMetadata(sa *corev1.ServiceAccount)

Nov 10, 2022

Changes in this version

+ const DefaultReplicationSlotsHASlotPrefix

+ const DefaultReplicationSlotsUpdateInterval

type Cluster

+ func (cluster Cluster) GetSlotNameFromInstanceName(instanceName string) string

type ClusterSpec

+ ReplicationSlots *ReplicationSlotsConfiguration

type ClusterStatus

+ InstanceNames []string

+ type ReplicationSlotsConfiguration struct

+ HighAvailability *ReplicationSlotsHAConfiguration

+ UpdateInterval int

+ func (in *ReplicationSlotsConfiguration) DeepCopy() *ReplicationSlotsConfiguration

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

+ func (r *ReplicationSlotsConfiguration) GetUpdateInterval() time.Duration

+ type ReplicationSlotsHAConfiguration struct

+ Enabled bool

+ SlotPrefix string

+ func (in *ReplicationSlotsHAConfiguration) DeepCopy() *ReplicationSlotsHAConfiguration

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

+ func (r *ReplicationSlotsHAConfiguration) GetSlotNameFromInstanceName(instanceName string) string

+ func (r *ReplicationSlotsHAConfiguration) GetSlotPrefix() string

Mar 20, 2023

Changes in this version

type PgBouncerSpec

+ PgHBA []string

Feb 14, 2023

Changes in this version

type Cluster

+ func (cluster *Cluster) SetInheritedDataAndOwnership(obj *metav1.ObjectMeta)

type StorageConfiguration

+ func (s *StorageConfiguration) GetSizeOrNil() *resource.Quantity

Dec 21, 2022

Changes in this version

+ const WalArchiveVolumeSuffix

Sep 6, 2022

Changes in this version

type BootstrapInitDB

+ PostInitApplicationSQLRefs *PostInitApplicationSQLRefs

type Cluster

+ func (cluster *Cluster) GetWalArchiveVolumeSuffix() string

+ func (cluster *Cluster) ShouldCreateWalArchiveVolume() bool

+ func (cluster *Cluster) ShouldInitDBRunPostInitApplicationSQLRefs() bool

type ClusterConditionType

+ const ConditionClusterReady

type ClusterSpec

+ WalStorage *StorageConfiguration

type ClusterStatus

+ UnusablePVC []string

type ConditionReason

+ const ClusterIsNotReady

+ const ClusterReady

+ type PostInitApplicationSQLRefs struct

+ ConfigMapRefs []ConfigMapKeySelector

+ SecretRefs []SecretKeySelector

+ func (in *PostInitApplicationSQLRefs) DeepCopy() *PostInitApplicationSQLRefs

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

Aug 12, 2022

Changes in this version

+ type BarmanCredentials struct

+ AWS *S3Credentials

+ Azure *AzureCredentials

+ Google *GoogleCredentials

+ func (crendentials BarmanCredentials) ArePopulated() bool

+ func (in *BarmanCredentials) DeepCopy() *BarmanCredentials

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

type ClusterStatus

+ InstancesReportedState map[PodName]InstanceReportedState

+ TimelineID int

+ type InstanceReportedState struct

+ IsPrimary bool

+ TimeLineID int

+ func (in *InstanceReportedState) DeepCopy() *InstanceReportedState

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

Jul 7, 2022

Changes in this version

+ const DefaultApplicationDatabaseName

+ const DefaultApplicationUserName

+ const PGBouncerPoolerUserName

type AzureCredentials

+ InheritFromAzureAD bool

type BootstrapInitDB

+ Import *Import

type BootstrapPgBaseBackup

+ Database string

+ Owner string

+ Secret *LocalObjectReference

type BootstrapRecovery

+ Database string

+ Owner string

+ Secret *LocalObjectReference

type Cluster

+ func (cluster *Cluster) GetApplicationDatabaseName() string

+ func (cluster *Cluster) GetApplicationDatabaseOwner() string

+ func (cluster *Cluster) GetSyncReplicasData() (syncReplicas int, electableSyncReplicas []string)

+ func (cluster *Cluster) ShouldCreateApplicationSecret() bool

+ func (cluster *Cluster) ShouldInitDBCreateApplicationDatabase() bool

+ func (cluster *Cluster) ShouldInitDBCreateApplicationSecret() bool

+ func (cluster *Cluster) ShouldPgBaseBackupCreateApplicationDatabase() bool

+ func (cluster *Cluster) ShouldPgBaseBackupCreateApplicationSecret() bool

+ func (cluster *Cluster) ShouldRecoveryCreateApplicationDatabase() bool

+ func (cluster *Cluster) ShouldRecoveryCreateApplicationSecret() bool

type ClusterStatus

+ Topology Topology

type ConditionReason

+ const ConditionBackupStarted

+ type Import struct

+ Databases []string

+ PostImportApplicationSQL []string

+ Roles []string

+ Source ImportSource

+ Type SnapshotType

+ func (in *Import) DeepCopy() *Import

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

+ type ImportSource struct

+ ExternalCluster string

+ func (in *ImportSource) DeepCopy() *ImportSource

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

+ type PodName string

+ type PodTopologyLabels map[string]string

+ func (in PodTopologyLabels) DeepCopy() PodTopologyLabels

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

type PostgresConfiguration

+ SyncReplicaElectionConstraint SyncReplicaElectionConstraints

type S3Credentials

+ RegionReference *SecretKeySelector

+ type SnapshotType string

+ const MicroserviceSnapshotType

+ const MonolithSnapshotType

+ type SyncReplicaElectionConstraints struct

+ Enabled bool

+ NodeLabelsAntiAffinity []string

+ func (in *SyncReplicaElectionConstraints) DeepCopy() *SyncReplicaElectionConstraints

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

+ type Topology struct

+ Instances map[PodName]PodTopologyLabels

+ SuccessfullyExtracted bool

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

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

Oct 6, 2022

Changes in this version

+ type ConditionReason string

+ const ConditionReasonContinuousArchivingFailing

+ const ConditionReasonContinuousArchivingSuccess

+ const ConditionReasonLastBackupFailed

+ const ConditionReasonLastBackupSucceeded

Aug 12, 2022

Changes in this version

type Cluster

+ func (cluster *Cluster) LogTimestampsWithMessage(ctx context.Context, logMessage string)

Jul 7, 2022

Changes in this version

type RecoveryTarget

+ BackupID string

May 27, 2022

Changes in this version

type BackupConfiguration

+ func (backupConfiguration *BackupConfiguration) IsBarmanBackupConfigured() bool

type ScheduledBackupSpec

+ BackupOwnerReference string

Apr 21, 2022

Changes in this version

+ const ApplicationUserSecretSuffix

+ const BackupPhaseCompleted

+ const BackupPhaseFailed

+ const BackupPhasePending

+ const BackupPhaseRunning

+ const BackupPhaseStarted

+ const BackupPhaseWalArchivingFailing

+ const ClientCaSecretSuffix

+ const ClusterSecretSuffix

+ const CompressionTypeBzip2

+ const CompressionTypeGzip

+ const CompressionTypeNone

+ const CompressionTypeSnappy

+ const DefaultMaxSwitchoverDelay

+ const DefaultMonitoringConfigMapName

+ const DefaultMonitoringKey

+ const DefaultMonitoringSecretName

+ const DefaultPgBouncerPoolerAuthQuery

+ const DefaultPgBouncerPoolerSecretSuffix

+ const DefaultPgCtlTimeoutForPromotion

+ const DefaultServerCaSecretSuffix

+ const EncryptionTypeAES256

+ const EncryptionTypeNone

+ const EncryptionTypeNoneAWSKMS

+ const KubernetesUpgradeStrategyAllocateSpace

+ const KubernetesUpgradeStrategyWaitForNode

+ const PendingFailoverMarker

+ const PgBouncerPoolModeSession

+ const PgBouncerPoolModeTransaction

+ const PhaseApplyingConfiguration

+ const PhaseCreatingReplica

+ const PhaseFailOver

+ const PhaseFirstPrimary

+ const PhaseHealthy

+ const PhaseInplaceDeletePrimaryRestart

+ const PhaseInplacePrimaryRestart

+ const PhaseOnlineUpgrading

+ const PhaseSwitchover

+ const PhaseUnrecoverable

+ const PhaseUpgrade

+ const PhaseWaitingForUser

+ const PodAntiAffinityTypePreferred

+ const PodAntiAffinityTypeRequired

+ const PoolerTypeRO

+ const PoolerTypeRW

+ const PrimaryPodDisruptionBudgetSuffix

+ const PrimaryUpdateMethodRestart

+ const PrimaryUpdateMethodSwitchover

+ const PrimaryUpdateStrategySupervised

+ const PrimaryUpdateStrategyUnsupervised

+ const ReplicationSecretSuffix

+ const ServerSecretSuffix

+ const ServiceAnySuffix

+ const ServiceReadOnlySuffix

+ const ServiceReadSuffix

+ const ServiceReadWriteSuffix

+ const StreamingReplicationUser

+ const SuperUserSecretSuffix

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var AllowedPgbouncerGenericConfigurationParameters = stringset.From([]string{ ... })

+ var BackupKind = "Backup"

+ var ClusterGVK = schema.GroupVersionResource

+ var ClusterKind = "Cluster"

+ var GroupVersion = schema.GroupVersion

+ var PoolerGVK = schema.GroupVersionResource

+ var PoolerKind = "Pooler"

+ var SchemeBuilder = &scheme.Builder

+ func ConfigMapKeySelectorToCore(selector *ConfigMapKeySelector) *corev1.ConfigMapKeySelector

+ func SecretKeySelectorToCore(selector *SecretKeySelector) *corev1.SecretKeySelector

+ type AffinityConfiguration struct

+ AdditionalPodAffinity *corev1.PodAffinity

+ AdditionalPodAntiAffinity *corev1.PodAntiAffinity

+ EnablePodAntiAffinity *bool

+ NodeSelector map[string]string

+ PodAntiAffinityType string

+ Tolerations []corev1.Toleration

+ TopologyKey string

+ func (in *AffinityConfiguration) DeepCopy() *AffinityConfiguration

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

+ type AzureCredentials struct

+ ConnectionString *SecretKeySelector

+ StorageAccount *SecretKeySelector

+ StorageKey *SecretKeySelector

+ StorageSasToken *SecretKeySelector

+ func (in *AzureCredentials) DeepCopy() *AzureCredentials

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

+ type Backup struct

+ Spec BackupSpec

+ Status BackupStatus

+ func (backup *Backup) GetKubernetesObject() client.Object

+ func (backup *Backup) GetMetadata() *metav1.ObjectMeta

+ func (backup *Backup) GetName() string

+ func (backup *Backup) GetNamespace() string

+ func (backup *Backup) GetStatus() *BackupStatus

+ func (in *Backup) DeepCopy() *Backup

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

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

+ func (r *Backup) Default()

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

+ func (r *Backup) ValidateCreate() error

+ func (r *Backup) ValidateDelete() error

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

+ type BackupConfiguration struct

+ BarmanObjectStore *BarmanObjectStoreConfiguration

+ RetentionPolicy string

+ func (backupConfiguration *BackupConfiguration) IsBarmanEndpointCASet() bool

+ func (in *BackupConfiguration) DeepCopy() *BackupConfiguration

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

+ type BackupList struct

+ Items []Backup

+ func (in *BackupList) DeepCopy() *BackupList

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

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

+ type BackupPhase string

+ type BackupSource struct

+ EndpointCA *SecretKeySelector

+ func (in *BackupSource) DeepCopy() *BackupSource

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

+ type BackupSpec struct

+ Cluster LocalObjectReference

+ func (in *BackupSpec) DeepCopy() *BackupSpec

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

+ type BackupStatus struct

+ AzureCredentials *AzureCredentials

+ BackupID string

+ BeginLSN string

+ BeginWal string

+ CommandError string

+ CommandOutput string

+ DestinationPath string

+ Encryption string

+ EndLSN string

+ EndWal string

+ EndpointCA *SecretKeySelector

+ EndpointURL string

+ Error string

+ GoogleCredentials *GoogleCredentials

+ InstanceID *InstanceID

+ Phase BackupPhase

+ S3Credentials *S3Credentials

+ ServerName string

+ StartedAt *metav1.Time

+ StoppedAt *metav1.Time

+ func (backupStatus *BackupStatus) IsDone() bool

+ func (backupStatus *BackupStatus) IsInProgress() bool

+ func (backupStatus *BackupStatus) SetAsCompleted()

+ func (backupStatus *BackupStatus) SetAsFailed(err error)

+ func (in *BackupStatus) DeepCopy() *BackupStatus

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

+ type BarmanObjectStoreConfiguration struct

+ AzureCredentials *AzureCredentials

+ Data *DataBackupConfiguration

+ DestinationPath string

+ EndpointCA *SecretKeySelector

+ EndpointURL string

+ GoogleCredentials *GoogleCredentials

+ HistoryTags map[string]string

+ S3Credentials *S3Credentials

+ ServerName string

+ Tags map[string]string

+ Wal *WalBackupConfiguration

+ func (in *BarmanObjectStoreConfiguration) DeepCopy() *BarmanObjectStoreConfiguration

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

+ type BootstrapConfiguration struct

+ InitDB *BootstrapInitDB

+ PgBaseBackup *BootstrapPgBaseBackup

+ Recovery *BootstrapRecovery

+ func (in *BootstrapConfiguration) DeepCopy() *BootstrapConfiguration

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

+ type BootstrapInitDB struct

+ DataChecksums *bool

+ Database string

+ Encoding string

+ LocaleCType string

+ LocaleCollate string

+ Options []string

+ Owner string

+ PostInitApplicationSQL []string

+ PostInitSQL []string

+ PostInitTemplateSQL []string

+ Secret *LocalObjectReference

+ WalSegmentSize int

+ func (in *BootstrapInitDB) DeepCopy() *BootstrapInitDB

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

+ type BootstrapPgBaseBackup struct

+ Source string

+ func (in *BootstrapPgBaseBackup) DeepCopy() *BootstrapPgBaseBackup

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

+ type BootstrapRecovery struct

+ Backup *BackupSource

+ RecoveryTarget *RecoveryTarget

+ Source string

+ func (in *BootstrapRecovery) DeepCopy() *BootstrapRecovery

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

+ type CertificatesConfiguration struct

+ ClientCASecret string

+ ReplicationTLSSecret string

+ ServerAltDNSNames []string

+ ServerCASecret string

+ ServerTLSSecret string

+ func (in *CertificatesConfiguration) DeepCopy() *CertificatesConfiguration

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

+ type CertificatesStatus struct

+ Expirations map[string]string

+ func (in *CertificatesStatus) DeepCopy() *CertificatesStatus

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

+ type Cluster struct

+ Spec ClusterSpec

+ Status ClusterStatus

+ func (cluster *Cluster) GetApplicationSecretName() string

+ func (cluster *Cluster) GetClientCASecretName() string

+ func (cluster *Cluster) GetClusterAltDNSNames() []string

+ func (cluster *Cluster) GetEnableLDAPAuth() bool

+ func (cluster *Cluster) GetEnableSuperuserAccess() bool

+ func (cluster *Cluster) GetFixedInheritedAnnotations() map[string]string

+ func (cluster *Cluster) GetFixedInheritedLabels() map[string]string

+ func (cluster *Cluster) GetImageName() string

+ func (cluster *Cluster) GetImagePullSecret() string

+ func (cluster *Cluster) GetLDAPSecretName() string

+ func (cluster *Cluster) GetMaxStartDelay() int32

+ func (cluster *Cluster) GetMaxStopDelay() int32

+ func (cluster *Cluster) GetMaxSwitchoverDelay() int32

+ func (cluster *Cluster) GetPgCtlTimeoutForPromotion() int32

+ func (cluster *Cluster) GetPostgresqlVersion() (int, error)

+ func (cluster *Cluster) GetPrimaryUpdateMethod() PrimaryUpdateMethod

+ func (cluster *Cluster) GetPrimaryUpdateStrategy() PrimaryUpdateStrategy

+ func (cluster *Cluster) GetReplicationSecretName() string

+ func (cluster *Cluster) GetServerCASecretName() string

+ func (cluster *Cluster) GetServerTLSSecretName() string

+ func (cluster *Cluster) GetServiceAnyName() string

+ func (cluster *Cluster) GetServiceReadName() string

+ func (cluster *Cluster) GetServiceReadOnlyName() string

+ func (cluster *Cluster) GetServiceReadWriteName() string

+ func (cluster *Cluster) GetSuperuserSecretName() string

+ func (cluster *Cluster) GetSyncReplicasNumber() (syncReplicas int)

+ func (cluster *Cluster) IsInstanceFenced(instance string) bool

+ func (cluster *Cluster) IsNodeMaintenanceWindowInProgress() bool

+ func (cluster *Cluster) IsPodMonitorEnabled() bool

+ func (cluster *Cluster) IsReusePVCEnabled() bool

+ func (cluster *Cluster) ShouldResizeInUseVolumes() bool

+ func (cluster *Cluster) UsesConfigMap(config string) (ok bool)

+ func (cluster *Cluster) UsesSecret(secret string) bool

+ func (cluster Cluster) ExternalCluster(name string) (ExternalCluster, bool)

+ func (cluster Cluster) GetBarmanEndpointCAForReplicaCluster() *SecretKeySelector

+ func (cluster Cluster) GetPostgresGID() int64

+ func (cluster Cluster) GetPostgresUID() int64

+ func (cluster Cluster) IsReplica() bool

+ func (cluster Cluster) ShouldCreateApplicationDatabase() bool

+ func (in *Cluster) DeepCopy() *Cluster

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

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

+ func (r *Cluster) Default()

+ func (r *Cluster) SetDefaults()

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

+ func (r *Cluster) Validate() (allErrs field.ErrorList)

+ func (r *Cluster) ValidateChanges(old *Cluster) (allErrs field.ErrorList)

+ func (r *Cluster) ValidateCreate() error

+ func (r *Cluster) ValidateDelete() error

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

+ type ClusterCondition struct

+ LastTransitionTime *metav1.Time

+ Message string

+ Reason string

+ Status ConditionStatus

+ Type ClusterConditionType

+ func (in *ClusterCondition) DeepCopy() *ClusterCondition

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

+ type ClusterConditionType string

+ const ConditionBackup

+ const ConditionContinuousArchiving

+ type ClusterList struct

+ Items []Cluster

+ func (in *ClusterList) DeepCopy() *ClusterList

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

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

+ type ClusterSpec struct

+ Affinity AffinityConfiguration

+ Backup *BackupConfiguration

+ Bootstrap *BootstrapConfiguration

+ Certificates *CertificatesConfiguration

+ Description string

+ EnableSuperuserAccess *bool

+ ExternalClusters []ExternalCluster

+ ImageName string

+ ImagePullPolicy corev1.PullPolicy

+ ImagePullSecrets []LocalObjectReference

+ InheritedMetadata *EmbeddedObjectMetadata

+ Instances int32

+ LogLevel string

+ MaxStartDelay int32

+ MaxStopDelay int32

+ MaxSwitchoverDelay int32

+ MaxSyncReplicas int32

+ MinSyncReplicas int32

+ Monitoring *MonitoringConfiguration

+ NodeMaintenanceWindow *NodeMaintenanceWindow

+ PostgresConfiguration PostgresConfiguration

+ PostgresGID int64

+ PostgresUID int64

+ PrimaryUpdateMethod PrimaryUpdateMethod

+ PrimaryUpdateStrategy PrimaryUpdateStrategy

+ ReplicaCluster *ReplicaClusterConfiguration

+ Resources corev1.ResourceRequirements

+ StorageConfiguration StorageConfiguration

+ SuperuserSecret *LocalObjectReference

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

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

+ type ClusterStatus struct

+ AzurePVCUpdateEnabled bool

+ Certificates CertificatesStatus

+ CommitHash string

+ Conditions []ClusterCondition

+ ConfigMapResourceVersion ConfigMapResourceVersion

+ CurrentPrimary string

+ CurrentPrimaryTimestamp string

+ DanglingPVC []string

+ FirstRecoverabilityPoint string

+ HealthyPVC []string

+ InitializingPVC []string

+ Instances int32

+ InstancesStatus map[utils.PodStatus][]string

+ JobCount int32

+ LatestGeneratedNode int32

+ OnlineUpdateEnabled bool

+ OperatorHash string

+ PVCCount int32

+ Phase string

+ PhaseReason string

+ PoolerIntegrations *PoolerIntegrations

+ ReadService string

+ ReadyInstances int32

+ ResizingPVC []string

+ SecretsResourceVersion SecretsResourceVersion

+ TargetPrimary string

+ TargetPrimaryTimestamp string

+ WriteService string

+ func (in *ClusterStatus) DeepCopy() *ClusterStatus

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

+ type CompressionType string

+ type ConditionStatus string

+ const ConditionFalse

+ const ConditionTrue

+ const ConditionUnknown

+ type ConfigMapKeySelector struct

+ Key string

+ func (in *ConfigMapKeySelector) DeepCopy() *ConfigMapKeySelector

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

+ type ConfigMapResourceVersion struct

+ Metrics map[string]string

+ func (in *ConfigMapResourceVersion) DeepCopy() *ConfigMapResourceVersion

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

+ type DataBackupConfiguration struct

+ Compression CompressionType

+ Encryption EncryptionType

+ ImmediateCheckpoint bool

+ Jobs *int32

+ func (in *DataBackupConfiguration) DeepCopy() *DataBackupConfiguration

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

+ type EmbeddedObjectMetadata struct

+ Annotations map[string]string

+ Labels map[string]string

+ func (in *EmbeddedObjectMetadata) DeepCopy() *EmbeddedObjectMetadata

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

+ type EncryptionType string

+ type ExternalCluster struct

+ BarmanObjectStore *BarmanObjectStoreConfiguration

+ ConnectionParameters map[string]string

+ Name string

+ Password *corev1.SecretKeySelector

+ SSLCert *corev1.SecretKeySelector

+ SSLKey *corev1.SecretKeySelector

+ SSLRootCert *corev1.SecretKeySelector

+ func (in *ExternalCluster) DeepCopy() *ExternalCluster

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

+ func (in ExternalCluster) GetServerName() string

+ type GoogleCredentials struct

+ ApplicationCredentials *SecretKeySelector

+ GKEEnvironment bool

+ func (in *GoogleCredentials) DeepCopy() *GoogleCredentials

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

+ type InstanceID struct

+ ContainerID string

+ PodName string

+ func (in *InstanceID) DeepCopy() *InstanceID

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

+ type KubernetesUpgradeStrategy string

+ type LDAPBindAsAuth struct

+ Prefix string

+ Suffix string

+ func (in *LDAPBindAsAuth) DeepCopy() *LDAPBindAsAuth

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

+ type LDAPBindSearchAuth struct

+ BaseDN string

+ BindDN string

+ BindPassword *corev1.SecretKeySelector

+ SearchAttribute string

+ SearchFilter string

+ func (in *LDAPBindSearchAuth) DeepCopy() *LDAPBindSearchAuth

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

+ type LDAPConfig struct

+ BindAsAuth *LDAPBindAsAuth

+ BindSearchAuth *LDAPBindSearchAuth

+ Port int

+ Scheme LDAPScheme

+ Server string

+ TLS bool

+ func (in *LDAPConfig) DeepCopy() *LDAPConfig

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

+ type LDAPScheme string

+ const LDAPSchemeLDAP

+ const LDAPSchemeLDAPS

+ type LocalObjectReference struct

+ Name string

+ func (in *LocalObjectReference) DeepCopy() *LocalObjectReference

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

+ type MonitoringConfiguration struct

+ CustomQueriesConfigMap []ConfigMapKeySelector

+ CustomQueriesSecret []SecretKeySelector

+ DisableDefaultQueries *bool

+ EnablePodMonitor bool

+ func (in *MonitoringConfiguration) DeepCopy() *MonitoringConfiguration

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

+ func (m *MonitoringConfiguration) AreDefaultQueriesDisabled() bool

+ type NodeMaintenanceWindow struct

+ InProgress bool

+ ReusePVC *bool

+ func (in *NodeMaintenanceWindow) DeepCopy() *NodeMaintenanceWindow

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

+ type PgBouncerIntegrationStatus struct

+ Secrets []string

+ func (in *PgBouncerIntegrationStatus) DeepCopy() *PgBouncerIntegrationStatus

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

+ type PgBouncerPoolMode string

+ type PgBouncerSecrets struct

+ AuthQuery SecretVersion

+ func (in *PgBouncerSecrets) DeepCopy() *PgBouncerSecrets

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

+ type PgBouncerSpec struct

+ AuthQuery string

+ AuthQuerySecret *LocalObjectReference

+ Parameters map[string]string

+ Paused *bool

+ PoolMode PgBouncerPoolMode

+ func (in *PgBouncerSpec) DeepCopy() *PgBouncerSpec

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

+ func (in PgBouncerSpec) IsPaused() bool

+ type PodMeta struct

+ Annotations map[string]string

+ Labels map[string]string

+ func (in *PodMeta) DeepCopy() *PodMeta

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

+ type PodTemplateSpec struct

+ ObjectMeta PodMeta

+ Spec corev1.PodSpec

+ func (in *PodTemplateSpec) DeepCopy() *PodTemplateSpec

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

+ type Pooler struct

+ Spec PoolerSpec

+ Status PoolerStatus

+ func (in *Pooler) DeepCopy() *Pooler

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

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

+ func (in *Pooler) GetAuthQuery() string

+ func (in *Pooler) GetAuthQuerySecretName() string

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

+ func (r *Pooler) Validate() (allErrs field.ErrorList)

+ func (r *Pooler) ValidateCreate() error

+ func (r *Pooler) ValidateDelete() error

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

+ type PoolerIntegrations struct

+ PgBouncerIntegration PgBouncerIntegrationStatus

+ func (in *PoolerIntegrations) DeepCopy() *PoolerIntegrations

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

+ type PoolerList struct

+ Items []Pooler

+ func (in *PoolerList) DeepCopy() *PoolerList

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

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

+ type PoolerSecrets struct

+ ClientCA SecretVersion

+ PgBouncerSecrets *PgBouncerSecrets

+ ServerCA SecretVersion

+ ServerTLS SecretVersion

+ func (in *PoolerSecrets) DeepCopy() *PoolerSecrets

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

+ type PoolerSpec struct

+ Cluster LocalObjectReference

+ Instances int32

+ PgBouncer *PgBouncerSpec

+ Template *PodTemplateSpec

+ Type PoolerType

+ func (in *PoolerSpec) DeepCopy() *PoolerSpec

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

+ type PoolerStatus struct

+ Instances int32

+ Secrets *PoolerSecrets

+ func (in *PoolerStatus) DeepCopy() *PoolerStatus

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

+ type PoolerType string

+ type PostgresConfiguration struct

+ AdditionalLibraries []string

+ LDAP *LDAPConfig

+ Parameters map[string]string

+ PgCtlTimeoutForPromotion int32

+ PgHBA []string

+ func (in *PostgresConfiguration) DeepCopy() *PostgresConfiguration

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

+ type PrimaryUpdateMethod string

+ type PrimaryUpdateStrategy string

+ type RecoveryTarget struct

+ Exclusive *bool

+ TargetImmediate *bool

+ TargetLSN string

+ TargetName string

+ TargetTLI string

+ TargetTime string

+ TargetXID string

+ func (in *RecoveryTarget) DeepCopy() *RecoveryTarget

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

+ func (target RecoveryTarget) BuildPostgresOptions() string

+ type ReplicaClusterConfiguration struct

+ Enabled bool

+ Source string

+ func (in *ReplicaClusterConfiguration) DeepCopy() *ReplicaClusterConfiguration

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

+ type RollingUpdateStatus struct

+ ImageName string

+ StartedAt metav1.Time

+ func (in *RollingUpdateStatus) DeepCopy() *RollingUpdateStatus

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

+ type S3Credentials struct

+ AccessKeyIDReference *SecretKeySelector

+ InheritFromIAMRole bool

+ SecretAccessKeyReference *SecretKeySelector

+ SessionToken *SecretKeySelector

+ func (in *S3Credentials) DeepCopy() *S3Credentials

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

+ type ScheduledBackup struct

+ Spec ScheduledBackupSpec

+ Status ScheduledBackupStatus

+ func (in *ScheduledBackup) DeepCopy() *ScheduledBackup

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

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

+ func (r *ScheduledBackup) Default()

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

+ func (r *ScheduledBackup) ValidateCreate() error

+ func (r *ScheduledBackup) ValidateDelete() error

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

+ func (scheduledBackup *ScheduledBackup) CreateBackup(name string) *Backup

+ func (scheduledBackup *ScheduledBackup) GetKubernetesObject() client.Object

+ func (scheduledBackup *ScheduledBackup) GetName() string

+ func (scheduledBackup *ScheduledBackup) GetNamespace() string

+ func (scheduledBackup *ScheduledBackup) GetSchedule() string

+ func (scheduledBackup *ScheduledBackup) GetStatus() *ScheduledBackupStatus

+ func (scheduledBackup ScheduledBackup) IsImmediate() bool

+ func (scheduledBackup ScheduledBackup) IsSuspended() bool

+ type ScheduledBackupList struct

+ Items []ScheduledBackup

+ func (in *ScheduledBackupList) DeepCopy() *ScheduledBackupList

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

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

+ type ScheduledBackupSpec struct

+ Cluster LocalObjectReference

+ Immediate *bool

+ Schedule string

+ Suspend *bool

+ func (in *ScheduledBackupSpec) DeepCopy() *ScheduledBackupSpec

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

+ type ScheduledBackupStatus struct

+ LastCheckTime *metav1.Time

+ LastScheduleTime *metav1.Time

+ NextScheduleTime *metav1.Time

+ func (in *ScheduledBackupStatus) DeepCopy() *ScheduledBackupStatus

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

+ type SecretKeySelector struct

+ Key string

+ func (in *SecretKeySelector) DeepCopy() *SecretKeySelector

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

+ type SecretVersion struct

+ Name string

+ Version string

+ func (in *SecretVersion) DeepCopy() *SecretVersion

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

+ type SecretsResourceVersion struct

+ ApplicationSecretVersion string

+ BarmanEndpointCA string

+ CASecretVersion string

+ ClientCASecretVersion string

+ Metrics map[string]string

+ ReplicationSecretVersion string

+ ServerCASecretVersion string

+ ServerSecretVersion string

+ SuperuserSecretVersion string

+ func (in *SecretsResourceVersion) DeepCopy() *SecretsResourceVersion

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

+ type StorageConfiguration struct

+ PersistentVolumeClaimTemplate *corev1.PersistentVolumeClaimSpec

+ ResizeInUseVolumes *bool

+ Size string

+ StorageClass *string

+ func (in *StorageConfiguration) DeepCopy() *StorageConfiguration

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

+ type WalBackupConfiguration struct

+ Compression CompressionType

+ Encryption EncryptionType

+ MaxParallel int

+ func (in *WalBackupConfiguration) DeepCopy() *WalBackupConfiguration

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