sqlite

package
v0.18.0 Latest Latest
Warning

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

 Go to latest Published: Jul 19, 2026 License: MIT Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

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) 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) 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) Close 

func (s *Store) Close() 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) 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) FailForkOperation added in v0.18.0 

func (s *Store) FailForkOperation(ctx context.Context, req storage.ForkOperationFailureRequest) (storage.ForkOperationRecord, bool, 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) 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) 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) 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) 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) 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) 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.SetThreadTitleResult, 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

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.