task

package

Go to main page

Versions in this module

v0

v0.0.7

Jun 4, 2026

Changes in this version

type SchedulerBacklogQuery

+ Scope Scope

+ func (q SchedulerBacklogQuery) Validate(path string) error

v0.0.6

Jun 3, 2026

Changes in this version

+ const RuntimeModeDefault

+ const RuntimeModeEvidence

+ const TaskFieldAutoEnqueueOnReady

type CreateTask

+ AutoEnqueueOnReady bool

type ExecutionProfile

+ Runtime RuntimePolicy

type Patch

+ AutoEnqueueOnReady *bool

+ type RuntimeMode string

+ func (m RuntimeMode) Normalize() RuntimeMode

+ type RuntimePolicy struct

+ Mode RuntimeMode

type Summary

+ AutoEnqueueOnReady bool

type Task

+ AutoEnqueueOnReady bool

v0.0.5

May 29, 2026

Changes in this version

+ const DefaultTaskStarvationAge

type Manager

+ RecoverRun func(ctx context.Context, runID string, req RecoverRunRequest, actor ActorContext) (*RetryRunResult, error)

type Option

+ func WithStarvationAge(age time.Duration) Option

+ type RecoverRunMutation struct

+ Metadata json.RawMessage

+ NewRunID string

+ Origin Origin

+ QueuedAt time.Time

+ Reason string

+ SourceRunID string

+ type RecoverRunRequest struct

+ Metadata json.RawMessage

+ Reason string

+ type RunStarvation struct

+ EscalationTier int

+ FirstStarvedAt time.Time

+ LastWakeAt time.Time

+ RunID string

+ SpawnRequestedAt *time.Time

+ StarvedEventAt *time.Time

+ UpdatedAt time.Time

+ WakeCount int

+ type RunStarvationMutation struct

+ EscalationTier int

+ FirstStarvedAt time.Time

+ LastWakeAt time.Time

+ RunID string

+ SpawnRequestedAt *time.Time

+ StarvedEventAt *time.Time

+ UpdatedAt time.Time

+ WakeCount int

type RunStatus

+ const TaskRunStatusNeedsAttention

type RunStore

+ MarkTaskRunNeedsAttention func(ctx context.Context, runID string, diagnostic string) (Run, error)

+ RecoverTaskRun func(ctx context.Context, mutation RecoverRunMutation) (RetryRunResult, error)

type SchedulerStatus

+ NeedsAttentionRunCount int

+ StarvedRunCount int

type Service

+ func (m *Service) MarkRunNeedsAttention(ctx context.Context, runID string, diagnostic string, actor ActorContext) (Run, error)

+ func (m *Service) RecordRunStarved(ctx context.Context, runID string, queuedAt time.Time, age time.Duration, ...) error

+ func (m *Service) RecoverRun(ctx context.Context, runID string, req RecoverRunRequest, actor ActorContext) (*RetryRunResult, error)

v0.0.4

May 27, 2026

v0.0.3

May 27, 2026

v0.0.2

May 27, 2026

v0.0.1

May 26, 2026

retracted

Changes in this version

+ const CoordinatorModeGuided

+ const CoordinatorModeInherit

+ const DefaultForceRunRateLimitPerMinute

+ const DefaultRunLeaseDuration

+ const DefaultTaskMaxAttempts

+ const FailureKindOperatorForced

+ const MaxDependencyCount

+ const MaxDirectChildren

+ const MaxForceRunBulkIDs

+ const MaxHierarchyDepth

+ const MaxMetadataBytes

+ const MaxPayloadBytes

+ const MaxResultBytes

+ const MaxRetryRunChainDepth

+ const MaxRunLeaseDuration

+ const MaxTaskMaxAttempts

+ const SandboxModeInherit

+ const SandboxModeNone

+ const SandboxModeRef

+ const TaskFieldApprovalPolicy

+ const TaskFieldCreatedBy

+ const TaskFieldDescription

+ const TaskFieldMaxAttempts

+ const TaskFieldMetadata

+ const TaskFieldNetworkChannel

+ const TaskFieldOrigin

+ const TaskFieldOwner

+ const TaskFieldParentTaskID

+ const TaskFieldPriority

+ const TaskFieldScope

+ const TaskFieldTitle

+ const TaskFieldWorkspaceID

+ const WorkerModeInherit

+ const WorkerModeSelect

+ var ErrActiveRunLease = errors.New("task: active run lease exists")

+ var ErrBulkTooLarge = errors.New("task: bulk operation too large")

+ var ErrConflict = errors.New("task: conflict")

+ var ErrCycleDetected = errors.New("task: dependency cycle detected")

+ var ErrExecutionProfileNotFound = errors.New("task: task execution profile not found")

+ var ErrForbiddenOperatorAction = errors.New("task: forbidden operator action")

+ var ErrForceOpRateLimited = errors.New("task: force operation rate limited")

+ var ErrForceOpRequiresReason = errors.New("task: force operation requires reason")

+ var ErrGraphLimitExceeded = errors.New("task: graph limit exceeded")

+ var ErrImmutableField = errors.New("task: immutable field")

+ var ErrInvalidClaimToken = errors.New("task: invalid claim token")

+ var ErrInvalidScopeBinding = errors.New("task: invalid scope binding")

+ var ErrInvalidStatusTransition = errors.New("task: invalid status transition")

+ var ErrLeaseExpired = errors.New("task: lease expired")

+ var ErrNoClaimableRun = errors.New("task: no claimable run")

+ var ErrPayloadTooLarge = errors.New("task: payload too large")

+ var ErrPermissionDenied = errors.New("task: permission denied")

+ var ErrRetryChainTooDeep = errors.New("task: retry chain too deep")

+ var ErrRunReviewNotFound = errors.New("task: task run review not found")

+ var ErrSessionAlreadyBound = errors.New("task: session already bound")

+ var ErrSessionAttachNotAllowed = errors.New("task: session attach not allowed")

+ var ErrStaleNetworkChannel = errors.New("task: stale network channel")

+ var ErrTaskDependencyNotFound = errors.New("task: task dependency not found")

+ var ErrTaskEventNotFound = errors.New("task: task event not found")

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

+ var ErrTaskRunIdempotencyNotFound = errors.New("task: task run idempotency not found")

+ var ErrTaskRunNotFound = errors.New("task: task run not found")

+ var ErrTaskTriageStateNotFound = errors.New("task: task triage state not found")

+ var ErrValidation = errors.New("task: validation failed")

+ func ClaimTokenHash(rawToken string) (string, error)

+ func DefaultSchedulerDrainTimeout() time.Duration

+ func ImmutableTaskFields() []string

+ func IsImmutableTaskField(field string) bool

+ func IsMutableTaskField(field string) bool

+ func IsTerminalRunStatus(status RunStatus) bool

+ func MutableTaskFields() []string

+ func NewClaimToken() (string, error)

+ func RedactClaimTokens(value string) string

+ func ValidateApprovalSemantics(policy ApprovalPolicy, state ApprovalState, path string) error

+ func ValidateCapabilityIDs(values []string, path string) error

+ func ValidateDependencyCount(count int) error

+ func ValidateDirectChildCount(count int) error

+ func ValidateHierarchyDepth(depth int) error

+ func ValidateImmutableTaskFields(current Task, next Task) error

+ func ValidateMetadataSize(payload json.RawMessage, path string) error

+ func ValidatePayloadSize(payload json.RawMessage, path string) error

+ func ValidateResultSize(payload json.RawMessage, path string) error

+ func ValidateScopeBinding(scope Scope, workspaceBinding string, path string, workspaceField string) error

+ func VerifyClaimToken(rawToken string, persistedHash string) bool

+ type ActorContext struct

+ Actor ActorIdentity

+ Authority Authority

+ Origin Origin

+ func DeriveAgentSessionActorContext(sessionRef string) (ActorContext, error)

+ func DeriveAgentSessionActorContextForOrigin(sessionRef string, originKind OriginKind, originRef string) (ActorContext, error)

+ func DeriveAutomationActorContext(actorRef string, originRef string) (ActorContext, error)

+ func DeriveAutomationLinkedAgentSessionActorContext(sessionRef string, originRef string) (ActorContext, error)

+ func DeriveDaemonActorContext(actorRef string, originRef string) (ActorContext, error)

+ func DeriveExtensionActorContext(actorRef string, originRef string) (ActorContext, error)

+ func DeriveHumanActorContext(actorRef string, originKind OriginKind, originRef string) (ActorContext, error)

+ func DeriveNetworkPeerActorContext(actorRef string, originRef string) (ActorContext, error)

+ func (a ActorContext) Validate() error

+ type ActorIdentity struct

+ Kind ActorKind

+ Ref string

+ func (a ActorIdentity) Validate(path string) error

+ type ActorKind string

+ const ActorKindAgentSession

+ const ActorKindAutomation

+ const ActorKindDaemon

+ const ActorKindExtension

+ const ActorKindHuman

+ const ActorKindNetworkPeer

+ func (k ActorKind) Normalize() ActorKind

+ func (k ActorKind) Validate(path string) error

+ type AddDependency struct

+ DependsOnTaskID string

+ Kind DependencyKind

+ TaskID string

+ func (r AddDependency) Validate(path string) error

+ type ApprovalPolicy string

+ const ApprovalPolicyManual

+ const ApprovalPolicyNone

+ const DefaultApprovalPolicy

+ func (p ApprovalPolicy) Normalize() ApprovalPolicy

+ func (p ApprovalPolicy) Validate(path string) error

+ type ApprovalState string

+ const ApprovalStateApproved

+ const ApprovalStateNotRequired

+ const ApprovalStatePending

+ const ApprovalStateRejected

+ func (s ApprovalState) Normalize() ApprovalState

+ func (s ApprovalState) Validate(path string) error

+ type Authority struct

+ CreateGlobal bool

+ CreateWorkspace bool

+ Read bool

+ Write bool

+ func FullAccessAuthority() Authority

+ func (a Authority) Validate(path string) error

+ type AutonomyError struct

+ Err error

+ Reason AutonomyReasonCode

+ func (e *AutonomyError) Error() string

+ func (e *AutonomyError) Unwrap() error

+ type AutonomyLeaseAuthority interface

+ LookupActiveRunForSession func(ctx context.Context, sessionID string, runID string) (AutonomyLeaseHandle, error)

+ type AutonomyLeaseHandle struct

+ ClaimToken string

+ ClaimTokenHash string

+ ClaimedBy *ActorIdentity

+ HeartbeatAt time.Time

+ LeaseUntil time.Time

+ RunID string

+ SessionID string

+ Status RunStatus

+ TaskID string

+ WorkspaceID string

+ type AutonomyLeaseStore interface

+ ListAutonomyLeaseHandles func(ctx context.Context, sessionID string) ([]AutonomyLeaseHandle, error)

+ type AutonomyReasonCode string

+ const AutonomyForeignRun

+ const AutonomyLeaseAlreadyHeld

+ const AutonomyLeaseExpired

+ const AutonomyNoActiveLease

+ const AutonomySessionRequired

+ func AutonomyReasonOf(err error) (AutonomyReasonCode, bool)

+ type BindRunReviewSessionRequest struct

+ ReviewID string

+ ReviewerAgentName string

+ ReviewerChannelID string

+ ReviewerPeerID string

+ SessionID string

+ func (r BindRunReviewSessionRequest) Normalize() BindRunReviewSessionRequest

+ func (r BindRunReviewSessionRequest) Validate(path string) error

+ type BulkForceRunItem struct

+ Err error

+ OK bool

+ Run *Run

+ RunID string

+ type BulkForceRunRequest struct

+ Metadata json.RawMessage

+ Reason string

+ RunIDs []string

+ type BulkForceRunResult struct

+ Items []BulkForceRunItem

+ type CancelRun struct

+ Metadata json.RawMessage

+ Reason string

+ func (r CancelRun) Validate(path string) error

+ type CancelTask struct

+ Metadata json.RawMessage

+ Reason string

+ func (r CancelTask) Validate(path string) error

+ type ClaimCriteria struct

+ AgentName string

+ ClaimedBy *ActorIdentity

+ ClaimerSessionID string

+ CoordinationChannelID string

+ LeaseDuration time.Duration

+ Now time.Time

+ PriorityMin int

+ RequiredCapabilities []string

+ Scope Scope

+ Soul *SoulClaimProvenance

+ WorkspaceID string

+ func (c ClaimCriteria) Normalize(defaultNow time.Time) (ClaimCriteria, error)

+ func (c ClaimCriteria) Validate(path string) error

+ type ClaimResult struct

+ ClaimToken string

+ CoordinationChannel *CoordinationChannelMetadata

+ LeaseUntil time.Time

+ Run Run

+ Task Task

+ type ClaimRun struct

+ IdempotencyKey string

+ func (r ClaimRun) Validate(path string) error

+ type ContextBundle struct

+ CurrentRun *RunSummary

+ ExecutionProfile *ExecutionProfile

+ HandoffSummary string

+ LatestEventSeq int64

+ Limits RuntimeLimits

+ PriorAttempts []RunSummary

+ RecentEvents []TimelineItem

+ ReviewContinuation *ReviewContinuation

+ ReviewHistory []RunReviewSummary

+ Task Reference

+ func NormalizeContextBundle(bundle ContextBundle) ContextBundle

+ type ContextRequest struct

+ Now time.Time

+ RunID string

+ SessionID string

+ type CoordinationChannelMetadata struct

+ AllowedMessageKinds []string

+ Channel string

+ DisplayName string

+ ID string

+ LastActivityAt time.Time

+ Purpose string

+ RunID string

+ TaskID string

+ WorkflowID string

+ WorkspaceID string

+ type CoordinatorMode string

+ func (m CoordinatorMode) Normalize() CoordinatorMode

+ type CoordinatorProfile struct

+ AgentName string

+ Guidance string

+ Mode CoordinatorMode

+ Model string

+ Provider string

+ type CreateTask struct

+ ApprovalPolicy ApprovalPolicy

+ Description string

+ Draft bool

+ ID string

+ Identifier string

+ MaxAttempts *int

+ Metadata json.RawMessage

+ NetworkChannel string

+ Owner *Ownership

+ ParentTaskID string

+ Priority Priority

+ Scope Scope

+ Title string

+ WorkspaceID string

+ func (r CreateTask) Validate(path string) error

+ type DeleteTaskMutationStore interface

+ CountDirectChildren func(ctx context.Context, parentTaskID string) (int, error)

+ DeleteTask func(ctx context.Context, id string) error

+ GetTask func(ctx context.Context, id string) (Task, error)

+ ListDependencies func(ctx context.Context, taskID string) ([]Dependency, error)

+ ListDependents func(ctx context.Context, dependsOnTaskID string) ([]Dependency, error)

+ ListTaskRuns func(ctx context.Context, query RunQuery) ([]Run, error)

+ UpdateTask func(ctx context.Context, task Task) error

+ type DeleteTaskTransactionStore interface

+ WithDeleteTaskTransaction func(ctx context.Context, fn func(DeleteTaskMutationStore) error) error

+ type Dependency struct

+ CreatedAt time.Time

+ DependsOnTaskID string

+ Kind DependencyKind

+ TaskID string

+ func (d Dependency) Validate() error

+ type DependencyKind string

+ const DependencyKindBlocks

+ func (k DependencyKind) Normalize() DependencyKind

+ func (k DependencyKind) Validate(path string) error

+ type DependencyReference struct

+ CreatedAt time.Time

+ DependsOn Reference

+ DependsOnTaskID string

+ Kind DependencyKind

+ TaskID string

+ type DependencyStore interface

+ CountDependencies func(ctx context.Context, taskID string) (int, error)

+ CreateDependency func(ctx context.Context, dependency Dependency) error

+ DeleteDependency func(ctx context.Context, taskID string, dependsOnID string) error

+ HasDependencyPath func(ctx context.Context, fromTaskID string, toTaskID string) (bool, error)

+ ListDependencies func(ctx context.Context, taskID string) ([]Dependency, error)

+ ListDependents func(ctx context.Context, dependsOnTaskID string) ([]Dependency, error)

+ type EnqueueRun struct

+ IdempotencyKey string

+ Metadata json.RawMessage

+ NetworkChannel string

+ TaskID string

+ func (r EnqueueRun) Validate(path string) error

+ type Event struct

+ Actor ActorIdentity

+ EventType string

+ ID string

+ Origin Origin

+ Payload json.RawMessage

+ RunID string

+ TaskID string

+ Timestamp time.Time

+ func (e Event) Validate() error

+ type EventObserver interface

+ OnTaskEvent func(ctx context.Context, record EventRecord)

+ type EventQuery struct

+ EventType string

+ Limit int

+ RunID string

+ TaskID string

+ func (q EventQuery) Validate(path string) error

+ type EventRecord struct

+ Event Event

+ Sequence int64

+ type EventRecordQuery struct

+ AfterSequence int64

+ Descending bool

+ Limit int

+ TaskID string

+ func (q EventRecordQuery) Validate(path string) error

+ type EventSequenceStore interface

+ GetTaskEventRecord func(ctx context.Context, eventID string) (EventRecord, error)

+ ListTaskEventRecords func(ctx context.Context, query EventRecordQuery) ([]EventRecord, error)

+ type EventStore interface

+ CreateTaskEvent func(ctx context.Context, event Event) error

+ ListTaskEvents func(ctx context.Context, query EventQuery) ([]Event, error)

+ type Execution struct

+ Action ExecutionAction

+ ExistingRun bool

+ Run Run

+ Task Task

+ type ExecutionAction string

+ const ExecutionActionApproval

+ const ExecutionActionPublish

+ const ExecutionActionStart

+ type ExecutionProfile struct

+ Coordinator CoordinatorProfile

+ CreatedAt time.Time

+ Participants ParticipantPolicy

+ Review ReviewProfile

+ Sandbox SandboxPolicy

+ TaskID string

+ UpdatedAt time.Time

+ Worker WorkerProfile

+ func DefaultExecutionProfile(taskID string) ExecutionProfile

+ func (p *ExecutionProfile) Normalize(options ExecutionProfileValidationOptions) (ExecutionProfile, error)

+ func (p *ExecutionProfile) Validate(options ExecutionProfileValidationOptions) error

+ type ExecutionProfileStore interface

+ DeleteExecutionProfile func(ctx context.Context, taskID string) error

+ GetExecutionProfile func(ctx context.Context, taskID string) (ExecutionProfile, error)

+ UpsertExecutionProfile func(ctx context.Context, profile *ExecutionProfile) (ExecutionProfile, error)

+ type ExecutionProfileValidationOptions struct

+ AllowProviderOverride bool

+ AllowSandboxNone bool

+ AllowSandboxRef bool

+ MaxCoordinatorGuidanceBytes int

+ func DefaultExecutionProfileValidationOptions() ExecutionProfileValidationOptions

+ type ExecutionRequest struct

+ IdempotencyKey string

+ Metadata json.RawMessage

+ NetworkChannel string

+ func (r ExecutionRequest) Validate(path string) error

+ type ExpiredLeaseRecovery struct

+ Limit int

+ Now time.Time

+ Reason string

+ func (r ExpiredLeaseRecovery) Normalize(defaultNow time.Time) (ExpiredLeaseRecovery, error)

+ func (r ExpiredLeaseRecovery) Validate(path string) error

+ type ExpiredLeaseRecoveryResult struct

+ PreviousClaimTokenHash string

+ PreviousLeaseUntil time.Time

+ PreviousRunStatus RunStatus

+ PreviousSessionID string

+ Reason string

+ Run Run

+ type ForceFailRun struct

+ Metadata json.RawMessage

+ Reason string

+ type ForceFailRunMutation struct

+ Now time.Time

+ Reason string

+ RunID string

+ type ForceRecoveryOptions struct

+ AllowAgentForce bool

+ RateLimitPerMinute int

+ type ForceReleaseRun struct

+ Metadata json.RawMessage

+ Reason string

+ type ForceReleaseRunMutation struct

+ Now time.Time

+ RunID string

+ type ForceRunMutationResult struct

+ Previous Run

+ Run Run

+ type IdempotencyStore interface

+ GetTaskRunByIdempotencyKey func(ctx context.Context, key string, origin Origin) (Run, error)

+ SaveTaskRunIdempotency func(ctx context.Context, record RunIdempotency) error

+ type InspectEventSummary struct

+ ID string

+ Outcome string

+ RunID string

+ SessionID string

+ Summary string

+ TaskID string

+ Timestamp time.Time

+ Type string

+ type InspectNextAction string

+ const InspectNextActionClaimAvailable

+ const InspectNextActionRecoveryRequired

+ const InspectNextActionRunning

+ const InspectNextActionStranded

+ const InspectNextActionTerminal

+ const InspectNextActionWaitingForSession

+ type InspectRunSummary struct

+ Attempt int

+ BoundSessionID string

+ ClaimTokenHashTruncated string

+ EndedAt time.Time

+ FailureKind string

+ HeartbeatAgeSeconds *int64

+ HeartbeatAt time.Time

+ LastErrorSummary string

+ LeaseUntil time.Time

+ PreviousRunID string

+ QueuedAt time.Time

+ Retries int

+ RunID string

+ StartedAt time.Time

+ Status RunStatus

+ TaskID string

+ type InspectSchedulerState struct

+ Paused bool

+ PausedAt time.Time

+ PausedBy string

+ Reason string

+ UpdatedAt time.Time

+ type InspectSessionSummary struct

+ AgentName string

+ FailureKind string

+ LastActivityAt time.Time

+ ProviderName string

+ SessionID string

+ StartedAt time.Time

+ State string

+ StopReason string

+ WorkspaceID string

+ type InspectStateReader interface

+ GetSchedulerPauseState func(ctx context.Context) (InspectSchedulerState, error)

+ ListEventSummaries func(ctx context.Context, query store.EventSummaryQuery) ([]store.EventSummary, error)

+ ListSessions func(ctx context.Context, query store.SessionListQuery) ([]store.SessionInfo, error)

+ type InspectTarget string

+ const InspectTargetRun

+ const InspectTargetTask

+ type InspectView struct

+ AsOf time.Time

+ BoundSession *InspectSessionSummary

+ CurrentRun *InspectRunSummary

+ Diagnostics []diagnosticcontract.DiagnosticItem

+ EligibleSessionCount int

+ NextAction InspectNextAction

+ RecentEvents []InspectEventSummary

+ RecentRuns []InspectRunSummary

+ Scheduler InspectSchedulerState

+ SessionCatalogPresent bool

+ Target InspectTarget

+ Task Summary

+ type LeaseCompletion struct

+ ClaimToken string

+ Now time.Time

+ Result RunResult

+ RunID string

+ func (c LeaseCompletion) Normalize(defaultNow time.Time) (LeaseCompletion, error)

+ func (c LeaseCompletion) Validate(path string) error

+ type LeaseFailure struct

+ ClaimToken string

+ Failure RunFailure

+ Now time.Time

+ RunID string

+ func (f LeaseFailure) Normalize(defaultNow time.Time) (LeaseFailure, error)

+ func (f LeaseFailure) Validate(path string) error

+ type LeaseHeartbeat struct

+ ClaimToken string

+ LeaseDuration time.Duration

+ Now time.Time

+ RunID string

+ func (h LeaseHeartbeat) Normalize(defaultNow time.Time) (LeaseHeartbeat, error)

+ func (h LeaseHeartbeat) Validate(path string) error

+ type LeaseRelease struct

+ ClaimToken string

+ Now time.Time

+ Reason string

+ RunID string

+ func (r LeaseRelease) Normalize(defaultNow time.Time) (LeaseRelease, error)

+ func (r LeaseRelease) Validate(path string) error

+ type LiveService interface

+ RunDetail func(ctx context.Context, runID string, actor ActorContext) (*RunDetailView, error)

+ Stream func(ctx context.Context, taskID string, query StreamQuery, actor ActorContext) (<-chan StreamEvent, error)

+ Timeline func(ctx context.Context, taskID string, query TimelineQuery, actor ActorContext) ([]TimelineItem, error)

+ Tree func(ctx context.Context, taskID string, actor ActorContext) (*TreeView, error)

+ type Manager interface

+ AddDependency func(ctx context.Context, spec AddDependency, actor ActorContext) error

+ ApproveTask func(ctx context.Context, id string, req ExecutionRequest, actor ActorContext) (*Execution, error)

+ ArchiveTask func(ctx context.Context, id string, actor ActorContext) (TriageState, error)

+ AttachRunSession func(ctx context.Context, runID string, sessionID string, actor ActorContext) (*Run, error)

+ BindRunReviewSession func(ctx context.Context, req BindRunReviewSessionRequest, actor ActorContext) (RunReviewBinding, error)

+ BulkForceFailRuns func(ctx context.Context, req BulkForceRunRequest, actor ActorContext) (BulkForceRunResult, error)

+ BulkForceReleaseRuns func(ctx context.Context, req BulkForceRunRequest, actor ActorContext) (BulkForceRunResult, error)

+ CancelRun func(ctx context.Context, runID string, req CancelRun, actor ActorContext) (*Run, error)

+ CancelTask func(ctx context.Context, id string, req CancelTask, actor ActorContext) (*Task, error)

+ ClaimNextRun func(ctx context.Context, criteria ClaimCriteria, actor ActorContext) (*ClaimResult, error)

+ ClaimRun func(ctx context.Context, runID string, claim ClaimRun, actor ActorContext) (*Run, error)

+ CompleteRun func(ctx context.Context, runID string, result RunResult, actor ActorContext) (*Run, error)

+ CompleteRunLease func(ctx context.Context, completion LeaseCompletion, actor ActorContext) (*Run, error)

+ CreateChildTask func(ctx context.Context, parentTaskID string, spec CreateTask, actor ActorContext) (*Task, error)

+ CreateTask func(ctx context.Context, spec CreateTask, actor ActorContext) (*Task, error)

+ DeleteExecutionProfile func(ctx context.Context, taskID string, actor ActorContext) error

+ DeleteTask func(ctx context.Context, id string, actor ActorContext) error

+ DismissTask func(ctx context.Context, id string, actor ActorContext) (TriageState, error)

+ DrainScheduler func(ctx context.Context, req SchedulerDrainRequest, actor ActorContext) (SchedulerDrainResult, error)

+ EnqueueRun func(ctx context.Context, spec EnqueueRun, actor ActorContext) (*Run, error)

+ FailRun func(ctx context.Context, runID string, failure RunFailure, actor ActorContext) (*Run, error)

+ FailRunLease func(ctx context.Context, failure LeaseFailure, actor ActorContext) (*Run, error)

+ ForceFailRun func(ctx context.Context, runID string, failure ForceFailRun, actor ActorContext) (*Run, error)

+ ForceReleaseRun func(ctx context.Context, runID string, release ForceReleaseRun, actor ActorContext) (*Run, error)

+ GetExecutionProfile func(ctx context.Context, taskID string, actor ActorContext) (ExecutionProfile, error)

+ GetRunReview func(ctx context.Context, reviewID string, actor ActorContext) (RunReview, error)

+ GetTask func(ctx context.Context, id string, actor ActorContext) (*View, error)

+ HeartbeatRunLease func(ctx context.Context, heartbeat LeaseHeartbeat, actor ActorContext) (*Run, error)

+ InspectRun func(ctx context.Context, runID string, actor ActorContext) (*InspectView, error)

+ InspectTask func(ctx context.Context, taskID string, actor ActorContext) (*InspectView, error)

+ ListRunReviews func(ctx context.Context, query RunReviewQuery, actor ActorContext) ([]RunReview, error)

+ ListTaskRuns func(ctx context.Context, taskID string, query RunQuery, actor ActorContext) ([]Run, error)

+ ListTasks func(ctx context.Context, query Query, actor ActorContext) ([]Summary, error)

+ LookupRunReviewForSession func(ctx context.Context, sessionID string, actor ActorContext) (RunReviewBinding, error)

+ MarkTaskRead func(ctx context.Context, id string, actor ActorContext) (TriageState, error)

+ PauseScheduler func(ctx context.Context, req SchedulerPauseRequest, actor ActorContext) (SchedulerStatus, error)

+ PauseTask func(ctx context.Context, id string, req PauseTaskRequest, actor ActorContext) (*Task, error)

+ PublishTask func(ctx context.Context, id string, req ExecutionRequest, actor ActorContext) (*Execution, error)

+ RecordRunReview func(ctx context.Context, req RecordRunReviewRequest, actor ActorContext) (RunReviewResult, error)

+ RecoverExpiredRunLeases func(ctx context.Context, recovery ExpiredLeaseRecovery, actor ActorContext) ([]ExpiredLeaseRecoveryResult, error)

+ RejectTask func(ctx context.Context, id string, actor ActorContext) (*Task, error)

+ ReleaseRunLease func(ctx context.Context, release LeaseRelease, actor ActorContext) (*Run, error)

+ RemoveDependency func(ctx context.Context, taskID string, dependsOnID string, actor ActorContext) error

+ RequestRunReview func(ctx context.Context, req RunReviewRequest, actor ActorContext) (RunReview, bool, error)

+ ResumeScheduler func(ctx context.Context, req SchedulerResumeRequest, actor ActorContext) (SchedulerStatus, error)

+ ResumeTask func(ctx context.Context, id string, req ResumeTaskRequest, actor ActorContext) (*Task, error)

+ RetryRun func(ctx context.Context, runID string, retry RetryRunRequest, actor ActorContext) (*RetryRunResult, error)

+ SchedulerBacklog func(ctx context.Context, query SchedulerBacklogQuery, actor ActorContext) (SchedulerBacklog, error)

+ SchedulerStatus func(ctx context.Context, actor ActorContext) (SchedulerStatus, error)

+ SetExecutionProfile func(ctx context.Context, taskID string, profile *ExecutionProfile, ...) (ExecutionProfile, error)

+ StartRun func(ctx context.Context, runID string, req StartRun, actor ActorContext) (*Run, error)

+ StartTask func(ctx context.Context, id string, req ExecutionRequest, actor ActorContext) (*Execution, error)

+ UpdateTask func(ctx context.Context, id string, patch Patch, actor ActorContext) (*Task, error)

+ type OperatorTaskContextRequest struct

+ Now time.Time

+ TaskID string

+ type Option func(*managerOptions)

+ func WithCancelGracePeriod(timeout time.Duration) Option

+ func WithEventObserver(observer EventObserver) Option

+ func WithExecutionProfileValidationOptions(options ExecutionProfileValidationOptions) Option

+ func WithForceRecoveryOptions(options ForceRecoveryOptions) Option

+ func WithIDGenerator(newID func(prefix string) string) Option

+ func WithInspectStateReader(reader InspectStateReader) Option

+ func WithManagerNow(now func() time.Time) Option

+ func WithNetworkChannelValidator(validator func(string) error) Option

+ func WithRunReviewRequestedObserver(observer RunReviewRequestedObserver) Option

+ func WithRuntimeViewReader(reader RuntimeViewReader) Option

+ func WithSessionExecutor(sessions SessionExecutor) Option

+ func WithStore(store Store) Option

+ func WithTaskRunHooks(hooks RunHookDispatcher) Option

+ type Origin struct

+ Kind OriginKind

+ Ref string

+ func (o Origin) Validate(path string) error

+ type OriginKind string

+ const OriginKindAgentSession

+ const OriginKindAutomation

+ const OriginKindCLI

+ const OriginKindDaemon

+ const OriginKindExtension

+ const OriginKindHTTP

+ const OriginKindNetwork

+ const OriginKindUDS

+ const OriginKindWeb

+ func (k OriginKind) Normalize() OriginKind

+ func (k OriginKind) Validate(path string) error

+ type OwnerKind string

+ const OwnerKindAgentSession

+ const OwnerKindAutomation

+ const OwnerKindExtension

+ const OwnerKindHuman

+ const OwnerKindNetworkPeer

+ const OwnerKindPool

+ func (k OwnerKind) Normalize() OwnerKind

+ func (k OwnerKind) Validate(path string) error

+ type Ownership struct

+ Kind OwnerKind

+ Ref string

+ func (o Ownership) IsZero() bool

+ func (o Ownership) Validate(path string) error

+ type ParticipantPolicy struct

+ AllowedAgentNames []string

+ AllowedChannelIDs []string

+ AllowedPeerIDs []string

+ PreferredAgentNames []string

+ PreferredCapabilities []string

+ PreferredChannelIDs []string

+ PreferredPeerIDs []string

+ RequiredCapabilities []string

+ type Patch struct

+ ApprovalPolicy *ApprovalPolicy

+ ClearOwner bool

+ Description *string

+ MaxAttempts *int

+ Metadata *json.RawMessage

+ NetworkChannel *string

+ Owner *Ownership

+ Priority *Priority

+ Title *string

+ func (p Patch) Validate(path string) error

+ type PauseMutation struct

+ Actor string

+ PausedAt time.Time

+ Reason string

+ TaskID string

+ type PauseState struct

+ EffectivePaused bool

+ Paused bool

+ PausedAt time.Time

+ PausedBy string

+ PausedByTaskID string

+ PausedReason string

+ TaskID string

+ type PauseTaskRequest struct

+ Metadata json.RawMessage

+ Reason string

+ type Priority string

+ const DefaultPriority

+ const PriorityHigh

+ const PriorityLow

+ const PriorityMedium

+ const PriorityUrgent

+ func (p Priority) Normalize() Priority

+ func (p Priority) Validate(path string) error

+ type Query struct

+ ApprovalState ApprovalState

+ Limit int

+ NetworkChannel string

+ OwnerKind OwnerKind

+ OwnerRef string

+ ParentTaskID string

+ Priority Priority

+ Scope Scope

+ Search string

+ Status Status

+ WorkspaceID string

+ func (q Query) Validate(path string) error

+ type RecordRunReviewRequest struct

+ ReviewID string

+ RunID string

+ Verdict RunReviewVerdict

+ func (r RecordRunReviewRequest) Normalize() RecordRunReviewRequest

+ func (r RecordRunReviewRequest) Validate(path string) error

+ type RecordStore interface

+ CountDirectChildren func(ctx context.Context, parentTaskID string) (int, error)

+ CreateTask func(ctx context.Context, task Task) error

+ DeleteTask func(ctx context.Context, id string) error

+ GetTask func(ctx context.Context, id string) (Task, error)

+ ListTasks func(ctx context.Context, query Query) ([]Summary, error)

+ UpdateTask func(ctx context.Context, task Task) error

+ type Reference struct

+ EffectivePaused bool

+ ID string

+ Identifier string

+ LatestEventSeq int64

+ Owner *Ownership

+ Paused bool

+ PausedByTaskID string

+ Priority Priority

+ Scope Scope

+ Status Status

+ Title string

+ WorkspaceID string

+ type ResumeMutation struct

+ ResumedAt time.Time

+ TaskID string

+ type ResumeTaskRequest struct

+ Metadata json.RawMessage

+ type RetryRunMutation struct

+ Metadata json.RawMessage

+ NewRunID string

+ Origin Origin

+ QueuedAt time.Time

+ SourceRunID string

+ type RetryRunRequest struct

+ Metadata json.RawMessage

+ type RetryRunResult struct

+ PreviousRun Run

+ Run Run

+ type ReviewContinuation struct

+ MissingWork []string

+ NextRoundGuidance string

+ Outcome string

+ Reason string

+ ReviewID string

+ ReviewRound int

+ ReviewedRunID string

+ type ReviewPolicy string

+ const ReviewPolicyAlways

+ const ReviewPolicyNone

+ const ReviewPolicyOnFailure

+ const ReviewPolicyOnSuccess

+ func (p ReviewPolicy) MatchesRunStatus(status RunStatus) bool

+ func (p ReviewPolicy) Normalize() ReviewPolicy

+ func (p ReviewPolicy) Validate(path string) error

+ type ReviewProfile struct

+ AgentName string

+ AllowedAgentNames []string

+ AllowedChannelIDs []string

+ AllowedPeerIDs []string

+ Model string

+ PreferredAgentNames []string

+ PreferredCapabilities []string

+ PreferredChannelIDs []string

+ PreferredPeerIDs []string

+ Provider string

+ RequiredCapabilities []string

+ type Run struct

+ Attempt int

+ ClaimToken string

+ ClaimTokenHash string

+ ClaimedAt time.Time

+ ClaimedBy *ActorIdentity

+ CoordinationChannelID string

+ EndedAt time.Time

+ Error string

+ FailureKind string

+ HeartbeatAt time.Time

+ ID string

+ IdempotencyKey string

+ LeaseUntil time.Time

+ Metadata json.RawMessage

+ NetworkChannel string

+ Origin Origin

+ PreferredCapabilities []string

+ PreviousRunID string

+ QueuedAt time.Time

+ RequiredCapabilities []string

+ Result json.RawMessage

+ Review *RunReviewLineage

+ SessionID string

+ StartedAt time.Time

+ Status RunStatus

+ TaskID string

+ func (r Run) Validate() error

+ type RunBootRecovery struct

+ Action RunBootRecoveryAction

+ Classification string

+ Detail string

+ Reason string

+ SessionState string

+ func (r RunBootRecovery) Validate(path string) error

+ type RunBootRecoveryAction string

+ const RunBootRecoveryFail

+ const RunBootRecoveryMarkRunning

+ const RunBootRecoveryRequeue

+ func (a RunBootRecoveryAction) Normalize() RunBootRecoveryAction

+ func (a RunBootRecoveryAction) Validate(path string) error

+ type RunDetailView struct

+ Run Run

+ Session *RunSessionRef

+ Summary RunOperationalSummary

+ Task Reference

+ type RunFailure struct

+ Error string

+ Metadata json.RawMessage

+ func (r RunFailure) Validate(path string) error

+ type RunHookDispatcher interface

+ DispatchTaskRunCompleted func(context.Context, hookspkg.TaskRunCompletedPayload) (hookspkg.TaskRunCompletedPayload, error)

+ DispatchTaskRunEnqueued func(context.Context, hookspkg.TaskRunEnqueuedPayload) (hookspkg.TaskRunEnqueuedPayload, error)

+ DispatchTaskRunFailed func(context.Context, hookspkg.TaskRunFailedPayload) (hookspkg.TaskRunFailedPayload, error)

+ DispatchTaskRunLeaseExpired func(context.Context, hookspkg.TaskRunLeaseExpiredPayload) (hookspkg.TaskRunLeaseExpiredPayload, error)

+ DispatchTaskRunLeaseExtended func(context.Context, hookspkg.TaskRunLeaseExtendedPayload) (hookspkg.TaskRunLeaseExtendedPayload, error)

+ DispatchTaskRunLeaseRecovered func(context.Context, hookspkg.TaskRunLeaseRecoveredPayload) (hookspkg.TaskRunLeaseRecoveredPayload, error)

+ DispatchTaskRunPostClaim func(context.Context, hookspkg.TaskRunPostClaimPayload) (hookspkg.TaskRunPostClaimPayload, error)

+ DispatchTaskRunPreClaim func(context.Context, hookspkg.TaskRunPreClaimPayload) (hookspkg.TaskRunPreClaimPayload, error)

+ DispatchTaskRunReleased func(context.Context, hookspkg.TaskRunReleasedPayload) (hookspkg.TaskRunReleasedPayload, error)

+ type RunIdempotency struct

+ CreatedAt time.Time

+ IdempotencyKey string

+ Origin Origin

+ RunID string

+ func (r RunIdempotency) Validate() error

+ type RunOperationalSummary struct

+ CostCurrency *string

+ InputTokens *int64

+ LastActivityAt time.Time

+ LastEventType string

+ OutputTokens *int64

+ ToolCallCount *int64

+ TotalCost *float64

+ TotalTokens *int64

+ TurnCount *int64

+ type RunQuery struct

+ CoordinationChannelID string

+ Limit int

+ SessionID string

+ Status RunStatus

+ TaskID string

+ func (q RunQuery) Validate(path string) error

+ type RunResult struct

+ Value json.RawMessage

+ func (r RunResult) Validate(path string) error

+ type RunReview struct

+ Attempt int

+ Confidence *float64

+ CreatedAt time.Time

+ DeadlineAt time.Time

+ DeliveryID string

+ MissingWork json.RawMessage

+ NextRoundGuidance string

+ Outcome RunReviewOutcome

+ ParentReviewID string

+ Policy ReviewPolicy

+ Reason string

+ RequestedAt time.Time

+ ReviewID string

+ ReviewRound int

+ ReviewText string

+ ReviewedAt time.Time

+ ReviewedBy *ActorIdentity

+ ReviewerAgentName string

+ ReviewerChannelID string

+ ReviewerPeerID string

+ ReviewerSessionID string

+ RoutedAt time.Time

+ RunID string

+ StartedAt time.Time

+ Status RunReviewStatus

+ TaskID string

+ UpdatedAt time.Time

+ func (r *RunReview) Normalize(now time.Time) (RunReview, error)

+ func (r *RunReview) Validate() error

+ type RunReviewBinding struct

+ Review RunReview

+ ReviewerAgentName string

+ ReviewerChannelID string

+ ReviewerPeerID string

+ SessionID string

+ type RunReviewLineage struct

+ ContinuationReason string

+ MissingWork json.RawMessage

+ NextRoundGuidance string

+ ParentRunID string

+ PolicySnapshot ReviewPolicy

+ RequestID string

+ RequestRound int

+ Required bool

+ ReviewID string

+ ReviewRound int

+ type RunReviewOutcome string

+ const RunReviewOutcomeApproved

+ const RunReviewOutcomeBlocked

+ const RunReviewOutcomeError

+ const RunReviewOutcomeInvalidOutput

+ const RunReviewOutcomeRejected

+ const RunReviewOutcomeTimeout

+ func (o RunReviewOutcome) Normalize() RunReviewOutcome

+ func (o RunReviewOutcome) Validate(path string) error

+ type RunReviewQuery struct

+ Limit int

+ ReviewerSessionID string

+ RunID string

+ Status RunReviewStatus

+ TaskID string

+ func (q RunReviewQuery) Validate(path string) error

+ type RunReviewRequest struct

+ Attempt int

+ DeadlineAt time.Time

+ ParentReviewID string

+ Policy ReviewPolicy

+ Reason string

+ ReviewRound int

+ RunID string

+ TaskID string

+ func (r RunReviewRequest) Normalize() RunReviewRequest

+ func (r RunReviewRequest) Validate(path string) error

+ type RunReviewRequestedNotification struct

+ Actor ActorContext

+ Review RunReview

+ Run Run

+ Task Task

+ type RunReviewRequestedObserver interface

+ OnRunReviewRequested func(ctx context.Context, notification *RunReviewRequestedNotification)

+ type RunReviewResult struct

+ CircuitOpened bool

+ ContinuationRun *Run

+ Review RunReview

+ type RunReviewStatus string

+ const RunReviewStatusCanceled

+ const RunReviewStatusCircuitOpened

+ const RunReviewStatusInReview

+ const RunReviewStatusRecorded

+ const RunReviewStatusRequested

+ const RunReviewStatusRouted

+ func (s RunReviewStatus) Normalize() RunReviewStatus

+ func (s RunReviewStatus) Validate(path string) error

+ type RunReviewStore interface

+ BindRunReviewSession func(ctx context.Context, req BindRunReviewSessionRequest, boundAt time.Time) (RunReview, error)

+ GetRunReview func(ctx context.Context, reviewID string) (RunReview, error)

+ ListRunReviews func(ctx context.Context, query RunReviewQuery) ([]RunReview, error)

+ LookupRunReviewBySession func(ctx context.Context, sessionID string) (RunReview, error)

+ RecordRunReview func(ctx context.Context, req RecordRunReviewRequest, actor ActorContext, ...) (RunReviewResult, error)

+ RequestRunReview func(ctx context.Context, review *RunReview) (RunReview, bool, error)

+ type RunReviewSummary struct

+ Attempt int

+ Outcome string

+ Reason string

+ ReviewID string

+ ReviewRound int

+ ReviewedAt string

+ ReviewerLabel string

+ RunID string

+ Status string

+ type RunReviewVerdict struct

+ Confidence *float64

+ DeliveryID string

+ MissingWork json.RawMessage

+ NextRoundGuidance string

+ Outcome RunReviewOutcome

+ Reason string

+ ReviewText string

+ func (v RunReviewVerdict) Normalize() RunReviewVerdict

+ func (v RunReviewVerdict) Validate(path string) error

+ type RunSessionRef struct

+ AgentName string

+ Channel string

+ CreatedAt time.Time

+ Name string

+ SessionID string

+ State string

+ UpdatedAt time.Time

+ WorkspaceID string

+ type RunStatus string

+ const TaskRunStatusCanceled

+ const TaskRunStatusClaimed

+ const TaskRunStatusCompleted

+ const TaskRunStatusFailed

+ const TaskRunStatusQueued

+ const TaskRunStatusRunning

+ const TaskRunStatusStarting

+ func (s RunStatus) Normalize() RunStatus

+ func (s RunStatus) Validate(path string) error

+ type RunStore interface

+ ClaimNextRun func(ctx context.Context, criteria ClaimCriteria) (ClaimResult, error)

+ CompleteRunLease func(ctx context.Context, completion LeaseCompletion) (Run, error)

+ CountActiveSessionBindings func(ctx context.Context, sessionID string) (int, error)

+ CreateTaskRun func(ctx context.Context, run Run) error

+ FailRunLease func(ctx context.Context, failure LeaseFailure) (Run, error)

+ ForceFailTaskRun func(ctx context.Context, failure ForceFailRunMutation) (ForceRunMutationResult, error)

+ ForceReleaseTaskRun func(ctx context.Context, release ForceReleaseRunMutation) (ForceRunMutationResult, error)

+ GetTaskRun func(ctx context.Context, id string) (Run, error)

+ HeartbeatRunLease func(ctx context.Context, heartbeat LeaseHeartbeat) (Run, error)

+ ListTaskRuns func(ctx context.Context, query RunQuery) ([]Run, error)

+ ListTaskRunsByStatus func(ctx context.Context, statuses []RunStatus) ([]Run, error)

+ RecoverExpiredRunLeases func(ctx context.Context, recovery ExpiredLeaseRecovery) ([]ExpiredLeaseRecoveryResult, error)

+ ReleaseRunLease func(ctx context.Context, release LeaseRelease) (Run, error)

+ ReserveQueuedRun func(ctx context.Context, taskID string, runID string, idempotencyKey string, ...) (Task, Run, bool, error)

+ RetryTaskRun func(ctx context.Context, retry RetryRunMutation) (RetryRunResult, error)

+ UpdateTaskRun func(ctx context.Context, run Run) error

+ type RunSummary struct

+ Attempt int

+ ClaimTokenHash string

+ ClaimedAt time.Time

+ ClaimedBy *ActorIdentity

+ CoordinationChannelID string

+ EndedAt time.Time

+ Error string

+ FailureKind string

+ HeartbeatAt time.Time

+ ID string

+ LeaseUntil time.Time

+ MaxAttempts int

+ PreviousRunID string

+ QueuedAt time.Time

+ SessionID string

+ StartedAt time.Time

+ Status RunStatus

+ TaskID string

+ type RuntimeLimits struct

+ ContextMaxBytes int

+ MaxRuntimeSeconds int64

+ SummaryMaxBytes int

+ type RuntimeViewReader interface

+ GetSession func(ctx context.Context, sessionID string) (*RunSessionRef, error)

+ ListSessionEvents func(ctx context.Context, sessionID string, query store.EventQuery) ([]store.SessionEvent, error)

+ ListSessionTokenStats func(ctx context.Context, sessionID string) ([]store.TokenStats, error)

+ type SandboxMode string

+ func (m SandboxMode) Normalize() SandboxMode

+ type SandboxPolicy struct

+ Mode SandboxMode

+ SandboxRef string

+ type SchedulerBacklog struct

+ Runs []SchedulerBacklogRun

+ Total int

+ type SchedulerBacklogQuery struct

+ IncludePaused bool

+ Limit int

+ WorkspaceID string

+ type SchedulerBacklogRun struct

+ EffectivePaused bool

+ PausedByTaskID string

+ Run Run

+ Task Task

+ type SchedulerDrainRequest struct

+ Reason string

+ Timeout time.Duration

+ type SchedulerDrainResult struct

+ Completed bool

+ CompletedAt time.Time

+ RemainingClaims int

+ StartedAt time.Time

+ Status SchedulerStatus

+ TimedOut bool

+ type SchedulerPauseMutation struct

+ Actor string

+ Paused bool

+ Reason string

+ UpdatedAt time.Time

+ type SchedulerPauseRequest struct

+ Reason string

+ type SchedulerPauseState struct

+ Paused bool

+ PausedAt time.Time

+ PausedBy string

+ Reason string

+ UpdatedAt time.Time

+ type SchedulerResumeRequest struct

+ Reason string

+ type SchedulerStatus struct

+ ActiveClaimCount int

+ AsOf time.Time

+ Paused bool

+ PausedAt time.Time

+ PausedBy string

+ PausedReason string

+ PausedTaskCount int

+ QueuedRunCount int

+ type Scope string

+ const ScopeGlobal

+ const ScopeWorkspace

+ func (s Scope) Normalize() Scope

+ func (s Scope) Validate(path string) error

+ type Service struct

+ func NewManager(opts ...Option) (*Service, error)

+ func (m *Service) AddDependency(ctx context.Context, spec AddDependency, actor ActorContext) error

+ func (m *Service) ApproveTask(ctx context.Context, id string, req ExecutionRequest, actor ActorContext) (*Execution, error)

+ func (m *Service) ArchiveTask(ctx context.Context, id string, actor ActorContext) (TriageState, error)

+ func (m *Service) AttachRunSession(ctx context.Context, runID string, sessionID string, actor ActorContext) (*Run, error)

+ func (m *Service) BindRunReviewSession(ctx context.Context, req BindRunReviewSessionRequest, actor ActorContext) (RunReviewBinding, error)

+ func (m *Service) BulkForceFailRuns(ctx context.Context, req BulkForceRunRequest, actor ActorContext) (BulkForceRunResult, error)

+ func (m *Service) BulkForceReleaseRuns(ctx context.Context, req BulkForceRunRequest, actor ActorContext) (BulkForceRunResult, error)

+ func (m *Service) CancelRun(ctx context.Context, runID string, req CancelRun, actor ActorContext) (*Run, error)

+ func (m *Service) CancelTask(ctx context.Context, id string, req CancelTask, actor ActorContext) (*Task, error)

+ func (m *Service) ClaimNextRun(ctx context.Context, criteria ClaimCriteria, actor ActorContext) (*ClaimResult, error)

+ func (m *Service) ClaimRun(ctx context.Context, runID string, claim ClaimRun, actor ActorContext) (*Run, error)

+ func (m *Service) CompleteRun(ctx context.Context, runID string, result RunResult, actor ActorContext) (*Run, error)

+ func (m *Service) CompleteRunLease(ctx context.Context, completion LeaseCompletion, actor ActorContext) (*Run, error)

+ func (m *Service) CreateChildTask(ctx context.Context, parentTaskID string, spec CreateTask, actor ActorContext) (*Task, error)

+ func (m *Service) CreateTask(ctx context.Context, spec CreateTask, actor ActorContext) (*Task, error)

+ func (m *Service) DeleteExecutionProfile(ctx context.Context, taskID string, actor ActorContext) error

+ func (m *Service) DeleteTask(ctx context.Context, id string, actor ActorContext) error

+ func (m *Service) DismissTask(ctx context.Context, id string, actor ActorContext) (TriageState, error)

+ func (m *Service) DrainScheduler(ctx context.Context, req SchedulerDrainRequest, actor ActorContext) (SchedulerDrainResult, error)

+ func (m *Service) EnqueueRun(ctx context.Context, spec EnqueueRun, actor ActorContext) (*Run, error)

+ func (m *Service) FailRun(ctx context.Context, runID string, failure RunFailure, actor ActorContext) (*Run, error)

+ func (m *Service) FailRunLease(ctx context.Context, failure LeaseFailure, actor ActorContext) (*Run, error)

+ func (m *Service) ForceFailRun(ctx context.Context, runID string, failure ForceFailRun, actor ActorContext) (*Run, error)

+ func (m *Service) ForceReleaseRun(ctx context.Context, runID string, release ForceReleaseRun, actor ActorContext) (*Run, error)

+ func (m *Service) GetExecutionProfile(ctx context.Context, taskID string, actor ActorContext) (ExecutionProfile, error)

+ func (m *Service) GetRunReview(ctx context.Context, reviewID string, actor ActorContext) (RunReview, error)

+ func (m *Service) GetTask(ctx context.Context, id string, actor ActorContext) (*View, error)

+ func (m *Service) HeartbeatRunLease(ctx context.Context, heartbeat LeaseHeartbeat, actor ActorContext) (*Run, error)

+ func (m *Service) InspectRun(ctx context.Context, runID string, actor ActorContext) (*InspectView, error)

+ func (m *Service) InspectTask(ctx context.Context, taskID string, actor ActorContext) (*InspectView, error)

+ func (m *Service) ListRunReviews(ctx context.Context, query RunReviewQuery, actor ActorContext) ([]RunReview, error)

+ func (m *Service) ListTaskRuns(ctx context.Context, taskID string, query RunQuery, actor ActorContext) ([]Run, error)

+ func (m *Service) ListTasks(ctx context.Context, query Query, actor ActorContext) ([]Summary, error)

+ func (m *Service) LookupActiveRunForSession(ctx context.Context, sessionID string, runID string) (AutonomyLeaseHandle, error)

+ func (m *Service) LookupRunReviewForSession(ctx context.Context, sessionID string, actor ActorContext) (RunReviewBinding, error)

+ func (m *Service) MarkTaskRead(ctx context.Context, id string, actor ActorContext) (TriageState, error)

+ func (m *Service) PauseScheduler(ctx context.Context, req SchedulerPauseRequest, actor ActorContext) (SchedulerStatus, error)

+ func (m *Service) PauseTask(ctx context.Context, id string, req PauseTaskRequest, actor ActorContext) (*Task, error)

+ func (m *Service) PublishTask(ctx context.Context, id string, req ExecutionRequest, actor ActorContext) (*Execution, error)

+ func (m *Service) RecordRunReview(ctx context.Context, req RecordRunReviewRequest, actor ActorContext) (RunReviewResult, error)

+ func (m *Service) RecoverExpiredRunLeases(ctx context.Context, recovery ExpiredLeaseRecovery, actor ActorContext) ([]ExpiredLeaseRecoveryResult, error)

+ func (m *Service) RecoverRunOnBoot(ctx context.Context, runID string, recovery RunBootRecovery, ...) (*Run, error)

+ func (m *Service) RejectTask(ctx context.Context, id string, actor ActorContext) (*Task, error)

+ func (m *Service) ReleaseRunLease(ctx context.Context, release LeaseRelease, actor ActorContext) (*Run, error)

+ func (m *Service) ReleaseSessionRunLeases(ctx context.Context, release SessionLeaseRelease, actor ActorContext) ([]SessionLeaseReleaseResult, error)

+ func (m *Service) RemoveDependency(ctx context.Context, taskID string, dependsOnID string, actor ActorContext) error

+ func (m *Service) RequestRunReview(ctx context.Context, req RunReviewRequest, actor ActorContext) (RunReview, bool, error)

+ func (m *Service) ResumeScheduler(ctx context.Context, _ SchedulerResumeRequest, actor ActorContext) (SchedulerStatus, error)

+ func (m *Service) ResumeTask(ctx context.Context, id string, req ResumeTaskRequest, actor ActorContext) (*Task, error)

+ func (m *Service) RetryRun(ctx context.Context, runID string, retry RetryRunRequest, actor ActorContext) (*RetryRunResult, error)

+ func (m *Service) RunDetail(ctx context.Context, runID string, actor ActorContext) (*RunDetailView, error)

+ func (m *Service) SchedulerBacklog(ctx context.Context, query SchedulerBacklogQuery, actor ActorContext) (SchedulerBacklog, error)

+ func (m *Service) SchedulerStatus(ctx context.Context, actor ActorContext) (SchedulerStatus, error)

+ func (m *Service) SetExecutionProfile(ctx context.Context, taskID string, profile *ExecutionProfile, ...) (ExecutionProfile, error)

+ func (m *Service) StartRun(ctx context.Context, runID string, req StartRun, actor ActorContext) (*Run, error)

+ func (m *Service) StartTask(ctx context.Context, id string, req ExecutionRequest, actor ActorContext) (*Execution, error)

+ func (m *Service) Stream(ctx context.Context, taskID string, query StreamQuery, actor ActorContext) (<-chan StreamEvent, error)

+ func (m *Service) Timeline(ctx context.Context, taskID string, query TimelineQuery, actor ActorContext) ([]TimelineItem, error)

+ func (m *Service) Tree(ctx context.Context, taskID string, actor ActorContext) (*TreeView, error)

+ func (m *Service) UpdateTask(ctx context.Context, id string, patch Patch, actor ActorContext) (*Task, error)

+ type SessionExecutor interface

+ AttachTaskSession func(ctx context.Context, runID string, sessionID string) (*SessionRef, error)

+ ForceTaskStop func(ctx context.Context, sessionID string, reason StopReason) error

+ RequestTaskStop func(ctx context.Context, sessionID string, reason StopReason) error

+ StartTaskSession func(ctx context.Context, spec *StartTaskSession) (*SessionRef, error)

+ type SessionLeaseRelease struct

+ Now time.Time

+ Reason string

+ SessionID string

+ func (r SessionLeaseRelease) Normalize(defaultNow time.Time) (SessionLeaseRelease, error)

+ func (r SessionLeaseRelease) Validate(path string) error

+ type SessionLeaseReleaseResult struct

+ PreviousClaimTokenHash string

+ PreviousLeaseUntil time.Time

+ PreviousRunStatus RunStatus

+ PreviousSessionID string

+ Reason string

+ Run Run

+ type SessionRef struct

+ SessionID string

+ StartedAt time.Time

+ WorkspaceID string

+ func (r SessionRef) Validate() error

+ type SoulClaimProvenance struct

+ AgentName string

+ CapturedAt time.Time

+ Digest string

+ SnapshotID string

+ func (p SoulClaimProvenance) Validate(path string) error

+ type StartRun struct

+ IdempotencyKey string

+ func (r StartRun) Validate(path string) error

+ type StartTaskSession struct

+ Actor ActorContext

+ ExecutionProfile *ExecutionProfile

+ Run Run

+ Task Task

+ func (r *StartTaskSession) Validate() error

+ type Status string

+ const TaskStatusBlocked

+ const TaskStatusCanceled

+ const TaskStatusCompleted

+ const TaskStatusDraft

+ const TaskStatusFailed

+ const TaskStatusInProgress

+ const TaskStatusPending

+ const TaskStatusReady

+ func (s Status) Normalize() Status

+ func (s Status) Validate(path string) error

+ type StopReason string

+ const StopReasonCancellation

+ const StopReasonCompleted

+ const StopReasonFailed

+ const StopReasonOrphanedRun

+ const StopReasonShutdown

+ func (r StopReason) Normalize() StopReason

+ func (r StopReason) Validate(path string) error

+ type Store interface

+ type StreamEvent struct

+ Sequence int64

+ Timeline TimelineItem

+ Type string

+ type StreamQuery struct

+ AfterSequence int64

+ func (q StreamQuery) Validate(path string) error

+ type Summary struct

+ ActiveRun *RunSummary

+ ApprovalPolicy ApprovalPolicy

+ ApprovalState ApprovalState

+ ChildCount int

+ ClosedAt time.Time

+ CreatedAt time.Time

+ CreatedBy ActorIdentity

+ CurrentRunID string

+ Dependencies []DependencyReference

+ DependencyCount int

+ Draft bool

+ EffectivePaused bool

+ ID string

+ Identifier string

+ LastActivityAt time.Time

+ LatestEventSeq int64

+ MaxAttempts int

+ NetworkChannel string

+ Origin Origin

+ Owner *Ownership

+ ParentTaskID string

+ Paused bool

+ PausedAt time.Time

+ PausedBy string

+ PausedByTaskID string

+ PausedReason string

+ Priority Priority

+ Scope Scope

+ Status Status

+ Title string

+ UpdatedAt time.Time

+ WorkspaceID string

+ type Task struct

+ ApprovalPolicy ApprovalPolicy

+ ApprovalState ApprovalState

+ ClosedAt time.Time

+ CreatedAt time.Time

+ CreatedBy ActorIdentity

+ CurrentRunID string

+ Description string

+ ID string

+ Identifier string

+ LatestEventSeq int64

+ MaxAttempts int

+ Metadata json.RawMessage

+ NetworkChannel string

+ Origin Origin

+ Owner *Ownership

+ ParentTaskID string

+ Paused bool

+ PausedAt time.Time

+ PausedBy string

+ PausedReason string

+ Priority Priority

+ Scope Scope

+ Status Status

+ Title string

+ UpdatedAt time.Time

+ WorkspaceID string

+ func (t Task) Validate() error

+ type TimelineItem struct

+ Actor ActorIdentity

+ EventID string

+ EventType string

+ Origin Origin

+ Payload json.RawMessage

+ Run *RunSummary

+ Sequence int64

+ Task Reference

+ Timestamp time.Time

+ type TimelineQuery struct

+ AfterSequence int64

+ Limit int

+ func (q TimelineQuery) Validate(path string) error

+ type TreeNode struct

+ ActiveRun *RunSummary

+ ChildCount int

+ Depth int

+ LastActivityAt time.Time

+ ParentTaskID string

+ Task Reference

+ type TreeView struct

+ Descendants []TreeNode

+ Root TreeNode

+ type TriageState struct

+ Actor ActorIdentity

+ Archived bool

+ Dismissed bool

+ LastSeenActivityAt time.Time

+ Read bool

+ TaskID string

+ UpdatedAt time.Time

+ func (t TriageState) Validate() error

+ type TriageStore interface

+ GetTaskTriageState func(ctx context.Context, taskID string, actor ActorIdentity) (TriageState, error)

+ UpsertTaskTriageState func(ctx context.Context, state TriageState) error

+ type View struct

+ Children []Summary

+ Dependencies []Dependency

+ DependencyReferences []DependencyReference

+ Events []Event

+ Runs []Run

+ Summary Summary

+ Task Task

+ type WorkerMode string

+ func (m WorkerMode) Normalize() WorkerMode

+ type WorkerProfile struct

+ AgentName string

+ AllowedAgentNames []string

+ Mode WorkerMode

+ Model string

+ PreferredAgentNames []string

+ PreferredCapabilities []string

+ Provider string

+ RequiredCapabilities []string

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