Method handleAllNodeMetricsStream

internal/serverapi/api.go:382–409

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

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

// handleAllNodeMetricsStream 推送所有节点的实时指标（SSE）。
// 所有 SSE 连接共享同一个 metricsHub 广播，避免每个连接独立轮询 DB 导致连接池耗尽。
func (a *API) handleAllNodeMetricsStream(w http.ResponseWriter, r *http.Request) {
	flusher, ok := w.(http.Flusher)
	if !ok {
		http.Error(w, "streaming not supported", http.StatusInternalServerError)
		return
	}
	if a.mHub == nil {
		http.Error(w, "metrics hub not ready", http.StatusServiceUnavailable)
		return
	}

	w.Header().Set("Content-Type", "text/event-stream")
	w.Header().Set("Cache-Control", "no-cache")
	w.Header().Set("Connection", "keep-alive")

	ch := a.mHub.subscribe()
	defer a.mHub.unsubscribe(ch)

	for {
		select {
		case <-r.Context().Done():
			return
		case data := <-ch:
			fmt.Fprintf(w, "data: %s\n\n", data)
			flusher.Flush()
		}
	}
}

func (a *API) handleNodeStatus(w http.ResponseWriter, r *http.Request, nodeID string) {
	if r.Method != http.MethodGet {