sqlite

package
v0.22.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 21, 2026 License: MIT Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CanonicalDatabasePath added in v0.20.0 

func CanonicalDatabasePath(path string) (string, error)

func DefaultTestUIPath 

func DefaultTestUIPath(root string) string

Types

type Option 

type Option func(*options)

func WithAuthorityClock added in v0.18.0 

func WithAuthorityClock(now func() time.Time) Option

func WithLeasePolicy added in v0.18.0 

func WithLeasePolicy(policy sessiontree.LeasePolicy) Option

type Store 

type Store struct {
	// contains filtered or unexported fields
}

func Open 

func Open(path string, opts ...Option) (*Store, error)

func (*Store) AcquireTurnLease 

func (s *Store) AcquireTurnLease(ctx context.Context, request sessiontree.TurnLease) (sessiontree.TurnLease, error)

func (*Store) ActiveToolset 

func (s *Store) ActiveToolset(ctx context.Context, promptScopeID, provider, model string) (cache.ToolsetSnapshot, bool, error)

func (*Store) ActiveTurnLease 

func (s *Store) ActiveTurnLease(ctx context.Context, threadID string) (sessiontree.TurnLease, bool, error)

func (*Store) AdmitPendingToolCompletion added in v0.18.0 

func (s *Store) AdmitPendingToolCompletion(ctx context.Context, req sessiontree.AdmitPendingToolCompletionRequest) (sessiontree.AdmitPendingToolCompletionResult, error)

func (*Store) AdmitSubAgentInput added in v0.18.0 

func (s *Store) AdmitSubAgentInput(ctx context.Context, req sessiontree.AdmitSubAgentInputRequest) (sessiontree.AdmitSubAgentInputResult, error)

func (*Store) AdmitTurn added in v0.18.0 

func (s *Store) AdmitTurn(ctx context.Context, req sessiontree.AdmitTurnRequest) (sessiontree.AdmitTurnResult, error)

func (*Store) Append 

func (s *Store) Append(ctx context.Context, entry sessiontree.Entry, opts sessiontree.AppendOptions) (sessiontree.Entry, error)

func (*Store) AppendProviderRequest 

func (s *Store) AppendProviderRequest(ctx context.Context, req cache.ProviderRequestRecord) error

func (*Store) AppendProviderResponse 

func (s *Store) AppendProviderResponse(ctx context.Context, resp cache.ProviderResponseRecord) error

func (*Store) AppendSegment 

func (s *Store) AppendSegment(ctx context.Context, seg cache.Segment) error

func (*Store) AppendToolset 

func (s *Store) AppendToolset(ctx context.Context, snap cache.ToolsetSnapshot) error

func (*Store) Approval added in v0.20.0 

func (s *Store) Approval(ctx context.Context, approvalID string) (sessiontree.ApprovalRecord, error)

func (*Store) ArtifactClosure added in v0.18.0 

func (s *Store) ArtifactClosure(ctx context.Context, req sessiontree.ArtifactClosureRequest) (artifact.Closure, error)

func (*Store) AuthorityLeasePolicy added in v0.18.0 

func (s *Store) AuthorityLeasePolicy() sessiontree.LeasePolicy

func (*Store) BeginAutomaticThreadTitle added in v0.20.0 

func (s *Store) BeginAutomaticThreadTitle(ctx context.Context, req sessiontree.BeginAutomaticThreadTitleRequest) (sessiontree.ThreadTitleMutationResult, error)

func (*Store) BeginCompaction added in v0.18.0 

func (s *Store) BeginCompaction(ctx context.Context, req sessiontree.BeginCompactionRequest) (sessiontree.BeginCompactionResult, error)

func (*Store) BeginEffectDispatch added in v0.18.0 

func (s *Store) BeginEffectDispatch(ctx context.Context, req sessiontree.BeginEffectDispatchRequest) (sessiontree.EffectAttempt, error)

func (*Store) CancelApprovalBatch added in v0.20.0 

func (s *Store) CancelApprovalBatch(ctx context.Context, req sessiontree.CancelApprovalBatchRequest) (sessiontree.CancelApprovalBatchResult, error)

func (*Store) CanonicalTurnEntries added in v0.20.0 

func (s *Store) CanonicalTurnEntries(ctx context.Context, threadID, turnID, runID string) ([]sessiontree.Entry, bool, error)

func (*Store) Close 

func (s *Store) Close() error

func (*Store) CommitApprovalDispatch added in v0.20.0 

func (s *Store) CommitApprovalDispatch(ctx context.Context, req sessiontree.CommitApprovalDispatchRequest) (sessiontree.CommitApprovalDispatchResult, error)

func (*Store) CommitForkOperation added in v0.18.0 

func (s *Store) CommitForkOperation(ctx context.Context, req storage.ForkOperationCommitRequest) (storage.ForkOperationRecord, bool, error)

func (*Store) CompareAndSwapAgentTodoState added in v0.11.0 

func (s *Store) CompareAndSwapAgentTodoState(ctx context.Context, state sessiontree.AgentTodoState, expectedVersion int64) (sessiontree.AgentTodoState, error)

func (*Store) CompleteAutomaticThreadTitle added in v0.20.0 

func (s *Store) CompleteAutomaticThreadTitle(ctx context.Context, req sessiontree.CompleteAutomaticThreadTitleRequest) (sessiontree.ThreadTitleMutationResult, error)

func (*Store) CreateRoot added in v0.18.0 

func (s *Store) CreateRoot(ctx context.Context, req sessiontree.CreateRootRequest) (sessiontree.CreateRootResult, error)

func (*Store) CreateThread 

func (s *Store) CreateThread(ctx context.Context, meta sessiontree.ThreadMeta) (sessiontree.ThreadMeta, error)

func (*Store) CreateThreadWithInitialEntry added in v0.18.0 

func (s *Store) CreateThreadWithInitialEntry(ctx context.Context, meta sessiontree.ThreadMeta, initial sessiontree.Entry) (sessiontree.ThreadMeta, sessiontree.Entry, error)

func (*Store) DBPath 

func (s *Store) DBPath() string

func (*Store) DeleteMetadata 

func (s *Store) DeleteMetadata(ctx context.Context, namespace, id string) error

func (*Store) DeletePromptScopes 

func (s *Store) DeletePromptScopes(ctx context.Context, promptScopeIDs ...string) error

func (*Store) DeleteProviderState added in v0.10.0 

func (s *Store) DeleteProviderState(ctx context.Context, threadID string) error

func (*Store) DeleteRootTree added in v0.18.0 

func (s *Store) DeleteRootTree(ctx context.Context, rootThreadID string) (sessiontree.DeleteRootTreeResult, error)

func (*Store) DeleteThread 

func (s *Store) DeleteThread(ctx context.Context, threadID string) error

func (*Store) DeleteThreadArtifacts 

func (s *Store) DeleteThreadArtifacts(ctx context.Context, threadID string) error

func (*Store) Entries 

func (s *Store) Entries(ctx context.Context, threadID string) ([]sessiontree.Entry, error)

func (*Store) Entry 

func (s *Store) Entry(ctx context.Context, threadID, entryID string) (sessiontree.Entry, error)

func (*Store) FailAutomaticThreadTitle added in v0.20.0 

func (s *Store) FailAutomaticThreadTitle(ctx context.Context, req sessiontree.FailAutomaticThreadTitleRequest) (sessiontree.ThreadTitleMutationResult, error)

func (*Store) FailForkOperation added in v0.18.0 

func (s *Store) FailForkOperation(ctx context.Context, req storage.ForkOperationFailureRequest) (storage.ForkOperationRecord, bool, error)

func (*Store) FinalizeApproval added in v0.20.0 

func (s *Store) FinalizeApproval(ctx context.Context, req sessiontree.FinalizeApprovalRequest) (sessiontree.FinalizeApprovalResult, error)

func (*Store) FinishCompaction added in v0.18.0 

func (s *Store) FinishCompaction(ctx context.Context, req sessiontree.FinishCompactionRequest) (sessiontree.FinishCompactionResult, error)

func (*Store) FinishEffectDispatch added in v0.18.0 

func (s *Store) FinishEffectDispatch(ctx context.Context, req sessiontree.FinishEffectDispatchRequest) (sessiontree.FinishEffectDispatchResult, error)

func (*Store) FinishSubAgentClose added in v0.18.0 

func (s *Store) FinishSubAgentClose(ctx context.Context, req sessiontree.FinishSubAgentCloseRequest) (sessiontree.FinishSubAgentCloseResult, error)

func (*Store) FinishTurn added in v0.18.0 

func (s *Store) FinishTurn(ctx context.Context, req sessiontree.FinishTurnRequest) (sessiontree.FinishTurnResult, error)

func (*Store) Fork 

func (s *Store) Fork(ctx context.Context, opts sessiontree.ForkOptions) (sessiontree.ThreadMeta, error)

func (*Store) ForkOperation added in v0.5.0 

func (s *Store) ForkOperation(ctx context.Context, operationID string) (storage.ForkOperationRecord, error)

func (*Store) ForkWithInitialEntry added in v0.18.0 

func (s *Store) ForkWithInitialEntry(ctx context.Context, opts sessiontree.ForkOptions, initial sessiontree.Entry) (sessiontree.ThreadMeta, sessiontree.Entry, error)

func (*Store) InspectSubAgentThreadAuthority added in v0.19.0 

func (s *Store) InspectSubAgentThreadAuthority(ctx context.Context, parentThreadID, childThreadID string) (sessiontree.SubAgentThreadAuthoritySnapshot, error)

func (*Store) InspectThreadAuthority added in v0.18.0 

func (s *Store) InspectThreadAuthority(ctx context.Context, threadID string) (sessiontree.ThreadAuthoritySnapshot, error)

func (*Store) LatestPressureAnchor 

func (s *Store) LatestPressureAnchor(ctx context.Context, promptScopeID, providerName, model string) (cache.PressureAnchorState, bool, error)

func (*Store) ListCanonicalTurns added in v0.20.0 

func (s *Store) ListCanonicalTurns(ctx context.Context, opts sessiontree.ListCanonicalTurnsOptions) (sessiontree.CanonicalTurnsPage, error)

func (*Store) ListMetadata 

func (s *Store) ListMetadata(ctx context.Context, namespace string) ([]storage.MetadataRecord, error)

func (*Store) ListSubAgentInputs added in v0.18.0 

func (s *Store) ListSubAgentInputs(ctx context.Context, childThreadID string, state sessiontree.SubAgentInputState) ([]sessiontree.SubAgentInputRecord, error)

func (*Store) ListThreads 

func (s *Store) ListThreads(ctx context.Context, opts sessiontree.ListThreadsOptions) ([]sessiontree.ThreadMeta, error)

func (*Store) MarkEffectUnknown added in v0.18.0 

func (s *Store) MarkEffectUnknown(ctx context.Context, req sessiontree.MarkEffectUnknownRequest) (sessiontree.EffectAttempt, error)

func (*Store) Metadata 

func (s *Store) Metadata(ctx context.Context, namespace, id string) (storage.MetadataRecord, error)

func (*Store) MoveLeaf 

func (s *Store) MoveLeaf(ctx context.Context, threadID, entryID string) error

func (*Store) Path 

func (s *Store) Path(ctx context.Context, threadID, leafID string) ([]sessiontree.Entry, error)

func (*Store) PathPage added in v0.11.4 

func (s *Store) PathPage(ctx context.Context, threadID, leafID, beforeEntryID string, limit int) (sessiontree.PathPage, error)

func (*Store) PendingAutomaticThreadTitles added in v0.20.0 

func (s *Store) PendingAutomaticThreadTitles(ctx context.Context) ([]sessiontree.ThreadMeta, error)

func (*Store) PrepareApprovalBatch added in v0.20.0 

func (s *Store) PrepareApprovalBatch(ctx context.Context, req sessiontree.PrepareApprovalBatchRequest) (sessiontree.PrepareApprovalBatchResult, error)

func (*Store) PrepareEffectAttempt added in v0.18.0 

func (s *Store) PrepareEffectAttempt(ctx context.Context, req sessiontree.PrepareEffectAttemptRequest) (sessiontree.PrepareEffectAttemptResult, error)

func (*Store) PrepareForkOperation added in v0.5.0 

func (s *Store) PrepareForkOperation(ctx context.Context, rec storage.ForkOperationRecord) (storage.ForkOperationRecord, bool, error)

func (*Store) PrepareSubAgentClose added in v0.18.0 

func (s *Store) PrepareSubAgentClose(ctx context.Context, req sessiontree.PrepareSubAgentCloseRequest) (sessiontree.PrepareSubAgentCloseResult, error)

func (*Store) ProviderRequests 

func (s *Store) ProviderRequests(ctx context.Context, promptScopeID string) ([]cache.ProviderRequestRecord, error)

func (*Store) ProviderResponses 

func (s *Store) ProviderResponses(ctx context.Context, promptScopeID string) ([]cache.ProviderResponseRecord, error)

func (*Store) ProviderState added in v0.10.0 

func (s *Store) ProviderState(ctx context.Context, threadID string) (sessiontree.ProviderStateRecord, error)

func (*Store) PublishSubAgent added in v0.18.0 

func (s *Store) PublishSubAgent(ctx context.Context, req sessiontree.PublishSubAgentRequest) (sessiontree.PublishSubAgentResult, error)

func (*Store) PublishSubAgentInput added in v0.18.0 

func (s *Store) PublishSubAgentInput(ctx context.Context, req sessiontree.PublishSubAgentInputRequest) (sessiontree.SubAgentInputRecord, bool, error)

func (*Store) PublishSubAgentPendingToolCompletion added in v0.18.0 

func (s *Store) PublishSubAgentPendingToolCompletion(ctx context.Context, req sessiontree.PublishSubAgentPendingToolCompletionRequest) (sessiontree.PublishSubAgentPendingToolCompletionResult, error)

func (*Store) PutMetadata 

func (s *Store) PutMetadata(ctx context.Context, rec storage.MetadataRecord) error

func (*Store) PutProviderState added in v0.10.0 

func (s *Store) PutProviderState(ctx context.Context, record sessiontree.ProviderStateRecord) error

func (*Store) ReadAgentTodoState added in v0.11.0 

func (s *Store) ReadAgentTodoState(ctx context.Context, threadID string) (sessiontree.AgentTodoState, error)

func (*Store) ReadApprovalQueue added in v0.20.0 

func (s *Store) ReadApprovalQueue(ctx context.Context, threadID string) (sessiontree.ApprovalQueue, error)

func (*Store) ReadArtifact added in v0.18.0 

func (s *Store) ReadArtifact(ctx context.Context, req sessiontree.ArtifactReadRequest) (sessiontree.ArtifactContent, error)

func (*Store) ReadCompaction added in v0.18.0 

func (s *Store) ReadCompaction(ctx context.Context, threadID, requestID string) (sessiontree.CompactionOperation, bool, error)

func (*Store) ReadPendingToolCompletion added in v0.18.0 

func (s *Store) ReadPendingToolCompletion(ctx context.Context, req sessiontree.AdmitPendingToolCompletionRequest) (sessiontree.AdmitPendingToolCompletionResult, bool, error)

func (*Store) ReadTurnAdmission added in v0.20.0 

func (s *Store) ReadTurnAdmission(ctx context.Context, threadID, turnID, runID string) (sessiontree.AdmitTurnResult, bool, error)

func (*Store) RecoverInterruptedTurn added in v0.18.0 

func (s *Store) RecoverInterruptedTurn(ctx context.Context, req sessiontree.RecoverInterruptedTurnRequest) (sessiontree.RecoverInterruptedTurnResult, error)

func (*Store) RejectEffectAttempt added in v0.18.0 

func (s *Store) RejectEffectAttempt(ctx context.Context, req sessiontree.RejectEffectAttemptRequest) (sessiontree.EffectAttempt, error)

func (*Store) ReleaseTurnLease 

func (s *Store) ReleaseTurnLease(ctx context.Context, proof sessiontree.TurnLease) error

func (*Store) RenewTurnLease added in v0.18.0 

func (s *Store) RenewTurnLease(ctx context.Context, proof sessiontree.TurnLease) (sessiontree.TurnLease, error)

func (*Store) ResolveApproval added in v0.20.0 

func (s *Store) ResolveApproval(ctx context.Context, req sessiontree.ResolveApprovalRequest) (sessiontree.ResolveApprovalResult, error)

func (*Store) SchemaVersion 

func (s *Store) SchemaVersion(ctx context.Context) (string, error)

func (*Store) Segments 

func (s *Store) Segments(ctx context.Context, promptScopeID, provider, model string) ([]cache.Segment, error)

func (*Store) SetThreadTitle added in v0.18.0 

func (s *Store) SetThreadTitle(ctx context.Context, req sessiontree.SetThreadTitleRequest) (sessiontree.ThreadTitleMutationResult, error)

func (*Store) SettlePendingToolRecovery added in v0.18.0 

func (s *Store) SettlePendingToolRecovery(ctx context.Context, req sessiontree.SettlePendingToolRecoveryRequest) (sessiontree.SettlePendingToolRecoveryResult, error)

func (*Store) TakeOverCompaction added in v0.18.0 

func (s *Store) TakeOverCompaction(ctx context.Context, req sessiontree.TakeOverCompactionRequest) (sessiontree.BeginCompactionResult, error)

func (*Store) Thread 

func (s *Store) Thread(ctx context.Context, threadID string) (sessiontree.ThreadMeta, error)

func (*Store) ThreadTombstone added in v0.18.0 

func (s *Store) ThreadTombstone(ctx context.Context, threadID string) (sessiontree.ThreadTombstone, error)

func (*Store) UpdateThread 

func (s *Store) UpdateThread(ctx context.Context, meta sessiontree.ThreadMeta) error

func (*Store) ValidateArtifactForkDestination added in v0.18.0 

func (s *Store) ValidateArtifactForkDestination(ctx context.Context, closure artifact.Closure) error

func (*Store) ValidateInterruptedTurnResolution added in v0.19.0 

func (s *Store) ValidateInterruptedTurnResolution(ctx context.Context, req sessiontree.RecoverInterruptedTurnRequest) error

func (*Store) WaitApprovalDecision added in v0.20.0 

func (s *Store) WaitApprovalDecision(ctx context.Context, approvalID string) (sessiontree.WaitApprovalDecisionResult, error)

type WriterAdmission added in v0.20.0 

type WriterAdmission struct {
	// contains filtered or unexported fields
}

WriterAdmission serializes writers opened by this process for one physical SQLite database while keeping admission responsive to context cancellation.

func NewWriterAdmission added in v0.20.0 

func NewWriterAdmission(path string) (*WriterAdmission, error)

func (*WriterAdmission) Close added in v0.20.0 

func (a *WriterAdmission) Close()

func (*WriterAdmission) Reserve added in v0.20.0 

func (a *WriterAdmission) Reserve(ctx context.Context) (func(), error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.