vega

package module

Go to main page

Versions in this module

v0

v0.4.2

Apr 18, 2026

v0.4.1

Apr 18, 2026

v0.4.0

Apr 18, 2026

v0.3.0

Mar 24, 2026

Changes in this version

+ func BinPath() string

type CallMetrics

+ CacheCreationInputTokens int

+ CacheReadInputTokens int

type ChatEvent

+ Metrics *ChatEventMetrics

+ type ChatEventMetrics struct

+ CostUSD float64

+ DurationMs int64

+ InputTokens int

+ OutputTokens int

type ProcessMetrics

+ CacheCreationInputTokens int

+ CacheReadInputTokens int

v0.2.1

Feb 24, 2026

v0.2.0

Feb 24, 2026

Changes in this version

+ func ContextWithEventSink(ctx context.Context, ch chan<- ChatEvent) context.Context

+ func DefaultDBPath() string

+ func EventSinkFromContext(ctx context.Context) chan<- ChatEvent

type Agent

+ FallbackModel string

type ChatEvent

+ NestedAgent string

type Process

+ func (p *Process) HydrateMessages(msgs []llm.Message)

v0.1.0

Feb 20, 2026

Changes in this version

+ const DefaultLLMTimeout

+ const DefaultMaxContextTokens

+ const DefaultMaxIterations

+ const DefaultStreamBufferSize

+ const DefaultSupervisorPollInterval

+ var ErrAgentNotFound = errors.New("agent not found")

+ var ErrBudgetExceeded = errors.New("budget exceeded")

+ var ErrCircuitOpen = errors.New("circuit breaker is open")

+ var ErrGroupNotFound = errors.New("process group not found")

+ var ErrInvalidInput = errors.New("invalid input")

+ var ErrLinkedProcessDied = errors.New("linked process died")

+ var ErrMaxIterationsExceeded = errors.New("maximum iterations exceeded")

+ var ErrMaxProcessesReached = errors.New("maximum number of processes reached")

+ var ErrNameTaken = errors.New("name already registered")

+ var ErrNotCompleted = errors.New("operation not completed")

+ var ErrProcessNotFound = errors.New("process not found")

+ var ErrProcessNotRunning = errors.New("process is not running")

+ var ErrRateLimited = errors.New("rate limited")

+ var ErrSandboxViolation = errors.New("sandbox violation: path escapes allowed directory")

+ var ErrTimeout = errors.New("operation timed out")

+ var ErrWorkflowNotFound = errors.New("workflow not found")

+ func ContextWithProcess(ctx context.Context, p *Process) context.Context

+ func EnsureHome() error

+ func Home() string

+ func IsRetryable(class ErrorClass) bool

+ func PublishEvent(ctx context.Context, event Event, config *CallbackConfig) error

+ func ShouldRetry(err error, policy *RetryPolicy, attempt int) bool

+ func WorkspacePath() string

+ type APIError struct

+ Err error

+ Message string

+ StatusCode int

+ func (e *APIError) Error() string

+ func (e *APIError) Unwrap() error

+ type Agent struct

+ Budget *Budget

+ CircuitBreaker *CircuitBreaker

+ Context memory.ContextManager

+ LLM llm.LLM

+ MaxIterations int

+ MaxTokens int

+ Memory memory.Memory

+ Model string

+ Name string

+ RateLimit *RateLimit

+ Retry *RetryPolicy

+ System SystemPrompt

+ Temperature *float64

+ Tools *tools.Tools

+ type Alert struct

+ AgentName string

+ Message string

+ ProcessID string

+ Timestamp time.Time

+ Type AlertType

+ type AlertType string

+ const AlertErrorLoop

+ const AlertHighCost

+ const AlertHighIterations

+ const AlertStaleProgress

+ const AlertTimeoutWarning

+ type BackoffConfig struct

+ Initial time.Duration

+ Jitter float64

+ Max time.Duration

+ Multiplier float64

+ Type BackoffType

+ type BackoffType int

+ const BackoffConstant

+ const BackoffExponential

+ const BackoffLinear

+ type Budget struct

+ Limit float64

+ OnExceed BudgetAction

+ type BudgetAction int

+ const BudgetAllow

+ const BudgetBlock

+ const BudgetWarn

+ type CallMetrics struct

+ CostUSD float64

+ InputTokens int

+ LatencyMs int64

+ OutputTokens int

+ Retries int

+ ToolCalls []string

+ type CallbackConfig struct

+ Dir string

+ URL string

+ func NewCallbackConfig(dir, url string) *CallbackConfig

+ type ChatEvent struct

+ Arguments map[string]any

+ Delta string

+ DurationMs int64

+ Error string

+ Result string

+ ToolCallID string

+ ToolName string

+ Type ChatEventType

+ type ChatEventType string

+ const ChatEventDone

+ const ChatEventError

+ const ChatEventTextDelta

+ const ChatEventToolEnd

+ const ChatEventToolStart

+ type ChatStream struct

+ func (cs *ChatStream) Err() error

+ func (cs *ChatStream) Events() <-chan ChatEvent

+ func (cs *ChatStream) Response() string

+ type ChildInfo struct

+ Agent string

+ ID string

+ Name string

+ Restart ChildRestart

+ Status Status

+ type ChildRestart int

+ const Permanent

+ const Temporary

+ const Transient

+ func (r ChildRestart) String() string

+ type ChildSpec struct

+ Agent Agent

+ Name string

+ Restart ChildRestart

+ SpawnOpts []SpawnOption

+ Task string

+ type CircuitBreaker struct

+ HalfOpenMax int

+ OnClose func()

+ OnOpen func()

+ ResetAfter time.Duration

+ Threshold int

+ type CombinedPrompt struct

+ func NewCombinedPrompt(prompts ...SystemPrompt) *CombinedPrompt

+ func (c *CombinedPrompt) Prompt() string

+ type DynamicPrompt func() string

+ func (d DynamicPrompt) Prompt() string

+ type ErrorClass int

+ const ErrClassAuthentication

+ const ErrClassBudgetExceeded

+ const ErrClassInvalidRequest

+ const ErrClassOverloaded

+ const ErrClassRateLimit

+ const ErrClassTemporary

+ const ErrClassTimeout

+ func ClassifyError(err error) ErrorClass

+ type Event struct

+ AgentName string

+ Data map[string]string

+ Error string

+ Iteration int

+ Message string

+ ProcessID string

+ Progress float64

+ Result string

+ Timestamp time.Time

+ Type EventType

+ type EventPoller struct

+ func (p *EventPoller) Start() <-chan Event

+ func (p *EventPoller) Stop()

+ type EventType string

+ const EventCompleted

+ const EventFailed

+ const EventHeartbeat

+ const EventProgress

+ const EventStarted

+ type ExitReason string

+ const ExitError

+ const ExitKilled

+ const ExitLinked

+ const ExitNormal

+ type ExitSignal struct

+ AgentName string

+ Error error

+ ProcessID string

+ Reason ExitReason

+ Result string

+ Timestamp time.Time

+ type Future struct

+ func (f *Future) Await(ctx context.Context) (string, error)

+ func (f *Future) Cancel()

+ func (f *Future) Done() bool

+ func (f *Future) Result() (string, error)

+ type GroupMember struct

+ Agent string

+ ID string

+ Name string

+ Status Status

+ type HealthConfig struct

+ CheckInterval time.Duration

+ CostAlertUSD float64

+ ErrorLoopCount int

+ MaxIterationsWarning int

+ StaleProgressMinutes int

+ type HealthMonitor struct

+ func NewHealthMonitor(config HealthConfig) *HealthMonitor

+ func (h *HealthMonitor) Alerts() <-chan Alert

+ func (h *HealthMonitor) Start(getProcesses func() []*Process)

+ func (h *HealthMonitor) Stop()

+ type JSONPersistence struct

+ func NewJSONPersistence(path string) *JSONPersistence

+ func (p *JSONPersistence) Load() ([]ProcessState, error)

+ func (p *JSONPersistence) Save(states []ProcessState) error

+ type LinkedProcessError struct

+ LinkedID string

+ OriginalError error

+ func (e *LinkedProcessError) Error() string

+ func (e *LinkedProcessError) Unwrap() error

+ type MonitorRef struct

+ type Orchestrator struct

+ func NewOrchestrator(opts ...OrchestratorOption) *Orchestrator

+ func (o *Orchestrator) BroadcastToGroup(ctx context.Context, groupName, message string) (map[string]error, error)

+ func (o *Orchestrator) CallbackDir() string

+ func (o *Orchestrator) CallbackURL() string

+ func (o *Orchestrator) DeleteGroup(name string) error

+ func (o *Orchestrator) Get(id string) *Process

+ func (o *Orchestrator) GetAgent(name string) (Agent, bool)

+ func (o *Orchestrator) GetByName(name string) *Process

+ func (o *Orchestrator) GetContainerManager() *container.Manager

+ func (o *Orchestrator) GetGroup(name string) (*ProcessGroup, bool)

+ func (o *Orchestrator) GetOrCreateGroup(name string) *ProcessGroup

+ func (o *Orchestrator) GetProjectRegistry() *container.ProjectRegistry

+ func (o *Orchestrator) GetSpawnTree() []*SpawnTreeNode

+ func (o *Orchestrator) GroupMembers(groupName string) ([]*Process, error)

+ func (o *Orchestrator) HandleEventCallback() http.HandlerFunc

+ func (o *Orchestrator) JoinGroup(groupName string, p *Process)

+ func (o *Orchestrator) Kill(id string) error

+ func (o *Orchestrator) LeaveAllGroups(p *Process)

+ func (o *Orchestrator) LeaveGroup(groupName string, p *Process) error

+ func (o *Orchestrator) List() []*Process

+ func (o *Orchestrator) ListGroups() []string

+ func (o *Orchestrator) NewSupervisor(spec SupervisorSpec) *Supervisor

+ func (o *Orchestrator) OnHealthAlert(fn func(Alert))

+ func (o *Orchestrator) OnProcessComplete(fn func(*Process, string))

+ func (o *Orchestrator) OnProcessFailed(fn func(*Process, error))

+ func (o *Orchestrator) OnProcessStarted(fn func(*Process))

+ func (o *Orchestrator) Register(name string, p *Process) error

+ func (o *Orchestrator) RegisterAgent(agent Agent)

+ func (o *Orchestrator) Shutdown(ctx context.Context) error

+ func (o *Orchestrator) Spawn(agent Agent, opts ...SpawnOption) (*Process, error)

+ func (o *Orchestrator) SpawnSupervised(agent Agent, restart ChildRestart, opts ...SpawnOption) (*Process, error)

+ func (o *Orchestrator) Unregister(name string)

+ type OrchestratorOption func(*Orchestrator)

+ func WithCallbackDir(dir string) OrchestratorOption

+ func WithCallbackURL(url string) OrchestratorOption

+ func WithContainerManager(cm *container.Manager, baseDir string) OrchestratorOption

+ func WithHealthCheck(config HealthConfig) OrchestratorOption

+ func WithLLM(l llm.LLM) OrchestratorOption

+ func WithMaxProcesses(n int) OrchestratorOption

+ func WithPersistence(p Persistence) OrchestratorOption

+ func WithRateLimits(limits map[string]RateLimitConfig) OrchestratorOption

+ func WithRecovery(enabled bool) OrchestratorOption

+ type Persistence interface

+ Load func() ([]ProcessState, error)

+ Save func(states []ProcessState) error

+ type Process struct

+ Agent *Agent

+ ChildIDs []string

+ ID string

+ ParentAgent string

+ ParentID string

+ Project string

+ SpawnDepth int

+ SpawnReason string

+ StartedAt time.Time

+ Supervision *Supervision

+ Task string

+ WorkDir string

+ func ProcessFromContext(ctx context.Context) *Process

+ func (p *Process) Complete(result string)

+ func (p *Process) Demonitor(ref MonitorRef)

+ func (p *Process) ExitSignals() <-chan ExitSignal

+ func (p *Process) Fail(err error)

+ func (p *Process) Groups() []string

+ func (p *Process) Link(other *Process)

+ func (p *Process) Links() []string

+ func (p *Process) Messages() []llm.Message

+ func (p *Process) Metrics() ProcessMetrics

+ func (p *Process) Monitor(other *Process) MonitorRef

+ func (p *Process) Name() string

+ func (p *Process) Result() string

+ func (p *Process) Send(ctx context.Context, message string) (string, error)

+ func (p *Process) SendAsync(message string) *Future

+ func (p *Process) SendStream(ctx context.Context, message string) (*Stream, error)

+ func (p *Process) SendStreamRich(ctx context.Context, message string) (*ChatStream, error)

+ func (p *Process) SetExtraSystem(content string)

+ func (p *Process) SetTrapExit(trap bool)

+ func (p *Process) Status() Status

+ func (p *Process) Stop()

+ func (p *Process) TrapExit() bool

+ func (p *Process) Unlink(other *Process)

+ type ProcessError struct

+ AgentName string

+ Err error

+ ProcessID string

+ func (e *ProcessError) Error() string

+ func (e *ProcessError) Unwrap() error

+ type ProcessEvent struct

+ Error error

+ Process *Process

+ Result string

+ Timestamp time.Time

+ Type ProcessEventType

+ type ProcessEventType int

+ const ProcessCompleted

+ const ProcessFailed

+ const ProcessStarted

+ type ProcessGroup struct

+ func NewGroup(name string) *ProcessGroup

+ func (g *ProcessGroup) BBDelete(key string)

+ func (g *ProcessGroup) BBGet(key string) (any, bool)

+ func (g *ProcessGroup) BBKeys() []string

+ func (g *ProcessGroup) BBSet(key string, value any)

+ func (g *ProcessGroup) BBSnapshot() map[string]any

+ func (g *ProcessGroup) Broadcast(ctx context.Context, message string) map[string]error

+ func (g *ProcessGroup) Count() int

+ func (g *ProcessGroup) Has(p *Process) bool

+ func (g *ProcessGroup) Join(p *Process) bool

+ func (g *ProcessGroup) Leave(p *Process) bool

+ func (g *ProcessGroup) MemberInfo() []GroupMember

+ func (g *ProcessGroup) Members() []*Process

+ func (g *ProcessGroup) Name() string

+ func (g *ProcessGroup) OnJoin(fn func(*Process))

+ func (g *ProcessGroup) OnLeave(fn func(*Process))

+ type ProcessMetrics struct

+ CompletedAt time.Time

+ CostUSD float64

+ Errors int

+ InputTokens int

+ Iterations int

+ LastActiveAt time.Time

+ OutputTokens int

+ StartedAt time.Time

+ ToolCalls int

+ type ProcessState struct

+ AgentName string

+ ID string

+ Metrics ProcessMetrics

+ StartedAt time.Time

+ Status Status

+ Task string

+ WorkDir string

+ type RateLimit struct

+ RequestsPerMinute int

+ TokensPerMinute int

+ type RateLimitConfig struct

+ RequestsPerMinute int

+ Strategy RateLimitStrategy

+ TokensPerMinute int

+ type RateLimitStrategy int

+ const RateLimitBackpressure

+ const RateLimitQueue

+ const RateLimitReject

+ type RetryPolicy struct

+ Backoff BackoffConfig

+ MaxAttempts int

+ RetryOn []ErrorClass

+ type SendResult struct

+ Error error

+ Metrics CallMetrics

+ Response string

+ type SkillMatch = skills.SkillMatch

+ type SkillSummary struct

+ Description string

+ Name string

+ Tags []string

+ type SkillsConfig struct

+ Directories []string

+ Exclude []string

+ Include []string

+ MaxActive int

+ type SkillsPrompt struct

+ func NewSkillsPrompt(base SystemPrompt, loader *skills.Loader, opts ...SkillsPromptOption) *SkillsPrompt

+ func SkillsPromptFromConfig(base SystemPrompt, config SkillsConfig) (*SkillsPrompt, error)

+ func (s *SkillsPrompt) AvailableSkills() []string

+ func (s *SkillsPrompt) GetMatchedSkills() []skills.SkillMatch

+ func (s *SkillsPrompt) ListSkillSummaries() []SkillSummary

+ func (s *SkillsPrompt) Loader() *skills.Loader

+ func (s *SkillsPrompt) Prompt() string

+ func (s *SkillsPrompt) SetContext(message string)

+ type SkillsPromptOption func(*SkillsPrompt)

+ func WithMaxActiveSkills(n int) SkillsPromptOption

+ type SpawnOption func(*Process)

+ func WithMaxIterations(n int) SpawnOption

+ func WithMessages(messages []llm.Message) SpawnOption

+ func WithParent(parent *Process) SpawnOption

+ func WithProcessContext(ctx context.Context) SpawnOption

+ func WithProject(name string) SpawnOption

+ func WithSpawnReason(reason string) SpawnOption

+ func WithSupervision(s Supervision) SpawnOption

+ func WithTask(task string) SpawnOption

+ func WithTimeout(d time.Duration) SpawnOption

+ func WithWorkDir(dir string) SpawnOption

+ type SpawnTreeNode struct

+ AgentName string

+ Children []*SpawnTreeNode

+ ProcessID string

+ SpawnDepth int

+ SpawnReason string

+ StartedAt time.Time

+ Status Status

+ Task string

+ type StaticPrompt string

+ func (s StaticPrompt) Prompt() string

+ type Status string

+ const StatusCompleted

+ const StatusFailed

+ const StatusPending

+ const StatusRunning

+ const StatusTimeout

+ type Strategy int

+ const Escalate

+ const Restart

+ const RestartAll

+ const Stop

+ func (s Strategy) String() string

+ type Stream struct

+ func (s *Stream) Chunks() <-chan string

+ func (s *Stream) Err() error

+ func (s *Stream) Response() string

+ type Supervision struct

+ Backoff BackoffConfig

+ MaxRestarts int

+ OnFailure func(p *Process, err error)

+ OnGiveUp func(p *Process, err error)

+ OnRestart func(p *Process, attempt int)

+ Strategy Strategy

+ Window time.Duration

+ type Supervisor struct

+ func (s *Supervisor) Children() []*Process

+ func (s *Supervisor) CountChildren() (total, running, failed int)

+ func (s *Supervisor) DeleteChild(name string) error

+ func (s *Supervisor) GetChild(name string) *Process

+ func (s *Supervisor) RestartChild(name string) error

+ func (s *Supervisor) Start() error

+ func (s *Supervisor) StartChild(spec ChildSpec) (*Process, error)

+ func (s *Supervisor) Stop()

+ func (s *Supervisor) TerminateChild(name string) error

+ func (s *Supervisor) WhichChildren() []ChildInfo

+ type SupervisorSpec struct

+ Backoff BackoffConfig

+ Children []ChildSpec

+ MaxRestarts int

+ Strategy SupervisorStrategy

+ Window time.Duration

+ type SupervisorStrategy int

+ const OneForAll

+ const OneForOne

+ const RestForOne

+ func (s SupervisorStrategy) String() string

+ type SystemPrompt interface

+ Prompt func() string

+ type ValidationError struct

+ Column int

+ Field string

+ Line int

+ Message string

+ func (e *ValidationError) Error() string

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