mongo

Documentation

Index

• Constants
• func CreateNewMongoGraph(addr string, options graph.OptionsDict) bool
• type IDLru
  • func NewIDLru(size int) *IDLru
  • func (lru *IDLru) Get(key string) (string, bool)
  • func (lru *IDLru) Put(key string, value string)
• type KV
• type MongoIterator
  • func NewMongoAllIterator(ts *MongoTripleStore, collection string) *MongoIterator
  • func NewMongoIterator(ts *MongoTripleStore, collection string, dir string, val graph.TSVal) *MongoIterator
  • func (m *MongoIterator) Check(v graph.TSVal) bool
  • func (m *MongoIterator) Clone() graph.Iterator
  • func (m *MongoIterator) Close()
  • func (m *MongoIterator) DebugString(indent int) string
  • func (m *MongoIterator) GetStats() *graph.IteratorStats
  • func (m *MongoIterator) Next() (graph.TSVal, bool)
  • func (m *MongoIterator) Optimize() (graph.Iterator, bool)
  • func (m *MongoIterator) Reset()
  • func (m *MongoIterator) Size() (int64, bool)
  • func (m *MongoIterator) Sorted() bool
  • func (m *MongoIterator) Type() string
• type MongoNode
• type MongoTripleStore
  • func NewMongoTripleStore(addr string, options graph.OptionsDict) *MongoTripleStore
  • func (ts *MongoTripleStore) AddTriple(t *graph.Triple)
  • func (ts *MongoTripleStore) AddTripleSet(in []*graph.Triple)
  • func (ts *MongoTripleStore) BulkLoad(t_chan chan *graph.Triple)
  • func (ts *MongoTripleStore) Close()
  • func (ts *MongoTripleStore) ConvertStringToByteHash(s string) string
  • func (ts *MongoTripleStore) GetIdFor(s string) graph.TSVal
  • func (ts *MongoTripleStore) GetNameFor(v graph.TSVal) string
  • func (ts *MongoTripleStore) GetNodesAllIterator() graph.Iterator
  • func (ts *MongoTripleStore) GetTriple(val graph.TSVal) *graph.Triple
  • func (ts *MongoTripleStore) GetTripleDirection(in graph.TSVal, dir string) graph.TSVal
  • func (ts *MongoTripleStore) GetTripleIterator(dir string, val graph.TSVal) graph.Iterator
  • func (ts *MongoTripleStore) GetTriplesAllIterator() graph.Iterator
  • func (ts *MongoTripleStore) MakeFixed() *graph.FixedIterator
  • func (ts *MongoTripleStore) OptimizeIterator(it graph.Iterator) (graph.Iterator, bool)
  • func (ts *MongoTripleStore) RemoveTriple(t *graph.Triple)
  • func (ts *MongoTripleStore) Size() int64

Constants

const DefaultDBName = "cayley"

Functions

func CreateNewMongoGraph

func CreateNewMongoGraph(addr string, options graph.OptionsDict) bool

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 KV

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

type MongoIterator

type MongoIterator struct {
	graph.BaseIterator
	// contains filtered or unexported fields
}

func NewMongoAllIterator

func NewMongoAllIterator(ts *MongoTripleStore, collection string) *MongoIterator

func NewMongoIterator

func NewMongoIterator(ts *MongoTripleStore, collection string, dir string, val graph.TSVal) *MongoIterator

func (*MongoIterator) Check

func (m *MongoIterator) Check(v graph.TSVal) bool

func (*MongoIterator) Clone

func (m *MongoIterator) Clone() graph.Iterator

func (*MongoIterator) Close

func (m *MongoIterator) Close()

func (*MongoIterator) DebugString

func (m *MongoIterator) DebugString(indent int) string

func (*MongoIterator) GetStats

func (m *MongoIterator) GetStats() *graph.IteratorStats

func (*MongoIterator) Next

func (m *MongoIterator) Next() (graph.TSVal, bool)

func (*MongoIterator) Optimize

func (m *MongoIterator) Optimize() (graph.Iterator, bool)

func (*MongoIterator) Reset

func (m *MongoIterator) Reset()

func (*MongoIterator) Size

func (m *MongoIterator) Size() (int64, bool)

func (*MongoIterator) Sorted

func (m *MongoIterator) Sorted() bool

func (*MongoIterator) Type

func (m *MongoIterator) Type() string

type MongoNode

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

type MongoTripleStore

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

func NewMongoTripleStore

func NewMongoTripleStore(addr string, options graph.OptionsDict) *MongoTripleStore

func (*MongoTripleStore) AddTriple

func (ts *MongoTripleStore) AddTriple(t *graph.Triple)

func (*MongoTripleStore) AddTripleSet

func (ts *MongoTripleStore) AddTripleSet(in []*graph.Triple)

func (*MongoTripleStore) BulkLoad

func (ts *MongoTripleStore) BulkLoad(t_chan chan *graph.Triple)

func (*MongoTripleStore) Close

func (ts *MongoTripleStore) Close()

func (*MongoTripleStore) ConvertStringToByteHash

func (ts *MongoTripleStore) ConvertStringToByteHash(s string) string

func (*MongoTripleStore) GetIdFor

func (ts *MongoTripleStore) GetIdFor(s string) graph.TSVal

func (*MongoTripleStore) GetNameFor

func (ts *MongoTripleStore) GetNameFor(v graph.TSVal) string

func (*MongoTripleStore) GetNodesAllIterator

func (ts *MongoTripleStore) GetNodesAllIterator() graph.Iterator

func (*MongoTripleStore) GetTriple

func (ts *MongoTripleStore) GetTriple(val graph.TSVal) *graph.Triple

func (*MongoTripleStore) GetTripleDirection

func (ts *MongoTripleStore) GetTripleDirection(in graph.TSVal, dir string) graph.TSVal

func (*MongoTripleStore) GetTripleIterator

func (ts *MongoTripleStore) GetTripleIterator(dir string, val graph.TSVal) graph.Iterator

func (*MongoTripleStore) GetTriplesAllIterator

func (ts *MongoTripleStore) GetTriplesAllIterator() graph.Iterator

func (*MongoTripleStore) MakeFixed

func (ts *MongoTripleStore) MakeFixed() *graph.FixedIterator

func (*MongoTripleStore) OptimizeIterator

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

func (*MongoTripleStore) RemoveTriple

func (ts *MongoTripleStore) RemoveTriple(t *graph.Triple)

func (*MongoTripleStore) Size

func (ts *MongoTripleStore) Size() int64