server

package

Go to main page

Versions in this module

v0

v0.7.3

Aug 16, 2018

v0.7.2

Aug 2, 2018

Changes in this version

type SharkStoreApi

+ func (api *SharkStoreApi) MultSelect(s *Server, dbName string, tableName string, fields []string, ...) *Reply

v0.7.1

Aug 1, 2018

v0.6.4

Aug 1, 2018

v0.6.3

Jul 27, 2018

Changes in this version

+ var MockDs *mock_ds.DsRpcServer

+ var MockMs *mock_ms.Cluster

+ func CloseMock(p *Proxy)

+ func UpdateConfig(addr string) error

type BenchMarkConfig

+ Scope int

type Proxy

+ func (p *Proxy) LockScan(dbName, tableName string, startKey, endKey string, number uint32) (*kvrpcpb.LockScanResponse, error)

v0.6.2

Jun 18, 2018

v0.6.1

Jun 17, 2018

Changes in this version

+ const ADMIN_ALLOW_IP

+ const ADMIN_BLACK_SQL

+ const ADMIN_CONFIG

+ const ADMIN_LOG_SQL

+ const ADMIN_NODE

+ const ADMIN_OPT_ADD

+ const ADMIN_OPT_CHANGE

+ const ADMIN_OPT_DEL

+ const ADMIN_OPT_DOWN

+ const ADMIN_OPT_SHOW

+ const ADMIN_OPT_UP

+ const ADMIN_PROXY

+ const ADMIN_SAVE_CONFIG

+ const ADMIN_SCHEMA

+ const ADMIN_SLOW_LOG_TIME

+ const ADMIN_STATUS

+ const CountFunc

+ const DefaultConfig

+ const DefaultDeleteSlowLog

+ const DefaultGrpcInitWinSize

+ const DefaultGrpcPoolSize

+ const DefaultHttpPort

+ const DefaultInsertSlowLog

+ const DefaultLockRpcPort

+ const DefaultMaxRawCount

+ const DefaultMaxSlowLogLen

+ const DefaultMaxTaskQueueLen

+ const DefaultMaxWorkNum

+ const DefaultSelectSlowLog

+ const DefaultServerName

+ const DefaultSqlPort

+ const FUNC_EXIST

+ const LOCK_EPOCH_ERROR

+ const LOCK_EXIST_ERROR

+ const LOCK_FORCE_UNLOCK_ERROR

+ const LOCK_NAMESPACE_NO_EXIST

+ const LOCK_NETWORK_ERROR

+ const LOCK_NOT_EXIST_ERROR

+ const LOCK_NOT_OWNER_ERROR

+ const LOCK_NO_SUPPORT_FORCE_UNLOCK

+ const LOCK_OK

+ const LOCK_STORE_ERROR

+ const LastInsertIdFunc

+ const Master

+ const MasterComment

+ const MaxFunc

+ const MinFunc

+ const NodeRegion

+ const Offline

+ const Online

+ const ServerRegion

+ const Slave

+ const SumFunc

+ const Unknown

+ var DEFAULT_CAPABILITY uint32 = ...

+ var ErrAffectRows = errors.New("affect rows is not equal")

+ var ErrCreateDatabase = errors.New(" create database err")

+ var ErrCreateTable = errors.New("create table err")

+ var ErrEmptyRow = errors.New("empty row")

+ var ErrExceedMaxLimit = errors.New("exceeding the maximum limit")

+ var ErrHttpCmdEmpty = errors.New("command empty")

+ var ErrHttpCmdParse = errors.New("parse error")

+ var ErrHttpCmdRun = errors.New("run error")

+ var ErrHttpCmdUnknown = errors.New("invalid command")

+ var ErrInternalError = errors.New("internal error")

+ var ErrInvalidColumn = errors.New("invalid column")

+ var ErrNoRoute = errors.New("no route")

+ var ErrNotExistDatabase = errors.New("database not exist")

+ var ErrNotExistNode = errors.New("node not exist")

+ var ErrNotExistPeer = errors.New("range peer not exist")

+ var ErrNotExistRange = errors.New("range not exist")

+ var ErrNotExistTable = errors.New("table not exist")

+ var Lock_epoch_error string = "range epoch error"

+ var Lock_error_name = map[int64]string

+ var Lock_exist_error string = "lock exist"

+ var Lock_force_unlock_error string = "force unlock ing"

+ var Lock_namespace_no_exist string = "namespace not exist"

+ var Lock_network_error string = "network exception"

+ var Lock_no_suport_force_unlock string = "no support force unlock"

+ var Lock_not_exist_error string = "lock not exist"

+ var Lock_not_owner_error string = "not lock owner"

+ var Lock_store_error string = "raft store error"

+ func CodeToErr(code int) error

+ func ComposeTS(physical, logical int64) uint64

+ func ExtractPhysical(ts uint64) int64

+ func LimitListener(l net.Listener, n int) net.Listener

+ func PutInsertTask(task *InsertTask)

+ func PutSelectTask(task *SelectTask)

+ type And struct

+ Field *Field_

+ Or []*Or

+ Relate string

+ type BenchMarkConfig struct

+ Batch int

+ DB string

+ DataLen int

+ SendNum int

+ Table string

+ Threads int

+ Type int

+ type BlacklistSqls struct

+ type ClientConn struct

+ func (c *ClientConn) AddDatabase(nodeName string, role string, addr string) error

+ func (c *ClientConn) Close() error

+ func (c *ClientConn) DeleteDatabase(nodeName string, role string, addr string) error

+ func (c *ClientConn) DownDatabase(nodeName string, role string, addr string) error

+ func (c *ClientConn) Handshake() error

+ func (c *ClientConn) IsAllowConnect() bool

+ func (c *ClientConn) Run()

+ func (c *ClientConn) UpDatabase(nodeName string, role string, addr string) error

+ type ClusterConfig struct

+ ID uint64

+ ServerAddr []string

+ Token string

+ type Column struct

+ DataType string

+ Name string

+ PrimaryKey bool

+ Unsigned bool

+ type Command struct

+ Field []string

+ Filter *Filter_

+ PKs [][]*And

+ Type string

+ Values [][]interface{}

+ Version string

+ type Config struct

+ BenchConfig BenchMarkConfig

+ Charset string

+ Cluster ClusterConfig

+ HttpPort int

+ LockRpcPort int

+ Log LogConfig

+ MaxClients int

+ MaxLimit uint64

+ Metric MetricConfig

+ Password string

+ Performance PerformConfig

+ SqlPort int

+ User string

+ func (c *Config) LoadConfig(configFileName *string)

+ type Counter struct

+ ClientConns int64

+ ClientQPS int64

+ ErrLogTotal int64

+ OldClientQPS int64

+ OldErrLogTotal int64

+ OldSlowLogTotal int64

+ SlowLogTotal int64

+ func (counter *Counter) DecrClientConns()

+ func (counter *Counter) FlushCounter()

+ func (counter *Counter) IncrClientConns()

+ func (counter *Counter) IncrClientQPS()

+ func (counter *Counter) IncrErrLogTotal()

+ func (counter *Counter) IncrSlowLogTotal()

+ type CreateDatabase struct

+ DatabaseName string

+ Sign string

+ type CreateTable struct

+ Columns []*Column

+ DatabaseName string

+ Sign string

+ TableName string

+ type DataBase struct

+ func NewDataBase(db *metapb.DataBase, cli client.Client) *DataBase

+ func (d *DataBase) AddTable(t *Table)

+ func (d *DataBase) DbId() uint64

+ func (d *DataBase) DbName() string

+ func (d *DataBase) FindTable(tableName string) *Table

+ type ExecuteDB struct

+ type Field struct

+ type Field_ struct

+ Column string

+ Value interface{}

+ type Filter struct

+ type Filter_ struct

+ And []*And

+ Limit *Limit_

+ Order []*Order

+ Scope *Scope

+ type InsertResult struct

+ func (r *InsertResult) GetAffected() uint64

+ func (r *InsertResult) GetDuplicateKey() []byte

+ type InsertRowValue []SQLValue

+ type InsertTask struct

+ func GetInsertTask() *InsertTask

+ func (it *InsertTask) Do()

+ func (it *InsertTask) Reset()

+ func (it *InsertTask) Wait() error

+ type KvParisSlice []*kvrpcpb.KeyValue

+ func (p KvParisSlice) Len() int

+ func (p KvParisSlice) Less(i int, j int) bool

+ func (p KvParisSlice) Swap(i int, j int)

+ type Limit struct

+ type Limit_ struct

+ Offset uint64

+ RowCount uint64

+ type LogConfig struct

+ Dir string

+ Level string

+ Module string

+ type Match struct

+ type MatchType int

+ var Equal MatchType = 1

+ var Invalid MatchType = 0

+ var Larger MatchType = 5

+ var LargerOrEqual MatchType = 6

+ var Less MatchType = 3

+ var LessOrEqual MatchType = 4

+ var NotEqual MatchType = 2

+ type MetricConfig struct

+ Address string

+ Interval util.Duration

+ type Or struct

+ And []*And

+ Field *Field_

+ Relate MatchType

+ type Order struct

+ By string

+ Desc bool

+ type PerformConfig struct

+ DeleteSlowLog util.Duration

+ GrpcInitWinSize int

+ GrpcPoolSize int

+ InsertSlowLog util.Duration

+ MaxTaskQueueLen uint64

+ MaxWorkNum uint64

+ SelectSlowLog util.Duration

+ SlowLogMaxLen uint64

+ type Proxy struct

+ func NewProxy(msAddrs []string, config *Config) *Proxy

+ func (p *Proxy) Close()

+ func (p *Proxy) EncodeRow(t *Table, colMap map[string]int, rowValue InsertRowValue) (*kvrpcpb.KeyValue, error)

+ func (p *Proxy) HandleAdmin(db string, cmd string, args []string) (*mysql.Result, error)

+ func (p *Proxy) HandleDelete(db string, stmt *sqlparser.Delete, args []interface{}) (*mysql.Result, error)

+ func (p *Proxy) HandleDescribe(db string, stmt *sqlparser.Describe) (*mysql.Result, error)

+ func (p *Proxy) HandleInsert(db string, stmt *sqlparser.Insert, args []interface{}) (*mysql.Result, error)

+ func (p *Proxy) HandleSelect(db string, stmt *sqlparser.Select, args []interface{}) (*mysql.Result, error)

+ func (p *Proxy) HandleTruncate(db string, stmt *sqlparser.Truncate) (*mysql.Result, error)

+ func (p *Proxy) Lock(dbName, tableName string, lockName string, userCondition []byte, uuid string, ...) (*kvrpcpb.LockResponse, error)

+ func (p *Proxy) LockUpdate(dbName, tableName string, lockName string, uuid string, condition []byte) (*kvrpcpb.LockResponse, error)

+ func (p *Proxy) RawDelete(dbName, tableName string, key []byte) error

+ func (p *Proxy) RawGet(dbName, tableName string, key []byte) ([]byte, error)

+ func (p *Proxy) RawPut(dbName, tableName string, key, value []byte) error

+ func (p *Proxy) Submit(t Task) error

+ func (p *Proxy) Unlock(dbName, tableName string, lockName, uuid, userName string) (*kvrpcpb.LockResponse, error)

+ func (p *Proxy) UnlockForce(dbName, tableName string, lockName, userName string) (*kvrpcpb.LockResponse, error)

+ func (p *Proxy) UpdateCondition(dbName, tableName string, lockName string, userCondition []byte) (*kvrpcpb.LockResponse, error)

+ type Query struct

+ Command *Command

+ DatabaseName string

+ Sign string

+ TableName string

+ type Reply struct

+ Code int

+ Message string

+ RowsAffected uint64

+ Values [][]interface{}

+ type Response struct

+ Code int

+ Data interface{}

+ Message string

+ type ResultRow struct

+ RowData mysql.RowData

+ Value []interface{}

+ type Router struct

+ func NewRouter(cli client.Client) *Router

+ func (rr *Router) FindColumn(db, table, clo string) *metapb.Column

+ func (rr *Router) FindDB(dbname string) *DataBase

+ func (rr *Router) FindTable(dbName, tableName string) *Table

+ func (rr *Router) GetAllColumns(db, table string) []*metapb.Column

+ type Row struct

+ type SQLValue []byte

+ type Scope struct

+ End []byte

+ Start []byte

+ type SelColumn struct

+ type SelectResult struct

+ type SelectTask struct

+ func GetSelectTask() *SelectTask

+ func (it *SelectTask) Do()

+ func (it *SelectTask) Reset()

+ func (it *SelectTask) Wait() error

+ type Server struct

+ func NewServer(cfg *Config) (*Server, error)

+ func (s *Server) ChangeProxy(v string) error

+ func (s *Server) Close()

+ func (s *Server) GetCfg() *Config

+ func (s *Server) Run() error

+ func (s *Server) Status() string

+ func (service *Server) DoHeartbeat(ctx context.Context, req *lockrpcpb.LockHeartbeatRequest) (*lockrpcpb.DLockResponse, error)

+ func (service *Server) ForceUnLock(ctx context.Context, req *lockrpcpb.ForceUnLockRequest) (*lockrpcpb.DLockResponse, error)

+ func (service *Server) Lock(ctx context.Context, req *lockrpcpb.LockRequest) (*lockrpcpb.DLockResponse, error)

+ func (service *Server) UnLock(ctx context.Context, req *lockrpcpb.UnLockRequest) (*lockrpcpb.DLockResponse, error)

+ func (service *Server) UpdateCondition(ctx context.Context, req *lockrpcpb.UpdateConditionRequest) (*lockrpcpb.DLockResponse, error)

+ type Session struct

+ func NewSession(id uint64, conn net.Conn) *Session

+ func (s *Session) Close()

+ func (s *Session) ID() uint64

+ func (s *Session) IsClosed() bool

+ func (s *Session) Process()

+ type SharkStoreApi struct

+ func (api *SharkStoreApi) Delete() *Reply

+ func (api *SharkStoreApi) Insert(s *Server, dbName string, tableName string, fields []string, ...) *Reply

+ func (api *SharkStoreApi) Select(s *Server, dbName string, tableName string, fields []string, ...) *Reply

+ type SortRoutes []*metapb.Route

+ func (s SortRoutes) Len() int

+ func (s SortRoutes) Less(i, j int) bool

+ func (s SortRoutes) Swap(i, j int)

+ type Stmt struct

+ func (s *Stmt) ResetParams()

+ type StmtParser struct

+ type Table struct

+ func NewTable(table *metapb.Table, cli client.Client, ttl time.Duration) *Table

+ func (t *Table) AddColumn(c *metapb.Column)

+ func (t *Table) AllIndexs() []uint64

+ func (t *Table) AllRoutes() []*dskv.KeyLocation

+ func (t *Table) DbName() string

+ func (t *Table) DeleteColumn(columnName string)

+ func (t *Table) FindColumn(columnName string) *metapb.Column

+ func (t *Table) FindColumnById(columnId uint64) *metapb.Column

+ func (t *Table) GetAllColumns() []*metapb.Column

+ func (t *Table) ID() uint64

+ func (t *Table) Name() string

+ func (t *Table) PKS() []string

+ func (t *Table) PkDupCheck() bool

+ type Task interface

+ Do func()

+ Reset func()

+ Wait func() error

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