postgresql

package

v0.4.0 Latest Latest Go to latest Published: Oct 22, 2016 License: Apache-2.0 Imports: 19 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 IsValidReplSlotName(name string) bool
type ConnParams
- func ParseConnString(name string) (ConnParams, error)
- func URLToConnParams(urlStr string) (ConnParams, error)
type Manager
- func NewManager(name string, pgBinPath string, dataDir string, confDir string, ...) *Manager
type Parameters
- func (s Parameters) Equals(is Parameters) bool
type SystemData
type TimelineHistory

Constants ¶

This section is empty.

Variables ¶

View Source

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

Functions ¶

func IsValidReplSlotName ¶

func IsValidReplSlotName(name string) bool

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, 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) 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) GetSystemData ¶ added in v0.4.0

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

func (*Manager) GetTimelinesHistory ¶ added in v0.4.0

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

func (*Manager) HasConnParams ¶ added in v0.4.0

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) 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, replSlotName string) error

type Parameters ¶

type Parameters map[string]string

func (Parameters) Equals ¶

func (s Parameters) Equals(is Parameters) bool

type SystemData ¶ added in v0.4.0

type SystemData struct {
	SystemID   string
	TimelineID uint64
	XLogPos    uint64
}

type TimelineHistory ¶ added in v0.4.0

type TimelineHistory struct {
	TimelineID  uint64
	SwitchPoint uint64
	Reason      string
}

Source Files ¶

View all Source files

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