Documentation ¶
Index ¶
- Constants
- Variables
- func AlterRole(ctx context.Context, connString string, roles []string, ...) error
- func Backup(conn ConnSettings, s3Cred store.S3Credentials, dbName, folder string) (string, error)
- func CheckDBStatus(ctx context.Context, connString string) error
- func Create(conn ConnSettings, name string) error
- func CreateReplicationSlot(ctx context.Context, connString string, name string) error
- func CreateRole(ctx context.Context, connString string, roles []string, ...) error
- func Delete(conn ConnSettings, 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, replConnParams ConnParams) (*cluster.PostgresState, error)
- func GetReplicationLag(ctx context.Context, connParams ConnParams) (uint, error)
- func GetReplicationSlots(ctx context.Context, connString string) ([]string, error)
- func GetRole(ctx context.Context, connParams ConnParams) (common.Role, error)
- func GetTimelinesHistory(ctx context.Context, timeline uint64, replConnParams ConnParams) (cluster.PostgresTimeLinesHistory, error)
- func IsValidReplSlotName(name string) bool
- func PGLSNToInt(lsn string) (uint64, error)
- func Query(ctx context.Context, db *sql.DB, query string, args ...interface{}) (*sql.Rows, error)
- func ReplicationLagFunction(ctx context.Context, connString string) error
- func Restore(conn ConnSettings, s3Cred store.S3Credentials, dbName, src string) error
- func Run(conn ConnSettings, filename string) error
- func SetPassword(ctx context.Context, connString, username, password string) error
- type ConnParams
- type ConnSettings
- type Manager
- func (p *Manager) CreateReplicationLagFunction() 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) GetReplicationSlots() ([]string, error)
- func (p *Manager) GetRole() (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) SetupRoles() error
- func (p *Manager) Start() 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(followedConnParams ConnParams) error
- type Parameters
Constants ¶
View Source
const ( PSQLBin pgBinary = "psql" PgDumpBin pgBinary = "pg_dump" PgRestoreBin pgBinary = "pg_restore" )
Variables ¶
View Source
var (
ValidReplSlotName = regexp.MustCompile("^[a-z0-9_]+$")
)
Functions ¶
func Backup ¶ added in v0.3.0
func Backup(conn ConnSettings, s3Cred store.S3Credentials, dbName, folder string) (string, error)
func Create ¶ added in v0.3.0
func Create(conn ConnSettings, name string) error
func CreateReplicationSlot ¶
func CreateRole ¶ added in v0.3.0
func Delete ¶ added in v0.3.0
func Delete(conn ConnSettings, name string) error
func DropReplicationSlot ¶
func GetPGMasterLocation ¶
func GetPGState ¶
func GetPGState(ctx context.Context, replConnParams ConnParams) (*cluster.PostgresState, error)
func GetReplicationLag ¶ added in v0.3.0
func GetReplicationLag(ctx context.Context, connParams ConnParams) (uint, error)
func GetReplicationSlots ¶ added in v0.3.0
func GetTimelinesHistory ¶
func GetTimelinesHistory(ctx context.Context, timeline uint64, replConnParams ConnParams) (cluster.PostgresTimeLinesHistory, error)
func IsValidReplSlotName ¶
func PGLSNToInt ¶
func ReplicationLagFunction ¶ added in v0.3.0
func Restore ¶ added in v0.3.0
func Restore(conn ConnSettings, s3Cred store.S3Credentials, dbName, src string) error
func Run ¶ added in v0.3.0
func Run(conn ConnSettings, filename string) error
Types ¶
type ConnParams ¶ added in v0.3.0
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 ConnSettings ¶ added in v0.3.0
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
func NewManager ¶
func (*Manager) CreateReplicationLagFunction ¶ added in v0.3.0
func (*Manager) CreateReplicationSlot ¶
func (*Manager) DropReplicationSlot ¶
func (*Manager) GetParameters ¶
func (p *Manager) GetParameters() Parameters
func (*Manager) GetPrimaryConninfo ¶
func (p *Manager) GetPrimaryConninfo() (ConnParams, error)
func (*Manager) GetReplicationSlots ¶ added in v0.3.0
func (*Manager) HasConnString ¶
func (*Manager) IsInitialized ¶
func (*Manager) SetParameters ¶
func (p *Manager) SetParameters(parameters Parameters)
func (*Manager) SetupRoles ¶ added in v0.3.0
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) WriteRecoveryConf ¶
func (p *Manager) WriteRecoveryConf(followedConnParams ConnParams) error
type Parameters ¶
func (Parameters) Copy ¶
func (s Parameters) Copy() Parameters
func (Parameters) Equals ¶
func (s Parameters) Equals(is Parameters) bool
func (Parameters) Set ¶
func (s Parameters) Set(k, v string)
Click to show internal directories.
Click to hide internal directories.