Versions in this module Expand all Collapse all v1 v1.5.0 Oct 12, 2026 Changes in this version + const DefaultEventQueueCapacity + const DefaultRuntimeEventQueueCapacity + const ToolHookStagePost + const ToolHookStagePre + type ErrorStage string + const ErrorStageDisabled + const ErrorStageExecution + const ErrorStageHook + const ErrorStagePermission + const ErrorStageTimeout + type EventQueue struct + func NewEventQueue(capacity int) *EventQueue + func (q *EventQueue) Close() + func (q *EventQueue) Drain(ctx context.Context) error + func (q *EventQueue) Emit(chunk types.APIResponseChunk) + func (q *EventQueue) EmitBlocking(ctx context.Context, chunk types.APIResponseChunk) (ok bool) + func (q *EventQueue) EmittedCount() int64 + func (q *EventQueue) OverflowCount() int64 + func (q *EventQueue) Recv() <-chan types.APIResponseChunk + func (q *EventQueue) Stats() EventQueueStats + type EventQueueStats struct + Closed bool + Emitted int64 + Overflow int64 + Pending int + type ExecuteRequest struct + DenialTracking *types.DenialTrackingState + EnableSandbox bool + PermissionCheck types.CanUseToolFn + PermissionContext *types.PermissionContext + PermissionMode types.PermissionMode + PermissionResolver types.PermissionResolver + ProgressCallback func(types.ToolProgress) + SessionID types.SessionID + ShouldAvoidPermissionPrompts bool + ToolUses []types.ToolUseContent + Tools map[string]tool.Tool + Transcript []types.Message + TurnID types.TurnID + WorkingDirectory string + type ExecuteResult struct + Errors []ExecutionError + FinalToolContext tool.ToolUseContext + Messages []types.Message + ProgressUpdates []types.ToolProgress + Results []tool.CallResult + TotalDuration time.Duration + Traces []ToolExecutionTrace + type ExecutionError struct + Error error + Stage ErrorStage + ToolName string + ToolUseID string + type Orchestrator struct + func NewOrchestrator() *Orchestrator + func (o *Orchestrator) AddHook(hook ToolHook) + func (o *Orchestrator) Execute(ctx context.Context, req ExecuteRequest) (ExecuteResult, error) + func (o *Orchestrator) RemoveHook(id string) int + func (o *Orchestrator) SetDenialLimitConfig(config types.DenialLimitConfig) + func (o *Orchestrator) SetMaxConcurrency(max int) + func (o *Orchestrator) SetMonitoring(monitoringSys *monitoring.System) + func (o *Orchestrator) SetSafetyChecker(checker types.SafetyChecker) + type RuntimeEventQueue struct + func NewRuntimeEventQueue(capacity int) *RuntimeEventQueue + func (q *RuntimeEventQueue) Close() + func (q *RuntimeEventQueue) Drain(ctx context.Context) error + func (q *RuntimeEventQueue) Emit(event types.RuntimeEvent) + func (q *RuntimeEventQueue) EmitBlocking(ctx context.Context, event types.RuntimeEvent) bool + func (q *RuntimeEventQueue) EmittedCount() int64 + func (q *RuntimeEventQueue) OverflowCount() int64 + func (q *RuntimeEventQueue) Recv() <-chan types.RuntimeEvent + func (q *RuntimeEventQueue) Stats() RuntimeEventQueueStats + type RuntimeEventQueueStats struct + Closed bool + Emitted int64 + Overflow int64 + Pending int + type StreamingExecutionResult struct + Error error + ErrorStage ErrorStage + FinalToolContext tool.ToolUseContext + Index int + Messages []types.Message + Progress []types.ToolProgress + Result tool.CallResult + ToolUse types.ToolUseContent + Trace ToolExecutionTrace + type StreamingExecutor struct + func NewStreamingExecutor(ctx context.Context, orchestrator *Orchestrator, req ExecuteRequest, ...) *StreamingExecutor + func (s *StreamingExecutor) Discard() + func (s *StreamingExecutor) DrainForAbort() []StreamingExecutionResult + func (s *StreamingExecutor) GetAllCompleted() []toolExecutionOutcome + func (s *StreamingExecutor) GetAllCompletedResults() []StreamingExecutionResult + func (s *StreamingExecutor) IsAborted() bool + func (s *StreamingExecutor) SubmitToolUse(toolUse types.ToolUseContent, index int) + func (s *StreamingExecutor) Wait(ctx context.Context) error + type ToolExecutionTrace struct + BackfilledInput map[string]any + FinalInput map[string]any + GlobalPermission types.PermissionResult + LocalPermission types.PermissionResult + Metadata map[string]any + ToolName string + ToolUseID string + ValidatedInput map[string]any + type ToolHook = runtimehooks.ToolHook + type ToolHookInput = runtimehooks.ToolHookInput + type ToolHookResult = runtimehooks.ToolHookResult + type ToolHookStage = runtimehooks.ToolHookStage + type ToolHookStop = runtimehooks.ToolHookStop + type ToolUseChunk struct + Index int + IsPartial bool + ToolUse types.ToolUseContent
Go to main page