Method Snapshot

internal/nodehub/metrics.go:70–100

Snapshot 返回当前 Hub 指标的快照。

()

// Snapshot 返回当前 Hub 指标的快照。
func (h *Hub) Snapshot() Snapshot {
	online := h.OnlineNodes()

	sum := h.metrics.callLatencyNanosSum.Load()
	cnt := h.metrics.callLatencyCount.Load()
	var avg uint64
	if cnt > 0 {
		avg = sum / cnt
	}

	h.metrics.mu.RLock()
	lastSeen := make(map[string]int64, len(h.metrics.perNodeLastSeen))
	for k, v := range h.metrics.perNodeLastSeen {
		lastSeen[k] = v.Unix()
	}
	h.metrics.mu.RUnlock()

	return Snapshot{
		OnlineCount:       h.metrics.onlineGauge.Load(),
		OnlineNodeIDs:     online,
		CallsTotal:        h.metrics.callsTotal.Load(),
		CallsErrTotal:     h.metrics.callsErrTotal.Load(),
		CallsOfflineTotal: h.metrics.callsOfflineTotal.Load(),
		PushUsageTotal:    h.metrics.pushUsageTotal.Load(),
		PushUsageAckTotal: h.metrics.pushUsageAckTotal.Load(),
		ReconnectTotal:    h.metrics.reconnectTotal.Load(),
		ReapedTotal:       h.metrics.reapedTotal.Load(),
		CallLatencyAvgNs:  avg,
		LastSeen:          lastSeen,
	}
}