Method Call

internal/nodehub/call.go:24–36

Call 向指定 node 发起一次请求-响应调用。 reqBody 会用 encoding/json 编码（nil 表示空 body）。 返回值是 node 的 NodeMessage.Body（json 原文）。 当 ctx 取消时，hub 会 best-effort 向 node 发送 cancel_id 帧， 然后返回 ctx.Err()。

(ctx context.Context, nodeID, method string, reqBody any)

// 当 ctx 取消时，hub 会 best-effort 向 node 发送 cancel_id 帧，
// 然后返回 ctx.Err()。
func (h *Hub) Call(ctx context.Context, nodeID, method string, reqBody any) (json.RawMessage, error) {
	h.metrics.callsTotal.Add(1)
	start := time.Now()
	raw, err := h.doCall(ctx, nodeID, method, reqBody)
	h.metrics.recordCallLatency(time.Since(start))
	if err != nil {
		h.metrics.callsErrTotal.Add(1)
		if errors.Is(err, ErrNodeOffline) {
			h.metrics.callsOfflineTotal.Add(1)
		}
	}
	return raw, err
}

func (h *Hub) doCall(ctx context.Context, nodeID, method string, reqBody any) (json.RawMessage, error) {
	h.mu.RLock()