Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AgentStartupEmitter ¶
AgentStartupEmitter reports local A2A agent startup (image pull, container start, health check) as agent_status custom events before the run's events begin, so a client can show progress instead of silence while a multi-GB image pulls.
func EmitRunError ¶
EmitRunError writes a RUN_ERROR event for a failure that happens before the run starts (gateway down, unknown model, ...) so stdout consumers see the failure instead of silence.
func Render ¶
func Render(events <-chan agentdomain.ChatEvent, w io.Writer, approvals <-chan ipc.ApprovalResponse, questions <-chan ipc.UserQuestionResponse, sessionID, model string, repo convdomain.ConversationRepository, jobs func() []scheddomain.TrackedJob) error
Render renders the run as newline-delimited AG-UI protocol events: one RUN_STARTED, per-turn deltas, tool calls and stats, then one terminal RUN_FINISHED or RUN_ERROR. approvals and questions broker IPC answers and jobs publishes background_tasks snapshots. ponytail: intermediate job state changes are not published, bridge the UI notifier in if a client needs them.
Types ¶
This section is empty.
Source Files