mysql

package

Go to main page

Versions in this module

v1

v1.0.5

Jan 18, 2019

Changes in this version

+ func DefaultChangeUserPasswd(db *sql.DB, user string, passwd string) error

+ func DefaultCheckUserExists(db *sql.DB, user string) (bool, error)

+ func DefaultCreateReplUserWithoutBinlog(db *sql.DB, user string, passwd string) error

+ func DefaultCreateUser(db *sql.DB, user string, passwd string) error

+ func DefaultCreateUserWithPrivileges(db *sql.DB, user, passwd, database, table, host, privs string, ssl string) error

+ func DefaultDropUser(db *sql.DB, user string, host string) error

+ func DefaultGetUser(db *sql.DB) ([]model.MysqlUser, error)

+ func DefaultGrantAllPrivileges(db *sql.DB, user string) error

+ func DefaultGrantNormalPrivileges(db *sql.DB, user string) error

+ func DefaultGrantReplicationPrivileges(db *sql.DB, user string) error

type MockGTID

+ ChangeUserPasswdFn func(*sql.DB, string, string) error

+ CheckUserExistsFn func(*sql.DB, string) (bool, error)

+ CreateReplUserWithoutBinlogFn func(*sql.DB, string, string) error

+ CreateUserFn func(*sql.DB, string, string) error

+ CreateUserWithPrivilegesFn func(*sql.DB, string, string, string, string, string, string, string) error

+ DropUserFn func(*sql.DB, string, string) error

+ GetUserFn func(*sql.DB) ([]model.MysqlUser, error)

+ GrantAllPrivilegesFn func(*sql.DB, string) error

+ GrantNormalPrivilegesFn func(*sql.DB, string) error

+ GrantReplicationPrivilegesFn func(*sql.DB, string) error

+ func (mogtid *MockGTID) ChangeUserPasswd(db *sql.DB, user string, passwd string) error

+ func (mogtid *MockGTID) CheckUserExists(db *sql.DB, query string) (bool, error)

+ func (mogtid *MockGTID) CreateReplUserWithoutBinlog(db *sql.DB, user string, passwd string) error

+ func (mogtid *MockGTID) CreateUser(db *sql.DB, user string, passwd string) error

+ func (mogtid *MockGTID) CreateUserWithPrivileges(db *sql.DB, user, passwd, database, table, host, privs string, ssl string) error

+ func (mogtid *MockGTID) DropUser(db *sql.DB, user string, host string) error

+ func (mogtid *MockGTID) GetUser(db *sql.DB) ([]model.MysqlUser, error)

+ func (mogtid *MockGTID) GrantAllPrivileges(db *sql.DB, user string) error

+ func (mogtid *MockGTID) GrantNormalPrivileges(db *sql.DB, user string) error

+ func (mogtid *MockGTID) GrantReplicationPrivileges(db *sql.DB, user string) error

type Mysql

+ func (m *Mysql) SetMysqlHandler(h MysqlHandler)

+ type Mysql56 struct

+ func (my *Mysql56) ChangeUserPasswd(db *sql.DB, user string, passwd string) error

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

+ type MysqlBase struct

+ func (my *MysqlBase) Change56UserPasswd(db *sql.DB, user string, passwd string) error

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

+ func (my *MysqlBase) ChangeToMaster(db *sql.DB) error

+ func (my *MysqlBase) ChangeUserPasswd(db *sql.DB, user string, passwd string) error

+ func (my *MysqlBase) CheckUserExists(db *sql.DB, user string) (bool, error)

+ func (my *MysqlBase) CreateReplUserWithoutBinlog(db *sql.DB, user string, passwd string) error

+ func (my *MysqlBase) CreateUser(db *sql.DB, user string, passwd string) error

+ func (my *MysqlBase) CreateUserWithPrivileges(db *sql.DB, user, passwd, database, table, host, privs string, ssl string) error

+ func (my *MysqlBase) DisableSemiSyncMaster(db *sql.DB) error

+ func (my *MysqlBase) DropUser(db *sql.DB, user string, host string) error

+ func (my *MysqlBase) EnableSemiSyncMaster(db *sql.DB) error

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

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

+ func (my *MysqlBase) GetUser(db *sql.DB) ([]model.MysqlUser, error)

+ func (my *MysqlBase) GrantAllPrivileges(db *sql.DB, user string) error

+ func (my *MysqlBase) GrantNormalPrivileges(db *sql.DB, user string) error

+ func (my *MysqlBase) GrantReplicationPrivileges(db *sql.DB, user string) error

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

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

+ func (my *MysqlBase) ResetMaster(db *sql.DB) error

+ func (my *MysqlBase) ResetSlaveAll(db *sql.DB) error

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

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

+ func (my *MysqlBase) SetSemiSyncMasterDefault(db *sql.DB) error

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

+ func (my *MysqlBase) StartSlave(db *sql.DB) error

+ func (my *MysqlBase) StartSlaveIOThread(db *sql.DB) error

+ func (my *MysqlBase) StopSlave(db *sql.DB) error

+ func (my *MysqlBase) StopSlaveIOThread(db *sql.DB) error

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

+ type MysqlHandler interface

+ ChangeMasterTo func(*sql.DB, *model.Repl) error

+ ChangeToMaster func(*sql.DB) error

+ ChangeUserPasswd func(*sql.DB, string, string) error

+ CheckUserExists func(*sql.DB, string) (bool, error)

+ CreateReplUserWithoutBinlog func(*sql.DB, string, string) error

+ CreateUser func(*sql.DB, string, string) error

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

+ DisableSemiSyncMaster func(db *sql.DB) error

+ DropUser func(*sql.DB, string, string) error

+ EnableSemiSyncMaster func(db *sql.DB) error

+ GetMasterGTID func(*sql.DB) (*model.GTID, error)

+ GetSlaveGTID func(*sql.DB) (*model.GTID, error)

+ GetUser func(*sql.DB) ([]model.MysqlUser, error)

+ GrantAllPrivileges func(*sql.DB, string) error

+ GrantNormalPrivileges func(*sql.DB, string) error

+ GrantReplicationPrivileges func(*sql.DB, string) error

+ Ping func(*sql.DB) (*PingEntry, error)

+ PurgeBinlogsTo func(*sql.DB, string) error

+ ResetMaster func(db *sql.DB) error

+ ResetSlaveAll func(db *sql.DB) error

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

+ SetReadOnly func(*sql.DB, bool) error

+ SetSemiSyncMasterDefault func(db *sql.DB) error

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

+ StartSlave func(*sql.DB) error

+ StartSlaveIOThread func(*sql.DB) error

+ StopSlave func(*sql.DB) error

+ StopSlaveIOThread func(*sql.DB) error

+ WaitUntilAfterGTID func(*sql.DB, string) error

v1.0.4

Jan 2, 2019

Changes in this version

+ func SetSemiSyncMasterDefault(db *sql.DB) error

type MockGTID

+ SetSemiSyncMasterDefaultFn func(*sql.DB) error

+ func NewMockGTIDX5ChangeToMasterError() *MockGTID

+ func NewMockGTIDX5WaitUntilAfterGTIDError() *MockGTID

+ func (mogtid *MockGTID) SetSemiSyncMasterDefault(db *sql.DB) error

type Mysql

+ func (m *Mysql) SetSemiSyncMasterDefault() error

type Mysql57

+ func (my *Mysql57) SetSemiSyncMasterDefault(db *sql.DB) error

type ReplHandler

+ SetSemiSyncMasterDefault func(db *sql.DB) error

v1.0.3

Dec 23, 2018

v1.0.2

Dec 23, 2018

Changes in this version

type Mysql

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

v1.0.1

Sep 12, 2018

Changes in this version

+ const MysqlAlive

+ const MysqlDead

+ const MysqlReadonly

+ const MysqlReadwrite

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

+ func ChangeToMasterError(db *sql.DB) error

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

+ func DefaultChangeToMaster(db *sql.DB) error

+ func DefaultDisableSemiSyncMaster(db *sql.DB) error

+ func DefaultEnableSemiSyncMaster(db *sql.DB) error

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

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

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

+ func DefaultResetMaster(db *sql.DB) error

+ func DefaultResetSlaveAll(db *sql.DB) error

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

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

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

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

+ func DefaultStartSlave(db *sql.DB) error

+ func DefaultStartSlaveIOThread(db *sql.DB) error

+ func DefaultStopSlave(db *sql.DB) error

+ func DefaultStopSlaveIOThread(db *sql.DB) error

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func StartSlaveError(db *sql.DB) error

+ func StartSlaveIOThreadError(db *sql.DB) error

+ func StopSlaveError(db *sql.DB) error

+ func StopSlaveIOThreadError(db *sql.DB) error

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

+ type MockGTID struct

+ ChangeMasterToFn func(*sql.DB, *model.Repl) error

+ ChangeToMasterFn func(*sql.DB) error

+ DisableSemiSyncMasterFn func(*sql.DB) error

+ EnableSemiSyncMasterFn func(*sql.DB) error

+ GetMasterGTIDFn func(*sql.DB) (*model.GTID, error)

+ GetSlaveGTIDFn func(*sql.DB) (*model.GTID, error)

+ PingFn func(*sql.DB) (*PingEntry, error)

+ PurgeBinlogsToFn func(*sql.DB, string) error

+ ResetMasterFn func(*sql.DB) error

+ ResetSlaveAllFn func(*sql.DB) error

+ SelectSysVarFn func(*sql.DB, string) (string, error)

+ SetGlobalSysVarFn func(*sql.DB, string) error

+ SetReadOnlyFn func(*sql.DB, bool) error

+ SetSemiWaitSlaveCountFn func(*sql.DB, int) error

+ StartSlaveFn func(*sql.DB) error

+ StartSlaveIOThreadFn func(*sql.DB) error

+ StopSlaveFn func(*sql.DB) error

+ StopSlaveIOThreadFn func(*sql.DB) error

+ WaitUntilAfterGTIDFn func(*sql.DB, string) error

+ func NewMockGTIDA() *MockGTID

+ func NewMockGTIDB() *MockGTID

+ func NewMockGTIDC() *MockGTID

+ func NewMockGTIDD() *MockGTID

+ func NewMockGTIDError() *MockGTID

+ func NewMockGTIDPingError() *MockGTID

+ func NewMockGTIDX1() *MockGTID

+ func NewMockGTIDX3() *MockGTID

+ func NewMockGTIDX5() *MockGTID

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type MockUserA struct

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

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

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

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

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

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

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

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

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

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

+ type Mysql struct

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

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

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

+ func (m *Mysql) ChangeToMaster() error

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

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

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

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

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

+ func (m *Mysql) DisableSemiSyncMaster() error

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

+ func (m *Mysql) EnableSemiSyncMaster() error

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

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

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

+ func (m *Mysql) GetMysqlRPC() *MysqlRPC

+ func (m *Mysql) GetOption() Option

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

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

+ func (m *Mysql) GetState() State

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

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

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

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

+ func (m *Mysql) Ping()

+ func (m *Mysql) PingStart()

+ func (m *Mysql) PingStop()

+ func (m *Mysql) Promotable() bool

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

+ func (m *Mysql) RelayMasterLogFile() string

+ func (m *Mysql) ResetMaster() error

+ func (m *Mysql) ResetSlaveAll() error

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

+ func (m *Mysql) SetMasterGlobalSysVar() error

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

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

+ func (m *Mysql) SetReplHandler(h ReplHandler)

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

+ func (m *Mysql) SetSlaveGlobalSysVar() error

+ func (m *Mysql) SetUserHandler(h UserHandler)

+ func (m *Mysql) StartSlave() error

+ func (m *Mysql) StartSlaveIOThread() error

+ func (m *Mysql) StopSlave() error

+ func (m *Mysql) StopSlaveIOThread() error

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

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

+ func (s *Mysql) IncMysqlDowns()

+ type Mysql57 struct

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type MysqlRPC struct

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

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

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

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

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

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

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

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

+ type Option string

+ type PingEntry struct

+ Relay_Master_Log_File string

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

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

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

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

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

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

+ type ReplHandler interface

+ ChangeMasterTo func(*sql.DB, *model.Repl) error

+ ChangeToMaster func(*sql.DB) error

+ DisableSemiSyncMaster func(db *sql.DB) error

+ EnableSemiSyncMaster func(db *sql.DB) error

+ GetMasterGTID func(*sql.DB) (*model.GTID, error)

+ GetSlaveGTID func(*sql.DB) (*model.GTID, error)

+ Ping func(*sql.DB) (*PingEntry, error)

+ PurgeBinlogsTo func(*sql.DB, string) error

+ ResetMaster func(db *sql.DB) error

+ ResetSlaveAll func(db *sql.DB) error

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

+ SetReadOnly func(*sql.DB, bool) error

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

+ StartSlave func(*sql.DB) error

+ StartSlaveIOThread func(*sql.DB) error

+ StopSlave func(*sql.DB) error

+ StopSlaveIOThread func(*sql.DB) error

+ WaitUntilAfterGTID func(*sql.DB, string) error

+ type State string

+ type User struct

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

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

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

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

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

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

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

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

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

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

+ type UserHandler interface

+ ChangeUserPasswd func(*sql.DB, string, string) error

+ CheckUserExists func(*sql.DB, string) (bool, error)

+ CreateReplUserWithoutBinlog func(*sql.DB, string, string) error

+ CreateUser func(*sql.DB, string, string) error

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

+ DropUser func(*sql.DB, string, string) error

+ GetUser func(*sql.DB) ([]model.MysqlUser, error)

+ GrantAllPrivileges func(*sql.DB, string) error

+ GrantNormalPrivileges func(*sql.DB, string) error

+ GrantReplicationPrivileges func(*sql.DB, string) error

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