1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
|
package postgres
import (
"embed"
"github.com/wader/fq/format/postgres/common/pg_heap/pgproee"
"github.com/wader/fq/format/postgres/common/pg_heap/postgres"
"github.com/wader/fq/format"
"github.com/wader/fq/pkg/decode"
"github.com/wader/fq/pkg/interp"
)
// TO DO
// oom kill on 1 GB file
//go:embed pg_heap.md
var pgHeapFS embed.FS
func init() {
interp.RegisterFormat(format.Pg_Heap, &decode.Format{
Description: "PostgreSQL heap file",
DecodeFn: decodePgheap,
DefaultInArg: format.Pg_Heap_In{
Flavour: PG_FLAVOUR_POSTGRES14,
Page: 0,
Segment: 0,
},
RootArray: true,
RootName: "pages",
})
interp.RegisterFS(pgHeapFS)
}
func decodePgheap(d *decode.D) any {
d.Endian = decode.LittleEndian
var pgIn format.Pg_Heap_In
if !d.ArgAs(&pgIn) {
d.Fatalf("no flavour specified")
}
switch pgIn.Flavour {
case PG_FLAVOUR_POSTGRES10,
PG_FLAVOUR_POSTGRES11,
PG_FLAVOUR_POSTGRES12,
PG_FLAVOUR_POSTGRES13,
PG_FLAVOUR_POSTGRES14,
PG_FLAVOUR_POSTGRES15,
PG_FLAVOUR_PGPRO10,
PG_FLAVOUR_PGPRO11,
PG_FLAVOUR_PGPRO12,
PG_FLAVOUR_PGPRO13,
PG_FLAVOUR_PGPRO14,
PG_FLAVOUR_PGPRO15:
return postgres.DecodeHeap(d, pgIn)
case PG_FLAVOUR_PGPROEE10,
PG_FLAVOUR_PGPROEE11,
PG_FLAVOUR_PGPROEE12,
PG_FLAVOUR_PGPROEE13,
PG_FLAVOUR_PGPROEE14,
PG_FLAVOUR_PGPROEE15:
return pgproee.DecodeHeap(d, pgIn)
default:
break
}
return postgres.DecodeHeap(d, pgIn)
}
|
