postgres

Jan 12, 2024

Changes in this version

+ const Asynchronous

+ const ConnectionURLKey

+ const DefaultPort

+ const PGDATA

+ const PGMAJOR

+ const PrimaryConnInfo

+ const ReplicationMode

+ const SyncStandBys

+ const Synchronous

+ const TimeLine

+ var ClusterHasNoLeader = errors.New("cluster has no leader now")

+ var LocalCommander = NewExecCommander

+ func ExecCommand(name string, args ...string) (string, error)

+ func FormatPgLsn(lsn int64) string

+ func NewCommands() engines.ClusterCommands

+ func NewFakeCommander(f func() error, stdout, stderr *bytes.Buffer) func(name string, args ...string) LocalCommand

+ func NewManager(properties map[string]string) (engines.DBManager, error)

+ func ParsePgLsn(str string) int64

+ func ParsePgWalDumpError(errorInfo string, lsnStr string) string

+ func ParsePrimaryConnInfo(str string) map[string]string

+ func ParseQuery(str string) (result []map[string]interface{}, err error)

+ func PgCtl(arg string) (string, error)

+ func PgRewind(args ...string) (string, error)

+ func PgWalDump(args ...string) (string, error)

+ func Psql(args ...string) (string, error)

+ type Commands struct

+ func (m *Commands) ConnectCommand(connectInfo *engines.AuthInfo) []string

+ func (m *Commands) ConnectExample(info *engines.ConnectionInfo, client string) string

+ func (m *Commands) Container() string

+ func (m *Commands) ExecuteCommand(scripts []string) ([]string, []corev1.EnvVar, error)

+ type Config struct

+ Database string

+ Host string

+ MaxConnections int32

+ MinConnections int32

+ Password string

+ Port int

+ URL string

+ Username string

+ func NewConfig(properties map[string]string) (*Config, error)

+ func (config *Config) GetConnectURLWithHost(host string) string

+ func (config *Config) GetConsensusIPPort(cluster *dcs.Cluster, name string) string

+ func (config *Config) GetDBPort() int

+ type ConsensusMemberHealthStatus struct

+ Connected bool

+ LogDelayNum int64

+ type FakeCommand struct

+ RunnerFunc func() error

+ Stderr *bytes.Buffer

+ Stdout *bytes.Buffer

+ func (cmd *FakeCommand) GetStderr() *bytes.Buffer

+ func (cmd *FakeCommand) GetStdout() *bytes.Buffer

+ func (cmd *FakeCommand) Run() error

+ type History struct

+ ParentTimeline int64

+ SwitchPoint int64

+ type HistoryFile struct

+ History []History

+ func ParseHistory(str string) *HistoryFile

+ type LocalCommand interface

+ GetStderr func() *bytes.Buffer

+ GetStdout func() *bytes.Buffer

+ Run func() error

+ func NewExecCommander(name string, args ...string) LocalCommand

+ type Manager struct

+ Config *Config

+ MajorVersion int

+ Pool PgxPoolIFace

+ Proc *process.Process

+ func (mgr *Manager) CreateUser(ctx context.Context, userName, password string) error

+ func (mgr *Manager) DeleteUser(ctx context.Context, userName string) error

+ func (mgr *Manager) DescribeUser(ctx context.Context, userName string) (*models.UserInfo, error)

+ func (mgr *Manager) Exec(ctx context.Context, sql string) (result int64, err error)

+ func (mgr *Manager) ExecLeader(ctx context.Context, sql string, cluster *dcs.Cluster) (result int64, err error)

+ func (mgr *Manager) ExecOthers(ctx context.Context, sql string, host string) (resp pgconn.CommandTag, err error)

+ func (mgr *Manager) ExecWithHost(ctx context.Context, sql string, host string) (result int64, err error)

+ func (mgr *Manager) GetHealthiestMember(*dcs.Cluster, string) *dcs.Member

+ func (mgr *Manager) GetIsLeader() (bool, bool)

+ func (mgr *Manager) GetLeaderAddr(ctx context.Context) (string, error)

+ func (mgr *Manager) GetPgCurrentSetting(ctx context.Context, setting string) (string, error)

+ func (mgr *Manager) GrantUserRole(ctx context.Context, userName, roleName string) error

+ func (mgr *Manager) IsLeaderMember(ctx context.Context, cluster *dcs.Cluster, member *dcs.Member) (bool, error)

+ func (mgr *Manager) IsPgReady(ctx context.Context) bool

+ func (mgr *Manager) IsRunning() bool

+ func (mgr *Manager) ListSystemAccounts(ctx context.Context) ([]models.UserInfo, error)

+ func (mgr *Manager) ListUsers(ctx context.Context) ([]models.UserInfo, error)

+ func (mgr *Manager) Lock(ctx context.Context, reason string) error

+ func (mgr *Manager) PgReload(ctx context.Context) error

+ func (mgr *Manager) Query(ctx context.Context, sql string) (result []byte, err error)

+ func (mgr *Manager) QueryLeader(ctx context.Context, sql string, cluster *dcs.Cluster) (result []byte, err error)

+ func (mgr *Manager) QueryOthers(ctx context.Context, sql string, host string) (rows pgx.Rows, err error)

+ func (mgr *Manager) QueryWithHost(ctx context.Context, sql string, host string) (result []byte, err error)

+ func (mgr *Manager) ReadCheck(ctx context.Context, host string) bool

+ func (mgr *Manager) Recover(context.Context) error

+ func (mgr *Manager) RevokeUserRole(ctx context.Context, userName, roleName string) error

+ func (mgr *Manager) SetIsLeader(isLeader bool)

+ func (mgr *Manager) ShutDownWithWait()

+ func (mgr *Manager) Unlock(ctx context.Context) error

+ func (mgr *Manager) UnsetIsLeader()

+ func (mgr *Manager) WriteCheck(ctx context.Context, host string) bool

+ type PGStandby struct

+ Amount int

+ HasStar bool

+ Members mapset.Set[string]

+ Types string

+ func ParsePGSyncStandby(standbyRow string) (*PGStandby, error)

+ type PgBaseIFace interface

+ Exec func(ctx context.Context, sql string) (result int64, err error)

+ GetMemberRoleWithHost func(ctx context.Context, host string) (string, error)

+ IsMemberHealthy func(ctx context.Context, cluster *dcs.Cluster, member *dcs.Member) bool

+ Query func(ctx context.Context, sql string) (result []byte, err error)

+ type PgIFace interface

+ type PgxIFace interface

+ Exec func(context.Context, string, ...interface{}) (pgconn.CommandTag, error)

+ Ping func(ctx context.Context) error

+ Query func(ctx context.Context, query string, args ...interface{}) (pgx.Rows, error)

+ type PgxPoolIFace interface

+ Acquire func(ctx context.Context) (*pgxpool.Conn, error)

+ Close func()

+ type PidFile struct