diff options
| author | Paul Buetow <paul@buetow.org> | 2026-05-18 19:13:59 +0300 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2026-05-18 19:13:59 +0300 |
| commit | 65599ad9b87b1c61cb6d8232200da88952370e96 (patch) | |
| tree | 862e20468835255ed06544a2df2470678d3b97dc /internal/parquet | |
| parent | a92cb0283b1ba8735a6697a8f94911397534131f (diff) | |
t6 add syscall family dashboard aggregation
Diffstat (limited to 'internal/parquet')
| -rw-r--r-- | internal/parquet/recorder_test.go | 1 | ||||
| -rw-r--r-- | internal/parquet/schema.go | 2 |
2 files changed, 3 insertions, 0 deletions
diff --git a/internal/parquet/recorder_test.go b/internal/parquet/recorder_test.go index 66c22a3..76d70a5 100644 --- a/internal/parquet/recorder_test.go +++ b/internal/parquet/recorder_test.go @@ -137,6 +137,7 @@ func testStreamRow(seq uint64, syscall string, isError bool) streamrow.Row { Seq: seq, TimeNs: seq * 10, Syscall: syscall, + Family: "FS", Comm: "ior-test", PID: 100 + uint32(seq), TID: 200 + uint32(seq), diff --git a/internal/parquet/schema.go b/internal/parquet/schema.go index 62d448b..03937bf 100644 --- a/internal/parquet/schema.go +++ b/internal/parquet/schema.go @@ -21,6 +21,7 @@ type Record struct { PID uint32 `parquet:"pid"` TID uint32 `parquet:"tid"` Syscall string `parquet:"syscall"` + Family string `parquet:"family"` FD int32 `parquet:"fd"` Ret int64 `parquet:"ret"` Bytes uint64 `parquet:"bytes"` @@ -62,6 +63,7 @@ func RecordFromStream(row streamrow.Row, filterEpoch uint64) Record { PID: row.PID, TID: row.TID, Syscall: row.Syscall, + Family: row.Family, FD: row.FD, Ret: row.RetVal, Bytes: row.Bytes, |