Mitchell-JohnsonandClaude Fable 5.1
4ddf10be51
- stock Monitors modules fed by one sensor stream, the catalog and one batch of histories (GET /api/sensors/history?ids=…), through sampleAdapter.ts - the stream closes while the page is hidden and refills its curves on return - Disks tab live rates from the stream - new sensors: hamlab.sample_interval, ups.last_event - stream: asking for about the sampling rate means every sample - NUT runtime rounded at the source Co-Authored-By: Claude Fable 5.1 <noreply@anthropic.com>
57 lines
2.0 KiB
Go
57 lines
2.0 KiB
Go
package metrics
|
|
|
|
import "testing"
|
|
|
|
func TestFlatten(t *testing.T) {
|
|
s := Sample{T: 1000, CPU: 10, Cores: []float64{5, 15}, Mem: Mem{Total: 200, Used: 50},
|
|
Temps: []Temp{{Chip: "nvme", Label: "Composite", C: 40, Crit: 85}, {Chip: "nvme", Label: "Composite", C: 45}},
|
|
Fans: []Fan{{Chip: "nct6775", Label: "fan2", RPM: 1100}},
|
|
FS: []FS{{Mount: "/", Size: 100, Used: 25}}, fsT: 900}
|
|
got := map[string]any{}
|
|
for _, x := range flatten(s, nil) {
|
|
if _, dup := got[x.ID]; dup {
|
|
t.Errorf("duplicate id %s", x.ID)
|
|
}
|
|
got[x.ID] = x.Value
|
|
}
|
|
for id, want := range map[string]any{"cpu.usage": 10.0, "cpu.core.1.usage": 15.0, "mem.used_pct": 25.0, "temp.nvme.composite": 40.0,
|
|
"temp.nvme.composite_2": 45.0, "fan.nct6775.fan2": 1100.0, "fs.root.used_pct": 25.0} {
|
|
if got[id] != want {
|
|
t.Errorf("%s = %v, want %v", id, got[id], want)
|
|
}
|
|
}
|
|
one := flatten(s, func(id string) bool { return id == "temp.nvme.composite_2" })
|
|
if len(one) != 1 || one[0].Value != 45.0 {
|
|
t.Errorf("only: got %+v", one)
|
|
}
|
|
for _, x := range flatten(s, func(id string) bool { return id == "fs.root.used" }) {
|
|
if x.T != 900 {
|
|
t.Errorf("fs sensor should carry the fs read time, got %d", x.T)
|
|
}
|
|
}
|
|
}
|
|
|
|
func TestSensorHistories(t *testing.T) {
|
|
c := NewCollector()
|
|
c.ring = []Sample{{T: 1, CPU: 10}, {T: 2, CPU: 20, Net: []Net{{Iface: "eth0", Up: true, RxBps: 5}}}}
|
|
got := map[string][]float64{}
|
|
for _, h := range c.SensorHistories(func(id string) bool { return id == "cpu.usage" || id == "net.eth0.rx" || id == "net.eth0.up" }) {
|
|
if len(h.T) != len(h.V) {
|
|
t.Errorf("%s: t and v differ in length", h.ID)
|
|
}
|
|
got[h.ID] = h.V
|
|
}
|
|
if len(got["cpu.usage"]) != 2 || got["cpu.usage"][1] != 20 {
|
|
t.Errorf("cpu: %v", got["cpu.usage"])
|
|
}
|
|
if len(got["net.eth0.rx"]) != 1 {
|
|
t.Errorf("a sensor that appeared later has a shorter history, got %v", got["net.eth0.rx"])
|
|
}
|
|
if _, ok := got["net.eth0.up"]; ok {
|
|
t.Error("a state has no history")
|
|
}
|
|
if len(c.SensorHistories(func(string) bool { return false })) != 0 {
|
|
t.Error("nothing matched, nothing returned")
|
|
}
|
|
}
|