postgresql

package

Go to main page

Versions in this module

v0

v0.10.0

Mar 21, 2018

Changes in this version

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

type Manager

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

v0.9.0

Feb 1, 2018

Changes in this version

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

type Manager

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

type SystemData

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

v0.8.0

Jan 18, 2018

v0.7.0

Aug 29, 2017

Changes in this version

+ const WalSegSize

+ func IsWalFileName(name string) bool

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

+ func XlogPosToWalFileNameNoTimeline(XLogPos uint64) string

+ type InitConfig struct

+ DataChecksums bool

+ Encoding string

+ Locale string

type Manager

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

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

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

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

+ func (p *Manager) Ping() error

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

+ func (p *Manager) UpdateCurHba()

+ func (p *Manager) UpdateCurParameters()

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

v0.6.0

May 30, 2017

Changes in this version

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

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

type Manager

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

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

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

v0.5.0

Dec 14, 2016

Changes in this version

+ func SetLogger(l zap.Logger)

type ConnParams

+ func (cp ConnParams) Copy() ConnParams

+ func (cp ConnParams) Del(k string)

type Manager

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

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

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

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

v0.4.0

Oct 22, 2016

Changes in this version

type Manager

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

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

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

+ type SystemData struct

+ SystemID string

+ TimelineID uint64

+ XLogPos uint64

+ type TimelineHistory struct

+ Reason string

+ SwitchPoint uint64

+ TimelineID uint64

v0.3.0

Sep 27, 2016

Changes in this version

+ func AlterRole(ctx context.Context, connString string, roles []string, ...) error

+ func CreateRole(ctx context.Context, connString string, roles []string, ...) error

+ func SetPassword(ctx context.Context, connString, username, password string) error

+ type ConnParams map[string]string

+ func (p ConnParams) ConnString() string

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

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

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

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

type Manager

+ func (p *Manager) SetupRoles() error

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

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

v0.2.0

Nov 2, 2015

Changes in this version

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

+ func CheckDBStatus(ctx context.Context, connString string) error

+ func CreateReplRole(ctx context.Context, connString, replUser, replPassword string) error

+ func CreateReplicationSlot(ctx context.Context, connString string, name string) error

+ func DropReplicationSlot(ctx context.Context, connString string, name string) error

+ func Exec(ctx context.Context, db *sql.DB, query string, args ...interface{}) (sql.Result, error)

+ func GetPGMasterLocation(ctx context.Context, connString string) (uint64, error)

+ func GetPGState(ctx context.Context, replConnString string) (*cluster.PostgresState, error)

+ func GetReplicatinSlots(ctx context.Context, connString string) ([]string, error)

+ func GetRole(ctx context.Context, connString string) (common.Role, error)

+ func GetTimelinesHistory(ctx context.Context, timeline uint64, replConnString string) (cluster.PostgresTimeLinesHistory, error)

+ func IsValidReplSlotName(name string) bool

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

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

+ func Query(ctx context.Context, db *sql.DB, query string, args ...interface{}) (*sql.Rows, error)

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

+ type Manager struct

+ func NewManager(name string, pgBinPath string, dataDir string, confDir string, ...) (*Manager, error)

+ func (p *Manager) BecomeStandby(masterconnString string) error

+ func (p *Manager) CreateReplRole() error

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

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

+ func (p *Manager) GetParameters() 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) HasConnString() (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) SetParameters(parameters Parameters)

+ func (p *Manager) Start() error

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

+ func (p *Manager) SyncFromMaster(masterconnString string) error

+ func (p *Manager) WriteConf() error

+ func (p *Manager) WriteRecoveryConf(masterconnString string) error

+ type Parameters map[string]string

+ func (s Parameters) Copy() Parameters

+ func (s Parameters) Equals(is Parameters) bool

+ func (s Parameters) Get(k string) (string, bool)

+ func (s Parameters) Set(k, v string)

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