postgres

Documentation

Index

• Constants
• Variables
• func DecodeBytes(encoded string) []byte
• func GetQueryFromRequest(req string) (string, error)
• func GetTablesFromQuery(query string) ([]string, error)
• func HandleClientMessage(req *structpb.Struct, logger hclog.Logger) (*structpb.Struct, error)
• func HandleServerMessage(resp *structpb.Struct, logger hclog.Logger) (*structpb.Struct, error)
• 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 GetQueryFromRequest

func GetQueryFromRequest(req string) (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 *structpb.Struct, logger hclog.Logger) (*structpb.Struct, error)

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

func HandleServerMessage

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

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

func IsPostgresStartupMessage

func IsPostgresStartupMessage(b []byte) bool

IsPostgresStartupMessage returns true if the message is a startup message.