states

package

Go to main page

Versions in this module

v0

v0.233.1

Oct 20, 2026

v0.232.0

Oct 20, 2026

Changes in this version

type AgentContext

+ MaxDuration time.Duration

+ MaxDurationExceeded bool

+ StartedAt time.Time

v0.231.1

Oct 19, 2026

v0.231.0

Oct 19, 2026

v0.230.2

Oct 18, 2026

v0.230.1

Oct 18, 2026

v0.230.0

Oct 18, 2026

v0.229.0

Oct 12, 2026

v0.228.0

Oct 9, 2026

v0.227.0

Oct 6, 2026

v0.226.0

Oct 6, 2026

Changes in this version

type AgentExecutionState

+ const StateInputRequired

+ func (s AgentExecutionState) IsWorking() bool

+ type InputRequiredState struct

+ func (s *InputRequiredState) Handle(event AgentEvent) error

+ func (s *InputRequiredState) Name() AgentExecutionState

type StateHandler

+ func NewInputRequiredState(ctx *StateContext) StateHandler

v0.225.0

Oct 4, 2026

v0.224.0

Oct 3, 2026

v0.223.0

Oct 3, 2026

Changes in this version

+ func AnyToolFailed(results []convdomain.ConversationEntry) bool

+ func AnyToolRejected(results []convdomain.ConversationEntry) bool

+ type AgentContext struct

+ ApprovalPolicy agentdomain.ApprovalPolicy

+ Conversation *[]sdk.Message

+ ConversationRepo convdomain.ConversationRepository

+ Ctx context.Context

+ HasToolResults bool

+ IsChatMode bool

+ LastToolFailed bool

+ MaxTurns int

+ MaxTurnsExceeded bool

+ MessageQueue convdomain.MessageQueue

+ RequestID string

+ ToolCalls []*sdk.ChatCompletionMessageToolCall

+ Turns int

+ type AgentEvent interface

+ EventType func() string

+ type AgentExecutionState int

+ const StateApprovingTools

+ const StateBlockingTools

+ const StateCancelled

+ const StateCheckingQueue

+ const StateCompleting

+ const StateError

+ const StateEvaluatingTools

+ const StateExecutingTools

+ const StateIdle

+ const StatePostStream

+ const StatePostToolExecution

+ const StateStopped

+ const StateStreamingLLM

+ func (s AgentExecutionState) String() string

+ type AgentStateMachine interface

+ CanTransition func(ctx *AgentContext, targetState AgentExecutionState) bool

+ GetCurrentState func() AgentExecutionState

+ Reset func()

+ Transition func(ctx *AgentContext, targetState AgentExecutionState) error

+ type AllToolsProcessedEvent struct

+ func (e AllToolsProcessedEvent) EventType() string

+ type ApprovalFailedEvent struct

+ Error error

+ func (e ApprovalFailedEvent) EventType() string

+ type ApprovingToolsState struct

+ func (s *ApprovingToolsState) Handle(event AgentEvent) error

+ func (s *ApprovingToolsState) Name() AgentExecutionState

+ type BlockingToolsState struct

+ func (s *BlockingToolsState) Handle(event AgentEvent) error

+ func (s *BlockingToolsState) Name() AgentExecutionState

+ type CallOrder struct

+ Tools agentdomain.ToolManifestLookup

+ func (o *CallOrder) Next(toolName string) (wait func(), done func())

+ type CancelledState struct

+ func (s *CancelledState) Handle(event AgentEvent) error

+ func (s *CancelledState) Name() AgentExecutionState

+ type CheckingQueueState struct

+ func (s *CheckingQueueState) Handle(event AgentEvent) error

+ func (s *CheckingQueueState) Name() AgentExecutionState

+ type CompletingState struct

+ func (s *CompletingState) Handle(event AgentEvent) error

+ func (s *CompletingState) Name() AgentExecutionState

+ type CompletionRequestedEvent struct

+ func (e CompletionRequestedEvent) EventType() string

+ type ErrorState struct

+ func (s *ErrorState) Handle(event AgentEvent) error

+ func (s *ErrorState) Name() AgentExecutionState

+ type EvaluatingToolsState struct

+ func (s *EvaluatingToolsState) Handle(event AgentEvent) error

+ func (s *EvaluatingToolsState) Name() AgentExecutionState

+ type ExecutingToolsState struct

+ func (s *ExecutingToolsState) Handle(event AgentEvent) error

+ func (s *ExecutingToolsState) Name() AgentExecutionState

+ type IdleState struct

+ func (s *IdleState) Handle(event AgentEvent) error

+ func (s *IdleState) Name() AgentExecutionState

+ type MessageReceivedEvent struct

+ func (e MessageReceivedEvent) EventType() string

+ type PostStreamState struct

+ func (s *PostStreamState) Handle(event AgentEvent) error

+ func (s *PostStreamState) Name() AgentExecutionState

+ type PostToolExecutionState struct

+ func (s *PostToolExecutionState) Handle(event AgentEvent) error

+ func (s *PostToolExecutionState) Name() AgentExecutionState

+ type StartStreamingEvent struct

+ func (e StartStreamingEvent) EventType() string

+ type StateAction func(ctx *AgentContext) error

+ type StateContext struct

+ AddMessage func(entry convdomain.ConversationEntry) error

+ AgentCtx *AgentContext

+ ApprovalDelivery func(toolCall *sdk.ChatCompletionMessageToolCall) string

+ BatchDrainQueue func() int

+ CurrentMessage *sdk.Message

+ CurrentReasoning *string

+ CurrentToolCalls *[]*sdk.ChatCompletionMessageToolCall

+ CurrentToolIndex *int

+ DispatchHooks func(hook agentdomain.HookPoint)

+ Events chan AgentEvent

+ ExecuteToolInternal func(toolCall sdk.ChatCompletionMessageToolCall, isApproved bool) convdomain.ConversationEntry

+ GetAgentMode func() agentdomain.AgentMode

+ GetMetrics func(requestID string) *agentdomain.ChatMetrics

+ MaxConcurrentTools int

+ Mutex *sync.Mutex

+ PublishChatCancelled func(metrics *agentdomain.ChatMetrics)

+ PublishChatComplete func(reasoning string, toolCalls []sdk.ChatCompletionMessageToolCall, ...)

+ PublishChatEvent func(event agentdomain.ChatEvent)

+ PublishToolResults func(results []convdomain.ConversationEntry)

+ Request *agentdomain.AgentRequest

+ RequestToolApproval func(toolCall sdk.ChatCompletionMessageToolCall) (bool, string, error)

+ ShouldRequireApproval func(toolCall *sdk.ChatCompletionMessageToolCall, isChatMode bool) bool

+ StartStreaming func()

+ StateMachine AgentStateMachine

+ ToolExecutor *func()

+ ToolResults *[]convdomain.ConversationEntry

+ Tools agentdomain.ToolManifestLookup

+ ToolsNeedingApproval *[]sdk.ChatCompletionMessageToolCall

+ WaitForBackgroundTasks func()

+ WaitGroup *sync.WaitGroup

+ type StateGuard func(ctx *AgentContext) bool

+ type StateHandler interface

+ Handle func(event AgentEvent) error

+ Name func() AgentExecutionState

+ func NewApprovingToolsState(ctx *StateContext) StateHandler

+ func NewBlockingToolsState(ctx *StateContext) StateHandler

+ func NewCancelledState(ctx *StateContext) StateHandler

+ func NewCheckingQueueState(ctx *StateContext) StateHandler

+ func NewCompletingState(ctx *StateContext) StateHandler

+ func NewErrorState(ctx *StateContext) StateHandler

+ func NewEvaluatingToolsState(ctx *StateContext) StateHandler

+ func NewExecutingToolsState(ctx *StateContext) StateHandler

+ func NewIdleState(ctx *StateContext) StateHandler

+ func NewPostStreamState(ctx *StateContext) StateHandler

+ func NewPostToolExecutionState(ctx *StateContext) StateHandler

+ func NewStoppedState(ctx *StateContext) StateHandler

+ func NewStreamingLLMState(ctx *StateContext) StateHandler

+ type StoppedState struct

+ func (s *StoppedState) Handle(event AgentEvent) error

+ func (s *StoppedState) Name() AgentExecutionState

+ type StreamCompletedEvent struct

+ Message sdk.Message

+ Reasoning string

+ ToolCalls []*sdk.ChatCompletionMessageToolCall

+ func (e StreamCompletedEvent) EventType() string

+ type StreamingLLMState struct

+ func (s *StreamingLLMState) Handle(event AgentEvent) error

+ func (s *StreamingLLMState) Name() AgentExecutionState

+ type ToolsCompletedEvent struct

+ Stop bool

+ func (e ToolsCompletedEvent) EventType() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL