postgresql

package

Go to main page

Versions in this module

v0

v0.17.0

Sep 3, 2021

v0.16.0

Feb 25, 2020

v0.15.0

Dec 3, 2019

Changes in this version

type Manager

+ func (p *Manager) CurRecoveryOptions() *RecoveryOptions

+ func (p *Manager) SetRecoveryOptions(recoveryOptions *RecoveryOptions)

+ func (p *Manager) UpdateCurRecoveryOptions()

+ type RecoveryMode int

+ const RecoveryModeNone

+ const RecoveryModeRecovery

+ const RecoveryModeStandby

+ type RecoveryOptions struct

+ RecoveryMode RecoveryMode

+ RecoveryParameters common.Parameters

+ func NewRecoveryOptions() *RecoveryOptions

+ func (r *RecoveryOptions) DeepCopy() *RecoveryOptions

v0.14.0

Jul 26, 2019

Changes in this version

type Manager

+ func (p *Manager) IsRestartRequired(changedParams []string) (bool, error)

+ type PGManager interface

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

v0.13.0

Sep 17, 2018

Changes in this version

type Manager

+ func (p *Manager) CurRecoveryParameters() common.Parameters

+ func (p *Manager) SetRecoveryParameters(recoveryParameters common.Parameters)

+ func (p *Manager) UpdateCurRecoveryParameters()

v0.12.0

Jul 3, 2018

Changes in this version

type Manager

+ func (p *Manager) GetSyncStandbys() ([]string, error)

v0.11.0

Jun 8, 2018

Changes in this version

+ const WalSegSize

+ var ErrUnknownState = errors.New("unknown postgres state")

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

+ func IsValidReplSlotName(name string) bool

+ func IsWalFileName(name string) bool

+ func PGLsnToInt(lsn string) (uint64, error)

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

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

+ func SetLogger(l *zap.SugaredLogger)

+ func WalFileNameNoTimeLine(name string) (string, error)

+ func XlogPosToWalFileNameNoTimeline(XLogPos uint64) string

+ type ConnParams map[string]string

+ func ParseConnString(name string) (ConnParams, error)

+ func URLToConnParams(urlStr string) (ConnParams, error)

+ func (cp ConnParams) Copy() ConnParams

+ func (cp ConnParams) Del(k string)

+ func (cp ConnParams) Equals(cp2 ConnParams) bool

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

+ func (cp ConnParams) Isset(k string) bool

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

+ func (p ConnParams) ConnString() string

+ type InitConfig struct

+ DataChecksums bool

+ Encoding string

+ Locale string

+ type Manager struct

+ func NewManager(pgBinPath string, dataDir string, localConnParams, replConnParams ConnParams, ...) *Manager

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (p *Manager) Ping() error

+ func (p *Manager) Promote() error

+ func (p *Manager) Reload() error

+ func (p *Manager) RemoveAll() error

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

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

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

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

+ func (p *Manager) SetupRoles() error

+ func (p *Manager) Start() error

+ func (p *Manager) StartTmpMerged() error

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

+ func (p *Manager) StopIfStarted(fast bool) error

+ func (p *Manager) SyncFromFollowed(followedConnParams ConnParams, replSlot string) error

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

+ func (p *Manager) UpdateCurHba()

+ func (p *Manager) UpdateCurParameters()

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

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

+ func (p *Manager) WriteConf() error

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

+ type SystemData struct

+ SystemID string

+ TimelineID uint64

+ XLogPos uint64

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

+ type TimelineHistory struct

+ Reason string

+ SwitchPoint uint64

+ TimelineID uint64

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