Versions in this module Expand all Collapse all v1 v1.4.0 Aug 14, 2022 v1.3.0 Mar 19, 2022 Changes in this version + const EventEdgeCreated + const EventEdgeDelete + const EventEdgeDeleted + const EventEdgeStore + const EventEdgeUpdated + const EventNodeCreated + const EventNodeDelete + const EventNodeDeleted + const EventNodeStore + const EventNodeUpdate + const EventNodeUpdated + const MainDBEdgeAttrs + const MainDBEdgeCount + const MainDBEdgeKinds + const MainDBEntryPrefix + const MainDBNodeAttrs + const MainDBNodeCount + const MainDBNodeEdges + const MainDBNodeKinds + const MainDBParts + const MainDBVersion + const PrefixNSAttr + const PrefixNSAttrs + const PrefixNSEdge + const PrefixNSSpecs + const RootIDNodeHTree + const RootIDNodeHTreeSecond + const StorageSuffixEdges + const StorageSuffixEdgesIndex + const StorageSuffixNodes + const StorageSuffixNodesIndex + const VERSION + var ErrEventHandled = errors.New("Event handled upstream") + func ExportPartition(out io.Writer, part string, gm *Manager) error + func ImportPartition(in io.Reader, part string, gm *Manager) error + func IsFullSpec(spec string) bool + func SortDump(in string) string + type IndexQuery interface + LookupPhrase func(attr, phrase string) ([]string, error) + LookupValue func(attr, value string) ([]string, error) + LookupWord func(attr, word string) (map[string][]uint64, error) + type Manager struct + func NewGraphManager(gs graphstorage.Storage) *Manager + func (gm *Manager) EdgeAttrs(kind string) []string + func (gm *Manager) EdgeCount(kind string) uint64 + func (gm *Manager) EdgeIndexQuery(part string, kind string) (IndexQuery, error) + func (gm *Manager) EdgeKinds() []string + func (gm *Manager) FetchEdge(part string, key string, kind string) (data.Edge, error) + func (gm *Manager) FetchEdgePart(part string, key string, kind string, attrs []string) (data.Edge, error) + func (gm *Manager) FetchNode(part string, key string, kind string) (data.Node, error) + func (gm *Manager) FetchNodeEdgeSpecs(part string, key string, kind string) ([]string, error) + func (gm *Manager) FetchNodePart(part string, key string, kind string, attrs []string) (data.Node, error) + func (gm *Manager) GraphRules() []string + func (gm *Manager) IsValidAttr(attr string) bool + func (gm *Manager) Name() string + func (gm *Manager) NodeAttrs(kind string) []string + func (gm *Manager) NodeCount(kind string) uint64 + func (gm *Manager) NodeEdges(kind string) []string + func (gm *Manager) NodeIndexQuery(part string, kind string) (IndexQuery, error) + func (gm *Manager) NodeKeyIterator(part string, kind string) (*NodeKeyIterator, error) + func (gm *Manager) NodeKinds() []string + func (gm *Manager) Partitions() []string + func (gm *Manager) RemoveEdge(part string, key string, kind string) (data.Edge, error) + func (gm *Manager) RemoveNode(part string, key string, kind string) (data.Node, error) + func (gm *Manager) SetGraphRule(rule Rule) + func (gm *Manager) StoreEdge(part string, edge data.Edge) error + func (gm *Manager) StoreNode(part string, node data.Node) error + func (gm *Manager) Traverse(part string, key string, kind string, spec string, allData bool) ([]data.Node, []data.Edge, error) + func (gm *Manager) TraverseMulti(part string, key string, kind string, spec string, allData bool) ([]data.Node, []data.Edge, error) + func (gm *Manager) UpdateNode(part string, node data.Node) error + type NodeKeyIterator struct + LastError error + func (it *NodeKeyIterator) Error() error + func (it *NodeKeyIterator) HasNext() bool + func (it *NodeKeyIterator) Next() string + type Rule interface + Handle func(gm *Manager, trans Trans, event int, data ...interface{}) error + Handles func() []int + Name func() string + type SystemRuleDeleteNodeEdges struct + func (r *SystemRuleDeleteNodeEdges) Handle(gm *Manager, trans Trans, event int, ed ...interface{}) error + func (r *SystemRuleDeleteNodeEdges) Handles() []int + func (r *SystemRuleDeleteNodeEdges) Name() string + type SystemRuleUpdateNodeStats struct + func (r *SystemRuleUpdateNodeStats) Handle(gm *Manager, trans Trans, event int, ed ...interface{}) error + func (r *SystemRuleUpdateNodeStats) Handles() []int + func (r *SystemRuleUpdateNodeStats) Name() string + type Trans interface + Commit func() error + Counts func() (int, int, int, int) + ID func() string + IsEmpty func() bool + RemoveEdge func(part string, ekey string, ekind string) error + RemoveNode func(part string, nkey string, nkind string) error + StoreEdge func(part string, edge data.Edge) error + StoreNode func(part string, node data.Node) error + String func() string + UpdateNode func(part string, node data.Node) error + func NewConcurrentGraphTrans(gm *Manager) Trans + func NewGraphTrans(gm *Manager) Trans + func NewRollingTrans(t Trans, n int, gm *Manager, newTrans func(*Manager) Trans) Trans