Versions in this module Expand all Collapse all v0 v0.2.0 May 15, 2026 Changes in this version + type AgentCapability struct + Expertise []string + MaxComplexity int + Model string + Name string + Tools []string + type AgentMessage struct + Content string + From string + ID string + Priority int + RequiresResponse bool + ResponseTo string + Timestamp time.Time + To string + Topic string + type AgentStatus struct + Busy bool + LastActive time.Time + Name string + SuccessRate float64 + TaskCount int + type Fact struct + Confidence float64 + Content string + ID string + Source string + Timestamp time.Time + type HandoffMessage struct + Context string + FromAgent string + Priority int + Reason string + State map[string]interface{} + Task string + Timestamp time.Time + ToAgent string + type HandoffProtocol struct + ActiveAgent string + Agents map[string]*AgentCapability + History []HandoffMessage + func NewHandoffProtocol() *HandoffProtocol + func (hp *HandoffProtocol) BuildHandoffContext(from, to string, task string) *HandoffMessage + func (hp *HandoffProtocol) CanHandle(agentName, task string) bool + func (hp *HandoffProtocol) EscalateToHuman(reason string) *HandoffMessage + func (hp *HandoffProtocol) FormatHandoffHistory() string + func (hp *HandoffProtocol) GetActiveAgent() *AgentCapability + func (hp *HandoffProtocol) Handoff(msg HandoffMessage) error + func (hp *HandoffProtocol) RegisterAgent(cap AgentCapability) + func (hp *HandoffProtocol) SelectBestAgent(task string) string + type Ledger struct + Agents map[string]*AgentStatus + CurrentAssignment string + Facts []Fact + Plan []PlanItem + StallCount int + type LedgerOrchestrator struct + Ledger *Ledger + MaxStalls int + ReassignThreshold time.Duration + func NewLedgerOrchestrator() *LedgerOrchestrator + func (lo *LedgerOrchestrator) AddFact(content, source string, confidence float64) + func (lo *LedgerOrchestrator) AddPlanItem(description string, deps []string) + func (lo *LedgerOrchestrator) AssignNext() (*PlanItem, string) + func (lo *LedgerOrchestrator) DetectStall() bool + func (lo *LedgerOrchestrator) FormatLedger() string + func (lo *LedgerOrchestrator) Reassign(itemID string) string + func (lo *LedgerOrchestrator) RegisterAgent(name string) + func (lo *LedgerOrchestrator) ReportProgress(agentName string, itemID string, status string) + func (lo *LedgerOrchestrator) UpdatePlan(newItems []PlanItem) + type MemEntry struct + CreatedAt time.Time + Key string + Owner string + Readers []string + Type string + UpdatedAt time.Time + Value interface{} + Version int + type MessageBus struct + func NewMessageBus() *MessageBus + func (mb *MessageBus) Broadcast(from, topic, content string) + func (mb *MessageBus) BuildContextFromMessages(agentID string, maxTokens int) string + func (mb *MessageBus) GetHistory(topic string, limit int) []AgentMessage + func (mb *MessageBus) Register(agentID string) <-chan AgentMessage + func (mb *MessageBus) ReportConflict(from string, files []string, description string) + func (mb *MessageBus) ReportDiscovery(from, discovery string) + func (mb *MessageBus) ReportProgress(from string, pct float64, status string) + func (mb *MessageBus) RequestHelp(from, description string) string + func (mb *MessageBus) Send(msg AgentMessage) error + func (mb *MessageBus) Subscribe(agentID, topic string) + func (mb *MessageBus) Unregister(agentID string) + func (mb *MessageBus) WaitForResponse(messageID string, timeout time.Duration) (*AgentMessage, error) + type PlanItem struct + AssignedTo string + Dependencies []string + Description string + ID string + Order int + Status string + type SharedMemory struct + Entries map[string]*MemEntry + Namespaces map[string][]string + func NewSharedMemory() *SharedMemory + func (sm *SharedMemory) Clear() + func (sm *SharedMemory) Delete(key string, owner string) error + func (sm *SharedMemory) Diff(since time.Time) []MemEntry + func (sm *SharedMemory) FormatState() string + func (sm *SharedMemory) Get(key string) (interface{}, bool) + func (sm *SharedMemory) GetBool(key string) bool + func (sm *SharedMemory) GetInt(key string) int + func (sm *SharedMemory) GetString(key string) string + func (sm *SharedMemory) List(namespace string) []MemEntry + func (sm *SharedMemory) Restore(snapshot map[string]interface{}) + func (sm *SharedMemory) Set(key string, value interface{}, owner string) + func (sm *SharedMemory) SetNamespace(key, namespace string) + func (sm *SharedMemory) Snapshot() map[string]interface{} + func (sm *SharedMemory) Watch(key string) <-chan *MemEntry v0.1.0 May 12, 2026 Changes in this version + type Config struct + AutonomyLevel int + BaseBranch string + MaxWorkers int + RepoDir string + SkipValidation bool + ValidatorModel string + WorkerModel string + type Feature struct + Branch string + CompletedAt time.Time + Description string + ExpectedBehavior string + Handoff *Handoff + ID string + StartedAt time.Time + Status FeatureStatus + WorkerSessionID string + type FeatureStatus string + const FeatureCompleted + const FeatureFailed + const FeatureInProgress + const FeaturePending + type Handoff struct + CommitID string + FilesChanged []string + RepoPath string + Summary string + TestsPassed bool + type Mission struct + CompletedAt time.Time + Config Config + Dir string + Features []Feature + ID string + Prompt string + StartedAt time.Time + Status Status + func New(prompt string, cfg Config) *Mission + func (m *Mission) Plan(ctx context.Context, planFn PlanFunc) error + func (m *Mission) Run(ctx context.Context, workerFn WorkerFunc) error + func (m *Mission) Summary() string + type PlanFunc func(ctx context.Context, prompt string) ([]Feature, error) + type Status string + const StatusCompleted + const StatusFailed + const StatusPlanning + const StatusRunning + const StatusValidating + type WorkerFunc func(ctx context.Context, feature *Feature, missionDir string, cfg Config) (*Handoff, error) + func EngineWorker(provider, model, systemPrompt string) WorkerFunc
Go to main page