Versions in this module Expand all Collapse all v1 v1.6.0 May 16, 2024 v1.5.1 Jan 25, 2024 v1.5.0 Dec 11, 2023 v1.4.0 Mar 31, 2023 v1.3.0 Aug 4, 2022 v1.2.0 Apr 6, 2022 v1.1.0 Dec 7, 2021 v1.0.0 Oct 1, 2021 v0 v0.2.0 Aug 23, 2021 Changes in this version type DCS + func (d *DCS) GetClusterDCSConfig() (*DCSConfig, goyaml.MapSlice, error) type LocalDB + func (l *LocalDB) GetLocalConfigFromCluster(configName string) (*LocalDBConfig, error) v0.1.0 May 4, 2021 Changes in this version + const PGHADCSConfigName + var ErrMissingClusterConfig error = errors.New("Configuration is missing from configMap") + var PGHALocalConfigName = "%s-local-config" + func GetLocalDBConfigNames(kubeclientset kubernetes.Interface, clusterName, namespace string) ([]string, error) + func PatchConfigMapData(kubeclientset kubernetes.Interface, configMap *corev1.ConfigMap, ...) error + type Callbacks struct + OnReload string + OnRestart string + OnRoleChange string + OnStart string + OnStop string + type CreateReplicaMethod struct + Command string + KeepData bool + NoMaster int + NoParams bool + type DCS struct + func NewDCS(configMap *corev1.ConfigMap, kubeclientset kubernetes.Interface, ...) *DCS + func (d *DCS) GetDCSConfig() (*DCSConfig, map[string]json.RawMessage, error) + func (d *DCS) Sync() error + func (d *DCS) Update(dcsConfig *DCSConfig) error + type DCSConfig struct + LoopWait int + MasterStartTimeout int + MaximumLagOnFailover int + PostgreSQL *PostgresDCS + RetryTimeout int + Slots map[string]SlotDCS + StandbyCluster *StandbyDCS + SynchronousMode bool + SynchronousModeStrict bool + TTL int + type LocalDB struct + func NewLocalDB(configMap *corev1.ConfigMap, restConfig *rest.Config, ...) (*LocalDB, error) + func (l *LocalDB) Sync() error + func (l *LocalDB) Update(configName string, localDBConfig LocalDBConfig) error + type LocalDBConfig struct + PostgreSQL PostgresLocalDB + type PostgresDCS struct + Parameters map[string]interface{} + RecoveryConf map[string]interface{} + UsePGRewind bool + UseSlots bool + type PostgresLocalDB struct + Authentication map[string]interface{} + Callbacks *Callbacks + ConfigDir string + CreateReplicaMethods []string + CustomConf map[string]interface{} + PGBackRest *CreateReplicaMethod + PGBackRestStandby *CreateReplicaMethod + PGCTLTimeout int + PGHBA []string + PGIdent []string + PGPass string + Parameters map[string]interface{} + RecoveryConf map[string]interface{} + RemoveDataDirectoryOnDivergedTimelines bool + RemoveDataDirectoryOnRewindFailure bool + UsePGRewind bool + UseUnixSocket bool + type SlotDCS struct + Database string + Plugin string + Type string + type StandbyDCS struct + ArchiveCleanupCommand string + CreateReplicaMethods []string + Host string + Port int + PrimarySlotName map[string]interface{} + RecoveryMinApplyDelay int + RestoreCommand string + type Syncer interface + Sync func() error