agents

package

Go to main page

Versions in this module

v0

v0.5.0

Feb 14, 2026

Changes in this version

+ type GuidedStepResult struct

+ Arguments any

+ Error error

+ Iteration int

+ Result any

+ ToolName string

v0.4.0

Feb 12, 2026

Changes in this version

+ type GoalNode struct

+ Action string

+ Goal string

+ Preconditions []string

+ StepNumber int

+ Subgoals []*GoalNode

+ type MCTSNode struct

+ Children []*MCTSNode

+ IsLeaf bool

+ Parent *MCTSNode

+ Step *PlanStep

+ Value float64

+ Visits int

+ type ReasoningBranch struct

+ Plan *ReasoningPlan

+ Score float64

v0.3.4

Feb 11, 2026

v0.3.3

Feb 8, 2026

v0.3.2

Feb 8, 2026

v0.3.1

Feb 8, 2026

v0.3.0

Feb 8, 2026

Changes in this version

type ReActAgent

+ func (r *ReActAgent) ExecuteWithSession(ctx context.Context, input *agent.Message, sess SessionProvider) (*agent.Message, error)

+ type SessionProvider interface

+ GetMessages func(ctx context.Context) ([]*publicAgent.Message, error)

v0.2.6

Jan 3, 2026

v0.2.5

Jan 3, 2026

v0.2.4

Jan 2, 2026

v0.2.3

Jan 2, 2026

v0.2.2

Dec 27, 2025

v0.2.1

Dec 26, 2025

v0.2.0

Dec 26, 2025

v0.1.3

Dec 14, 2025

v0.1.2

Dec 7, 2025

Changes in this version

+ const StrategyVotingConfidence

+ const StrategyVotingMajority

+ const StrategyVotingUnanimous

+ const StrategyVotingWeighted

v0.1.1

Dec 7, 2025

v0.1.0

Dec 6, 2025

Changes in this version

+ const StrategyBackwardChaining

+ const StrategyChainOfThought

+ const StrategyConsensus

+ const StrategyHierarchical

+ const StrategyHierarchicalPlan

+ const StrategyMonteCarlo

+ const StrategyRAG

+ const StrategyReActPlanning

+ const StrategySemantic

+ const StrategyTreeOfThought

+ const StrategyWeighted

+ func NewAggregatorAgent(def agent.AgentDef, rt agent.Runtime) (agent.Agent, error)

+ func NewClassifierAgent(def agent.AgentDef, rt agent.Runtime) (agent.Agent, error)

+ func NewPlannerAgent(def agent.AgentDef, rt agent.Runtime) (agent.Agent, error)

+ func NewReActAgent(def agent.AgentDef, rt agent.Runtime) (agent.Agent, error)

+ func NewReActAgentWithClient(def agent.AgentDef, rt agent.Runtime, client OpenAIClient) (agent.Agent, error)

+ func NewReActAgentWithProvider(def agent.AgentDef, rt agent.Runtime, client OpenAIClient, ...) (agent.Agent, error)

+ type AgentInput struct

+ AgentName string

+ Confidence float64

+ Content string

+ Embedding []float64

+ Metadata map[string]any

+ Timestamp time.Time

+ type AggregationResult struct

+ AggregatedContent string

+ ConflictsSolved []ConflictResolution

+ ConsensusLevel float64

+ ProcessingTimeMs int64

+ SemanticClusters []SemanticCluster

+ Sources []string

+ Strategy string

+ SummaryInsights string

+ TokensUsed int

+ type AggregationStats struct

+ AvgConsensusLevel float64

+ ConflictsResolved int

+ ProcessingTimes []time.Duration

+ TokensUsed int

+ TotalAggregations int

+ type AggregatorAgent struct

+ func (a *AggregatorAgent) Execute(ctx context.Context, input *agent.Message) (*agent.Message, error)

+ func (a *AggregatorAgent) Start(ctx context.Context) error

+ type AggregatorConfig struct

+ AggregationStrategy string

+ ConflictResolution string

+ ConsensusThreshold float64

+ DeduplicationMethod string

+ MaxInputSources int

+ MaxTokens int

+ SemanticSimilarity float64

+ SummarizationEnabled bool

+ Temperature float64

+ TimeoutMs int

+ WeightedAggregation map[string]float64

+ type AlternativeClass struct

+ Category string

+ Confidence float64

+ type AlternativeStep struct

+ Action string

+ Reasoning string

+ TradeOffs string

+ type BackupPlan struct

+ AlternativeSteps []PlanStep

+ Description string

+ TriggerCondition string

+ type BaseAgent struct

+ func NewBaseAgent(def agent.AgentDef) *BaseAgent

+ func (b *BaseAgent) DefaultExecute(ctx context.Context, input *agent.Message) (*agent.Message, error)

+ func (b *BaseAgent) DefaultStart(ctx context.Context) error

+ func (b *BaseAgent) GetContext() context.Context

+ func (b *BaseAgent) InitContext(ctx context.Context)

+ func (b *BaseAgent) Name() string

+ func (b *BaseAgent) Ready() bool

+ func (b *BaseAgent) Role() string

+ func (b *BaseAgent) SetReady(ready bool)

+ func (b *BaseAgent) Stop(ctx context.Context) error

+ type Category struct

+ Description string

+ Examples []string

+ Keywords []string

+ Name string

+ type ClassificationMetrics struct

+ Confidence float64

+ InputLength int

+ ResponseLatency time.Duration

+ Success bool

+ Timestamp time.Time

+ TokensUsed int

+ type ClassificationResult struct

+ Alternatives []AlternativeClass

+ Category string

+ Confidence float64

+ PromptStrategy string

+ Reasoning string

+ TokensUsed int

+ type ClassifierAgent struct

+ func (c *ClassifierAgent) Execute(ctx context.Context, input *agent.Message) (*agent.Message, error)

+ func (c *ClassifierAgent) Name() string

+ func (c *ClassifierAgent) Ready() bool

+ func (c *ClassifierAgent) Role() string

+ func (c *ClassifierAgent) Start(ctx context.Context) error

+ func (c *ClassifierAgent) Stop(ctx context.Context) error

+ type ClassifierConfig struct

+ Categories []Category

+ ConfidenceThreshold float64

+ FewShotExamples []Example

+ MaxTokens int

+ MultiLabel bool

+ Temperature float64

+ UseEmbeddings bool

+ type ConflictResolution struct

+ Reasoning string

+ Resolution string

+ Sources []string

+ Topic string

+ type Example struct

+ Category string

+ Input string

+ Reason string

+ type ExamplePlan struct

+ Explanation string

+ Problem string

+ Steps []string

+ type Logger struct

+ func (l *Logger) Execute(ctx context.Context, input *agent.Message) (*agent.Message, error)

+ func (l *Logger) Name() string

+ func (l *Logger) Ready() bool

+ func (l *Logger) Role() string

+ func (l *Logger) Start(ctx context.Context) error

+ func (l *Logger) Stop(ctx context.Context) error

+ type MetacognitionModule struct

+ FailurePatterns []string

+ LearningInsights map[string]float64

+ SuccessPatterns []string

+ type MockOpenAIClient struct

+ func NewMockOpenAIClient() *MockOpenAIClient

+ func (m *MockOpenAIClient) AddResponse(resp openai.ChatCompletionResponse, err error)

+ func (m *MockOpenAIClient) CreateChatCompletion(ctx context.Context, req openai.ChatCompletionRequest) (openai.ChatCompletionResponse, error)

+ func (m *MockOpenAIClient) GetCalls() []openai.ChatCompletionRequest

+ func (m *MockOpenAIClient) Reset()

+ type OpenAIClient interface

+ CreateChatCompletion func(ctx context.Context, req openai.ChatCompletionRequest) (openai.ChatCompletionResponse, error)

+ type PlanExecutionHistory struct

+ ExecutionTime time.Duration

+ PlanID string

+ Problem string

+ StepsCompleted int

+ Success bool

+ TokensUsed int

+ TotalSteps int

+ type PlanStep struct

+ Action string

+ Alternatives []AlternativeStep

+ CanParallelize bool

+ Complexity string

+ Confidence float64

+ EstimatedTokens int

+ ExpectedOutcome string

+ Prerequisites []int

+ Reasoning string

+ StepNumber int

+ type PlannerAgent struct

+ func (p *PlannerAgent) Execute(ctx context.Context, input *agent.Message) (*agent.Message, error)

+ func (p *PlannerAgent) Start(ctx context.Context) error

+ type PlannerConfig struct

+ EnableBacktracking bool

+ EnableSelfCritique bool

+ ExamplePlans []ExamplePlan

+ IncludeAlternatives bool

+ MaxSteps int

+ MaxTokens int

+ ParallelizableSteps bool

+ PlanningStrategy string

+ ReasoningDepth int

+ StepDetailLevel string

+ Temperature float64

+ type ProblemAnalysis struct

+ Assumptions []string

+ Constraints []string

+ Domain string

+ KeyChallenges []string

+ Resources []string

+ Type string

+ type Producer struct

+ func (p *Producer) Execute(ctx context.Context, input *agent.Message) (*agent.Message, error)

+ func (p *Producer) Name() string

+ func (p *Producer) Ready() bool

+ func (p *Producer) Role() string

+ func (p *Producer) Start(ctx context.Context) error

+ func (p *Producer) Stop(ctx context.Context) error

+ type ReActAgent struct

+ func (r *ReActAgent) ConnectMCPServers(ctx context.Context, serverConfigs []mcp.ServerConfig) error

+ func (r *ReActAgent) Execute(ctx context.Context, input *agent.Message) (*agent.Message, error)

+ func (r *ReActAgent) SetProvider(prov provider.Provider)

+ func (r *ReActAgent) Start(ctx context.Context) error

+ type ReasoningPlan struct

+ Analysis ProblemAnalysis

+ BackupPlans []BackupPlan

+ CriticalPath []int

+ EstimatedDuration string

+ ExecutionStrategy string

+ ParallelGroups [][]int

+ PlanningStrategy string

+ Problem string

+ RiskAssessment RiskAssessment

+ SelfCritique string

+ Steps []PlanStep

+ SuccessCriteria []string

+ TokensUsed int

+ TotalComplexity string

+ type RiskAssessment struct

+ MitigationSteps []string

+ OverallRisk string

+ RiskFactors []RiskFactor

+ type RiskFactor struct

+ Factor string

+ Impact string

+ Likelihood float64

+ Severity string

+ type SemanticCluster struct

+ ClusterID string

+ CoreConcept string

+ Members []string

+ Similarity float64

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