Invoke processes all inputs through the inner task and returns results. It handles concurrency, errors, and interrupts according to configuration. Pa

Append adds a message to memory and persists it to disk.

GetOrCreate returns the session for id, creating it if it does not exist.

consistentHashing implements consistent hashing using Go standard library hash/fnv

nodeID sanitizes a node key to be a valid Mermaid identifier, and adds a caller-provided prefix to ensure uniqueness when rendering nested graphs.

GetMessages returns a snapshot of all messages.

KindFromEnv reads MESSAGE_KIND. AgenticMessage is the default representation; set MESSAGE_KIND=message only when explicitly exercising the legacy path

Stream calls the agent and returns a stream response.

NormalizeMessagesForModelInput prepares stored messages before passing them back to Runner/ChatModel. Today this matches NormalizeForSession; keeping

DefaultSessionDir returns the default session directory for the current kind.

Title derives a display title from the first user message.

IsNil reports whether a generic message value is nil.

NewBatchNode creates a new batch processing node. Example: batchNode := batch.NewBatchNode(&batch.NodeConfig[Request, Response]{ Name:

newLoop creates a new TurnLoop for the session. Every loop uses the checkpoint store when one is configured so the first /chat interrupt can be persis

--------------------------------------------------------------------------- helper: setup test server + HTTP client ----------------------------------

ApplyMessageModelRetry enables model-call retries for transient rate-limit errors.

SingleChunkReader returns a StreamReader that emits one string then EOF.

ToolResults extracts function tool results from a message or streaming chunk.

emitToolChip emits a compact single-line chip for tool calls or tool results.

sanitizeLogValue removes line breaks and carriage returns to prevent log forging

NewMermaidGenerator creates a generator that auto-writes Markdown and attempts PNG/SVG generation. If dir is empty, current working directory is used.

Spin starts the HTTP server (blocking).

createSampleDocuments generates test documents with rotating priorities

simpleReplyAgent returns a mock that emits a single text message and exits.

GetPromptTemplate 加载并返回一个提示模板

SetPendingInterruptID saves the interrupt ID so the approve endpoint can resume it.

Text returns the user-facing text found in a message.

ToolCalls extracts function tool calls from a message or streaming chunk.

WithTools implements model.ToolCallingChatModel. It creates a new ChatModel wrapping the result of the inner model's WithTools.

createSession creates a session via the Store directly.

createSimpleReviewWorkflow creates a basic document review workflow that simulates automated review with random scoring

Generate generates a response from the agent.

NormalizeForSession returns a provider-safe message for chatwitheino's JSONL session store. Agentic model implementations attach Responses API item ID

Run executes the Ralph Loop synchronously, returning when the loop completes. The outer loop drives turn iteration and validates completion externally

StreamToWriter converts an agent event stream into A2UI JSONL messages written to w. It returns the content of the last assistant text response, all i