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