diff options
| author | Paul Buetow <paul@buetow.org> | 2026-02-25 08:36:59 +0200 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2026-02-25 08:36:59 +0200 |
| commit | 87462508e417816c3f1ae832e02bda19c1642ec9 (patch) | |
| tree | 37a427c88e60b2c97ca899f6103bdf7b138f7ff1 /internal/ior.go | |
| parent | 39bbe57ca8022a516b8139710ec879e81ab21736 (diff) | |
Wire event stream source into TUI trace pipeline
Diffstat (limited to 'internal/ior.go')
| -rw-r--r-- | internal/ior.go | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/internal/ior.go b/internal/ior.go index 55c637c..da5d6db 100644 --- a/internal/ior.go +++ b/internal/ior.go @@ -17,6 +17,7 @@ import ( "ior/internal/statsengine" "ior/internal/tracepoints" "ior/internal/tui" + "ior/internal/tui/eventstream" bpf "github.com/aquasecurity/libbpfgo" ) @@ -142,7 +143,9 @@ func tuiTraceStarterFromRunTrace( }) engine := statsengine.NewEngine(64) + streamBuf := eventstream.NewRingBuffer() tui.SetDashboardSnapshotSource(engine) + tui.SetEventStreamSource(streamBuf) startedCh := make(chan struct{}) errCh := make(chan error, 1) @@ -151,6 +154,7 @@ func tuiTraceStarterFromRunTrace( errCh <- startTrace(ctx, startedCh, func(el *eventLoop) { el.printCb = func(ep *event.Pair) { engine.Ingest(ep) + streamBuf.Push(eventstream.NewStreamEvent(ep.EnterEv.GetTime(), ep)) ep.Recycle() } }) |