postgresql

Documentation

Index

• Variables
• func IsValidReplSlotName(name string) bool
• func SetLogger(l zap.Logger)
• type ConnParams
  • func ParseConnString(name string) (ConnParams, error)
  • func URLToConnParams(urlStr string) (ConnParams, error)
  • func (p ConnParams) ConnString() string
  • 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)
• type Manager
  • func NewManager(pgBinPath string, dataDir string, parameters common.Parameters, ...) *Manager
  • func (p *Manager) CreateReplicationSlot(name string) error
  • func (p *Manager) DropReplicationSlot(name string) error
  • func (p *Manager) GetConfigFilePGParameters() (common.Parameters, error)
  • func (p *Manager) GetParameters() common.Parameters
  • func (p *Manager) GetPrimaryConninfo() (ConnParams, error)
  • func (p *Manager) GetReplicatinSlots() ([]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() error
  • func (p *Manager) IsInitialized() (bool, error)
  • func (p *Manager) IsStarted() (bool, 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) SetParameters(parameters common.Parameters)
  • func (p *Manager) SetupRoles() error
  • func (p *Manager) Start() error
  • func (p *Manager) StartTmpMerged(args ...string) error
  • func (p *Manager) Stop(fast bool) error
  • func (p *Manager) SyncFromFollowed(followedConnParams ConnParams) error
  • func (p *Manager) SyncFromFollowedPGRewind(followedConnParams ConnParams, password string) error
  • func (p *Manager) WriteConf() error
  • func (p *Manager) WriteRecoveryConf(recoveryParameters common.Parameters) error
• type SystemData
• type TimelineHistory

Variables

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

Functions

func IsValidReplSlotName

func IsValidReplSlotName(name string) bool

func SetLogger

func SetLogger(l zap.Logger)

Types

type ConnParams

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

func (p ConnParams) ConnString() string

func (ConnParams) Copy

func (cp ConnParams) Copy() ConnParams

func (ConnParams) Del

func (cp ConnParams) Del(k string)

func (ConnParams) Equals

func (cp ConnParams) Equals(cp2 ConnParams) bool

func (ConnParams) Get

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

func (ConnParams) Isset

func (cp ConnParams) Isset(k string) bool

func (ConnParams) Set

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

type Manager

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

func NewManager

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

func (*Manager) CreateReplicationSlot

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

func (*Manager) DropReplicationSlot

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

func (*Manager) GetConfigFilePGParameters

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

func (*Manager) GetParameters

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

func (*Manager) GetPrimaryConninfo

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

func (*Manager) GetReplicatinSlots

func (p *Manager) GetReplicatinSlots() ([]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

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

func (*Manager) GetSystemdID

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

func (*Manager) GetTimelinesHistory

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

func (*Manager) HasConnParams

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

func (*Manager) Init

func (p *Manager) Init() error

func (*Manager) IsInitialized

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

func (*Manager) IsStarted

func (p *Manager) IsStarted() (bool, 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

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

func (*Manager) SetParameters

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

func (*Manager) SetupRoles

func (p *Manager) SetupRoles() error

func (*Manager) Start

func (p *Manager) Start() error

func (*Manager) StartTmpMerged

func (p *Manager) StartTmpMerged(args ...string) error

func (*Manager) Stop

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

func (*Manager) SyncFromFollowed

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

func (*Manager) SyncFromFollowedPGRewind

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

func (*Manager) WriteConf

func (p *Manager) WriteConf() error

func (*Manager) WriteRecoveryConf

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

type SystemData

type SystemData struct {
	SystemID   string
	TimelineID uint64
	XLogPos    uint64
}

type TimelineHistory

type TimelineHistory struct {
	TimelineID  uint64
	SwitchPoint uint64
	Reason      string
}