api

Jun 19, 2026

Changes in this version

type GraphStore

+ func (gs *GraphStore) ListEdges() ([]*graph.Relationship, error)

+ func (gs *GraphStore) ListNodes() ([]*graph.Node, error)

Apr 28, 2026

Changes in this version

type GraphStore

+ func (gs *GraphStore) GetNeighborsByTypes(nodeID string, depth int, limit int, relTypes []string) ([]*NeighborResult, error)

Apr 6, 2026

Changes in this version

+ var ErrInvalidEdgeData = errors.New("invalid edge data")

+ var ErrInvalidNodeID = errors.New("invalid node id")

+ var ErrNodeNotFound = errors.New("node not found")

type DB

+ func (db *DB) IsClosedLocked() bool

+ func (db *DB) Lock()

+ func (db *DB) RLock()

+ func (db *DB) RUnlock()

+ func (db *DB) Store() *storage.DB

+ func (db *DB) Unlock()

+ type EdgeData struct

+ FromNodeID string

+ Properties map[string]interface{}

+ ToNodeID string

+ Type string

+ type GraphStore struct

+ func NewGraphStore(db *DB) *GraphStore

+ func (gs *GraphStore) GetNeighbors(nodeID string, depth int, limit int) ([]*NeighborResult, error)

+ func (gs *GraphStore) GetNode(nodeID string) (*graph.Node, error)

+ func (gs *GraphStore) UpsertEdges(edges []*EdgeData) error

+ func (gs *GraphStore) UpsertNodes(nodes []*NodeData) error

+ type NeighborResult struct

+ Edge *graph.Relationship

+ Node *graph.Node

+ type NodeData struct

+ ID string

+ Labels []string

+ Properties map[string]interface{}

Mar 28, 2026

Changes in this version

+ var ErrDBClosed = errors.New("database is closed")

+ var ErrNoMoreRows = errors.New("no more rows")

+ type DB struct

+ func Open(path string, opts ...DBOption) (*DB, error)

+ func (db *DB) BeginTx(ctx context.Context, opts *TxOptions) (*Tx, error)

+ func (db *DB) Close() error

+ func (db *DB) Exec(ctx context.Context, cypherQuery string, args ...interface{}) (Result, error)

+ func (db *DB) IsClosed() bool

+ func (db *DB) Query(ctx context.Context, cypherQuery string, args ...interface{}) (*Rows, error)

+ type DBOption func(*DB)

+ func WithObservability(o *cypher.Observability) DBOption

+ type Result = cypher.Result

+ type Rows struct

+ func (r *Rows) Close() error

+ func (r *Rows) Columns() []string

+ func (r *Rows) Next() bool

+ func (r *Rows) Scan(dest ...interface{}) error

+ type Tx struct

+ func (tx *Tx) Commit() error

+ func (tx *Tx) Exec(cypherQuery string, args ...interface{}) (Result, error)

+ func (tx *Tx) Query(cypherQuery string, args ...interface{}) (*Rows, error)

+ func (tx *Tx) Rollback() error

+ type TxOptions struct

+ ReadOnly bool