postgres

Documentation

Index

• Variables
• func DecodeBytes(v string) []byte
• 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

Variables

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

Functions

func DecodeBytes

func DecodeBytes(v string) []byte

DecodeBytes decodes a base64 encoded string to bytes.

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.