Documentation
¶
Index ¶
- Constants
- type Pgsql
- func (pgsql *Pgsql) GapInStream(tcptuple *common.TcpTuple, dir uint8, private protos.ProtocolData) protos.ProtocolData
- func (pgsql *Pgsql) Init(test_mode bool, results chan common.MapStr) error
- func (pgsql *Pgsql) InitDefaults()
- func (pgsql *Pgsql) Parse(pkt *protos.Packet, tcptuple *common.TcpTuple, dir uint8, ...) protos.ProtocolData
- func (pgsql *Pgsql) ReceivedFin(tcptuple *common.TcpTuple, dir uint8, private protos.ProtocolData) protos.ProtocolData
- type PgsqlMessage
- type PgsqlStream
- type PgsqlTransaction
Constants ¶
View Source
const ( TransactionsHashSize = 2 ^ 16 TransactionTimeout = 10 * 1e9 )
View Source
const ( PgsqlStartState = iota PgsqlGetDataState )
View Source
const ( SSLRequest = iota StartupMessage CancelRequest )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Pgsql ¶
type Pgsql struct {
Send_request bool
Send_response bool
// contains filtered or unexported fields
}
func (*Pgsql) GapInStream ¶
func (pgsql *Pgsql) GapInStream(tcptuple *common.TcpTuple, dir uint8, private protos.ProtocolData) protos.ProtocolData
Called when there's a drop packet
func (*Pgsql) InitDefaults ¶
func (pgsql *Pgsql) InitDefaults()
func (*Pgsql) Parse ¶
func (pgsql *Pgsql) Parse(pkt *protos.Packet, tcptuple *common.TcpTuple, dir uint8, private protos.ProtocolData) protos.ProtocolData
func (*Pgsql) ReceivedFin ¶
func (pgsql *Pgsql) ReceivedFin(tcptuple *common.TcpTuple, dir uint8, private protos.ProtocolData) protos.ProtocolData
type PgsqlMessage ¶
type PgsqlMessage struct {
Ts time.Time
IsRequest bool
Query string
Size uint64
Fields []string
FieldsFormat []byte
Rows [][]string
NumberOfRows int
NumberOfFields int
IsOK bool
IsError bool
ErrorInfo string
ErrorCode string
ErrorSeverity string
Direction uint8
Incomplete bool
TcpTuple common.TcpTuple
CmdlineTuple *common.CmdlineTuple
// contains filtered or unexported fields
}
type PgsqlStream ¶
type PgsqlStream struct {
// contains filtered or unexported fields
}
func (*PgsqlStream) PrepareForNewMessage ¶
func (stream *PgsqlStream) PrepareForNewMessage()
Click to show internal directories.
Click to hide internal directories.