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 ContinuationAbsence + const ContinuationApplied + const ContinuationIdempotent + const EffectActionCompensate + const EffectActionRetry + const MaxEffectContinuations + const MaxEffectDuration + const MaxReservationDepth + const MaxReservations + const MaxRunRecoveryBytes + const MaxRunRecoveryEntries + const PrefixEffectAttempt + const PrefixReservation + const PrefixRunCall + var ErrBudgetExceeded = cortex.ErrSharedBudgetExceeded + var ErrEffectConflict = cortex.ErrEffectConflict + var ErrEffectNotFound = cortex.ErrEffectNotFound + var ErrEffectUnavailable = cortex.ErrEffectUnavailable + var ErrEffectUncertain = cortex.ErrEffectUncertain + var ErrInvalidEffect = errors.New("cortex: invalid effect requirement") + var ErrInvalidReservation = cortex.ErrInvalidReservation + var ErrInvalidRunCall = cortex.ErrInvalidRunCall + var ErrProviderCallUncertain = cortex.ErrProviderCallUncertain + var ErrReservationConflict = cortex.ErrReservationConflict + var ErrReservationNotFound = cortex.ErrReservationNotFound + var ErrRunCallConflict = cortex.ErrRunCallConflict + var ErrRunCallNotFound = cortex.ErrRunCallNotFound + var ErrRunCallUnavailable = cortex.ErrRunCallUnavailable + var ErrRunCallsSealed = cortex.ErrRunCallsSealed + func AdmitReservation(p ReservationPolicy, reservations []Reservation, r ReservationRequest, ...) error + func CheckReservationBudget(p ReservationPolicy, reservations []Reservation, identifier id.ID, ...) error + func CompensationOperationKey(original EffectRequest) string + func EffectPredecessorDigest(request EffectRequest, receipt *EffectReceipt) (string, error) + func IsCompensationOperationKey(key string) bool + func RunCallKey(runID id.AgentRunID, operationDigest string) string + func WithRunCallContext(ctx context.Context, r RunCallRequest) context.Context + type BoundEffectStore interface + BeginBoundEffect func(context.Context, EffectRequest) (bool, error) + type Budget struct + Deadline time.Time + MaxSteps int + MaxTokens int + MaxToolCalls int + func (b Budget) Check(u Usage, now time.Time) Limit + func (b Budget) CheckTool(u Usage, now time.Time) Limit + func (b Budget) Equal(other Budget) bool + func (b Budget) OutputLimit(configured int, u Usage) int + func (b Budget) Validate() error + type BudgetSnapshot struct + Charged Resources + Overflow bool + Policy ReservationPolicy + Reservations int + func AccountReservations(p ReservationPolicy, reservations []Reservation) (BudgetSnapshot, error) + type BudgetStore interface + CreateReservationPolicy func(context.Context, ReservationPolicy) error + GetBudgetSnapshot func(context.Context, id.ID) (BudgetSnapshot, error) + GetReservation func(context.Context, id.ID) (Reservation, error) + GetReservationPolicy func(context.Context, id.ID) (ReservationPolicy, error) + ListReservations func(context.Context, ReservationListRequest) ([]Reservation, error) + Reserve func(context.Context, ReservationRequest) (Reservation, error) + Settle func(context.Context, Settlement) error + type EffectAction string + const EffectActionExecute + const EffectActionReconcile + type EffectAdapter interface + Execute func(context.Context, EffectRequest, []byte) (EffectReceipt, error) + Reconcile func(context.Context, EffectRequest) (EffectStatus, error) + type EffectClass string + const EffectCompensatable + const EffectIdempotent + const EffectNonIdempotent + const EffectReadOnly + type EffectContinuation struct + At time.Time + Fresh bool + Request EffectContinuationRequest + RequestDigest string + Reservation Reservation + func (a EffectContinuation) Validate() error + type EffectContinuationAuthority interface + AuthorizeEffectContinuation func(context.Context, EffectContinuationRequest, EffectAction) error + WithEffectContinuationAuthority func(context.Context, EffectContinuationRequest, ...) error + type EffectContinuationProof struct + Digest string + ExpiresAt time.Time + Issuer string + Mode string + ObservedAt time.Time + Reference string + Revision string + type EffectContinuationRequest struct + Action EffectAction + ClaimDigest string + Operation EffectRequest + Original EffectRequest + PredecessorDigest string + Proof EffectContinuationProof + Reservation ReservationRequest + ResultID id.ID + ResultRetention time.Duration + SchemaVersion int + Seal RunCallSeal + Sequence int + SnapshotDigest string + func (r EffectContinuationRequest) Freeze() (EffectContinuationRequest, string, error) + func (r EffectContinuationRequest) Key() string + type EffectContinuationResult struct + At time.Time + Evidence evidence.Ref + Receipt EffectReceipt + RequestDigest string + Settlement SettlementReceipt + func (r EffectContinuationResult) Validate(a EffectContinuation) error + type EffectContinuationStore interface + AdmitEffectContinuation func(context.Context, EffectContinuationRequest) (EffectContinuation, error) + CompleteEffectContinuation func(context.Context, EffectContinuationRequest, EffectReceipt) (EffectContinuationResult, error) + GetEffectContinuationResult func(context.Context, EffectContinuationRequest) (*EffectContinuationResult, error) + ListEffectContinuations func(context.Context, EffectRequest) ([]EffectContinuation, error) + type EffectDiscoveryStore interface + ListEffects func(context.Context, EffectListRequest) ([]EffectRecord, error) + type EffectExecutor struct + func NewEffectExecutor(cfg EffectExecutorConfig) (*EffectExecutor, error) + func (e *EffectExecutor) ContinueEffect(ctx context.Context, request EffectContinuationRequest, args []byte, ...) (EffectContinuationResult, error) + func (e *EffectExecutor) Execute(ctx context.Context, request EffectRequest, args []byte) (EffectReceipt, error) + func (e *EffectExecutor) Reconcile(ctx context.Context, request EffectRequest) (EffectReceipt, error) + func (e *EffectExecutor) ReconcileContinuation(ctx context.Context, request EffectContinuationRequest, ...) (EffectContinuationResult, error) + func (e *EffectExecutor) RecoverPage(ctx context.Context, request EffectListRequest) (EffectRecoveryPage, error) + func (e *EffectExecutor) RecoverSealedPage(ctx context.Context, request EffectRecoveryPageRequest) (EffectRecoveryPage, error) + type EffectExecutorConfig struct + Adapters []EffectRegistration + Authorize func(context.Context, EffectRequest, EffectAction) error + AuthorizeScan func(context.Context, RunCallSeal) error + MaxConcurrent int + Store EffectStore + type EffectListRequest struct + After string + Limit int + RunID id.AgentRunID + func (r EffectListRequest) Validate() error + type EffectOutcome string + const EffectApplied + const EffectNotApplied + const EffectUnknown + type EffectReceipt struct + EvidenceRef string + ExternalID string + ExternalVersion string + Outcome EffectOutcome + RequestDigest string + SchemaVersion int + func (v EffectReceipt) Validate(r EffectRequest) error + type EffectRecord struct + Receipt *EffectReceipt + Request EffectRequest + type EffectRecoveryItem struct + OperationDigest string + Outcome EffectOutcome + RunID id.AgentRunID + Status EffectRecoveryStatus + type EffectRecoveryPage struct + Items []EffectRecoveryItem + NextAfter string + type EffectRecoveryPageRequest struct + After string + Limit int + Seal RunCallSeal + type EffectRecoveryStatus string + const EffectRecoveryTerminal + const EffectRecoveryUnavailable + const EffectRecoveryUncertain + type EffectReference struct + Revision string + Tool string + type EffectRegistration struct + Adapter EffectAdapter + Requirement EffectRequirement + type EffectRequest struct + ArgsDigest string + AttemptID id.ID + AuthorityRef string + Deadline time.Time + OperationKey string + PrincipalRef string + Requirement EffectRequirement + RunCall *RunCallRequest + RunID id.AgentRunID + SchemaVersion int + Scope cortex.Scope + func (r EffectRequest) Freeze() (EffectRequest, string, error) + type EffectRequirement struct + Class EffectClass + Compensation EffectReference + IdempotencyRevision string + ReconcileRevision string + Retry RetryPolicy + Revision string + Tool string + func (r EffectRequirement) Validate() error + type EffectStatus struct + Outcome EffectOutcome + Receipt *EffectReceipt + type EffectStore interface + BeginEffect func(context.Context, EffectRequest) (bool, error) + CompleteEffect func(context.Context, EffectRequest, EffectReceipt) error + GetEffect func(context.Context, string) (EffectRecord, error) + type KnownResources uint8 + const KnownAll + const KnownFanOut + const KnownMoney + const KnownReplans + const KnownSteps + const KnownTokens + const KnownToolCalls + type Limit string + const LimitDeadline + const LimitSteps + const LimitTokens + const LimitTools + type ProviderCallOutcome string + const ProviderCallFailed + const ProviderCallNotAccepted + const ProviderCallSucceeded + type ProviderCallReceipt struct + AccountRef string + AdapterRevision string + ObservedAt time.Time + OperationID string + Outcome ProviderCallOutcome + ProofDigest string + ProofRef string + Provider string + RequestDigest string + ResultDigest string + SchemaVersion int + Usage ReservationUsage + func (c ProviderCallReceipt) Freeze(request RunCallRequest) (ProviderCallReceipt, string, error) + func (c ProviderCallReceipt) ValidateObservation(record RunCallRecord) error + type ProviderCallReceiptStore interface + GetProviderCallReceipt func(context.Context, RunCallRequest) (*ProviderCallReceipt, error) + PutProviderCallReceipt func(context.Context, RunCallRequest, ProviderCallReceipt) error + type ProviderCallRecoveryAdapter interface + ReconcileProviderCall func(context.Context, RunCallRequest) (ProviderCallReceipt, error) + type ProviderCallRecoveryFence interface + WithProviderCallFence func(context.Context, RunCallRequest, func() error) error + type ProviderReconciler struct + func NewProviderReconciler(config ProviderRecoveryConfig) (*ProviderReconciler, error) + func (p *ProviderReconciler) Reconcile(ctx context.Context, request RunCallRequest) (ProviderCallReceipt, error) + func (p *ProviderReconciler) ReconcilePage(ctx context.Context, request ProviderRecoveryPageRequest) (ProviderRecoveryPage, error) + type ProviderRecoveryConfig struct + Adapter ProviderCallRecoveryAdapter + Authenticate func(context.Context, RunCallRequest, ProviderCallReceipt) error + Authorize func(context.Context, RunCallRequest) error + AuthorizeScan func(context.Context, RunCallSeal) error + Fence ProviderCallRecoveryFence + MaxConcurrent int + Store ProviderCallReceiptStore + Timeout time.Duration + type ProviderRecoveryPage struct + NextAfter string + Scanned int + Terminal int + ToolCalls int + Unresolved int + type ProviderRecoveryPageRequest struct + After string + Limit int + Seal RunCallSeal + type RecoveredRunCall struct + Call RunCallRecord + Provider *ProviderCallReceipt + type Reservation struct + CreatedAt time.Time + Request ReservationRequest + RequestDigest string + Settlement *SettlementReceipt + func (r Reservation) Validate() error + type ReservationKind string + const ReservationBranch + const ReservationLeaf + type ReservationListRequest struct + After id.ID + Limit int + PlanID id.ID + type ReservationPolicy struct + Deadline time.Time + Limits Resources + PlanID id.ID + PricingRevision string + SchemaVersion int + Scope cortex.Scope + TokenOnly bool + func (p ReservationPolicy) Admit(used Resources, r ReservationRequest, at time.Time) error + func (p ReservationPolicy) Freeze() (ReservationPolicy, string, error) + type ReservationRequest struct + Allocation Resources + Deadline time.Time + ID id.ID + Kind ReservationKind + MoneyBound bool + OwnerRef string + ParentID id.ID + PlanDigest string + PlanID id.ID + PricingRevision string + SchemaVersion int + Scope cortex.Scope + TaskID id.ID + func (r ReservationRequest) Freeze() (ReservationRequest, string, error) + type ReservationUsage struct + Actual Resources + Known KnownResources + type Resources struct + FanOut int64 + Replans int64 + Steps int64 + Tokens int64 + ToolCalls int64 + USDMicros int64 + func SettlementCharge(r ReservationRequest, s Settlement) (Resources, error) + func (r Resources) Add(other Resources) (Resources, bool) + func (r Resources) Admit(used, want Resources) error + func (r Resources) Covers(other Resources) bool + func (r Resources) Max(other Resources) Resources + func (r Resources) Validate() error + type RetryPolicy struct + InitialBackoff time.Duration + MaxAttempts int + MaxBackoff time.Duration + type RunCallCompletion struct + ReportedTokens int64 + RequestDigest string + ResultDigest string + SchemaVersion int + TokensReported bool + func (c RunCallCompletion) Validate(r RunCallRequest) error + type RunCallKind string + const RunCallComplete + const RunCallStream + const RunCallTool + type RunCallListRequest struct + After string + Limit int + RunID id.AgentRunID + func (r RunCallListRequest) Validate() error + type RunCallRecord struct + CompletedAt time.Time + Completion *RunCallCompletion + Request RunCallRequest + StartedAt time.Time + func (r RunCallRecord) Validate() error + type RunCallRequest struct + AgentID id.AgentID + AssignmentDigest string + ClaimID id.ID + Deadline time.Time + ID id.ID + Kind RunCallKind + OperationDigest string + ParentRunID id.AgentRunID + PreparedDigest string + RequestDigest string + RunID id.AgentRunID + SchemaVersion int + Scope cortex.Scope + func RunCallFromContext(ctx context.Context) (RunCallRequest, bool) + func (r RunCallRequest) Freeze() (RunCallRequest, string, error) + func (r RunCallRequest) Key() string + type RunCallSeal struct + At time.Time + Request RunCallSealRequest + RequestDigest string + func (s RunCallSeal) Validate() error + type RunCallSealAuthorizer interface + AuthorizeRunCallSeal func(context.Context, RunCallSealRequest) error + type RunCallSealFence interface + WithRunCallSeal func(context.Context, RunCallSealRequest, func(RunCallSealRequest) error) error + type RunCallSealRequest struct + Actor string + Reason string + RunID id.AgentRunID + SchemaVersion int + Scope cortex.Scope + func (r RunCallSealRequest) Freeze() (RunCallSealRequest, string, error) + type RunCallSealStore interface + GetRunCallSeal func(context.Context, id.AgentRunID) (*RunCallSeal, error) + SealRunCalls func(context.Context, RunCallSealRequest) (RunCallSeal, error) + type RunCallSealer interface + Seal func(context.Context, RunCallSealRequest) (RunCallSeal, error) + func NewRunCallSealer(store RunCallSealStore, fence RunCallSealFence, ...) (RunCallSealer, error) + type RunCallStore interface + BeginRunCall func(context.Context, RunCallRequest) (bool, error) + CompleteRunCall func(context.Context, RunCallRequest, RunCallCompletion) error + GetRunCall func(context.Context, id.AgentRunID, string) (RunCallRecord, error) + ListRunCalls func(context.Context, RunCallListRequest) ([]RunCallRecord, error) + type RunRecoverySnapshot struct + Calls []RecoveredRunCall + Digest string + Effects []EffectRecord + SchemaVersion int + Seal RunCallSeal + func SealRunRecoverySnapshot(s RunRecoverySnapshot) (RunRecoverySnapshot, error) + func (s RunRecoverySnapshot) Validate() error + type RunRecoverySnapshotStore interface + SnapshotRunRecovery func(context.Context, RunCallSeal) (RunRecoverySnapshot, error) + type Settlement struct + CloseBranch bool + Minimum *Resources + Overflow KnownResources + Receipt string + RequestDigest string + ReservationID id.ID + Usage ReservationUsage + func (s Settlement) Freeze() (Settlement, string, error) + type SettlementReceipt struct + At time.Time + Digest string + Request Settlement + type Usage struct + Estimated bool + ReportedTokens int + Steps int + Tokens int + ToolCalls int + func (u *Usage) ChargeTokens(reported int, b Budget) v1.8.0 Oct 18, 2026
Go to main page