gaedatastore

Documentation

Index

• Constants
• type Config
  • func LoadConf(file string) (*Config, error)
  • func (c *Config) MarshalJSON() ([]byte, error)
  • func (c *Config) UnmarshalJSON(data []byte) error
• type Iterator
  • func NewAllIterator(qs *QuadStore, kind string) *Iterator
  • func NewIterator(qs *QuadStore, k string, d quad.Direction, val graph.Value) *Iterator
  • func (it *Iterator) Clone() graph.Iterator
  • func (it *Iterator) Close() error
  • func (it *Iterator) Contains(ctx context.Context, v graph.Value) bool
  • func (it *Iterator) Err() error
  • func (it *Iterator) Next(ctx context.Context) bool
  • func (it *Iterator) NextPath(ctx context.Context) bool
  • func (it *Iterator) Optimize() (graph.Iterator, bool)
  • func (it *Iterator) Reset()
  • func (it *Iterator) Result() graph.Value
  • func (it *Iterator) Size() (int64, bool)
  • func (it *Iterator) Sorted() bool
  • func (it *Iterator) Stats() graph.IteratorStats
  • func (it *Iterator) String() string
  • 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 LogEntry
• type MetadataEntry
• type NodeEntry
• type QuadEntry
• type QuadStore
  • func (qs *QuadStore) ApplyDeltas(in []graph.Delta, ignoreOpts graph.IgnoreOpts) error
  • func (qs *QuadStore) Close() error
  • func (qs *QuadStore) ForRequest(r *http.Request) (graph.QuadStore, error)
  • func (qs *QuadStore) NameOf(val graph.Value) quad.Value
  • func (qs *QuadStore) NodeSize() int64
  • func (qs *QuadStore) NodesAllIterator() graph.Iterator
  • func (qs *QuadStore) OptimizeIterator(it graph.Iterator) (graph.Iterator, bool)
  • func (qs *QuadStore) Quad(val graph.Value) quad.Quad
  • func (qs *QuadStore) QuadDirection(val graph.Value, dir quad.Direction) graph.Value
  • func (qs *QuadStore) QuadIterator(dir quad.Direction, v graph.Value) graph.Iterator
  • func (qs *QuadStore) QuadsAllIterator() graph.Iterator
  • func (qs *QuadStore) Size() int64
  • func (qs *QuadStore) ValueOf(s quad.Value) graph.Value
• type Token
  • func (t Token) IsNode() bool
  • func (t Token) Key() interface{}

Constants

const (
	QuadStoreType = "gaedatastore"
)

Types

type Config

type Config struct {
	DatabaseType       string
	DatabasePath       string
	DatabaseOptions    map[string]interface{}
	ReplicationType    string
	ReplicationOptions map[string]interface{}
	ListenHost         string
	ListenPort         string
	ReadOnly           bool
	Timeout            time.Duration
	LoadSize           int
}

Config defines the behavior of cayley database instances.

func LoadConf

func LoadConf(file string) (*Config, error)

Load reads a JSON-encoded config contained in the given file. A zero value config is returned if the filename is empty.

func (*Config) MarshalJSON

func (c *Config) MarshalJSON() ([]byte, error)

func (*Config) UnmarshalJSON

func (c *Config) UnmarshalJSON(data []byte) error

type Iterator

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

func NewAllIterator

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

func NewIterator

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

func (*Iterator) Clone

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

func (*Iterator) Close

func (it *Iterator) Close() error

func (*Iterator) Contains

func (it *Iterator) Contains(ctx context.Context, v graph.Value) bool

func (*Iterator) Err

func (it *Iterator) Err() error

func (*Iterator) Next

func (it *Iterator) Next(ctx context.Context) bool

func (*Iterator) NextPath

func (it *Iterator) NextPath(ctx context.Context) 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) Size

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

func (*Iterator) Sorted

func (it *Iterator) Sorted() bool

func (*Iterator) Stats

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

TODO (panamafrancis) calculate costs

func (*Iterator) String

func (it *Iterator) String() string

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 LogEntry

type LogEntry struct {
	Action    string
	Key       string
	Timestamp int64
}

type MetadataEntry

type MetadataEntry struct {
	NodeCount int64
	QuadCount int64
}

type NodeEntry

type NodeEntry struct {
	Name string
	Size int64
}

type QuadEntry

type QuadEntry struct {
	Hash      string
	Added     []int64 `datastore:",noindex"`
	Deleted   []int64 `datastore:",noindex"`
	Subject   string  `datastore:"subject"`
	Predicate string  `datastore:"predicate"`
	Object    string  `datastore:"object"`
	Label     string  `datastore:"label"`
}

type QuadStore

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

func (*QuadStore) ApplyDeltas

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

func (*QuadStore) Close

func (qs *QuadStore) Close() error

func (*QuadStore) ForRequest

func (qs *QuadStore) ForRequest(r *http.Request) (graph.QuadStore, error)

func (*QuadStore) NameOf

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

func (*QuadStore) NodeSize

func (qs *QuadStore) NodeSize() int64

func (*QuadStore) NodesAllIterator

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

func (*QuadStore) OptimizeIterator

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

func (*QuadStore) Quad

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

func (*QuadStore) QuadDirection

func (qs *QuadStore) QuadDirection(val graph.Value, dir quad.Direction) graph.Value

func (*QuadStore) QuadIterator

func (qs *QuadStore) QuadIterator(dir quad.Direction, v graph.Value) graph.Iterator

func (*QuadStore) QuadsAllIterator

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

func (*QuadStore) Size

func (qs *QuadStore) Size() int64

func (*QuadStore) ValueOf

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

type Token

type Token struct {
	Kind string
	Hash string
}

func (Token) IsNode

func (t Token) IsNode() bool

func (Token) Key

func (t Token) Key() interface{}