Versions in this module Expand all Collapse all v0 v0.1.0 Apr 28, 2026 Changes in this version + func DecodeVector(b []byte) []float32 + func EncodeVector(v []float32) []byte + type Edge struct + Acyclic bool + CreatedAt time.Time + FromID string + ID string + Metadata string + ToID string + Type string + Weight float64 + type Node struct + AccessCount int + AccessedAt time.Time + Confidence float64 + Content string + ContentHash string + CreatedAt time.Time + ID string + Project string + Scope string + SourceAgent string + SourceSession string + Summary string + Tags string + Tier int + Type string + UpdatedAt time.Time + Version int + type NodeFilter struct + MinConfidence float64 + Project string + Scope string + Tier int + Type string + type NodeVersion struct + ChangedAt time.Time + ChangedBy string + Content string + NodeID string + Reason string + Version int + type ReplayEvent struct + CreatedAt time.Time + Data string + ID int64 + SessionID string + type Session struct + Agent string + EndedAt time.Time + ID string + Project string + StartedAt time.Time + Summary string + type Store struct + func NewStore(dbPath string) (*Store, error) + func (s *Store) AddFileWatch(filePath, nodeID, gitHash string) error + func (s *Store) AddReplayEvent(sessionID, data string) error + func (s *Store) AllEmbeddings() (map[string][]float32, error) + func (s *Store) Close() error + func (s *Store) CreateEdge(e *Edge) error + func (s *Store) CreateNode(n *Node) error + func (s *Store) CreateSession(sess *Session) error + func (s *Store) DB() *sql.DB + func (s *Store) DeleteEdge(id string) error + func (s *Store) DeleteNode(id string) error + func (s *Store) EndSession(id string, summary string) error + func (s *Store) GetEdge(id string) (*Edge, error) + func (s *Store) GetEdgesFrom(nodeID string) ([]*Edge, error) + func (s *Store) GetEdgesTo(nodeID string) ([]*Edge, error) + func (s *Store) GetEmbedding(nodeID string) ([]float32, string, error) + func (s *Store) GetNeighbors(nodeID string) ([]*Node, error) + func (s *Store) GetNode(id string) (*Node, error) + func (s *Store) GetNodesByFile(filePath string) ([]*Node, error) + func (s *Store) GetReplayEvents(sessionID string) ([]*ReplayEvent, error) + func (s *Store) GetVersions(nodeID string) ([]*NodeVersion, error) + func (s *Store) ListNodes(f NodeFilter) ([]*Node, error) + func (s *Store) ListSessions(project string, limit int) ([]*Session, error) + func (s *Store) SaveEmbedding(nodeID, model string, vector []float32) error + func (s *Store) SaveVersion(nodeID string, content, changedBy, reason string) error + func (s *Store) SearchNodeByHash(hash, scope, project string) (*Node, error) + func (s *Store) SearchNodes(query string, limit int) ([]*Node, error) + func (s *Store) UpdateNode(n *Node) error + func (s *Store) UpsertByTopic(n *Node, topicKey string) (*Node, bool, error)