pangolin

wangjia/pangolin

Fork 0

Commit Graph

Author	SHA1	Message	Date
wangjia	5d4b484646	feat(alert): 统一告警出口 TG bot + runbook [tsk_9YMHMTfWJyNB] 新增 server/internal/alert 包（15G）： - 定义 Notifier 接口及 7 种 EventType（判封确认/补新失败/水位低/熔断/ 探针失联/心跳缺失/故障态） - TGNotifier：Bot API 发送，Critical 事件不去重，Warning/Info 事件 10min SETNX 去重窗口，失败重试 ≤2 次后降级至 LogNotifier - LogNotifier：slog 结构化降级实现 - 单测：7 种事件模板 + runbook 锚点正确性；去重窗口内第二条被抑制； TG 5xx 重试后 fallback 且 Notify() 返回 nil； runbook 文件锚点与枚举一致性接入 scheduler（替换旧的 NotifyFault 桩）： - detect/engine.go：故障态（Rule 5）→ EventTypeFault；判封确认（Rule 3）→ EventTypeBlockConfirmed - orchestrate/deps.go：Notifier 类型别名指向 alert.Notifier - orchestrate/replacer.go：补新失败 → EventTypeReplenishFailed；熔断触发 → EventTypeBreakerTripped - probe/prober_agent.go：failCount ≥3 → EventTypeProbeAgentLost - probe/store.go：新增 CheckHeartbeats() 供 15H 检测心跳缺失>90s 新增 docs/runbook-scheduler.md：7 节各含含义/先查什么/处置/升级条件，锚点与代码枚举对应。 Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>	2026-06-16 00:52:26 +08:00
wangjia	a47121f99b	feat(probe): add third-party dial-test adapter for 15C (tsk_-WC9smQK7YRt) Implements ProberAgent interface + Alibaba Cloud CloudMonitor Synthetic adapter: - ProbeTarget / VantageResult types aligned with 15A schema (L3 always nil) - AliyunSyntheticAgent: CreateSiteMonitor → poll → map to VantageResult - ISP vantage uses "3rd-{ISP}" prefix; Redis key probe:{node}:CN:{region}:3rd-* - Degradation: API error/rate-limit/timeout → skip vantage, log + counter (no write) - RunOnce(ctx, targets) shape for 15H assembly wiring - Credentials via cfg only (env-var injection, zero hardcoded secrets) - 6 new tests (mock vendor server): normalization, rate-limit, timeout, Redis keys, failed-target L1, no-credentials check; all 22 probe-package tests pass Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>	2026-06-13 17:21:43 +08:00
wangjia	f76e1797c2	merge: maestro/tsk_rBPr0Xuy10bz [tsk_rBPr0Xuy10bz] 探针汇聚入口 + Redis 探针存储 (tsk_eu2qVvni1HJR) Manually apply changes from maestro/tsk_rBPr0Xuy10bz that could not be auto-merged due to uncommitted changes on main at merge time. Added: - server/internal/scheduler/probe/types.go – frozen schema types (ReportRequest, VantagePoint, NodeReport, L1/L2/L3Result, ProbeSnapshot) - server/internal/scheduler/probe/store.go – Redis Store: SaveReports, CheckAndMarkSeen, SnapshotsByNode, AliveProbes with TTL constants and key-schema docs - server/internal/scheduler/probe/ingest.go – IngestHandler (POST /probe/report), HMAC-SHA256 auth + timestamp window + replay prevention via SetNX - server/internal/scheduler/probe/ingest_test.go – 17 tests (auth failures, integration, Store unit tests); all pass with miniredis Updated: - server/cmd/server/main.go – register /probe/report route when PROBE_SECRETS env is set Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>	2026-06-13 14:35:24 +08:00

Author

SHA1

Message

Date

wangjia

5d4b484646

feat(alert): 统一告警出口 TG bot + runbook [tsk_9YMHMTfWJyNB]

新增 server/internal/alert 包（15G）：
- 定义 Notifier 接口及 7 种 EventType（判封确认/补新失败/水位低/熔断/
  探针失联/心跳缺失/故障态）
- TGNotifier：Bot API 发送，Critical 事件不去重，Warning/Info 事件
  10min SETNX 去重窗口，失败重试 ≤2 次后降级至 LogNotifier
- LogNotifier：slog 结构化降级实现
- 单测：7 种事件模板 + runbook 锚点正确性；去重窗口内第二条被抑制；
  TG 5xx 重试后 fallback 且 Notify() 返回 nil；
  runbook 文件锚点与枚举一致性

接入 scheduler（替换旧的 NotifyFault 桩）：
- detect/engine.go：故障态（Rule 5）→ EventTypeFault；
  判封确认（Rule 3）→ EventTypeBlockConfirmed
- orchestrate/deps.go：Notifier 类型别名指向 alert.Notifier
- orchestrate/replacer.go：补新失败 → EventTypeReplenishFailed；
  熔断触发 → EventTypeBreakerTripped
- probe/prober_agent.go：failCount ≥3 → EventTypeProbeAgentLost
- probe/store.go：新增 CheckHeartbeats() 供 15H 检测心跳缺失>90s

新增 docs/runbook-scheduler.md：7 节各含含义/先查什么/处置/升级条件，
锚点与代码枚举对应。

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

2026-06-16 00:52:26 +08:00

wangjia

a47121f99b

feat(probe): add third-party dial-test adapter for 15C (tsk_-WC9smQK7YRt)

Implements ProberAgent interface + Alibaba Cloud CloudMonitor Synthetic adapter:
- ProbeTarget / VantageResult types aligned with 15A schema (L3 always nil)
- AliyunSyntheticAgent: CreateSiteMonitor → poll → map to VantageResult
- ISP vantage uses "3rd-{ISP}" prefix; Redis key probe:{node}:CN:{region}:3rd-*
- Degradation: API error/rate-limit/timeout → skip vantage, log + counter (no write)
- RunOnce(ctx, targets) shape for 15H assembly wiring
- Credentials via cfg only (env-var injection, zero hardcoded secrets)
- 6 new tests (mock vendor server): normalization, rate-limit, timeout, Redis keys,
  failed-target L1, no-credentials check; all 22 probe-package tests pass

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

2026-06-13 17:21:43 +08:00

wangjia

f76e1797c2

merge: maestro/tsk_rBPr0Xuy10bz [tsk_rBPr0Xuy10bz] 探针汇聚入口 + Redis 探针存储 (tsk_eu2qVvni1HJR)

Manually apply changes from maestro/tsk_rBPr0Xuy10bz that could not be
auto-merged due to uncommitted changes on main at merge time.

Added:
- server/internal/scheduler/probe/types.go  – frozen schema types (ReportRequest,
  VantagePoint, NodeReport, L1/L2/L3Result, ProbeSnapshot)
- server/internal/scheduler/probe/store.go  – Redis Store: SaveReports, CheckAndMarkSeen,
  SnapshotsByNode, AliveProbes with TTL constants and key-schema docs
- server/internal/scheduler/probe/ingest.go – IngestHandler (POST /probe/report),
  HMAC-SHA256 auth + timestamp window + replay prevention via SetNX
- server/internal/scheduler/probe/ingest_test.go – 17 tests (auth failures, integration,
  Store unit tests); all pass with miniredis

Updated:
- server/cmd/server/main.go – register /probe/report route when PROBE_SECRETS env is set

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

2026-06-13 14:35:24 +08:00

3 Commits