Function pgFrame

server/conn_skip_until_sync_test.go:74–79

pgFrame builds a framed wire-protocol message: type byte + int32 length (including itself) + body.

(msgType byte, body []byte)

// pgFrame builds a framed wire-protocol message: type byte + int32 length
// (including itself) + body.
func pgFrame(msgType byte, body []byte) []byte {
	frame := make([]byte, 0, 5+len(body))
	frame = append(frame, msgType)
	frame = binary.BigEndian.AppendUint32(frame, uint32(4+len(body)))
	return append(frame, body...)
}

func parseFrame(stmtName, query string) []byte {
	var body bytes.Buffer