mongo

package
v0.4.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 25, 2015 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const DefaultDBName = "cayley"
View Source 
const QuadStoreType = "mongo"

Variables

This section is empty.

Functions

func Type added in v0.3.1 

func Type() graph.Type

Types

type Iterator added in v0.3.1 

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

func NewAllIterator added in v0.3.1 

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

func NewIterator added in v0.3.1 

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

func (*Iterator) Clone added in v0.3.1 

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

func (*Iterator) Close added in v0.3.1 

func (it *Iterator) Close() error

func (*Iterator) Contains added in v0.3.1 

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

func (*Iterator) Describe added in v0.4.1 

func (it *Iterator) Describe() graph.Description

func (*Iterator) Err added in v0.4.1 

func (it *Iterator) Err() error

func (*Iterator) Next added in v0.3.1 

func (it *Iterator) Next() bool

func (*Iterator) NextPath added in v0.4.0 

func (it *Iterator) NextPath() bool

func (*Iterator) Optimize added in v0.3.1 

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

func (*Iterator) Reset added in v0.3.1 

func (it *Iterator) Reset()

func (*Iterator) Result added in v0.3.1 

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

func (*Iterator) ResultTree added in v0.3.1 

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

func (*Iterator) Size added in v0.3.1 

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

func (*Iterator) Sorted added in v0.3.1 

func (it *Iterator) Sorted() bool

func (*Iterator) Stats added in v0.3.1 

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

func (*Iterator) SubIterators added in v0.3.1 

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

SubIterators returns no subiterators for a Mongo iterator.

func (*Iterator) TagResults added in v0.3.1 

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

func (*Iterator) Tagger added in v0.3.1 

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

func (*Iterator) Type added in v0.3.1 

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

func (*Iterator) UID added in v0.3.1 

func (it *Iterator) UID() uint64

type LinksTo added in v0.4.1 

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

LinksTo is a MongoDB-dependent version of a LinksTo iterator. Like the normal LinksTo, it represents a set of links to a set of nodes, represented by its subiterator. However, this iterator may often be faster than the generic LinksTo, as it can use the secondary indices in Mongo as features within the Mongo query, reducing the size of the result set and speeding up iteration.

func NewLinksTo added in v0.4.1 

func NewLinksTo(qs *QuadStore, it graph.Iterator, collection string, d quad.Direction, lset []graph.Linkage) *LinksTo

NewLinksTo constructs a new indexed LinksTo iterator for Mongo around a direction and a subiterator of nodes.

func (*LinksTo) Clone added in v0.4.1 

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

func (*LinksTo) Close added in v0.4.1 

func (it *LinksTo) Close() error

func (*LinksTo) Contains added in v0.4.1 

func (it *LinksTo) Contains(val graph.Value) bool

func (*LinksTo) Describe added in v0.4.1 

func (it *LinksTo) Describe() graph.Description

func (*LinksTo) Direction added in v0.4.1 

func (it *LinksTo) Direction() quad.Direction

Return the direction under consideration.

func (*LinksTo) Err added in v0.4.1 

func (it *LinksTo) Err() error

func (*LinksTo) Next added in v0.4.1 

func (it *LinksTo) Next() bool

func (*LinksTo) NextPath added in v0.4.1 

func (it *LinksTo) NextPath() bool

func (*LinksTo) Optimize added in v0.4.1 

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

Optimize the LinksTo, by replacing it if it can be.

func (*LinksTo) Reset added in v0.4.1 

func (it *LinksTo) Reset()

func (*LinksTo) Result added in v0.4.1 

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

func (*LinksTo) ResultTree added in v0.4.1 

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

DEPRECATED

func (*LinksTo) Size added in v0.4.1 

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

func (*LinksTo) Stats added in v0.4.1 

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

Return a guess as to how big or costly it is to next the iterator.

func (*LinksTo) SubIterators added in v0.4.1 

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

Return a list containing only our subiterator.

func (*LinksTo) TagResults added in v0.4.1 

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

Tag these results, and our subiterator's results.

func (*LinksTo) Tagger added in v0.4.1 

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

func (*LinksTo) Type added in v0.4.1 

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

func (*LinksTo) UID added in v0.4.1 

func (it *LinksTo) UID() uint64

type MongoLogEntry added in v0.4.0 

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 QuadStore added in v0.4.1 

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

func (*QuadStore) ApplyDeltas added in v0.4.1 

func (qs *QuadStore) ApplyDeltas(in []graph.Delta, ignoreOpts graph.IgnoreOpts) error

func (*QuadStore) Close added in v0.4.1 

func (qs *QuadStore) Close()

func (*QuadStore) FixedIterator added in v0.4.1 

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

func (*QuadStore) Horizon added in v0.4.1 

func (qs *QuadStore) Horizon() graph.PrimaryKey

func (*QuadStore) NameOf added in v0.4.1 

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

func (*QuadStore) NodesAllIterator added in v0.4.1 

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

func (*QuadStore) OptimizeIterator added in v0.4.1 

func (qs *QuadStore) OptimizeIterator(it graph.Iterator) (graph.Iterator, bool)

func (*QuadStore) Quad added in v0.4.1 

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

func (*QuadStore) QuadDirection added in v0.4.1 

func (qs *QuadStore) QuadDirection(in graph.Value, d quad.Direction) graph.Value

func (*QuadStore) QuadIterator added in v0.4.1 

func (qs *QuadStore) QuadIterator(d quad.Direction, val graph.Value) graph.Iterator

func (*QuadStore) QuadsAllIterator added in v0.4.1 

func (qs *QuadStore) QuadsAllIterator() graph.Iterator

func (*QuadStore) Size added in v0.4.1 

func (qs *QuadStore) Size() int64

func (*QuadStore) Type added in v0.4.1 

func (qs *QuadStore) Type() string

func (*QuadStore) ValueOf added in v0.4.1 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.