pgsql

Documentation

Index

• Constants
• func New(testMode bool, results publish.Transactions, cfg *common.Config) (protos.Plugin, error)
• 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) 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
  • func (stream *PgsqlStream) PrepareForNewMessage()
• type PgsqlTransaction

Constants

const (
	PgsqlStartState = iota
	PgsqlGetDataState
	PgsqlExtendedQueryState
)

const (
	SSLRequest = iota
	StartupMessage
	CancelRequest
)

Functions

func New

func New(
	testMode bool,
	results publish.Transactions,
	cfg *common.Config,
) (protos.Plugin, error)

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 *Pgsql) ConnectionTimeout() time.Duration

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) GetPorts

func (pgsql *Pgsql) GetPorts() []int

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
}