Documentation
¶
Index ¶
- Constants
- type Pgsql
- func (pgsql *Pgsql) ConnectionTimeout() time.Duration
- func (pgsql *Pgsql) GapInStream(tcptuple *common.TcpTuple, dir uint8, nbytes int, private protos.ProtocolData) (priv protos.ProtocolData, drop bool)
- func (pgsql *Pgsql) GetPorts() []int
- func (pgsql *Pgsql) Init(test_mode bool, results publish.Transactions) 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 ( 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 {
// config
Ports []int
Send_request bool
Send_response bool
// contains filtered or unexported fields
}
func (*Pgsql) ConnectionTimeout ¶
func (*Pgsql) GapInStream ¶
func (pgsql *Pgsql) GapInStream(tcptuple *common.TcpTuple, dir uint8, nbytes int, private protos.ProtocolData) (priv protos.ProtocolData, drop bool)
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
Notes []string
Direction uint8
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()
type PgsqlTransaction ¶
type PgsqlTransaction struct {
Type string
Src common.Endpoint
Dst common.Endpoint
ResponseTime int32
Ts int64
JsTs time.Time
Query string
Method string
BytesOut uint64
BytesIn uint64
Notes []string
Pgsql common.MapStr
Request_raw string
Response_raw string
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.