postgresql

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Sep 27, 2016 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

func AlterRole added in v0.3.0 

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

func CheckDBStatus 

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

func CreateReplicationSlot 

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

func CreateRole added in v0.3.0 

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

func DropReplicationSlot 

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

func Exec 

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

func GetPGMasterLocation 

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

func GetPGState 

func GetPGState(ctx context.Context, replConnParams ConnParams) (*cluster.PostgresState, error)

func GetReplicatinSlots 

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

func GetRole 

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

func GetTimelinesHistory 

func GetTimelinesHistory(ctx context.Context, timeline uint64, replConnParams ConnParams) (cluster.PostgresTimeLinesHistory, error)

func IsValidReplSlotName 

func IsValidReplSlotName(name string) bool

func PGLSNToInt 

func PGLSNToInt(lsn string) (uint64, error)

func Query 

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

func SetPassword added in v0.3.0 

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

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) Equals added in v0.3.0 

func (p ConnParams) Equals(cp ConnParams) bool

func (ConnParams) Get added in v0.3.0 

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

func (ConnParams) Isset added in v0.3.0 

func (p ConnParams) Isset(k string) bool

func (ConnParams) Set added in v0.3.0 

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

type Manager 

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

func NewManager 

func NewManager(name string, pgBinPath string, dataDir string, confDir string, parameters Parameters, localConnString, replConnString, 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) GetParameters 

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

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

func (p *Manager) SetParameters(parameters Parameters)

func (*Manager) SetupRoles added in v0.3.0 

func (p *Manager) SetupRoles() error

func (*Manager) Start 

func (p *Manager) Start() 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) WriteConf 

func (p *Manager) WriteConf() error

func (*Manager) WriteRecoveryConf 

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

type Parameters 

type Parameters map[string]string

func (Parameters) Copy 

func (s Parameters) Copy() Parameters

func (Parameters) Equals 

func (s Parameters) Equals(is Parameters) bool

func (Parameters) Get 

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

func (Parameters) Set 

func (s Parameters) Set(k, v 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.