proxy

Documentation

Index

• Constants
• Variables
• type Conn
  • func (c *Conn) Close() error
  • func (c *Conn) Handshake() error
  • func (c *Conn) Run()
• type MysqlConfig
• type Node
  • func (n *Node) String() string
• type Schema
• type Server
  • func NewServer(cfg *config.Config) (*Server, error)
  • func (s *Server) Close()
  • func (s *Server) DownMaster(node string) error
  • func (s *Server) DownSlave(node string) error
  • func (s *Server) GetMySqlVariable(name string) (v string, ok bool)
  • func (s *Server) GetRule(table string) *router.Rule
  • func (s *Server) Run() error
  • func (s *Server) SetMysqlConfig(mysql_config MysqlConfig)
  • func (s *Server) UpMaster(node string, addr string) error
  • func (s *Server) UpSlave(node string, addr string) error
• type Stmt
  • func (s *Stmt) ResetParams()

Constants

const (
	Master = "master"
	Slave  = "slave"
)

Variables

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

Types

type Conn

type Conn struct {
	sync.Mutex
	// 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()

type MysqlConfig

type MysqlConfig map[string]string

type Node

type Node struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*Node) String

func (n *Node) String() 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(cfg *config.Config) (*Server, error)

func (*Server) Close

func (s *Server) Close()

func (*Server) DownMaster

func (s *Server) DownMaster(node string) error

func (*Server) DownSlave

func (s *Server) DownSlave(node string) error

func (*Server) GetMySqlVariable

func (s *Server) GetMySqlVariable(name string) (v string, ok bool)

func (*Server) GetRule

func (s *Server) GetRule(table string) *router.Rule

func (*Server) Run

func (s *Server) Run() error

func (*Server) SetMysqlConfig

func (s *Server) SetMysqlConfig(mysql_config MysqlConfig)

func (*Server) UpMaster

func (s *Server) UpMaster(node string, addr string) error

func (*Server) UpSlave

func (s *Server) UpSlave(node string, addr string) error

type Stmt

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

func (*Stmt) ResetParams

func (s *Stmt) ResetParams()