sessiontree

Jul 26, 2026

Changes in this version

+ var ErrCanonicalTurnNotFound = errors.New("session tree canonical turn not found")

+ func ValidateCanonicalTurnReadAuthority(turn CanonicalTurn, admission CanonicalTurnAdmissionFact) error

+ func ValidateCanonicalTurnReadStructure(turn CanonicalTurn, threadID string) error

+ type CanonicalTurnAdmissionFact struct

+ BaseLeafID string

+ RunID string

+ ThreadID string

+ TurnID string

+ TurnStartedID string

+ UserMessageID string

+ type CanonicalTurnRead struct

+ HasRetryTarget bool

+ LatestTurn CanonicalTurn

+ ThroughOrdinal int64

+ Turn CanonicalTurn

+ type CanonicalTurnReadRepo interface

+ ReadCanonicalTurn func(context.Context, string, string) (CanonicalTurnRead, error)

type MemoryRepo

+ func (r *MemoryRepo) ReadCanonicalTurn(_ context.Context, threadID, turnID string) (CanonicalTurnRead, error)

Jul 26, 2026

Changes in this version

+ const SubAgentInputIDMetadataKey

+ const SubAgentUserMessageOriginDelegatedMission

+ const SubAgentUserMessageOriginInput

+ const SubAgentUserMessageOriginMetadataKey

+ const SubAgentUserMessageOriginPendingToolCompletion

+ func SubAgentUserMessageOrigin(kind SubAgentRequestKind) (string, error)

type MemoryRepo

+ func (r *MemoryRepo) ReadSubAgentInput(_ context.Context, inputID string) (SubAgentInputRecord, bool, error)

+ type SubAgentInputReadRepo interface

+ ReadSubAgentInput func(context.Context, string) (SubAgentInputRecord, bool, error)

Jul 26, 2026

Changes in this version

+ const MaxThreadTitleRunes

+ func ValidateCanonicalThreadTitle(title string) error

+ func ValidateThreadTitleProjection(projection ThreadTitleProjection) error

type ListThreadsOptions

+ RootOnly bool

+ type ThreadTitleProjection struct

+ Error string

+ Generation int64

+ Source ThreadTitleSource

+ Status ThreadTitleStatus

+ Title string

+ UpdatedAt time.Time

Jul 24, 2026

Changes in this version

+ func ValidateAdmitPendingToolCompletionEnvelope(req AdmitPendingToolCompletionRequest) error

+ func ValidateAdmitPendingToolCompletionReplayRequest(req AdmitPendingToolCompletionRequest) error

+ func ValidateAdmitTurnReplayRequest(req AdmitTurnRequest) error

+ func ValidateAdmitTurnRequestEnvelope(req AdmitTurnRequest) error

+ func ValidateEntryMessageAttachments(entry Entry) error

+ func ValidateNewEntryMessageAttachments(entry Entry) error

+ func ValidatePublishSubAgentInputEnvelope(req PublishSubAgentInputRequest) error

+ func ValidatePublishSubAgentInputReplayRequest(req PublishSubAgentInputRequest) error

+ func ValidatePublishSubAgentPendingToolCompletionEnvelope(req PublishSubAgentPendingToolCompletionRequest) error

+ func ValidatePublishSubAgentPendingToolCompletionReplayRequest(req PublishSubAgentPendingToolCompletionRequest) error

+ func ValidatePublishSubAgentReplayRequest(req PublishSubAgentRequest) error

Jul 21, 2026

Changes in this version

+ const ApprovalReasonAuthorizationContract

+ const ApprovalReasonAuthorizationUnavailable

+ const ApprovalReasonCancelled

+ const ApprovalReasonPolicyDenied

+ const ApprovalReasonTimedOut

+ const ApprovalReasonUserRejected

+ const BranchBoundaryTurnFailureMessage

+ const InterruptedTurnEffectOutcomeUnknownMessage

+ const InterruptedTurnRecoveryApprovalGenerationKey

+ const InterruptedTurnRecoveryApprovalRevisionKey

+ const InterruptedTurnRecoveryApprovalRootKey

+ const InterruptedTurnRecoverySourceFailureEntryKey

+ const InterruptedTurnRecoverySourceFailureRawHashKey

+ const RetrySourceEntryIDMetadataKey

+ const RetrySourceTurnIDMetadataKey

+ const TurnFailureAuthorizationContract

+ const TurnFailureAuthorizationUnavailable

+ const TurnFailureCancelled

+ const TurnFailureCodeMetadataKey

+ const TurnFailureEffectOutcomeUnknown

+ const TurnFailureEngineContract

+ const TurnFailureInterrupted

+ const TurnFailureLegacyUnclassified

+ const TurnFailureProvider

+ const TurnFailureStorage

+ const TurnFailureToolDispatch

+ var ErrApprovalNotFound = errors.New("session tree approval not found")

+ var ErrStaleCanonicalTurnCursor = errors.New("session tree canonical turn cursor is stale")

+ func AddInterruptedTurnApprovalQueueProof(metadata map[string]string, proof *InterruptedTurnApprovalQueueProof) error

+ func AddInterruptedTurnRecoverySourceFailureProof(metadata map[string]string, proof *InterruptedTurnRecoveryFailureProof) error

+ func ApprovalBatchCancellationFingerprint(fingerprint string) string

+ func ApprovalCancellationEntryID(cancellationFingerprint, approvalID string) string

+ func ApprovalDispatchEntryID(decisionID, approvalID string) string

+ func ApprovalDispatchEntryRequestMatches(stored, requested Entry) bool

+ func ApprovalEffectAttemptID(invocation EffectInvocationIdentity) string

+ func ApprovalFinalizationEntryID(decisionID, approvalID string) string

+ func ApprovalPreflightMatchesEffect(item ApprovalPreflightItem, lease TurnLease, attempt EffectAttempt) bool

+ func ApprovalPreflightMatchesRecord(record ApprovalRecord, rootID, parentID string, item ApprovalPreflightItem, ...) bool

+ func ApprovalQueueVisible(state ApprovalState) bool

+ func ApprovalRejectedEntryID(decisionID, approvalID string) string

+ func ApprovalRequestedEntryID(approvalID string) string

+ func BuildContextChecked(path []Entry, opts ContextOptions) ([]session.Message, error)

+ func InterruptedTurnRecoveryApprovalCancellationID(recoveryFingerprint, approvalID string) string

+ func InterruptedTurnRecoveryCancelledEffectFingerprint(recoveryFingerprint string) string

+ func InterruptedTurnRecoveryUnknownEffectFingerprint(recoveryFingerprint string) string

+ func NormalizeApprovalCancellationEntries(req CancelApprovalBatchRequest) (map[string]Entry, error)

+ func RetryPathHasRetryEligibleDurableInput(path []Entry) (bool, error)

+ func RetrySourceHasRetryEligibleDurableInput(path []Entry, sourceTurnID, sourceEntryID string) (int, bool, error)

+ func SameApprovalIdentity(left, right ApprovalIdentity) bool

+ func SameThreadTitleState(left, right ThreadMeta) bool

+ func TurnAdmissionRequestFingerprint(req AdmitTurnRequest) (string, error)

+ func ValidTurnFailureCode(code string) bool

+ func ValidateAdmitTurnRequest(req AdmitTurnRequest) error

+ func ValidateApprovalDecisionReceiptAuthority(receipt ApprovalDecisionReceipt, record ApprovalRecord, queue ApprovalQueue) error

+ func ValidateApprovalRecord(record ApprovalRecord) error

+ func ValidateBeginAutomaticThreadTitleRequest(req BeginAutomaticThreadTitleRequest) error

+ func ValidateCancelApprovalBatchRequest(req CancelApprovalBatchRequest) error

+ func ValidateCanonicalTurnEntries(entries []Entry, threadID, turnID, runID string) error

+ func ValidateCommitApprovalDispatchRequest(req CommitApprovalDispatchRequest) error

+ func ValidateCompleteAutomaticThreadTitleRequest(req CompleteAutomaticThreadTitleRequest) error

+ func ValidateEffectLeaseSuccessor(proof, current TurnLease) error

+ func ValidateEntryIntegrity(entry Entry) error

+ func ValidateEntryMessageReferences(entry Entry) error

+ func ValidateFailAutomaticThreadTitleRequest(req FailAutomaticThreadTitleRequest) error

+ func ValidateFinalizeApprovalRequest(req FinalizeApprovalRequest) error

+ func ValidateFinalizeApprovalRequestedEntry(record ApprovalRecord, entry Entry) error

+ func ValidateFinalizeApprovalResultAuthority(req FinalizeApprovalRequest, result FinalizeApprovalResult) error

+ func ValidateFinalizeApprovalSourceAuthority(req FinalizeApprovalRequest, record ApprovalRecord, effect EffectAttempt, ...) error

+ func ValidateFinishTurnRequest(req FinishTurnRequest) error

+ func ValidateForkRetryAuthorityPath(path []Entry, threadID string) error

+ func ValidateInterruptedTurnRecoveryEffectAttempts(attempts []EffectAttempt, threadID, turnID, runID string) error

+ func ValidateListCanonicalTurnsOptions(opts ListCanonicalTurnsOptions) error

+ func ValidatePublishSubAgentInputRequest(req PublishSubAgentInputRequest) error

+ func ValidateResolveApprovalReplayAuthority(expectedDecisionID string, decision ApprovalDecision, ...) error

+ func ValidateResolveApprovalRequest(req ResolveApprovalRequest) error

+ func ValidateRetrySourcePath(path []Entry, sourceTurnID, sourceEntryID string) (int, error)

+ func ValidateRetryStartedEntry(entry Entry, threadID, turnID, runID, startedEntryID string, ...) error

+ func ValidateThreadTitleState(meta ThreadMeta) error

type AdmitTurnRequest

+ RetrySourceEntryID string

+ RetrySourceTurnID string

type AdmitTurnResult

+ Terminal *TurnTerminalOutcome

+ type ApprovalAuthorityRepo interface

+ Approval func(context.Context, string) (ApprovalRecord, error)

+ CancelApprovalBatch func(context.Context, CancelApprovalBatchRequest) (CancelApprovalBatchResult, error)

+ CommitApprovalDispatch func(context.Context, CommitApprovalDispatchRequest) (CommitApprovalDispatchResult, error)

+ FinalizeApproval func(context.Context, FinalizeApprovalRequest) (FinalizeApprovalResult, error)

+ PrepareApprovalBatch func(context.Context, PrepareApprovalBatchRequest) (PrepareApprovalBatchResult, error)

+ ReadApprovalQueue func(context.Context, string) (ApprovalQueue, error)

+ ResolveApproval func(context.Context, ResolveApprovalRequest) (ResolveApprovalResult, error)

+ WaitApprovalDecision func(context.Context, string) (WaitApprovalDecisionResult, error)

+ type ApprovalCancellationEntry struct

+ ApprovalID string

+ Entry Entry

+ type ApprovalDecision string

+ const ApprovalDecisionApprove

+ const ApprovalDecisionReject

+ type ApprovalDecisionReceipt struct

+ ApprovalID string

+ ApprovalRevision int64

+ AuthorizationProofHash string

+ Decision ApprovalDecision

+ DecisionID string

+ QueueGeneration int64

+ QueueRevision int64

+ Reason string

+ ResolvedAt time.Time

+ RootThreadID string

+ State ApprovalState

+ SubmittedAt time.Time

+ func CanonicalApprovalDecisionReceipt(record ApprovalRecord, queue ApprovalQueue) (ApprovalDecisionReceipt, error)

+ type ApprovalIdentity struct

+ ApprovalID string

+ EffectAttemptID string

+ RunID string

+ ThreadID string

+ ToolCallID string

+ TurnID string

+ type ApprovalPreflightItem struct

+ ApprovalRequestFingerprint string

+ BatchIndex int

+ BatchSize int

+ Destructive bool

+ EffectAttemptID string

+ EffectRequestFingerprint string

+ Effects []string

+ HostContext map[string]string

+ Invocation EffectInvocationIdentity

+ Labels map[string]string

+ OpenWorld bool

+ ReadOnly bool

+ RequestedEntry Entry

+ Resources []ApprovalResource

+ Step int

+ ToolKind string

+ func NormalizeApprovalPreflightBatch(req PrepareApprovalBatchRequest) ([]ApprovalPreflightItem, error)

+ type ApprovalQueue struct

+ CurrentApprovalID string

+ GeneratedAt time.Time

+ Generation int64

+ Items []ApprovalRecord

+ Revision int64

+ RootThreadID string

+ type ApprovalRecord struct

+ ApprovalID string

+ ArgsHash string

+ AuthorizationProofHash string

+ BatchIndex int

+ BatchSize int

+ DecisionID string

+ Destructive bool

+ EffectAttemptID string

+ Effects []string

+ HostContext map[string]string

+ Labels map[string]string

+ OpenWorld bool

+ ParentThreadID string

+ QueueSequence int64

+ ReadOnly bool

+ Reason string

+ RequestFingerprint string

+ RequestedAt time.Time

+ ResolvedAt time.Time

+ Resources []ApprovalResource

+ Revision int64

+ RootThreadID string

+ RunID string

+ State ApprovalState

+ Step int

+ ThreadID string

+ ToolCallID string

+ ToolKind string

+ ToolName string

+ TurnID string

+ UpdatedAt time.Time

+ func ApprovalRecordFromPreflight(rootID, parentID string, item ApprovalPreflightItem, attempt EffectAttempt, ...) ApprovalRecord

+ func (a ApprovalRecord) Identity() ApprovalIdentity

+ type ApprovalResource struct

+ Kind string

+ Value string

+ type ApprovalState string

+ const ApprovalApproved

+ const ApprovalCancelled

+ const ApprovalDecisionSubmitted

+ const ApprovalFailed

+ const ApprovalRejected

+ const ApprovalRequested

+ const ApprovalTimedOut

+ type BeginAutomaticThreadTitleRequest struct

+ Now time.Time

+ ThreadID string

+ Token string

+ type CancelApprovalBatchRequest struct

+ CancellationEntries []ApprovalCancellationEntry

+ CancellationFingerprint string

+ Lease TurnLease

+ Now time.Time

+ RunID string

+ type CancelApprovalBatchResult struct

+ Approvals []ApprovalRecord

+ CancellationEntries []Entry

+ Effects []EffectAttempt

+ Queue ApprovalQueue

+ Replayed bool

+ type CanonicalTurn struct

+ Entries []CanonicalTurnPathEntry

+ RetrySource *CanonicalTurnRetrySource

+ RunID string

+ StartedEntryID string

+ StartedOrdinal int64

+ TurnID string

+ type CanonicalTurnBeforeCursor struct

+ EntryID string

+ type CanonicalTurnPageRepo interface

+ ListCanonicalTurns func(context.Context, ListCanonicalTurnsOptions) (CanonicalTurnsPage, error)

+ type CanonicalTurnPathEntry struct

+ Entry Entry

+ Ordinal int64

+ type CanonicalTurnRepo interface

+ CanonicalTurnEntries func(context.Context, string, string, string) ([]Entry, bool, error)

+ type CanonicalTurnRetrySource struct

+ EntryID string

+ TurnID string

+ func CanonicalTurnRetrySourceForStartedEntry(entry Entry) (*CanonicalTurnRetrySource, error)

+ func ValidateCanonicalRetrySourceTurn(entries []Entry, threadID string, source CanonicalTurnRetrySource) (bool, *CanonicalTurnRetrySource, string, string, error)

+ type CanonicalTurnSinceCursor struct

+ EntryID string

+ type CanonicalTurnsPage struct

+ BeforeCursor *CanonicalTurnBeforeCursor

+ HasMore bool

+ HasRetryTarget bool

+ LatestTurnID string

+ SinceCursor CanonicalTurnSinceCursor

+ ThroughOrdinal int64

+ Turns []CanonicalTurn

+ type CommitApprovalDispatchRequest struct

+ ApprovedEntry Entry

+ AuthorizationProofHash string

+ DecisionID string

+ EffectAttemptID string

+ ExpectedApprovalRevision int64

+ ExpectedCurrent ApprovalIdentity

+ ExpectedGeneration int64

+ ExpectedRootThreadID string

+ Lease TurnLease

+ Now time.Time

+ type CommitApprovalDispatchResult struct

+ Approval ApprovalRecord

+ ApprovedEntry Entry

+ Effect EffectAttempt

+ Queue ApprovalQueue

+ Receipt ApprovalDecisionReceipt

+ Replayed bool

+ type CompleteAutomaticThreadTitleRequest struct

+ Generation int64

+ Now time.Time

+ ThreadID string

+ Title string

+ Token string

type ContextProjection

+ func BuildContextProjectionChecked(path []Entry, opts ContextProjectionOptions) (ContextProjection, error)

type Entry

+ PathDepth int64

+ func CanonicalTurnEntriesForRead(entries []Entry) []Entry

+ type FailAutomaticThreadTitleRequest struct

+ Error string

+ Generation int64

+ Now time.Time

+ ThreadID string

+ Token string

type FileRepo

+ func (r *FileRepo) BeginAutomaticThreadTitle(ctx context.Context, req BeginAutomaticThreadTitleRequest) (ThreadTitleMutationResult, error)

+ func (r *FileRepo) CanonicalTurnEntries(ctx context.Context, threadID, turnID, runID string) ([]Entry, bool, error)

+ func (r *FileRepo) CompleteAutomaticThreadTitle(ctx context.Context, req CompleteAutomaticThreadTitleRequest) (ThreadTitleMutationResult, error)

+ func (r *FileRepo) FailAutomaticThreadTitle(ctx context.Context, req FailAutomaticThreadTitleRequest) (ThreadTitleMutationResult, error)

+ func (r *FileRepo) ListCanonicalTurns(ctx context.Context, opts ListCanonicalTurnsOptions) (CanonicalTurnsPage, error)

+ func (r *FileRepo) PendingAutomaticThreadTitles(ctx context.Context) ([]ThreadMeta, error)

+ func (r *FileRepo) SetThreadTitle(ctx context.Context, req SetThreadTitleRequest) (ThreadTitleMutationResult, error)

+ type FinalizeApprovalRequest struct

+ ExpectedApprovalRevision int64

+ ExpectedCurrent ApprovalIdentity

+ ExpectedGeneration int64

+ ExpectedRootThreadID string

+ FinalizedEntry Entry

+ Now time.Time

+ Reason string

+ ResolutionID string

+ State ApprovalState

+ type FinalizeApprovalResult struct

+ Approval ApprovalRecord

+ Effect EffectAttempt

+ FinalizedEntry Entry

+ Queue ApprovalQueue

+ Receipt ApprovalDecisionReceipt

+ Replayed bool

+ type InterruptedTurnApprovalQueueProof struct

+ Generation int64

+ Revision int64

+ RootThreadID string

+ func InterruptedTurnApprovalQueueProofFromMetadata(metadata map[string]string) (*InterruptedTurnApprovalQueueProof, error)

+ type InterruptedTurnRecoveryEffect struct

+ EffectAttemptID string

+ State EffectAttemptState

+ ToolCallID string

+ func InterruptedTurnRecoveryEffects(attempts []EffectAttempt, committedFingerprint string) ([]InterruptedTurnRecoveryEffect, error)

+ type InterruptedTurnRecoveryFailureProof struct

+ EntryID string

+ Message string

+ RawHash string

+ func InterruptedTurnRecoverySourceFailureProofFromMetadata(metadata map[string]string) (*InterruptedTurnRecoveryFailureProof, error)

type InterruptedTurnRecoveryPlan

+ Effects []InterruptedTurnRecoveryEffect

+ FailureCode string

+ SourceFailure *InterruptedTurnRecoveryFailureProof

+ type ListCanonicalTurnsOptions struct

+ BeforeCursor *CanonicalTurnBeforeCursor

+ Limit int

+ SinceCursor *CanonicalTurnSinceCursor

+ Tail int

+ ThreadID string

type MemoryRepo

+ func (r *MemoryRepo) Approval(_ context.Context, approvalID string) (ApprovalRecord, error)

+ func (r *MemoryRepo) BeginAutomaticThreadTitle(ctx context.Context, req BeginAutomaticThreadTitleRequest) (ThreadTitleMutationResult, error)

+ func (r *MemoryRepo) CancelApprovalBatch(ctx context.Context, req CancelApprovalBatchRequest) (CancelApprovalBatchResult, error)

+ func (r *MemoryRepo) CanonicalTurnEntries(_ context.Context, threadID, turnID, runID string) ([]Entry, bool, error)

+ func (r *MemoryRepo) CommitApprovalDispatch(ctx context.Context, req CommitApprovalDispatchRequest) (CommitApprovalDispatchResult, error)

+ func (r *MemoryRepo) CompleteAutomaticThreadTitle(ctx context.Context, req CompleteAutomaticThreadTitleRequest) (ThreadTitleMutationResult, error)

+ func (r *MemoryRepo) FailAutomaticThreadTitle(ctx context.Context, req FailAutomaticThreadTitleRequest) (ThreadTitleMutationResult, error)

+ func (r *MemoryRepo) FinalizeApproval(_ context.Context, req FinalizeApprovalRequest) (FinalizeApprovalResult, error)

+ func (r *MemoryRepo) ListCanonicalTurns(_ context.Context, opts ListCanonicalTurnsOptions) (CanonicalTurnsPage, error)

+ func (r *MemoryRepo) PendingAutomaticThreadTitles(_ context.Context) ([]ThreadMeta, error)

+ func (r *MemoryRepo) PrepareApprovalBatch(_ context.Context, req PrepareApprovalBatchRequest) (PrepareApprovalBatchResult, error)

+ func (r *MemoryRepo) ReadApprovalQueue(_ context.Context, threadID string) (ApprovalQueue, error)

+ func (r *MemoryRepo) ReadTurnAdmission(_ context.Context, threadID, turnID, runID string) (AdmitTurnResult, bool, error)

+ func (r *MemoryRepo) ResolveApproval(_ context.Context, req ResolveApprovalRequest) (ResolveApprovalResult, error)

+ func (r *MemoryRepo) WaitApprovalDecision(ctx context.Context, approvalID string) (WaitApprovalDecisionResult, error)

+ type PrepareApprovalBatchRequest struct

+ Items []ApprovalPreflightItem

+ Lease TurnLease

+ Now time.Time

+ type PrepareApprovalBatchResult struct

+ Approvals []ApprovalRecord

+ Effects []EffectAttempt

+ Queue ApprovalQueue

+ Replayed bool

+ RequestedEntries []Entry

+ type ResolveApprovalRequest struct

+ Decision ApprovalDecision

+ DecisionID string

+ ExpectedApprovalRevision int64

+ ExpectedCurrent ApprovalIdentity

+ ExpectedGeneration int64

+ ExpectedRevision int64

+ ExpectedRootThreadID string

+ Now time.Time

+ RejectedEntry Entry

+ type ResolveApprovalResult struct

+ Approval ApprovalRecord

+ Effect EffectAttempt

+ Queue ApprovalQueue

+ Receipt ApprovalDecisionReceipt

+ RejectedEntry Entry

+ Replayed bool

type ThreadMeta

+ TitleGeneration int64

+ TitleToken string

type ThreadTitleAuthorityRepo

+ BeginAutomaticThreadTitle func(context.Context, BeginAutomaticThreadTitleRequest) (ThreadTitleMutationResult, error)

+ CompleteAutomaticThreadTitle func(context.Context, CompleteAutomaticThreadTitleRequest) (ThreadTitleMutationResult, error)

+ FailAutomaticThreadTitle func(context.Context, FailAutomaticThreadTitleRequest) (ThreadTitleMutationResult, error)

+ PendingAutomaticThreadTitles func(context.Context) ([]ThreadMeta, error)

+ type ThreadTitleMutationResult struct

+ Changed bool

+ Thread ThreadMeta

type ThreadTitleStatus

+ const ThreadTitlePending

type TurnAuthorityRepo

+ ReadTurnAdmission func(context.Context, string, string, string) (AdmitTurnResult, bool, error)

+ type TurnTerminalOutcome struct

+ Failure *Entry

+ Terminal Entry

+ type WaitApprovalDecisionResult struct

+ Approval ApprovalRecord

+ Queue ApprovalQueue

+ Receipt ApprovalDecisionReceipt

Jul 19, 2026

Changes in this version

+ var ErrRecoveryTargetResolved = errors.New("session tree interrupted recovery target is resolved")

+ func ValidateInterruptedTurnAdmissionPath(path []Entry, threadID, turnID, runID, turnStartedID string) error

+ func ValidateInterruptedTurnLeaseSuccessor(target, current TurnLease) error

+ func ValidateInterruptedTurnStartedEntry(entry Entry, threadID, turnID, runID, turnStartedID string) error

+ func ValidateThreadAuthoritySnapshot(meta ThreadMeta, path []Entry, lease *TurnLease, claimOperationID string, ...) error

+ type InterruptedTurnResolutionValidationRepo interface

+ ValidateInterruptedTurnResolution func(context.Context, RecoverInterruptedTurnRequest) error

type MemoryRepo

+ func (r *MemoryRepo) InspectSubAgentThreadAuthority(_ context.Context, parentThreadID, childThreadID string) (SubAgentThreadAuthoritySnapshot, error)

+ func (r *MemoryRepo) ValidateInterruptedTurnResolution(_ context.Context, req RecoverInterruptedTurnRequest) error

+ type SubAgentThreadAuthorityInspectionRepo interface

+ InspectSubAgentThreadAuthority func(context.Context, string, string) (SubAgentThreadAuthoritySnapshot, error)

+ type SubAgentThreadAuthoritySnapshot struct

+ Child ThreadAuthoritySnapshot

+ Parent ThreadMeta

type ThreadAuthoritySnapshot

+ LeaseGeneration int64

Jul 19, 2026

Changes in this version

+ const CompactionMutationKind

+ const InterruptedTurnFailureMessage

+ const InterruptedTurnRecoveryFingerprintKey

+ const InterruptedTurnRecoveryKind

+ const InterruptedTurnRecoveryKindKey

+ const InterruptedTurnRecoveryParentKey

+ const PendingToolEffectAttemptIDKey

+ const PendingToolSettlementFingerprintKey

+ const PendingToolSettlementKind

+ const PendingToolSettlementKindKey

+ var DefaultLeasePolicy = LeasePolicy

+ var ErrArtifactNotFound = errors.New("session tree artifact not found")

+ var ErrAuthorityCorrupt = errors.New("session tree authority state is corrupt")

+ var ErrEffectAttemptNotFound = errors.New("session tree effect attempt not found")

+ var ErrEffectOutcomeUnknown = errors.New("session tree effect outcome is unknown")

+ var ErrPendingToolNotFound = errors.New("session tree pending tool not found")

+ var ErrPendingToolNotPending = errors.New("session tree pending tool is not pending")

+ var ErrPendingToolRunNotFound = errors.New("session tree pending tool run not found")

+ var ErrPendingToolTurnNotFound = errors.New("session tree pending tool turn not found")

+ var ErrProviderStateNotFound = errors.New("provider state not found")

+ var ErrRequestConflict = errors.New("session tree authority request conflicts with persisted request")

+ var ErrStaleAuthority = errors.New("session tree authority proof is stale")

+ var ErrSubAgentClosing = errors.New("session tree subagent is closing")

+ var ErrSubAgentInputNotFound = errors.New("session tree subagent input not found")

+ var ErrSubAgentNotFound = errors.New("session tree subagent not found")

+ var ErrSubAgentParentRequired = errors.New("session tree subagent requires parent authority")

+ var ErrSubAgentRequestConflict = fmt.Errorf("subagent request identity conflicts with persisted request: %w", ...)

+ var ErrThreadAuthorityBusy = errors.New("session tree thread authority is busy")

+ var ErrThreadClosed = errors.New("session tree thread is closed")

+ var ErrThreadDeleted = errors.New("session tree thread is deleted")

+ var ErrUnsupportedStoreCapability = errors.New("session tree store capability is unsupported")

+ func ActivePathHash(path []Entry) string

+ func ContextWithTurnLease(ctx context.Context, lease TurnLease) context.Context

+ func CreateRootFingerprint(req CreateRootRequest) string

+ func CreateRootReplayMatches(meta ThreadMeta, threadID string) bool

+ func EffectResultRequestMatches(committed, requested Entry, effectAttemptID string) bool

+ func InterruptedTurnRecoveryFingerprint(expectedLease TurnLease, parentThreadID string, runID string, ...) (string, error)

+ func InterruptedTurnToolResult(call session.Message) session.Message

+ func NormalizeSubAgentCloseIntent(operationID, parentThreadID, targetThreadID, reason string) (string, string, string, string, string, error)

+ func PublishSubAgentChildMatches(req PublishSubAgentRequest, child ThreadMeta) bool

+ func SameTurnLease(left, right TurnLease) bool

+ func SubAgentCloseRequestFingerprint(intentFingerprint string, nodes []SubAgentCloseNode) (string, error)

+ func UpdateTurnLeaseContext(ctx context.Context, previous, renewed TurnLease) error

+ func ValidateAdmitPendingToolCompletionRequest(req AdmitPendingToolCompletionRequest) error

+ func ValidateBeginCompactionRequest(req BeginCompactionRequest) error

+ func ValidateCreateRootRequest(req CreateRootRequest) error

+ func ValidateForkPrepareState(rootThreadID string, nodes []ForkOptions, states []ForkPrepareThreadState) error

+ func ValidateInterruptedTurnRecoveryPath(path []Entry, turnID, runID string) error

+ func ValidatePendingToolCompletionPath(path []Entry) error

+ func ValidatePublishSubAgentIdentity(req PublishSubAgentRequest) error

+ func ValidatePublishSubAgentPendingToolCompletionRequest(req PublishSubAgentPendingToolCompletionRequest) error

+ func ValidatePublishSubAgentRequest(req PublishSubAgentRequest) error

+ func ValidateRecoverInterruptedTurnRequest(req RecoverInterruptedTurnRequest) error

+ func ValidateSetThreadTitleRequest(req SetThreadTitleRequest) error

+ func ValidateThreadAuthorityState(path []Entry, lease *TurnLease, claimOperationID string) error

+ type AdmitPendingToolCompletionRequest struct

+ CompletionRequestID string

+ ContinuationRunID string

+ ContinuationTurnID string

+ Input session.Message

+ Now time.Time

+ OwnerID string

+ RequestFingerprint string

+ Settlement Entry

+ SettlementFingerprint string

+ Target PendingToolSettlementTarget

+ type AdmitPendingToolCompletionResult struct

+ Admission AdmitTurnResult

+ Replayed bool

+ Settlement Entry

+ SettlementReplayed bool

+ type AdmitSubAgentInputRequest struct

+ ChildThreadID string

+ Now time.Time

+ OwnerID string

+ ParentThreadID string

+ RunID string

+ TurnID string

+ type AdmitSubAgentInputResult struct

+ Input SubAgentInputRecord

+ Lease TurnLease

+ Replayed bool

+ TurnStarted Entry

+ UserMessage Entry

+ type AdmitTurnRequest struct

+ Input session.Message

+ Now time.Time

+ OwnerID string

+ RequestFingerprint string

+ RetryLeafID string

+ RunID string

+ ThreadID string

+ TurnID string

+ type AdmitTurnResult struct

+ BaseLeafID string

+ BoundaryTerminal Entry

+ Lease TurnLease

+ Replayed bool

+ TurnStarted Entry

+ UserMessage Entry

+ type ArtifactAuthorityRepo interface

+ ArtifactClosure func(context.Context, ArtifactClosureRequest) (artifact.Closure, error)

+ ReadArtifact func(context.Context, ArtifactReadRequest) (ArtifactContent, error)

+ type ArtifactClosureRequest struct

+ DestinationThreadID string

+ EntryIDs []string

+ SourceThreadID string

+ type ArtifactContent struct

+ Ref artifact.Ref

+ Text string

+ type ArtifactReadRequest struct

+ ArtifactID string

+ ParentThreadID string

+ ThreadID string

+ type BeginCompactionRequest struct

+ ActivePathHash string

+ Now time.Time

+ OwnerID string

+ PromptIdentity string

+ RequestFingerprint string

+ RequestID string

+ RequestPayloadHash string

+ Source string

+ SourceLeafID string

+ SummarySchemaVersion string

+ ThreadID string

+ type BeginCompactionResult struct

+ Operation CompactionOperation

+ Owner bool

+ Replayed bool

+ TakeoverEligible bool

+ type BeginEffectDispatchRequest struct

+ AuthorizationProofHash string

+ EffectAttemptID string

+ Lease TurnLease

+ Now time.Time

+ ObservedHeartbeat int64

+ RequestFingerprint string

+ type CompactionAuthorityRepo interface

+ BeginCompaction func(context.Context, BeginCompactionRequest) (BeginCompactionResult, error)

+ FinishCompaction func(context.Context, FinishCompactionRequest) (FinishCompactionResult, error)

+ ReadCompaction func(context.Context, string, string) (CompactionOperation, bool, error)

+ TakeOverCompaction func(context.Context, TakeOverCompactionRequest) (BeginCompactionResult, error)

+ type CompactionOperation struct

+ ActivePathHash string

+ CreatedAt time.Time

+ ErrorCode string

+ ErrorMessage string

+ FinishedAt time.Time

+ FinishedGeneration int64

+ FinishedOwnerID string

+ Lease TurnLease

+ OutcomeFingerprint string

+ PromptIdentity string

+ RequestFingerprint string

+ RequestID string

+ RequestPayloadHash string

+ ResultEntryID string

+ Source string

+ SourceLeafID string

+ State CompactionOperationState

+ SummarySchemaVersion string

+ ThreadID string

+ UpdatedAt time.Time

+ type CompactionOperationState string

+ const CompactionOperationCompleted

+ const CompactionOperationFailed

+ const CompactionOperationPrepared

+ type CreateRootRequest struct

+ ContractVersion string

+ CreateIntentID string

+ Meta ThreadMeta

+ ThreadID string

+ type CreateRootResult struct

+ Replayed bool

+ Thread ThreadMeta

+ type DeleteRootTreeResult struct

+ Replayed bool

+ ThreadIDs []string

+ type EffectAttempt struct

+ CreatedAt time.Time

+ EffectAttemptID string

+ Generation int64

+ Invocation EffectInvocationIdentity

+ OwnerID string

+ RejectionCode string

+ RequestFingerprint string

+ ResultEntryID string

+ State EffectAttemptState

+ TerminalFingerprint string

+ UpdatedAt time.Time

+ type EffectAttemptAuthorityRepo interface

+ BeginEffectDispatch func(context.Context, BeginEffectDispatchRequest) (EffectAttempt, error)

+ FinishEffectDispatch func(context.Context, FinishEffectDispatchRequest) (FinishEffectDispatchResult, error)

+ MarkEffectUnknown func(context.Context, MarkEffectUnknownRequest) (EffectAttempt, error)

+ PrepareEffectAttempt func(context.Context, PrepareEffectAttemptRequest) (PrepareEffectAttemptResult, error)

+ RejectEffectAttempt func(context.Context, RejectEffectAttemptRequest) (EffectAttempt, error)

+ type EffectAttemptState string

+ const EffectAttemptCancelled

+ const EffectAttemptCompleted

+ const EffectAttemptDispatching

+ const EffectAttemptFailed

+ const EffectAttemptPrepared

+ const EffectAttemptRejected

+ const EffectAttemptUnknown

+ type EffectInvocationIdentity struct

+ ArgumentHash string

+ RunID string

+ ThreadID string

+ ToolCallID string

+ ToolName string

+ TurnID string

type Entry

+ func CompactionEntry(threadID, turnID string, result compaction.Result) (Entry, error)

+ func PrepareBranchBoundaryEntry(path []Entry, threadID, parentEntryID, entryID, reason string, now time.Time) (Entry, error)

+ func PrepareSubAgentCloseLifecycleEntry(operation SubAgentCloseOperation, threadID, parentEntryID, entryID string, ...) Entry

+ func UnresolvedInterruptedTurnCalls(path []Entry, turnID string) []Entry

type FileRepo

+ func (r *FileRepo) ArtifactClosure(context.Context, ArtifactClosureRequest) (artifact.Closure, error)

+ func (r *FileRepo) ReadArtifact(context.Context, ArtifactReadRequest) (ArtifactContent, error)

+ type FinishCompactionRequest struct

+ ErrorCode string

+ ErrorMessage string

+ Lease TurnLease

+ Now time.Time

+ OutcomeFingerprint string

+ RequestFingerprint string

+ RequestID string

+ Result *Entry

+ type FinishCompactionResult struct

+ Entry *Entry

+ Operation CompactionOperation

+ Replayed bool

+ type FinishEffectDispatchRequest struct

+ EffectAttemptID string

+ Failed bool

+ FullOutput *artifact.FullOutput

+ Lease TurnLease

+ Now time.Time

+ OutcomeFingerprint string

+ RequestFingerprint string

+ Result Entry

+ type FinishEffectDispatchResult struct

+ Artifact *artifact.Ref

+ Attempt EffectAttempt

+ Replayed bool

+ Result Entry

+ type FinishSubAgentCloseRequest struct

+ CloseOperationID string

+ Now time.Time

+ ParentThreadID string

+ Reason string

+ TargetThreadID string

+ type FinishSubAgentCloseResult struct

+ CancelledInputIDs []string

+ Entries []Entry

+ Operation SubAgentCloseOperation

+ Replayed bool

+ Threads []ThreadMeta

+ type FinishTurnRequest struct

+ ClearProviderState bool

+ FailureMessage string

+ Lease TurnLease

+ Metadata map[string]string

+ Now time.Time

+ OutcomeFingerprint string

+ ProviderState *ProviderStateRecord

+ RunID string

+ Status TurnMarkerStatus

+ TerminalEntryID string

+ type FinishTurnResult struct

+ Failure *Entry

+ Replayed bool

+ Terminal Entry

type ForkDestinationMeta

+ Lifecycle ThreadLifecycle

type ForkOptions

+ ArtifactClosure artifact.Closure

+ ExpectedSourceLeafID string

+ type ForkPrepareThreadState struct

+ Meta ThreadMeta

+ Path []Entry

+ PendingInputCount int

+ PinnedPath []Entry

+ type InterruptedTurnRecoveryPlan struct

+ FailureMessage string

+ OutcomeFingerprint string

+ RunID string

+ Status TurnMarkerStatus

+ TerminalEntryID string

+ func DeriveInterruptedTurnRecoveryPlan(path []Entry, expectedLease TurnLease, parentThreadID string) (InterruptedTurnRecoveryPlan, error)

+ type InterruptedTurnRecoveryRepo interface

+ RecoverInterruptedTurn func(context.Context, RecoverInterruptedTurnRequest) (RecoverInterruptedTurnResult, error)

+ type JournalRepo interface

+ Append func(context.Context, Entry, AppendOptions) (Entry, error)

+ Entries func(context.Context, string) ([]Entry, error)

+ Entry func(context.Context, string, string) (Entry, error)

+ Path func(context.Context, string, string) ([]Entry, error)

+ PathPage func(context.Context, string, string, string, int) (PathPage, error)

+ Thread func(context.Context, string) (ThreadMeta, error)

+ type LeasePolicy struct

+ ClockSkewAllowance time.Duration

+ RenewInterval time.Duration

+ TTL time.Duration

+ func (p LeasePolicy) Validate() error

+ type LeasePolicyRepo interface

+ AuthorityLeasePolicy func() LeasePolicy

+ type MarkEffectUnknownRequest struct

+ EffectAttemptID string

+ Lease TurnLease

+ Now time.Time

+ OutcomeFingerprint string

+ RequestFingerprint string

type MemoryRepo

+ func NewMemoryRepoWithLeasePolicy(policy LeasePolicy, now func() time.Time) (*MemoryRepo, error)

+ func (r *MemoryRepo) AcquireThreadAuthorityClaim(_ context.Context, operationID string, ...) error

+ func (r *MemoryRepo) AdmitPendingToolCompletion(_ context.Context, req AdmitPendingToolCompletionRequest) (AdmitPendingToolCompletionResult, error)

+ func (r *MemoryRepo) AdmitSubAgentInput(ctx context.Context, req AdmitSubAgentInputRequest) (AdmitSubAgentInputResult, error)

+ func (r *MemoryRepo) AdmitTurn(_ context.Context, req AdmitTurnRequest) (AdmitTurnResult, error)

+ func (r *MemoryRepo) ArtifactClosure(_ context.Context, req ArtifactClosureRequest) (artifact.Closure, error)

+ func (r *MemoryRepo) AuthorityLeasePolicy() LeasePolicy

+ func (r *MemoryRepo) BeginCompaction(_ context.Context, req BeginCompactionRequest) (BeginCompactionResult, error)

+ func (r *MemoryRepo) BeginEffectDispatch(_ context.Context, req BeginEffectDispatchRequest) (EffectAttempt, error)

+ func (r *MemoryRepo) CommitForkBatch(ctx context.Context, operationID string, nodes []ForkOptions, ...) ([]ThreadMeta, error)

+ func (r *MemoryRepo) CreateRoot(_ context.Context, req CreateRootRequest) (CreateRootResult, error)

+ func (r *MemoryRepo) CreateThreadWithInitialEntry(ctx context.Context, meta ThreadMeta, initial Entry) (ThreadMeta, Entry, error)

+ func (r *MemoryRepo) DeleteProviderState(ctx context.Context, threadID string) error

+ func (r *MemoryRepo) DeleteRootTree(_ context.Context, rootThreadID string) (DeleteRootTreeResult, error)

+ func (r *MemoryRepo) FailForkClaim(operationID string, sourceThreadIDs, authorityThreadIDs []string, ...) error

+ func (r *MemoryRepo) FinishCompaction(_ context.Context, req FinishCompactionRequest) (FinishCompactionResult, error)

+ func (r *MemoryRepo) FinishEffectDispatch(_ context.Context, req FinishEffectDispatchRequest) (FinishEffectDispatchResult, error)

+ func (r *MemoryRepo) FinishSubAgentClose(_ context.Context, req FinishSubAgentCloseRequest) (FinishSubAgentCloseResult, error)

+ func (r *MemoryRepo) FinishTurn(_ context.Context, req FinishTurnRequest) (FinishTurnResult, error)

+ func (r *MemoryRepo) ForkWithInitialEntry(ctx context.Context, opts ForkOptions, initial Entry) (ThreadMeta, Entry, error)

+ func (r *MemoryRepo) InspectThreadAuthority(_ context.Context, threadID string) (ThreadAuthoritySnapshot, error)

+ func (r *MemoryRepo) ListSubAgentInputs(_ context.Context, childThreadID string, state SubAgentInputState) ([]SubAgentInputRecord, error)

+ func (r *MemoryRepo) MarkEffectUnknown(_ context.Context, req MarkEffectUnknownRequest) (EffectAttempt, error)

+ func (r *MemoryRepo) PrepareEffectAttempt(_ context.Context, req PrepareEffectAttemptRequest) (PrepareEffectAttemptResult, error)

+ func (r *MemoryRepo) PrepareForkClaim(ctx context.Context, operationID, rootThreadID string, nodes []ForkOptions) error

+ func (r *MemoryRepo) PrepareSubAgentClose(_ context.Context, req PrepareSubAgentCloseRequest) (PrepareSubAgentCloseResult, error)

+ func (r *MemoryRepo) ProviderState(_ context.Context, threadID string) (ProviderStateRecord, error)

+ func (r *MemoryRepo) PublishSubAgent(_ context.Context, req PublishSubAgentRequest) (PublishSubAgentResult, error)

+ func (r *MemoryRepo) PublishSubAgentInput(_ context.Context, req PublishSubAgentInputRequest) (SubAgentInputRecord, bool, error)

+ func (r *MemoryRepo) PublishSubAgentPendingToolCompletion(_ context.Context, req PublishSubAgentPendingToolCompletionRequest) (PublishSubAgentPendingToolCompletionResult, error)

+ func (r *MemoryRepo) PutProviderState(ctx context.Context, record ProviderStateRecord) error

+ func (r *MemoryRepo) ReadArtifact(_ context.Context, req ArtifactReadRequest) (ArtifactContent, error)

+ func (r *MemoryRepo) ReadCompaction(_ context.Context, threadID, requestID string) (CompactionOperation, bool, error)

+ func (r *MemoryRepo) ReadPendingToolCompletion(_ context.Context, req AdmitPendingToolCompletionRequest) (AdmitPendingToolCompletionResult, bool, error)

+ func (r *MemoryRepo) RecoverInterruptedTurn(_ context.Context, req RecoverInterruptedTurnRequest) (RecoverInterruptedTurnResult, error)

+ func (r *MemoryRepo) RejectEffectAttempt(_ context.Context, req RejectEffectAttemptRequest) (EffectAttempt, error)

+ func (r *MemoryRepo) ReleaseThreadAuthorityClaim(_ context.Context, operationID string)

+ func (r *MemoryRepo) RenewTurnLease(_ context.Context, proof TurnLease) (TurnLease, error)

+ func (r *MemoryRepo) SetThreadTitle(ctx context.Context, req SetThreadTitleRequest) (SetThreadTitleResult, error)

+ func (r *MemoryRepo) SettlePendingToolRecovery(_ context.Context, req SettlePendingToolRecoveryRequest) (SettlePendingToolRecoveryResult, error)

+ func (r *MemoryRepo) TakeOverCompaction(_ context.Context, req TakeOverCompactionRequest) (BeginCompactionResult, error)

+ func (r *MemoryRepo) ThreadTombstone(_ context.Context, threadID string) (ThreadTombstone, error)

+ func (r *MemoryRepo) ValidateArtifactForkDestination(_ context.Context, closure artifact.Closure) error

+ type PendingToolCompletionAuthorityRepo interface

+ AdmitPendingToolCompletion func(context.Context, AdmitPendingToolCompletionRequest) (AdmitPendingToolCompletionResult, error)

+ ReadPendingToolCompletion func(context.Context, AdmitPendingToolCompletionRequest) (AdmitPendingToolCompletionResult, bool, error)

+ type PendingToolRecoveryRepo interface

+ SettlePendingToolRecovery func(context.Context, SettlePendingToolRecoveryRequest) (SettlePendingToolRecoveryResult, error)

+ type PendingToolSettlementTarget struct

+ EffectAttemptID string

+ Handle string

+ RunID string

+ ThreadID string

+ ToolCallID string

+ ToolName string

+ TurnID string

+ type PrepareEffectAttemptRequest struct

+ Invocation EffectInvocationIdentity

+ Lease TurnLease

+ Now time.Time

+ RequestFingerprint string

+ type PrepareEffectAttemptResult struct

+ Attempt EffectAttempt

+ Replayed bool

+ type PrepareSubAgentCloseRequest struct

+ CloseOperationID string

+ Now time.Time

+ ParentThreadID string

+ Reason string

+ TargetLease *TurnLease

+ TargetThreadID string

+ type PrepareSubAgentCloseResult struct

+ Operation SubAgentCloseOperation

+ Replayed bool

+ type ProviderStateReader interface

+ ProviderState func(context.Context, string) (ProviderStateRecord, error)

+ type ProviderStateRecord struct

+ CompatibilityKey string

+ CreatedByRunID string

+ CreatedByTurnID string

+ LeafEntryID string

+ State provider.State

+ ThreadID string

+ UpdatedAt time.Time

+ type ProviderStateStore interface

+ DeleteProviderState func(context.Context, string) error

+ PutProviderState func(context.Context, ProviderStateRecord) error

+ type PublishSubAgentInputRequest struct

+ ChildThreadID string

+ CorrelationLabels map[string]string

+ HostLabels map[string]string

+ InputRequestID string

+ Interrupt bool

+ Message session.Message

+ Now time.Time

+ ParentThreadID string

+ RequestFingerprint string

+ type PublishSubAgentPendingToolCompletionRequest struct

+ ChildThreadID string

+ CorrelationLabels map[string]string

+ HostLabels map[string]string

+ InputRequestID string

+ Message session.Message

+ Now time.Time

+ ParentThreadID string

+ RequestFingerprint string

+ Settlement Entry

+ SettlementFingerprint string

+ Target PendingToolSettlementTarget

+ type PublishSubAgentPendingToolCompletionResult struct

+ Input SubAgentInputRecord

+ Replayed bool

+ Settlement Entry

+ SettlementReplayed bool

+ type PublishSubAgentRequest struct

+ ArtifactClosure artifact.Closure

+ ChildMeta ThreadMeta

+ CorrelationLabels map[string]string

+ ForkOptions *ForkOptions

+ HostLabels map[string]string

+ Message session.Message

+ Now time.Time

+ ParentThreadID string

+ PublicationID string

+ RequestFingerprint string

+ type PublishSubAgentResult struct

+ Input SubAgentInputRecord

+ Replayed bool

+ Thread ThreadMeta

+ type RecoverInterruptedTurnRequest struct

+ ExpectedLease TurnLease

+ Now time.Time

+ ParentThreadID string

+ type RecoverInterruptedTurnResult struct

+ Failure *Entry

+ Generation int64

+ OutcomeFingerprint string

+ Replayed bool

+ RunID string

+ Status TurnMarkerStatus

+ Terminal Entry

+ ToolResults []Entry

+ type RejectEffectAttemptRequest struct

+ EffectAttemptID string

+ Lease TurnLease

+ Now time.Time

+ RejectionCode string

+ RejectionFingerprint string

+ RequestFingerprint string

+ type RootAuthorityRepo interface

+ CreateRoot func(context.Context, CreateRootRequest) (CreateRootResult, error)

+ DeleteRootTree func(context.Context, string) (DeleteRootTreeResult, error)

+ type SetThreadTitleRequest struct

+ Error string

+ Mode ThreadTitleMutationMode

+ Now time.Time

+ Source ThreadTitleSource

+ Status ThreadTitleStatus

+ ThreadID string

+ Title string

+ type SetThreadTitleResult struct

+ Changed bool

+ Thread ThreadMeta

+ type SettlePendingToolRecoveryRequest struct

+ Now time.Time

+ RequestFingerprint string

+ Settlement Entry

+ Target PendingToolSettlementTarget

+ type SettlePendingToolRecoveryResult struct

+ Entry Entry

+ Replayed bool

+ type SubAgentCloseAuthorityRepo interface

+ FinishSubAgentClose func(context.Context, FinishSubAgentCloseRequest) (FinishSubAgentCloseResult, error)

+ PrepareSubAgentClose func(context.Context, PrepareSubAgentCloseRequest) (PrepareSubAgentCloseResult, error)

+ type SubAgentCloseNode struct

+ ThreadID string

+ WasOpen bool

+ type SubAgentCloseOperation struct

+ CloseOperationID string

+ FinishedAt time.Time

+ IntentFingerprint string

+ Nodes []SubAgentCloseNode

+ ParentThreadID string

+ PreparedAt time.Time

+ Reason string

+ RequestFingerprint string

+ ResultEntryIDs []string

+ State SubAgentCloseState

+ TargetThreadID string

+ type SubAgentCloseState string

+ const SubAgentCloseCompleted

+ const SubAgentClosePrepared

+ type SubAgentInputAuthorityRepo interface

+ AdmitSubAgentInput func(context.Context, AdmitSubAgentInputRequest) (AdmitSubAgentInputResult, error)

+ ListSubAgentInputs func(context.Context, string, SubAgentInputState) ([]SubAgentInputRecord, error)

+ PublishSubAgent func(context.Context, PublishSubAgentRequest) (PublishSubAgentResult, error)

+ PublishSubAgentInput func(context.Context, PublishSubAgentInputRequest) (SubAgentInputRecord, bool, error)

+ PublishSubAgentPendingToolCompletion func(context.Context, PublishSubAgentPendingToolCompletionRequest) (PublishSubAgentPendingToolCompletionResult, error)

+ type SubAgentInputRecord struct

+ AdmittedAt time.Time

+ AdmittedRunID string

+ AdmittedTurnID string

+ CancelledAt time.Time

+ ChildThreadID string

+ CorrelationLabels map[string]string

+ CreatedAt time.Time

+ HostLabels map[string]string

+ Message session.Message

+ ParentThreadID string

+ RequestFingerprint string

+ RequestID string

+ RequestKind SubAgentRequestKind

+ Sequence int64

+ State SubAgentInputState

+ SubAgentInputID string

+ type SubAgentInputState string

+ const SubAgentInputAdmitted

+ const SubAgentInputCancelled

+ const SubAgentInputPending

+ type SubAgentRequestKind string

+ const SubAgentRequestInput

+ const SubAgentRequestPendingToolCompletion

+ const SubAgentRequestPublication

+ type TakeOverCompactionRequest struct

+ ExpectedLease TurnLease

+ Now time.Time

+ OwnerID string

+ RequestFingerprint string

+ RequestID string

+ ThreadID string

+ type ThreadAuthorityInspectionRepo interface

+ InspectThreadAuthority func(context.Context, string) (ThreadAuthoritySnapshot, error)

+ type ThreadAuthoritySnapshot struct

+ ClaimOperationID string

+ Lease *TurnLease

+ Thread ThreadMeta

+ type ThreadLifecycle string

+ const ThreadLifecycleClosed

+ const ThreadLifecycleClosing

+ const ThreadLifecycleDeleted

+ const ThreadLifecycleOpen

+ func (l ThreadLifecycle) Valid() bool

type ThreadMeta

+ CloseOperationID string

+ Lifecycle ThreadLifecycle

+ func (m ThreadMeta) CanonicalLifecycle() (ThreadLifecycle, error)

+ func (m ThreadMeta) IsClosed() bool

+ func (m ThreadMeta) IsClosing() bool

+ type ThreadPublishRepo interface

+ CreateThreadWithInitialEntry func(context.Context, ThreadMeta, Entry) (ThreadMeta, Entry, error)

+ ForkWithInitialEntry func(context.Context, ForkOptions, Entry) (ThreadMeta, Entry, error)

+ type ThreadTitleAuthorityRepo interface

+ SetThreadTitle func(context.Context, SetThreadTitleRequest) (SetThreadTitleResult, error)

+ type ThreadTitleMutationMode string

+ const ThreadTitleMutationAutomatic

+ const ThreadTitleMutationManual

+ type ThreadTombstone struct

+ CreateIntentID string

+ DeletedAt time.Time

+ ForkOperationID string

+ ForkOperationNodeID string

+ ForkedFromEntryID string

+ ForkedFromThreadID string

+ ParentThreadID string

+ RootThreadID string

+ ThreadID string

+ type ThreadTombstoneRepo interface

+ ThreadTombstone func(context.Context, string) (ThreadTombstone, error)

+ type TurnAuthorityRepo interface

+ AdmitTurn func(context.Context, AdmitTurnRequest) (AdmitTurnResult, error)

+ FinishTurn func(context.Context, FinishTurnRequest) (FinishTurnResult, error)

type TurnLease

+ AcquiredAt time.Time

+ ExpiresAt time.Time

+ Generation int64

+ Heartbeat int64

+ MutationID string

+ MutationKind string

+ Purpose TurnLeasePurpose

+ RenewedAt time.Time

+ func TurnLeaseFromContext(ctx context.Context) (TurnLease, bool)

+ func (l TurnLease) Fresh(now time.Time) bool

+ func (l TurnLease) TakeoverEligible(now time.Time, policy LeasePolicy) bool

+ func (l TurnLease) Validate() error

+ type TurnLeasePurpose string

+ const TurnLeasePurposeMutation

+ const TurnLeasePurposeTurn

+ func (p TurnLeasePurpose) Normalize() (TurnLeasePurpose, error)

type TurnLeaseRepo

+ RenewTurnLease func(context.Context, TurnLease) (TurnLease, error)

Jul 18, 2026

Changes in this version

+ var ErrInvalidThreadAuthority = errors.New("session tree invalid thread authority")

+ func MatchesForkDestinationMeta(meta ThreadMeta, destination *ForkDestinationMeta) bool

+ func SameThreadAuthority(left, right ThreadMeta) bool

+ func ThreadAuthorityTreeIDs(threads []ThreadMeta, rootThreadID string) ([]string, error)

+ func ValidateThreadAuthorityGraph(threads []ThreadMeta) error

+ func ValidateThreadMetaAuthority(meta ThreadMeta) error

+ type ForkDestinationMeta struct

+ AgentPath string

+ Closed bool

+ ForkMode string

+ HostProfileRef string

+ ParentThreadID string

+ ParentTurnID string

+ Status string

+ TaskDescription string

+ TaskName string

type ForkOptions

+ DestinationMeta *ForkDestinationMeta

Jul 18, 2026

Changes in this version

type FileRepo

+ func (r *FileRepo) PathPage(ctx context.Context, threadID, leafID, beforeEntryID string, limit int) (PathPage, error)

type MemoryRepo

+ func (r *MemoryRepo) PathPage(_ context.Context, threadID, leafID, beforeEntryID string, limit int) (PathPage, error)

+ type PathPage struct

+ Entries []Entry

+ HasMore bool

+ NewestOrdinal int64

+ NextEntryID string

type Repo

+ PathPage func(context.Context, string, string, string, int) (PathPage, error)

Jul 17, 2026

Changes in this version

+ var ErrAgentTodoVersionConflict = errors.New("session tree agent todo version conflict")

+ type AgentTodoItem struct

+ Content string

+ ID string

+ Status AgentTodoStatus

+ type AgentTodoState struct

+ Items []AgentTodoItem

+ ThreadID string

+ UpdatedAt time.Time

+ UpdatedByRunID string

+ UpdatedByToolCall string

+ UpdatedByTurnID string

+ Version int64

+ type AgentTodoStateRepo interface

+ CompareAndSwapAgentTodoState func(context.Context, AgentTodoState, int64) (AgentTodoState, error)

+ ReadAgentTodoState func(context.Context, string) (AgentTodoState, error)

+ type AgentTodoStatus string

+ const AgentTodoCompleted

+ const AgentTodoInProgress

+ const AgentTodoPending

type Entry

+ func AppendTurnMarkerWithID(ctx context.Context, repo Repo, threadID, turnID, entryID string, ...) (Entry, error)

type FileRepo

+ func (r *FileRepo) CompareAndSwapAgentTodoState(ctx context.Context, state AgentTodoState, expectedVersion int64) (AgentTodoState, error)

+ func (r *FileRepo) ReadAgentTodoState(ctx context.Context, threadID string) (AgentTodoState, error)

type MemoryRepo

+ func (r *MemoryRepo) CompareAndSwapAgentTodoState(_ context.Context, state AgentTodoState, expectedVersion int64) (AgentTodoState, error)

+ func (r *MemoryRepo) ReadAgentTodoState(_ context.Context, threadID string) (AgentTodoState, error)

Jul 17, 2026

Changes in this version

type Entry

+ CompactionOperationID string

+ CompactionRequestID string

+ CompactionSource string

+ type ForkEntryIdentity struct

+ DestinationThreadID string

+ RunIDMap map[string]string

+ SourceThreadID string

+ TurnIDMap map[string]string

type ForkOptions

+ RewriteEntry func(Entry, ForkEntryIdentity) (Entry, error)

Jul 15, 2026

Changes in this version

+ var ErrForkDestinationConflict = errors.New("session tree fork destination conflicts with operation marker")

type ForkOptions

+ EntryIDPinned bool

+ OperationID string

+ OperationNodeID string

type ThreadMeta

+ ForkOperationID string

+ ForkOperationNodeID string

Jul 6, 2026

Changes in this version

type ForkOptions

+ RunIDMap map[string]string

+ TurnIDMap map[string]string

Jul 1, 2026

Changes in this version

type ThreadMeta

+ TaskDescription string

Jun 29, 2026

Changes in this version

type Entry

+ func AppendMessageAt(ctx context.Context, repo Repo, threadID, turnID string, msg session.Message, ...) (Entry, error)

Jun 28, 2026

Changes in this version

type ThreadMeta

+ ForkMode string

Jun 23, 2026

Changes in this version

type ThreadMeta

+ AgentPath string

+ Closed bool

+ HostProfileRef string

+ ParentTurnID string

+ TaskName string

Jun 13, 2026

Changes in this version

type ThreadMeta

+ LastViewedAt time.Time

+ Status string

Jun 11, 2026

Changes in this version

+ var ErrActiveTurn = errors.New("session tree thread already has an active turn")

+ var ErrEntryNotFound = errors.New("session tree entry not found")

+ var ErrInvalidParent = errors.New("session tree invalid parent")

+ var ErrThreadExists = errors.New("session tree thread already exists")

+ var ErrThreadNotFound = errors.New("session tree thread not found")

+ func BuildContext(path []Entry, opts ContextOptions) []session.Message

+ func RawForEntry(entry Entry) string

+ func SortThreadsByCreatedAtDesc(threads []ThreadMeta)

+ func StableHash(value string) string

+ type AppendCommittedError struct

+ Err error

+ func (e AppendCommittedError) Error() string

+ func (e AppendCommittedError) Unwrap() error

+ type AppendOptions struct

+ ID string

+ Now time.Time

+ ParentID string

+ type ContextOptions struct

+ type ContextProjection struct

+ Messages []session.Message

+ Segments []ProjectedSegment

+ func BuildContextProjection(path []Entry, opts ContextProjectionOptions) ContextProjection

+ type ContextProjectionOptions struct

+ Purpose ProjectionPurpose

+ type Entry struct

+ CompactedThroughEntryID string

+ CompactionGeneration int

+ CompactionID string

+ CompactionPhase string

+ CompactionReason string

+ CompactionTrigger string

+ CompactionWindowID string

+ ContextUsageAfter contextpolicy.Usage

+ ContextUsageBefore contextpolicy.Usage

+ CreatedAt time.Time

+ Error string

+ FirstKeptEntryID string

+ ID string

+ KeptUserEntryIDs []string

+ Message session.Message

+ Metadata map[string]string

+ Model string

+ ParentID string

+ PreviousCompactionID string

+ Provider string

+ Raw string

+ RawHash string

+ Summary string

+ SummarySchemaVersion string

+ ThreadID string

+ TokensAfterEstimate int64

+ TokensBefore int64

+ TurnID string

+ TurnStatus TurnMarkerStatus

+ Type EntryType

+ func AppendActiveTools(ctx context.Context, repo Repo, threadID string, metadata map[string]string) (Entry, error)

+ func AppendCompaction(ctx context.Context, repo Repo, threadID, turnID string, ...) (Entry, error)

+ func AppendFailure(ctx context.Context, repo Repo, threadID, turnID, message string) (Entry, error)

+ func AppendMessage(ctx context.Context, repo Repo, threadID, turnID string, msg session.Message) (Entry, error)

+ func AppendTurnMarker(ctx context.Context, repo Repo, threadID, turnID string, ...) (Entry, error)

+ func PrepareEntry(entry Entry) Entry

+ type EntryType string

+ const EntryActiveTools

+ const EntryAssistantMessage

+ const EntryBranchSummary

+ const EntryCompaction

+ const EntryCustom

+ const EntryModelChange

+ const EntryRunFailure

+ const EntryThreadInfo

+ const EntryToolCall

+ const EntryToolResult

+ const EntryTurnMarker

+ const EntryUserMessage

+ type FileRepo struct

+ func NewFileRepo(root string) *FileRepo

+ func (r *FileRepo) AcquireTurnLease(ctx context.Context, lease TurnLease) error

+ func (r *FileRepo) ActiveTurnLease(ctx context.Context, threadID string) (TurnLease, bool, error)

+ func (r *FileRepo) Append(ctx context.Context, entry Entry, opts AppendOptions) (Entry, error)

+ func (r *FileRepo) ClearExpiredTurnLease(ctx context.Context, threadID string, cutoff time.Time) (TurnLease, bool, error)

+ func (r *FileRepo) CreateThread(ctx context.Context, meta ThreadMeta) (ThreadMeta, error)

+ func (r *FileRepo) DeleteThread(ctx context.Context, threadID string) error

+ func (r *FileRepo) Entries(ctx context.Context, threadID string) ([]Entry, error)

+ func (r *FileRepo) Entry(ctx context.Context, threadID, entryID string) (Entry, error)

+ func (r *FileRepo) Fork(ctx context.Context, opts ForkOptions) (ThreadMeta, error)

+ func (r *FileRepo) ListThreads(ctx context.Context, opts ListThreadsOptions) ([]ThreadMeta, error)

+ func (r *FileRepo) MoveLeaf(ctx context.Context, threadID, entryID string) error

+ func (r *FileRepo) Path(ctx context.Context, threadID, leafID string) ([]Entry, error)

+ func (r *FileRepo) ReleaseTurnLease(ctx context.Context, lease TurnLease) error

+ func (r *FileRepo) Thread(ctx context.Context, threadID string) (ThreadMeta, error)

+ func (r *FileRepo) UpdateThread(ctx context.Context, meta ThreadMeta) error

+ type ForkOptions struct

+ EntryID string

+ NewThreadID string

+ Now time.Time

+ Position ForkPosition

+ SourceThreadID string

+ type ForkPosition string

+ const ForkAt

+ const ForkBefore

+ type ListThreadsOptions struct

+ AfterCreatedAt time.Time

+ AfterID string

+ IncludeArchived bool

+ Limit int

+ type MemoryRepo struct

+ func NewMemoryRepo() *MemoryRepo

+ func (r *MemoryRepo) AcquireTurnLease(_ context.Context, lease TurnLease) error

+ func (r *MemoryRepo) ActiveTurnLease(_ context.Context, threadID string) (TurnLease, bool, error)

+ func (r *MemoryRepo) Append(_ context.Context, entry Entry, opts AppendOptions) (Entry, error)

+ func (r *MemoryRepo) ClearExpiredTurnLease(_ context.Context, threadID string, cutoff time.Time) (TurnLease, bool, error)

+ func (r *MemoryRepo) CreateThread(_ context.Context, meta ThreadMeta) (ThreadMeta, error)

+ func (r *MemoryRepo) DeleteThread(_ context.Context, threadID string) error

+ func (r *MemoryRepo) Entries(_ context.Context, threadID string) ([]Entry, error)

+ func (r *MemoryRepo) Entry(_ context.Context, threadID, entryID string) (Entry, error)

+ func (r *MemoryRepo) Fork(ctx context.Context, opts ForkOptions) (ThreadMeta, error)

+ func (r *MemoryRepo) ListThreads(_ context.Context, opts ListThreadsOptions) ([]ThreadMeta, error)

+ func (r *MemoryRepo) MoveLeaf(_ context.Context, threadID, entryID string) error

+ func (r *MemoryRepo) Path(_ context.Context, threadID, leafID string) ([]Entry, error)

+ func (r *MemoryRepo) ReleaseTurnLease(_ context.Context, lease TurnLease) error

+ func (r *MemoryRepo) Thread(_ context.Context, threadID string) (ThreadMeta, error)

+ func (r *MemoryRepo) UpdateThread(_ context.Context, meta ThreadMeta) error

+ type ProjectedSegment struct

+ ArtifactRefs []artifact.Ref

+ EntryID string

+ EntryType EntryType

+ MessageIndex int

+ Role session.Role

+ TokenEstimate int64

+ ToolCallID string

+ ToolName string

+ UIPreview string

+ type ProjectionPurpose string

+ const ProjectionCompaction

+ const ProjectionProviderRequest

+ const ProjectionTestUI

+ type Repo interface

+ Append func(context.Context, Entry, AppendOptions) (Entry, error)

+ CreateThread func(context.Context, ThreadMeta) (ThreadMeta, error)

+ DeleteThread func(context.Context, string) error

+ Entries func(context.Context, string) ([]Entry, error)

+ Entry func(context.Context, string, string) (Entry, error)

+ Fork func(context.Context, ForkOptions) (ThreadMeta, error)

+ MoveLeaf func(context.Context, string, string) error

+ Path func(context.Context, string, string) ([]Entry, error)

+ Thread func(context.Context, string) (ThreadMeta, error)

+ UpdateThread func(context.Context, ThreadMeta) error

+ type ThreadListRepo interface

+ ListThreads func(context.Context, ListThreadsOptions) ([]ThreadMeta, error)

+ type ThreadMeta struct

+ Archived bool

+ CreatedAt time.Time

+ ForkedFromEntryID string

+ ForkedFromThreadID string

+ ID string

+ LeafID string

+ ParentThreadID string

+ Title string

+ TitleError string

+ TitleSource ThreadTitleSource

+ TitleStatus ThreadTitleStatus

+ TitleUpdatedAt time.Time

+ UpdatedAt time.Time

+ func ApplyThreadListOptions(threads []ThreadMeta, opts ListThreadsOptions) []ThreadMeta

+ func ListThreads(ctx context.Context, repo Repo, opts ListThreadsOptions) ([]ThreadMeta, error)

+ type ThreadTitleSource string

+ const ThreadTitleSourceHost

+ const ThreadTitleSourceProvider

+ type ThreadTitleStatus string

+ const ThreadTitleFailed

+ const ThreadTitleReady

+ type TurnLease struct

+ CreatedAt time.Time

+ OwnerID string

+ ThreadID string

+ TurnID string

+ type TurnLeaseRepo interface

+ AcquireTurnLease func(context.Context, TurnLease) error

+ ActiveTurnLease func(context.Context, string) (TurnLease, bool, error)

+ ClearExpiredTurnLease func(context.Context, string, time.Time) (TurnLease, bool, error)

+ ReleaseTurnLease func(context.Context, TurnLease) error

+ type TurnMarkerStatus string

+ const TurnAborted

+ const TurnCompleted

+ const TurnFailed

+ const TurnSavePoint

+ const TurnStarted

+ const TurnWaiting