Method handleNodeMetrics

internal/serverapi/api.go:360–378

(w http.ResponseWriter, r *http.Request, nodeID string)

}

func (a *API) handleNodeMetrics(w http.ResponseWriter, r *http.Request, nodeID string) {
	if r.Method != http.MethodGet {
		writeMethodNotAllowed(w, http.MethodGet)
		return
	}
	client, err := a.clientFor(nodeID)
	if err != nil {
		writeNodeError(w, err)
		return
	}
	ctx, cancel := context.WithTimeout(r.Context(), 3*time.Second)
	defer cancel()
	out, err := client.Usage(ctx, false)
	if err != nil {
		writeJSON(w, http.StatusUnprocessableEntity, map[string]any{"error": err.Error()})
		return
	}
	writeJSON(w, http.StatusOK, out)
}

// handleAllNodeMetricsStream 推送所有节点的实时指标（SSE）。
// 所有 SSE 连接共享同一个 metricsHub 广播，避免每个连接独立轮询 DB 导致连接池耗尽。