postgresql

package

v0.2.0 Latest Latest Go to latest Published: Nov 2, 2015 License: Apache-2.0 Imports: 21 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/gocardless/stolon

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
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
- 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
- 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)

Constants ¶

This section is empty.

Variables ¶

View Source

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

Functions ¶

func CheckDBStatus ¶

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

func CreateReplRole ¶

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

func CreateReplicationSlot ¶

func CreateReplicationSlot(ctx context.Context, connString string, name 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, replConnString string) (*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, replConnString string) (cluster.PostgresTimeLinesHistory, error)

func IsValidReplSlotName ¶

func IsValidReplSlotName(name string) bool

func PGLSNToInt ¶

func PGLSNToInt(lsn string) (uint64, error)

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 Query ¶

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

func URLToConnParams ¶

func URLToConnParams(urlStr string) (connParams, error)

URLToConnParams creates the connParams from the url.

Types ¶

type Manager ¶

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

func NewManager ¶

func NewManager(name string, pgBinPath string, dataDir string, confDir string, parameters Parameters, connString, replConnString, replUser, replPassword string, requestTimeout time.Duration) (*Manager, error)

func (*Manager) BecomeStandby ¶

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

func (*Manager) CreateReplRole ¶

func (p *Manager) CreateReplRole() error

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) Start ¶

func (p *Manager) Start() error

func (*Manager) Stop ¶

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

func (*Manager) SyncFromMaster ¶

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

func (*Manager) WriteConf ¶

func (p *Manager) WriteConf() error

func (*Manager) WriteRecoveryConf ¶

func (p *Manager) WriteRecoveryConf(masterconnString string) 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

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