parser

package

Go to main page

Versions in this module

v0

v0.3.1

Sep 13, 2025

v0.3.0

Jul 24, 2025

v0.3.0-alpha.1

Jul 24, 2025

v0.2.2

Dec 27, 2024

v0.2.1

Apr 24, 2024

v0.2.0

Jan 17, 2024

Changes in this version

type ClientFlags

+ const ClientQueryAttributes

type Context

+ QueryAttributes bool

type QueryPacket

+ ParamCount *UintV

+ ParamSetCount *UintV

type UintV

+ func (v *UintV) Uint64() uint64

v0.1.0

Dec 6, 2023

Changes in this version

+ const Close

+ const CreateDB

+ const DropDB

+ const Execute

+ const Fetch

+ const FieldList

+ const InitDB

+ const Prepare

+ const ProcessInfo

+ const Query

+ const Quit

+ const Refresh

+ const Reset

+ const SendLongData

+ const SetOption

+ const Shutdown

+ const Sleep

+ const Statistics

+ var ErrNotEnoughBuffer = errors.New("not enough buffer")

+ var ReuseBufferMaxSize = 1024 * 1024

+ func NewCOMPacket(b []byte, ctx *Context) (interface{}, error)

+ type AwaitingReplyPacket struct

+ func NewAwaitingReplyPacket(b []byte) (*AwaitingReplyPacket, error)

+ type COMPacket struct

+ Raw []byte

+ Type CommandType

+ func (p *COMPacket) CommandType() CommandType

+ type ClientAuthResendPacket struct

+ func NewClientAuthResendPacket(b []byte) (*ClientAuthResendPacket, error)

+ type ClientFlags uint32

+ const ClientCanHandleExpiredPasswords

+ const ClientCapabilityExtension

+ const ClientCompress

+ const ClientConnectAttrs

+ const ClientConnectWithDB

+ const ClientDeprecateEOF

+ const ClientFoundRows

+ const ClientIgnoreSIGPIPE

+ const ClientIgnoreSpace

+ const ClientInteractive

+ const ClientLocalFiles

+ const ClientLongFlag

+ const ClientLongPassword

+ const ClientMultiResults

+ const ClientMultiStatements

+ const ClientNoSchema

+ const ClientODBC

+ const ClientOptionalResultsetMetadata

+ const ClientPSMultiResults

+ const ClientPluginAuth

+ const ClientPluginAuthLenEncClientData

+ const ClientProtocol41

+ const ClientRememberOptions

+ const ClientReserved

+ const ClientSSL

+ const ClientSSLVerifyServerCert

+ const ClientSecureConn

+ const ClientSessionTrack

+ const ClientTransactions

+ const ClientZstdCompressionAlgorithm

+ const MultiFactorAuthorization

+ type ClientHandshakePacket struct

+ Charset uint8

+ ClientFlags ClientFlags

+ Database string

+ HashedPassword *StringV

+ MaxPacketSize uint32

+ Username string

+ func NewClientHandshakePacket(b []byte) (*ClientHandshakePacket, error)

+ type CloseQueryPacket struct

+ StatementID uint32

+ func NewCloseQueryPacket(b []byte) (*CloseQueryPacket, error)

+ type Command interface

+ CommandType func() CommandType

+ type CommandType int

+ type Context struct

+ ClientFlags ClientFlags

+ Compressing bool

+ Data interface{}

+ FieldNCurr uint64

+ FieldNMax uint64

+ LastCommand CommandType

+ PreparedStmts map[uint32]Stmt

+ ResultState ResultState

+ State State

+ WillCompress bool

+ func (ctx *Context) IsClientDeprecateEOF() bool

+ type CountReader struct

+ N uint64

+ R io.Reader

+ func (cr *CountReader) Read(p []byte) (int, error)

+ type EOFPacket struct

+ ServerStatus uint16

+ WarningCount uint16

+ func NewEOFPacket(b []byte) (*EOFPacket, error)

+ type ErrorPacket struct

+ Message string

+ Number uint16

+ State string

+ func NewErrorPacket(b []byte) (*ErrorPacket, error)

+ type ExecuteQueryPacket struct

+ CursorType uint8

+ Parameters []interface{}

+ StatementID uint32

+ Types []FieldType

+ func NewExecuteQueryPacket(b []byte, ctx *Context) (*ExecuteQueryPacket, error)

+ func (p *ExecuteQueryPacket) CommandType() CommandType

+ type FieldListPacket struct

+ Table string

+ Wildcard string

+ func NewFieldListPacket(b []byte) (*FieldListPacket, error)

+ func (pkt *FieldListPacket) CommandType() CommandType

+ type FieldType uint16

+ const FieldTypeBLOB

+ const FieldTypeBit

+ const FieldTypeDate

+ const FieldTypeDateTime

+ const FieldTypeDecimal

+ const FieldTypeDouble

+ const FieldTypeEnum

+ const FieldTypeFloat

+ const FieldTypeGeometry

+ const FieldTypeInt24

+ const FieldTypeJSON

+ const FieldTypeLong

+ const FieldTypeLongBLOB

+ const FieldTypeLongLong

+ const FieldTypeMediumBLOB

+ const FieldTypeNULL

+ const FieldTypeNewDate

+ const FieldTypeNewDecimal

+ const FieldTypeSet

+ const FieldTypeShort

+ const FieldTypeString

+ const FieldTypeTime

+ const FieldTypeTimestamp

+ const FieldTypeTiny

+ const FieldTypeTinyBLOB

+ const FieldTypeVarChar

+ const FieldTypeVarString

+ const FieldTypeYear

+ type OKPacket struct

+ AffectedRows *UintV

+ InsertID *UintV

+ Message string

+ Status uint16

+ WarningCount uint16

+ func NewOKPacket(b []byte) (*OKPacket, error)

+ type Parser struct

+ Body []byte

+ Detail interface{}

+ PktLens []int

+ SeqNums []uint8

+ func NewFromClient(r io.Reader) *Parser

+ func NewFromServer(r io.Reader) *Parser

+ func (pa *Parser) Context() Context

+ func (pa *Parser) ContextData() interface{}

+ func (pa *Parser) PacketRawLen() uint64

+ func (pa *Parser) Parse() error

+ func (pa *Parser) SetContextData(d interface{})

+ func (pa *Parser) ShareContext(other *Parser)

+ func (pa *Parser) String() string

+ type PrepareQueryPacket struct

+ Query string

+ func NewPrepareQueryPacket(b []byte) (*PrepareQueryPacket, error)

+ func (p *PrepareQueryPacket) CommandType() CommandType

+ type PrepareResultPacket struct

+ FieldCount uint16

+ ParameterCount uint16

+ StatementID uint32

+ WarningCount uint16

+ func NewPrepareResultPacket(b []byte) (*PrepareResultPacket, error)

+ type QueryPacket struct

+ Query string

+ func NewQueryPacket(b []byte) (*QueryPacket, error)

+ func (p *QueryPacket) CommandType() CommandType

+ type QuitPacket struct

+ func (pkt *QuitPacket) CommandType() CommandType

+ type ResultFieldNumPacket struct

+ Num uint64

+ type ResultFieldPacket struct

+ Charset uint16

+ Column *StringV

+ ColumnOrigin *StringV

+ Database *StringV

+ Default *StringV

+ DotN uint8

+ Flag uint16

+ Length uint32

+ Table *StringV

+ TableOrigin *StringV

+ Type uint8

+ func NewResultFieldPacket(b []byte) (*ResultFieldPacket, error)

+ type ResultNonePacket struct

+ AffectedRows *UintV

+ InsertID *UintV

+ Message *StringV

+ ServerStatus uint16

+ WarningCount uint16

+ func NewResultNonePacket(b []byte) (*ResultNonePacket, error)

+ type ResultPacket struct

+ type ResultRecordPacket struct

+ Columns []*StringV

+ func NewResultRecordPacket(b []byte, nfields int) (*ResultRecordPacket, error)

+ type ResultState int

+ const Fields

+ const PrepareColumns

+ const PrepareParams

+ const PrepareParamsAndColumns

+ const Records

+ type ServerHandshakePacket struct

+ Charset uint8

+ Filter uint8

+ ProtocolVersion uint8

+ ScrambleBuffer uint64

+ ServerCapability uint16

+ ServerStatus uint16

+ ServerVersion string

+ ThreadID uint32

+ func NewServerHandshakePacket(b []byte) (*ServerHandshakePacket, error)

+ type State int

+ const Auth

+ const AuthResend

+ const AwaitingReply

+ const Connected

+ const Handshake

+ const None

+ type Stmt struct

+ ID uint32

+ NumColumns uint16

+ NumParams uint16

+ type StringV string

+ func (v *StringV) GoString() string

+ func (v *StringV) String() string

+ type UintV uint64

+ func (v *UintV) GoString() string

+ func (v *UintV) String() string

v0.1.0-alpha.1

Dec 6, 2023

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL