Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

task

package

Go to main page

Versions in this module

v0

v0.1.2

Sep 6, 2026

Changes in this version

+ const ApprovalGateSchemaVersion

+ const ComplexityLarge

+ const ComplexityMedium

+ const ComplexitySmall

+ const ComplexitySystem

+ const ComplexityTrivial

+ const PhaseAwaitingApproval

+ var ErrApprovalArtifactMissing = errors.New("approval artifact not found")

+ var ErrArtifactConflict = errors.New("approval artifact conflicts with existing bytes")

+ var ErrArtifactCorrupt = errors.New("approval artifact content digest mismatch")

+ var ErrInvalidArtifactDigest = errors.New("invalid approval artifact digest")

+ var ErrInvalidArtifactPath = errors.New("invalid approval artifact path")

+ var ErrInvalidGateID = errors.New("invalid approval gate id")

+ var ErrPrivatePath = errors.New("private RoleMux path contains a symlink or non-directory")

+ func BuildCodeApprovalArtifact(st State, record ApprovalRecord) ([]byte, error)

+ func BuildPlanApprovalArtifact(st State, record ApprovalRecord) ([]byte, error)

+ func HashWorktreeManifest(entries []FileEntry) string

+ func NormalizeComplexity(complexity string) string

+ func PlanPath(repoRoot, id string) (string, error)

+ func ResolvePlanPath(repoRoot, id string) (string, error)

+ func ValidateComplexity(complexity string) error

+ func ValidateWorkUnitsForComplexity(complexity string, units []WorkUnit) error

+ func WorkUnitCriticalPath(units []WorkUnit) ([]string, int, error)

+ func WritePlanPath(repoRoot, id string) (string, error)

+ type ApprovalArtifactRef = ContentRef

+ type ApprovalChangedFile struct

+ ChangeKind string

+ Kind string

+ Path string

+ type ApprovalDecision string

+ const ApprovalApprove

+ const ApprovalDecisionApprove

+ const ApprovalDecisionDiscuss

+ const ApprovalDecisionRequestChanges

+ const ApprovalDiscuss

+ const ApprovalRequestChanges

+ const DecisionApprove

+ const DecisionDiscuss

+ const DecisionRequestChanges

+ type ApprovalFileChange = ApprovalChangedFile

+ type ApprovalKind string

+ const ApprovalCode

+ const ApprovalKindCode

+ const ApprovalKindPlan

+ const ApprovalPlan

+ type ApprovalRecord struct

+ Artifact *ContentRef

+ ArtifactDigest string

+ ArtifactRef string

+ ChangedFiles []ApprovalChangedFile

+ ChangedPaths []string

+ Choices []string

+ CreatedAt time.Time

+ DecidedAt *time.Time

+ ExternalReview *ExternalReview

+ FeedbackOperationRef string

+ GateID string

+ HumanFeedback string

+ Kind ApprovalKind

+ Question string

+ ReviewerEvidence *ReviewerEvidence

+ Scope string

+ Status ApprovalDecision

+ SubjectFingerprint string

+ type BudgetIssue struct

+ Kind string

+ Limit int64

+ Message string

+ Observed int64

+ Role string

+ type ChangedFile = ApprovalChangedFile

+ type CodeApprovalArtifact struct

+ Advisories []Diagnostic

+ CandidateFingerprint string

+ ChangedFiles []ApprovalChangedFile

+ ChangedPaths []string

+ Choices []string

+ Diagnostics []string

+ Findings []Finding

+ GateID string

+ Kind ApprovalKind

+ Question string

+ ReviewCheckpointFindings []Finding

+ ReviewerEvidence *ReviewerEvidence

+ SchemaVersion int

+ Scope string

+ SubjectFingerprint string

+ type ExternalReview struct

+ BaseBranch string

+ BaseCommit string

+ HeadBranch string

+ HeadCommit string

+ LastIssueCommentID int64

+ LastReviewCommentID int64

+ LastReviewID int64

+ LastSyncedAt time.Time

+ Number int

+ Provider string

+ PublishedAt time.Time

+ PublishedCandidateFingerprint string

+ Remote string

+ Repository string

+ URL string

+ type PlanApprovalArtifact struct

+ Choices []string

+ Complexity string

+ GateID string

+ Kind ApprovalKind

+ Plan string

+ Question string

+ ReviewerEvidence *ReviewerEvidence

+ SchemaVersion int

+ Scope string

+ SubjectFingerprint string

+ WorkUnits []WorkUnit

+ type Progress struct

+ Active bool

+ AgentTurns int64

+ LastActivity time.Time

+ LastHeartbeat time.Time

+ LastTool string

+ Operation string

+ Role string

+ ToolCalls int64

+ type ReviewPolicy struct

+ MaxRounds int

+ type ReviewProgress struct

+ Kind string

+ Status string

+ type ReviewerEvidence struct

+ AcceptedRound int

+ Profile *ProfileSnapshot

+ ReviewedFingerprint string

+ ReviewerProfile *ProfileSnapshot

+ ReviewerRole string

+ ReviewerSession string

+ ReviewerSessionID string

+ SourceTask string

+ SourceTaskID string

+ Verdict string

+ type RoleBudget struct

+ MaxOutputBytes int64

+ MaxToolCalls int

+ MaxTurns int

+ TimeoutSeconds int

type State

+ Approval *ApprovalRecord

+ ApprovalGateSchemaVersion int

+ ApprovalHistory []ApprovalRecord

+ BudgetIssue *BudgetIssue

+ BudgetsSnapshot map[string]RoleBudget

+ Complexity string

+ DirectImplementation bool

+ Events []WorkflowEvent

+ PlanReviewCheckpointHash string

+ Progress *Progress

+ ReviewPolicy *ReviewPolicy

+ ReviewProgress *ReviewProgress

type Store

+ func (s *Store) ApprovalArtifactPath(taskID, gateID string, digest ...string) (string, error)

+ func (s *Store) ArtifactPath(taskID, gateID, digest string) (string, error)

+ func (s *Store) PersistApprovalArtifact(st State, record ApprovalRecord) (ApprovalRecord, ContentRef, error)

+ func (s *Store) ReadApprovalArtifact(taskID, gateID string, digest ...string) ([]byte, error)

+ func (s *Store) ReadApprovalArtifactRef(ref ContentRef) ([]byte, error)

+ func (s *Store) ReadContentRef(ref ContentRef) ([]byte, error)

+ func (s *Store) ReadOrRepairApprovalArtifact(taskID, gateID string, contents []byte) (ContentRef, error)

+ func (s *Store) ReadOrRepairArtifact(taskID, gateID string, contents []byte) (ContentRef, error)

+ func (s *Store) WriteApprovalArtifact(taskID, gateID string, contents []byte) (ContentRef, error)

+ func (s *Store) WriteCodeApprovalArtifact(st State, record ApprovalRecord) (ContentRef, error)

+ func (s *Store) WritePlanApprovalArtifact(st State, record ApprovalRecord) (ContentRef, error)

type TokenUsage

+ AgentTurns int64

+ IncompleteRequests int64

+ ToolCalls int64

+ UnreportedRequests int64

type WorkUnit

+ AffectedSymbols []string

+ ContextFiles []string

+ ContextGroup string

+ EstimatedMinutes int

+ type WorkflowEvent struct

+ Findings []Finding

+ Message string

+ OccurredAt time.Time

+ Operation string

+ Role string

+ Round int

+ Type string

v0.1.1

Sep 5, 2026

v0.1.0

Sep 5, 2026

Changes in this version

+ const PhaseApproved

+ const PhaseCodeReviewing

+ const PhaseFailed

+ const PhaseImplementationReady

+ const PhaseImplementing

+ const PhaseNeedsInput

+ const PhasePlanApproved

+ const PhasePlanReviewing

+ const PhasePlanned

+ const PhaseReviewNeeded

+ var ErrInvalidPhase = errors.New("invalid task phase")

+ var ErrInvalidTaskID = errors.New("invalid task id")

+ var ErrNotFound = errors.New("task not found")

+ var ErrNotGitRepository = errors.New("not inside a git worktree")

+ var ErrOperationInFlight = errors.New("task operation is already in flight")

+ var ErrScopeChanged = errors.New("task scope changed during review barrier")

+ var ErrStaleOperation = errors.New("stale task operation")

+ var ErrTaskExists = errors.New("task already exists")

+ func CanonicalScope(raw string) (string, error)

+ func DiscoverRepository(start string) (string, error)

+ func HashManifest(entries []FileEntry) string

+ func IntegrationTaskID(parentID string) string

+ func ManifestChanged(before, after []FileEntry) bool

+ func NewToken() string

+ func ScopeMatches(scope, repoPath string) bool

+ func ScopePatterns(scope string) []string

+ func ScopeSpecHash(scope string) string

+ func ScopesOverlap(a, b string) bool

+ func StateFingerprint(st State) string

+ func UnmatchedScopePatterns(entries []FileEntry, scope string) []string

+ func ValidateScope(scope string) error

+ func ValidateWorkUnits(units []WorkUnit) error

+ func WorkTaskID(parentID, unitID string) string

+ func WorkUnitWaves(units []WorkUnit) ([][]string, error)

+ func WritePlan(repoRoot, id, contents string) error

+ type AdvisoryLock struct

+ func (l *AdvisoryLock) Unlock() error

+ type ContentRef struct

+ Digest string

+ Path string

+ Size int64

+ type ContentState struct

+ Hash string

+ Mode string

+ Present bool

+ Ref *ContentRef

+ Size int64

+ type Diagnostic struct

+ Code string

+ Message string

+ Paths []string

+ Severity string

+ TaskID string

+ type FileEntry struct

+ Hash string

+ Index IndexState

+ Kind string

+ Mode string

+ Path string

+ Size int64

+ Status string

+ Worktree ContentState

+ func CaptureContentRefs(entries []FileEntry, repoRoot, privateRoot, label, taskID string) ([]FileEntry, error)

+ func CaptureIndexRefs(entries []FileEntry, repoRoot, privateRoot, label, taskID string) ([]FileEntry, error)

+ func ScopeEntries(entries []FileEntry, scope string) []FileEntry

+ type Finding struct

+ Line int

+ Message string

+ Path string

+ Severity string

+ type InFlight struct

+ Findings []Finding

+ KnownSession bool

+ Loop string

+ Operation string

+ OwnerPID int

+ PreviousPhase string

+ Prompt string

+ Role string

+ Scope string

+ SessionID string

+ SnapshotManifest []FileEntry

+ StartedAt time.Time

+ Token string

+ type IndexStage struct

+ Blob string

+ Mode string

+ Ref *ContentRef

+ Stage int

+ type IndexState struct

+ Blob string

+ Entries []IndexStage

+ Mode string

+ Present bool

+ Ref *ContentRef

+ Stages []int

+ type ManifestDeltaResult struct

+ Added []FileEntry

+ Changed []FileEntry

+ Removed []FileEntry

+ func ManifestDelta(before, after []FileEntry) ManifestDeltaResult

+ func (d ManifestDeltaResult) Paths() []string

+ type ProfileSnapshot struct

+ Effort string

+ Model string

+ Provider string

+ Speed string

+ type RetryState struct

+ CreatedAt time.Time

+ Findings []Finding

+ KnownSession bool

+ Loop string

+ Operation string

+ PreviousPhase string

+ Prompt string

+ Role string

+ Scope string

+ SessionID string

+ SnapshotManifest []FileEntry

+ Token string

+ type RuntimeSnapshot struct

+ Auth map[string]any

+ AuthEnvRefs []string

+ CLIPath string

+ Endpoint string

+ ProviderID string

+ ProviderType string

+ SDKSettings map[string]any

+ WireAPI string

+ type State struct

+ Advisories []Diagnostic

+ ApprovedManifestHash string

+ ApprovedPlanHash string

+ CandidateManifest []FileEntry

+ CandidateManifestHash string

+ ChangeManifest []FileEntry

+ CodeReviewerSessionID string

+ CodeRound int

+ Diagnostics []string

+ Findings []Finding

+ ID string

+ ImplementerSessionID string

+ InFlight *InFlight

+ IntegrationReview bool

+ InterruptedLoop string

+ LastUsedAt time.Time

+ MaxRounds int

+ ParentTaskID string

+ PendingAnswer string

+ PendingQuestion string

+ PendingQuestionSource string

+ Phase string

+ Plan string

+ PlanHash string

+ PlanReviewerSessionID string

+ PlanRound int

+ PlannedScope string

+ PlannerSessionID string

+ ProfilesSnapshot map[string]ProfileSnapshot

+ Prompt string

+ PromptInputs []string

+ ProviderUsageCumulative map[string]TokenUsage

+ RepoRoot string

+ Retry *RetryState

+ ReturnPhase string

+ ReviewCheckpoint []FileEntry

+ ReviewCheckpointFindings []Finding

+ ReviewCheckpointHash string

+ Round int

+ RuntimeSnapshot map[string]RuntimeSnapshot

+ Scope string

+ ScopeSpecHash string

+ ScopedBaseline []FileEntry

+ ScopedBaselineHash string

+ Task string

+ UpdatedAt time.Time

+ Usage map[string]TokenUsage

+ WorkGraph bool

+ WorkUnitID string

+ WorkUnits []WorkUnit

+ type Store struct

+ Dir string

+ Root string

+ func NewStore(repoRoot string) *Store

+ func NewStoreAt(dir string) *Store

+ func (s *Store) Create(st State) error

+ func (s *Store) Delete(id string) error

+ func (s *Store) List() ([]State, error)

+ func (s *Store) Load(id string) (State, error)

+ func (s *Store) Lock(id string) (*AdvisoryLock, error)

+ func (s *Store) Save(st State) error

+ func (s *Store) SaveOwned(st State, token string) error

+ func (s *Store) Update(id string, update func(*State) error) (State, error)

+ func (s *Store) UpdateOwned(id, token string, update func(*State) error) (State, error)

+ type TokenUsage struct

+ CacheWriteTokens int64

+ CachedInputTokens int64

+ InputTokens int64

+ OutputTokens int64

+ PromptBytes int64

+ ReasoningTokens int64

+ Requests int64

+ TotalTokens int64

+ func (u *TokenUsage) Add(turn TokenUsage)

+ func (u TokenUsage) Empty() bool

+ type WorkUnit struct

+ AcceptanceCriteria []string

+ DependsOn []string

+ ExecutionPacket string

+ ID string

+ Objective string

+ Scope string

+ ValidationCommands []string

+ func NormalizeWorkUnits(units []WorkUnit, plan string) ([]WorkUnit, error)

+ type Worktree struct

+ Root string

+ func NewWorktree(root string) *Worktree

+ func (w *Worktree) Head() (string, error)

+ func (w *Worktree) Manifest() ([]FileEntry, error)

+ func (w *Worktree) ManifestForScope(scope string) ([]FileEntry, error)

+ func (w *Worktree) Paths() ([]string, error)