diagnostics.go RawHistoryFolder

1package dgram
2
3import (
4	"log/slog"
5	"time"
6
7	"github.com/bnema/vev/internal/ports"
8)
9
10const diagnosticBufferSize = 16
11
12// Diagnostic is an immutable, privacy-safe snapshot of UDP link health.
13// It intentionally contains no packet payloads, addresses, keys, or identities.
14type Diagnostic struct {
15	At                       time.Time
16	State                    ports.LinkState
17	SinceAuthenticatedPacket time.Duration
18	SinceCompleteRecord      time.Duration
19	SinceACKProgress         time.Duration
20	PendingRecords           int
21	PendingBytes             int
22	Retransmits              uint64
23	ReassemblyInflight       int
24}
25
26// DiagnosticObserver receives bounded asynchronous UDP health snapshots.
27type DiagnosticObserver func(Diagnostic)
28
29// DiagnosticLogObserver returns an observer suitable for composition roots. It
30// logs only the privacy-safe diagnostic counters and ages.
31func DiagnosticLogObserver(log *slog.Logger) DiagnosticObserver {
32	if log == nil {
33		return nil
34	}
35	return func(d Diagnostic) {
36		log.Debug("udp health",
37			"state", d.State,
38			"since_authenticated_packet", d.SinceAuthenticatedPacket,
39			"since_complete_record", d.SinceCompleteRecord,
40			"since_ack_progress", d.SinceACKProgress,
41			"pending_records", d.PendingRecords,
42			"pending_bytes", d.PendingBytes,
43			"retransmits", d.Retransmits,
44			"reassembly_inflight", d.ReassemblyInflight,
45		)
46	}
47}