mysql

package
v1.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 23, 2018 License: GPL-3.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// MysqlAlive enum.
	MysqlAlive State = "ALIVE"
	// MysqlDead enum.
	MysqlDead State = "DEAD"

	// MysqlReadonly enum.
	MysqlReadonly Option = "READONLY"
	// MysqlReadwrite enum.
	MysqlReadwrite Option = "READWRITE"
)

Variables

This section is empty.

Functions

func ChangeMasterToError 

func ChangeMasterToError(db *sql.DB, gtid *model.Repl) error

ChangeMasterToError mock.

func ChangeToMasterError 

func ChangeToMasterError(db *sql.DB) error

ChangeToMasterError mock.

func DefaultChangeMasterTo 

func DefaultChangeMasterTo(db *sql.DB, gtid *model.Repl) error

DefaultChangeMasterTo mock.

func DefaultChangeToMaster 

func DefaultChangeToMaster(db *sql.DB) error

DefaultChangeToMaster mock.

func DefaultDisableSemiSyncMaster 

func DefaultDisableSemiSyncMaster(db *sql.DB) error

DefaultDisableSemiSyncMaster mock.

func DefaultEnableSemiSyncMaster 

func DefaultEnableSemiSyncMaster(db *sql.DB) error

DefaultEnableSemiSyncMaster mock.

func DefaultGetMasterGTID 

func DefaultGetMasterGTID(db *sql.DB) (*model.GTID, error)

DefaultGetMasterGTID mock.

func DefaultGetSlaveGTID 

func DefaultGetSlaveGTID(db *sql.DB) (*model.GTID, error)

DefaultGetSlaveGTID returns the default slave gtid.

func DefaultPurgeBinlogsTo 

func DefaultPurgeBinlogsTo(db *sql.DB, binlog string) error

DefaultPurgeBinlogsTo mock.

func DefaultResetMaster 

func DefaultResetMaster(db *sql.DB) error

DefaultResetMaster mock.

func DefaultResetSlaveAll 

func DefaultResetSlaveAll(db *sql.DB) error

DefaultResetSlaveAll mock.

func DefaultSelectSysVar 

func DefaultSelectSysVar(db *sql.DB, query string) (string, error)

DefaultSelectSysVar mock.

func DefaultSetGlobalSysVar 

func DefaultSetGlobalSysVar(db *sql.DB, varsql string) error

DefaultSetGlobalSysVar mock.

func DefaultSetReadOnly 

func DefaultSetReadOnly(db *sql.DB, readonly bool) error

DefaultSetReadOnly mock.

func DefaultSetSemiWaitSlaveCount 

func DefaultSetSemiWaitSlaveCount(db *sql.DB, count int) error

DefaultSetSemiWaitSlaveCount mock.

func DefaultStartSlave 

func DefaultStartSlave(db *sql.DB) error

DefaultStartSlave mock.

func DefaultStartSlaveIOThread 

func DefaultStartSlaveIOThread(db *sql.DB) error

DefaultStartSlaveIOThread mock.

func DefaultStopSlave 

func DefaultStopSlave(db *sql.DB) error

DefaultStopSlave mock.

func DefaultStopSlaveIOThread 

func DefaultStopSlaveIOThread(db *sql.DB) error

DefaultStopSlaveIOThread mock.

func DefaultWaitUntilAfterGTID 

func DefaultWaitUntilAfterGTID(db *sql.DB, targetGTID string) error

DefaultWaitUntilAfterGTID mock.

func Execute 

func Execute(db *sql.DB, query string, args ...interface{}) error

Execute executes a query without returning any rows

func ExecuteSuperQueryList 

func ExecuteSuperQueryList(db *sql.DB, queryList []string) error

ExecuteSuperQueryList alows the user to execute queries as a super user.

func ExecuteSuperQueryListWithTimeout 

func ExecuteSuperQueryListWithTimeout(db *sql.DB, maxTime int, queryList []string) error

ExecuteSuperQueryListWithTimeout alows the user to execute queries as a super user.

func ExecuteWithTimeout 

func ExecuteWithTimeout(db *sql.DB, maxTime int, query string, args ...interface{}) error

ExecuteWithTimeout executes a query without returning any rows.

func GetMasterGTIDA 

func GetMasterGTIDA(db *sql.DB) (*model.GTID, error)

GetMasterGTIDA mock.

func GetMasterGTIDB 

func GetMasterGTIDB(db *sql.DB) (*model.GTID, error)

GetMasterGTIDB mock.

func GetMasterGTIDC 

func GetMasterGTIDC(db *sql.DB) (*model.GTID, error)

GetMasterGTIDC mock.

func GetMasterGTIDD 

func GetMasterGTIDD(db *sql.DB) (*model.GTID, error)

GetMasterGTIDD mock.

func GetMasterGTIDError 

func GetMasterGTIDError(db *sql.DB) (*model.GTID, error)

GetMasterGTIDError mock.

func GetMasterGTIDPingError 

func GetMasterGTIDPingError(db *sql.DB) (*model.GTID, error)

GetMasterGTIDPingError mock.

func GetSlaveGTIDA 

func GetSlaveGTIDA(db *sql.DB) (*model.GTID, error)

GetSlaveGTIDA mock. with GTID{Master_Log_File = "", Read_Master_Log_Pos = 0} all functions return is OK

func GetSlaveGTIDB 

func GetSlaveGTIDB(db *sql.DB) (*model.GTID, error)

GetSlaveGTIDB mock.

func GetSlaveGTIDC 

func GetSlaveGTIDC(db *sql.DB) (*model.GTID, error)

GetSlaveGTIDC mock.

func GetSlaveGTIDError 

func GetSlaveGTIDError(db *sql.DB) (*model.GTID, error)

GetSlaveGTIDError mock.

func GetSlaveGTIDX1 

func GetSlaveGTIDX1(db *sql.DB) (*model.GTID, error)

GetSlaveGTIDX1 mock.

func GetSlaveGTIDX3 

func GetSlaveGTIDX3(db *sql.DB) (*model.GTID, error)

GetSlaveGTIDX3 mock.

func GetSlaveGTIDX5 

func GetSlaveGTIDX5(db *sql.DB) (*model.GTID, error)

GetSlaveGTIDX5 mock.

func MockGetClient 

func MockGetClient(t *testing.T, svrConn string) (*xrpc.Client, func())

MockGetClient mock.

func Query 

func Query(db *sql.DB, query string, args ...interface{}) ([]map[string]string, error)

Query executes a query that returns rows

func QueryWithTimeout 

func QueryWithTimeout(db *sql.DB, maxTime int, query string, args ...interface{}) ([]map[string]string, error)

QueryWithTimeout used to execute the query with maxTime.

func SetReadOnlyError 

func SetReadOnlyError(db *sql.DB, readonly bool) error

SetReadOnlyError mock.

func StartSlaveError 

func StartSlaveError(db *sql.DB) error

StartSlaveError mock.

func StartSlaveIOThreadError 

func StartSlaveIOThreadError(db *sql.DB) error

StartSlaveIOThreadError mock.

func StopSlaveError 

func StopSlaveError(db *sql.DB) error

StopSlaveError mock.

func StopSlaveIOThreadError 

func StopSlaveIOThreadError(db *sql.DB) error

StopSlaveIOThreadError mock.

func WaitUntilAfterGTIDError 

func WaitUntilAfterGTIDError(db *sql.DB, targetGTID string) error

WaitUntilAfterGTIDError mock.

Types

type MockGTID 

type MockGTID struct {
	PingFn                  func(*sql.DB) (*PingEntry, error)
	SetReadOnlyFn           func(*sql.DB, bool) error
	GetMasterGTIDFn         func(*sql.DB) (*model.GTID, error)
	GetSlaveGTIDFn          func(*sql.DB) (*model.GTID, error)
	StartSlaveIOThreadFn    func(*sql.DB) error
	StopSlaveIOThreadFn     func(*sql.DB) error
	StartSlaveFn            func(*sql.DB) error
	StopSlaveFn             func(*sql.DB) error
	ChangeMasterToFn        func(*sql.DB, *model.Repl) error
	ChangeToMasterFn        func(*sql.DB) error
	WaitUntilAfterGTIDFn    func(*sql.DB, string) error
	SetGlobalSysVarFn       func(*sql.DB, string) error
	ResetMasterFn           func(*sql.DB) error
	ResetSlaveAllFn         func(*sql.DB) error
	PurgeBinlogsToFn        func(*sql.DB, string) error
	EnableSemiSyncMasterFn  func(*sql.DB) error
	DisableSemiSyncMasterFn func(*sql.DB) error
	SelectSysVarFn          func(*sql.DB, string) (string, error)
	SetSemiWaitSlaveCountFn func(*sql.DB, int) error
}

MockGTID tuple.

func NewMockGTIDA 

func NewMockGTIDA() *MockGTID

NewMockGTIDA mock.

func NewMockGTIDB 

func NewMockGTIDB() *MockGTID

NewMockGTIDB mock. with GTID{Master_Log_File = "mysql-bin.000001", Read_Master_Log_Pos = 123} all functions return is OK

func NewMockGTIDC 

func NewMockGTIDC() *MockGTID

NewMockGTIDC mock. with GTID{Master_Log_File = "mysql-bin.000001", Read_Master_Log_Pos = 124} all functions return is OK

func NewMockGTIDD 

func NewMockGTIDD() *MockGTID

NewMockGTIDD mock.

func NewMockGTIDError 

func NewMockGTIDError() *MockGTID

NewMockGTIDError mock. mock GetSlaveGTID returns error mock GetMasterGTID returns error

func NewMockGTIDPingError 

func NewMockGTIDPingError() *MockGTID

NewMockGTIDPingError mock. mock Ping returns error

func NewMockGTIDX1 

func NewMockGTIDX1() *MockGTID

NewMockGTIDX1 mock. with GTID{Master_Log_File = "mysql-bin.000001", Read_Master_Log_Pos = 123} all functions return is OK

func NewMockGTIDX3 

func NewMockGTIDX3() *MockGTID

NewMockGTIDX3 mock. with GTID{Master_Log_File = "mysql-bin.000003", Read_Master_Log_Pos = 123} all functions return is OK

func NewMockGTIDX5 

func NewMockGTIDX5() *MockGTID

NewMockGTIDX5 mock. with GTID{Master_Log_File = "mysql-bin.000005", Read_Master_Log_Pos = 123} all functions return is OK

func (*MockGTID) ChangeMasterTo 

func (mogtid *MockGTID) ChangeMasterTo(db *sql.DB, gtid *model.Repl) error

ChangeMasterTo mock.

func (*MockGTID) ChangeToMaster 

func (mogtid *MockGTID) ChangeToMaster(db *sql.DB) error

ChangeToMaster mock.

func (*MockGTID) DisableSemiSyncMaster 

func (mogtid *MockGTID) DisableSemiSyncMaster(db *sql.DB) error

DisableSemiSyncMaster mock.

func (*MockGTID) EnableSemiSyncMaster 

func (mogtid *MockGTID) EnableSemiSyncMaster(db *sql.DB) error

EnableSemiSyncMaster mock.

func (*MockGTID) GetMasterGTID 

func (mogtid *MockGTID) GetMasterGTID(db *sql.DB) (*model.GTID, error)

GetMasterGTID mock.

func (*MockGTID) GetSlaveGTID 

func (mogtid *MockGTID) GetSlaveGTID(db *sql.DB) (*model.GTID, error)

GetSlaveGTID mock.

func (*MockGTID) Ping 

func (mogtid *MockGTID) Ping(db *sql.DB) (*PingEntry, error)

Ping mock.

func (*MockGTID) PurgeBinlogsTo 

func (mogtid *MockGTID) PurgeBinlogsTo(db *sql.DB, binlog string) error

PurgeBinlogsTo mock.

func (*MockGTID) ResetMaster 

func (mogtid *MockGTID) ResetMaster(db *sql.DB) error

ResetMaster mock.

func (*MockGTID) ResetSlaveAll 

func (mogtid *MockGTID) ResetSlaveAll(db *sql.DB) error

ResetSlaveAll mock.

func (*MockGTID) SelectSysVar 

func (mogtid *MockGTID) SelectSysVar(db *sql.DB, query string) (string, error)

SelectSysVar mock.

func (*MockGTID) SetGlobalSysVar 

func (mogtid *MockGTID) SetGlobalSysVar(db *sql.DB, varsql string) error

SetGlobalSysVar mock.

func (*MockGTID) SetReadOnly 

func (mogtid *MockGTID) SetReadOnly(db *sql.DB, readonly bool) error

SetReadOnly mock.

func (*MockGTID) SetSemiWaitSlaveCount 

func (mogtid *MockGTID) SetSemiWaitSlaveCount(db *sql.DB, count int) error

SetSemiWaitSlaveCount mock

func (*MockGTID) StartSlave 

func (mogtid *MockGTID) StartSlave(db *sql.DB) error

StartSlave mock.

func (*MockGTID) StartSlaveIOThread 

func (mogtid *MockGTID) StartSlaveIOThread(db *sql.DB) error

StartSlaveIOThread mock.

func (*MockGTID) StopSlave 

func (mogtid *MockGTID) StopSlave(db *sql.DB) error

StopSlave mock.

func (*MockGTID) StopSlaveIOThread 

func (mogtid *MockGTID) StopSlaveIOThread(db *sql.DB) error

StopSlaveIOThread mock.

func (*MockGTID) WaitUntilAfterGTID 

func (mogtid *MockGTID) WaitUntilAfterGTID(db *sql.DB, targetGTID string) error

WaitUntilAfterGTID mock.

type MockUserA 

type MockUserA struct {
	UserHandler
}

MockUserA tuple.

func (*MockUserA) ChangeUserPasswd 

func (u *MockUserA) ChangeUserPasswd(db *sql.DB, user string, passwd string) error

ChangeUserPasswd mock.

func (*MockUserA) CheckUserExists 

func (u *MockUserA) CheckUserExists(db *sql.DB, user string) (bool, error)

CheckUserExists mock.

func (*MockUserA) CreateReplUserWithoutBinlog 

func (u *MockUserA) CreateReplUserWithoutBinlog(db *sql.DB, user string, passwd string) error

CreateReplUserWithoutBinlog mock.

func (*MockUserA) CreateUser 

func (u *MockUserA) CreateUser(db *sql.DB, user string, passwd string) error

CreateUser mock.

func (*MockUserA) CreateUserWithPrivileges 

func (u *MockUserA) CreateUserWithPrivileges(db *sql.DB, user, passwd, database, table, host, privs string, ssl string) error

CreateUserWithPrivileges mock.

func (*MockUserA) DropUser 

func (u *MockUserA) DropUser(db *sql.DB, user string, host string) error

DropUser mock.

func (*MockUserA) GetUser 

func (u *MockUserA) GetUser(db *sql.DB) ([]model.MysqlUser, error)

GetUser mock.

func (*MockUserA) GrantAllPrivileges 

func (u *MockUserA) GrantAllPrivileges(db *sql.DB, user string) error

GrantAllPrivileges mock.

func (*MockUserA) GrantNormalPrivileges 

func (u *MockUserA) GrantNormalPrivileges(db *sql.DB, user string) error

GrantNormalPrivileges mock.

func (*MockUserA) GrantReplicationPrivileges 

func (u *MockUserA) GrantReplicationPrivileges(db *sql.DB, user string) error

GrantReplicationPrivileges mock.

type Mysql 

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

Mysql tuple.

func MockMysql 

func MockMysql(log *xlog.Log, port int, h ReplHandler) (string, *Mysql, func())

MockMysql mock.

func MockMysqlReplUser added in v1.0.2 

func MockMysqlReplUser(log *xlog.Log, port int, h ReplHandler) (string, *Mysql, func())

MockMysqlReplUser mock.

func NewMysql 

func NewMysql(conf *config.MysqlConfig, log *xlog.Log) *Mysql

NewMysql creates the new Mysql.

func (*Mysql) ChangeMasterTo 

func (m *Mysql) ChangeMasterTo(repl *model.Repl) error

ChangeMasterTo used to do the 'change master to' command.

func (*Mysql) ChangeToMaster 

func (m *Mysql) ChangeToMaster() error

ChangeToMaster used to do the 'reset slave all' command.

func (*Mysql) ChangeUserPasswd 

func (m *Mysql) ChangeUserPasswd(user string, passwd string) error

ChangeUserPasswd used to change the user's password.

func (*Mysql) CheckUserExists 

func (m *Mysql) CheckUserExists(user string) (bool, error)

CheckUserExists used to check the user exists or not.

func (*Mysql) CreateReplUserWithoutBinlog 

func (m *Mysql) CreateReplUserWithoutBinlog(user string, passwd string) error

CreateReplUserWithoutBinlog used to create a repl user without binlog.

func (*Mysql) CreateUser 

func (m *Mysql) CreateUser(user string, passwd string) error

CreateUser used to create the new user.

func (*Mysql) CreateUserWithPrivileges 

func (m *Mysql) CreateUserWithPrivileges(user, passwd, database, table, host, privs string, ssl string) error

CreateUserWithPrivileges used to create a new user with grants.

func (*Mysql) DisableSemiSyncMaster 

func (m *Mysql) DisableSemiSyncMaster() error

DisableSemiSyncMaster used to disable the semi-sync from master.

func (*Mysql) DropUser 

func (m *Mysql) DropUser(user string, host string) error

DropUser used to drop a user.

func (*Mysql) EnableSemiSyncMaster 

func (m *Mysql) EnableSemiSyncMaster() error

EnableSemiSyncMaster used to enable the semi-sync on master.

func (*Mysql) GTIDGreaterThan 

func (m *Mysql) GTIDGreaterThan(gtid *model.GTID) (bool, model.GTID, error)

GTIDGreaterThan used to compare the master_log_file and read_master_log_pos between from and this.

func (*Mysql) GetGTID 

func (m *Mysql) GetGTID() (model.GTID, error)

GetGTID returns the mysql master_binlog and read_master_log_pos. 1. first try GetSlaveGTID 2. if STEP1) fails, try GetMasterGTID

func (*Mysql) GetMasterGTID 

func (m *Mysql) GetMasterGTID() (*model.GTID, error)

GetMasterGTID used to get master binlog info.

func (*Mysql) GetMysqlRPC 

func (m *Mysql) GetMysqlRPC() *MysqlRPC

GetMysqlRPC returns the MysqlRPC.

func (*Mysql) GetOption 

func (m *Mysql) GetOption() Option

GetOption returns the mysql option.

func (*Mysql) GetRepl 

func (m *Mysql) GetRepl() model.Repl

GetRepl returns the repl info.

func (*Mysql) GetSlaveGTID 

func (m *Mysql) GetSlaveGTID() (*model.GTID, error)

GetSlaveGTID used to get Relay_Master_Log_File and read_master_binlog_pos.

func (*Mysql) GetState 

func (m *Mysql) GetState() State

GetState returns the mysql state.

func (*Mysql) GetUser 

func (m *Mysql) GetUser() ([]model.MysqlUser, error)

GetUser used to get the mysql user list.

func (*Mysql) GrantAllPrivileges 

func (m *Mysql) GrantAllPrivileges(user string) error

GrantAllPrivileges used to grants all privs for the user.

func (*Mysql) GrantNormalPrivileges 

func (m *Mysql) GrantNormalPrivileges(user string) error

GrantNormalPrivileges used grant normal privs.

func (*Mysql) GrantReplicationPrivileges 

func (m *Mysql) GrantReplicationPrivileges(user string) error

GrantReplicationPrivileges used to grant replication privs.

func (*Mysql) IncMysqlDowns 

func (s *Mysql) IncMysqlDowns()

IncMysqlDowns used to increase the mysql down counter.

func (*Mysql) Ping 

func (m *Mysql) Ping()

Ping used to get the master binlog every ping.

func (*Mysql) PingStart 

func (m *Mysql) PingStart()

PingStart used to start the ping.

func (*Mysql) PingStop 

func (m *Mysql) PingStop()

PingStop used to stop the ping.

func (*Mysql) Promotable 

func (m *Mysql) Promotable() bool

Promotable used to check whether we can promote to candidate. Promotable: 1. MySQL is MysqlAlive 2. Slave_SQL_Running

NOTES: we do not consider Slave_IO_Running to Promotable, because the MySQL of leader maybe down the slaves Slave_IO_Running is false, because it's in connecting state

func (*Mysql) PurgeBinlogsTo 

func (m *Mysql) PurgeBinlogsTo(binlog string) error

PurgeBinlogsTo used to purge binlog.

func (*Mysql) RelayMasterLogFile 

func (m *Mysql) RelayMasterLogFile() string

RelayMasterLogFile returns RelayMasterLogFile.

func (*Mysql) ResetMaster 

func (m *Mysql) ResetMaster() error

ResetMaster used to reset master.

func (*Mysql) ResetSlaveAll 

func (m *Mysql) ResetSlaveAll() error

ResetSlaveAll used to reset slave.

func (*Mysql) SetGlobalSysVar 

func (m *Mysql) SetGlobalSysVar(varsql string) error

SetGlobalSysVar used to set global variables.

func (*Mysql) SetMasterGlobalSysVar 

func (m *Mysql) SetMasterGlobalSysVar() error

SetMasterGlobalSysVar used to set master global variables.

func (*Mysql) SetReadOnly 

func (m *Mysql) SetReadOnly() (err error)

SetReadOnly used to set the mysql to readonly.

func (*Mysql) SetReadWrite 

func (m *Mysql) SetReadWrite() (err error)

SetReadWrite used to set the mysql to write.

func (*Mysql) SetReplHandler 

func (m *Mysql) SetReplHandler(h ReplHandler)

SetReplHandler used to set the repl handler.

func (*Mysql) SetSemiWaitSlaveCount 

func (m *Mysql) SetSemiWaitSlaveCount(count int) error

SetSemiWaitSlaveCount used to set rpl_semi_sync_master_wait_for_slave_count

func (*Mysql) SetSlaveGlobalSysVar 

func (m *Mysql) SetSlaveGlobalSysVar() error

SetSlaveGlobalSysVar used to set slave global variables.

func (*Mysql) SetUserHandler 

func (m *Mysql) SetUserHandler(h UserHandler)

SetUserHandler used to set the user handler.

func (*Mysql) StartSlave 

func (m *Mysql) StartSlave() error

StartSlave used to start the slave.

func (*Mysql) StartSlaveIOThread 

func (m *Mysql) StartSlaveIOThread() error

StartSlaveIOThread used to start the slave io thread.

func (*Mysql) StopSlave 

func (m *Mysql) StopSlave() error

StopSlave used to stop the slave.

func (*Mysql) StopSlaveIOThread 

func (m *Mysql) StopSlaveIOThread() error

StopSlaveIOThread used to stop the slave io thread.

func (*Mysql) WaitMysqlWorks 

func (m *Mysql) WaitMysqlWorks(timeout int) error

WaitMysqlWorks used to wait for the mysqld to work.

func (*Mysql) WaitUntilAfterGTID 

func (m *Mysql) WaitUntilAfterGTID(targetGTID string) error

WaitUntilAfterGTID used to do 'SELECT WAIT_UNTIL_SQL_THREAD_AFTER_GTIDS' command.

type Mysql57 

type Mysql57 struct {
	ReplHandler
}

Mysql57 tuple.

func (*Mysql57) ChangeMasterTo 

func (my *Mysql57) ChangeMasterTo(db *sql.DB, master *model.Repl) error

ChangeMasterTo stop for all channels and reset all replication filter to null. In Xenon, we never set replication filter.

func (*Mysql57) ChangeToMaster 

func (my *Mysql57) ChangeToMaster(db *sql.DB) error

ChangeToMaster changes a slave to be master.

func (*Mysql57) DisableSemiSyncMaster 

func (my *Mysql57) DisableSemiSyncMaster(db *sql.DB) error

DisableSemiSyncMaster used to disable the semi-sync from master.

func (*Mysql57) EnableSemiSyncMaster 

func (my *Mysql57) EnableSemiSyncMaster(db *sql.DB) error

EnableSemiSyncMaster used to enable the semi-sync on master.

func (*Mysql57) GetMasterGTID 

func (my *Mysql57) GetMasterGTID(db *sql.DB) (*model.GTID, error)

GetMasterGTID used to get binlog info from master.

func (*Mysql57) GetSlaveGTID 

func (my *Mysql57) GetSlaveGTID(db *sql.DB) (*model.GTID, error)

GetSlaveGTID gets the gtid from the default channel. Here, We just show the default slave channel.

func (*Mysql57) Ping 

func (my *Mysql57) Ping(db *sql.DB) (*PingEntry, error)

Ping has 2 affects: one for heath check other for get master_binglog the slave is syncing

func (*Mysql57) PurgeBinlogsTo 

func (my *Mysql57) PurgeBinlogsTo(db *sql.DB, binlog string) error

PurgeBinlogsTo used to purge binlog.

func (*Mysql57) ResetMaster 

func (my *Mysql57) ResetMaster(db *sql.DB) error

ResetMaster used to reset master.

func (*Mysql57) ResetSlaveAll 

func (my *Mysql57) ResetSlaveAll(db *sql.DB) error

ResetSlaveAll used to reset slave.

func (*Mysql57) SetGlobalSysVar 

func (my *Mysql57) SetGlobalSysVar(db *sql.DB, varsql string) error

SetGlobalSysVar used to set global variables.

func (*Mysql57) SetReadOnly 

func (my *Mysql57) SetReadOnly(db *sql.DB, readonly bool) error

SetReadOnly used to set mysql to readonly.

func (*Mysql57) SetSemiWaitSlaveCount 

func (my *Mysql57) SetSemiWaitSlaveCount(db *sql.DB, count int) error

SetSemiWaitSlaveCount used set rpl_semi_sync_master_wait_for_slave_count

func (*Mysql57) StartSlave 

func (my *Mysql57) StartSlave(db *sql.DB) error

StartSlave used to start slave.

func (*Mysql57) StartSlaveIOThread 

func (my *Mysql57) StartSlaveIOThread(db *sql.DB) error

StartSlaveIOThread used to start the io thread.

func (*Mysql57) StopSlave 

func (my *Mysql57) StopSlave(db *sql.DB) error

StopSlave used to stop the slave.

func (*Mysql57) StopSlaveIOThread 

func (my *Mysql57) StopSlaveIOThread(db *sql.DB) error

StopSlaveIOThread used to stop the op thread.

func (*Mysql57) WaitUntilAfterGTID 

func (my *Mysql57) WaitUntilAfterGTID(db *sql.DB, targetGTID string) error

WaitUntilAfterGTID used to do 'SELECT WAIT_UNTIL_SQL_THREAD_AFTER_GTIDS' command. https://dev.mysql.com/doc/refman/5.7/en/gtid-functions.html

type MysqlRPC 

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

MysqlRPC tuple.

func (*MysqlRPC) ChangeToMaster 

func (m *MysqlRPC) ChangeToMaster(req *model.MysqlRPCRequest, rsp *model.MysqlRPCResponse) error

ChangeToMaster used to do 'reset slave all' command.

func (*MysqlRPC) IsWorking 

func (m *MysqlRPC) IsWorking(req *model.MysqlRPCRequest, rsp *model.MysqlRPCResponse) error

IsWorking used to check the mysql works or not.

func (*MysqlRPC) ResetMaster 

func (m *MysqlRPC) ResetMaster(req *model.MysqlRPCRequest, rsp *model.MysqlRPCResponse) error

ResetMaster used to reset master.

func (*MysqlRPC) ResetSlaveAll 

func (m *MysqlRPC) ResetSlaveAll(req *model.MysqlRPCRequest, rsp *model.MysqlRPCResponse) error

ResetSlaveAll used to reset slave.

func (*MysqlRPC) SetGlobalSysVar 

func (m *MysqlRPC) SetGlobalSysVar(req *model.MysqlVarRPCRequest, rsp *model.MysqlVarRPCResponse) error

SetGlobalSysVar used to set global vars.

func (*MysqlRPC) StartSlave 

func (m *MysqlRPC) StartSlave(req *model.MysqlRPCRequest, rsp *model.MysqlRPCResponse) error

StartSlave used to start the slave.

func (*MysqlRPC) Status 

func (m *MysqlRPC) Status(req *model.MysqlStatusRPCRequest, rsp *model.MysqlStatusRPCResponse) error

Status returns the mysql GTID info.

func (*MysqlRPC) StopSlave 

func (m *MysqlRPC) StopSlave(req *model.MysqlRPCRequest, rsp *model.MysqlRPCResponse) error

StopSlave used to stop the slave.

type Option 

type Option string

Option enum.

type PingEntry 

type PingEntry struct {
	Relay_Master_Log_File string
}

PingEntry tuple.

func DefaultPing 

func DefaultPing(db *sql.DB) (*PingEntry, error)

DefaultPing mock.

func PingError1 

func PingError1(db *sql.DB) (*PingEntry, error)

PingError1 mock.

func PingError2 

func PingError2(db *sql.DB) (*PingEntry, error)

PingError2 mock.

func PingX1 

func PingX1(db *sql.DB) (*PingEntry, error)

PingX1 mock.

func PingX3 

func PingX3(db *sql.DB) (*PingEntry, error)

PingX3 mock.

func PingX5 

func PingX5(db *sql.DB) (*PingEntry, error)

PingX5 mock.

type ReplHandler 

type ReplHandler interface {
	// check health and return log_bin_basename
	Ping(*sql.DB) (*PingEntry, error)

	// set mysql readonly variable
	SetReadOnly(*sql.DB, bool) error

	// get GTID from traversal binlog folder and find the newest one
	GetMasterGTID(*sql.DB) (*model.GTID, error)

	// get GTID from SHOW SLAVE STATUS
	GetSlaveGTID(*sql.DB) (*model.GTID, error)

	// start slave io_thread
	StartSlaveIOThread(*sql.DB) error

	// stop slave io_thread
	StopSlaveIOThread(*sql.DB) error

	// start slave
	StartSlave(*sql.DB) error

	// stop slave
	StopSlave(*sql.DB) error

	// use the provided master as the new master
	ChangeMasterTo(*sql.DB, *model.Repl) error

	// change a slave to master
	ChangeToMaster(*sql.DB) error

	// waits until slave replication reaches at least targetGTID
	WaitUntilAfterGTID(*sql.DB, string) error

	// set global variables
	SetGlobalSysVar(db *sql.DB, varsql string) error

	// reset master
	ResetMaster(db *sql.DB) error

	// reset slave all
	ResetSlaveAll(db *sql.DB) error

	// purge binglog to
	PurgeBinlogsTo(*sql.DB, string) error

	// enable master semi sync: wait slave ack
	EnableSemiSyncMaster(db *sql.DB) error

	// disable master semi sync: don't wait slave ack
	DisableSemiSyncMaster(db *sql.DB) error

	//set rpl_semi_master_wait_for_slave_count
	SetSemiWaitSlaveCount(db *sql.DB, count int) error
}

ReplHandler interface.

type State 

type State string

State enum.

type User 

type User struct {
	UserHandler
}

User tuple.

func (*User) ChangeUserPasswd 

func (u *User) ChangeUserPasswd(db *sql.DB, user string, passwd string) error

ChangeUserPasswd used to change the user password.

func (*User) CheckUserExists 

func (u *User) CheckUserExists(db *sql.DB, user string) (bool, error)

CheckUserExists used to check the user exists or not.

func (*User) CreateReplUserWithoutBinlog 

func (u *User) CreateReplUserWithoutBinlog(db *sql.DB, user string, passwd string) error

CreateReplUserWithoutBinlog create replication accounts without writing binlog.

func (*User) CreateUser 

func (u *User) CreateUser(db *sql.DB, user string, passwd string) error

CreateUser use to create new user. see http://dev.mysql.com/doc/refman/5.7/en/string-literals.html

func (*User) CreateUserWithPrivileges 

func (u *User) CreateUserWithPrivileges(db *sql.DB, user, passwd, database, table, host, privs string, ssl string) error

CreateUserWithPrivileges for create normal user.

func (*User) DropUser 

func (u *User) DropUser(db *sql.DB, user string, host string) error

DropUser used to drop the user.

func (*User) GetUser 

func (u *User) GetUser(db *sql.DB) ([]model.MysqlUser, error)

GetUser used to get the mysql user list

func (*User) GrantAllPrivileges 

func (u *User) GrantAllPrivileges(db *sql.DB, user string) error

GrantAllPrivileges used to grant all privis.

func (*User) GrantNormalPrivileges 

func (u *User) GrantNormalPrivileges(db *sql.DB, user string) error

GrantNormalPrivileges used to grants normal privileges.

func (*User) GrantReplicationPrivileges 

func (u *User) GrantReplicationPrivileges(db *sql.DB, user string) error

GrantReplicationPrivileges used to grant repli privis.

type UserHandler 

type UserHandler interface {
	GetUser(*sql.DB) ([]model.MysqlUser, error)
	CheckUserExists(*sql.DB, string) (bool, error)
	CreateUser(*sql.DB, string, string) error
	DropUser(*sql.DB, string, string) error
	ChangeUserPasswd(*sql.DB, string, string) error
	CreateReplUserWithoutBinlog(*sql.DB, string, string) error
	GrantAllPrivileges(*sql.DB, string) error
	GrantNormalPrivileges(*sql.DB, string) error
	CreateUserWithPrivileges(db *sql.DB, user, passwd, database, table, host, privs string, ssl string) error
	GrantReplicationPrivileges(*sql.DB, string) error
}

UserHandler interface.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.