Help us shape the future of Go! Take the 2026 Go Developer Survey

pgsql

package
v1.1.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 11, 2016 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

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 *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) Init

func (pgsql *Pgsql) Init(test_mode bool, results publish.Transactions) error

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL