cluster

package

Go to main page

Versions in this module

v0

v0.3.0

Oct 27, 2017

Changes in this version

+ const DefaultInitWithMultipleKeepers

+ const DefaultMaxReplicationLag

+ const DefaultMaxReplicationLagB

+ const DefaultUsePGRewind

type Config

+ InitWithMultipleKeepers bool

+ MaxReplicationLag uint

+ MaxReplicationLagB uint

+ UsePGRewind bool

type KeeperState

+ func (ks *KeeperState) String() string

type NilConfig

+ InitWithMultipleKeepers *bool

+ MaxReplicationLag *uint

+ MaxReplicationLagB *uint

+ UsePGRewind *bool

type PostgresState

+ ReplicationLag uint

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