corestats.go RawHistoryFolder

1package app
2
3import (
4	"context"
5	"time"
6
7	"github.com/bnema/neferwl/internal/core"
8	"github.com/bnema/zerowrap"
9)
10
11// commandStatsEvery is how often the command outbox counters are logged,
12// like the output and input stats.
13const commandStatsEvery = 10 * time.Second
14
15// logCommandStats logs core's command counters every commandStatsEvery
16// until ctx ends. A queued command or a flush wait means the display goroutine
17// held core's commands up; a period with no counter set logs nothing (a wait
18// that ends after the tick still logs, with no new command).
19func logCommandStats(ctx context.Context, c *core.Core, log zerowrap.Logger) {
20	t := time.NewTicker(commandStatsEvery)
21	defer t.Stop()
22	for {
23		select {
24		case <-ctx.Done():
25			return
26		case <-t.C:
27		}
28		s := c.CommandStats()
29		if s == (core.CommandStats{}) {
30			continue
31		}
32		log.Info().Int("direct", s.Direct).Int("queued", s.Queued).Int("merged", s.Merged).
33			Uint64("max_backlog", s.MaxBacklog).
34			Float64("max_queue_wait_ms", s.MaxQueueWait.Seconds()*1e3).
35			Float64("max_flush_wait_ms", s.MaxFlushWait.Seconds()*1e3).Msg("outbox stats")
36	}
37}