cluster

package

Go to main page

Versions in this module

v0

v0.10.0

Mar 21, 2018

Changes in this version

+ const DefaultSUReplAccess

type ClusterSpec

+ AdditionalMasterReplicationSlots []string

+ DefaultSUReplAccessMode *SUReplAccessMode

type DBSpec

+ AdditionalReplicationSlots []string

+ ExternalSynchronousStandbys []string

type ProxiesInfo

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

+ InfoUID string

+ type SUReplAccessMode string

+ const SUReplAccessAll

+ const SUReplAccessStrict

+ func SUReplAccessModeP(s SUReplAccessMode) *SUReplAccessMode

v0.9.0

Feb 1, 2018

v0.8.0

Jan 18, 2018

Changes in this version

+ const DefaultDBWaitReadyTimeout

+ const DefaultStoreTimeout

v0.7.0

Aug 29, 2017

Changes in this version

+ const DefaultAdditionalWalSenders

+ const DefaultDBNotIncreasingXLogPosTimes

+ const DefaultProxyTimeoutInterval

type ClusterSpec

+ AdditionalWalSenders *uint16

+ NewConfig *NewConfig

+ PGHBA []string

type DBSpec

+ AdditionalWalSenders uint16

+ NewConfig *NewConfig

+ PGHBA []string

type DBStatus

+ OlderWalFile string

+ type NewConfig struct

+ DataChecksums bool

+ Encoding string

+ Locale string

type PostgresState

+ OlderWalFile string

type ProxyInfo

+ Generation int64

type ProxySpec

+ EnabledProxies []string

type RecoveryTargetSettings

+ RecoveryTarget string

+ RecoveryTargetLsn string

+ RecoveryTargetName string

+ RecoveryTargetTime string

+ RecoveryTargetTimeline string

+ RecoveryTargetXid string

v0.6.0

May 30, 2017

Changes in this version

+ const DefaultDeadKeeperRemovalInterval

+ const DefaultMaxStandbyLag

+ func Uint32P(u uint32) *uint32

type ClusterRole

+ func ClusterRoleP(s ClusterRole) *ClusterRole

type ClusterSpec

+ DeadKeeperRemovalInterval *Duration

+ MaxStandbyLag *uint32

type KeeperStatus

+ LastHealthyTime time.Time

v0.5.0

Dec 14, 2016

Changes in this version

+ const DefaultConvergenceTimeout

+ const DefaultFailInterval

+ const DefaultInitTimeout

+ const DefaultMaxStandbys

+ const DefaultMaxSynchronousStandbys

+ const DefaultMergePGParameter

+ const DefaultMinSynchronousStandbys

+ const DefaultRole

+ const DefaultSyncTimeout

+ const DefaultUsePgrewind

+ const InitialGeneration

+ const NoGeneration

+ func Uint16P(u uint16) *uint16

+ 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

+ Cluster *Cluster

+ DBs DBs

+ 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

+ type ClusterSpec struct

+ ConvergenceTimeout *Duration

+ ExistingConfig *ExistingConfig

+ FailInterval *Duration

+ InitMode *ClusterInitMode

+ InitTimeout *Duration

+ MaxStandbys *uint16

+ MaxStandbysPerSender *uint16

+ MaxSynchronousStandbys *uint16

+ MergePgParameters *bool

+ MinSynchronousStandbys *uint16

+ 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

+ Role ClusterRole

+ 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

+ FollowConfig *FollowConfig

+ Followers []string

+ IncludeConfig bool

+ InitMode DBInitMode

+ KeeperUID string

+ MaxStandbys uint16

+ PGParameters PGParameters

+ PITRConfig *PITRConfig

+ RequestTimeout Duration

+ Role common.Role

+ SynchronousReplication bool

+ SynchronousStandbys []string

+ UsePgrewind bool

+ type DBStatus struct

+ CurrentGeneration int64

+ Healthy bool

+ ListenAddress string

+ PGParameters PGParameters

+ Port string

+ SynchronousStandbys []string

+ SystemID string

+ TimelineID uint64

+ TimelinesHistory PostgresTimelinesHistory

+ XLogPos uint64

+ type DBs map[string]*DB

+ type ExistingConfig struct

+ KeeperUID string

+ type FollowConfig struct

+ DBUID string

+ StandbySettings *StandbySettings

+ Type FollowType

+ type FollowType string

+ const FollowTypeExternal

+ const FollowTypeInternal

type Keeper

+ ChangeTime time.Time

+ Generation int64

+ Spec *KeeperSpec

+ Status KeeperStatus

+ UID string

+ func NewKeeperFromKeeperInfo(ki *KeeperInfo) *Keeper

type KeeperInfo

+ 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

+ type Keepers map[string]*Keeper

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

type KeepersInfo

+ func (k KeepersInfo) DeepCopy() KeepersInfo

+ type PGParameters map[string]string

+ type PITRConfig struct

+ ArchiveRecoverySettings *ArchiveRecoverySettings

+ DataRestoreCommand string

+ RecoveryTargetSettings *RecoveryTargetSettings

type PostgresState

+ Generation int64

+ Healthy bool

+ ListenAddress string

+ PGParameters common.Parameters

+ Port string

+ SynchronousStandbys []string

+ UID string

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

+ type Proxy struct

+ ChangeTime time.Time

+ Generation int64

+ Spec ProxySpec

+ Status ProxyStatus

+ UID string

type ProxyInfo

+ ProxyGeneration int64

+ ProxyUID string

+ UID string

+ type ProxySpec struct

+ MasterDBUID string

+ type ProxyStatus struct

+ type RecoveryTargetSettings struct

type SentinelInfo

+ UID string

+ type StandbySettings struct

+ PrimaryConninfo string

+ PrimarySlotName string

+ RecoveryMinApplyDelay string

v0.4.0

Oct 22, 2016

Changes in this version

+ const CurrentCDFormatVersion

type ClusterData

+ FormatVersion uint64

+ type PostgresTimelineHistory struct

+ Reason string

+ SwitchPoint uint64

+ TimelineID uint64

+ type PostgresTimelinesHistory []*PostgresTimelineHistory

+ func (tlsh PostgresTimelinesHistory) Copy() PostgresTimelinesHistory

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

v0.3.0

Sep 27, 2016

Changes in this version

+ const DefaultInitWithMultipleKeepers

+ const DefaultUsePGRewind

type Config

+ InitWithMultipleKeepers bool

+ UsePGRewind bool

type NilConfig

+ InitWithMultipleKeepers *bool

+ UsePGRewind *bool

v0.2.0

Nov 2, 2015

Changes in this version

+ const DefaultKeeperFailInterval

+ const DefaultMaxStandbysPerSender

+ const DefaultPGReplPassword

+ const DefaultPGReplUser

+ const DefaultProxyCheckInterval

+ const DefaultRequestTimeout

+ const DefaultSleepInterval

+ const DefaultSynchronousReplication

+ func BoolP(b bool) *bool

+ func MapStringP(m map[string]string) *map[string]string

+ func StringP(s string) *string

+ func UintP(u uint) *uint

+ type ClusterData struct

+ ClusterView *ClusterView

+ KeepersState KeepersState

+ type ClusterView struct

+ ChangeTime time.Time

+ Config *NilConfig

+ KeepersRole KeepersRole

+ Master string

+ ProxyConf *ProxyConf

+ Version int

+ func NewClusterView() *ClusterView

+ func (cv *ClusterView) Copy() *ClusterView

+ func (cv *ClusterView) Equals(ncv *ClusterView) bool

+ func (cv *ClusterView) GetFollowersIDs(id string) []string

+ type Config struct

+ KeeperFailInterval time.Duration

+ MaxStandbysPerSender uint

+ PGParameters map[string]string

+ PGReplPassword string

+ PGReplUser string

+ RequestTimeout time.Duration

+ SleepInterval time.Duration

+ SynchronousReplication bool

+ func NewDefaultConfig() *Config

+ func (c *Config) Copy() *Config

+ type Duration struct

+ func DurationP(d Duration) *Duration

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

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

+ type Keeper struct

+ ClusterViewVersion int

+ type KeeperDiscoveryInfo struct

+ ListenAddress string

+ Port string

+ type KeeperInfo struct

+ ClusterViewVersion int

+ ID string

+ ListenAddress string

+ PGListenAddress string

+ PGPort string

+ Port string

+ func (k *KeeperInfo) Copy() *KeeperInfo

+ type KeeperRole struct

+ Follow string

+ ID string

+ func (kr *KeeperRole) Copy() *KeeperRole

+ type KeeperState struct

+ ClusterViewVersion int

+ ErrorStartTime time.Time

+ Healthy bool

+ ID string

+ ListenAddress string

+ PGListenAddress string

+ PGPort string

+ PGState *PostgresState

+ Port string

+ func (ks *KeeperState) ChangedFromKeeperInfo(ki *KeeperInfo) (bool, error)

+ func (ks *KeeperState) CleanError()

+ func (ks *KeeperState) Copy() *KeeperState

+ func (ks *KeeperState) SetError()

+ func (ks *KeeperState) UpdateFromKeeperInfo(ki *KeeperInfo) error

+ type KeepersDiscoveryInfo []*KeeperDiscoveryInfo

+ type KeepersInfo map[string]*KeeperInfo

+ type KeepersRole map[string]*KeeperRole

+ func NewKeepersRole() KeepersRole

+ func (ksr KeepersRole) Add(id string, follow string) error

+ func (ksr KeepersRole) Copy() KeepersRole

+ type KeepersState map[string]*KeeperState

+ func (kss KeepersState) Copy() KeepersState

+ func (kss KeepersState) NewFromKeeperInfo(ki *KeeperInfo) error

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

+ type NilConfig struct

+ KeeperFailInterval *Duration

+ MaxStandbysPerSender *uint

+ PGParameters *map[string]string

+ PGReplPassword *string

+ PGReplUser *string

+ RequestTimeout *Duration

+ SleepInterval *Duration

+ SynchronousReplication *bool

+ func (c *NilConfig) Copy() *NilConfig

+ func (c *NilConfig) MergeDefaults()

+ func (c *NilConfig) ToConfig() *Config

+ func (c *NilConfig) UnmarshalJSON(in []byte) error

+ func (c *NilConfig) Validate() error

+ type PostgresState struct

+ Initialized bool

+ Role common.Role

+ SystemID string

+ TimelineID uint64

+ TimelinesHistory PostgresTimeLinesHistory

+ XLogPos uint64

+ func (p *PostgresState) Copy() *PostgresState

+ type PostgresTimeLineHistory struct

+ Reason string

+ SwitchPoint uint64

+ TimelineID uint64

+ type PostgresTimeLinesHistory []*PostgresTimeLineHistory

+ func (tlsh PostgresTimeLinesHistory) Copy() PostgresTimeLinesHistory

+ func (tlsh PostgresTimeLinesHistory) GetTimelineHistory(id uint64) *PostgresTimeLineHistory

+ type ProxiesInfo []*ProxyInfo

+ func (p ProxiesInfo) Len() int

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

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

+ type ProxyConf struct

+ Host string

+ Port string

+ func (pc *ProxyConf) Copy() *ProxyConf

+ type ProxyInfo struct

+ ClusterViewVersion int

+ ID string

+ ListenAddress string

+ Port string

+ type SentinelInfo struct

+ ID string

+ ListenAddress string

+ Port string

+ type SentinelsInfo []*SentinelInfo

+ func (s SentinelsInfo) Len() int

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

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

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