listener

Documentation

Index

• func NewHttpListener(conf *config.Listener) (proto.Listener, error)
• func NewMysqlListener(conf *config.Listener) (proto.Listener, error)
• type HttpConfig
• type HttpListener
  • func (l *HttpListener) Close()
  • func (l *HttpListener) Listen()
• type MysqlConfig
• type MysqlListener
  • func (l *MysqlListener) Close()
  • func (l *MysqlListener) ExecuteCommand(ctx context.Context, c *mysql.Conn, data []byte) error
  • func (l *MysqlListener) Listen()
  • func (l *MysqlListener) SetExecutor(executor proto.Executor)
  • func (l *MysqlListener) ValidateHash(user string, salt []byte, authResponse []byte) error

Functions

func NewHttpListener

func NewHttpListener(conf *config.Listener) (proto.Listener, error)

func NewMysqlListener

func NewMysqlListener(conf *config.Listener) (proto.Listener, error)

Types

type HttpConfig

type HttpConfig struct {
	BackendHost string `yaml:"backend_host" json:"backend_host"`
}

type HttpListener

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

func (*HttpListener) Close

func (l *HttpListener) Close()

func (*HttpListener) Listen

func (l *HttpListener) Listen()

type MysqlConfig

type MysqlConfig struct {
	Users         map[string]string `yaml:"users" json:"users"`
	ServerVersion string            `yaml:"server_version" json:"server_version"`
}

type MysqlListener

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

func (*MysqlListener) Close

func (l *MysqlListener) Close()

func (*MysqlListener) ExecuteCommand

func (l *MysqlListener) ExecuteCommand(ctx context.Context, c *mysql.Conn, data []byte) error

func (*MysqlListener) Listen

func (l *MysqlListener) Listen()

func (*MysqlListener) SetExecutor

func (l *MysqlListener) SetExecutor(executor proto.Executor)

func (*MysqlListener) ValidateHash

func (l *MysqlListener) ValidateHash(user string, salt []byte, authResponse []byte) error