simplegraph

README

simplegraph

a really, really simple graph database modeled after hexastore

Documentation

Index

• Variables
• type DataField
• type Edge
  • func (e Edge) String() string
• type EdgeResult
  • func (e *EdgeResult) Edge() *Edge
• type FdbGraph
  • func (f *FdbGraph) Delete(keys ...[]byte) error
  • func (f *FdbGraph) Get(prefix []byte, outputStream chan<- []byte) error
  • func (f *FdbGraph) Put(keys ...[]byte) error
• type KVStore
• type OrderedStreamJoin
• type Query
• type SearchResults
• type SimpleGraph
  • func NewSimpleGraph(kvstore KVStore) *SimpleGraph
  • func (graph *SimpleGraph) AddEdges(edges []Edge) error
  • func (graph *SimpleGraph) GetEdges(query Query) (<-chan *Edge, error)
  • func (graph *SimpleGraph) GetRangeStreamingAnd(query1 Query, query2 Query) (<-chan *Edge, error)
  • func (graph *SimpleGraph) Search(query Query) (<-chan *SearchResults, error)
• type SortStream
• type TripleOrder
• type VariableResult
• type VariableStream

Variables

var Indices = map[string]*hexastoreIndex{
	"spo": {subspace.Sub("spo"), []DataField{SUBJECT, PREDICATE, OBJECT}},
	"sop": {subspace.Sub("sop"), []DataField{SUBJECT, OBJECT, PREDICATE}},
	"pos": {subspace.Sub("pos"), []DataField{PREDICATE, OBJECT, SUBJECT}},
	"pso": {subspace.Sub("pso"), []DataField{PREDICATE, SUBJECT, OBJECT}},
	"osp": {subspace.Sub("osp"), []DataField{OBJECT, SUBJECT, PREDICATE}},
	"ops": {subspace.Sub("ops"), []DataField{OBJECT, PREDICATE, SUBJECT}},
}

Types

type DataField

type DataField int

const (
	SUBJECT   DataField = 1
	PREDICATE DataField = 2
	OBJECT    DataField = 3
)

type Edge

type Edge struct {
	// contains filtered or unexported fields
}

func (Edge) String

func (e Edge) String() string

type EdgeResult

type EdgeResult struct {
	// contains filtered or unexported fields
}

func (*EdgeResult) Edge

func (e *EdgeResult) Edge() *Edge

type FdbGraph

type FdbGraph struct {
	// contains filtered or unexported fields
}

func (*FdbGraph) Delete

func (f *FdbGraph) Delete(keys ...[]byte) error

func (*FdbGraph) Get

func (f *FdbGraph) Get(prefix []byte, outputStream chan<- []byte) error

func (*FdbGraph) Put

func (f *FdbGraph) Put(keys ...[]byte) error

type KVStore

type KVStore interface {
	Get(prefix []byte, stream chan<- []byte) error
	Put(keys ...[]byte) error
	Delete(keys ...[]byte) error
}

type OrderedStreamJoin

type OrderedStreamJoin struct {
	// contains filtered or unexported fields
}

type Query

type Query struct {
	// contains filtered or unexported fields
}

type SearchResults

type SearchResults struct {
	// contains filtered or unexported fields
}

type SimpleGraph

type SimpleGraph struct {
	// contains filtered or unexported fields
}

func NewSimpleGraph

func NewSimpleGraph(kvstore KVStore) *SimpleGraph

func (*SimpleGraph) AddEdges

func (graph *SimpleGraph) AddEdges(edges []Edge) error

func (*SimpleGraph) GetEdges

func (graph *SimpleGraph) GetEdges(query Query) (<-chan *Edge, error)

func (*SimpleGraph) GetRangeStreamingAnd

func (graph *SimpleGraph) GetRangeStreamingAnd(query1 Query, query2 Query) (<-chan *Edge, error)

func (*SimpleGraph) Search

func (graph *SimpleGraph) Search(query Query) (<-chan *SearchResults, error)

type SortStream

type SortStream struct {
	// contains filtered or unexported fields
}

type TripleOrder

type TripleOrder struct {
	// contains filtered or unexported fields
}

type VariableResult

type VariableResult struct {
	// contains filtered or unexported fields
}

type VariableStream

type VariableStream struct {
	// contains filtered or unexported fields
}