Versions in this module Expand all Collapse all v1 v1.10.4 Nov 4, 2026 v1.10.3 Oct 30, 2026 v1.10.2 Oct 30, 2026 v1.10.1 Oct 30, 2026 v1.10.0 Oct 30, 2026 v1.9.0 Oct 27, 2026 Changes in this version + const MaxProgressAttempts + const MaxReplanAttempts + const PrefixPlan + const PrefixTask + var ErrConflict = errors.New("cortex: plan revision conflict") + var ErrInvalid = errors.New("cortex: invalid plan") + var ErrNotFound = errors.New("cortex: plan not found") + func ArtifactProducer(p Plan, taskID id.ID) string + func Ready(p Plan, states []TaskState, at time.Time) ([]id.ID, error) + func TaskContract(p Plan, taskID, contractID id.ID) (verification.Contract, error) + func Validate(p Plan, limits Limits) error + func ValidateTaskAcceptance(p Plan, taskID id.ID, states []TaskState, at time.Time) error + func ValidateTaskBinding(p Plan, taskID id.ID, binding verification.Binding) error + func ValidateTaskBindingForContract(p Plan, taskID id.ID, contract verification.Contract, ...) error + func ValidateTaskContract(p Plan, taskID id.ID, contract verification.Contract) error + type Access string + const AccessRead + const AccessWrite + type ArtifactRequirement struct + MaxBytes int64 + MediaType string + Name string + type Authority struct + Budget execution.Budget + Effects []execution.EffectRequirement + Resources []ResourceGrant + func TaskAuthority(p Plan, taskID id.ID) (Authority, error) + func (a Authority) Validate() error + func (a Authority) Within(parent Authority) bool + type Limits struct + MaxDepth int + MaxEdges int + MaxTasks int + type ListRequest struct + After id.ID + Limit int + type Origin struct + Digest string + ID id.ID + Kind string + type Plan struct + Actor string + AffectedTasks []id.ID + Budget execution.Budget + Contract verification.Contract + Digest string + Effects []execution.EffectRequirement + ID id.ID + Objective string + Origin Origin + Owners []string + PreviousDigest string + Reason string + Resources []ResourceGrant + Revision int64 + SchemaVersion int + Scope cortex.Scope + Sources []verification.Source + Tasks []Task + func ApplyRevision(current Plan, proposal Revision, expected int64, limits Limits) (Plan, error) + func Seal(p Plan, limits Limits) (Plan, error) + type ProgressAttempt struct + Advanced bool + FailureDigest string + FinishedAt time.Time + PlanDigest string + RunID id.AgentRunID + TaskID id.ID + type ProgressConflict struct + LeftDigest string + PlanDigest string + RightDigest string + TaskID id.ID + type ProgressSnapshot struct + Account execution.BudgetSnapshot + At time.Time + Attempts []ProgressAttempt + Conflicts []ProgressConflict + LastProgressAt time.Time + Plan Plan + SchemaVersion int + StartedAt time.Time + UnresolvedEffects bool + WaitingSince time.Time + func (s ProgressSnapshot) Validate() error + type ReplanAction string + const ReplanContinue + const ReplanPropose + const ReplanReconcile + const ReplanStop + const ReplanWait + type ReplanDecision struct + Action ReplanAction + PlanDigest string + PlanID id.ID + PlanRevision int64 + PolicyDigest string + Reason ReplanReason + SchemaVersion int + SnapshotDigest string + func ProposeReplan(snapshot ProgressSnapshot, policy ReplanPolicy) ReplanDecision + type ReplanPolicy struct + DeadlineReserve time.Duration + Disabled bool + FailureThreshold int + MaxIdle time.Duration + MaxReplans int + NoProgressThreshold int + SchemaVersion int + func (p ReplanPolicy) Normalize() (ReplanPolicy, error) + type ReplanReason string + const ReplanBudget + const ReplanContradiction + const ReplanDeadline + const ReplanDeadlinePressure + const ReplanDisabled + const ReplanHealthy + const ReplanIdle + const ReplanInvalidPolicy + const ReplanInvalidSnapshot + const ReplanLimit + const ReplanNoProgress + const ReplanRepeatedFailure + const ReplanStalledWait + const ReplanUnresolvedEffects + const ReplanWaiting + type ResourceGrant struct + Access Access + Resource string + Revision string + type ReviewRequirement struct + PolicyRevision string + ReviewerAgent string + ReviewerPrincipal string + type Revision struct + Actor string + Plan Plan + Reason string + type Status string + const StatusBlocked + const StatusCancelled + const StatusClaimed + const StatusFailed + const StatusPending + const StatusReady + const StatusRunning + const StatusSucceeded + const StatusVerifying + const StatusWaiting + type Store interface + CommitRevision func(context.Context, Revision, int64) (Plan, error) + CreatePlan func(context.Context, Plan) error + GetPlan func(context.Context, id.ID) (Plan, error) + GetPlanRevision func(context.Context, id.ID, int64) (Plan, error) + ListPlans func(context.Context, ListRequest) ([]Plan, error) + ReadTasks func(context.Context, id.ID) ([]Task, error) + type Task struct + Budget execution.Budget + Criteria []string + DependsOn []id.ID + Effects []string + ID id.ID + Instruction string + Output ArtifactRequirement + Owner string + Resources []ResourceGrant + Review *ReviewRequirement + Sources []string + type TaskState struct + Contract *verification.Contract + Current verification.Binding + PlanDigest string + Reports []verification.Report + Status Status + TaskID id.ID