proxy

package
v1.0.2 Latest Latest
Warning

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

 Go to latest Published: Oct 13, 2018 License: GPL-3.0 Imports: 41 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// R enum.
	R mode = iota
	// W enum.
	W
)

Variables

This section is empty.

Functions

func CheckCreateTable 

func CheckCreateTable(ddl *sqlparser.DDL) error

CheckCreateTable used to check the CRERATE TABLE statement.

func MockConfigMax16 

func MockConfigMax16() *config.Config

MockConfigMax16 mocks the config with MaxConnections=16.

func MockDefaultConfig 

func MockDefaultConfig() *config.Config

MockDefaultConfig mocks the default config.

Types

type BackupRelay 

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

BackupRelay tuple.

func NewBackupRelay 

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

NewBackupRelay creates new BackupRelay tuple.

func (*BackupRelay) Close 

func (br *BackupRelay) Close()

Close used to close all the backgroud workers.

func (*BackupRelay) Init 

func (br *BackupRelay) Init() error

Init used to init all the workers.

func (*BackupRelay) MaxWorkers 

func (br *BackupRelay) MaxWorkers() int32

MaxWorkers returns the max parallel worker numbers.

func (*BackupRelay) ParallelType 

func (br *BackupRelay) ParallelType() int32

ParallelType returns the type of parallel.

func (*BackupRelay) ParallelWorkers 

func (br *BackupRelay) ParallelWorkers() int32

ParallelWorkers returns the number of the parallel workers.

func (*BackupRelay) RelayBinlog 

func (br *BackupRelay) RelayBinlog() string

RelayBinlog returns the current relay binlog name.

func (*BackupRelay) RelayCounts 

func (br *BackupRelay) RelayCounts() int64

RelayCounts returns the counts have relayed.

func (*BackupRelay) RelayGTID 

func (br *BackupRelay) RelayGTID() int64

RelayGTID returns the current relay GTID.

func (*BackupRelay) RelayRates 

func (br *BackupRelay) RelayRates() string

RelayRates returns the relay rates.

func (*BackupRelay) RelayStatus 

func (br *BackupRelay) RelayStatus() bool

RelayStatus returns the stop status.

func (*BackupRelay) ResetRelayWorker 

func (br *BackupRelay) ResetRelayWorker(gtid int64)

ResetRelayWorker used to reset the relay gtid. Then the relay worker should relay from the new gtid point.

func (*BackupRelay) RestartGTID 

func (br *BackupRelay) RestartGTID() int64

RestartGTID returns the restart GTID of next relay.

func (*BackupRelay) SetMaxWorkers 

func (br *BackupRelay) SetMaxWorkers(n int32)

SetMaxWorkers used to set the limits number.

func (*BackupRelay) SetParallelType 

func (br *BackupRelay) SetParallelType(n int32)

SetParallelType used to set the parallel type.

func (*BackupRelay) StartRelayWorker 

func (br *BackupRelay) StartRelayWorker()

StartRelayWorker used to restart the relay worker.

func (*BackupRelay) StopRelayWorker 

func (br *BackupRelay) StopRelayWorker()

StopRelayWorker used to stop the relay worker.

type DiskCheck 

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

DiskCheck tuple.

func NewDiskCheck 

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

NewDiskCheck creates the DiskCheck tuple.

func (*DiskCheck) Close 

func (dc *DiskCheck) Close()

Close used to close the disk check goroutine.

func (*DiskCheck) HighWater 

func (dc *DiskCheck) HighWater() bool

HighWater returns the highwater mark. If true there is no space left on device.

func (*DiskCheck) Init 

func (dc *DiskCheck) Init() error

Init used to init disk check goroutine.

type IP 

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

IP tuple.

type IPTable 

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

IPTable tuple.

func NewIPTable 

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

NewIPTable creates a new IPTable.

func (*IPTable) Add 

func (ipt *IPTable) Add(ip string)

Add used to add a ip to table.

func (*IPTable) Check 

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

Check used to check a whether the ip is in ip table or not.

func (*IPTable) Refresh 

func (ipt *IPTable) Refresh()

Refresh used to refresh the table.

func (*IPTable) Remove 

func (ipt *IPTable) Remove(ip string)

Remove used to remove a ip from table.

type Proxy 

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

Proxy tuple.

func MockProxy 

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

MockProxy mocks a proxy.

func MockProxy1 

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

MockProxy1 mocks the proxy with config.

func MockProxy2 

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

MockProxy2 mocks the proxy with the conf.

func MockProxyWithBackup 

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

MockProxyWithBackup mocks the proxy with backup.

func NewProxy 

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

NewProxy creates new proxy.

func (*Proxy) Address 

func (p *Proxy) Address() string

Address returns the proxy endpoint.

func (*Proxy) Binlog 

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

Binlog returns the binlog.

func (*Proxy) Config 

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

Config returns the config.

func (*Proxy) FlushConfig 

func (p *Proxy) FlushConfig() error

FlushConfig used to flush the config to disk.

func (*Proxy) IPTable 

func (p *Proxy) IPTable() *IPTable

IPTable returns the ip table.

func (*Proxy) PeerAddress 

func (p *Proxy) PeerAddress() string

PeerAddress returns the peer address.

func (*Proxy) Router 

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

Router returns the router.

func (*Proxy) Scatter 

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

Scatter returns the scatter.

func (*Proxy) Sessions 

func (p *Proxy) Sessions() *Sessions

Sessions returns the sessions.

func (*Proxy) SetAllowIP 

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

SetAllowIP used to set allow ips.

func (*Proxy) SetAuditMode 

func (p *Proxy) SetAuditMode(mode string)

SetAuditMode used to set the mode of audit.

func (*Proxy) SetDDLTimeout 

func (p *Proxy) SetDDLTimeout(timeout int)

SetDDLTimeout used to set the ddl timeout.

func (*Proxy) SetLongQueryTime added in v1.0.1 

func (p *Proxy) SetLongQueryTime(longQueryTime int)

SetLongQueryTime Set long Query Time used to set long query time.

func (*Proxy) SetMaxConnections 

func (p *Proxy) SetMaxConnections(connections int)

SetMaxConnections used to set the max connections.

func (*Proxy) SetMaxResultSize 

func (p *Proxy) SetMaxResultSize(size int)

SetMaxResultSize used to set the max result size.

func (*Proxy) SetQueryTimeout 

func (p *Proxy) SetQueryTimeout(timeout int)

SetQueryTimeout used to set query timeout.

func (*Proxy) SetReadOnly 

func (p *Proxy) SetReadOnly(val bool)

SetReadOnly used to enable/disable readonly.

func (*Proxy) SetThrottle 

func (p *Proxy) SetThrottle(val int)

SetThrottle used to set the throttle.

func (*Proxy) SetTwoPC 

func (p *Proxy) SetTwoPC(enable bool)

SetTwoPC used to set twopc to enable or disable.

func (*Proxy) Spanner 

func (p *Proxy) Spanner() *Spanner

Spanner returns the spanner.

func (*Proxy) Start 

func (p *Proxy) Start()

Start used to start the proxy.

func (*Proxy) Stop 

func (p *Proxy) Stop()

Stop used to stop the proxy.

func (*Proxy) Syncer 

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

Syncer returns the syncer.

type SessionInfo 

type SessionInfo struct {
	ID           uint32
	User         string
	Host         string
	DB           string
	Command      string
	Time         uint32
	State        string
	Info         string
	RowsSent     uint64
	RowsExamined uint64
}

SessionInfo tuple.

type Sessions 

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

Sessions tuple.

func NewSessions 

func NewSessions(log *xlog.Log) *Sessions

NewSessions creates new session.

func (*Sessions) Add 

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

Add used to add the session to map when session created.

func (*Sessions) Close 

func (ss *Sessions) Close()

Close used to close all sessions.

func (*Sessions) Kill 

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

Kill used to kill a live session. 1. remove from sessions list. 2. close the session from the server side. 3. abort the session's txn.

func (*Sessions) Reaches 

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

Reaches used to check whether the sessions count reaches(>=) the quota.

func (*Sessions) Remove 

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

Remove used to remove the session from the map when session exit.

func (*Sessions) Snapshot 

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

Snapshot returns all session info.

func (*Sessions) TxnBinding 

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

TxnBinding used to bind txn to the session.

func (*Sessions) TxnUnBinding 

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

TxnUnBinding used to set transaction and node to nil.

type Spanner 

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

Spanner tuple.

func NewSpanner 

func NewSpanner(log *xlog.Log, conf *config.Config,
	iptable *IPTable, router *router.Router, scatter *backend.Scatter, binlog *binlog.Binlog, sessions *Sessions, audit *audit.Audit, throttle *xbase.Throttle) *Spanner

NewSpanner creates a new spanner.

func (*Spanner) AuthCheck 

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

AuthCheck impl.

func (*Spanner) BackupRelay 

func (spanner *Spanner) BackupRelay() *BackupRelay

BackupRelay returns BackupRelay tuple.

func (*Spanner) Close 

func (spanner *Spanner) Close() error

Close used to close spanner.

func (*Spanner) ComInitDB 

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

ComInitDB impl. Here, we will send a fake query 'SELECT 1' to the backend and check the 'USE DB'.

func (*Spanner) ComQuery 

func (spanner *Spanner) ComQuery(session *driver.Session, query string, callback func(qr *sqltypes.Result) error) error

ComQuery impl. Supports statements are: 1. DDL 2. DML 3. USE DB

func (*Spanner) Execute 

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

Execute used to execute querys to shards.

func (*Spanner) ExecuteDDL 

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

ExecuteDDL used to execute ddl querys to the shards with DDLTimeout limits, used for create/drop index long time operation.

func (*Spanner) ExecuteNormal 

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

ExecuteNormal used to execute non-2pc querys to shards with QueryTimeout limits.

func (*Spanner) ExecuteOnBackup 

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

ExecuteOnBackup used to executye query on the backup.

func (*Spanner) ExecuteOnThisBackend 

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

ExecuteOnThisBackend used to executye query on the backend whitout planner.

func (*Spanner) ExecuteScatter 

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

ExecuteScatter used to execute query on all shards without planner.

func (*Spanner) ExecuteSingle 

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

ExecuteSingle used to execute query on one shard without planner. The query must contain the database, such as db.table.

func (*Spanner) ExecuteStreamFetch 

func (spanner *Spanner) ExecuteStreamFetch(session *driver.Session, database string, query string, node sqlparser.Statement, callback func(qr *sqltypes.Result) error, streamBufferSize int) error

ExecuteStreamFetch used to execute a stream fetch query.

func (*Spanner) ExecuteTwoPC 

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

ExecuteTwoPC allows multi-shards transactions with 2pc commit.

func (*Spanner) Init 

func (spanner *Spanner) Init() error

Init used to init the async worker.

func (*Spanner) IsDDL 

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

IsDDL returns the DDL query or not.

func (*Spanner) IsDML 

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

IsDML returns the DML query or not.

func (*Spanner) IsDMLWrite 

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

IsDMLWrite returns the DML write or not.

func (*Spanner) NewSession 

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

NewSession impl.

func (*Spanner) ReadOnly 

func (spanner *Spanner) ReadOnly() bool

ReadOnly returns the readonly or not.

func (*Spanner) SessionCheck 

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

SessionCheck used to check authentication.

func (*Spanner) SessionClosed 

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

SessionClosed impl.

func (*Spanner) SessionDec added in v1.0.1 

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

SessionDec decrease client connection metrics.

func (*Spanner) SessionInc added in v1.0.1 

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

SessionInc increase client connection metrics, it need the user is assigned

func (*Spanner) SetReadOnly 

func (spanner *Spanner) SetReadOnly(val bool)

SetReadOnly used to set readonly.

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.