Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

v0

package

Go to main page

Versions in this module

v0

v0.16.8

May 12, 2021

v0.16.7

Apr 1, 2021

v0.13.0

Sep 17, 2018

v0.12.0

Jul 3, 2018

v0.11.0

Jun 8, 2018

Changes in this version

+ const CurrentCDFormatVersion

+ const DefaultInitWithMultipleKeepers

+ const DefaultKeeperFailInterval

+ const DefaultMaxStandbysPerSender

+ const DefaultProxyCheckInterval

+ const DefaultRequestTimeout

+ const DefaultSleepInterval

+ const DefaultSynchronousReplication

+ const DefaultUsePGRewind

+ 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

+ FormatVersion uint64

+ 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

+ InitWithMultipleKeepers bool

+ KeeperFailInterval time.Duration

+ MaxStandbysPerSender uint

+ PGParameters map[string]string

+ RequestTimeout time.Duration

+ SleepInterval time.Duration

+ SynchronousReplication bool

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

+ InitWithMultipleKeepers *bool

+ KeeperFailInterval *Duration

+ MaxStandbysPerSender *uint

+ PGParameters *map[string]string

+ RequestTimeout *Duration

+ SleepInterval *Duration

+ SynchronousReplication *bool

+ UsePGRewind *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)