server

Documentation

Index

• type Handler
  • func NewHandler(readTimeout time.Duration, conf *config.Conf, logger *zap.SugaredLogger, ...) *Handler
  • func (h *Handler) ComInitDB(c *mysql.Conn, schemaName string) error
  • func (h *Handler) ComPrepare(c *mysql.Conn, query string) ([]*query.Field, error)
  • func (h *Handler) ComQuery(c *mysql.Conn, query string, callback func(*sqltypes.Result) error) (err error)
  • func (h *Handler) ComResetConnection(c *mysql.Conn)
  • func (h *Handler) ComStmtExecute(c *mysql.Conn, prepare *mysql.PrepareData, ...) error
  • func (h *Handler) ConnectionClosed(c *mysql.Conn)
  • func (h *Handler) NewConnection(c *mysql.Conn)
  • func (h *Handler) WarningCount(c *mysql.Conn) uint16
• type Listener
  • func NewListener(protocol, address string, handler *Handler) (*Listener, error)
  • func (l *Listener) Accept() (net.Conn, error)
• type Server
  • func NewServer(conf *config.Conf) (*Server, error)
  • func (s *Server) Close() error
  • func (s *Server) Start() error
• type Session
  • func (s *Session) GetDSN() *ntunnel.DSN
  • func (s *Session) SetDSN(dsn string) (err error)
• type SessionManager
  • func NewSessionManager() *SessionManager
  • func (sm *SessionManager) DeleteSession(conn *mysql.Conn)
  • func (sm *SessionManager) GetSession(conn *mysql.Conn) *Session
  • func (sm *SessionManager) NewSession(conn *mysql.Conn)

Types

type Handler

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

func NewHandler

func NewHandler(readTimeout time.Duration, conf *config.Conf, logger *zap.SugaredLogger, sm *SessionManager) *Handler

func (*Handler) ComInitDB

func (h *Handler) ComInitDB(c *mysql.Conn, schemaName string) error

func (*Handler) ComPrepare

func (h *Handler) ComPrepare(c *mysql.Conn, query string) ([]*query.Field, error)

func (*Handler) ComQuery

func (h *Handler) ComQuery(
	c *mysql.Conn,
	query string,
	callback func(*sqltypes.Result) error,
) (err error)

func (*Handler) ComResetConnection

func (h *Handler) ComResetConnection(c *mysql.Conn)

func (*Handler) ComStmtExecute

func (h *Handler) ComStmtExecute(c *mysql.Conn, prepare *mysql.PrepareData, callback func(*sqltypes.Result) error) error

func (*Handler) ConnectionClosed

func (h *Handler) ConnectionClosed(c *mysql.Conn)

func (*Handler) NewConnection

func (h *Handler) NewConnection(c *mysql.Conn)

func (*Handler) WarningCount

func (h *Handler) WarningCount(c *mysql.Conn) uint16

type Listener

type Listener struct {
	net.Listener
	// contains filtered or unexported fields
}

func NewListener

func NewListener(protocol, address string, handler *Handler) (*Listener, error)

func (*Listener) Accept

func (l *Listener) Accept() (net.Conn, error)

type Server

type Server struct {
	Listener *mysql.Listener
	// contains filtered or unexported fields
}

func NewServer

func NewServer(conf *config.Conf) (*Server, error)

func (*Server) Close

func (s *Server) Close() error

func (*Server) Start

func (s *Server) Start() error

type Session

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

func (*Session) GetDSN

func (s *Session) GetDSN() *ntunnel.DSN

func (*Session) SetDSN

func (s *Session) SetDSN(dsn string) (err error)

type SessionManager

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

func NewSessionManager

func NewSessionManager() *SessionManager

func (*SessionManager) DeleteSession

func (sm *SessionManager) DeleteSession(conn *mysql.Conn)

func (*SessionManager) GetSession

func (sm *SessionManager) GetSession(conn *mysql.Conn) *Session

func (*SessionManager) NewSession

func (sm *SessionManager) NewSession(conn *mysql.Conn)