tcjlj/flvx
1
0
Fork 0
mirror of https://github.com/Sagit-chu/flvx.git synced 2026-09-29 07:56:37 +08:00
Code Issues Packages Projects Releases Wiki Activity

Tunnel metrics ingestion logging improvements (#364)

Browse Source 
Added debug logging for better tunnel metrics monitoring.
This commit is contained in:
sagit
2026-03-21 19:22:32 +08:00
committed by GitHub
parent 32e4f0f514 949dfcd42d
commit 433c8aab13
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
go-backend/internal/http/handler/tunnel_metrics_ingestion.go
+9
View File
@@ -35,6 +35,7 @@ func (h *Handler) recordTunnelMetricsFromFlowItems(nodeID int64, items []flowIte
} }
forwardDeltas := make(map[int64]tunnelTrafficDelta) forwardDeltas := make(map[int64]tunnelTrafficDelta)
var skippedParse, skippedZero int
for _, item := range items { for _, item := range items {
name := strings.TrimSpace(item.N) name := strings.TrimSpace(item.N)
if name == "" || name == "web_api" { if name == "" || name == "web_api" {
@@ -42,9 +43,11 @@ func (h *Handler) recordTunnelMetricsFromFlowItems(nodeID int64, items []flowIte
} }
forwardID, _, _, ok := parseFlowServiceIDs(name) forwardID, _, _, ok := parseFlowServiceIDs(name)
if !ok { if !ok {
skippedParse++
continue continue
} }
if item.D == 0 && item.U == 0 { if item.D == 0 && item.U == 0 {
skippedZero++
continue continue
} }
d := forwardDeltas[forwardID] d := forwardDeltas[forwardID]
@@ -53,6 +56,9 @@ func (h *Handler) recordTunnelMetricsFromFlowItems(nodeID int64, items []flowIte
forwardDeltas[forwardID] = d forwardDeltas[forwardID] = d
} }
if len(forwardDeltas) == 0 { if len(forwardDeltas) == 0 {
if len(items) > 0 {
log.Printf("monitoring debug op=tunnel_metric.no_forward_deltas node_id=%d items=%d skipped_parse=%d skipped_zero=%d", nodeID, len(items), skippedParse, skippedZero)
}
return return
} }
@@ -67,6 +73,7 @@ func (h *Handler) recordTunnelMetricsFromFlowItems(nodeID int64, items []flowIte
return return
} }
if len(forwardTunnelMap) == 0 { if len(forwardTunnelMap) == 0 {
log.Printf("monitoring debug op=tunnel_metric.no_tunnel_map node_id=%d forward_ids=%v", nodeID, forwardIDs)
return return
} }
@@ -107,5 +114,7 @@ func (h *Handler) recordTunnelMetricsFromFlowItems(nodeID int64, items []flowIte
if err := h.repo.UpsertTunnelMetricBuckets(metrics); err != nil { if err := h.repo.UpsertTunnelMetricBuckets(metrics); err != nil {
log.Printf("monitoring write failed op=tunnel_metric.upsert_buckets node_id=%d bucket_ts=%d count=%d err=%v", nodeID, bucketTs, len(metrics), err) log.Printf("monitoring write failed op=tunnel_metric.upsert_buckets node_id=%d bucket_ts=%d count=%d err=%v", nodeID, bucketTs, len(metrics), err)
} else {
log.Printf("monitoring ok op=tunnel_metric.upsert_buckets node_id=%d bucket_ts=%d count=%d", nodeID, bucketTs, len(metrics))
} }
} }