package com.yunhai.agent.service; import lombok.Data; /** * 编排过程中的一个阶段事件(用于 SSE 推送给前端做「正在思考 / 正在调用 XX」的实时反馈)。 */ @Data public class AgentEvent { /** thinking / tool_call / tool_result / message / done / error */ private String type; /** 事件文本(展示用) */ private String text; /** 结构化负载(工具名、参数、结果等) */ private Object payload; public static AgentEvent of(String type, String text) { AgentEvent e = new AgentEvent(); e.type = type; e.text = text; return e; } public static AgentEvent of(String type, String text, Object payload) { AgentEvent e = new AgentEvent(); e.type = type; e.text = text; e.payload = payload; return e; } }