orchestrator

package

Go to main page

Versions in this module

v0

v0.0.7

Oct 27, 2026

v0.0.6

Oct 16, 2026

v0.0.5

Oct 12, 2026

Changes in this version

+ var ErrStateNotPersisted = errors.New("orchestrator: project state not persisted")

type Abort

+ Details map[string]any

type AbortClass

+ const AbortNetwork

+ const AbortUncommittedWork

+ const AbortUnfinishedTurn

type Config

+ Handoff *runbuild.Handoff

+ HandoffError string

+ MinFreeDiskMB int

+ ProviderModels map[string]string

+ Resumed bool

+ ReviewGateHelper []string

+ ReviewProvider provider.Provider

type GateEventKind

+ const GateHoldQuarantined

v0.0.4

Sep 27, 2026

v0.0.3

Sep 27, 2026

v0.0.2

Sep 17, 2026

Changes in this version

+ func RanOnHost(t *pm.Task) bool

+ type ConditionFunc func(ctx context.Context, plan *pm.Plan, task *pm.Task) (condition.Result, error)

+ type GateConfig struct

+ EvalCondition ConditionFunc

+ Parallel bool

+ TagFilter []string

+ type GateDecision struct

+ Events []GateEvent

+ Exhausted bool

+ Runnable []*pm.Task

+ func GateTasks(ctx context.Context, plan *pm.Plan, cfg GateConfig) GateDecision

+ func (d GateDecision) Skipped() int

+ func (d GateDecision) SkippedIDs() []int

+ type GateEvent struct

+ Annotation string

+ Kind GateEventKind

+ Line string

+ Task *pm.Task

+ func (e GateEvent) IsAlert() bool

+ func (e GateEvent) IsSkip() bool

+ type GateEventKind string

+ const GateConditionError

+ const GateConditionMet

+ const GateSkipBlocked

+ const GateSkipCondition

+ const GateSkipTagFilter

v0.0.1

Sep 13, 2026

Changes in this version

+ func ClassifyStoredOutcome(t *pm.Task) *pm.TaskAbort

+ type Abort struct

+ Class AbortClass

+ Evidence string

+ Reason string

+ RetryAfter time.Time

+ func ClassifyAbort(output string) (Abort, bool)

+ func (a Abort) String() string

+ type AbortClass string

+ const AbortAuth

+ const AbortEmptyOutput

+ const AbortHarnessRefusal

+ const AbortNoEvidence

+ const AbortQuotaExceeded

+ const AbortUsageLimit

+ const AbortZeroArtifact

+ func (c AbortClass) Retryable() bool

+ type CompletionEvidence struct

+ ArtifactBytes int64

+ Diff bool

+ Summary string

+ func (e CompletionEvidence) Positive() bool

+ type Config struct

+ AdaptiveReplan bool

+ AutoEval bool

+ AutoPromote bool

+ AutoPromoteThresholdDays int

+ AutoSplit bool

+ Budget config.BudgetConfig

+ CalibrationFactor float64

+ ClaudeCode config.ClaudeCodeConfig

+ CoachMode bool

+ ConsensusN int

+ ContextSteps int

+ ContextTokenLimit int

+ CostLimit float64

+ DiagnoseFailures bool

+ DiscordWebhookURL string

+ DocsUpdateFile string

+ DocsUpdateOnComplete bool

+ DryRun bool

+ Effort string

+ ExtendedThinking bool

+ FrequencyPenalty *float64

+ GitMode bool

+ HealRetries int

+ Hooks hooks.Config

+ InjectContext bool

+ InnovateMode bool

+ Learn bool

+ LogJSON bool

+ MaxFailures int

+ MaxParallel int

+ MaxTokens int

+ MaxVerifyRetries int

+ MemoryLimit int

+ Metrics *metrics.Metrics

+ Model string

+ MultiAgent bool

+ NoCodeContextInject bool

+ NoDedup bool

+ NoHeal bool

+ Notify bool

+ NotifyCfg config.NotifyConfig

+ Optimize bool

+ OptimizeInteractive bool

+ PMMode bool

+ Parallel bool

+ PlanOnly bool

+ PostReview bool

+ ProviderCfg provider.ProviderConfig

+ ProviderName string

+ Replan bool

+ RequireApproval bool

+ RetryFailed bool

+ ReviewMode bool

+ RiskCheck bool

+ RiskForce bool

+ ScriptVerify bool

+ SkipClarify bool

+ SlackWebhookURL string

+ StepDelay time.Duration

+ StepTimeout time.Duration

+ StepsLimit int

+ Streaming bool

+ TagFilter []string

+ TaskTimeoutMinutes int

+ Temperature *float64

+ ThinkingBudget int

+ TokenBudget int

+ TopP *float64

+ TracingEnabled bool

+ UseMemory bool

+ Verbose bool

+ Verify bool

+ WebhookEvents []string

+ WebhookSecret string

+ WebhookURL string

+ WorkDir string

+ WorktreeParallel bool

+ type Orchestrator struct

+ func New(cfg Config, prov provider.Provider) (*Orchestrator, error)

+ func (o *Orchestrator) AddSteps(n int)

+ func (o *Orchestrator) Close() error

+ func (o *Orchestrator) RegisterRoute(role pm.AgentRole, prov provider.Provider)

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

+ func (o *Orchestrator) SetAutoEvolve(enabled bool)

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

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