store

func (*Store) AcquireLocks ¶

func (s *Store) AcquireLocks(ctx context.Context, intentID string, lockKeys []string, ttl time.Duration) ([]core.LockRecord, error)

func (*Store) AllEdges ¶ added in v0.5.0

func (s *Store) AllEdges(ctx context.Context) ([]core.Edge, error)

func (*Store) AllFileMeta ¶ added in v0.17.1

func (s *Store) AllFileMeta(ctx context.Context) (map[string]FileMeta, error)

AllFileMeta returns the stat cache for every indexed file in one query.

func (*Store) AllSymbols ¶

func (s *Store) AllSymbols(ctx context.Context) ([]core.SymbolRecord, error)

func (*Store) Close ¶

func (s *Store) Close() error

func (*Store) DeleteFilesNotIn ¶

func (s *Store) DeleteFilesNotIn(ctx context.Context, current map[string]bool) (int, error)

func (*Store) EdgesBySource ¶ added in v0.23.0

func (s *Store) EdgesBySource(ctx context.Context, source string) ([]core.Edge, error)

EdgesBySource returns stored edges whose evidence source equals source, in the same (from_node, edge_type, to_node) order AllEdges uses, so callers that previously filtered AllEdges see an identical sequence. On monorepos this avoids materializing millions of rows the caller would discard (the delta carry path keeps only native edges — ~1/6 of the table).

func (*Store) FileBlobSHA ¶

func (s *Store) FileBlobSHA(ctx context.Context, filePath string) (string, bool, error)

func (*Store) FilesNotIn ¶ added in v0.6.2

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

FilesNotIn returns the indexed file paths absent from current — the files a delete pass would prune — without deleting anything.

func (*Store) Migrate ¶

func (s *Store) Migrate(ctx context.Context) error

func (*Store) ReleaseLocks ¶

func (s *Store) ReleaseLocks(ctx context.Context, intentID string) (int64, error)

func (*Store) ReplaceEdges ¶

func (s *Store) ReplaceEdges(ctx context.Context, edges []core.Edge) error

ReplaceEdges makes the edges table equal to the given set. It diffs against what is stored and writes only the difference: a one-file change on a million-edge repo touches hundreds of rows, and the previous delete-everything-reinsert paid the full million-row write every index (21s on a 19k-file monorepo). Inserts are batched multi-row.

func (*Store) Status ¶

func (s *Store) Status(ctx context.Context) (core.Status, error)

func (*Store) UpdateFileStats ¶ added in v0.17.1

func (s *Store) UpdateFileStats(ctx context.Context, stats map[string][2]int64) error

UpdateFileStats refreshes size+mtime for files whose content was verified unchanged (touched files: stat differs, blob identical).

func (*Store) UpsertFile ¶

func (s *Store) UpsertFile(ctx context.Context, filePath, blobSHA, language string, size, mtime int64, symbols []core.SymbolRecord) error