postgres

Documentation

Index

• Constants
• Variables
• func DecodeBytes(encoded string) []byte
• func ErrorResponse(msg, severity, code, detail string) []byte
• func GetQueryFromRequest(req interface{}) (string, error)
• func GetTablesFromQuery(query string) ([]string, error)
• func HandleClientMessage(req *v1.Struct, logger hclog.Logger) (*v1.Struct, error)
• func HandleServerMessage(resp *v1.Struct, logger hclog.Logger) (*v1.Struct, error)
• func IsPostgresSSLRequest(b []byte) bool
• func IsPostgresStartupMessage(b []byte) bool

Constants

const MinPgSQLMessageLength = 5

Variables

var PostgreSQLFrontEndMessageTypes = []uint8{
	'B',
	'C',
	'D',
	'E',
	'F',
	'f',
	'd',
	'c',
	'H',
	'P',
	'p',
	'Q',
	'S',
	'X',
}

Functions

func DecodeBytes

func DecodeBytes(encoded string) []byte

DecodeBytes decodes a base64 encoded string to bytes.

func ErrorResponse

func ErrorResponse(msg, severity, code, detail string) []byte

func GetQueryFromRequest

func GetQueryFromRequest(req interface{}) (string, error)

GetQueryFromRequest decodes the request and returns the query.

func GetTablesFromQuery

func GetTablesFromQuery(query string) ([]string, error)

GetTablesFromQuery returns the tables used in a query.

func HandleClientMessage

func HandleClientMessage(req *v1.Struct, logger hclog.Logger) (*v1.Struct, error)

HandleClientMessage handles the client message. This function should be called from onTrafficFromClient hook.

func HandleServerMessage

func HandleServerMessage(resp *v1.Struct, logger hclog.Logger) (*v1.Struct, error)

HandleServerMessage handles the server response. This function should be called from onTrafficFromServer hook.

func IsPostgresSSLRequest

func IsPostgresSSLRequest(b []byte) bool

IsPostgresSSLRequest returns true if the message is a SSL request.

func IsPostgresStartupMessage

func IsPostgresStartupMessage(b []byte) bool

IsPostgresStartupMessage returns true if the message is a startup message.