mysql

Documentation

Index

• Constants
• type Mysql
  • func (mysql *Mysql) GapInStream(tcptuple *common.TcpTuple, dir uint8, private protos.ProtocolData) protos.ProtocolData
  • func (mysql *Mysql) Init(test_mode bool, results chan common.MapStr) error
  • func (mysql *Mysql) InitDefaults()
  • func (mysql *Mysql) Parse(pkt *protos.Packet, tcptuple *common.TcpTuple, dir uint8, ...) protos.ProtocolData
  • func (mysql *Mysql) ReceivedFin(tcptuple *common.TcpTuple, dir uint8, private protos.ProtocolData) protos.ProtocolData
• type MysqlMessage
• type MysqlStream
  • func (stream *MysqlStream) PrepareForNewMessage()
• type MysqlTransaction

Constants

const (
	TransactionsHashSize = 2 ^ 16
	TransactionTimeout   = 10 * 1e9
)

const (
	MysqlStateStart = iota
	MysqlStateEatMessage
	MysqlStateEatFields
	MysqlStateEatRows
)

const MAX_PAYLOAD_SIZE = 100 * 1024

const (
	MYSQL_CMD_QUERY = 3
)

Packet types

Types

type Mysql

type Mysql struct {
	Send_request  bool
	Send_response bool
	// contains filtered or unexported fields
}

func (*Mysql) GapInStream

func (mysql *Mysql) GapInStream(tcptuple *common.TcpTuple, dir uint8,
	private protos.ProtocolData) protos.ProtocolData

func (*Mysql) Init

func (mysql *Mysql) Init(test_mode bool, results chan common.MapStr) error

func (*Mysql) InitDefaults

func (mysql *Mysql) InitDefaults()

func (*Mysql) Parse

func (mysql *Mysql) Parse(pkt *protos.Packet, tcptuple *common.TcpTuple,
	dir uint8, private protos.ProtocolData) protos.ProtocolData

func (*Mysql) ReceivedFin

func (mysql *Mysql) ReceivedFin(tcptuple *common.TcpTuple, dir uint8,
	private protos.ProtocolData) protos.ProtocolData

type MysqlMessage

type MysqlMessage struct {
	Ts             time.Time
	IsRequest      bool
	PacketLength   uint32
	Seq            uint8
	Typ            uint8
	NumberOfRows   int
	NumberOfFields int
	Size           uint64
	Fields         []string
	Rows           [][]string
	Tables         string
	IsOK           bool
	AffectedRows   int
	InsertId       int
	IsError        bool
	ErrorCode      int
	ErrorInfo      string
	Query          string
	IgnoreMessage  bool

	Direction    uint8
	IsTruncated  bool
	TcpTuple     common.TcpTuple
	CmdlineTuple *common.CmdlineTuple
	Raw          []byte
	// contains filtered or unexported fields
}

type MysqlStream

type MysqlStream struct {
	// contains filtered or unexported fields
}

func (*MysqlStream) PrepareForNewMessage

func (stream *MysqlStream) PrepareForNewMessage()

type MysqlTransaction

type MysqlTransaction struct {
	Type string

	Src          common.Endpoint
	Dst          common.Endpoint
	ResponseTime int32
	Ts           int64
	JsTs         time.Time

	Query  string
	Method string
	Path   string // for mysql, Path refers to the mysql table queried
	Size   uint64

	Mysql common.MapStr

	Request_raw  string
	Response_raw string
	// contains filtered or unexported fields
}