executor

package

Go to main page

Versions in this module

v0

v0.2.0

Sep 9, 2026

Changes in this version

+ const EvidenceTailBytes

+ const TaskTypeReview

+ const TaskTypeStatus

+ 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 ReadTQVerify(repoDir string) string

+ 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

+ MaxConcurrent int

type AgentPayload

+ Item string

+ type AgentResult struct

+ CommitSHA string

+ FilesChanged []string

+ LogPath string

+ SessionID string

+ VerifyTail string

type CommandExecutor

+ MemoryLimitMB int

+ Nice int

+ type FailureEvidence struct

+ ExitCode int

+ Stage string

+ Tail string

+ type PreflightError struct

+ Cause error

+ func (e *PreflightError) Error() string

+ func (e *PreflightError) Unwrap() error

+ 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

v0.1.0

Sep 6, 2026

Changes in this version

+ const DefaultAgentBinary

+ const TaskTypeAgent

+ const TaskTypeCrush

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

+ func Permanent(cause error) error

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

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

+ type AgentExecutor struct

+ Bin string

+ 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

+ Model string

+ Prompt string

+ Repo string

+ RequireClean *bool

+ Session string

+ TimeoutMinutes int

+ Verify string

+ Yolo bool

+ type CommandExecutor struct

+ 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 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 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

Other modules containing this package

github.com/larsartmann/go-taskqueue/internal/executor

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