IsCallbacksEnabled implements components.Checker. Delegates to the inner model if it implements Checker.

IsCallbacksEnabled returns true to enable callback support. Implements components.Checker interface.

KindOf returns the message kind represented by M.

NewMiniRedisClient starts an embedded Redis server for local demos/tests.

NewModel creates a model matching M. The caller chooses the concrete message type at the boundary; MODEL_TYPE still selects the provider (OpenAI by de

NewPanicErr creates a new panic error. panicErr is a wrapper of panic info and stack trace. it implements the error interface, can print error message

NewPanicErr creates a new panic error. panicErr is a wrapper of panic info and stack trace. it implements the error interface, can print error message

NewSafeToolMiddleware converts tool errors into error-message strings so that a non-zero exit code or mid-stream failure is returned to the model as a

NewStore creates a new Store backed by the given directory (created if absent).

NewSystem constructs a system message for M.

NewToolResult constructs a tool-result message for M.

NewUser constructs a user message for M.

OnFinish is the compile callback entrypoint invoked by Eino after graph compilation. It reads the compile-time GraphInfo and writes a complete Mermaid

PrintAndCollect prints an agent event stream and returns the assistant text.

Set stores checkpoint data for a batch index. Implements compose.CheckPointStore interface.

Streamable wraps a stream tool endpoint to sanitize JSON arguments. Register via ToolCallMiddlewares to apply automatically to streamable tools.

Streamable creates a middleware endpoint for streaming tools. It intercepts the tool's execution. If the tool returns an error, it calls the error han