store

package
v0.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 14, 2026 License: MIT Imports: 12 Imported by: 0

Documentation

Overview

Package store provides SQLite-backed persistence.

Index

Constants

View Source 
const (
	OriginParsed = "parsed"
	OriginManual = "manual"

	DirectionOut  = "out"
	DirectionIn   = "in"
	DirectionBoth = "both"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type DiffRecord 

type DiffRecord struct {
	SnapshotID int64
	NodeID     string
	Op         string
	OldHash    string
	NewHash    string
	OldContent string
	NewContent string
}

type FileSummary added in v0.1.6 

type FileSummary struct {
	Path        string
	NodeCount   int
	TokenCount  int
	CompileRoot string
}

type Node 

type Node struct {
	ID           string
	ParentID     string
	SourceFile   string
	NodeType     string
	Depth        int
	Label        string
	Content      string
	Format       string
	TokenCount   int
	ContentHash  string
	Temperature  float64
	AccessCount  int
	LastAccessed sql.NullInt64
	CreatedAt    int64
	UpdatedAt    int64
	Pinned       bool
	SeedTemp     *float64
}

func BuildTree 

func BuildTree(nodes []*Node) (roots []*Node, children map[string][]*Node)

type PendingRelation added in v0.3.0 

type PendingRelation struct {
	ID           int64
	SourceNodeID string
	TargetLabel  string
	TargetSource string
	TargetIDHint string
	Weight       float64
	Origin       string
	CreatedAt    int64
}

type RankedNode 

type RankedNode struct {
	Node *Node
	Rank float64
}

type RelatedNode added in v0.3.0 

type RelatedNode struct {
	Node   *Node
	Weight float64
	Hop    int
}

type Relation added in v0.3.0 

type Relation struct {
	ID           int64
	SourceNodeID string
	TargetNodeID string
	Weight       float64
	Origin       string
	CreatedAt    int64
}

type RowScanner 

type RowScanner interface {
	Scan(...any) error
}

type Snapshot 

type Snapshot struct {
	ID          int64
	CursorHash  string
	ParentID    sql.NullInt64
	Message     string
	CompileRoot string
	CreatedAt   int64
}

type Stats 

type Stats struct {
	NodeCount            int
	SnapshotCount        int
	AvgTemp              float64
	MedianTemp           float64
	HotCount             int
	ColdCount            int
	PinnedCount          int
	TokenCountTotal      int64
	FTSRowCount          int
	PendingRelationCount int
}

type Store 

type Store struct {
	Path string

	OpMu sync.Mutex
	// contains filtered or unexported fields
}

func Open 

func Open(path string) (*Store, error)

func (*Store) AdvanceCursorTx 

func (s *Store) AdvanceCursorTx(ctx context.Context, tx *sql.Tx, snapshotID int64) error

func (*Store) BoostTemperature 

func (s *Store) BoostTemperature(ctx context.Context, id string, boost float64) error

func (*Store) BoostTemperatureBatch 

func (s *Store) BoostTemperatureBatch(ctx context.Context, ids []string, boost float64) error

func (*Store) Close 

func (s *Store) Close() error

func (*Store) CreateSnapshotTx 

func (s *Store) CreateSnapshotTx(ctx context.Context, tx *sql.Tx, cursorHash, message, compileRoot string) (int64, error)

func (*Store) DecayTemperatures 

func (s *Store) DecayTemperatures(ctx context.Context, factor float64) (int64, error)

func (*Store) DeleteNode 

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

func (*Store) DeleteNodeTx 

func (s *Store) DeleteNodeTx(ctx context.Context, tx *sql.Tx, id string) error

func (*Store) DeleteNodesByFiles 

func (s *Store) DeleteNodesByFiles(ctx context.Context, paths []string) error

func (*Store) DeleteParsedPendingForSource added in v0.3.0 

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

func (*Store) DeleteParsedPendingForSourceTx added in v0.3.0 

func (s *Store) DeleteParsedPendingForSourceTx(ctx context.Context, tx *sql.Tx, sourceID string) error

func (*Store) DeletePendingByID added in v0.3.0 

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

func (*Store) DeletePendingByIDTx added in v0.3.0 

func (s *Store) DeletePendingByIDTx(ctx context.Context, tx *sql.Tx, id int64) error

func (*Store) ExecRewriteSourcePaths 

func (s *Store) ExecRewriteSourcePaths(ctx context.Context, oldPrefix, newPrefix string) error

Replace every source file prefix matching oldPrefix with newPrefix.

func (*Store) FindHeadingByLabel added in v0.3.0 

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

Look up a heading node ID by case-insensitive trimmed label match across all files.

func (*Store) FindHeadingByLabelInFile added in v0.3.0 

func (s *Store) FindHeadingByLabelInFile(ctx context.Context, sourceFile, label string) (string, error)

Look up a heading node ID by label scoped to a source file.

func (*Store) GetAllNodes 

func (s *Store) GetAllNodes(ctx context.Context) ([]*Node, error)

func (*Store) GetAllPendingRelations added in v0.3.0 

func (s *Store) GetAllPendingRelations(ctx context.Context) ([]*PendingRelation, error)

func (*Store) GetAncestors 

func (s *Store) GetAncestors(ctx context.Context, id string) ([]*Node, error)

func (*Store) GetChildren 

func (s *Store) GetChildren(ctx context.Context, parentID string) ([]*Node, error)

func (*Store) GetColdNodes 

func (s *Store) GetColdNodes(ctx context.Context, threshold float64, limit int) ([]*Node, error)

func (*Store) GetDescendants 

func (s *Store) GetDescendants(ctx context.Context, id string, maxDepth int) ([]*Node, error)

func (*Store) GetDiffsBySnapshot 

func (s *Store) GetDiffsBySnapshot(ctx context.Context, snapshotID int64) ([]*DiffRecord, error)

func (*Store) GetDiffsForNode 

func (s *Store) GetDiffsForNode(ctx context.Context, nodeID string) ([]*DiffRecord, error)

func (*Store) GetDiffsSince 

func (s *Store) GetDiffsSince(ctx context.Context, sinceSnapshotID int64) ([]*DiffRecord, error)

func (*Store) GetHeadCursorHash 

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

func (*Store) GetLatestCompileRoot 

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

Return the compile root of the most recent snapshot created via a directory compile.

func (*Store) GetNode 

func (s *Store) GetNode(ctx context.Context, id string) (*Node, error)

func (*Store) GetNodeCountsByType added in v0.3.0 

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

Return node counts grouped by node_type (e.g. heading, list, kv, table).

func (*Store) GetNodesByCompileRoot added in v0.1.7 

func (s *Store) GetNodesByCompileRoot(ctx context.Context, root string) ([]*Node, error)

func (*Store) GetNodesByFile 

func (s *Store) GetNodesByFile(ctx context.Context, path string) ([]*Node, error)

func (*Store) GetNodesByFiles 

func (s *Store) GetNodesByFiles(ctx context.Context, paths []string) ([]*Node, error)

func (*Store) GetNodesByIDs added in v0.3.0 

func (s *Store) GetNodesByIDs(ctx context.Context, ids []string) ([]*Node, error)

func (*Store) GetPendingBySource added in v0.3.0 

func (s *Store) GetPendingBySource(ctx context.Context, sourceID string) ([]*PendingRelation, error)

func (*Store) GetRelatedNodes added in v0.3.0 

func (s *Store) GetRelatedNodes(ctx context.Context, anchorID, direction string, maxDepth int, weightMin float64, limit int) ([]*RelatedNode, error)

Return nodes reachable from anchor via relations edges, up to maxDepth hops, filtered by weightMin.

func (*Store) GetRelationCountsByOrigin added in v0.3.0 

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

Return relation counts grouped by origin (parsed, manual).

func (*Store) GetRootNodes 

func (s *Store) GetRootNodes(ctx context.Context) ([]*Node, error)

func (*Store) GetSiblings 

func (s *Store) GetSiblings(ctx context.Context, id string) ([]*Node, error)

func (*Store) GetSnapshot 

func (s *Store) GetSnapshot(ctx context.Context, id int) (*Snapshot, error)

func (*Store) GetStats 

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

func (*Store) IncrementAccess 

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

func (*Store) InsertDiffTx 

func (s *Store) InsertDiffTx(ctx context.Context, tx *sql.Tx, d *DiffRecord) error

func (*Store) InsertPendingRelation added in v0.3.0 

func (s *Store) InsertPendingRelation(ctx context.Context, p *PendingRelation) error

func (*Store) InsertPendingRelationTx added in v0.3.0 

func (s *Store) InsertPendingRelationTx(ctx context.Context, tx *sql.Tx, p *PendingRelation) error

func (*Store) ListFileSummaries added in v0.1.6 

func (s *Store) ListFileSummaries(ctx context.Context) ([]FileSummary, error)

func (*Store) ListSnapshots 

func (s *Store) ListSnapshots(ctx context.Context, limit int) ([]*Snapshot, error)

func (*Store) Migrate 

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

Apply any embedded migration that hasn't run on the DB yet.

func (*Store) ResetTemperaturesByFiles added in v0.1.8 

func (s *Store) ResetTemperaturesByFiles(ctx context.Context, paths []string, temp float64) error

func (*Store) Search 

func (s *Store) Search(ctx context.Context, query string, limit int) ([]*Node, error)

func (*Store) SearchRanked 

func (s *Store) SearchRanked(ctx context.Context, query string, limit int) ([]*RankedNode, error)

func (*Store) SetPinned added in v0.3.0 

func (s *Store) SetPinned(ctx context.Context, id string, pinned bool, temp *float64) error

func (*Store) Tx 

func (s *Store) Tx(ctx context.Context, fn func(tx *sql.Tx) error) error

Run fn inside a transaction; commit on nil error, roll back otherwise.

func (*Store) UpdateTemperature 

func (s *Store) UpdateTemperature(ctx context.Context, id string, temp float64) error

func (*Store) UpsertNode 

func (s *Store) UpsertNode(ctx context.Context, n *Node) error

func (*Store) UpsertNodeTx 

func (s *Store) UpsertNodeTx(ctx context.Context, tx *sql.Tx, n *Node) error

func (*Store) UpsertRelation added in v0.3.0 

func (s *Store) UpsertRelation(ctx context.Context, r *Relation) error

func (*Store) UpsertRelationTx added in v0.3.0 

func (s *Store) UpsertRelationTx(ctx context.Context, tx *sql.Tx, r *Relation) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.