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 MaxBoardRequestBytes + const MaxBoardTransitions + const MaxClaimBytes + const MaxClaimDuration + const MaxHandoffBytes + const MaxPlanBoardTransitions + const MaxPlanningArtifactResources + const MaxReviewBytes + const MaxTaskAcceptanceBytes + const MaxTaskAdjudicationBytes + const MaxTaskUsageBytes + const MaxTaskUsageJobs + const PrefixAssignment + const PrefixBoardTransition + const PrefixClaim + const PrefixHandoff + const PrefixPlanReplan + const PrefixReview + const PrefixTaskAcceptance + const PrefixTaskAcceptedEvent + const PrefixTaskAdjudication + const PrefixTaskClaimedEvent + const PrefixTaskDispatchEvent + const PrefixTaskRenewalEvent + const PrefixTaskRunEvent + var ErrAssignmentConflict = cortex.ErrAssignmentConflict + var ErrAssignmentNotFound = cortex.ErrAssignmentNotFound + var ErrAssignmentUnavailable = cortex.ErrAssignmentUnavailable + var ErrClaimConflict = cortex.ErrClaimConflict + var ErrClaimNotFound = cortex.ErrClaimNotFound + var ErrHandoffUnavailable = cortex.ErrHandoffUnavailable + var ErrInvalidAssignment = cortex.ErrInvalidAssignment + var ErrInvalidClaim = cortex.ErrInvalidClaim + var ErrInvalidHandoff = cortex.ErrInvalidHandoff + var ErrInvalidReview = cortex.ErrInvalidReview + var ErrInvalidScheduler = cortex.ErrInvalidScheduler + var ErrInvalidTaskAcceptance = cortex.ErrInvalidTaskAcceptance + var ErrInvalidTaskSettlement = cortex.ErrInvalidTaskSettlement + var ErrInvalidTaskUsage = cortex.ErrInvalidTaskUsage + var ErrPlanningDenied = errors.New("cortex: planning operator access denied") + var ErrPlanningUnavailable = errors.New("cortex: planning operator unavailable") + var ErrReviewConflict = cortex.ErrReviewConflict + var ErrReviewNotFound = cortex.ErrReviewNotFound + var ErrSchedulerFull = cortex.ErrSchedulerFull + var ErrSchedulerReconciliationRequired = cortex.ErrSchedulerReconciliationRequired + var ErrSchedulerStopped = cortex.ErrSchedulerStopped + var ErrTaskAcceptanceConflict = cortex.ErrTaskAcceptanceConflict + var ErrTaskAcceptanceNotFound = cortex.ErrTaskAcceptanceNotFound + var ErrTaskSettlementConflict = cortex.ErrTaskSettlementConflict + var ErrTaskUsageClosed = cortex.ErrTaskUsageClosed + var ErrTaskUsageConflict = cortex.ErrTaskUsageConflict + func EventSources() []string + func HandoffSendParams(h Handoff, localNode string) (a2a.SendParams, error) + func PrepareTaskUsageSettlement(r TaskUsageSettlementRequest, snapshot TaskUsageSnapshot, ...) (execution.Settlement, error) + func ValidateClaimSuccessor(previous, next Claim) error + func ValidateHandoff(h Handoff, p planning.Plan, current HandoffAuthority, at time.Time) error + func ValidateHandoffPlan(h Handoff, p planning.Plan, at time.Time) error + func ValidateReview(r Review, subject Assignment, binding verification.Binding, p planning.Plan, ...) error + func ValidateTaskCompletion(request TaskCompletionRequest, subject Assignment, ...) error + func ValidateTaskRecoverySnapshot(proof TaskRecoveryProof, snapshot execution.RunRecoverySnapshot, c Claim, ...) error + type A2AHandoffHandler struct + func NewA2AHandoffHandler(localNode string, receiver *HandoffReceiver, now func() time.Time) (*A2AHandoffHandler, error) + func (a *A2AHandoffHandler) ReceiveHandoff(ctx context.Context, e *a2a.Envelope) error + func (a *A2AHandoffHandler) ValidateHandoff(ctx context.Context, e *a2a.Envelope) error + type AcceptedClaimStore interface + ListAcceptedTaskClaims func(context.Context, TaskAcceptanceListRequest) ([]Claim, error) + type AcceptedDependency struct + AcceptanceID id.ID + Current verification.Binding + Digest string + type AdjudicationDecision string + const AdjudicationBlocked + const AdjudicationSupported + type AgentReplyListRequest struct + After string + Limit int + type AgentReplyPage struct + Next string + Runs []ScheduledAgentReply + type AgentReplyRecoverer interface + Recover func(context.Context, id.AgentRunID) error + type AgentReplyRecoveryConfig struct + AttemptTimeout time.Duration + Discovery AgentReplySource + DiscoveryTimeout time.Duration + Interval time.Duration + MaxInFlight int + MaxPerScope int + Recoverer AgentReplyRecoverer + ReportError func(error) + type AgentReplyRecoveryService struct + func NewAgentReplyRecoveryService(config AgentReplyRecoveryConfig) (*AgentReplyRecoveryService, error) + func (s *AgentReplyRecoveryService) RequestStop() + func (s *AgentReplyRecoveryService) Start(ctx context.Context) error + func (s *AgentReplyRecoveryService) Status() TaskServiceStatus + func (s *AgentReplyRecoveryService) Stop(ctx context.Context) error + type AgentReplySource interface + ListAgentReplyRuns func(context.Context, AgentReplyListRequest) (AgentReplyPage, error) + type ArtifactBoard struct + func NewArtifactBoard(storage ArtifactBoardStore, authority ArtifactBoardAuthority) (*ArtifactBoard, error) + func (b *ArtifactBoard) Read(ctx context.Context, req ArtifactBoardRead) ([]ArtifactBoardEntry, error) + func (b *ArtifactBoard) Write(ctx context.Context, req ArtifactBoardRequest) (ArtifactBoardEntry, error) + type ArtifactBoardAuthority interface + AuthorizeArtifactBoard func(context.Context, ArtifactBoardRequest) error + AuthorizeArtifactBoardRead func(context.Context, ArtifactBoardRead) error + WithArtifactBoardFence func(context.Context, ArtifactBoardRequest, func(ArtifactBoardRequest) error) error + WithArtifactBoardReadFence func(context.Context, ArtifactBoardRead, func(ArtifactBoardRead) error) error + type ArtifactBoardEntry struct + Artifact evidence.Ref + At time.Time + Conflict bool + Digest string + HeadRevision int64 + Owner Identity + PlanRevision int64 + PreviousDigest string + Request ArtifactBoardRequest + RequestDigest string + SchemaVersion int + Sequence int64 + TaskID id.ID + func SealArtifactBoardEntry(e ArtifactBoardEntry) (ArtifactBoardEntry, error) + func (e ArtifactBoardEntry) Validate() error + type ArtifactBoardRead struct + After int64 + Limit int + PlanID id.ID + Resource planning.ResourceGrant + Scope cortex.Scope + func (r ArtifactBoardRead) Freeze() (ArtifactBoardRead, string, error) + type ArtifactBoardRequest struct + AcceptanceDigest string + AcceptanceID id.ID + Actor string + Current verification.Binding + Dependencies []AcceptedDependency + ExpectedDigest string + ExpectedRevision int64 + ID id.ID + PlanDigest string + PlanID id.ID + Reason string + Resolve id.ID + Resource planning.ResourceGrant + SchemaVersion int + Scope cortex.Scope + func (r ArtifactBoardRequest) Freeze() (ArtifactBoardRequest, string, error) + type ArtifactBoardStore interface + ReadArtifactBoard func(context.Context, ArtifactBoardRead) ([]ArtifactBoardEntry, error) + WriteArtifactBoard func(context.Context, ArtifactBoardRequest) (ArtifactBoardEntry, error) + type ArtifactPublicationConfig struct + Authority ArtifactBoardAuthority + AuthorizeScan func(context.Context, id.ID) error + Discovery TaskPlanSource + DiscoveryTimeout time.Duration + Interval time.Duration + MaxInFlight int + MaxPerScope int + PageSize int + PageTimeout time.Duration + ReportError func(error) + Resolver ArtifactPublicationResolver + Store ArtifactPublicationStore + type ArtifactPublicationResolver interface + ResolveArtifactPublication func(context.Context, TaskAcceptance) (*ArtifactBoardRequest, error) + type ArtifactPublicationService struct + func NewArtifactPublicationService(config ArtifactPublicationConfig) (*ArtifactPublicationService, error) + func (s *ArtifactPublicationService) RequestStop() + func (s *ArtifactPublicationService) Start(ctx context.Context) error + func (s *ArtifactPublicationService) Status() TaskServiceStatus + func (s *ArtifactPublicationService) Stop(ctx context.Context) error + type ArtifactPublicationStore interface + type Assignment struct + Actor string + At time.Time + Digest string + Handoff Handoff + PreviousDigest string + Reason string + RequestDigest string + Revision int64 + SchemaVersion int + State AssignmentState + Submission *Submission + func Advance(previous Assignment, change AssignmentChange, at time.Time) (Assignment, error) + func Propose(h Handoff, at time.Time) (Assignment, error) + func (a Assignment) Validate() error + type AssignmentChange struct + Actor string + AssignmentID id.ID + ExpectedRevision int64 + Fence uint64 + HandoffDigest string + Reason string + State AssignmentState + Submission *Submission + func (c AssignmentChange) BindingDigest() (string, error) + func (c AssignmentChange) Freeze() (AssignmentChange, string, error) + type AssignmentHistoryRequest struct + AfterRevision int64 + AssignmentID id.ID + Limit int + type AssignmentListRequest struct + After id.ID + Limit int + PlanID id.ID + type AssignmentState string + const AssignmentAccepted + const AssignmentBlocked + const AssignmentCancelled + const AssignmentProposed + const AssignmentRejected + const AssignmentSubmitted + const AssignmentWorking + const MaxAssignmentBytes + func (s AssignmentState) Terminal() bool + type AssignmentStore interface + AdvanceAssignment func(context.Context, AssignmentChange) (Assignment, error) + AssignmentHistory func(context.Context, AssignmentHistoryRequest) ([]Assignment, error) + GetAssignment func(context.Context, id.ID) (Assignment, error) + ListAssignments func(context.Context, AssignmentListRequest) ([]Assignment, error) + ProposeAssignment func(context.Context, Handoff) (Assignment, error) + type BudgetedClaim struct + Claim Claim + Fresh bool + Reservation execution.Reservation + func (a BudgetedClaim) Validate(request BudgetedClaimRequest) error + type BudgetedClaimRequest struct + Claim ClaimRequest + Reservation execution.ReservationRequest + func (r BudgetedClaimRequest) Freeze() (BudgetedClaimRequest, string, error) + type BudgetedClaimStore interface + AcquireBudgetedTaskClaim func(context.Context, BudgetedClaimRequest) (BudgetedClaim, error) + GetBudgetedTaskClaim func(context.Context, id.ID) (BudgetedClaim, error) + type Claim struct + AcceptanceID *id.ID + AcquiredAt time.Time + At time.Time + Deadline time.Time + Digest string + ExpiresAt time.Time + Fence uint64 + GrantRef string + ID id.ID + PlanDigest string + PlanID id.ID + PlanRevision int64 + PreviousDigest string + RecoveryDigest string + RetirementDigest string + Revision int64 + RunID id.AgentRunID + SchemaVersion int + Scope cortex.Scope + State ClaimState + TaskID id.ID + Worker Identity + func AcquireClaim(previous *Claim, request ClaimRequest, p planning.Plan, at time.Time) (Claim, error) + func AdoptRecoveredClaim(c Claim, token ClaimToken, acceptanceID id.ID, proof TaskRecoveryProof, ...) (Claim, error) + func BeginDispatch(c Claim, token ClaimToken, runID id.AgentRunID, at time.Time) (Claim, error) + func CompleteClaim(c Claim, token ClaimToken, acceptanceID id.ID, at time.Time) (Claim, error) + func ExpireClaim(c Claim, expectedRevision int64, at time.Time) (Claim, error) + func RenewClaim(c Claim, token ClaimToken, duration time.Duration, at time.Time) (Claim, error) + func RetireRecoveredClaim(c Claim, request TaskRetirementRequest, at time.Time) (Claim, error) + func (c Claim) Token() ClaimToken + func (c Claim) Validate() error + type ClaimExpiryStore interface + ExpireTaskClaim func(context.Context, id.ID, id.ID, int64) (Claim, error) + ListTaskClaims func(context.Context, ClaimListRequest) ([]Claim, error) + type ClaimHistoryRequest struct + AfterRevision int64 + Limit int + PlanID id.ID + TaskID id.ID + type ClaimListRequest struct + AfterTaskID id.ID + Limit int + PlanID id.ID + func (r ClaimListRequest) Validate() error + type ClaimRecoveryConfig struct + Clock verification.Clock + Discovery TaskPlanSource + DiscoveryTimeout time.Duration + Interval time.Duration + MaxInFlight int + MaxPerScope int + PageSize int + PageTimeout time.Duration + ReportError func(error) + Store ClaimExpiryStore + type ClaimRecoveryService struct + func NewClaimRecoveryService(config ClaimRecoveryConfig) (*ClaimRecoveryService, error) + func (s *ClaimRecoveryService) RequestStop() + func (s *ClaimRecoveryService) Start(ctx context.Context) error + func (s *ClaimRecoveryService) Status() TaskServiceStatus + func (s *ClaimRecoveryService) Stop(ctx context.Context) error + type ClaimRequest struct + Duration time.Duration + ExpectedRevision int64 + GrantRef string + ID id.ID + PlanDigest string + PlanID id.ID + PlanRevision int64 + SchemaVersion int + TaskID id.ID + Worker Identity + func (r ClaimRequest) Freeze() (ClaimRequest, string, error) + type ClaimState string + const ClaimCompleted + const ClaimDispatching + const ClaimHeld + const ClaimRecovering + const ClaimReleased + const ClaimRetired + type ClaimStore interface + AcquireTaskClaim func(context.Context, ClaimRequest) (Claim, error) + BeginTaskDispatch func(context.Context, ClaimToken, id.AgentRunID) (DispatchAdmission, error) + ExpireTaskClaim func(context.Context, id.ID, id.ID, int64) (Claim, error) + GetTaskClaim func(context.Context, id.ID, id.ID) (Claim, error) + ListTaskClaims func(context.Context, ClaimListRequest) ([]Claim, error) + RenewTaskClaim func(context.Context, ClaimToken, time.Duration) (Claim, error) + TaskClaimHistory func(context.Context, ClaimHistoryRequest) ([]Claim, error) + type ClaimSweepPage struct + Conflicts int + NextTaskID id.ID + Recovering int + Released int + Scanned int + type ClaimSweeper struct + func NewClaimSweeper(store ClaimExpiryStore, clock verification.Clock) (*ClaimSweeper, error) + func (s *ClaimSweeper) Sweep(ctx context.Context, request ClaimListRequest) (ClaimSweepPage, error) + type ClaimToken struct + ClaimID id.ID + Fence uint64 + PlanID id.ID + Revision int64 + TaskID id.ID + Worker Identity + func (t ClaimToken) Validate() error + type ClaimedTaskWorker interface + RunClaimedTask func(context.Context, ReadyTaskClaimRequest, ReadyTaskClaim) error + type CurrentTaskAcceptance struct + ObservedAt time.Time + State planning.TaskState + ValidUntil time.Time + type CurrentTaskAcceptanceRequest struct + Accepted AcceptedDependency + Dependencies []AcceptedDependency + func (r CurrentTaskAcceptanceRequest) Validate() error + type CurrentTaskAcceptanceStore interface + ReadCurrentTaskAcceptance func(context.Context, CurrentTaskAcceptanceRequest) (CurrentTaskAcceptance, error) + type Delivery struct + Event Event + Reference string + SinkID string + func (r Delivery) Validate() error + type DeliveryRequest struct + Event Event + SinkID string + func (r DeliveryRequest) Freeze() (DeliveryRequest, string, error) + type DispatchAdmission struct + Claim Claim + Fresh bool + type EffectContinuationOffer struct + Arguments []byte + Request execution.EffectContinuationRequest + type EffectContinuationResolver interface + ResolveEffectContinuation func(context.Context, Claim, execution.RunRecoverySnapshot, execution.EffectRecord, ...) (*EffectContinuationOffer, error) + type EffectContinuationService struct + func NewEffectContinuationService(config EffectContinuationServiceConfig) (*EffectContinuationService, error) + func (s *EffectContinuationService) RequestStop() + func (s *EffectContinuationService) Start(ctx context.Context) error + func (s *EffectContinuationService) Status() TaskServiceStatus + func (s *EffectContinuationService) Stop(ctx context.Context) error + type EffectContinuationServiceConfig struct + Authority execution.EffectContinuationAuthority + Discovery TaskPlanSource + DiscoveryTimeout time.Duration + Effects execution.EffectExecutorConfig + Interval time.Duration + MaxInFlight int + MaxPerScope int + PageSize int + PageTimeout time.Duration + ReportError func(error) + Resolver EffectContinuationResolver + type EffectRecoveryService struct + func NewEffectRecoveryService(config EffectRecoveryServiceConfig) (*EffectRecoveryService, error) + func (s *EffectRecoveryService) RequestStop() + func (s *EffectRecoveryService) Start(ctx context.Context) error + func (s *EffectRecoveryService) Status() TaskServiceStatus + func (s *EffectRecoveryService) Stop(ctx context.Context) error + type EffectRecoveryServiceConfig struct + Discovery TaskPlanSource + DiscoveryTimeout time.Duration + Interval time.Duration + MaxInFlight int + MaxPerScope int + PageSize int + PageTimeout time.Duration + Recovery execution.EffectExecutorConfig + ReportError func(error) + type Event struct + Artifact *evidence.Ref + ClaimRevision int64 + Digest string + EventID string + ObservedAt time.Time + PlanID id.ID + PlanRevision int64 + PredecessorDigest string + RunID id.AgentRunID + SchemaVersion int + Scope cortex.Scope + Sequence int64 + SourceDigest string + SourceID string + SourceKind string + TaskID id.ID + Type string + func SealEvent(e Event) (Event, error) + func (e Event) Validate() error + type EventAuthority interface + AuthorizeCoordinationDelivery func(context.Context, DeliveryRequest) error + AuthorizeCoordinationScan func(context.Context, id.ID, string) error + WithCoordinationDeliveryFence func(context.Context, DeliveryRequest, func(DeliveryRequest) error) error + type EventImport struct + After string + Limit int + PlanID id.ID + Scope cortex.Scope + Source string + func (r EventImport) Validate() error + type EventImportPage struct + Imported int + Next string + type EventPage struct + After int64 + Limit int + PlanID id.ID + Scope cortex.Scope + func (r EventPage) Validate() error + type EventService struct + func NewEventService(config EventServiceConfig) (*EventService, error) + func (s *EventService) RequestStop() + func (s *EventService) Start(ctx context.Context) error + func (s *EventService) Status() TaskServiceStatus + func (s *EventService) Stop(ctx context.Context) error + type EventServiceConfig struct + Authority EventAuthority + Discovery TaskPlanSource + DiscoveryTimeout time.Duration + Interval time.Duration + MaxInFlight int + MaxPerScope int + MaxTrackedPlans int + PageSize int + PageTimeout time.Duration + ReportError func(error) + Sink EventSink + SinkID string + Store EventStore + type EventSink interface + DeliverCoordinationEvent func(context.Context, DeliveryRequest) (Delivery, error) + type EventStore interface + AcknowledgeCoordinationEvent func(context.Context, Delivery) error + GetCoordinationDelivery func(context.Context, Event, string) (*Delivery, error) + ImportCoordinationEvents func(context.Context, EventImport) (EventImportPage, error) + ListCoordinationEvents func(context.Context, EventPage) ([]Event, error) + type Handoff struct + AssignmentID id.ID + Authority planning.Authority + ContractDigest string + Criteria []string + Deadline time.Time + Digest string + Fence uint64 + GrantRef string + ID id.ID + Inputs []evidence.Ref + ParentRunID id.AgentRunID + PlanDigest string + PlanID id.ID + PlanRevision int64 + Purpose HandoffPurpose + Receiver Identity + SchemaVersion int + Scope cortex.Scope + Sender Identity + TaskID id.ID + func DecodeHandoff(data []byte) (Handoff, error) + func SealHandoff(h Handoff) (Handoff, error) + func (h Handoff) Validate() error + type HandoffAuthority struct + AssignmentID id.ID + Ceiling planning.Authority + Fence uint64 + GrantRef string + ParentRunID id.AgentRunID + ProducerPrincipal string + Receiver Identity + Sender Identity + type HandoffContext struct + Authority HandoffAuthority + Plan planning.Plan + type HandoffPurpose string + const HandoffReview + const HandoffWork + type HandoffReceiver struct + func NewHandoffReceiver(config HandoffReceiverConfig) (*HandoffReceiver, error) + func (r *HandoffReceiver) Receive(ctx context.Context, h Handoff) error + type HandoffReceiverConfig struct + Accept func(context.Context, Handoff) error + MaxConcurrent int + Now func() time.Time + Resolve func(context.Context, Handoff) (HandoffContext, error) + type Identity struct + Agent string + Node string + Principal string + type OrchestrationExpirer interface + Expire func(context.Context, id.OrchestrationID) error + type OrchestrationExpiryConfig struct + AttemptTimeout time.Duration + Discovery OrchestrationSource + DiscoveryTimeout time.Duration + Expirer OrchestrationExpirer + Interval time.Duration + MaxInFlight int + MaxPerScope int + ReportError func(error) + type OrchestrationExpiryService struct + func NewOrchestrationExpiryService(config OrchestrationExpiryConfig) (*OrchestrationExpiryService, error) + func (s *OrchestrationExpiryService) RequestStop() + func (s *OrchestrationExpiryService) Start(ctx context.Context) error + func (s *OrchestrationExpiryService) Status() TaskServiceStatus + func (s *OrchestrationExpiryService) Stop(ctx context.Context) error + type OrchestrationListRequest struct + After string + Limit int + type OrchestrationPage struct + Next string + Teams []ScheduledOrchestration + type OrchestrationRecoverer interface + Recover func(context.Context, id.OrchestrationID) error + type OrchestrationRecoveryConfig struct + AttemptTimeout time.Duration + Discovery OrchestrationSource + DiscoveryTimeout time.Duration + Interval time.Duration + MaxInFlight int + MaxPerScope int + Recoverer OrchestrationRecoverer + ReportError func(error) + type OrchestrationRecoveryService struct + func NewOrchestrationRecoveryService(config OrchestrationRecoveryConfig) (*OrchestrationRecoveryService, error) + func (s *OrchestrationRecoveryService) RequestStop() + func (s *OrchestrationRecoveryService) Start(ctx context.Context) error + func (s *OrchestrationRecoveryService) Status() TaskServiceStatus + func (s *OrchestrationRecoveryService) Stop(ctx context.Context) error + type OrchestrationSource interface + ListOrchestrations func(context.Context, OrchestrationListRequest) (OrchestrationPage, error) + type PlanReplanAbandonment = PreparedRunAbandonment + type PlanReplanAdmission struct + At time.Time + Fresh bool + Request PlanReplanRequest + RequestDigest string + Reservation execution.Reservation + SchemaVersion int + func (a PlanReplanAdmission) Validate() error + type PlanReplanAuthorizer interface + AuthorizePlanReplan func(context.Context, PlanReplanControl) error + type PlanReplanControl struct + Abandonment *PlanReplanAbandonment + Claims []TaskRecoveryProof + Operation string + Request PlanReplanRequest + func (c PlanReplanControl) Freeze() (PlanReplanControl, string, error) + type PlanReplanFence interface + WithPlanReplanFence func(context.Context, PlanReplanControl, func(PlanReplanControl) error) error + type PlanReplanOutcome struct + Abandonment *PlanReplanAbandonment + AdmissionDigest string + At time.Time + AttemptID id.ID + Digest string + Proposed *planning.Plan + RunDigest string + RunRevision int64 + SchemaVersion int + Settlement execution.SettlementReceipt + func SealPlanReplanOutcome(o PlanReplanOutcome) (PlanReplanOutcome, error) + func (o PlanReplanOutcome) Validate() error + type PlanReplanRequest struct + Actor string + AgentID id.AgentID + ID id.ID + InputDigest string + Policy planning.ReplanPolicy + PreparedDigest string + Progress planning.ProgressSnapshot + Reason string + Reservation execution.ReservationRequest + RunID id.AgentRunID + SchemaVersion int + SessionID id.SessionID + func (r PlanReplanRequest) Freeze() (PlanReplanRequest, string, error) + type PlanReplanResolver interface + ResolvePlanReplan func(context.Context, id.ID) (*PlanReplanRequest, error) + ResolvePlanReplanControl func(context.Context, PlanReplanAdmission, *PlanReplanOutcome) (*PlanReplanControl, error) + type PlanReplanRuntime interface + ExecutePlanReplan func(context.Context, PlanReplanAdmission) error + type PlanReplanService struct + func NewPlanReplanService(config PlanReplanServiceConfig) (*PlanReplanService, error) + func (s *PlanReplanService) RequestStop() + func (s *PlanReplanService) Start(ctx context.Context) error + func (s *PlanReplanService) Status() TaskServiceStatus + func (s *PlanReplanService) Stop(ctx context.Context) error + type PlanReplanServiceConfig struct + AttemptTimeout time.Duration + AuthorizeScan func(context.Context, id.ID) error + Authorizer PlanReplanAuthorizer + Discovery TaskPlanSource + DiscoveryTimeout time.Duration + Fence PlanReplanFence + Interval time.Duration + MaxInFlight int + MaxPerScope int + ReportError func(error) + Resolver PlanReplanResolver + Runtime PlanReplanRuntime + Store PlanReplanStore + type PlanReplanStore interface + AdmitPlanReplan func(context.Context, PlanReplanRequest) (PlanReplanAdmission, error) + CommitPlanReplan func(context.Context, PlanReplanControl) (planning.Plan, error) + GetPlan func(context.Context, id.ID) (planning.Plan, error) + GetPlanReplan func(context.Context, id.ID) (*PlanReplanAdmission, error) + GetPlanReplanCommit func(context.Context, id.ID) (*planning.Plan, error) + GetPlanReplanOutcome func(context.Context, id.ID) (*PlanReplanOutcome, error) + ListPlanReplans func(context.Context, id.ID) ([]PlanReplanAdmission, error) + ObservePlanReplan func(context.Context, PlanReplanControl) (*PlanReplanOutcome, error) + type PlanReplanner struct + func NewPlanReplanner(store PlanReplanStore, fence PlanReplanFence, authorizer PlanReplanAuthorizer, ...) (*PlanReplanner, error) + func (r *PlanReplanner) Commit(ctx context.Context, control PlanReplanControl) (planning.Plan, error) + func (r *PlanReplanner) Execute(ctx context.Context, request PlanReplanRequest) (PlanReplanAdmission, error) + func (r *PlanReplanner) Observe(ctx context.Context, control PlanReplanControl) (*PlanReplanOutcome, error) + type PlanReplannerConfig struct + ExecutionTimeout time.Duration + type PlanningAccess struct + Operation string + PlanID id.ID + type PlanningArtifactCandidate struct + Artifact evidence.Ref + At time.Time + ID id.ID + Owner Identity + TaskID id.ID + type PlanningArtifactReadResolver interface + ResolvePlanningArtifactReads func(context.Context, planning.Plan) ([]ArtifactBoardRead, error) + type PlanningArtifactResolver interface + ResolvePlanningArtifact func(context.Context, PlanningCommand) (ArtifactBoardRequest, error) + type PlanningArtifactView struct + Conflicts []PlanningArtifactCandidate + Head *PlanningArtifactCandidate + HeadDigest string + HeadRevision int64 + Resource planning.ResourceGrant + type PlanningCancellation interface + CancelPlanningAssignment func(context.Context, PlanningCommand) (Assignment, error) + func NewPlanningCancellation(store PlanningCancellationStore, authority PlanningCancellationAuthority, ...) (PlanningCancellation, error) + type PlanningCancellationAuthority interface + AuthorizePlanningCancellation func(context.Context, PlanningCommand, Assignment) (string, error) + WithPlanningCancellationFence func(context.Context, PlanningCommand, func() error) error + type PlanningCancellationStore interface + GetRun func(context.Context, id.AgentRunID) (*run.Run, error) + type PlanningCapabilities struct + Cancel bool + Claim bool + Reassign bool + Reconcile bool + Replan bool + ResolveConflict bool + Retry bool + type PlanningClaimResolver interface + ResolvePlanningClaim func(context.Context, PlanningCommand) (ReadyTaskClaimRequest, error) + type PlanningCommand struct + ConflictID id.ID + ExpectedAssignmentRevision int64 + ExpectedClaimRevision int64 + ExpectedDigest string + ExpectedResourceDigest string + ExpectedResourceRevision int64 + ExpectedRevision int64 + Operation string + OperationID id.ID + PlanID id.ID + Reason string + TaskID id.ID + Worker string + func (c PlanningCommand) Validate() error + type PlanningCommandResult struct + AssignmentID id.ID + ClaimID id.ID + Fresh bool + Operation string + OperationID id.ID + Pending bool + PlanDigest string + PlanRevision int64 + type PlanningDetail struct + Artifacts []PlanningArtifactView + Budget execution.BudgetSnapshot + Capabilities PlanningCapabilities + Complete bool + ObservedAt time.Time + Plan PlanningPlanView + Replans []PlanningReplanView + Tasks []PlanningTaskView + type PlanningOperator struct + func NewPlanningOperator(c PlanningOperatorConfig) (*PlanningOperator, error) + func (o *PlanningOperator) Capabilities() PlanningCapabilities + func (o *PlanningOperator) Command(ctx context.Context, c PlanningCommand) (PlanningCommandResult, error) + func (o *PlanningOperator) Detail(ctx context.Context, planID id.ID) (PlanningDetail, error) + func (o *PlanningOperator) List(ctx context.Context, request planning.ListRequest) ([]PlanningPlanView, error) + type PlanningOperatorAuthority interface + AuthorizePlanning func(context.Context, PlanningAccess) error + WithPlanningReadFence func(context.Context, PlanningAccess, func() error) error + type PlanningOperatorConfig struct + Admitter TaskClaimAdmitter + ArtifactReads PlanningArtifactReadResolver + ArtifactResolver PlanningArtifactResolver + Artifacts *ArtifactBoard + Authority PlanningOperatorAuthority + Cancellation PlanningCancellation + Claims PlanningClaimResolver + Clock verification.Clock + Completion *TaskCompletionServiceConfig + Reassign bool + Replanner *PlanReplanner + Replans PlanningReplanResolver + Retry bool + Source SchedulingSource + Store PlanningOperatorStore + Worker ClaimedTaskWorker + type PlanningOperatorStore interface + type PlanningPlanView struct + Deadline time.Time + Digest string + ID id.ID + Objective string + Revision int64 + Tasks int + type PlanningReplanResolver interface + ResolvePlanningReplan func(context.Context, PlanningCommand) (PlanReplanControl, error) + type PlanningReplanView struct + AcceptedRevision int64 + BaseDigest string + BaseRevision int64 + ID id.ID + ProposedDigest string + ProposedTasks []PlanningTaskView + RunID id.AgentRunID + Status string + type PlanningRunCanceller interface + CancelRun func(context.Context, id.AgentRunID) error + type PlanningTaskView struct + AcceptanceID id.ID + AcceptedArtifact *evidence.Ref + AssignmentID id.ID + AssignmentRevision int64 + AssignmentState AssignmentState + Budget execution.Budget + ClaimID id.ID + ClaimRevision int64 + ClaimState ClaimState + CurrentlyAccepted bool + DependsOn []id.ID + ID id.ID + Instruction string + NextAction string + Owner string + Ready bool + ReviewRequired bool + RunID id.AgentRunID + Status planning.Status + type PreparedRunAbandonment struct + AdmissionDigest string + ExpiresAt time.Time + Issuer string + ObservedAt time.Time + ProofDigest string + ProofRef string + type ProviderRecoveryService struct + func NewProviderRecoveryService(config ProviderRecoveryServiceConfig) (*ProviderRecoveryService, error) + func (s *ProviderRecoveryService) RequestStop() + func (s *ProviderRecoveryService) Start(ctx context.Context) error + func (s *ProviderRecoveryService) Status() TaskServiceStatus + func (s *ProviderRecoveryService) Stop(ctx context.Context) error + type ProviderRecoveryServiceConfig struct + Discovery TaskPlanSource + DiscoveryTimeout time.Duration + Interval time.Duration + MaxInFlight int + MaxPerScope int + PageSize int + PageTimeout time.Duration + Recovery execution.ProviderRecoveryConfig + ReportError func(error) + type ReadyTaskClaim struct + Acquisition BudgetedClaim + Fresh bool + Outbox TaskClaimOutbox + RequestDigest string + func (r ReadyTaskClaim) Validate(request ReadyTaskClaimRequest) error + type ReadyTaskClaimRequest struct + Acquisition BudgetedClaimRequest + Dependencies []AcceptedDependency + SchemaVersion int + func (r ReadyTaskClaimRequest) Freeze() (ReadyTaskClaimRequest, string, error) + type ReadyTaskClaimStore interface + ClaimReadyTask func(context.Context, ReadyTaskClaimRequest) (ReadyTaskClaim, error) + GetReadyTaskClaim func(context.Context, id.ID) (ReadyTaskClaim, error) + type RenewingClaimedTaskWorker interface + RunClaimedTaskWithRenewal func(context.Context, ReadyTaskClaimRequest, ReadyTaskClaim, TaskRenewalStart) error + type Review struct + BindingDigest string + Digest string + Findings []ReviewFinding + Handoff Handoff + ID id.ID + PreparedDigest string + ReviewedAt time.Time + RunID id.AgentRunID + RunRevision int64 + SchemaVersion int + SubjectAssignmentID id.ID + SubjectDigest string + SubjectRevision int64 + func SealReview(r Review) (Review, error) + func (r Review) Output() ([]byte, error) + func (r Review) Validate() error + func (r Review) ValidateOutput(data []byte) error + type ReviewAssessment string + const ReviewContradicted + const ReviewMissing + const ReviewSupported + type ReviewFinding struct + Assessment ReviewAssessment + CriterionID string + EvidenceIDs []id.ID + Reason string + type ReviewListRequest struct + After id.ID + AssignmentID id.ID + Limit int + type ReviewOutput struct + BindingDigest string + Findings []ReviewFinding + HandoffDigest string + SchemaVersion int + SubjectDigest string + type ReviewStore interface + GetAssignmentReview func(context.Context, id.ID) (Review, error) + ListAssignmentReviews func(context.Context, ReviewListRequest) ([]Review, error) + RecordAssignmentReview func(context.Context, Review) (Review, error) + type ScheduledAgentReply struct + ID id.AgentRunID + Scope cortex.Scope + type ScheduledOrchestration struct + ID id.OrchestrationID + Scope cortex.Scope + type ScheduledPlan struct + PlanID id.ID + Scope cortex.Scope + type ScheduledTaskCompletion struct + AssignmentID id.ID + Scope cortex.Scope + type ScheduledVerificationJob struct + ID id.ID + Scope cortex.Scope + type Scheduler interface + Tick func(context.Context, id.ID) error + type SchedulerConfig struct + Admitter TaskClaimAdmitter + Clock verification.Clock + MaxConcurrent int + MaxPerScope int + MaxQueued int + Renewal *TaskRenewalConfig + Resolver TaskClaimResolver + Source SchedulingSource + TickTimeout time.Duration + Worker ClaimedTaskWorker + type SchedulerStatus struct + Active int + Queued int + Stopped bool + type SchedulingSource interface + LoadSchedulingState func(context.Context, id.ID) (planning.Plan, []planning.TaskState, error) + type ScopedAgentReplySource struct + func NewScopedAgentReplySource(store suspension.ReplyDiscoveryStore, scopes []cortex.Scope, ...) (*ScopedAgentReplySource, error) + func (s *ScopedAgentReplySource) ListAgentReplyRuns(ctx context.Context, req AgentReplyListRequest) (AgentReplyPage, error) + type ScopedOrchestrationSource struct + func NewScopedOrchestrationSource(store orchestration.BudgetDiscoveryStore, scopes []cortex.Scope, ...) (*ScopedOrchestrationSource, error) + func (s *ScopedOrchestrationSource) ListOrchestrations(ctx context.Context, request OrchestrationListRequest) (OrchestrationPage, error) + type ScopedVerificationSource struct + func NewScopedVerificationSource(store VerificationJobDiscoveryStore, scopes []cortex.Scope, ...) (*ScopedVerificationSource, error) + func (s *ScopedVerificationSource) ListCapturedVerificationJobs(ctx context.Context, req VerificationJobListRequest) (VerificationJobPage, error) + type Submission struct + BindingDigest string + JobID id.ID + JobRequestDigest string + RunID id.AgentRunID + RunRevision int64 + SchemaVersion int + func (s Submission) Validate() error + type TaskAcceptance struct + Claim Claim + Digest string + Fresh bool + ObservedAt time.Time + Outbox TaskAcceptanceOutbox + Request TaskAcceptanceRequest + RequestDigest string + SchemaVersion int + func SealTaskAcceptance(a TaskAcceptance) (TaskAcceptance, error) + func (a TaskAcceptance) Validate() error + type TaskAcceptanceAuthorizer interface + AuthorizeTaskAcceptance func(context.Context, TaskAcceptanceRequest) error + type TaskAcceptanceFence interface + WithTaskAcceptanceFence func(context.Context, TaskAcceptanceRequest, func(TaskAcceptanceRequest) error) error + type TaskAcceptanceListRequest struct + After id.ID + Limit int + PlanID id.ID + func (r TaskAcceptanceListRequest) Validate() error + type TaskAcceptanceOutbox struct + AcceptanceID id.ID + EventID id.ID + PlanID id.ID + RunID id.AgentRunID + TaskID id.ID + Type string + type TaskAcceptanceRequest struct + Actor string + Adjudication *TaskAdjudicationRef + AssignmentDigest string + AssignmentID id.ID + AssignmentRevision int64 + Claim ClaimToken + Current verification.Binding + Dependencies []AcceptedDependency + ID id.ID + Reason string + Recovery *TaskRecoveryProof + Result verification.ResultReadRequest + SchemaVersion int + func (r TaskAcceptanceRequest) Freeze() (TaskAcceptanceRequest, string, error) + type TaskAcceptanceStore interface + AcceptTaskResult func(context.Context, TaskAcceptanceRequest) (TaskAcceptance, error) + GetTaskAcceptance func(context.Context, id.ID) (TaskAcceptance, error) + ListTaskAcceptances func(context.Context, TaskAcceptanceListRequest) ([]TaskAcceptance, error) + type TaskAcceptor interface + Accept func(context.Context, TaskAcceptanceRequest) (TaskAcceptance, error) + func NewTaskAcceptor(storage TaskAcceptanceStore, fence TaskAcceptanceFence, ...) (TaskAcceptor, error) + type TaskAdjudication struct + Decision AdjudicationDecision + Digest string + ObservedAt time.Time + Request TaskAdjudicationRequest + RequestDigest string + SchemaVersion int + func PrepareTaskAdjudication(request TaskAdjudicationRequest, r Review, p planning.Plan, at time.Time) (TaskAdjudication, error) + func SealTaskAdjudication(a TaskAdjudication) (TaskAdjudication, error) + func (a TaskAdjudication) Validate() error + type TaskAdjudicationRef struct + Digest string + ID id.ID + func (r TaskAdjudicationRef) Validate() error + type TaskAdjudicationRequest struct + Actor string + AssignmentDigest string + AssignmentID id.ID + AssignmentRevision int64 + BindingDigest string + ID id.ID + PlanDigest string + PlanID id.ID + PolicyRevision string + Reason string + ReviewDigest string + ReviewID id.ID + SchemaVersion int + TaskID id.ID + func (r TaskAdjudicationRequest) Freeze() (TaskAdjudicationRequest, string, error) + type TaskAdjudicationStore interface + GetTaskAdjudication func(context.Context, id.ID) (TaskAdjudication, error) + RecordTaskAdjudication func(context.Context, TaskAdjudicationRequest) (TaskAdjudication, error) + type TaskAdoptionService struct + func NewTaskAdoptionService(config TaskAdoptionServiceConfig) (*TaskAdoptionService, error) + func (s *TaskAdoptionService) RequestStop() + func (s *TaskAdoptionService) Start(ctx context.Context) error + func (s *TaskAdoptionService) Status() TaskServiceStatus + func (s *TaskAdoptionService) Stop(ctx context.Context) error + type TaskAdoptionServiceConfig struct + AttemptTimeout time.Duration + AuthorizeScan func(context.Context, Claim, execution.RunCallSeal) error + Authorizer TaskRecoveryAuthorizer + Discovery TaskPlanSource + DiscoveryTimeout time.Duration + Fence TaskRecoveryFence + Interval time.Duration + MaxInFlight int + MaxPerScope int + PageSize int + PageTimeout time.Duration + ReportError func(error) + Resolver TaskRecoveryResolver + Store TaskAdoptionStore + type TaskAdoptionStore interface + type TaskBillingProof struct + ExpiresAt time.Time + Issuer string + ObservedAt time.Time + PricingRevision string + ProofDigest string + ProofRef string + Revision string + type TaskCallSealAuthorizer interface + AuthorizeTaskCallSeal func(context.Context, TaskCallSealRequest) error + type TaskCallSealFence interface + WithTaskCallSealFence func(context.Context, TaskCallSealRequest, func(TaskCallSealRequest) error) error + type TaskCallSealRequest struct + Claim ClaimToken + ClaimDigest string + SchemaVersion int + Seal execution.RunCallSealRequest + func (r TaskCallSealRequest) Freeze() (TaskCallSealRequest, string, error) + type TaskCallSealStore interface + SealTaskCalls func(context.Context, TaskCallSealRequest) (execution.RunCallSeal, error) + type TaskCallSealer interface + Seal func(context.Context, TaskCallSealRequest) (execution.RunCallSeal, error) + func NewTaskCallSealer(store TaskCallSealStore, fence TaskCallSealFence, ...) (TaskCallSealer, error) + type TaskClaimAdmitter interface + Admit func(context.Context, ReadyTaskClaimRequest) (ReadyTaskClaim, error) + func NewTaskClaimAdmitter(storage ReadyTaskClaimStore, fence TaskClaimFence, ...) (TaskClaimAdmitter, error) + type TaskClaimAuthorizer interface + AuthorizeTaskClaim func(context.Context, ReadyTaskClaimRequest) error + type TaskClaimFence interface + WithTaskClaimFence func(context.Context, ReadyTaskClaimRequest, func(ReadyTaskClaimRequest) error) error + type TaskClaimOutbox struct + ClaimID id.ID + EventID id.ID + PlanID id.ID + TaskID id.ID + Type string + type TaskClaimRenewer interface + Renew func(context.Context, TaskRenewalRequest) (TaskRenewal, error) + func NewTaskClaimRenewer(storage TaskRenewalStore, fence TaskRenewalFence, ...) (TaskClaimRenewer, error) + type TaskClaimResolver interface + ResolveTaskClaim func(context.Context, planning.Plan, id.ID) (ReadyTaskClaimRequest, error) + type TaskCompletion struct + Digest string + Fresh bool + ObservedAt time.Time + Request TaskCompletionRequest + RequestDigest string + Reservation execution.Reservation + SchemaVersion int + func SealTaskCompletion(c TaskCompletion) (TaskCompletion, error) + func (c TaskCompletion) Validate() error + type TaskCompletionAbandoner interface + Abandon func(context.Context, TaskCompletionAbandonmentRequest) (TaskCompletionSettlement, error) + type TaskCompletionAbandonmentAuthority interface + AuthorizeTaskCompletionAbandonment func(context.Context, TaskCompletionAbandonmentRequest) error + WithTaskCompletionAbandonmentFence func(context.Context, TaskCompletionAbandonmentRequest, ...) error + type TaskCompletionAbandonmentRequest struct + Actor string + Completion TaskCompletion + Proof PreparedRunAbandonment + Reason string + func (r TaskCompletionAbandonmentRequest) Freeze() (TaskCompletionAbandonmentRequest, string, error) + type TaskCompletionAbandonmentResolver interface + ResolveTaskCompletionAbandonment func(context.Context, TaskCompletion) (*TaskCompletionAbandonmentRequest, error) + type TaskCompletionAbandonmentStore interface + AbandonTaskCompletion func(context.Context, TaskCompletionAbandonmentRequest) (TaskCompletionSettlement, error) + type TaskCompletionAcceptance interface + Accept func(context.Context, TaskAcceptanceRequest) (TaskAcceptance, error) + type TaskCompletionAuthority interface + AuthorizeTaskCompletion func(context.Context, Assignment) error + WithTaskCompletionFence func(context.Context, Assignment, func(Assignment) error) error + type TaskCompletionCloser struct + func NewTaskCompletionCloser(store TaskCompletionAbandonmentStore, ...) (*TaskCompletionCloser, error) + func (c *TaskCompletionCloser) Abandon(ctx context.Context, request TaskCompletionAbandonmentRequest) (TaskCompletionSettlement, error) + type TaskCompletionListRequest struct + After string + Limit int + type TaskCompletionPage struct + Assignments []ScheduledTaskCompletion + Next string + type TaskCompletionRequest struct + AcceptanceID id.ID + Actor string + AdjudicationID id.ID + AssignmentDigest string + AssignmentID id.ID + AssignmentRevision int64 + BindingDigest string + Handoff Handoff + InputDigest string + PreparedDigest string + Reason string + Reservation execution.ReservationRequest + ReviewID id.ID + RunID id.AgentRunID + SchemaVersion int + SessionID id.SessionID + func (r TaskCompletionRequest) Freeze() (TaskCompletionRequest, string, error) + type TaskCompletionResolver interface + ResolveTaskAcceptance func(context.Context, TaskCompletion, TaskAdjudication) (*TaskAcceptanceRequest, error) + ResolveTaskCompletion func(context.Context, Assignment) (*TaskCompletionRequest, error) + ResolveTaskSubmission func(context.Context, Assignment) (*Submission, error) + type TaskCompletionReviewer interface + Execute func(context.Context, TaskCompletion) error + Observe func(context.Context, TaskCompletion) (*Review, error) + type TaskCompletionService struct + func NewTaskCompletionService(config TaskCompletionServiceConfig) (*TaskCompletionService, error) + func (s *TaskCompletionService) RequestStop() + func (s *TaskCompletionService) Start(ctx context.Context) error + func (s *TaskCompletionService) Status() TaskServiceStatus + func (s *TaskCompletionService) Stop(ctx context.Context) error + type TaskCompletionServiceConfig struct + Abandoner TaskCompletionAbandoner + Acceptor TaskCompletionAcceptance + AttemptTimeout time.Duration + Authority TaskCompletionAuthority + Discovery TaskCompletionSource + DiscoveryTimeout time.Duration + Interval time.Duration + MaxInFlight int + MaxPerScope int + ReportError func(error) + Resolver TaskCompletionResolver + Reviewer TaskCompletionReviewer + Store TaskCompletionServiceStore + type TaskCompletionServiceStore interface + GetPlan func(context.Context, id.ID) (planning.Plan, error) + GetTaskAcceptance func(context.Context, id.ID) (TaskAcceptance, error) + type TaskCompletionSettlement struct + Abandonment *TaskCompletionAbandonmentRequest + AssignmentID id.ID + CompletionDigest string + Digest string + ObservedAt time.Time + RunDigest string + RunID id.AgentRunID + RunRevision int64 + SchemaVersion int + Settlement execution.SettlementReceipt + func SealTaskCompletionSettlement(s TaskCompletionSettlement) (TaskCompletionSettlement, error) + func (s TaskCompletionSettlement) Validate() error + type TaskCompletionSettlementStore interface + GetTaskCompletionSettlement func(context.Context, id.ID) (*TaskCompletionSettlement, error) + SettleTaskCompletion func(context.Context, id.ID, string) (*TaskCompletionSettlement, error) + type TaskCompletionSource interface + ListTaskCompletionAssignments func(context.Context, TaskCompletionListRequest) (TaskCompletionPage, error) + type TaskCompletionStore interface + GetTaskCompletion func(context.Context, id.ID) (*TaskCompletion, error) + ReserveTaskCompletion func(context.Context, TaskCompletionRequest) (TaskCompletion, error) + type TaskDispatch struct + Assignment Assignment + Claim Claim + Fresh bool + Outbox TaskDispatchOutbox + RequestDigest string + func (r TaskDispatch) Validate(request TaskDispatchRequest) error + type TaskDispatchAdmitter interface + Admit func(context.Context, TaskDispatchRequest) (TaskDispatch, error) + func NewTaskDispatchAdmitter(storage TaskDispatchStore, fence TaskDispatchFence, ...) (TaskDispatchAdmitter, error) + type TaskDispatchAuthorizer interface + AuthorizeTaskDispatch func(context.Context, TaskDispatchRequest) error + type TaskDispatchFence interface + WithTaskDispatchFence func(context.Context, TaskDispatchRequest, func(TaskDispatchRequest) error) error + type TaskDispatchOutbox struct + AssignmentID id.ID + ClaimID id.ID + EventID id.ID + PlanID id.ID + RunID id.AgentRunID + TaskID id.ID + Type string + type TaskDispatchRequest struct + Actor string + AdmissionDigest string + AssignmentDigest string + AssignmentID id.ID + AssignmentRevision int64 + Claim ClaimToken + ClaimDigest string + Dependencies []AcceptedDependency + ParentRunRevision int64 + Reason string + RunID id.AgentRunID + SchemaVersion int + Scope cortex.Scope + func (r TaskDispatchRequest) Freeze() (TaskDispatchRequest, string, error) + type TaskDispatchStore interface + DispatchReadyTask func(context.Context, TaskDispatchRequest) (TaskDispatch, error) + GetTaskDispatch func(context.Context, id.ID) (TaskDispatch, error) + type TaskPlanListRequest struct + After string + Limit int + type TaskPlanPage struct + Next string + Plans []ScheduledPlan + type TaskPlanSource interface + ListScheduledPlans func(context.Context, TaskPlanListRequest) (TaskPlanPage, error) + type TaskRecoveryAdopter interface + Adopt func(context.Context, TaskAcceptanceRequest) (TaskAcceptance, error) + func NewTaskRecoveryAdopter(storage TaskRecoveryStore, fence TaskRecoveryFence, ...) (TaskRecoveryAdopter, error) + type TaskRecoveryAuthorizer interface + AuthorizeTaskRecovery func(context.Context, TaskAcceptanceRequest) error + type TaskRecoveryFence interface + WithTaskRecoveryFence func(context.Context, TaskAcceptanceRequest, func(TaskAcceptanceRequest) error) error + type TaskRecoveryProof struct + ClaimDigest string + ExpiresAt time.Time + Issuer string + ObservedAt time.Time + ProofDigest string + ProofRef string + Revision string + SchemaVersion int + Seal execution.RunCallSeal + SnapshotDigest string + func (p TaskRecoveryProof) Freeze() (TaskRecoveryProof, string, error) + type TaskRecoveryResolver interface + ResolveTaskRecovery func(context.Context, Claim, execution.RunRecoverySnapshot) (*TaskAcceptanceRequest, error) + type TaskRecoveryStore interface + AdoptTaskResult func(context.Context, TaskAcceptanceRequest) (TaskAcceptance, error) + type TaskRenewal struct + Claim Claim + Fresh bool + Outbox TaskRenewalOutbox + RequestDigest string + func (r TaskRenewal) Validate(request TaskRenewalRequest) error + type TaskRenewalAuthorizer interface + AuthorizeTaskRenewal func(context.Context, TaskRenewalRequest) error + type TaskRenewalConfig struct + Duration time.Duration + Interval time.Duration + Renewer TaskClaimRenewer + Source TaskRenewalSource + type TaskRenewalFence interface + WithTaskRenewalFence func(context.Context, TaskRenewalRequest, func(TaskRenewalRequest) error) error + type TaskRenewalOutbox struct + ClaimID id.ID + EventID id.ID + PlanID id.ID + RunID id.AgentRunID + TaskID id.ID + Type string + type TaskRenewalRequest struct + Actor string + AssignmentDigest string + AssignmentID id.ID + AssignmentRevision int64 + Claim Claim + Dependencies []AcceptedDependency + Duration time.Duration + ParentRunID id.AgentRunID + ParentRunRevision int64 + Reason string + RunRevision int64 + SchemaVersion int + func (r TaskRenewalRequest) Freeze() (TaskRenewalRequest, string, error) + type TaskRenewalSource interface + ResolveTaskRenewal func(context.Context, Claim, time.Duration) (TaskRenewalRequest, error) + type TaskRenewalStart func(Claim) error + type TaskRenewalStore interface + RenewTaskExecution func(context.Context, TaskRenewalRequest) (TaskRenewal, error) + type TaskRetirement struct + Claim Claim + Digest string + Fresh bool + Request TaskRetirementRequest + RequestDigest string + SchemaVersion int + func SealTaskRetirement(r TaskRetirement) (TaskRetirement, error) + func (r TaskRetirement) Validate() error + type TaskRetirementAuthorizer interface + AuthorizeTaskRetirement func(context.Context, TaskRetirementRequest) error + type TaskRetirementFence interface + WithTaskRetirementFence func(context.Context, TaskRetirementRequest, func(TaskRetirementRequest) error) error + type TaskRetirementRequest struct + Actor string + Claim ClaimToken + ClosureDigest string + Reason string + Recovery TaskRecoveryProof + SchemaVersion int + SettlementDigest string + func (r TaskRetirementRequest) Freeze() (TaskRetirementRequest, string, error) + type TaskRetirementResolver interface + ResolveTaskRetirement func(context.Context, Claim, execution.RunRecoverySnapshot, TaskUsageClosure, ...) (*TaskRetirementRequest, error) + type TaskRetirementService struct + func NewTaskRetirementService(config TaskRetirementServiceConfig) (*TaskRetirementService, error) + func (s *TaskRetirementService) RequestStop() + func (s *TaskRetirementService) Start(ctx context.Context) error + func (s *TaskRetirementService) Status() TaskServiceStatus + func (s *TaskRetirementService) Stop(ctx context.Context) error + type TaskRetirementServiceConfig struct + AttemptTimeout time.Duration + AuthorizeScan func(context.Context, Claim, execution.RunCallSeal) error + Authorizer TaskRetirementAuthorizer + Discovery TaskPlanSource + DiscoveryTimeout time.Duration + Fence TaskRetirementFence + Interval time.Duration + MaxInFlight int + MaxPerScope int + PageSize int + PageTimeout time.Duration + ReportError func(error) + Resolver TaskRetirementResolver + Store TaskRetirementServiceStore + type TaskRetirementServiceStore interface + type TaskRetirementStore interface + GetTaskRetirement func(context.Context, id.ID) (*TaskRetirement, error) + RetireTaskClaim func(context.Context, TaskRetirementRequest) (TaskRetirement, error) + type TaskRetirer interface + Retire func(context.Context, TaskRetirementRequest) (TaskRetirement, error) + func NewTaskRetirer(store TaskRetirementStore, fence TaskRetirementFence, ...) (TaskRetirer, error) + type TaskRunAdmitter interface + Admit func(context.Context, TaskRunRequest) (TaskRunStart, error) + func NewTaskRunAdmitter(storage TaskRunStore, fence TaskRunFence, authorizer TaskRunAuthorizer) (TaskRunAdmitter, error) + type TaskRunAuthorizer interface + AuthorizeTaskRun func(context.Context, TaskRunRequest) error + type TaskRunFence interface + WithTaskRunFence func(context.Context, TaskRunRequest, func(TaskRunRequest) error) error + type TaskRunOutbox struct + ClaimID id.ID + EventID id.ID + IntentID id.ID + PlanID id.ID + RunID id.AgentRunID + TaskID id.ID + Type string + type TaskRunRequest struct + Actor string + AssignmentDigest string + AssignmentRevision int64 + Claim ClaimToken + Dependencies []AcceptedDependency + DispatchDigest string + Intent verification.CaptureIntent + ParentRunRevision int64 + Reason string + Run run.Run + SchemaVersion int + func (r TaskRunRequest) Freeze() (TaskRunRequest, string, error) + func (r TaskRunRequest) InitialRun(at time.Time) (run.Run, error) + type TaskRunStart struct + CreatedAt time.Time + Fresh bool + IntentDigest string + IntentID id.ID + Outbox TaskRunOutbox + RequestDigest string + RunDigest string + RunID id.AgentRunID + func (r TaskRunStart) Validate(request TaskRunRequest) error + type TaskRunStore interface + CreateTaskRun func(context.Context, TaskRunRequest) (TaskRunStart, error) + GetTaskRunStart func(context.Context, id.ID) (TaskRunStart, error) + type TaskScheduler struct + func NewScheduler(config SchedulerConfig) (*TaskScheduler, error) + func (s *TaskScheduler) Shutdown(ctx context.Context) error + func (s *TaskScheduler) Status() SchedulerStatus + func (s *TaskScheduler) Tick(ctx context.Context, planID id.ID) error + type TaskService struct + func NewTaskService(config TaskServiceConfig) (*TaskService, error) + func (s *TaskService) RequestStop() + func (s *TaskService) Start(ctx context.Context) error + func (s *TaskService) Status() TaskServiceStatus + func (s *TaskService) Stop(ctx context.Context) error + type TaskServiceConfig struct + Discovery TaskPlanSource + DiscoveryTimeout time.Duration + Interval time.Duration + MaxInFlight int + ReportError func(error) + Scheduler SchedulerConfig + type TaskServiceStatus struct + Active int + Failures uint64 + Running bool + Stopping bool + type TaskSettlementRunReader interface + GetRun func(context.Context, id.AgentRunID) (*run.Run, error) + type TaskSettlementService struct + func NewTaskSettlementService(config TaskSettlementServiceConfig) (*TaskSettlementService, error) + func (s *TaskSettlementService) RequestStop() + func (s *TaskSettlementService) Start(ctx context.Context) error + func (s *TaskSettlementService) Status() TaskServiceStatus + func (s *TaskSettlementService) Stop(ctx context.Context) error + type TaskSettlementServiceConfig struct + AttemptTimeout time.Duration + AuthorizeScan func(context.Context, Claim, execution.RunCallSeal) error + Authorizer TaskUsageSettlementAuthorizer + CallSealAuthorizer TaskCallSealAuthorizer + CallSealFence TaskCallSealFence + ClosureActor string + ClosureAuthorizer TaskUsageClosureAuthorizer + ClosureFence TaskUsageClosureFence + Discovery TaskPlanSource + DiscoveryTimeout time.Duration + Fence TaskUsageSettlementFence + Interval time.Duration + MaxInFlight int + MaxPerScope int + PageSize int + PageTimeout time.Duration + ReportError func(error) + Resolver TaskUsageSettlementResolver + Store TaskSettlementStore + UnsuccessfulRuns TaskSettlementRunReader + type TaskSettlementStore interface + GetBudgetedTaskClaim func(context.Context, id.ID) (BudgetedClaim, error) + type TaskUsageCloser interface + Close func(context.Context, TaskUsageClosureRequest) (TaskUsageClosure, error) + func NewTaskUsageCloser(store TaskUsageClosureStore, fence TaskUsageClosureFence, ...) (TaskUsageCloser, error) + type TaskUsageClosure struct + At time.Time + Digest string + Fresh bool + Request TaskUsageClosureRequest + RequestDigest string + SchemaVersion int + func SealTaskUsageClosure(c TaskUsageClosure) (TaskUsageClosure, error) + func (c TaskUsageClosure) Validate() error + type TaskUsageClosureAuthorizer interface + AuthorizeTaskUsageClosure func(context.Context, TaskUsageClosureRequest) error + type TaskUsageClosureFence interface + WithTaskUsageClosureFence func(context.Context, TaskUsageClosureRequest, func(TaskUsageClosureRequest) error) error + type TaskUsageClosureRequest struct + Actor string + Reason string + Rejection *TaskUsageRejection + SchemaVersion int + Termination *TaskUsageTermination + Usage TaskUsageRequest + UsageDigest string + func (r TaskUsageClosureRequest) Freeze() (TaskUsageClosureRequest, string, error) + func (r TaskUsageClosureRequest) MatchesClaim(c Claim) bool + type TaskUsageClosureStore interface + CloseTaskUsage func(context.Context, TaskUsageClosureRequest) (TaskUsageClosure, error) + GetTaskUsageClosure func(context.Context, id.AgentRunID) (*TaskUsageClosure, error) + type TaskUsageRejection struct + CompletedAt time.Time + ResultRef string + RunRevision int64 + VerificationStatus verification.Status + type TaskUsageRequest struct + Claim ClaimToken + Seal execution.RunCallSeal + SnapshotDigest string + func (r TaskUsageRequest) Freeze() (TaskUsageRequest, error) + type TaskUsageSettlement struct + Digest string + Fresh bool + Request TaskUsageSettlementRequest + RequestDigest string + SchemaVersion int + Settlement execution.SettlementReceipt + func SealTaskUsageSettlement(s TaskUsageSettlement) (TaskUsageSettlement, error) + func (s TaskUsageSettlement) Validate() error + type TaskUsageSettlementAuthorizer interface + AuthorizeTaskUsageSettlement func(context.Context, TaskUsageSettlementRequest) error + type TaskUsageSettlementFence interface + WithTaskUsageSettlementFence func(context.Context, TaskUsageSettlementRequest, ...) error + type TaskUsageSettlementRequest struct + Actor string + Billing TaskBillingProof + ClosureDigest string + Reason string + ReservationDigest string + ReservationID id.ID + SchemaVersion int + Usage TaskUsageRequest + UsageDigest string + func (r TaskUsageSettlementRequest) Freeze() (TaskUsageSettlementRequest, string, error) + type TaskUsageSettlementResolver interface + ResolveTaskUsageSettlement func(context.Context, TaskUsageSnapshot, TaskUsageClosure, execution.Reservation) (*TaskUsageSettlementRequest, error) + type TaskUsageSettlementStore interface + GetTaskUsageSettlement func(context.Context, id.AgentRunID) (*TaskUsageSettlement, error) + SettleTaskUsage func(context.Context, TaskUsageSettlementRequest) (TaskUsageSettlement, error) + type TaskUsageSettler interface + Settle func(context.Context, TaskUsageSettlementRequest) (TaskUsageSettlement, error) + func NewTaskUsageSettler(store TaskUsageSettlementStore, fence TaskUsageSettlementFence, ...) (TaskUsageSettler, error) + type TaskUsageSnapshot struct + Claim Claim + Digest string + Jobs []verification.Job + Journal execution.RunRecoverySnapshot + SchemaVersion int + func SealTaskUsageSnapshot(s TaskUsageSnapshot) (TaskUsageSnapshot, error) + func (s TaskUsageSnapshot) Validate() error + type TaskUsageSnapshotStore interface + SnapshotTaskUsage func(context.Context, TaskUsageRequest) (TaskUsageSnapshot, error) + type TaskUsageSummary struct + Known execution.KnownResources + Observed execution.Resources + OpenJobs int + Overflow execution.KnownResources + ProviderCalls int + VerifierCalls int + func SummarizeTaskUsage(s TaskUsageSnapshot) (TaskUsageSummary, error) + type TaskUsageTermination struct + CompletedAt time.Time + RunRevision int64 + State run.State + type VerificationJobDiscoveryStore interface + ListVerificationJobs func(context.Context, verification.JobListRequest) ([]verification.Job, error) + type VerificationJobListRequest struct + After string + Limit int + type VerificationJobPage struct + Jobs []ScheduledVerificationJob + Next string + type VerificationJobRecoverer interface + Recover func(context.Context, id.ID) error + type VerificationJobSource interface + ListCapturedVerificationJobs func(context.Context, VerificationJobListRequest) (VerificationJobPage, error) + type VerificationRecoveryConfig struct + AttemptTimeout time.Duration + Discovery VerificationJobSource + DiscoveryTimeout time.Duration + Interval time.Duration + MaxInFlight int + MaxPerScope int + Recoverer VerificationJobRecoverer + ReportError func(error) + type VerificationRecoveryService struct + func NewVerificationRecoveryService(config VerificationRecoveryConfig) (*VerificationRecoveryService, error) + func (s *VerificationRecoveryService) RequestStop() + func (s *VerificationRecoveryService) Start(ctx context.Context) error + func (s *VerificationRecoveryService) Status() TaskServiceStatus + func (s *VerificationRecoveryService) Stop(ctx context.Context) error
Go to main page