decoding

Sep 25, 2021

Changes in this version

+ const INT24Width

+ type CommandCode byte

+ func (c CommandCode) String() string

+ type ConnectionBuilder interface

+ AddToConnection func(request bool, seen []time.Time, typeName string, item interface{})

+ Compressed func() bool

+ JustSeenGreeting func() bool

+ ParamsForQuery func(query uint32) uint16

+ PreviousRequestType func() string

+ type Emitter interface

+ ConnectionBuilder func() ConnectionBuilder

+ Transmission func(typeName string, t interface{})

+ type MySQLConnectionBuilder struct

+ Address structure.ConnectionAddress

+ Readers *MySQLConnectionReaders

+ Requests []structure.Transmission

+ Responses []structure.Transmission

+ func NewBuilder(address structure.ConnectionAddress, readers *MySQLConnectionReaders) *MySQLConnectionBuilder

+ func (b *MySQLConnectionBuilder) AddToConnection(request bool, seen []time.Time, typeName string, item interface{})

+ func (b *MySQLConnectionBuilder) Compressed() bool

+ func (b *MySQLConnectionBuilder) Connection(noSort bool) structure.Connection

+ func (b *MySQLConnectionBuilder) DecodeConnection()

+ func (b *MySQLConnectionBuilder) JustSeenGreeting() bool

+ func (b *MySQLConnectionBuilder) ParamsForQuery(query uint32) uint16

+ func (b *MySQLConnectionBuilder) PreviousRequestType() string

+ func (b *MySQLConnectionBuilder) ReadDone()

+ func (b *MySQLConnectionBuilder) RequestPacketBuffer(t packet.TimesSeen) *packet.Buffer

+ func (b *MySQLConnectionBuilder) ResponsePacketBuffer(t packet.TimesSeen) *packet.Buffer

+ type MySQLConnectionReaders struct

+ IntermediateData bool

+ RawData bool

+ func New(intermediateData bool, rawData bool, verbose bool) *MySQLConnectionReaders

+ func (h *MySQLConnectionReaders) ConnectionBuilder(address structure.ConnectionAddress) *MySQLConnectionBuilder

+ func (h *MySQLConnectionReaders) GetConnections(noSort bool) []structure.Connection

+ func (h *MySQLConnectionReaders) ReadStream(r tcp.Stream, a, b gopacket.Flow)

+ type RawDataEmitter struct

+ func SetupRawDataEmitter(e Emitter, wrt io.Writer) (io.Writer, *RawDataEmitter)

+ func (e *RawDataEmitter) ConnectionBuilder() ConnectionBuilder

+ func (e *RawDataEmitter) Transmission(typeName string, t interface{})

+ type RequestDecoder struct

+ Emit Emitter

+ func (m *RequestDecoder) String() string

+ func (m *RequestDecoder) Write(p []byte) (int, error)

+ type ResponseDecoder struct

+ Emit Emitter

+ Fields []structure.ColumnInfo

+ Results [][]interface{}

+ State readState

+ func (m *ResponseDecoder) DecodeBinaryResult(b *bytes.Buffer) error

+ func (m *ResponseDecoder) FlushResponse()

+ func (m *ResponseDecoder) ResetState()

+ func (m *ResponseDecoder) String() string

+ func (m *ResponseDecoder) Write(p []byte) (int, error)

+ type TransmissionEmitter struct

+ Builder *MySQLConnectionBuilder

+ Request bool

+ Times packet.TimesSeen

+ func (e *TransmissionEmitter) ConnectionBuilder() ConnectionBuilder

+ func (e *TransmissionEmitter) Transmission(typeName string, t interface{})