mongo

Documentation

Index

• Constants
• func Type() graph.Type
• type IDLru
  • func NewIDLru(size int) *IDLru
  • func (lru *IDLru) Get(key string) (string, bool)
  • func (lru *IDLru) Put(key string, value string)
• type Iterator
  • func NewAllIterator(qs *TripleStore, collection string) *Iterator
  • func NewIterator(qs *TripleStore, collection string, d quad.Direction, val graph.Value) *Iterator
  • func (it *Iterator) Clone() graph.Iterator
  • func (it *Iterator) Close()
  • func (it *Iterator) Contains(v graph.Value) bool
  • func (it *Iterator) DebugString(indent int) string
  • func (it *Iterator) Next() bool
  • func (it *Iterator) NextPath() bool
  • func (it *Iterator) Optimize() (graph.Iterator, bool)
  • func (it *Iterator) Reset()
  • func (it *Iterator) Result() graph.Value
  • func (it *Iterator) ResultTree() *graph.ResultTree
  • func (it *Iterator) Size() (int64, bool)
  • func (it *Iterator) Sorted() bool
  • func (it *Iterator) Stats() graph.IteratorStats
  • func (it *Iterator) SubIterators() []graph.Iterator
  • func (it *Iterator) TagResults(dst map[string]graph.Value)
  • func (it *Iterator) Tagger() *graph.Tagger
  • func (it *Iterator) Type() graph.Type
  • func (it *Iterator) UID() uint64
• type KV
• type MongoLogEntry
• type MongoNode
• type TripleStore
  • func (qs *TripleStore) ApplyDeltas(in []graph.Delta) error
  • func (qs *TripleStore) Close()
  • func (qs *TripleStore) FixedIterator() graph.FixedIterator
  • func (qs *TripleStore) Horizon() int64
  • func (qs *TripleStore) NameOf(v graph.Value) string
  • func (qs *TripleStore) NodesAllIterator() graph.Iterator
  • func (ts *TripleStore) OptimizeIterator(it graph.Iterator) (graph.Iterator, bool)
  • func (qs *TripleStore) Quad(val graph.Value) quad.Quad
  • func (qs *TripleStore) Size() int64
  • func (qs *TripleStore) TripleDirection(in graph.Value, d quad.Direction) graph.Value
  • func (qs *TripleStore) TripleIterator(d quad.Direction, val graph.Value) graph.Iterator
  • func (qs *TripleStore) TriplesAllIterator() graph.Iterator
  • func (qs *TripleStore) ValueOf(s string) graph.Value

Constants

const DefaultDBName = "cayley"

Functions

func Type

func Type() graph.Type

Types

type IDLru

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

func NewIDLru

func NewIDLru(size int) *IDLru

func (*IDLru) Get

func (lru *IDLru) Get(key string) (string, bool)

func (*IDLru) Put

func (lru *IDLru) Put(key string, value string)

type Iterator

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

func NewAllIterator

func NewAllIterator(qs *TripleStore, collection string) *Iterator

func NewIterator

func NewIterator(qs *TripleStore, collection string, d quad.Direction, val graph.Value) *Iterator

func (*Iterator) Clone

func (it *Iterator) Clone() graph.Iterator

func (*Iterator) Close

func (it *Iterator) Close()

func (*Iterator) Contains

func (it *Iterator) Contains(v graph.Value) bool

func (*Iterator) DebugString

func (it *Iterator) DebugString(indent int) string

func (*Iterator) Next

func (it *Iterator) Next() bool

func (*Iterator) NextPath

func (it *Iterator) NextPath() bool

func (*Iterator) Optimize

func (it *Iterator) Optimize() (graph.Iterator, bool)

func (*Iterator) Reset

func (it *Iterator) Reset()

func (*Iterator) Result

func (it *Iterator) Result() graph.Value

func (*Iterator) ResultTree

func (it *Iterator) ResultTree() *graph.ResultTree

func (*Iterator) Size

func (it *Iterator) Size() (int64, bool)

func (*Iterator) Sorted

func (it *Iterator) Sorted() bool

func (*Iterator) Stats

func (it *Iterator) Stats() graph.IteratorStats

func (*Iterator) SubIterators

func (it *Iterator) SubIterators() []graph.Iterator

No subiterators.

func (*Iterator) TagResults

func (it *Iterator) TagResults(dst map[string]graph.Value)

func (*Iterator) Tagger

func (it *Iterator) Tagger() *graph.Tagger

func (*Iterator) Type

func (it *Iterator) Type() graph.Type

func (*Iterator) UID

func (it *Iterator) UID() uint64

type KV

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

type MongoLogEntry

type MongoLogEntry struct {
	LogID     int64  `bson:"LogID"`
	Action    string `bson:"Action"`
	Key       string `bson:"Key"`
	Timestamp int64
}

type MongoNode

type MongoNode struct {
	Id   string `bson:"_id"`
	Name string `bson:"Name"`
	Size int    `bson:"Size"`
}

type TripleStore

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

func (*TripleStore) ApplyDeltas

func (qs *TripleStore) ApplyDeltas(in []graph.Delta) error

func (*TripleStore) Close

func (qs *TripleStore) Close()

func (*TripleStore) FixedIterator

func (qs *TripleStore) FixedIterator() graph.FixedIterator

func (*TripleStore) Horizon

func (qs *TripleStore) Horizon() int64

func (*TripleStore) NameOf

func (qs *TripleStore) NameOf(v graph.Value) string

func (*TripleStore) NodesAllIterator

func (qs *TripleStore) NodesAllIterator() graph.Iterator

func (*TripleStore) OptimizeIterator

func (ts *TripleStore) OptimizeIterator(it graph.Iterator) (graph.Iterator, bool)

func (*TripleStore) Quad

func (qs *TripleStore) Quad(val graph.Value) quad.Quad

func (*TripleStore) Size

func (qs *TripleStore) Size() int64

func (*TripleStore) TripleDirection

func (qs *TripleStore) TripleDirection(in graph.Value, d quad.Direction) graph.Value

func (*TripleStore) TripleIterator

func (qs *TripleStore) TripleIterator(d quad.Direction, val graph.Value) graph.Iterator

func (*TripleStore) TriplesAllIterator

func (qs *TripleStore) TriplesAllIterator() graph.Iterator

func (*TripleStore) ValueOf

func (qs *TripleStore) ValueOf(s string) graph.Value