executor

package module

v0.3.0 Latest Latest Go to latest Published: Sep 13, 2026 License: MIT Imports: 1 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/larsartmann/go-taskqueue

Links

Open Source Insights

Documentation ¶

Overview ¶

Package executor is the public facade over the pluggable-execution module (ADR-0016): the Executor interface, Registry, and the built-in executors (sh, HTTP, headless agent, review, status, dlqfix, prioritize). The implementation stays internal; this package pins the names.

Index ¶

Constants
Variables
type AgentExecutor
type AgentPayload
type AgentResult
type CommandExecutor
type DLQFixExecutor
type DLQFixPayload
type DLQFixResult
type DLQFixVerdict
type Executor
type FailureEvidence
type Func
type HTTPExecutor
type LeaseLostError
type PermanentError
type PreflightError
type PrioritizeExecutor
type PrioritizeItem
type PrioritizePayload
type PrioritizeResult
type PrioritizeVerdict
type RateLimitError
type Registry
type ReviewExecutor
type ReviewFinding
type ReviewPayload
type ReviewResult
type ReviewVerdict
type Sink
type StatusCompletion
type StatusExecutor
type StatusPayload
type StatusResult

Constants ¶

View Source

const (
	TaskTypeAgent      = internalexecutor.TaskTypeAgent
	TaskTypeReview     = internalexecutor.TaskTypeReview
	TaskTypeStatus     = internalexecutor.TaskTypeStatus
	TaskTypeDLQFix     = internalexecutor.TaskTypeDLQFix
	TaskTypePrioritize = internalexecutor.TaskTypePrioritize
)

Task-type keys.

View Source

const (
	DefaultAgentBinary    = internalexecutor.DefaultAgentBinary
	DefaultCloseoutPrompt = internalexecutor.DefaultCloseoutPrompt
	EvidenceTailBytes     = internalexecutor.EvidenceTailBytes
	GoEnvExperiment       = internalexecutor.GoEnvExperiment
)

Defaults and knobs.

View Source

const (
	VerdictApprove        = internalexecutor.VerdictApprove
	VerdictRequestChanges = internalexecutor.VerdictRequestChanges
	VerdictFixed          = internalexecutor.VerdictFixed
	VerdictWontFix        = internalexecutor.VerdictWontFix
)

Verdicts.

Variables ¶

View Source

var (
	ErrUnknownType                = internalexecutor.ErrUnknownType
	ErrDLQFixSummaryMissing       = internalexecutor.ErrDLQFixSummaryMissing
	ErrPrioritizeEmptyPayload     = internalexecutor.ErrPrioritizeEmptyPayload
	ErrPrioritizeSparsePayload    = internalexecutor.ErrPrioritizeSparsePayload
	ErrPrioritizeUnknownItem      = internalexecutor.ErrPrioritizeUnknownItem
	ErrPrioritizeDuplicateVerdict = internalexecutor.ErrPrioritizeDuplicateVerdict
	ErrPrioritizeMissingVerdict   = internalexecutor.ErrPrioritizeMissingVerdict
	ErrPrioritizeScoreRange       = internalexecutor.ErrPrioritizeScoreRange
)

Sentinel errors.

View Source

var (
	NewRegistry           = internalexecutor.NewRegistry
	NewCommandExecutor    = internalexecutor.NewCommandExecutor
	NewHTTPExecutor       = internalexecutor.NewHTTPExecutor
	NewAgentExecutor      = internalexecutor.NewAgentExecutor
	AgentVersion          = internalexecutor.AgentVersion
	CommandFromPayload    = internalexecutor.CommandFromPayload
	DetectRateLimit       = internalexecutor.DetectRateLimit
	DetectVerify          = internalexecutor.DetectVerify
	ExtractResultPayload  = internalexecutor.ExtractResultPayload
	ExtractSessionID      = internalexecutor.ExtractSessionID
	Permanent             = internalexecutor.Permanent
	RateLimited           = internalexecutor.RateLimited
	ReadTQVerify          = internalexecutor.ReadTQVerify
	RenderAgentPayload    = internalexecutor.RenderAgentPayload
	ResultLine            = internalexecutor.ResultLine
	SetFailureEvidence    = internalexecutor.SetFailureEvidence
	SetResultDetail       = internalexecutor.SetResultDetail
	SweepSidecars         = internalexecutor.SweepSidecars
	SweepSidecarsByBytes  = internalexecutor.SweepSidecarsByBytes
	ParseResult           = internalexecutor.ParseResult
	ParseDLQFixResult     = internalexecutor.ParseDLQFixResult
	ParsePrioritizeResult = internalexecutor.ParsePrioritizeResult
	NewSink               = internalexecutor.NewSink
)

Functions.

Functions ¶

This section is empty.

Types ¶

type AgentExecutor ¶

type AgentExecutor = internalexecutor.AgentExecutor

Built-in executors.

type AgentPayload ¶

type AgentPayload = internalexecutor.AgentPayload

Payloads, results, and verdicts.

type AgentResult ¶

type AgentResult = internalexecutor.AgentResult

Payloads, results, and verdicts.

type CommandExecutor ¶

type CommandExecutor = internalexecutor.CommandExecutor

Built-in executors.

type DLQFixExecutor ¶

type DLQFixExecutor = internalexecutor.DLQFixExecutor

Built-in executors.

type DLQFixPayload ¶

type DLQFixPayload = internalexecutor.DLQFixPayload

Payloads, results, and verdicts.

type DLQFixResult ¶

type DLQFixResult = internalexecutor.DLQFixResult

Payloads, results, and verdicts.

type DLQFixVerdict ¶

type DLQFixVerdict = internalexecutor.DLQFixVerdict

Payloads, results, and verdicts.

type Executor ¶

type Executor = internalexecutor.Executor

Executor contract.

type FailureEvidence ¶

type FailureEvidence = internalexecutor.FailureEvidence

Payloads, results, and verdicts.

type Func ¶

type Func = internalexecutor.Func

Executor contract.

type HTTPExecutor ¶

type HTTPExecutor = internalexecutor.HTTPExecutor

Built-in executors.

type LeaseLostError ¶

type LeaseLostError = internalexecutor.LeaseLostError

Typed errors.

type PermanentError ¶

type PermanentError = internalexecutor.PermanentError

Typed errors.

type PreflightError ¶

type PreflightError = internalexecutor.PreflightError

Typed errors.

type PrioritizeExecutor ¶

type PrioritizeExecutor = internalexecutor.PrioritizeExecutor

Built-in executors.

type PrioritizeItem ¶

type PrioritizeItem = internalexecutor.PrioritizeItem

Payloads, results, and verdicts.

type PrioritizePayload ¶

type PrioritizePayload = internalexecutor.PrioritizePayload

Payloads, results, and verdicts.

type PrioritizeResult ¶

type PrioritizeResult = internalexecutor.PrioritizeResult

Payloads, results, and verdicts.

type PrioritizeVerdict ¶

type PrioritizeVerdict = internalexecutor.PrioritizeVerdict

Payloads, results, and verdicts.

type RateLimitError ¶

type RateLimitError = internalexecutor.RateLimitError

Typed errors.

type Registry ¶

type Registry = internalexecutor.Registry

Executor contract.

type ReviewExecutor ¶

type ReviewExecutor = internalexecutor.ReviewExecutor

Built-in executors.

type ReviewFinding ¶

type ReviewFinding = internalexecutor.ReviewFinding

Payloads, results, and verdicts.

type ReviewPayload ¶

type ReviewPayload = internalexecutor.ReviewPayload

Payloads, results, and verdicts.

type ReviewResult ¶

type ReviewResult = internalexecutor.ReviewResult

Payloads, results, and verdicts.

type ReviewVerdict ¶

type ReviewVerdict = internalexecutor.ReviewVerdict

Payloads, results, and verdicts.

type Sink ¶

type Sink = internalexecutor.Sink

Sink carries failure/result detail through the context (error and result sinks).

type StatusCompletion ¶

type StatusCompletion = internalexecutor.StatusCompletion

Payloads, results, and verdicts.

type StatusExecutor ¶

type StatusExecutor = internalexecutor.StatusExecutor

Built-in executors.

type StatusPayload ¶

type StatusPayload = internalexecutor.StatusPayload

Payloads, results, and verdicts.

type StatusResult ¶

type StatusResult = internalexecutor.StatusResult

Payloads, results, and verdicts.

Source Files ¶

View all Source files

executor.go

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