inbound_mysql

type ClientCommandQueryPacket struct {
	Statement string
}

type ClientCommandStatementClosePacket struct {
	StatementId uint32
}

type ClientCommandStatementPreparePacket struct {
	Statement string
}

type EndpointSide string

type MySQLConn struct {
	State MySQLConnState

	CommandQueue list.List
	QueueLock    sync.Mutex

	SQLSnifferHandler    SQLSnifferHandler
	UnknownPacketHandler UnknownPacketHandler

	DebugUnknownPacketType bool
	DebugRawPacket         bool
}

type MySQLConnState int32

type OkPacket struct {
}

type Packet interface {
	PacketType() PacketType
}

type PacketType int

type RawPacket struct {
	Length uint32
	SeqId  uint8
	Data   []byte
}

type SQLSnifferHandler func(sql string)

type ServerCommandStatementResponsePacket struct {
	StatementId uint32
}

type UnknownPacket struct {
	Type uint8
	Data []byte
}

type UnknownPacketHandler func(packet *RawPacket, side EndpointSide)