server

Index ¶

• type ColumnInfo
• • func (column *ColumnInfo) Dump(alloc arena.Allocator) []byte
• type FrameItem
• • func NewFrameItemFromRegionKey(key []byte) (frame *FrameItem, err error)
• type IDriver
• type IndexRegions
• type PreparedStatement
• type QueryCtx
• type RegionDetail
• type RegionFrameRange
• • func NewRegionFrameRange(region *tikv.KeyLocation) (idxRange *RegionFrameRange, err error)
• type RegionMeta
• type ResultSet
• type Server
• • func NewServer(cfg *config.Config, driver IDriver) (*Server, error)
• • func (s *Server) Close()
  • func (s *Server) ConnectionCount() int
  • func (s *Server) Kill(connectionID uint64, query bool)
  • func (s *Server) Run() error
  • func (s *Server) ShowProcessList() []util.ProcessInfo
• type TableRegions
• type TiDBContext
• • func (tc *TiDBContext) AffectedRows() uint64
  • func (tc *TiDBContext) Auth(user *auth.UserIdentity, auth []byte, salt []byte) bool
  • func (tc *TiDBContext) Cancel()
  • func (tc *TiDBContext) Close() error
  • func (tc *TiDBContext) CommitTxn() error
  • func (tc *TiDBContext) CurrentDB() string
  • func (tc *TiDBContext) Execute(sql string) (rs []ResultSet, err error)
  • func (tc *TiDBContext) FieldList(table string) (columns []*ColumnInfo, err error)
  • func (tc *TiDBContext) GetStatement(stmtID int) PreparedStatement
  • func (tc *TiDBContext) LastInsertID() uint64
  • func (tc *TiDBContext) Prepare(sql string) (statement PreparedStatement, columns, params []*ColumnInfo, err error)
  • func (tc *TiDBContext) RollbackTxn() error
  • func (tc *TiDBContext) SetClientCapability(flags uint32)
  • func (tc *TiDBContext) SetSessionManager(sm util.SessionManager)
  • func (tc *TiDBContext) SetValue(key fmt.Stringer, value interface{})
  • func (tc *TiDBContext) ShowProcess() util.ProcessInfo
  • func (tc *TiDBContext) Status() uint16
  • func (tc *TiDBContext) Value(key fmt.Stringer) interface{}
  • func (tc *TiDBContext) WarningCount() uint16
• type TiDBDriver
• • func NewTiDBDriver(store kv.Storage) *TiDBDriver
• • func (qd *TiDBDriver) OpenCtx(connID uint64, capability uint32, collation uint8, dbname string, ...) (QueryCtx, error)
• type TiDBStatement
• • func (ts *TiDBStatement) AppendParam(paramID int, data []byte) error
  • func (ts *TiDBStatement) BoundParams() [][]byte
  • func (ts *TiDBStatement) Close() error
  • func (ts *TiDBStatement) Execute(args ...interface{}) (rs ResultSet, err error)
  • func (ts *TiDBStatement) GetParamsType() []byte
  • func (ts *TiDBStatement) ID() int
  • func (ts *TiDBStatement) NumParams() int
  • func (ts *TiDBStatement) Reset()
  • func (ts *TiDBStatement) SetParamsType(paramsType []byte)
• type Token
• type TokenLimiter
• • func NewTokenLimiter(count int) *TokenLimiter
• • func (tl *TokenLimiter) Get() *Token
  • func (tl *TokenLimiter) Put(tk *Token)