postgresql

package
v0.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 1, 2018 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// TODO(sgotti) for now we assume wal size is the default 16MiB size
	WalSegSize = (16 * 1024 * 1024) // 16MiB
)

Variables

View Source 
var (
	ValidReplSlotName = regexp.MustCompile("^[a-z0-9_]+$")
)

Functions

func IsValidReplSlotName 

func IsValidReplSlotName(name string) bool

func IsWalFileName added in v0.7.0 

func IsWalFileName(name string) bool

func PGLsnToInt added in v0.9.0 

func PGLsnToInt(lsn string) (uint64, error)

func ParseBinaryVersion added in v0.6.0 

func ParseBinaryVersion(v string) (int, int, error)

func ParseVersion added in v0.6.0 

func ParseVersion(v string) (int, int, error)

func SetLogger added in v0.5.0 

func SetLogger(l *zap.SugaredLogger)

func WalFileNameNoTimeLine added in v0.7.0 

func WalFileNameNoTimeLine(name string) (string, error)

func XlogPosToWalFileNameNoTimeline added in v0.7.0 

func XlogPosToWalFileNameNoTimeline(XLogPos uint64) string

Types

type ConnParams added in v0.3.0 

type ConnParams map[string]string

func ParseConnString 

func ParseConnString(name string) (ConnParams, error)

ParseConnString parses the options from name and adds them to the values.

The parsing code is based on conninfo_parse from libpq's fe-connect.c

func URLToConnParams 

func URLToConnParams(urlStr string) (ConnParams, error)

URLToConnParams creates the connParams from the url.

func (ConnParams) ConnString added in v0.3.0 

func (p ConnParams) ConnString() string

func (ConnParams) Copy added in v0.5.0 

func (cp ConnParams) Copy() ConnParams

func (ConnParams) Del added in v0.5.0 

func (cp ConnParams) Del(k string)

func (ConnParams) Equals added in v0.3.0 

func (cp ConnParams) Equals(cp2 ConnParams) bool

func (ConnParams) Get added in v0.3.0 

func (cp ConnParams) Get(k string) (v string)

func (ConnParams) Isset added in v0.3.0 

func (cp ConnParams) Isset(k string) bool

func (ConnParams) Set added in v0.3.0 

func (cp ConnParams) Set(k, v string)

type InitConfig added in v0.7.0 

type InitConfig struct {
	Locale        string
	Encoding      string
	DataChecksums bool
}

type Manager 

type Manager struct {
	// contains filtered or unexported fields
}

func NewManager 

func NewManager(pgBinPath string, dataDir string, localConnParams, replConnParams ConnParams, suAuthMethod, suUsername, suPassword, replAuthMethod, replUsername, replPassword string, requestTimeout time.Duration) *Manager

func (*Manager) BinaryVersion added in v0.6.0 

func (p *Manager) BinaryVersion() (int, int, error)

func (*Manager) CreateReplicationSlot 

func (p *Manager) CreateReplicationSlot(name string) error

func (*Manager) CurHba added in v0.7.0 

func (p *Manager) CurHba() []string

func (*Manager) CurParameters added in v0.7.0 

func (p *Manager) CurParameters() common.Parameters

func (*Manager) DropReplicationSlot 

func (p *Manager) DropReplicationSlot(name string) error

func (*Manager) GetConfigFilePGParameters added in v0.5.0 

func (p *Manager) GetConfigFilePGParameters() (common.Parameters, error)

func (*Manager) GetPrimaryConninfo 

func (p *Manager) GetPrimaryConninfo() (ConnParams, error)

func (*Manager) GetPrimarySlotName added in v0.6.0 

func (p *Manager) GetPrimarySlotName() (string, error)

func (*Manager) GetReplicationSlots added in v0.7.0 

func (p *Manager) GetReplicationSlots() ([]string, error)

func (*Manager) GetRole 

func (p *Manager) GetRole() (common.Role, error)

func (*Manager) GetRoleFromDB 

func (p *Manager) GetRoleFromDB() (common.Role, error)

func (*Manager) GetSystemData added in v0.4.0 

func (p *Manager) GetSystemData() (*SystemData, error)

func (*Manager) GetSystemdID added in v0.5.0 

func (p *Manager) GetSystemdID() (string, error)

func (*Manager) GetTimelinesHistory added in v0.4.0 

func (p *Manager) GetTimelinesHistory(timeline uint64) ([]*TimelineHistory, error)

func (*Manager) HasConnParams added in v0.4.0 

func (p *Manager) HasConnParams() (bool, error)

func (*Manager) Init 

func (p *Manager) Init(initConfig *InitConfig) error

func (*Manager) IsInitialized 

func (p *Manager) IsInitialized() (bool, error)

func (*Manager) IsStarted 

func (p *Manager) IsStarted() (bool, error)

func (*Manager) OlderWalFile added in v0.7.0 

func (p *Manager) OlderWalFile() (string, error)

func (*Manager) PGDataVersion added in v0.6.0 

func (p *Manager) PGDataVersion() (int, int, error)

func (*Manager) Ping added in v0.7.0 

func (p *Manager) Ping() error

func (*Manager) Promote 

func (p *Manager) Promote() error

func (*Manager) Reload 

func (p *Manager) Reload() error

func (*Manager) RemoveAll 

func (p *Manager) RemoveAll() error

func (*Manager) Restart 

func (p *Manager) Restart(fast bool) error

func (*Manager) Restore added in v0.5.0 

func (p *Manager) Restore(command string) error

func (*Manager) SetHba added in v0.7.0 

func (p *Manager) SetHba(hba []string)

func (*Manager) SetParameters 

func (p *Manager) SetParameters(parameters common.Parameters)

func (*Manager) SetupRoles added in v0.3.0 

func (p *Manager) SetupRoles() error

func (*Manager) Start 

func (p *Manager) Start() error

func (*Manager) StartTmpMerged added in v0.5.0 

func (p *Manager) StartTmpMerged() error

func (*Manager) Stop 

func (p *Manager) Stop(fast bool) error

func (*Manager) SyncFromFollowed added in v0.3.0 

func (p *Manager) SyncFromFollowed(followedConnParams ConnParams) error

func (*Manager) SyncFromFollowedPGRewind added in v0.3.0 

func (p *Manager) SyncFromFollowedPGRewind(followedConnParams ConnParams, password string) error

func (*Manager) UpdateCurHba added in v0.7.0 

func (p *Manager) UpdateCurHba()

func (*Manager) UpdateCurParameters added in v0.7.0 

func (p *Manager) UpdateCurParameters()

func (*Manager) WaitReady added in v0.7.0 

func (p *Manager) WaitReady(timeout time.Duration) error

func (*Manager) WaitRecoveryDone added in v0.9.0 

func (p *Manager) WaitRecoveryDone(timeout time.Duration) error

func (*Manager) WriteConf 

func (p *Manager) WriteConf() error

func (*Manager) WriteRecoveryConf 

func (p *Manager) WriteRecoveryConf(recoveryParameters common.Parameters) error

type SystemData added in v0.4.0 

type SystemData struct {
	SystemID   string
	TimelineID uint64
	XLogPos    uint64
}

func GetSystemData added in v0.9.0 

func GetSystemData(ctx context.Context, replConnParams ConnParams) (*SystemData, error)

type TimelineHistory added in v0.4.0 

type TimelineHistory struct {
	TimelineID  uint64
	SwitchPoint uint64
	Reason      string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.