proxy

package

Go to main page

Versions in this module

v1

v1.1.4

Jan 28, 2021

Changes in this version

type Proxy

+ func (p *Proxy) SetLowerCaseTableNames(lowerCase int)

v1.1.3

Oct 26, 2020

v1.1.2

Sep 21, 2020

Changes in this version

+ func RebalanceMigrate(log *xlog.Log, rebalance *Rebalance, max, min *BackendSize, ...) error

+ func ShardBalanceAdvice(log *xlog.Log, spanner *Spanner, scatter *backend.Scatter, ...) error

+ func SubTableToTable(from string) (isSub bool, to string)

+ type AdminXA struct

+ func NewAdminXA(log *xlog.Log, scatter *backend.Scatter, router *router.Router, ...) *AdminXA

+ func (adminXA *AdminXA) Commit() (*sqltypes.Result, error)

+ func (adminXA *AdminXA) Recover() (*sqltypes.Result, error)

+ func (adminXA *AdminXA) Rollback() (*sqltypes.Result, error)

+ type BackendSize struct

+ Address string

+ Name string

+ Passwd string

+ Size float64

+ User string

type Proxy

+ func (p *Proxy) SetLoadBalance(val int)

+ type Rebalance struct

+ func NewRebalance(log *xlog.Log, scatter *backend.Scatter, router *router.Router, ...) *Rebalance

+ func (r *Rebalance) Rebalance() (*sqltypes.Result, error)

v1.0.9

Apr 5, 2020

Changes in this version

+ type Cleanup struct

+ func NewCleanup(log *xlog.Log, scatter *backend.Scatter, router *router.Router, ...) *Cleanup

+ func (c *Cleanup) Cleanup() (*sqltypes.Result, error)

type Proxy

+ func (p *Proxy) Plugins() *plugins.Plugin

+ func (p *Proxy) SetBlocks(blocks int)

type Spanner

+ func (spanner *Spanner) IsAdminCmd(node sqlparser.Statement) bool

v1.0.8

Dec 2, 2019

Changes in this version

+ const AttachDatabaseCheckTable

+ const AttachParamsCount

+ const DetachParamsCount

+ type Attach struct

+ func NewAttach(log *xlog.Log, scatter *backend.Scatter, router *router.Router, ...) *Attach

+ func (attach *Attach) Attach(node *sqlparser.Radon) (*sqltypes.Result, error)

+ func (attach *Attach) Detach(attachName string) (*sqltypes.Result, error)

+ func (attach *Attach) ListAttach() (*sqltypes.Result, error)

type Proxy

+ func (p *Proxy) SetAutocommitFalseIsTxn(enable bool)

+ func (p *Proxy) SetMaxJoinRows(size int)

+ type Reshard struct

+ func NewReshard(log *xlog.Log, scatter *backend.Scatter, router *router.Router, ...) *Reshard

+ func (reshard *Reshard) CheckReshardDBTable(db, singleTable, dstDB, dstTable string) (bool, error)

+ func (reshard *Reshard) IsSingleTable(db, singleTable string) (bool, error)

+ func (reshard *Reshard) ReShardTable(db, singleTable, dstDB, dstTable string) (*sqltypes.Result, error)

+ func (reshard *Reshard) SetHandle(r ReshardHandle)

+ func (reshard *Reshard) SetShiftProcessBar(finished int)

+ func (reshard *Reshard) SetShiftStatus(err error)

+ func (reshard *Reshard) ShiftProcess() error

+ func (reshard *Reshard) ShiftProcessBar() int

+ func (reshard *Reshard) ShiftStatus() error

+ type ReshardHandle interface

+ ShiftProcess func() error

type Spanner

+ func (spanner *Spanner) SetServerVersion()

v1.0.6

May 17, 2019

Changes in this version

+ func MockConfigIdleTxnTimeout1() *config.Config

+ type Manager struct

+ func NewManager(log *xlog.Log, sessions *Sessions, conf *config.ProxyConfig) *Manager

+ func (mgr *Manager) Close()

+ func (mgr *Manager) Init() error

type Proxy

+ func MockProxyPrivilegeN(log *xlog.Log, conf *config.Config) (*fakedb.DB, *Proxy, func())

+ func MockProxyPrivilegeNotSuper(log *xlog.Log, conf *config.Config) (*fakedb.DB, *Proxy, func())

+ func MockProxyPrivilegeUsers(log *xlog.Log, conf *config.Config) (*fakedb.DB, *Proxy, func())

type Sessions

+ func (ss *Sessions) SnapshotTxn() []SessionInfo

+ func (ss *Sessions) SnapshotUser(user string) []SessionInfo

type Spanner

+ func (spanner *Spanner) ServerVersion() string

v1.0.4

Jan 2, 2019

Changes in this version

type Proxy

+ func (p *Proxy) SetStreamBufferSize(streamBufferSize int)

type Sessions

+ func (ss *Sessions) MultiStmtTxnBinding(s *driver.Session, txn backend.Transaction, node sqlparser.Statement, ...)

+ func (ss *Sessions) MultiStmtTxnUnBinding(s *driver.Session, isEnd bool)

type Spanner

+ func (spanner *Spanner) ExecuteBegin(session *driver.Session, query string, node sqlparser.Statement) (*sqltypes.Result, error)

+ func (spanner *Spanner) ExecuteCommit(session *driver.Session, query string, node sqlparser.Statement) (*sqltypes.Result, error)

+ func (spanner *Spanner) ExecuteDML(session *driver.Session, database string, query string, ...) (*sqltypes.Result, error)

+ func (spanner *Spanner) ExecuteMultiStmtsInTxn(session *driver.Session, database string, query string, ...) (*sqltypes.Result, error)

+ func (spanner *Spanner) ExecuteRollback(session *driver.Session, query string, node sqlparser.Statement) (*sqltypes.Result, error)

+ func (spanner *Spanner) ExecuteSingleStmtTxnTwoPC(session *driver.Session, database string, query string, ...) (*sqltypes.Result, error)

v1.0.2

Oct 13, 2018

v1.0.1

Sep 17, 2018

Changes in this version

type Proxy

+ func (p *Proxy) SetLongQueryTime(longQueryTime int)

type Spanner

+ func (spanner *Spanner) SessionDec(s *driver.Session)

+ func (spanner *Spanner) SessionInc(s *driver.Session)

v1.0.0

Sep 3, 2018

Changes in this version

+ const R

+ const W

+ func CheckCreateTable(ddl *sqlparser.DDL) error

+ func MockConfigMax16() *config.Config

+ func MockDefaultConfig() *config.Config

+ type BackupRelay struct

+ func NewBackupRelay(log *xlog.Log, conf *config.BinlogConfig, spanner *Spanner) *BackupRelay

+ func (br *BackupRelay) Close()

+ func (br *BackupRelay) Init() error

+ func (br *BackupRelay) MaxWorkers() int32

+ func (br *BackupRelay) ParallelType() int32

+ func (br *BackupRelay) ParallelWorkers() int32

+ func (br *BackupRelay) RelayBinlog() string

+ func (br *BackupRelay) RelayCounts() int64

+ func (br *BackupRelay) RelayGTID() int64

+ func (br *BackupRelay) RelayRates() string

+ func (br *BackupRelay) RelayStatus() bool

+ func (br *BackupRelay) ResetRelayWorker(gtid int64)

+ func (br *BackupRelay) RestartGTID() int64

+ func (br *BackupRelay) SetMaxWorkers(n int32)

+ func (br *BackupRelay) SetParallelType(n int32)

+ func (br *BackupRelay) StartRelayWorker()

+ func (br *BackupRelay) StopRelayWorker()

+ type DiskCheck struct

+ func NewDiskCheck(log *xlog.Log, dir string) *DiskCheck

+ func (dc *DiskCheck) Close()

+ func (dc *DiskCheck) HighWater() bool

+ func (dc *DiskCheck) Init() error

+ type IP struct

+ type IPTable struct

+ func NewIPTable(log *xlog.Log, conf *config.ProxyConfig) *IPTable

+ func (ipt *IPTable) Add(ip string)

+ func (ipt *IPTable) Check(address string) bool

+ func (ipt *IPTable) Refresh()

+ func (ipt *IPTable) Remove(ip string)

+ type Proxy struct

+ func MockProxy(log *xlog.Log) (*fakedb.DB, *Proxy, func())

+ func MockProxy1(log *xlog.Log, conf *config.Config) (*fakedb.DB, *Proxy, func())

+ func MockProxy2(log *xlog.Log, conf *config.Config) (*fakedb.DB, *Proxy, func())

+ func MockProxyWithBackup(log *xlog.Log) (*fakedb.DB, *Proxy, func())

+ func NewProxy(log *xlog.Log, path string, conf *config.Config) *Proxy

+ func (p *Proxy) Address() string

+ func (p *Proxy) Binlog() *binlog.Binlog

+ func (p *Proxy) Config() *config.Config

+ func (p *Proxy) FlushConfig() error

+ func (p *Proxy) IPTable() *IPTable

+ func (p *Proxy) PeerAddress() string

+ func (p *Proxy) Router() *router.Router

+ func (p *Proxy) Scatter() *backend.Scatter

+ func (p *Proxy) Sessions() *Sessions

+ func (p *Proxy) SetAllowIP(ips []string)

+ func (p *Proxy) SetAuditMode(mode string)

+ func (p *Proxy) SetDDLTimeout(timeout int)

+ func (p *Proxy) SetMaxConnections(connections int)

+ func (p *Proxy) SetMaxResultSize(size int)

+ func (p *Proxy) SetQueryTimeout(timeout int)

+ func (p *Proxy) SetReadOnly(val bool)

+ func (p *Proxy) SetThrottle(val int)

+ func (p *Proxy) SetTwoPC(enable bool)

+ func (p *Proxy) Spanner() *Spanner

+ func (p *Proxy) Start()

+ func (p *Proxy) Stop()

+ func (p *Proxy) Syncer() *syncer.Syncer

+ type SessionInfo struct

+ Command string

+ DB string

+ Host string

+ ID uint32

+ Info string

+ RowsExamined uint64

+ RowsSent uint64

+ State string

+ Time uint32

+ User string

+ type Sessions struct

+ func NewSessions(log *xlog.Log) *Sessions

+ func (ss *Sessions) Add(s *driver.Session)

+ func (ss *Sessions) Close()

+ func (ss *Sessions) Kill(id uint32, reason string)

+ func (ss *Sessions) Reaches(quota int) bool

+ func (ss *Sessions) Remove(s *driver.Session)

+ func (ss *Sessions) Snapshot() []SessionInfo

+ func (ss *Sessions) TxnBinding(s *driver.Session, txn backend.Transaction, node sqlparser.Statement, ...)

+ func (ss *Sessions) TxnUnBinding(s *driver.Session)

+ type Spanner struct

+ func NewSpanner(log *xlog.Log, conf *config.Config, iptable *IPTable, router *router.Router, ...) *Spanner

+ func (spanner *Spanner) AuthCheck(s *driver.Session) error

+ func (spanner *Spanner) BackupRelay() *BackupRelay

+ func (spanner *Spanner) Close() error

+ func (spanner *Spanner) ComInitDB(session *driver.Session, database string) error

+ func (spanner *Spanner) ComQuery(session *driver.Session, query string, ...) error

+ func (spanner *Spanner) Execute(session *driver.Session, database string, query string, ...) (*sqltypes.Result, error)

+ func (spanner *Spanner) ExecuteDDL(session *driver.Session, database string, query string, ...) (*sqltypes.Result, error)

+ func (spanner *Spanner) ExecuteNormal(session *driver.Session, database string, query string, ...) (*sqltypes.Result, error)

+ func (spanner *Spanner) ExecuteOnBackup(database string, query string) (*sqltypes.Result, error)

+ func (spanner *Spanner) ExecuteOnThisBackend(backend string, query string) (*sqltypes.Result, error)

+ func (spanner *Spanner) ExecuteScatter(query string) (*sqltypes.Result, error)

+ func (spanner *Spanner) ExecuteSingle(query string) (*sqltypes.Result, error)

+ func (spanner *Spanner) ExecuteStreamFetch(session *driver.Session, database string, query string, ...) error

+ func (spanner *Spanner) ExecuteTwoPC(session *driver.Session, database string, query string, ...) (*sqltypes.Result, error)

+ func (spanner *Spanner) Init() error

+ func (spanner *Spanner) IsDDL(node sqlparser.Statement) bool

+ func (spanner *Spanner) IsDML(node sqlparser.Statement) bool

+ func (spanner *Spanner) IsDMLWrite(node sqlparser.Statement) bool

+ func (spanner *Spanner) NewSession(s *driver.Session)

+ func (spanner *Spanner) ReadOnly() bool

+ func (spanner *Spanner) SessionCheck(s *driver.Session) error

+ func (spanner *Spanner) SessionClosed(s *driver.Session)

+ func (spanner *Spanner) SetReadOnly(val bool)

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