sqlite

Oct 9, 2026

Changes in this version

type MergeResult

+ SourcesNoMatch []string

type Store

+ func (s *Store) CountOrphanObservations(ctx context.Context) (int, error)

Oct 7, 2026

Changes in this version

+ const QuantHeaderBytes

+ var QuantMagic = [4]byte

+ func DecodeEmbeddingPayload(data []byte) ([]float32, error)

+ func DecodeQuantHeader(data []byte) (dims, prefix int, scale float64, ok bool)

Sep 13, 2026

Changes in this version

+ var ErrImportFailed = &ImportError

+ var ErrImportObservation = &ImportError

+ var ErrImportPrompt = &ImportError

+ var ErrImportSession = &ImportError

+ var ErrImportTransaction = &ImportError

+ func PreflightObservation(obs *domain.Observation) (*domain.Observation, error)

+ func PreflightObservationCeiling(obs *domain.Observation, maxContent int) (*domain.Observation, error)

+ func PreflightPrompt(p *domain.Prompt) (*domain.Prompt, error)

+ func PreflightSession(sess *domain.Session) (*domain.Session, error)

type ExportData

+ func PreflightExportData(data *ExportData) (*ExportData, error)

+ type ImportError struct

+ Message string

+ func (e *ImportError) Error() string

+ func (e *ImportError) Is(target error) bool

+ type TransientPayloadStore struct

+ func NewTransientPayloadStore(db *sql.DB) (*TransientPayloadStore, error)

+ func (s *TransientPayloadStore) Get(ctx context.Context, id string) (*payload.TransientPayload, error)

+ func (s *TransientPayloadStore) PurgeSession(ctx context.Context, sessionID string) error

+ func (s *TransientPayloadStore) Save(ctx context.Context, p *payload.TransientPayload) error

+ func (s *TransientPayloadStore) Search(ctx context.Context, id string, query string, limit int) ([]payload.SearchResult, error)

+ func (s *TransientPayloadStore) Stats(ctx context.Context, sessionID string) (int, int, int, error)

Sep 1, 2026

Changes in this version

+ type CodeStore struct

+ func NewCodeStore(db *sql.DB) (*CodeStore, error)

+ func (s *CodeStore) CountSymbols(ctx context.Context, filter code.SymbolFilter) (int, error)

+ func (s *CodeStore) DeleteRelationsByFile(ctx context.Context, project, filePath string) error

+ func (s *CodeStore) DeleteRelationsByProject(ctx context.Context, project string) error

+ func (s *CodeStore) DeleteSymbolsByFile(ctx context.Context, project, filePath string) error

+ func (s *CodeStore) DeleteSymbolsByProject(ctx context.Context, project string) error

+ func (s *CodeStore) GetGraph(ctx context.Context, project string) (*code.CodeGraph, error)

+ func (s *CodeStore) GetSymbolByID(ctx context.Context, id string) (*code.Symbol, error)

+ func (s *CodeStore) ListRelationsBySymbol(ctx context.Context, symbolID string) ([]code.Relation, error)

+ func (s *CodeStore) ListSymbols(ctx context.Context, filter code.SymbolFilter) ([]code.Symbol, error)

+ func (s *CodeStore) SaveRelations(ctx context.Context, relations []code.Relation) error

+ func (s *CodeStore) SaveSymbols(ctx context.Context, symbols []code.Symbol) error

Aug 23, 2026

Changes in this version

+ const DefaultEmbeddingDimension

+ const MaxEmbeddingDimension

+ const MinEmbeddingDimension

+ const OutboxDefaultMaxAttempts

+ const OutboxStatusComplete

+ const OutboxStatusDeadLetter

+ const OutboxStatusLeased

+ const OutboxStatusPending

+ type ConsolidationGroup struct

+ Count int

+ Latest string

+ TopicKey string

+ type ExportData struct

+ ExportedAt string

+ Observations []*domain.Observation

+ Prompts []*domain.Prompt

+ Sessions []*domain.Session

+ Version string

+ type MergeResult struct

+ Canonical string

+ ObservationsUpdated int64

+ SessionsUpdated int64

+ SourcesMerged []string

+ type MetricsRepository struct

+ func NewMetricsRepository(db *sql.DB) *MetricsRepository

+ func (r *MetricsRepository) CreateMetric(ctx context.Context, metric *domain.Metrics) error

+ func (r *MetricsRepository) GetAggregatedMetrics(ctx context.Context, from, to time.Time) (*domain.AggregatedMetrics, error)

+ func (r *MetricsRepository) GetByOperationType(ctx context.Context, operationType string, from, to time.Time) ([]*domain.Metrics, error)

+ func (r *MetricsRepository) GetTemporalMetrics(ctx context.Context, sessionID string, from, to time.Time) ([]*domain.Metrics, error)

+ type OutboxIntent struct

+ Attempts int

+ CompletedAt sql.NullString

+ CreatedAt string

+ Error sql.NullString

+ ID int64

+ Intent string

+ LeasedAt sql.NullString

+ MaxAttempts int

+ ModelInfo string

+ NextRetryAt sql.NullString

+ ObservationID int64

+ Status string

+ type OutboxStore struct

+ func NewOutboxStore(db *sql.DB) *OutboxStore

+ func (s *OutboxStore) DeadLetter(ctx context.Context, id int64, cause error) error

+ func (s *OutboxStore) EnqueueInTx(ctx context.Context, observationID int64, intent, modelInfo string) error

+ func (s *OutboxStore) Lease(ctx context.Context, limit int) ([]OutboxIntent, error)

+ func (s *OutboxStore) MarkComplete(ctx context.Context, id int64) error

+ func (s *OutboxStore) MarkFailed(ctx context.Context, id int64, cause error, nextRetryAt time.Time) error

+ func (s *OutboxStore) PendingCount(ctx context.Context) (int, error)

+ func (s *OutboxStore) RecoverPending(ctx context.Context) error

+ func (s *OutboxStore) UpdateIndexState(ctx context.Context, namespace string, coverage float64, parity int) error

+ func (s *OutboxStore) WithinTx(ctx context.Context, handle any, fn func(context.Context) error) error

+ type QualityMetricsRepository struct

+ func NewQualityMetricsRepository(db *sql.DB) *QualityMetricsRepository

+ func (r *QualityMetricsRepository) CreateQualityMetric(ctx context.Context, quality *domain.QualityMetrics) error

+ func (r *QualityMetricsRepository) GetBySession(ctx context.Context, sessionID string, limit int) ([]*domain.QualityMetrics, error)

+ func (r *QualityMetricsRepository) GetByType(ctx context.Context, evaluationType string, from, to time.Time) ([]*domain.QualityMetrics, error)

+ func (r *QualityMetricsRepository) GetLatest(ctx context.Context, limit int) ([]*domain.QualityMetrics, error)

+ type Stats struct

+ ByType map[string]int

+ Projects []string

+ TotalObservations int

+ type Store struct

+ func NewStore(db *sql.DB) *Store

+ func (s *Store) CountAll(ctx context.Context) (int, error)

+ func (s *Store) CountByRoot(ctx context.Context, rootObsID int64) (int, error)

+ func (s *Store) DB() *sql.DB

+ func (s *Store) Delete(ctx context.Context, id int64) error

+ func (s *Store) ExportAll(ctx context.Context) (*ExportData, error)

+ func (s *Store) FindConsolidationCandidates(ctx context.Context, project string, minCount int) ([]ConsolidationGroup, error)

+ func (s *Store) GetByID(ctx context.Context, id int64) (*domain.Observation, error)

+ func (s *Store) GetByIDs(ctx context.Context, ids []int64) (map[int64]*domain.Observation, error)

+ func (s *Store) GetBySource(ctx context.Context, source string, limit int) ([]*domain.Observation, error)

+ func (s *Store) GetByTopicKey(ctx context.Context, project, topicKey string) (*domain.Observation, error)

+ func (s *Store) GetByType(ctx context.Context, obsType string, limit int) ([]*domain.Observation, error)

+ func (s *Store) GetSearchFeedbackStats(ctx context.Context) (totalEntries int, uniqueQueries int, err error)

+ func (s *Store) GetSyncedChunks(ctx context.Context) (map[string]bool, error)

+ func (s *Store) HardDelete(ctx context.Context, id int64) error

+ func (s *Store) ImportData(ctx context.Context, data *ExportData) (*SyncImportResult, error)

+ func (s *Store) List(ctx context.Context, filter domain.ObservationFilter) ([]*domain.Observation, error)

+ func (s *Store) ListArchivable(ctx context.Context, cutoff time.Time, minScore float64, limit int) ([]*domain.Observation, error)

+ func (s *Store) ListByTopicKey(ctx context.Context, project, topicKey string) ([]*domain.Observation, error)

+ func (s *Store) MergeProjects(ctx context.Context, sources []string, canonical string) (*MergeResult, error)

+ func (s *Store) OrphanObservations(ctx context.Context, project string, limit int) ([]*domain.Observation, error)

+ func (s *Store) RecordSearchFeedback(ctx context.Context, query string, observationID int64, rankPosition int) error

+ func (s *Store) RecordSyncedChunk(ctx context.Context, chunkID string) error

+ func (s *Store) Restore(ctx context.Context, id int64) error

+ func (s *Store) Save(ctx context.Context, obs *domain.Observation) error

+ func (s *Store) SaveHandoffWithEffect(ctx context.Context, obs *domain.Observation) (domain.SaveEffect, error)

+ func (s *Store) SaveInTx(ctx context.Context, obs *domain.Observation) error

+ func (s *Store) SaveWithEffect(ctx context.Context, obs *domain.Observation) (domain.SaveEffect, error)

+ func (s *Store) SoftDelete(ctx context.Context, id int64) error

+ func (s *Store) StaleObservations(ctx context.Context, project string, minScore float64, daysSinceAccess int) ([]*domain.Observation, error)

+ func (s *Store) Stats(ctx context.Context) (*Stats, error)

+ func (s *Store) Unarchive(ctx context.Context, id int64) error

+ func (s *Store) Update(ctx context.Context, obs *domain.Observation) error

+ func (s *Store) WithinTx(ctx context.Context, handle any, fn func(context.Context) error) error

+ type SyncImportResult struct

+ ObservationsImported int

+ PromptsImported int

+ SessionsImported int

+ type TemporalSnapshotRepository struct

+ func NewTemporalSnapshotRepository(db *sql.DB) *TemporalSnapshotRepository

+ func (r *TemporalSnapshotRepository) CreateSnapshot(ctx context.Context, snapshot *domain.TemporalSnapshot) error

+ func (r *TemporalSnapshotRepository) GetByID(ctx context.Context, id int64) (*domain.TemporalSnapshot, error)

+ func (r *TemporalSnapshotRepository) GetByRootObservation(ctx context.Context, rootObsID int64) ([]*domain.TemporalSnapshot, error)

+ func (r *TemporalSnapshotRepository) GetBySnapshotKey(ctx context.Context, snapshotKey string) ([]*domain.TemporalSnapshot, error)

+ func (r *TemporalSnapshotRepository) GetSnapshotsInRange(ctx context.Context, from, to time.Time) ([]*domain.TemporalSnapshot, error)

+ type VectorStore struct

+ func NewVectorStore(_ *sql.DB) *VectorStore

+ func (s *VectorStore) DeleteEmbedding(ctx context.Context, observationID int64) error

+ func (s *VectorStore) GetEmbedding(ctx context.Context, observationID int64) ([]float32, string, error)

+ func (s *VectorStore) IsAvailable() bool

+ func (s *VectorStore) SearchByVector(ctx context.Context, opts domain.VectorSearchOptions) ([]*domain.VectorSearchResult, error)

+ func (s *VectorStore) StoreEmbedding(ctx context.Context, observationID int64, embedding []float32, model string) error