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

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