Method Handle

internal/nodeagent/dispatch.go:47–198

Handle 实现 Dispatcher。

(ctx context.Context, method string, body json.RawMessage)

// Handle 实现 Dispatcher。
func (d *APIDispatcher) Handle(ctx context.Context, method string, body json.RawMessage) (json.RawMessage, error) {
	switch method {
	// ── 流式 method ──────────────────────────────────────────────
	case "LogsStream":
		return nil, d.handleLogsStream(ctx)
	case "TracerouteStream":
		var req nodes.TracerouteRequest
		if len(body) > 0 {
			if err := json.Unmarshal(body, &req); err != nil {
				return nil, fmt.Errorf("decode TracerouteStream body: %w", err)
			}
		}
		return nil, d.handleTracerouteStream(ctx, req)

	// ── runtime / 状态 ──
	case "Runtime":
		return marshal(d.api.DoRuntime(ctx))
	case "Status":
		return marshal(d.api.DoStatus())
	case "Config":
		return marshal(d.api.DoConfig())
	case "Logs":
		return marshal(d.api.DoLogs())
	case "AccessLogs":
		return marshal(d.api.DoAccessLogs())

	case "Usage":
		var req struct {
			Reset bool `json:"reset"`
		}
		if len(body) > 0 {
			if err := json.Unmarshal(body, &req); err != nil {
				return nil, fmt.Errorf("decode Usage body: %w", err)
			}
		}
		return marshal(d.api.DoUsage(req.Reset))

	// ── 进程控制 ──
	case "Start":
		var req nodes.ConfigRequest
		if err := json.Unmarshal(body, &req); err != nil {
			return nil, fmt.Errorf("decode Start body: %w", err)
		}
		st, err := d.api.DoStart(req.Config, "")
		if err != nil {
			return nil, err
		}
		return marshal(st)
	case "Stop":
		st, err := d.api.DoStop()
		if err != nil {
			return nil, err
		}
		return marshal(st)
	case "Restart":
		var req nodes.ConfigRequest
		if err := json.Unmarshal(body, &req); err != nil {
			return nil, fmt.Errorf("decode Restart body: %w", err)