Documentation
¶
Index ¶
- func NewApprovingToolsState(ctx *domain.StateContext) domain.StateHandler
- func NewCancelledState(ctx *domain.StateContext) domain.StateHandler
- func NewCheckingQueueState(ctx *domain.StateContext) domain.StateHandler
- func NewCompletingState(ctx *domain.StateContext) domain.StateHandler
- func NewErrorState(ctx *domain.StateContext) domain.StateHandler
- func NewEvaluatingToolsState(ctx *domain.StateContext) domain.StateHandler
- func NewExecutingToolsState(ctx *domain.StateContext) domain.StateHandler
- func NewIdleState(ctx *domain.StateContext) domain.StateHandler
- func NewPostStreamState(ctx *domain.StateContext) domain.StateHandler
- func NewPostToolExecutionState(ctx *domain.StateContext) domain.StateHandler
- func NewStoppedState(ctx *domain.StateContext) domain.StateHandler
- func NewStreamingLLMState(ctx *domain.StateContext) domain.StateHandler
- type ApprovingToolsState
- type CancelledState
- type CheckingQueueState
- type CompletingState
- type ErrorState
- type EvaluatingToolsState
- type ExecutingToolsState
- type IdleState
- type PostStreamState
- type PostToolExecutionState
- type StoppedState
- type StreamingLLMState
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewApprovingToolsState ¶
func NewApprovingToolsState(ctx *domain.StateContext) domain.StateHandler
NewApprovingToolsState creates a new ApprovingTools state handler
func NewCancelledState ¶
func NewCancelledState(ctx *domain.StateContext) domain.StateHandler
NewCancelledState creates a new Cancelled state handler
func NewCheckingQueueState ¶
func NewCheckingQueueState(ctx *domain.StateContext) domain.StateHandler
NewCheckingQueueState creates a new CheckingQueue state handler
func NewCompletingState ¶
func NewCompletingState(ctx *domain.StateContext) domain.StateHandler
NewCompletingState creates a new Completing state handler
func NewErrorState ¶
func NewErrorState(ctx *domain.StateContext) domain.StateHandler
NewErrorState creates a new Error state handler
func NewEvaluatingToolsState ¶
func NewEvaluatingToolsState(ctx *domain.StateContext) domain.StateHandler
NewEvaluatingToolsState creates a new EvaluatingTools state handler
func NewExecutingToolsState ¶
func NewExecutingToolsState(ctx *domain.StateContext) domain.StateHandler
NewExecutingToolsState creates a new ExecutingTools state handler
func NewIdleState ¶
func NewIdleState(ctx *domain.StateContext) domain.StateHandler
NewIdleState creates a new Idle state handler
func NewPostStreamState ¶
func NewPostStreamState(ctx *domain.StateContext) domain.StateHandler
NewPostStreamState creates a new PostStream state handler
func NewPostToolExecutionState ¶
func NewPostToolExecutionState(ctx *domain.StateContext) domain.StateHandler
NewPostToolExecutionState creates a new PostToolExecution state handler
func NewStoppedState ¶
func NewStoppedState(ctx *domain.StateContext) domain.StateHandler
NewStoppedState creates a new Stopped state handler
func NewStreamingLLMState ¶
func NewStreamingLLMState(ctx *domain.StateContext) domain.StateHandler
NewStreamingLLMState creates a new StreamingLLM state handler
Types ¶
type ApprovingToolsState ¶
type ApprovingToolsState struct {
// contains filtered or unexported fields
}
ApprovingToolsState handles events in the ApprovingTools state.
This state manages sequential tool approval:
- MessageReceivedEvent → initializes tool processing queue, starts sequential approval
- AllToolsProcessedEvent → transitions to PostToolExecution
- ApprovalFailedEvent → handles approval failures
func (*ApprovingToolsState) Handle ¶
func (s *ApprovingToolsState) Handle(event domain.AgentEvent) error
Handle processes events in ApprovingTools state
func (*ApprovingToolsState) Name ¶
func (s *ApprovingToolsState) Name() domain.AgentExecutionState
Name returns the state this handler manages
type CancelledState ¶
type CancelledState struct {
// contains filtered or unexported fields
}
CancelledState handles events in the Cancelled state.
The Cancelled state is a terminal state reached when the agent is cancelled by the user. The event loop will exit when this state is reached.
func (*CancelledState) Handle ¶
func (s *CancelledState) Handle(event domain.AgentEvent) error
Handle processes events in Cancelled state This is a terminal state, so no events are expected
func (*CancelledState) Name ¶
func (s *CancelledState) Name() domain.AgentExecutionState
Name returns the state this handler manages
type CheckingQueueState ¶
type CheckingQueueState struct {
// contains filtered or unexported fields
}
CheckingQueueState handles events in the CheckingQueue state.
This state evaluates multiple conditions to determine the next action:
- Tool results pending → must respond to tools first (StreamingLLM)
- Messages queued → drain queue into conversation
- Background tasks pending → wait for completion
- Can complete → transition to Completing
- Otherwise → continue agent loop (StreamingLLM)
func (*CheckingQueueState) Handle ¶
func (s *CheckingQueueState) Handle(event domain.AgentEvent) error
Handle processes events in CheckingQueue state
func (*CheckingQueueState) Name ¶
func (s *CheckingQueueState) Name() domain.AgentExecutionState
Name returns the state this handler manages
type CompletingState ¶
type CompletingState struct {
// contains filtered or unexported fields
}
CompletingState handles events in the Completing state.
This state finalizes the agent execution:
- Performs a final 100ms queue check
- If messages queued → restart agent (CheckingQueue)
- Otherwise → publish completion event and transition to Idle
func (*CompletingState) Handle ¶
func (s *CompletingState) Handle(event domain.AgentEvent) error
Handle processes events in Completing state
func (*CompletingState) Name ¶
func (s *CompletingState) Name() domain.AgentExecutionState
Name returns the state this handler manages
type ErrorState ¶
type ErrorState struct {
// contains filtered or unexported fields
}
ErrorState handles events in the Error state.
The Error state is a terminal state reached when unrecoverable errors occur. The event loop will exit when this state is reached.
func (*ErrorState) Handle ¶
func (s *ErrorState) Handle(event domain.AgentEvent) error
Handle processes events in Error state This is a terminal state, so no events are expected
func (*ErrorState) Name ¶
func (s *ErrorState) Name() domain.AgentExecutionState
Name returns the state this handler manages
type EvaluatingToolsState ¶
type EvaluatingToolsState struct {
// contains filtered or unexported fields
}
EvaluatingToolsState handles events in the EvaluatingTools state.
This state:
- Publishes chat complete event with tool calls
- Checks if any tool requires approval
- If approval needed → ApprovingTools
- Otherwise → ExecutingTools (starts background execution)
func (*EvaluatingToolsState) Handle ¶
func (s *EvaluatingToolsState) Handle(event domain.AgentEvent) error
Handle processes events in EvaluatingTools state
func (*EvaluatingToolsState) Name ¶
func (s *EvaluatingToolsState) Name() domain.AgentExecutionState
Name returns the state this handler manages
type ExecutingToolsState ¶
type ExecutingToolsState struct {
// contains filtered or unexported fields
}
ExecutingToolsState handles events in the ExecutingTools state.
This state processes tool execution completion:
- ToolsCompletedEvent → transitions to PostToolExecution
func (*ExecutingToolsState) Handle ¶
func (s *ExecutingToolsState) Handle(event domain.AgentEvent) error
Handle processes events in ExecutingTools state
func (*ExecutingToolsState) Name ¶
func (s *ExecutingToolsState) Name() domain.AgentExecutionState
Name returns the state this handler manages
type IdleState ¶
type IdleState struct {
// contains filtered or unexported fields
}
IdleState handles events in the Idle state.
The Idle state is the initial and final resting state of the agent. When a MessageReceivedEvent arrives, it transitions to CheckingQueue to begin processing.
func (*IdleState) Handle ¶
func (s *IdleState) Handle(event domain.AgentEvent) error
Handle processes events in Idle state
func (*IdleState) Name ¶
func (s *IdleState) Name() domain.AgentExecutionState
Name returns the state this handler manages
type PostStreamState ¶
type PostStreamState struct {
// contains filtered or unexported fields
}
PostStreamState handles events in the PostStream state.
This state:
- Stores assistant message to conversation
- Checks if messages were queued during stream → CheckingQueue
- If tool calls exist → EvaluatingTools
- If no tools and can complete → Completing
- Otherwise → CheckingQueue
func (*PostStreamState) Handle ¶
func (s *PostStreamState) Handle(event domain.AgentEvent) error
Handle processes events in PostStream state
func (*PostStreamState) Name ¶
func (s *PostStreamState) Name() domain.AgentExecutionState
Name returns the state this handler manages
type PostToolExecutionState ¶
type PostToolExecutionState struct {
// contains filtered or unexported fields
}
PostToolExecutionState handles events in the PostToolExecution state.
This state:
- Checks if messages were queued during tool execution → drains and goes to CheckingQueue
- Checks if can complete → Completing
- Otherwise → CheckingQueue for next turn
func (*PostToolExecutionState) Handle ¶
func (s *PostToolExecutionState) Handle(event domain.AgentEvent) error
Handle processes events in PostToolExecution state
func (*PostToolExecutionState) Name ¶
func (s *PostToolExecutionState) Name() domain.AgentExecutionState
Name returns the state this handler manages
type StoppedState ¶
type StoppedState struct {
// contains filtered or unexported fields
}
StoppedState handles events in the Stopped state.
The Stopped state is a terminal state reached when the agent stops execution (e.g., due to tool rejection or other stop conditions). The event loop will exit when this state is reached.
func (*StoppedState) Handle ¶
func (s *StoppedState) Handle(event domain.AgentEvent) error
Handle processes events in Stopped state This is a terminal state, so no events are expected
func (*StoppedState) Name ¶
func (s *StoppedState) Name() domain.AgentExecutionState
Name returns the state this handler manages
type StreamingLLMState ¶
type StreamingLLMState struct {
// contains filtered or unexported fields
}
StreamingLLMState handles events in the StreamingLLM state.
This state manages LLM streaming:
- StartStreamingEvent → launches background streaming goroutine
- StreamCompletedEvent → processes completed stream, stores data, transitions to PostStream
func (*StreamingLLMState) Handle ¶
func (s *StreamingLLMState) Handle(event domain.AgentEvent) error
Handle processes events in StreamingLLM state
func (*StreamingLLMState) Name ¶
func (s *StreamingLLMState) Name() domain.AgentExecutionState
Name returns the state this handler manages
Source Files