server

Documentation

Index

• Variables
• func FindForKey(key string, shardNum int) int
• type AutoKey
  • func (a *AutoKey) Get() uint64
  • func (a *AutoKey) OK() bool
  • func (a *AutoKey) Set(id, interval uint64)
• type Bpool
  • func NewBpool() *Bpool
  • func (p *Bpool) CloseDB(backend *meta.Backend) error
  • func (p *Bpool) GetConn(backend *meta.Backend) (*client.Conn, error)
  • func (p *Bpool) PushConn(backend *meta.Backend, conn *client.Conn, err error)
• type MetaCache
  • func NewMetaCache(info *meta.Info) *MetaCache
  • func (m *MetaCache) Del(name string, args ...string)
  • func (m *MetaCache) GetTable(name, db, table string) (*Table, error)
• type Plan
• type SQL
• type Server
  • func NewSever() *Server
  • func (s *Server) GetInfo() *meta.Info
  • func (s *Server) Run()
  • func (s *Server) StartDDLMange()
• type Table
  • func (t *Table) GetKey(field string, interval uint64, info *meta.Info) (string, error)

Variables

var DEFAULT_CAPABILITY uint32 = mysql.CLIENT_LONG_PASSWORD | mysql.CLIENT_LONG_FLAG |
	mysql.CLIENT_CONNECT_WITH_DB | mysql.CLIENT_PROTOCOL_41 |
	mysql.CLIENT_TRANSACTIONS | mysql.CLIENT_SECURE_CONNECTION

Functions

func FindForKey

func FindForKey(key string, shardNum int) int

Types

type AutoKey

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

func (*AutoKey) Get

func (a *AutoKey) Get() uint64

func (*AutoKey) OK

func (a *AutoKey) OK() bool

func (*AutoKey) Set

func (a *AutoKey) Set(id, interval uint64)

type Bpool

type Bpool struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewBpool

func NewBpool() *Bpool

func (*Bpool) CloseDB

func (p *Bpool) CloseDB(backend *meta.Backend) error

func (*Bpool) GetConn

func (p *Bpool) GetConn(backend *meta.Backend) (*client.Conn, error)

func (*Bpool) PushConn

func (p *Bpool) PushConn(backend *meta.Backend, conn *client.Conn, err error)

type MetaCache

type MetaCache struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewMetaCache

func NewMetaCache(info *meta.Info) *MetaCache

func (*MetaCache) Del

func (m *MetaCache) Del(name string, args ...string)

func (*MetaCache) GetTable

func (m *MetaCache) GetTable(name, db, table string) (*Table, error)

type Plan

type Plan struct {
	SQLs  []*SQL
	Table *Table
	// contains filtered or unexported fields
}

type SQL

type SQL struct {
	Backend *meta.Backend
	SQL     []string
}

type Server

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

func NewSever

func NewSever() *Server

func (*Server) GetInfo

func (s *Server) GetInfo() *meta.Info

func (*Server) Run

func (s *Server) Run()

func (*Server) StartDDLMange

func (s *Server) StartDDLMange()

type Table

type Table struct {
	Backends []*meta.Backend
	Table    *meta.Table
	// contains filtered or unexported fields
}

func (*Table) GetKey

func (t *Table) GetKey(field string, interval uint64, info *meta.Info) (string, error)