graph

Apr 10, 2026

Changes in this version

type Edge

+ ExpiresAt *time.Time

+ func (e *Edge) WithTTL(d time.Duration) *Edge

type Node

+ ExpiresAt *time.Time

+ func (n *Node) WithTTL(d time.Duration) *Node

type StalenessManager

+ CountExpired func(ctx context.Context) (int64, int64, error)

+ DeleteExpired func(ctx context.Context) (int64, int64, error)

Apr 10, 2026

Changes in this version

type StalenessManager

+ FindOrphanedEdges func(ctx context.Context) ([]*Edge, error)

Apr 10, 2026

Changes in this version

type NodeFilter

+ ExcludeTypes []string

Apr 10, 2026

Changes in this version

+ type Describer interface

+ DescribeSchema func(ctx context.Context, includeFields bool) (*SchemaDescription, error)

+ type EdgeConnection struct

+ Count int

+ From string

+ To string

+ type EdgeTypeInfo struct

+ Connections []EdgeConnection

+ Count int

+ Type string

+ type NodeTypeInfo struct

+ Count int

+ Fields []string

+ Type string

+ type SchemaDescription struct

+ EdgeTypes []EdgeTypeInfo

+ NodeTypes []NodeTypeInfo

Apr 10, 2026

Changes in this version

type NodeFilter

+ func (f NodeFilter) Normalize() NodeFilter

Apr 10, 2026

Changes in this version

type NodeFilter

+ Generation string

Apr 10, 2026

Changes in this version

+ type EmbeddingStore interface

+ FindSimilar func(ctx context.Context, query []float32, limit int, filter *NodeFilter) ([]*NodeWithScore, error)

+ GetEmbedding func(ctx context.Context, nodeID string) ([]float32, error)

+ PutEmbedding func(ctx context.Context, nodeID string, embedding []float32) error

+ type NodeWithScore struct

+ Score float32

Apr 10, 2026

Changes in this version

type QueryResult

+ GroupingColumn string

Apr 9, 2026

Changes in this version

type QueryResult

+ Rows []map[string]any

type ResultType

+ const ResultTypeRows

Apr 9, 2026

Changes in this version

+ type CountItem struct

+ Count int

+ Name string

type QueryResult

+ SelectedColumns []string

Apr 9, 2026

Changes in this version

+ var ErrUnknownEdgeType = errors.New("unknown edge type")

+ var ErrUnknownNodeType = errors.New("unknown node type")

+ func IDFromEdgeKey(edgeType, from, to string) string

+ func IDFromURI(uri string) string

+ func NewID() string

+ func RegisterNodeType[T any](r *Registry, spec NodeSpec)

+ type AQLQuerier interface

+ Explain func(ctx context.Context, query interface{}) (*QueryPlan, error)

+ Query func(ctx context.Context, query interface{}) (*QueryResult, error)

+ type DatabaseInfo interface

+ GetDatabasePath func() string

+ type Direction int

+ const Both

+ const Incoming

+ const Outgoing

+ type Edge struct

+ CreatedAt time.Time

+ Data any

+ From string

+ Generation string

+ ID string

+ To string

+ Type string

+ func NewEdge(edgeType, from, to string) *Edge

+ func (e *Edge) WithData(data any) *Edge

+ func (e *Edge) WithGeneration(gen string) *Edge

+ type EdgeFilter struct

+ Direction string

+ From *NodeFilter

+ To *NodeFilter

+ Type string

+ Types []string

+ type EdgeQuerier interface

+ CountEdges func(ctx context.Context, filter EdgeFilter, opts QueryOptions) (map[string]int, error)

+ type EdgeReader interface

+ GetEdge func(ctx context.Context, id string) (*Edge, error)

+ GetEdgesFrom func(ctx context.Context, nodeID string) ([]*Edge, error)

+ GetEdgesTo func(ctx context.Context, nodeID string) ([]*Edge, error)

+ type EdgeSpec struct

+ Description string

+ FromTypes []string

+ ToTypes []string

+ Type string

+ type EdgeStore interface

+ type EdgeWriter interface

+ DeleteEdge func(ctx context.Context, id string) error

+ PutEdge func(ctx context.Context, edge *Edge) error

+ type Flusher interface

+ Flush func(ctx context.Context) error

+ type Graph struct

+ func New(s Storage, r *Registry) *Graph

+ func (g *Graph) AddEdge(ctx context.Context, e *Edge) error

+ func (g *Graph) AddNode(ctx context.Context, n *Node) error

+ func (g *Graph) Children(ctx context.Context, nodeID string) ([]*Node, error)

+ func (g *Graph) CountEdges(ctx context.Context, filter EdgeFilter, opts QueryOptions) (map[string]int, error)

+ func (g *Graph) CountNodes(ctx context.Context, filter NodeFilter, opts QueryOptions) (map[string]int, error)

+ func (g *Graph) DeleteEdge(ctx context.Context, id string) error

+ func (g *Graph) DeleteNode(ctx context.Context, id string) error

+ func (g *Graph) FindNodes(ctx context.Context, filter NodeFilter, opts QueryOptions) ([]*Node, error)

+ func (g *Graph) GetEdge(ctx context.Context, id string) (*Edge, error)

+ func (g *Graph) GetEdgesFrom(ctx context.Context, nodeID string) ([]*Edge, error)

+ func (g *Graph) GetEdgesTo(ctx context.Context, nodeID string) ([]*Edge, error)

+ func (g *Graph) GetNode(ctx context.Context, id string) (*Node, error)

+ func (g *Graph) GetNodeByURI(ctx context.Context, uri string) (*Node, error)

+ func (g *Graph) Neighbors(ctx context.Context, nodeID string, dir Direction) ([]*Node, error)

+ func (g *Graph) Parents(ctx context.Context, nodeID string) ([]*Node, error)

+ func (g *Graph) Registry() *Registry

+ func (g *Graph) Storage() Storage

+ type IndexRunRecord struct

+ DirsIndexed int

+ DurationMs int64

+ FilesIndexed int

+ FinishedAt time.Time

+ Generation string

+ ID int64

+ ReposIndexed int

+ RootPath string

+ StaleRemoved int

+ StartedAt time.Time

+ type IndexRunTracker interface

+ GetLastIndexRun func(ctx context.Context) (*IndexRunRecord, error)

+ RecordIndexRun func(ctx context.Context, run IndexRunRecord) error

+ type Node struct

+ CreatedAt time.Time

+ Data any

+ Generation string

+ ID string

+ Key string

+ Labels []string

+ Name string

+ Type string

+ URI string

+ UpdatedAt time.Time

+ func NewNode(nodeType string) *Node

+ func (n *Node) AddLabels(labels ...string)

+ func (n *Node) Clone() *Node

+ func (n *Node) HasLabel(label string) bool

+ func (n *Node) WithData(data any) *Node

+ func (n *Node) WithGeneration(gen string) *Node

+ func (n *Node) WithKey(key string) *Node

+ func (n *Node) WithLabels(labels ...string) *Node

+ func (n *Node) WithName(name string) *Node

+ func (n *Node) WithURI(uri string) *Node

+ type NodeFilter struct

+ Extensions []string

+ Labels []string

+ Name string

+ NamePattern string

+ NodeIDs []string

+ Root bool

+ Type string

+ TypePattern string

+ URIPrefix string

+ type NodeQuerier interface

+ CountNodes func(ctx context.Context, filter NodeFilter, opts QueryOptions) (map[string]int, error)

+ FindNodes func(ctx context.Context, filter NodeFilter, opts QueryOptions) ([]*Node, error)

+ type NodeReader interface

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

+ GetNodeByKey func(ctx context.Context, nodeType, key string) (*Node, error)

+ GetNodeByURI func(ctx context.Context, uri string) (*Node, error)

+ type NodeSpec struct

+ DataType reflect.Type

+ Description string

+ Type string

+ type NodeStore interface

+ type NodeWriter interface

+ DeleteNode func(ctx context.Context, id string) error

+ PutNode func(ctx context.Context, node *Node) error

+ type QueryOptions struct

+ Desc bool

+ GroupBy string

+ Limit int

+ OrderBy string

+ type QueryPlan struct

+ Args []any

+ EstimatedMs int64

+ SQL string

+ SQLitePlan string

+ type QueryResult struct

+ Counts map[string]int

+ Edges []*Edge

+ Nodes []*Node

+ Type ResultType

+ func (qr *QueryResult) Count() int

+ type Registry struct

+ func NewRegistry() *Registry

+ func (r *Registry) EdgeSpec(edgeType string) (EdgeSpec, bool)

+ func (r *Registry) EdgeTypes() []string

+ func (r *Registry) NodeSpec(nodeType string) (NodeSpec, bool)

+ func (r *Registry) NodeTypes() []string

+ func (r *Registry) RegisterEdgeType(spec EdgeSpec)

+ func (r *Registry) ValidateEdge(e *Edge, fromNode, toNode *Node) error

+ func (r *Registry) ValidateNode(n *Node) error

+ type ResultType int

+ const ResultTypeCounts

+ const ResultTypeEdges

+ const ResultTypeNodes

+ type StalenessManager interface

+ CountOrphanedEdges func(ctx context.Context) (int, error)

+ DeleteByURIPrefix func(ctx context.Context, uriPrefix string) (int, error)

+ DeleteOrphanedEdges func(ctx context.Context) (int, error)

+ DeleteStaleByURIPrefix func(ctx context.Context, uriPrefix, currentGen string) (int, error)

+ DeleteStaleEdges func(ctx context.Context, currentGen string) (int, error)

+ FindStaleByURIPrefix func(ctx context.Context, uriPrefix, currentGen string) ([]*Node, error)

+ type Storage interface