kv

package

Go to main page

Versions in this module

v0

v0.7.7

Oct 15, 2019

v0.7.6

Oct 14, 2019

Changes in this version

+ const OptNoBloom

type AllIterator

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

+ type IndexScan struct

+ Index QuadIndex

+ Values []uint64

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

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

type QuadIterator

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

type QuadStore

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

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

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

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

v0.7.5

Nov 26, 2018

Changes in this version

type QuadStore

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

v0.7.4

Jun 3, 2018

v0.7.4-2

Nov 26, 2018

v0.7.3

Apr 23, 2018

v0.7.2

Mar 3, 2018

v0.7.1

Jan 30, 2018

v0.7.0

Dec 24, 2017

Changes in this version

+ var DefaultQuadIndexes = []QuadIndex

+ var ErrBucketExists = errors.New("kv: bucket already exists")

+ var ErrNoBucket = errors.New("kv: bucket is missing")

+ var ErrNotFound = errors.New("kv: not found")

+ func Each(ctx context.Context, b Bucket, pref []byte, fnc func(k, v []byte) error) error

+ func GetOne(ctx context.Context, b Bucket, key []byte) ([]byte, error)

+ func Init(kv BucketKV, opt graph.Options) error

+ func New(kv BucketKV, _ graph.Options) (graph.QuadStore, error)

+ func Register(name string, r Registration)

+ func Update(ctx context.Context, kv BucketKV, update func(tx BucketTx) error) error

+ func View(kv BucketKV, view func(tx BucketTx) error) error

+ type AllIterator struct

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

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

+ func (it *AllIterator) Close() error

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

+ func (it *AllIterator) Err() error

+ func (it *AllIterator) Next(ctx context.Context) bool

+ func (it *AllIterator) NextPath(ctx context.Context) bool

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

+ func (it *AllIterator) Reset()

+ func (it *AllIterator) Result() graph.Value

+ func (it *AllIterator) Size() (int64, bool)

+ func (it *AllIterator) Sorted() bool

+ func (it *AllIterator) Stats() graph.IteratorStats

+ func (it *AllIterator) String() string

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

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

+ func (it *AllIterator) Tagger() *graph.Tagger

+ func (it *AllIterator) Type() graph.Type

+ func (it *AllIterator) UID() uint64

+ type Base interface

+ Close func() error

+ Type func() string

+ type Bucket interface

+ Del func(k []byte) error

+ Get func(ctx context.Context, keys [][]byte) ([][]byte, error)

+ Put func(k, v []byte) error

+ Scan func(pref []byte) KVIterator

+ type BucketKV interface

+ Tx func(update bool) (BucketTx, error)

+ func FromFlat(flat FlatKV) BucketKV

+ type BucketKey struct

+ Bucket []byte

+ Key []byte

+ type BucketTx interface

+ Bucket func(name []byte) Bucket

+ Get func(ctx context.Context, keys []BucketKey) ([][]byte, error)

+ type FillBucket interface

+ SetFillPercent func(v float64)

+ type FlatKV interface

+ Tx func(update bool) (FlatTx, error)

+ type FlatTx interface

+ type InitFunc func(string, graph.Options) (BucketKV, error)

+ type Int64Set []uint64

+ func (a Int64Set) Len() int

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

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

+ type Int64Value uint64

+ func (v Int64Value) Key() interface{}

+ type KVIterator interface

+ Close func() error

+ Err func() error

+ Key func() []byte

+ Next func(ctx context.Context) bool

+ Val func() []byte

+ type NewFunc func(string, graph.Options) (BucketKV, error)

+ type QuadIndex struct

+ Dirs []quad.Direction

+ Unique bool

+ func (ind QuadIndex) Bucket() []byte

+ func (ind QuadIndex) Key(vals []uint64) []byte

+ func (ind QuadIndex) KeyFor(p *proto.Primitive) []byte

+ type QuadIterator struct

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

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

+ func (it *QuadIterator) Close() error

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

+ func (it *QuadIterator) Err() error

+ func (it *QuadIterator) Next(ctx context.Context) bool

+ func (it *QuadIterator) NextPath(ctx context.Context) bool

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

+ func (it *QuadIterator) Reset()

+ func (it *QuadIterator) Result() graph.Value

+ func (it *QuadIterator) Size() (int64, bool)

+ func (it *QuadIterator) Sorted() bool

+ func (it *QuadIterator) Stats() graph.IteratorStats

+ func (it *QuadIterator) String() string

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

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

+ func (it *QuadIterator) Tagger() *graph.Tagger

+ func (it *QuadIterator) Type() graph.Type

+ func (it *QuadIterator) UID() uint64

+ type QuadStore struct

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

+ func (qs *QuadStore) Close() error

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

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

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

+ func (qs *QuadStore) Quad(k graph.Value) quad.Quad

+ func (qs *QuadStore) QuadDirection(val graph.Value, d 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

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

+ type Registration struct

+ InitFunc InitFunc

+ IsPersistent bool

+ NewFunc NewFunc

+ type Tx interface

+ Commit func(ctx context.Context) error

+ Rollback func() error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL