mrlee
74d731d0ac
CI / verify (push) Canceled after 0s
- 自动备份：每日一份（按最新备份是否在 24h 内判定，重启不重复）、保留份数可配、列表/下载/恢复/删除，恢复前先校验归档；顺手修 writeArchive 逐个检查 tar/gzip/文件 Close()（审查报告 §二） - 健康持续化：只存状态变更（up/down/unknown）并推导可用率与不可用区间；公开状态页默认关闭、访问码存 SHA-256、按 IP 限流、只暴露域名与可用率 - 隧道判定修复：RouteHealthCandidate 新增 tunnel_known，frps 管理接口不可用时不再把「判不出来」当成「不通」（此前会误报「隧道连续不通」）；汇总与徽标同样区分「无法判定」 - 指标历史：metrics_samples 纵向点表（本机 CPU/内存/磁盘 + 每规则上下行，30 天保留、查询按桶平均、不做降采样表）；仪表盘趋势卡支持 1h/24h/7d - 仪表盘布局：运行状态并入顶部统计区（运行时长补进「服务」卡）；性能并入系统资源那一行，整行 4 列 - 测试：backup/metrics/frp/api/app 新增用例；gofmt、go build/vet/test、vue-tsc、vite build 全绿 - agent 无改动，AgentVersion 保持 0.12.2
83 lines
2.6 KiB
Go
83 lines
2.6 KiB
Go
package metrics
|
|
|
|
import (
|
|
"testing"
|
|
"time"
|
|
)
|
|
|
|
func TestBucketizeAveragesAndSkipsEmptyBuckets(t *testing.T) {
|
|
from := time.Date(2026, 9, 25, 0, 0, 0, 0, time.UTC)
|
|
to := from.Add(time.Hour)
|
|
|
|
// 12 个 5 分钟桶：第 0 桶两个点（取平均）、第 1 桶一个、第 11 桶一个
|
|
at := []time.Time{
|
|
from.Add(time.Minute),
|
|
from.Add(2 * time.Minute),
|
|
from.Add(6 * time.Minute),
|
|
from.Add(59 * time.Minute),
|
|
}
|
|
values := []float64{10, 20, 30, 40}
|
|
|
|
points := Bucketize(at, values, from, to, 12)
|
|
if len(points) != 3 {
|
|
t.Fatalf("空桶不该产出点（否则图上会出现凭空补 0 的谷底），实际 %d 个：%+v", len(points), points)
|
|
}
|
|
if points[0].Value != 15 {
|
|
t.Fatalf("第 0 桶应为 (10+20)/2=15，实际 %v", points[0].Value)
|
|
}
|
|
if points[0].At != from.Format(time.RFC3339) {
|
|
t.Fatalf("桶时间戳应为桶起点，实际 %q", points[0].At)
|
|
}
|
|
if points[1].Value != 30 || points[2].Value != 40 {
|
|
t.Fatalf("后续桶取值不对：%+v", points)
|
|
}
|
|
}
|
|
|
|
func TestBucketizeDropsOutOfWindowPoints(t *testing.T) {
|
|
from := time.Date(2026, 9, 25, 0, 0, 0, 0, time.UTC)
|
|
to := from.Add(time.Hour)
|
|
|
|
at := []time.Time{from.Add(-time.Minute), from.Add(30 * time.Minute), to.Add(time.Minute)}
|
|
values := []float64{1, 2, 3}
|
|
points := Bucketize(at, values, from, to, 12)
|
|
if len(points) != 1 || points[0].Value != 2 {
|
|
t.Fatalf("窗口外的点应被丢掉，实际 %+v", points)
|
|
}
|
|
|
|
if points := Bucketize(at[:1], values[:1], from, to, 12); len(points) != 0 {
|
|
t.Fatalf("全在窗口外时应返回空，实际 %+v", points)
|
|
}
|
|
}
|
|
|
|
func TestBucketizeRejectsDegenerateInput(t *testing.T) {
|
|
from := time.Date(2026, 9, 25, 0, 0, 0, 0, time.UTC)
|
|
values := []float64{1}
|
|
|
|
if points := Bucketize([]time.Time{from}, values, from, from, 12); points != nil {
|
|
t.Fatalf("零宽窗口应返回 nil，实际 %+v", points)
|
|
}
|
|
if points := Bucketize([]time.Time{from}, values, from, from.Add(time.Hour), 0); points != nil {
|
|
t.Fatalf("桶数为 0 应返回 nil，实际 %+v", points)
|
|
}
|
|
if points := Bucketize(nil, nil, from, from.Add(time.Hour), 12); points != nil {
|
|
t.Fatalf("没有样本应返回 nil，实际 %+v", points)
|
|
}
|
|
}
|
|
|
|
func TestBucketizeKeepsPointsShorterThanValues(t *testing.T) {
|
|
from := time.Date(2026, 9, 25, 0, 0, 0, 0, time.UTC)
|
|
points := Bucketize([]time.Time{from.Add(time.Minute)}, nil, from, from.Add(time.Hour), 12)
|
|
if len(points) != 0 {
|
|
t.Fatalf("值与时刻数量不一致时应忽略多出的时刻，实际 %+v", points)
|
|
}
|
|
}
|
|
|
|
func TestPercent(t *testing.T) {
|
|
if got := Percent(0, 0); got != 0 {
|
|
t.Fatalf("总量为 0 应返回 0，实际 %v", got)
|
|
}
|
|
if got := Percent(50, 200); got != 25 {
|
|
t.Fatalf("期望 25，实际 %v", got)
|
|
}
|
|
}
|