executor

package module

Go to main page

Versions in this module

v0

v0.4.1

Oct 30, 2026

Changes in this version

type AgentExecutor

+ CrushServer string

+ func (e *AgentExecutor) Binary() string

v0.4.0

Oct 30, 2026

Changes in this version

+ const WorktreeBranchPrefix

+ var ErrDirtyTree = errors.New("dirty tree")

+ func DeleteWorktreeBranch(repoDir, branch string) error

+ func MatchesEvidenceStage(evidence FailureEvidence, lastError, want string) bool

+ func MatchesEvidenceStageSet(evidence FailureEvidence, lastError, spec string) bool

+ func MergeWorktreeBranch(repoDir, branch, base, message string) error

+ func ReapWorktreeOrphans(projectsDir string, inFlight func(taskID string) bool) []string

+ func RemoveWorktree(repoDir, dir string) error

+ func ResolveRepoDir(domain, projectsDir, repo string) (string, error)

type AgentExecutor

+ Worktrees bool

+ func (e *AgentExecutor) ParkCloseoutForTest(id, repoDir, session string)

+ func (e *AgentExecutor) WorktreeInUse(id string) bool

type AgentResult

+ BaseBranch string

+ Branch string

+ WorktreeDir string

+ type FactTrailReader interface

+ FactsForTask func(ctx context.Context, id string, limit int) ([]journal.Fact, error)

type FailureEvidence

+ func LastFailureEvidence(ctx context.Context, store FactTrailReader, id task.ID) FailureEvidence

+ func LastFailureEvidenceFromTrail(trail []journal.Fact) FailureEvidence

+ func (e FailureEvidence) Summary() string

type PreflightError

+ func (e *PreflightError) DirtyTree() bool

type RateLimitError

+ FastRefused bool

type ReviewPayload

+ BaseBranch string

+ Branch string

+ WorktreeDir string

+ type WorktreeOrphan struct

+ Branch string

+ Dir string

+ Merged bool

+ Repo string

+ TaskID string

+ func ScanWorktreeOrphans(projectsDir string, inFlight func(taskID string) bool) []WorktreeOrphan

v0.3.4

Oct 11, 2026

Changes in this version

+ const EnvStreakCode

+ const RiskHigh

+ const RiskLow

+ const RiskMedium

+ func IsEnvironmentalDeath(lastError string) bool

type DLQFixPayload

+ ReclaimsWithUnknownEffect int

+ type Finding struct

+ Flags []string

+ Severity string

+ func MergeFindings(deterministic, learned Finding) Finding

v0.3.3

Oct 7, 2026

Changes in this version

type AgentPayload

+ Anchor string

+ RejectedSHA string

type AgentResult

+ PreflightDone string

v0.3.2

Oct 6, 2026

v0.3.1

Oct 6, 2026

Changes in this version

+ const RedactMarker

+ const ScopedGofmtStage

+ const TaskTrailer

+ const TaskTypeDepBump

+ const VerifyGateEnvCode

+ const VerifyStageE2ETimeout

+ const VerifyStageGofmt

+ const VerifyStageRun

+ const VerifyStageTest

+ var ErrDepBumpBadVersion = errors.New("depbump: bump target version is empty or not stable semver")

+ var ErrDepBumpEmptyPayload = errors.New("depbump: empty payload, want {repo, bumps|release}")

+ var ErrDepBumpNoWork = errors.New("depbump: payload needs at least one bump or a release")

+ func Excerpt(text string) string

+ func IsGateArtifactDeath(ev FailureEvidence, lastError string) bool

+ func IsStableSemver(v string) bool

+ func QuestionPending(cause error, retryAfter time.Duration) error

+ func RedactSecrets(s string) string

+ func SecretHits(s string) int

+ func SetVerifyFailureEvidence(ctx context.Context, verifyStage string, err error, tail string)

+ func StaleVerifyReasons(verify string) []string

type AgentExecutor

+ ReresolveVerify bool

type AgentPayload

+ Answered []queue.QuestionAnsweredDetail

+ Items []string

type AgentResult

+ Commits []Commit

+ type Commit struct

+ SHA string

+ Subject string

+ type DepBump struct

+ Module string

+ Version string

+ type DepBumpExecutor struct

+ ExtraEnv []string

+ GitBin string

+ GoBin string

+ ProjectsDir string

+ TemplBin string

+ func NewDepBumpExecutor(projectsDir string) *DepBumpExecutor

+ func (e *DepBumpExecutor) Execute(ctx context.Context, t task.Task) error

+ type DepBumpPayload struct

+ Bumps []DepBump

+ Release *DepBumpRelease

+ Repo string

+ RepoName string

+ RequireClean *bool

+ TimeoutMinutes int

+ V int

+ type DepBumpRelease struct

+ Push bool

+ Version string

+ type FailureClass string

+ const FailureClassEnvironment

+ const FailureClassPermanent

+ const FailureClassProviderWindow

+ const FailureClassTransient

+ func ClassifyFailure(err error) FailureClass

type FailureEvidence

+ Class string

+ VerifyStage string

+ type GitLogScanner struct

+ Bin string

+ func (s GitLogScanner) CommitsByTrailer(ctx context.Context, repo, key, value string) ([]Commit, error)

+ type GitScanner interface

+ CommitsByTrailer func(ctx context.Context, repo, key, value string) ([]Commit, error)

+ type GitScannerFunc func(ctx context.Context, repo, key, value string) ([]Commit, error)

+ func (f GitScannerFunc) CommitsByTrailer(ctx context.Context, repo, key, value string) ([]Commit, error)

+ type QuestionPendingError struct

+ Cause error

+ ResumeCloseout bool

+ RetryAfter time.Duration

+ func (e *QuestionPendingError) Error() string

+ func (e *QuestionPendingError) Unwrap() error

type RateLimitError

+ Provider string

+ ResumeCloseout bool

type ReviewFinding

+ Anchor string

+ CommitSHA string

type StatusCompletion

+ Report string

+ type VerifyGateClass string

+ const VerifyGateDead

+ const VerifyGateEnvironmental

+ const VerifyGateSlow

+ type VerifyGateError struct

+ Cause error

+ Class VerifyGateClass

+ Tail string

+ Verify string

+ func (e *VerifyGateError) Error() string

+ func (e *VerifyGateError) Unwrap() error

v0.3.0

Sep 13, 2026

Changes in this version

+ const DefaultCloseoutPrompt

+ const GoEnvExperiment

+ const TaskTypeDLQFix

+ const TaskTypePrioritize

+ var ErrDLQFixSummaryMissing = errors.New("verdict JSON has no summary (a diagnosis is required for either verdict)")

+ var ErrPrioritizeDuplicateVerdict = errors.New("duplicate verdict for item")

+ var ErrPrioritizeEmptyPayload = errors.New("prioritize: empty payload, want {repo, items}")

+ var ErrPrioritizeMissingVerdict = errors.New("no verdict for item")

+ var ErrPrioritizeScoreRange = errors.New("out of range 0-100")

+ var ErrPrioritizeSparsePayload = errors.New("prioritize: payload needs non-empty repo and items")

+ var ErrPrioritizeUnknownItem = errors.New("verdict for unknown item")

+ func CommandFromPayload(payload []byte) string

+ func DetectRateLimit(output string, now time.Time) (time.Duration, bool)

+ func RateLimited(cause error, retryAfter time.Duration) error

type AgentExecutor

+ CloseoutPrompt string

+ func (e *AgentExecutor) WithoutCloseout() *AgentExecutor

type AgentPayload

+ V int

+ type DLQFixExecutor struct

+ Agent *AgentExecutor

+ func (e *DLQFixExecutor) Execute(ctx context.Context, t task.Task) error

+ type DLQFixPayload struct

+ Attempts int

+ DeadTask string

+ DeadType string

+ Failure FailureEvidence

+ LastError string

+ Model string

+ Repo string

+ RequireClean *bool

+ TimeoutMinutes int

+ Work string

+ Yolo bool

+ type DLQFixResult struct

+ CommitSHA string

+ LogPath string

+ SessionID string

+ Summary string

+ Verdict DLQFixVerdict

+ func ParseDLQFixResult(output string) (DLQFixResult, error)

+ type DLQFixVerdict string

+ const VerdictFixed

+ const VerdictWontFix

+ type PrioritizeExecutor struct

+ Agent *AgentExecutor

+ func (e *PrioritizeExecutor) Execute(ctx context.Context, t task.Task) error

+ type PrioritizeItem struct

+ Heading string

+ Key string

+ Text string

+ type PrioritizePayload struct

+ Items []PrioritizeItem

+ Model string

+ Repo string

+ RepoName string

+ RequireClean *bool

+ TimeoutMinutes int

+ Yolo bool

+ type PrioritizeResult struct

+ LogPath string

+ SessionID string

+ Verdicts []PrioritizeVerdict

+ func ParsePrioritizeResult(output string, items []PrioritizeItem) (PrioritizeResult, error)

+ type PrioritizeVerdict struct

+ Confidence int

+ EffortMinutes int

+ ItemKey string

+ Reasoning string

+ Score int

+ type RateLimitError struct

+ Cause error

+ RetryAfter time.Duration

+ func (e *RateLimitError) Error() string

+ func (e *RateLimitError) Unwrap() error

v0.2.0

Sep 9, 2026

Changes in this version

+ const DefaultAgentBinary

+ const EvidenceTailBytes

+ const TaskTypeAgent

+ const TaskTypeCrush

+ const TaskTypeReview

+ const TaskTypeStatus

+ var ErrUnknownType = errors.New("executor: unknown task type")

+ func AgentVersion(ctx context.Context, bin string) (string, error)

+ func DetectVerify(repo string) string

+ func ExtractResultPayload(output string) (files []string, sha string, ok bool)

+ func ExtractSessionID(output string) string

+ func Permanent(cause error) error

+ func ReadTQVerify(repoDir string) string

+ func RenderAgentPayload(p AgentPayload) (json.RawMessage, error)

+ func RenderCrushPayload(p AgentPayload) (json.RawMessage, error)

+ func ResultLine(output string) (json.RawMessage, error)

+ func SetFailureEvidence(ctx context.Context, stage string, err error, tail string)

+ func SetResultDetail(ctx context.Context, detail json.RawMessage)

+ func SweepSidecars(dir string, maxAge time.Duration) (int, error)

+ func SweepSidecarsByBytes(dir string, maxBytes int64) (int, error)

+ type AgentExecutor struct

+ Bin string

+ MaxConcurrent int

+ ProjectsDir string

+ Yolo bool

+ func NewAgentExecutor(projectsDir string) *AgentExecutor

+ func (e *AgentExecutor) Execute(ctx context.Context, t task.Task) error

+ type AgentPayload struct

+ Dedup string

+ Item string

+ Model string

+ Prompt string

+ Repo string

+ RequireClean *bool

+ Session string

+ TimeoutMinutes int

+ Verify string

+ Yolo bool

+ type AgentResult struct

+ CommitSHA string

+ FilesChanged []string

+ LogPath string

+ SessionID string

+ VerifyTail string

+ type CommandExecutor struct

+ MemoryLimitMB int

+ Nice int

+ Template string

+ func NewCommandExecutor(template string) *CommandExecutor

+ func (e *CommandExecutor) Execute(ctx context.Context, t task.Task) error

+ type CrushPayload = AgentPayload

+ type Executor interface

+ Execute func(ctx context.Context, t task.Task) error

+ type FailureEvidence struct

+ ExitCode int

+ Stage string

+ Tail string

+ type Func func(ctx context.Context, t task.Task) error

+ func (f Func) Execute(ctx context.Context, t task.Task) error

+ type HTTPExecutor struct

+ Client *http.Client

+ URL string

+ func NewHTTPExecutor(url string) *HTTPExecutor

+ func (e *HTTPExecutor) Execute(ctx context.Context, t task.Task) error

+ type LeaseLostError struct

+ Cause error

+ func (e *LeaseLostError) Error() string

+ func (e *LeaseLostError) Unwrap() error

+ type PermanentError struct

+ Cause error

+ func (e *PermanentError) Error() string

+ func (e *PermanentError) Unwrap() error

+ type PreflightError struct

+ Cause error

+ func (e *PreflightError) Error() string

+ func (e *PreflightError) Unwrap() error

+ type Registry struct

+ func NewRegistry() *Registry

+ func (r *Registry) Lookup(taskType string) (Executor, error)

+ func (r *Registry) Register(taskType string, e Executor)

+ func (r *Registry) RegisterFunc(taskType string, f Func)

+ func (r *Registry) Types() []string

+ type ReviewExecutor struct

+ Agent *AgentExecutor

+ func (e *ReviewExecutor) Execute(ctx context.Context, t task.Task) error

+ type ReviewFinding struct

+ Detail string

+ Severity string

+ Title string

+ type ReviewPayload struct

+ CommitSHA string

+ Extra string

+ FilesChanged []string

+ Item string

+ Model string

+ Repo string

+ RequireClean *bool

+ ReviewedTask string

+ TimeoutMinutes int

+ Yolo bool

+ type ReviewResult struct

+ Findings []ReviewFinding

+ LogPath string

+ SessionID string

+ Summary string

+ Verdict ReviewVerdict

+ func ParseResult(output string) (ReviewResult, error)

+ type ReviewVerdict string

+ const VerdictApprove

+ const VerdictRequestChanges

+ type Sink struct

+ func NewSink(ctx context.Context) (context.Context, *Sink)

+ func (s *Sink) Detail() json.RawMessage

+ func (s *Sink) Failure() json.RawMessage

+ type StatusCompletion struct

+ Commit string

+ CompletedAt string

+ Files []string

+ Item string

+ TaskID string

+ type StatusExecutor struct

+ Agent *AgentExecutor

+ func (e *StatusExecutor) Execute(ctx context.Context, t task.Task) error

+ type StatusPayload struct

+ Completed []StatusCompletion

+ Model string

+ Project string

+ Repo string

+ RequireClean *bool

+ TimeoutMinutes int

+ Verify string

+ Yolo bool

+ type StatusResult struct

+ LogPath string

+ NextItems int

+ Report string

+ SessionID string

Other modules containing this package

github.com/larsartmann/go-taskqueue

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