agents

Jan 19, 2026

Changes in this version

+ func NilCallback(msg *responses.ResponseChunk)

type Agent

+ Name string

+ func (e *Agent) GetRunID(ctx context.Context) string

+ func (e *Agent) PrepareMCPTools(ctx context.Context, runContext map[string]any) ([]core.Tool, error)

+ func (e *Agent) WithLLM(wrappedLLM LLM) *Agent

type AgentInput

+ StreamBroker core.StreamBroker

+ type LLM interface

+ NewStreamingResponses func(ctx context.Context, in *responses.Request, ...) (*responses.Response, error)

+ type MCPToolset interface

+ GetName func() string

+ ListTools func(ctx context.Context, runContext map[string]any) ([]core.Tool, error)

+ type WrappedLLM struct

+ func (l *WrappedLLM) NewStreamingResponses(ctx context.Context, in *responses.Request, ...) (*responses.Response, error)

Jan 6, 2026

Changes in this version

+ type A2A struct

+ AgentCardHandler http.Handler

+ InvokeHandler http.Handler

+ func (*A2A) Cancel(ctx context.Context, reqCtx *a2asrv.RequestContext, q eventqueue.Queue) error

+ func (agent *A2A) Execute(ctx context.Context, reqCtx *a2asrv.RequestContext, q eventqueue.Queue) error

type Agent

+ func (a *Agent) A2A(agentCard *a2a.AgentCard) *A2A

Jan 6, 2026

Changes in this version

+ func RegisterAgent(name string, agent *Agent)

+ func UnregisterAgent(name string)

+ type Accumulator struct

+ func (a *Accumulator) ReadStream(stream chan *responses.ResponseChunk, cb func(chunk *responses.ResponseChunk)) (*responses.Response, error)

+ type Agent struct

+ func GetAgent(name string) *Agent

+ func NewAgent(opts *AgentOptions) *Agent

+ func (e *Agent) Cancel(ctx context.Context, executor core.DurableExecutor, reason string) error

+ func (e *Agent) Execute(ctx context.Context, in *AgentInput) (*AgentOutput, error)

+ func (e *Agent) ExecuteWithExecutor(ctx context.Context, in *AgentInput, executor core.DurableExecutor) (*AgentOutput, error)

+ func (e *Agent) PrepareTools(ctx context.Context, runContext map[string]any) ([]core.Tool, error)

+ type AgentInput struct

+ Callback func(chunk *responses.ResponseChunk)

+ Messages []responses.InputMessageUnion

+ Namespace string

+ PreviousMessageID string

+ RunContext map[string]any

+ type AgentOptions struct

+ History *history.CommonConversationManager

+ Instruction core.SystemPromptProvider

+ LLM llm.Provider

+ MaxLoops int

+ McpServers []*mcpclient.MCPClient

+ Name string

+ Output map[string]any

+ Parameters responses.Parameters

+ Runtime AgentRuntime

+ Tools []core.Tool

+ type AgentOutput struct

+ Output []responses.InputMessageUnion

+ PendingApprovals []responses.FunctionCallMessage

+ RunID string

+ Status core.RunStatus

+ type AgentRuntime interface

+ Run func(ctx context.Context, agent *Agent, in *AgentInput) (*AgentOutput, error)

+ func DefaultRuntime() AgentRuntime

+ type AgentWorkflow struct

+ func (w AgentWorkflow) Run(restateCtx restate.WorkflowContext, input *WorkflowInput) (*AgentOutput, error)

+ type LocalRuntime struct

+ func (r *LocalRuntime) Run(ctx context.Context, agent *Agent, in *AgentInput) (*AgentOutput, error)

+ type RestateRuntime struct

+ func NewRestateRuntime(endpoint string) *RestateRuntime

+ func (r *RestateRuntime) Run(ctx context.Context, agent *Agent, in *AgentInput) (*AgentOutput, error)

+ type WorkflowInput struct

+ AgentName string

+ Messages []responses.InputMessageUnion

+ Namespace string

+ PreviousMessageID string

+ RunContext map[string]any