agentcore

Aug 2, 2026

Changes in this version

+ type ForkPrefixReceiver interface

+ SetForkPrefix func(LLMPrefix)

+ type LLMPrefix struct

+ CacheControl string

+ CallOptions []CallOption

+ ConvertToLLM func([]AgentMessage) []Message

+ Model ChatModel

+ System []Message

+ Tools []ToolSpec

type Message

+ func MarkLastMessageForCache(messages []Message, cacheControl string) []Message

Jul 29, 2026

Changes in this version

+ var ErrRunsHeld = errors.New("agent runs are held")

type Agent

+ func (a *Agent) HoldRuns() (release func())

type GateDecision

+ UpdatedArgs json.RawMessage

Jul 25, 2026

Changes in this version

type Agent

+ func (a *Agent) HasFollowUps() bool

+ func (a *Agent) SetMessageCommitter(fn func(AgentMessage) error)

type AgentOption

+ func WithMessageCommitter(fn func(AgentMessage) error) AgentOption

type LoopConfig

+ CommitMessage func(msg AgentMessage) error

Jul 21, 2026

Changes in this version

+ const IssueUnknown

+ const IssueValue

type StopReason

+ const StopReasonSafety

Jul 14, 2026

Changes in this version

+ var ErrProviderContentFilter = errors.New("provider content filter")

Jul 4, 2026

Changes in this version

type Agent

+ func (a *Agent) SetPromptCacheKey(key string)

type AgentOption

+ func WithPromptCacheKey(key string) AgentOption

type CallConfig

+ PromptCacheKey string

type CallOption

+ func WithCallPromptCacheKey(key string) CallOption

type LoopConfig

+ PromptCacheKey string

Jun 26, 2026

Changes in this version

type ThinkingLevel

+ const ThinkingAuto

+ func NormalizeThinkingLevel(level ThinkingLevel) ThinkingLevel

Jun 26, 2026

Changes in this version

+ var ErrProviderOverloaded = errors.New("provider overloaded")

+ var ErrProviderQuota = errors.New("provider quota exhausted")

type Agent

+ func (a *Agent) InjectContext(ctx context.Context, msg AgentMessage) (InjectResult, error)

type ThinkingLevel

+ const ThinkingMax

Jun 13, 2026

Changes in this version

type AgentOption

+ func WithAbortMarkerText(inference, toolUse string) AgentOption

+ type ConcurrencySafeTool interface

+ ConcurrencySafe func(args json.RawMessage) bool

+ type ContextWindowProvider interface

+ ContextWindow func() int

type EventType

+ const EventModelResponse

+ type InterruptBehaviorTool interface

+ InterruptBehavior func(args json.RawMessage) InterruptBehavior

type LoopConfig

+ AbortMarkerText string

+ AbortMarkerToolText string

+ type ReadOnlyTool interface

+ ReadOnly func(args json.RawMessage) bool

Jun 13, 2026

Changes in this version

+ func ErrorKind(err error) string

type AgentOption

+ func WithLengthRecoveryPrompt(prompt string) AgentOption

+ type ContextWindowSetter interface

+ SetContextWindow func(n int)

type LoopConfig

+ LengthRecoveryPrompt string

+ type ModelNamer interface

+ ModelName func() string

+ type RetryHinter interface

+ RetryAfter func() time.Duration

+ type RetryableError interface

+ Retryable func() bool

type StopInfo

+ Trigger StopTrigger

+ type StopTrigger string

+ const StopTriggerAfterTool

+ const StopTriggerEndTurn

type SwappableModel

+ func (m *SwappableModel) ModelName() string

Jun 4, 2026

Changes in this version

type ToolCall

+ ThoughtSignature string

May 29, 2026

Changes in this version

type Agent

+ func (a *Agent) BuildLLMTools() []ToolSpec

type Usage

+ Model string

+ Provider string

type ValidationIssue

+ Hint string

May 22, 2026

Changes in this version

+ const IssueMissing

+ const IssueType

+ const ResponseFormatJSONObject

+ const ResponseFormatJSONSchema

+ const ResponseFormatText

+ var ErrAlreadyRunning = errors.New("agent is already running")

+ var ErrBadContinuation = errors.New("cannot continue from this message role without queued messages")

+ var ErrContextOverflow = errors.New("context window overflow")

+ var ErrInjectNilMessage = errors.New("inject message is nil")

+ var ErrMaxTurns = errors.New("max turns reached")

+ var ErrNoMessages = errors.New("cannot continue: no messages in context")

+ var ErrNoModel = errors.New("no model configured")

+ var ErrProviderAuth = errors.New("provider auth")

+ var ErrProviderNetwork = errors.New("provider network")

+ var ErrProviderRateLimit = errors.New("provider rate limit")

+ var ErrProviderStreamIdle = errors.New("provider stream idle")

+ var ErrProviderTimeout = errors.New("provider timeout")

+ var ErrStopGuard = errors.New("stop guard escalated: run terminated")

+ var ErrStreamPartial = errors.New("stream closed without done event")

+ var ErrToolValidation = errors.New("tool argument validation failed")

+ func ClassifyProvider(err error) error

+ func FailoverReason(err error) string

+ func IsFailoverEligible(err error) bool

+ func IsStreamIdleMessage(s string) bool

type AgentOption

+ func WithCacheLastMessage(cacheControl string) AgentOption

type CallConfig

+ ResponseFormat *ResponseFormat

type CallOption

+ func WithJSONMode() CallOption

+ func WithJSONSchema(name, description string, schema any, strict bool) CallOption

+ func WithResponseFormat(format *ResponseFormat) CallOption

+ type ContextOverflowError struct

+ Cause error

+ func (e *ContextOverflowError) Error() string

+ func (e *ContextOverflowError) Is(target error) bool

+ func (e *ContextOverflowError) Unwrap() error

+ type JSONSchema struct

+ Description string

+ Name string

+ Schema any

+ Strict *bool

type LoopConfig

+ CacheLastMessage string

+ type MaxTurnsError struct

+ Limit int

+ func (e *MaxTurnsError) Error() string

+ func (e *MaxTurnsError) Is(target error) bool

+ type PartialStreamError struct

+ Partial Message

+ func (e *PartialStreamError) Error() string

+ func (e *PartialStreamError) Is(target error) bool

+ type ResponseFormat struct

+ JSONSchema *JSONSchema

+ Type string

type ToolCall

+ ArgsInvalid bool

+ ArgsParseError string

+ ArgsRawText string

+ type ToolValidationError struct

+ Issues []ValidationIssue

+ ToolName string

+ func (e *ToolValidationError) Error() string

+ func (e *ToolValidationError) Is(target error) bool

+ type ValidationIssue struct

+ Expected string

+ Kind string

+ Path string

+ Received string

+ type ValidationResult struct

+ ErrorCode int

+ Message string

+ OK bool

+ type Validator interface

+ Validate func(ctx context.Context, args json.RawMessage) ValidationResult

May 5, 2026

Changes in this version

type AgentOption

+ func WithToolGate(gate ToolGate) AgentOption

+ type GateDecision struct

+ Allowed bool

+ Reason string

+ type GateRequest struct

+ Call ToolCall

+ Preview json.RawMessage

+ Tool Tool

+ ToolLabel string

type LoopConfig

+ ToolGate ToolGate

+ type ToolGate func(ctx context.Context, req GateRequest) (*GateDecision, error)

May 2, 2026

Changes in this version

type AgentOption

+ func WithStopAfterToolResult(fn func(toolName string, result json.RawMessage) bool) AgentOption

type LoopConfig

+ StopAfterToolResult func(toolName string, result json.RawMessage) bool

type SubAgentConfig

+ StopAfterToolResult func(toolName string, result json.RawMessage) bool

May 1, 2026

Changes in this version

type AgentOption

+ func WithStopAfterTool(fn func(toolName string) bool) AgentOption

Apr 25, 2026

Changes in this version

type AgentOption

+ func WithToolsAreIdempotent(idempotent bool) AgentOption

type LoopConfig

+ ToolsAreIdempotent bool

+ type StrictSchemaTool interface

+ StrictSchema func() bool

type SubAgentConfig

+ MaxRetries int

+ ToolsAreIdempotent bool

type ToolSpec

+ Strict *bool

Apr 24, 2026

Changes in this version

type AgentOption

+ func WithOnMaxTurns(action MaxTurnsAction) AgentOption

+ func WithReminderGenerator(gen ReminderGenerator) AgentOption

+ func WithStopGuard(guard StopGuard) AgentOption

type LoopConfig

+ OnMaxTurns MaxTurnsAction

+ ReminderGens []ReminderGenerator

+ StopGuard StopGuard

+ type MaxTurnsAction int

+ const MaxTurnsSoftRestart

+ const MaxTurnsTerminate

type ProgressPayload

+ DeltaKind DeltaKind

+ type Reminder struct

+ Content string

+ Source string

+ type ReminderGenerator func(ctx context.Context, turn TurnInfo) []Reminder

+ type StopDecision struct

+ Allow bool

+ Escalate bool

+ InjectMessage string

+ type StopGuard func(ctx context.Context, stop StopInfo) StopDecision

+ type StopInfo struct

+ Message Message

+ TurnIndex int

type SubAgentConfig

+ StopGuardFactory func(agentName, task string) StopGuard

+ type TurnInfo struct

+ TurnIndex int

Apr 17, 2026

Changes in this version

type AgentOption

+ func WithOnMessage(fn func(AgentMessage)) AgentOption

+ type DeltaKind string

+ const DeltaText

+ const DeltaThinking

+ const DeltaToolCall

type Event

+ DeltaKind DeltaKind

type LoopConfig

+ OnMessage func(msg AgentMessage)

type ProgressPayloadKind

+ const ProgressToolEnd

type SubAgentConfig

+ OnMessage func(agentName, task string, msg AgentMessage)

Apr 13, 2026

Changes in this version

type AgentOption

+ func WithDefaultToolChoice(choice any) AgentOption

type CallConfig

+ ToolChoice any

type CallOption

+ func WithToolChoice(choice any) CallOption

type LoopConfig

+ StopAfterTool func(toolName string) bool

+ ToolChoice any

type SubAgentConfig

+ StopAfterTools []string

+ ToolChoice any

Apr 6, 2026

Changes in this version

type Agent

+ func (a *Agent) BaselineContextUsage() *ContextUsage

+ func (a *Agent) ContextSnapshot() *ContextSnapshot

type ContextProjection

+ CommitMessages []AgentMessage

+ ShouldCommit bool

type ContextSnapshot

+ BaselineUsage *ContextUsage

type ProgressPayloadKind

+ const ProgressContext

Apr 4, 2026

Changes in this version

+ const BackgroundTaskCompletedTag

+ func AssertMessageSequence(msgs []Message) error

+ type ActivityDescriber interface

+ ActivityDescription func(args json.RawMessage) string

type Agent

+ func (a *Agent) StopAllTasks() int

+ func (a *Agent) StopTask(id string) bool

+ func (a *Agent) TaskRuntime() *TaskRuntime

+ func (a *Agent) Tasks() []BackgroundTaskEntry

type AgentOption

+ func WithContextManager(mgr ContextManager) AgentOption

+ func WithPermissionEngine(engine permission.DecisionEngine) AgentOption

+ func WithStrictMessageSequence(enabled bool) AgentOption

+ func WithTaskRuntime(rt *TaskRuntime) AgentOption

+ type BackgroundTaskEntry struct

+ Agent string

+ Command string

+ Description string

+ EndedAt time.Time

+ Error string

+ ExitCode int

+ ID string

+ OutputFile string

+ PID int

+ Prompt string

+ StartedAt time.Time

+ Status TaskStatus

+ TokensIn int

+ TokensOut int

+ ToolCount int

+ Type TaskType

+ func (e *BackgroundTaskEntry) SetCancel(fn func())

+ type CompactReason string

+ const CompactReasonManual

+ const CompactReasonOverflow

+ const CompactReasonThreshold

+ type ConcurrencySafer interface

+ ConcurrencySafe func(args json.RawMessage) bool

+ type ContextCommitResult struct

+ Changed bool

+ CompactedCount int

+ KeptCount int

+ Messages []AgentMessage

+ SplitTurn bool

+ Strategy string

+ Usage *ContextUsage

+ type ContextEstimator interface

+ EstimateContext func([]AgentMessage) (tokens, usageTokens, trailingTokens int)

+ type ContextLLMConverter interface

+ ConvertToLLM func([]AgentMessage) []Message

+ type ContextManager interface

+ Compact func(ctx context.Context, msgs []AgentMessage, reason CompactReason) (ContextCommitResult, error)

+ Project func(ctx context.Context, msgs []AgentMessage) (ContextProjection, error)

+ RecoverOverflow func(ctx context.Context, msgs []AgentMessage, cause error) (ContextRecoveryResult, error)

+ Snapshot func() *ContextSnapshot

+ Sync func(msgs []AgentMessage)

+ Usage func() *ContextUsage

+ type ContextProjection struct

+ Messages []AgentMessage

+ Usage *ContextUsage

+ type ContextRecoveryResult struct

+ Changed bool

+ CommitMessages []AgentMessage

+ CompactedCount int

+ KeptCount int

+ ShouldCommit bool

+ SplitTurn bool

+ Strategy string

+ Usage *ContextUsage

+ View []AgentMessage

+ type ContextSnapshot struct

+ ActiveMessages int

+ ClearedToolResults int

+ LastChanged bool

+ LastCompactedCount int

+ LastKeptCount int

+ LastSplitTurn bool

+ LastStrategy string

+ Scope string

+ SummaryMessages int

+ ToolMessages int

+ TranscriptMessages int

+ TrimmedTextBlocks int

+ Usage *ContextUsage

+ type ContextWindower interface

+ ContextWindow func() int

type Event

+ PermissionDecision *permission.Decision

+ PermissionRequest *permission.Request

+ type InterruptBehavior string

+ const InterruptBehaviorBlock

+ const InterruptBehaviorCancel

+ type InterruptBehaviorer interface

+ InterruptBehavior func(args json.RawMessage) InterruptBehavior

type LoopConfig

+ CommitContext func(msgs []AgentMessage, usage *ContextUsage) error

+ ContextManager ContextManager

+ PermissionEngine permission.DecisionEngine

+ StrictMessageSequence bool

+ type MessageSequenceIssue struct

+ AssistantIndex int

+ Kind MessageSequenceIssueKind

+ MessageIndex int

+ ToolCallID string

+ ToolName string

+ func ValidateMessageSequence(msgs []Message) []MessageSequenceIssue

+ type MessageSequenceIssueKind string

+ const MessageSequenceIssueMissingToolResult

+ const MessageSequenceIssueOrphanToolResult

+ type PermissionChecker interface

+ CheckPermission func(ctx context.Context, req permission.Request) (*permission.Decision, error)

+ type PermissionMetadataProvider interface

+ PermissionMetadata func() permission.Metadata

+ type ReadOnlyer interface

+ ReadOnly func(args json.RawMessage) bool

type StreamEvent

+ CompletedToolCall *ToolCall

type SubAgentConfig

+ ContextManager ContextManager

+ ContextManagerFactory func(model ChatModel) ContextManager

type SubAgentTool

+ func (t *SubAgentTool) SetTaskRuntime(rt *TaskRuntime)

+ type TaskNotification struct

+ Agent string

+ Command string

+ Description string

+ Error string

+ ExitCode *int

+ OutputFile string

+ Status TaskStatus

+ TaskID string

+ Type TaskType

+ func NotificationFromEntry(e *BackgroundTaskEntry) TaskNotification

+ func (n TaskNotification) ToAgentMessage() AgentMessage

+ type TaskRuntime struct

+ func NewTaskRuntime() *TaskRuntime

+ func (r *TaskRuntime) Get(id string) *BackgroundTaskEntry

+ func (r *TaskRuntime) List() []BackgroundTaskEntry

+ func (r *TaskRuntime) NextID(prefix string) string

+ func (r *TaskRuntime) Register(entry *BackgroundTaskEntry)

+ func (r *TaskRuntime) Stop(id string) bool

+ func (r *TaskRuntime) StopAll() int

+ func (r *TaskRuntime) Update(id string, fn func(e *BackgroundTaskEntry)) bool

+ type TaskStatus string

+ const TaskCompleted

+ const TaskFailed

+ const TaskRunning

+ type TaskType string

+ const TaskTypeShell

+ const TaskTypeSubAgent

Mar 27, 2026

Changes in this version

type Agent

+ func (a *Agent) Inject(msg AgentMessage) (InjectResult, error)

+ type EndReason string

+ const EndReasonAborted

+ const EndReasonError

+ const EndReasonMaxTurns

+ const EndReasonStop

type Event

+ Progress *ProgressPayload

+ Summary *RunSummary

+ type InjectDisposition string

+ const InjectQueued

+ const InjectResumedIdleRun

+ const InjectSteeredCurrentRun

+ type InjectResult struct

+ Disposition InjectDisposition

+ type ProgressPayload struct

+ Agent string

+ Args json.RawMessage

+ Attempt int

+ Delta string

+ IsError bool

+ Kind ProgressPayloadKind

+ MaxRetries int

+ Message string

+ Meta json.RawMessage

+ Summary string

+ Thinking string

+ Tool string

+ Turn int

+ type ProgressPayloadKind string

+ const ProgressRetry

+ const ProgressSummary

+ const ProgressThinking

+ const ProgressToolDelta

+ const ProgressToolError

+ const ProgressToolStart

+ const ProgressTurnCounter

+ type RunSummary struct

+ EndReason EndReason

+ ToolCalls int

+ ToolErrors int

+ TurnCount int

+ type SwappableModel struct

+ func NewSwappableModel(initial ChatModel) *SwappableModel

+ func (m *SwappableModel) Current() ChatModel

+ func (m *SwappableModel) Generate(ctx context.Context, messages []Message, tools []ToolSpec, opts ...CallOption) (*LLMResponse, error)

+ func (m *SwappableModel) GenerateStream(ctx context.Context, messages []Message, tools []ToolSpec, opts ...CallOption) (<-chan StreamEvent, error)

+ func (m *SwappableModel) ProviderName() string

+ func (m *SwappableModel) SupportsTools() bool

+ func (m *SwappableModel) Swap(next ChatModel)

Mar 22, 2026

Changes in this version

type Agent

+ func (a *Agent) BuildLLMMessages() []Message

type AgentOption

+ func WithToolApproval(fn ToolApprovalFunc) AgentOption

type Event

+ ApprovalDecision ToolApprovalDecision

+ ApprovalReason string

+ Preview json.RawMessage

type EventType

+ const EventToolApprovalRequest

+ const EventToolApprovalResolved

type LoopConfig

+ CheckToolApproval ToolApprovalFunc

+ type ToolApprovalDecision string

+ const ToolApprovalAllowAlways

+ const ToolApprovalAllowOnce

+ const ToolApprovalAllowSession

+ const ToolApprovalDeny

+ type ToolApprovalFunc func(ctx context.Context, req ToolApprovalRequest) (*ToolApprovalResult, error)

+ type ToolApprovalRequest struct

+ Call ToolCall

+ Preview []byte

+ Reason string

+ Summary string

+ ToolLabel string

+ type ToolApprovalResult struct

+ Approved bool

+ Decision ToolApprovalDecision

+ Reason string

Mar 15, 2026

Changes in this version

+ type BackgroundTask struct

+ Agent string

+ Description string

+ EndedAt time.Time

+ Error string

+ ID string

+ OutputFile string

+ Progress []string

+ Prompt string

+ StartedAt time.Time

+ Status string

+ TokensIn int

+ TokensOut int

+ ToolCount int

type SubAgentConfig

+ ConvertToLLM func(msgs []AgentMessage) []Message

+ TransformContext func(ctx context.Context, msgs []AgentMessage) ([]AgentMessage, error)

type SubAgentTool

+ func (t *SubAgentTool) BackgroundTasks() []BackgroundTask

+ func (t *SubAgentTool) SetBgOutputFactory(fn func(taskID, agentName string) (io.WriteCloser, string, error))

+ func (t *SubAgentTool) StopAllBackgroundTasks() int

+ func (t *SubAgentTool) StopBackgroundTask(id string) bool

Mar 14, 2026

Changes in this version

+ func ReactivateDeferred(tools []Tool, msgs []AgentMessage)

type Agent

+ func (a *Agent) SetContextWindow(n int)

+ func (a *Agent) SetSystemBlocks(blocks []SystemBlock)

type AgentContext

+ SystemBlocks []SystemBlock

type AgentOption

+ func WithSystemBlocks(blocks []SystemBlock) AgentOption

type ContentBlock

+ ToolName string

+ func ToolRefBlock(toolName string) ContentBlock

type ContentType

+ const ContentToolRef

+ type DeferActivator interface

+ Activate func(names ...string)

+ type DeferFilter interface

+ IsDeferred func(toolName string) bool

+ WasDeferred func(toolName string) bool

+ type SystemBlock struct

+ CacheControl string

+ Text string

type ToolSpec

+ DeferLoading bool

Mar 5, 2026

Changes in this version

type Agent

+ func (a *Agent) AbortSilent()

type AgentMessage

+ func Collect(events <-chan Event) ([]AgentMessage, error)

type AgentOption

+ func WithMaxRetryDelay(d time.Duration) AgentOption

+ func WithMaxToolConcurrency(n int) AgentOption

+ func WithMiddlewares(mw ...ToolMiddleware) AgentOption

type CallConfig

+ MaxTokens int

type CallOption

+ func WithMaxTokens(tokens int) CallOption

type ContentBlock

+ func ImageURLBlock(url string) ContentBlock

+ type ContentTool interface

+ ExecuteContent func(ctx context.Context, args json.RawMessage) ([]ContentBlock, error)

+ type Cost struct

+ CacheRead float64

+ CacheWrite float64

+ Input float64

+ Output float64

+ Total float64

+ func (c *Cost) Add(other *Cost)

type Event

+ UpdateKind ToolExecUpdateKind

+ type EventStream struct

+ func NewEventStream(source <-chan Event) *EventStream

+ func (s *EventStream) Done() <-chan struct{}

+ func (s *EventStream) Events() <-chan Event

+ func (s *EventStream) Result() ([]AgentMessage, error)

type ImageData

+ URL string

type LoopConfig

+ MaxRetryDelay time.Duration

+ MaxToolConcurrency int

+ Middlewares []ToolMiddleware

+ ShouldEmitAbortMarker func() bool

type Message

+ func AbortMsg(text, phase string) Message

+ type Previewer interface

+ Preview func(ctx context.Context, args json.RawMessage) (json.RawMessage, error)

type SubAgentTool

+ func (t *SubAgentTool) SetCreateModel(fn func(name string) (ChatModel, error))

+ func (t *SubAgentTool) SetNotifyFn(fn func(AgentMessage))

+ type ToolExecUpdateKind string

+ const ToolExecUpdatePreview

+ const ToolExecUpdateProgress

+ type ToolExecuteFunc func(ctx context.Context, args json.RawMessage) (json.RawMessage, error)

+ type ToolMiddleware func(ctx context.Context, call ToolCall, next ToolExecuteFunc) (json.RawMessage, error)

type ToolResult

+ ContentBlocks []ContentBlock

+ ToolName string

type Usage

+ Cost *Cost

Feb 17, 2026

Changes in this version

+ func AgentLoop(ctx context.Context, prompts []AgentMessage, agentCtx AgentContext, ...) <-chan Event

+ func AgentLoopContinue(ctx context.Context, agentCtx AgentContext, config LoopConfig) <-chan Event

+ func IsContextOverflow(err error) bool

+ func ReportToolProgress(ctx context.Context, partial json.RawMessage)

+ func WithToolProgress(ctx context.Context, fn ToolProgressFunc) context.Context

+ type Agent struct

+ func NewAgent(opts ...AgentOption) *Agent

+ func (a *Agent) Abort()

+ func (a *Agent) ClearAllQueues()

+ func (a *Agent) ClearFollowUpQueue()

+ func (a *Agent) ClearMessages()

+ func (a *Agent) ClearSteeringQueue()

+ func (a *Agent) ContextUsage() *ContextUsage

+ func (a *Agent) Continue() error

+ func (a *Agent) ExportMessages() []Message

+ func (a *Agent) FollowUp(msg AgentMessage)

+ func (a *Agent) HasQueuedMessages() bool

+ func (a *Agent) ImportMessages(msgs []Message) error

+ func (a *Agent) Messages() []AgentMessage

+ func (a *Agent) Prompt(input string) error

+ func (a *Agent) PromptMessages(msgs ...AgentMessage) error

+ func (a *Agent) Reset()

+ func (a *Agent) SetMessages(msgs []AgentMessage) error

+ func (a *Agent) SetModel(m ChatModel)

+ func (a *Agent) SetSystemPrompt(s string)

+ func (a *Agent) SetThinkingLevel(level ThinkingLevel)

+ func (a *Agent) SetTools(tools ...Tool)

+ func (a *Agent) State() AgentState

+ func (a *Agent) Steer(msg AgentMessage)

+ func (a *Agent) Subscribe(fn func(Event)) func()

+ func (a *Agent) TotalUsage() Usage

+ func (a *Agent) WaitForIdle()

+ type AgentContext struct

+ Messages []AgentMessage

+ SystemPrompt string

+ Tools []Tool

+ type AgentMessage interface

+ GetRole func() Role

+ GetTimestamp func() time.Time

+ HasToolCalls func() bool

+ TextContent func() string

+ ThinkingContent func() string

+ func ToAgentMessages(msgs []Message) []AgentMessage

+ type AgentOption func(*Agent)

+ func WithContextEstimate(fn ContextEstimateFn) AgentOption

+ func WithContextPipeline(...) AgentOption

+ func WithContextWindow(n int) AgentOption

+ func WithConvertToLLM(fn func([]AgentMessage) []Message) AgentOption

+ func WithFollowUpMode(mode QueueMode) AgentOption

+ func WithGetApiKey(fn func(provider string) (string, error)) AgentOption

+ func WithMaxRetries(n int) AgentOption

+ func WithMaxToolErrors(n int) AgentOption

+ func WithMaxTurns(n int) AgentOption

+ func WithModel(model ChatModel) AgentOption

+ func WithPermission(fn PermissionFunc) AgentOption

+ func WithSessionID(id string) AgentOption

+ func WithSteeringMode(mode QueueMode) AgentOption

+ func WithStreamFn(fn StreamFn) AgentOption

+ func WithSystemPrompt(prompt string) AgentOption

+ func WithThinkingBudgets(budgets map[ThinkingLevel]int) AgentOption

+ func WithThinkingLevel(level ThinkingLevel) AgentOption

+ func WithTools(tools ...Tool) AgentOption

+ func WithTransformContext(fn func(ctx context.Context, msgs []AgentMessage) ([]AgentMessage, error)) AgentOption

+ type AgentState struct

+ Error string

+ IsRunning bool

+ Messages []AgentMessage

+ PendingToolCalls map[string]struct{}

+ StreamMessage AgentMessage

+ SystemPrompt string

+ Tools []Tool

+ TotalUsage Usage

+ type CallConfig struct

+ APIKey string

+ SessionID string

+ ThinkingBudget int

+ ThinkingLevel ThinkingLevel

+ func ResolveCallConfig(opts []CallOption) CallConfig

+ type CallOption func(*CallConfig)

+ func WithAPIKey(key string) CallOption

+ func WithCallSessionID(id string) CallOption

+ func WithThinking(level ThinkingLevel) CallOption

+ func WithThinkingBudget(tokens int) CallOption

+ type ChatModel interface

+ Generate func(ctx context.Context, messages []Message, tools []ToolSpec, opts ...CallOption) (*LLMResponse, error)

+ GenerateStream func(ctx context.Context, messages []Message, tools []ToolSpec, opts ...CallOption) (<-chan StreamEvent, error)

+ SupportsTools func() bool

+ type ContentBlock struct

+ Image *ImageData

+ Text string

+ Thinking string

+ ToolCall *ToolCall

+ Type ContentType

+ func ImageBlock(data, mimeType string) ContentBlock

+ func TextBlock(text string) ContentBlock

+ func ThinkingBlock(thinking string) ContentBlock

+ func ToolCallBlock(tc ToolCall) ContentBlock

+ type ContentType string

+ const ContentImage

+ const ContentText

+ const ContentThinking

+ const ContentToolCall

+ type ContextEstimateFn func(msgs []AgentMessage) (tokens, usageTokens, trailingTokens int)

+ type ContextUsage struct

+ ContextWindow int

+ Percent float64

+ Tokens int

+ TrailingTokens int

+ UsageTokens int

+ type Event struct

+ Args json.RawMessage

+ Delta string

+ Err error

+ IsError bool

+ Message AgentMessage

+ NewMessages []AgentMessage

+ Result json.RawMessage

+ RetryInfo *RetryInfo

+ Tool string

+ ToolID string

+ ToolLabel string

+ ToolResults []ToolResult

+ Type EventType

+ type EventType string

+ const EventAgentEnd

+ const EventAgentStart

+ const EventError

+ const EventMessageEnd

+ const EventMessageStart

+ const EventMessageUpdate

+ const EventRetry

+ const EventToolExecEnd

+ const EventToolExecStart

+ const EventToolExecUpdate

+ const EventTurnEnd

+ const EventTurnStart

+ type FuncTool struct

+ func NewFuncTool(name, description string, schema map[string]any, ...) *FuncTool

+ func (t *FuncTool) Description() string

+ func (t *FuncTool) Execute(ctx context.Context, args json.RawMessage) (json.RawMessage, error)

+ func (t *FuncTool) Name() string

+ func (t *FuncTool) Schema() map[string]any

+ type ImageData struct

+ Data string

+ MimeType string

+ type LLMRequest struct

+ Messages []Message

+ Tools []ToolSpec

+ type LLMResponse struct

+ Message Message

+ type LoopConfig struct

+ CheckPermission PermissionFunc

+ ConvertToLLM func(msgs []AgentMessage) []Message

+ GetApiKey func(provider string) (string, error)

+ GetFollowUpMessages func() []AgentMessage

+ GetSteeringMessages func() []AgentMessage

+ MaxRetries int

+ MaxToolErrors int

+ MaxTurns int

+ Model ChatModel

+ SessionID string

+ StreamFn StreamFn

+ ThinkingBudgets map[ThinkingLevel]int

+ ThinkingLevel ThinkingLevel

+ TransformContext func(ctx context.Context, msgs []AgentMessage) ([]AgentMessage, error)

+ type Message struct

+ Content []ContentBlock

+ Metadata map[string]any

+ Role Role

+ StopReason StopReason

+ Timestamp time.Time

+ Usage *Usage

+ func CollectMessages(msgs []AgentMessage) []Message

+ func DefaultConvertToLLM(msgs []AgentMessage) []Message

+ func RepairMessageSequence(msgs []Message) []Message

+ func SystemMsg(text string) Message

+ func ToolResultMsg(toolCallID string, content json.RawMessage, isError bool) Message

+ func UserMsg(text string) Message

+ func (m Message) GetRole() Role

+ func (m Message) GetTimestamp() time.Time

+ func (m Message) HasToolCalls() bool

+ func (m Message) IsEmpty() bool

+ func (m Message) TextContent() string

+ func (m Message) ThinkingContent() string

+ func (m Message) ToolCalls() []ToolCall

+ type PermissionFunc func(ctx context.Context, call ToolCall) error

+ type ProviderNamer interface

+ ProviderName func() string

+ type ProxyEvent struct

+ Delta string

+ Err error

+ StopReason StopReason

+ ToolCallID string

+ ToolName string

+ Type ProxyEventType

+ Usage *Usage

+ type ProxyEventType string

+ const ProxyEventDone

+ const ProxyEventError

+ const ProxyEventTextDelta

+ const ProxyEventThinkingDelta

+ const ProxyEventToolCallDelta

+ const ProxyEventToolCallStart

+ type ProxyModel struct

+ func NewProxyModel(fn ProxyStreamFn) *ProxyModel

+ func (p *ProxyModel) Generate(ctx context.Context, messages []Message, tools []ToolSpec, opts ...CallOption) (*LLMResponse, error)

+ func (p *ProxyModel) GenerateStream(ctx context.Context, messages []Message, tools []ToolSpec, opts ...CallOption) (<-chan StreamEvent, error)

+ func (p *ProxyModel) SupportsTools() bool

+ type ProxyStreamFn func(ctx context.Context, req *LLMRequest) (<-chan ProxyEvent, error)

+ type QueueMode string

+ const QueueModeAll

+ const QueueModeOneAtATime

+ type RetryInfo struct

+ Attempt int

+ Delay time.Duration

+ Err error

+ MaxRetries int

+ type Role string

+ const RoleAssistant

+ const RoleSystem

+ const RoleTool

+ const RoleUser

+ type StopReason string

+ const StopReasonAborted

+ const StopReasonError

+ const StopReasonLength

+ const StopReasonStop

+ const StopReasonToolUse

+ type StreamEvent struct

+ ContentIndex int

+ Delta string

+ Err error

+ Message Message

+ StopReason StopReason

+ Type StreamEventType

+ type StreamEventType string

+ const StreamEventDone

+ const StreamEventError

+ const StreamEventTextDelta

+ const StreamEventTextEnd

+ const StreamEventTextStart

+ const StreamEventThinkingDelta

+ const StreamEventThinkingEnd

+ const StreamEventThinkingStart

+ const StreamEventToolCallDelta

+ const StreamEventToolCallEnd

+ const StreamEventToolCallStart

+ type StreamFn func(ctx context.Context, req *LLMRequest) (*LLMResponse, error)

+ type SubAgentConfig struct

+ Description string

+ MaxTurns int

+ Model ChatModel

+ Name string

+ StreamFn StreamFn

+ SystemPrompt string

+ Tools []Tool

+ type SubAgentTool struct

+ func NewSubAgentTool(agents ...SubAgentConfig) *SubAgentTool

+ func (t *SubAgentTool) Description() string

+ func (t *SubAgentTool) Execute(ctx context.Context, args json.RawMessage) (json.RawMessage, error)

+ func (t *SubAgentTool) Label() string

+ func (t *SubAgentTool) Name() string

+ func (t *SubAgentTool) Schema() map[string]any

+ type ThinkingLevel string

+ const ThinkingHigh

+ const ThinkingLow

+ const ThinkingMedium

+ const ThinkingMinimal

+ const ThinkingOff

+ const ThinkingXHigh

+ type Tool interface

+ Description func() string

+ Execute func(ctx context.Context, args json.RawMessage) (json.RawMessage, error)

+ Name func() string

+ Schema func() map[string]any

+ type ToolCall struct

+ Args json.RawMessage

+ ID string

+ Name string

+ type ToolLabeler interface

+ Label func() string

+ type ToolProgressFunc func(partialResult json.RawMessage)

+ type ToolResult struct

+ Content json.RawMessage

+ Details any

+ IsError bool

+ ToolCallID string

+ type ToolSpec struct

+ Description string

+ Name string

+ Parameters any

+ type Usage struct

+ CacheRead int

+ CacheWrite int

+ Input int

+ Output int

+ TotalTokens int

+ func (u *Usage) Add(other *Usage)