Documentation
¶
Index ¶
- func AddNodeRPC(node string, nodes []string) error
- func BackupCancelRPC(self string) (*model.BackupRPCResponse, error)
- func ChangeUserPasswordRPC(node string, user string, passwd string) (*model.MysqlUserRPCResponse, error)
- func CreateNormalUserRPC(node string, user string, passwd string) (*model.MysqlUserRPCResponse, error)
- func CreateSuperUserRPC(node string, user string, passwd string) (*model.MysqlUserRPCResponse, error)
- func CreateUserWithPrivRPC(node, user, passwd, database, table, host, privs string, ssl string) (*model.MysqlUserRPCResponse, error)
- func DisableRaftRPC(node string) (*model.HARPCResponse, error)
- func DoApplyLogRPC(node string, backupdir string) error
- func DropUserRPC(node string, user string, host string) (*model.MysqlUserRPCResponse, error)
- func EnableRaftRPC(node string) (*model.HARPCResponse, error)
- func FindBestoneForBackup(self string) (string, error)
- func GTIDFilter(in string) string
- func GetClient(conn string) (*xrpc.Client, func(), error)
- func GetClusterLeader(self string) (string, error)
- func GetGTIDRPC(node string) (*model.MysqlStatusRPCResponse, error)
- func GetMysqlStatusRPC(node string) (*model.MysqlStatusRPCResponse, error)
- func GetMysqlUserRPC(node string) (*model.MysqlUserRPCResponse, error)
- func GetMysqldStatusRPC(node string) (*model.MysqldStatusRPCResponse, error)
- func GetNodes(endpoint string) ([]string, error)
- func GetNodesRPC(node string) (*model.NodeRPCResponse, error)
- func GetRaftState(endpoint string) (string, []string, error)
- func GetRaftStatusRPC(node string) (*model.RaftStatusRPCResponse, error)
- func GetXtrabackupGTIDPurged(node string, backuppath string) (string, error)
- func KillMysqldRPC(node string) error
- func MysqlIsWorkingRPC(node string) (bool, error)
- func MysqlResetMasterRPC(node string) (*model.MysqlRPCResponse, error)
- func MysqlResetSlaveAllRPC(node string) (*model.MysqlRPCResponse, error)
- func MysqlStartSlaveRPC(node string) (*model.MysqlRPCResponse, error)
- func MysqlStopSlaveRPC(node string) (*model.MysqlRPCResponse, error)
- func MysqldIsRunningRPC(node string) (bool, error)
- func PrintQueryOutput(cols []string, allRows [][]string)
- func RaftDisablePurgeBinlogRPC(node string) error
- func RaftEnablePurgeBinlogRPC(node string) error
- func RemoveNodeRPC(node string, nodes []string) error
- func RequestBackupRPC(fromnode string, conf *config.Config, backupdir string) (*model.BackupRPCResponse, error)
- func ServerPingRPC(node string) (*model.ServerRPCResponse, error)
- func ServerStatusRPC(node string) (*model.ServerRPCResponse, error)
- func SetGlobalVarRPC(node string, varsql string) (*model.MysqlVarRPCResponse, error)
- func ShutdownMysqldRPC(node string) error
- func StartMonitorRPC(node string) (*model.MysqldRPCResponse, error)
- func StartMysqldRPC(node string) error
- func StopMonitorRPC(node string) (*model.MysqldRPCResponse, error)
- func TryToLeaderRPC(node string) (*model.HARPCResponse, error)
- func WaitMysqlWorkingRPC(node string) error
- func WaitMysqldRunningRPC(node string) error
- func WaitMysqldShutdownRPC(node string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BackupCancelRPC ¶
func BackupCancelRPC(self string) (*model.BackupRPCResponse, error)
func ChangeUserPasswordRPC ¶
func CreateNormalUserRPC ¶
func CreateSuperUserRPC ¶
func CreateUserWithPrivRPC ¶
func CreateUserWithPrivRPC(node, user, passwd, database, table, host, privs string, ssl string) (*model.MysqlUserRPCResponse, error)
func DisableRaftRPC ¶
func DisableRaftRPC(node string) (*model.HARPCResponse, error)
func DoApplyLogRPC ¶
func DropUserRPC ¶
func EnableRaftRPC ¶
func EnableRaftRPC(node string) (*model.HARPCResponse, error)
func FindBestoneForBackup ¶
func GTIDFilter ¶
func GetClusterLeader ¶
func GetGTIDRPC ¶
func GetGTIDRPC(node string) (*model.MysqlStatusRPCResponse, error)
func GetMysqlStatusRPC ¶
func GetMysqlStatusRPC(node string) (*model.MysqlStatusRPCResponse, error)
func GetMysqlUserRPC ¶
func GetMysqlUserRPC(node string) (*model.MysqlUserRPCResponse, error)
GetMysqlUserRPC get mysql user
func GetMysqldStatusRPC ¶
func GetMysqldStatusRPC(node string) (*model.MysqldStatusRPCResponse, error)
func GetNodesRPC ¶
func GetNodesRPC(node string) (*model.NodeRPCResponse, error)
func GetRaftStatusRPC ¶
func GetRaftStatusRPC(node string) (*model.RaftStatusRPCResponse, error)
func GetXtrabackupGTIDPurged ¶
func KillMysqldRPC ¶
func MysqlIsWorkingRPC ¶
func MysqlResetMasterRPC ¶
func MysqlResetMasterRPC(node string) (*model.MysqlRPCResponse, error)
func MysqlResetSlaveAllRPC ¶
func MysqlResetSlaveAllRPC(node string) (*model.MysqlRPCResponse, error)
func MysqlStartSlaveRPC ¶
func MysqlStartSlaveRPC(node string) (*model.MysqlRPCResponse, error)
func MysqlStopSlaveRPC ¶
func MysqlStopSlaveRPC(node string) (*model.MysqlRPCResponse, error)
func MysqldIsRunningRPC ¶
func PrintQueryOutput ¶
func RemoveNodeRPC ¶
func RequestBackupRPC ¶
func ServerStatusRPC ¶
func ServerStatusRPC(node string) (*model.ServerRPCResponse, error)
func SetGlobalVarRPC ¶
func SetGlobalVarRPC(node string, varsql string) (*model.MysqlVarRPCResponse, error)
func ShutdownMysqldRPC ¶
func StartMonitorRPC ¶
func StartMonitorRPC(node string) (*model.MysqldRPCResponse, error)
func StartMysqldRPC ¶
func TryToLeaderRPC ¶
func TryToLeaderRPC(node string) (*model.HARPCResponse, error)
func WaitMysqldRunningRPC ¶
func WaitMysqldShutdownRPC ¶
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.