processing

Documentation

Index

• func AssociatePGPackets(combinedQueryMetrics *metrics.QueryMetrics, responses []*ResponsePacket)
• func NormalizeQuery(query string) string
• type ResponsePacket
  • func ExtractPGPackets(handle *pcap.Handle) (*metrics.QueryMetrics, []*ResponsePacket)

Functions

func AssociatePGPackets

func AssociatePGPackets(combinedQueryMetrics *metrics.QueryMetrics, responses []*ResponsePacket)

AssociatePGPacket will go through each response and match it to a QueryMetric

func NormalizeQuery

func NormalizeQuery(query string) string

normalizeQuery is used on a raw query payload and returns a cleaned up query string.

Types

type ResponsePacket

type ResponsePacket struct {
	DstIP net.IP
	Ack   uint32
	Size  uint64
}

func ExtractPGPackets

func ExtractPGPackets(handle *pcap.Handle) (*metrics.QueryMetrics, []*ResponsePacket)