wire

Documentation

Overview

Package wire provides encoding and decoding operation of MySQL packets.

Index

• Constants
• func DecodePayload(ctx context.Context, logger *zap.Logger, data []byte, clientConn net.Conn, ...) (*mysql.PacketBundle, error)
• func EncodeToBinary(ctx context.Context, logger *zap.Logger, packet *mysql.PacketBundle, ...) ([]byte, error)
• func GetCachingSha2PasswordMechanism(data byte) (string, error)
• func GetPluginName(buf interface{}) (string, error)
• func IsGenericResponsePkt(packet *mysql.PacketBundle) bool
• func IsNoResponseCommand(command string) bool
• func PrintByteArray(name string, b []byte)
• func StringToCachingSha2PasswordMechanism(data string) (mysql.CachingSha2Password, error)
• type DecodeContext
• type LastOperation
  • func NewLastOpMap() *LastOperation
  • func (lo *LastOperation) Load(key net.Conn) (value byte, ok bool)
  • func (lo *LastOperation) Store(key net.Conn, value byte)
• type ServerGreetings
  • func NewGreetings() *ServerGreetings
  • func (sg *ServerGreetings) Load(key net.Conn) (*mysql.HandshakeV10Packet, bool)
  • func (sg *ServerGreetings) Store(key net.Conn, value *mysql.HandshakeV10Packet)

Constants

const RESET = 0x00

Functions

func DecodePayload

func DecodePayload(ctx context.Context, logger *zap.Logger, data []byte, clientConn net.Conn, decodeCtx *DecodeContext) (*mysql.PacketBundle, error)

DecodePayload is used to decode mysql packets that don't consist of multiple packets within them, because we are reading per packet.

func EncodeToBinary

func EncodeToBinary(ctx context.Context, logger *zap.Logger, packet *mysql.PacketBundle, clientConn net.Conn, decodeCtx *DecodeContext) ([]byte, error)

func GetCachingSha2PasswordMechanism

func GetCachingSha2PasswordMechanism(data byte) (string, error)

func GetPluginName

func GetPluginName(buf interface{}) (string, error)

func IsGenericResponsePkt

func IsGenericResponsePkt(packet *mysql.PacketBundle) bool

func IsNoResponseCommand

func IsNoResponseCommand(command string) bool

func PrintByteArray

func PrintByteArray(name string, b []byte)

PrintByteArray is only for debugging purpose

func StringToCachingSha2PasswordMechanism

func StringToCachingSha2PasswordMechanism(data string) (mysql.CachingSha2Password, error)

Types

type DecodeContext

type DecodeContext struct {
	Mode               models.Mode
	LastOp             *LastOperation
	PreparedStatements map[uint32]*mysql.StmtPrepareOkPacket
	ServerGreetings    *ServerGreetings
	ClientCapabilities uint32
	PluginName         string
}

type LastOperation

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

func NewLastOpMap

func NewLastOpMap() *LastOperation

func (*LastOperation) Load

func (lo *LastOperation) Load(key net.Conn) (value byte, ok bool)

func (*LastOperation) Store

func (lo *LastOperation) Store(key net.Conn, value byte)

type ServerGreetings

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

func NewGreetings

func NewGreetings() *ServerGreetings

func (*ServerGreetings) Load

func (sg *ServerGreetings) Load(key net.Conn) (*mysql.HandshakeV10Packet, bool)

func (*ServerGreetings) Store

func (sg *ServerGreetings) Store(key net.Conn, value *mysql.HandshakeV10Packet)