proxy

package

v0.0.0-...-48d5904 Latest Latest Go to latest Published: Feb 5, 2015 License: MIT Imports: 27 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/dongzerun/cm

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func GetRowCacheType(rowCacheType string) int
type Conn
type IServer
type Schema
type Server
- func NewServer(configFile string) (*Server, error)
type Shard
- func (shard *Shard) Close()
- func (shard *Shard) String() string
type Stmt
- func (s *Stmt) ResetParams()

Constants ¶

View Source

const (
	Master = "master"
)

Variables ¶

View Source

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 GetRowCacheType ¶

func GetRowCacheType(rowCacheType string) int

Types ¶

type Conn ¶

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

client <-> proxy

func (*Conn) Close ¶

func (c *Conn) Close() error

func (*Conn) Handshake ¶

func (c *Conn) Handshake() error

func (*Conn) Run ¶

func (c *Conn) Run()

func (*Conn) String ¶

func (c *Conn) String() string

type IServer ¶

type IServer interface {
	GetSchema(string) *Schema
	GetRowCacheSchema(string) (*tabletserver.SchemaInfo, bool)
	CfgGetPwd() string
	SkipAuth() bool
	GetToken() *tokenlimiter.Token
	ReleaseToken(token *tokenlimiter.Token)
	GetRWlock() *sync.RWMutex
	GetShard(shardId string) *Shard
	GetShardIds() []string
	AsynExec(task *execTask)
	IncCounter(key string)
	DecCounter(key string)
}

type Schema ¶

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

type Server ¶

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

func NewServer ¶

func NewServer(configFile string) (*Server, error)

func (*Server) AsynExec ¶

func (s *Server) AsynExec(task *execTask)

func (*Server) CfgGetPwd ¶

func (s *Server) CfgGetPwd() string

func (*Server) Close ¶

func (s *Server) Close()

func (*Server) DecCounter ¶

func (s *Server) DecCounter(key string)

func (*Server) GetRWlock ¶

func (s *Server) GetRWlock() *sync.RWMutex

func (*Server) GetRowCacheSchema ¶

func (s *Server) GetRowCacheSchema(db string) (*tabletserver.SchemaInfo, bool)

func (*Server) GetSchema ¶

func (s *Server) GetSchema(db string) *Schema

func (*Server) GetShard ¶

func (s *Server) GetShard(shardId string) *Shard

func (*Server) GetShardIds ¶

func (s *Server) GetShardIds() []string

func (*Server) GetToken ¶

func (s *Server) GetToken() *tokenlimiter.Token

func (*Server) HandleReload ¶

func (s *Server) HandleReload(w http.ResponseWriter, req *http.Request)

func (*Server) IncCounter ¶

func (s *Server) IncCounter(key string)

func (*Server) MapToShards ¶

func (s *Server) MapToShards(db string, table string) []string

func (*Server) ReleaseToken ¶

func (s *Server) ReleaseToken(token *tokenlimiter.Token)

func (*Server) Run ¶

func (s *Server) Run() error

func (*Server) SkipAuth ¶

func (s *Server) SkipAuth() bool

type Shard ¶

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

func (*Shard) Close ¶

func (shard *Shard) Close()

func (*Shard) String ¶

func (shard *Shard) String() string

type Stmt ¶

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

func (*Stmt) ResetParams ¶

func (s *Stmt) ResetParams()

Source Files ¶

View all Source files

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