sqlite

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

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

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

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

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

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

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

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

func (s *Store) ClearExpiredTurnLease(ctx context.Context, threadID string, cutoff time.Time) (sessiontree.TurnLease, bool, error)

func (s *Store) Close() error

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

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

func (s *Store) DBPath() string

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

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

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

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

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

func (s *Store) DeleteThreadTreeData(ctx context.Context, req storage.DeleteThreadTreeDataRequest) error

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

func (s *Store) PutToolOutput(ctx context.Context, output artifact.ToolOutputArtifact) (artifact.Ref, error)

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

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

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

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

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

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

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