backend

Sep 21, 2020

Changes in this version

type Txn

+ func (txn *Txn) RollbackPhaseOne() error

May 14, 2020

Changes in this version

+ func MockBackendConfigReplica(name, addr, replica string) *config.BackendConfig

+ type Poolz struct

+ func NewPoolz(log *xlog.Log, conf *config.BackendConfig) *Poolz

+ func (p *Poolz) Close()

+ func (p *Poolz) JSON() string

type Scatter

+ func (scatter *Scatter) PoolzClone() map[string]*Poolz

type Transaction

+ SetIsExecOnRep func(isExecOnRep bool)

type Txn

+ func (txn *Txn) SetIsExecOnRep(isExecOnRep bool)

type TxnManager

+ func MockTxnMgrWithReplica(log *xlog.Log, n int) (*fakedb.DB, *TxnManager, map[string]*Poolz, []string, func())

Dec 2, 2019

Changes in this version

type Scatter

+ func (scatter *Scatter) CheckBackend(backenName string) bool

Jul 20, 2019

Changes in this version

+ func MockBackendConfigAttach(name, addr string) *config.BackendConfig

type Scatter

+ func (scatter *Scatter) AllBackends() []string

type Transaction

+ MaxJoinRows func() int

+ SetMaxJoinRows func(max int)

type Txn

+ func (txn *Txn) MaxJoinRows() int

+ func (txn *Txn) SetMaxJoinRows(max int)

type TxnManager

+ func MockTxnMgrWithAttach(log *xlog.Log, n int) (*fakedb.DB, *TxnManager, map[string]*Pool, []string, func())

May 17, 2019

Changes in this version

type Transaction

+ SetSessionID func(id uint32)

type Txn

+ func (txn *Txn) SetSessionID(id uint32)

type XaCommitErr

+ Times int

Jan 2, 2019

Changes in this version

type Transaction

+ SetMultiStmtTxn func()

type Txn

+ func (txn *Txn) SetMultiStmtTxn()

Dec 26, 2018

Changes in this version

type Transaction

+ BeginScatter func() error

+ CommitScatter func() error

+ RollbackScatter func() error

type Txn

+ func (txn *Txn) BeginScatter() error

+ func (txn *Txn) CommitScatter() error

+ func (txn *Txn) RollbackScatter() error

Oct 13, 2018

Changes in this version

+ func MockScatterDefault(log *xlog.Log) *config.ScatterConfig

+ func MockScatterDefault2(dir string) *config.ScatterConfig

+ func MockTxnMgrScatter(log *xlog.Log, n int) (*fakedb.DB, *TxnManager, map[string]*Pool, *Pool, []string, *Scatter, func())

type Scatter

+ func (scatter *Scatter) Init(scatterConf *config.ScatterConfig) error

type Txn

+ func (txn *Txn) WriteXaCommitErrLog(state string) error

type TxnManager

+ func (mgr *TxnManager) Close()

+ func (mgr *TxnManager) Init(scatter *Scatter, ScatterConf *config.ScatterConfig) error

+ type XaCheck struct

+ func NewXaCheck(scatter *Scatter, conf *config.ScatterConfig) *XaCheck

+ func (xc *XaCheck) Close()

+ func (xc *XaCheck) GetRetrysLen() int

+ func (xc *XaCheck) GetXaCheckFile() string

+ func (xc *XaCheck) Init() error

+ func (xc *XaCheck) LoadXaCommitErrLogs() error

+ func (xc *XaCheck) ReadXaCommitErrLogs(data string) (*XaCommitErrs, error)

+ func (xc *XaCheck) RemoveXaCommitErrLogs() error

+ func (xc *XaCheck) WriteXaCommitErrLog(txn *Txn, state string) error

+ type XaCommitErr struct

+ State string

+ Time string

+ Xaid string

+ type XaCommitErrs struct

+ Logs []*XaCommitErr

Sep 3, 2018

Changes in this version

+ func MockBackendConfigDefault(name, addr string) *config.BackendConfig

+ func MockTxnMgr(log *xlog.Log, n int) (*fakedb.DB, *TxnManager, map[string]*Pool, *Pool, []string, func())

+ type BackupTxn struct

+ func NewBackupTxn(log *xlog.Log, txid uint64, mgr *TxnManager, backup *Pool) (*BackupTxn, error)

+ func (txn *BackupTxn) Abort() error

+ func (txn *BackupTxn) Begin() error

+ func (txn *BackupTxn) Commit() error

+ func (txn *BackupTxn) Execute(req *xcontext.RequestContext) (*sqltypes.Result, error)

+ func (txn *BackupTxn) ExecuteRaw(database string, query string) (*sqltypes.Result, error)

+ func (txn *BackupTxn) Finish() error

+ func (txn *BackupTxn) Rollback() error

+ func (txn *BackupTxn) SetMaxResult(max int)

+ func (txn *BackupTxn) SetTimeout(timeout int)

+ func (txn *BackupTxn) State() int32

+ func (txn *BackupTxn) TxID() uint64

+ func (txn *BackupTxn) XID() string

+ func (txn *BackupTxn) XaState() int32

+ type Connection interface

+ Address func() string

+ Close func()

+ Closed func() bool

+ Dial func() error

+ Execute func(string) (*sqltypes.Result, error)

+ ExecuteStreamFetch func(string) (driver.Rows, error)

+ ExecuteWithLimits func(query string, timeout int, maxmem int) (*sqltypes.Result, error)

+ ID func() uint32

+ Kill func(string) error

+ LastErr func() error

+ Ping func() error

+ Recycle func()

+ SetTimestamp func(int64)

+ Timestamp func() int64

+ UseDB func(string) error

+ func MockClient(log *xlog.Log, addr string) (Connection, func())

+ func MockClientWithConfig(log *xlog.Log, conf *config.BackendConfig) (Connection, func())

+ func NewConnection(log *xlog.Log, pool *Pool) Connection

+ type Pool struct

+ func NewPool(log *xlog.Log, conf *config.BackendConfig) *Pool

+ func (p *Pool) Close()

+ func (p *Pool) Get() (Connection, error)

+ func (p *Pool) JSON() string

+ func (p *Pool) Put(conn Connection)

+ type QueryDetail struct

+ ID uint64

+ func NewQueryDetail(conn Connection, query string) *QueryDetail

+ type QueryDetailzRow struct

+ Address string

+ Color string

+ ConnID uint32

+ Duration time.Duration

+ Query string

+ Start time.Time

+ type Queryz struct

+ ID uint64

+ func NewQueryz() *Queryz

+ func (qz *Queryz) Add(qd *QueryDetail)

+ func (qz *Queryz) GetQueryzRows() []QueryDetailzRow

+ func (qz *Queryz) Remove(qd *QueryDetail)

+ type Scatter struct

+ func MockScatter(log *xlog.Log, n int) (*Scatter, *fakedb.DB, func())

+ func NewScatter(log *xlog.Log, metadir string) *Scatter

+ func (scatter *Scatter) Add(config *config.BackendConfig) error

+ func (scatter *Scatter) AddBackup(config *config.BackendConfig) error

+ func (scatter *Scatter) BackendConfigsClone() []*config.BackendConfig

+ func (scatter *Scatter) Backends() []string

+ func (scatter *Scatter) BackupBackend() string

+ func (scatter *Scatter) BackupConfig() *config.BackendConfig

+ func (scatter *Scatter) BackupPool() *Pool

+ func (scatter *Scatter) Close()

+ func (scatter *Scatter) CreateBackupTransaction() (*BackupTxn, error)

+ func (scatter *Scatter) CreateTransaction() (*Txn, error)

+ func (scatter *Scatter) FlushConfig() error

+ func (scatter *Scatter) HasBackup() bool

+ func (scatter *Scatter) LoadConfig() error

+ func (scatter *Scatter) MySQLStats() *stats.Timings

+ func (scatter *Scatter) PoolClone() map[string]*Pool

+ func (scatter *Scatter) QueryRates() *stats.Rates

+ func (scatter *Scatter) QueryStats() *stats.Timings

+ func (scatter *Scatter) Queryz() *Queryz

+ func (scatter *Scatter) Remove(config *config.BackendConfig) error

+ func (scatter *Scatter) RemoveBackup(config *config.BackendConfig) error

+ func (scatter *Scatter) TxnCounters() *stats.Counters

+ func (scatter *Scatter) Txnz() *Txnz

+ type Transaction interface

+ Abort func() error

+ Begin func() error

+ Commit func() error

+ Execute func(req *xcontext.RequestContext) (*sqltypes.Result, error)

+ ExecuteRaw func(database string, query string) (*sqltypes.Result, error)

+ Finish func() error

+ Rollback func() error

+ SetMaxResult func(max int)

+ SetTimeout func(timeout int)

+ State func() int32

+ TxID func() uint64

+ XID func() string

+ XaState func() int32

+ type Txn struct

+ func NewTxn(log *xlog.Log, txid uint64, mgr *TxnManager, backends map[string]*Pool) (*Txn, error)

+ func (txn *Txn) Abort() error

+ func (txn *Txn) Begin() error

+ func (txn *Txn) Commit() error

+ func (txn *Txn) Execute(req *xcontext.RequestContext) (*sqltypes.Result, error)

+ func (txn *Txn) ExecuteOnThisBackend(backend string, query string) (*sqltypes.Result, error)

+ func (txn *Txn) ExecuteRaw(database string, query string) (*sqltypes.Result, error)

+ func (txn *Txn) ExecuteScatter(query string) (*sqltypes.Result, error)

+ func (txn *Txn) ExecuteSingle(query string) (*sqltypes.Result, error)

+ func (txn *Txn) ExecuteStreamFetch(req *xcontext.RequestContext, callback func(*sqltypes.Result) error, ...) error

+ func (txn *Txn) Finish() error

+ func (txn *Txn) Rollback() error

+ func (txn *Txn) SetMaxResult(max int)

+ func (txn *Txn) SetTimeout(timeout int)

+ func (txn *Txn) State() int32

+ func (txn *Txn) TxID() uint64

+ func (txn *Txn) XID() string

+ func (txn *Txn) XaState() int32

+ type TxnDetail struct

+ func NewTxnDetail(txn Transaction) *TxnDetail

+ type TxnDetailzRow struct

+ Color string

+ Duration time.Duration

+ Query string

+ Start time.Time

+ State string

+ TxnID uint64

+ XAID string

+ XaState string

+ type TxnManager struct

+ func NewTxnManager(log *xlog.Log) *TxnManager

+ func (mgr *TxnManager) Add() error

+ func (mgr *TxnManager) CommitLock()

+ func (mgr *TxnManager) CommitRLock()

+ func (mgr *TxnManager) CommitRUnlock()

+ func (mgr *TxnManager) CommitUnlock()

+ func (mgr *TxnManager) CreateBackupTxn(backup *Pool) (*BackupTxn, error)

+ func (mgr *TxnManager) CreateTxn(backends map[string]*Pool) (*Txn, error)

+ func (mgr *TxnManager) GetID() uint64

+ func (mgr *TxnManager) Remove() error

+ type Txnz struct

+ func NewTxnz() *Txnz

+ func (tz *Txnz) Add(td *TxnDetail)

+ func (tz *Txnz) GetTxnzRows() []TxnDetailzRow

+ func (tz *Txnz) Remove(td *TxnDetail)