kv

package
v0.7.7 Latest Latest
Warning

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

 Go to latest Published: Oct 15, 2019 License: Apache-2.0 Imports: 24 Imported by: 70

Documentation

Index

Constants

View Source 
const (
	OptNoBloom = "no_bloom"
)

Variables

View Source 
var (
	DefaultQuadIndexes = []QuadIndex{

		{Dirs: []quad.Direction{quad.Subject, quad.Predicate}},

		{Dirs: []quad.Direction{quad.Object, quad.Predicate, quad.Subject}},
	}
)
View Source 
var ErrNoBucket = errors.New("kv: no bucket")

Functions

func Init 

func Init(kv kv.KV, opt graph.Options) error

func New 

func New(kv kv.KV, opt graph.Options) (graph.QuadStore, error)

func Register 

func Register(name string, r Registration)

Types

type AllIterator 

type AllIterator struct {
	graph.Iterator
	// contains filtered or unexported fields
}

func NewAllIterator 

func NewAllIterator(nodes bool, qs *QuadStore, cons *constraint) *AllIterator

func (*AllIterator) AsShape added in v0.7.6 

func (it *AllIterator) AsShape() graph.IteratorShape

func (*AllIterator) Sorted 

func (it *AllIterator) Sorted() bool

type IndexScan added in v0.7.6 

type IndexScan struct {
	Index  QuadIndex
	Values []uint64
}

func (IndexScan) BuildIterator added in v0.7.6 

func (s IndexScan) BuildIterator(qs graph.QuadStore) graph.Iterator

func (IndexScan) Optimize added in v0.7.6 

func (s IndexScan) Optimize(r shape.Optimizer) (shape.Shape, bool)

type InitFunc 

type InitFunc func(string, graph.Options) (kv.KV, error)

type Int64Set 

type Int64Set []uint64

func (Int64Set) Len 

func (a Int64Set) Len() int

func (Int64Set) Less 

func (a Int64Set) Less(i, j int) bool

func (Int64Set) Swap 

func (a Int64Set) Swap(i, j int)

type Int64Value 

type Int64Value uint64

func (Int64Value) Key 

func (v Int64Value) Key() interface{}

type NewFunc 

type NewFunc func(string, graph.Options) (kv.KV, error)

type QuadIndex 

type QuadIndex struct {
	Dirs   []quad.Direction `json:"dirs"`
	Unique bool             `json:"unique"`
}

func (QuadIndex) Key 

func (ind QuadIndex) Key(vals []uint64) kv.Key

func (QuadIndex) KeyFor 

func (ind QuadIndex) KeyFor(p *proto.Primitive) kv.Key

type QuadIterator 

type QuadIterator struct {
	graph.Iterator
	// contains filtered or unexported fields
}

func NewQuadIterator 

func NewQuadIterator(qs *QuadStore, ind QuadIndex, vals []uint64) *QuadIterator

func (*QuadIterator) AsShape added in v0.7.6 

func (it *QuadIterator) AsShape() graph.IteratorShape

func (*QuadIterator) Sorted 

func (it *QuadIterator) Sorted() bool

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) NameOf 

func (qs *QuadStore) NameOf(v graph.Ref) quad.Value

func (*QuadStore) NewQuadWriter added in v0.7.6 

func (qs *QuadStore) NewQuadWriter() (quad.WriteCloser, error)

func (*QuadStore) NodesAllIterator 

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

func (*QuadStore) OptimizeShape added in v0.7.6 

func (qs *QuadStore) OptimizeShape(s shape.Shape) (shape.Shape, bool)

func (*QuadStore) Quad 

func (qs *QuadStore) Quad(k graph.Ref) quad.Quad

func (*QuadStore) QuadDirection 

func (qs *QuadStore) QuadDirection(val graph.Ref, d quad.Direction) graph.Ref

func (*QuadStore) QuadIterator 

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

func (*QuadStore) QuadIteratorSize added in v0.7.6 

func (qs *QuadStore) QuadIteratorSize(ctx context.Context, d quad.Direction, v graph.Ref) (graph.Size, error)

func (*QuadStore) QuadsAllIterator 

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

func (*QuadStore) RefsOf added in v0.7.5 

func (qs *QuadStore) RefsOf(ctx context.Context, nodes []quad.Value) ([]graph.Ref, error)

func (*QuadStore) Size 

func (qs *QuadStore) Size() int64

func (*QuadStore) Stats added in v0.7.6 

func (qs *QuadStore) Stats(ctx context.Context, exact bool) (graph.Stats, error)

func (*QuadStore) ValueOf 

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

func (*QuadStore) ValuesOf 

func (qs *QuadStore) ValuesOf(ctx context.Context, vals []graph.Ref) ([]quad.Value, error)

type Registration 

type Registration struct {
	NewFunc      NewFunc
	InitFunc     InitFunc
	IsPersistent bool
}

Source Files

View all Source files

Directories

Path Synopsis

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.