Versions in this module Expand all Collapse all v1 v1.0.2 Nov 27, 2021 Changes in this version + const PACKET_BUFFER_SIZE + const PACKET_MAX_SIZE + var ErrBadConn = errors.New("connection.was.bad") + var ErrMalformPacket = errors.New("Malform.packet.error") + type MockConn struct + func NewMockConn() *MockConn + func (m *MockConn) Close() error + func (m *MockConn) Datas() []byte + func (m *MockConn) LocalAddr() net.Addr + func (m *MockConn) Read(b []byte) (n int, err error) + func (m *MockConn) RemoteAddr() net.Addr + func (m *MockConn) SetDeadline(t time.Time) error + func (m *MockConn) SetReadDeadline(t time.Time) error + func (m *MockConn) SetWriteDeadline(t time.Time) error + func (m *MockConn) Write(b []byte) (n int, err error) + type Packet struct + Datas []byte + SequenceID byte + type Packets struct + func NewPackets(c net.Conn) *Packets + func (p *Packets) Append(rawdata []byte) error + func (p *Packets) AppendColumns(columns []*querypb.Field) error + func (p *Packets) AppendEOF(flags uint16, warnings uint16) error + func (p *Packets) AppendOKWithEOFHeader(affectedRows, lastInsertID uint64, flags uint16, warnings uint16) error + func (p *Packets) Flush() error + func (p *Packets) Next() ([]byte, error) + func (p *Packets) ParseERR(data []byte) error + func (p *Packets) ParseOK(data []byte) (*proto.OK, error) + func (p *Packets) ReadColumns(colNumber int) ([]*querypb.Field, error) + func (p *Packets) ReadComQueryResponse() (*proto.OK, int, error, error) + func (p *Packets) ReadEOF() error + func (p *Packets) ReadOK() error + func (p *Packets) ReadStatementPrepareResponse(clientFlags uint32) (*proto.Statement, error) + func (p *Packets) ResetSeq() + func (p *Packets) Write(payload []byte) error + func (p *Packets) WriteCommand(command byte, payload []byte) error + func (p *Packets) WriteERR(errorCode uint16, sqlState string, format string, args ...interface{}) error + func (p *Packets) WriteOK(affectedRows, lastInsertID uint64, flags uint16, warnings uint16) error + func (p *Packets) WriteStatementPrepareResponse(clientFlags uint32, stmt *proto.Statement) error + type Stream struct + func NewStream(conn net.Conn, pktMaxSize int) *Stream + func (s *Stream) Append(data []byte) error + func (s *Stream) Flush() error + func (s *Stream) Read() (*Packet, error) + func (s *Stream) Write(data []byte) error