cluster

package

Go to main page

Versions in this module

v0

v0.16.8

May 12, 2021

v0.16.7

Apr 1, 2021

Changes in this version

+ const DefaultAutomaticPgRestart

+ const DefaultProxyTimeout

type ClusterSpec

+ AutomaticPgRestart *bool

+ DBWaitReadyTimeout *Duration

+ ProxyCheckInterval *Duration

+ ProxyTimeout *Duration

type KeeperInfo

+ CanBeMaster *bool

+ CanBeSynchronousReplica *bool

type KeeperStatus

+ CanBeMaster *bool

+ CanBeSynchronousReplica *bool

type ProxyInfo

+ ProxyTimeout time.Duration

v0.13.0

Sep 17, 2018

Changes in this version

type ClusterSpec

+ StandbyConfig *StandbyConfig

type FollowConfig

+ ArchiveRecoverySettings *ArchiveRecoverySettings

type KeeperStatus

+ ForceFail bool

+ type StandbyConfig struct

+ ArchiveRecoverySettings *ArchiveRecoverySettings

+ StandbySettings *StandbySettings

v0.12.0

Jul 3, 2018

Changes in this version

type DBStatus

+ CurSynchronousStandbys []string

type KeeperInfo

+ PostgresBinaryVersion PostgresBinaryVersion

type KeeperStatus

+ PostgresBinaryVersion PostgresBinaryVersion

+ type PostgresBinaryVersion struct

+ Maj int

+ Min int

v0.11.0

Jun 8, 2018

Changes in this version

+ const CurrentCDFormatVersion

+ const DefaultAdditionalWalSenders

+ const DefaultConvergenceTimeout

+ const DefaultDBNotIncreasingXLogPosTimes

+ const DefaultDBWaitReadyTimeout

+ const DefaultDeadKeeperRemovalInterval

+ const DefaultFailInterval

+ const DefaultInitTimeout

+ const DefaultMaxStandbyLag

+ const DefaultMaxStandbys

+ const DefaultMaxStandbysPerSender

+ const DefaultMaxSynchronousStandbys

+ const DefaultMergePGParameter

+ const DefaultMinSynchronousStandbys

+ const DefaultProxyCheckInterval

+ const DefaultProxyTimeoutInterval

+ const DefaultRequestTimeout

+ const DefaultRole

+ const DefaultSUReplAccess

+ const DefaultSleepInterval

+ const DefaultStoreTimeout

+ const DefaultSyncTimeout

+ const DefaultSynchronousReplication

+ const DefaultUsePgrewind

+ const InitialGeneration

+ const NoGeneration

+ func BoolP(b bool) *bool

+ func Uint16P(u uint16) *uint16

+ func Uint32P(u uint32) *uint32

+ type ArchiveRecoverySettings struct

+ RestoreCommand string

+ type Cluster struct

+ ChangeTime time.Time

+ Generation int64

+ Spec *ClusterSpec

+ Status ClusterStatus

+ UID string

+ func NewCluster(uid string, cs *ClusterSpec) *Cluster

+ func (c *Cluster) DeepCopy() *Cluster

+ func (c *Cluster) DefSpec() *ClusterSpec

+ func (c *Cluster) UpdateSpec(ns *ClusterSpec) error

+ type ClusterData struct

+ ChangeTime time.Time

+ Cluster *Cluster

+ DBs DBs

+ FormatVersion uint64

+ Keepers Keepers

+ Proxy *Proxy

+ func NewClusterData(c *Cluster) *ClusterData

+ func (c *ClusterData) DeepCopy() *ClusterData

+ func (cd *ClusterData) FindDB(keeper *Keeper) *DB

+ type ClusterInitMode string

+ const ClusterInitModeExisting

+ const ClusterInitModeNew

+ const ClusterInitModePITR

+ func ClusterInitModeP(s ClusterInitMode) *ClusterInitMode

+ type ClusterPhase string

+ const ClusterPhaseInitializing

+ const ClusterPhaseNormal

+ type ClusterRole string

+ const ClusterRoleMaster

+ const ClusterRoleStandby

+ func ClusterRoleP(s ClusterRole) *ClusterRole

+ type ClusterSpec struct

+ AdditionalMasterReplicationSlots []string

+ AdditionalWalSenders *uint16

+ ConvergenceTimeout *Duration

+ DeadKeeperRemovalInterval *Duration

+ DefaultSUReplAccessMode *SUReplAccessMode

+ ExistingConfig *ExistingConfig

+ FailInterval *Duration

+ InitMode *ClusterInitMode

+ InitTimeout *Duration

+ MaxStandbyLag *uint32

+ MaxStandbys *uint16

+ MaxStandbysPerSender *uint16

+ MaxSynchronousStandbys *uint16

+ MergePgParameters *bool

+ MinSynchronousStandbys *uint16

+ NewConfig *NewConfig

+ PGHBA []string

+ PGParameters PGParameters

+ PITRConfig *PITRConfig

+ RequestTimeout *Duration

+ Role *ClusterRole

+ SleepInterval *Duration

+ StandbySettings *StandbySettings

+ SyncTimeout *Duration

+ SynchronousReplication *bool

+ UsePgrewind *bool

+ func (c *ClusterSpec) DeepCopy() *ClusterSpec

+ func (os *ClusterSpec) Validate() error

+ func (os *ClusterSpec) WithDefaults() *ClusterSpec

+ type ClusterStatus struct

+ CurrentGeneration int64

+ Master string

+ Phase ClusterPhase

+ type DB struct

+ ChangeTime time.Time

+ Generation int64

+ Spec *DBSpec

+ Status DBStatus

+ UID string

+ type DBInitMode string

+ const DBInitModeExisting

+ const DBInitModeNew

+ const DBInitModeNone

+ const DBInitModePITR

+ const DBInitModeResync

+ type DBSpec struct

+ AdditionalReplicationSlots []string

+ AdditionalWalSenders uint16

+ ExternalSynchronousStandbys []string

+ FollowConfig *FollowConfig

+ Followers []string

+ IncludeConfig bool

+ InitMode DBInitMode

+ KeeperUID string

+ MaxStandbys uint16

+ NewConfig *NewConfig

+ PGHBA []string

+ PGParameters PGParameters

+ PITRConfig *PITRConfig

+ RequestTimeout Duration

+ Role common.Role

+ SynchronousReplication bool

+ SynchronousStandbys []string

+ UsePgrewind bool

+ type DBStatus struct

+ CurrentGeneration int64

+ Healthy bool

+ ListenAddress string

+ OlderWalFile string

+ PGParameters PGParameters

+ Port string

+ SynchronousStandbys []string

+ SystemID string

+ TimelineID uint64

+ TimelinesHistory PostgresTimelinesHistory

+ XLogPos uint64

+ type DBs map[string]*DB

+ type Duration struct

+ func (d *Duration) UnmarshalJSON(b []byte) error

+ func (d Duration) MarshalJSON() ([]byte, error)

+ type ExistingConfig struct

+ KeeperUID string

+ type FollowConfig struct

+ DBUID string

+ StandbySettings *StandbySettings

+ Type FollowType

+ type FollowType string

+ const FollowTypeExternal

+ const FollowTypeInternal

+ type Keeper struct

+ ChangeTime time.Time

+ Generation int64

+ Spec *KeeperSpec

+ Status KeeperStatus

+ UID string

+ func NewKeeperFromKeeperInfo(ki *KeeperInfo) *Keeper

+ type KeeperInfo struct

+ BootUUID string

+ ClusterUID string

+ InfoUID string

+ PostgresState *PostgresState

+ UID string

+ func (k *KeeperInfo) DeepCopy() *KeeperInfo

+ type KeeperSpec struct

+ type KeeperStatus struct

+ BootUUID string

+ Healthy bool

+ LastHealthyTime time.Time

+ type Keepers map[string]*Keeper

+ func (kss Keepers) SortedKeys() []string

+ type KeepersInfo map[string]*KeeperInfo

+ func (k KeepersInfo) DeepCopy() KeepersInfo

+ type NewConfig struct

+ DataChecksums bool

+ Encoding string

+ Locale string

+ type PGParameters map[string]string

+ type PITRConfig struct

+ ArchiveRecoverySettings *ArchiveRecoverySettings

+ DataRestoreCommand string

+ RecoveryTargetSettings *RecoveryTargetSettings

+ type PostgresState struct

+ Generation int64

+ Healthy bool

+ ListenAddress string

+ OlderWalFile string

+ PGParameters common.Parameters

+ Port string

+ SynchronousStandbys []string

+ SystemID string

+ TimelineID uint64

+ TimelinesHistory PostgresTimelinesHistory

+ UID string

+ XLogPos uint64

+ func (p *PostgresState) DeepCopy() *PostgresState

+ type PostgresTimelineHistory struct

+ Reason string

+ SwitchPoint uint64

+ TimelineID uint64

+ type PostgresTimelinesHistory []*PostgresTimelineHistory

+ func (tlsh PostgresTimelinesHistory) GetTimelineHistory(id uint64) *PostgresTimelineHistory

+ type ProxiesInfo map[string]*ProxyInfo

+ func (p ProxiesInfo) DeepCopy() ProxiesInfo

+ func (p ProxiesInfo) ToSlice() ProxiesInfoSlice

+ type ProxiesInfoSlice []*ProxyInfo

+ func (p ProxiesInfoSlice) Len() int

+ func (p ProxiesInfoSlice) Less(i, j int) bool

+ func (p ProxiesInfoSlice) Swap(i, j int)

+ type Proxy struct

+ ChangeTime time.Time

+ Generation int64

+ Spec ProxySpec

+ Status ProxyStatus

+ UID string

+ type ProxyInfo struct

+ Generation int64

+ InfoUID string

+ UID string

+ type ProxySpec struct

+ EnabledProxies []string

+ MasterDBUID string

+ type ProxyStatus struct

+ type RecoveryTargetSettings struct

+ RecoveryTarget string

+ RecoveryTargetLsn string

+ RecoveryTargetName string

+ RecoveryTargetTime string

+ RecoveryTargetTimeline string

+ RecoveryTargetXid string

+ type SUReplAccessMode string

+ const SUReplAccessAll

+ const SUReplAccessStrict

+ func SUReplAccessModeP(s SUReplAccessMode) *SUReplAccessMode

+ type SentinelInfo struct

+ UID string

+ type SentinelsInfo []*SentinelInfo

+ func (s SentinelsInfo) Len() int

+ func (s SentinelsInfo) Less(i, j int) bool

+ func (s SentinelsInfo) Swap(i, j int)

+ type StandbySettings struct

+ PrimaryConninfo string

+ PrimarySlotName string

+ RecoveryMinApplyDelay string

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