storm

package module

Go to main page

Versions in this module

v1

v1.1.0

Sep 9, 2017

Changes in this version

type DB

+ func (s *DB) Prefix(fieldName string, prefix string, to interface{}, ...) error

type Finder

+ Prefix func(fieldName string, prefix string, to interface{}, ...) error

v1.0.1

Jul 26, 2017

v1.0.0

Jul 16, 2017

v0

v0.8.1

Jun 1, 2017

v0.8.0

Apr 17, 2017

Changes in this version

type DB

+ func (s *DB) GetBytes(bucketName string, key interface{}) ([]byte, error)

+ func (s *DB) SetBytes(bucketName string, key interface{}, value []byte) error

type KeyValueStore

+ GetBytes func(bucketName string, key interface{}) ([]byte, error)

+ SetBytes func(bucketName string, key interface{}, value []byte) error

type Query

+ Each func(interface{}, func(interface{}) error) error

v0.7.0

Jan 7, 2017

v0.6.1

Oct 25, 2016

v0.6.0

Oct 12, 2016

Changes in this version

type DB

+ func (s *DB) ReIndex(data interface{}) error

type Query

+ OrderBy func(string) Query

type TypeStore

+ ReIndex func(data interface{}) error

v0.5.0

Oct 3, 2016

Changes in this version

+ var ErrDifferentCodec = errors.New("the selected codec is incompatible with this bucket")

+ func Batch() func(*DB) error

type DB

+ func (s *DB) WithBatch(enabled bool) Node

type Node

+ WithBatch func(enabled bool) Node

v0.4.1

Sep 23, 2016

v0.4.0

Sep 23, 2016

Changes in this version

+ const Version

+ var ErrAlreadyExists = errors.New("already exists")

+ var ErrBadType = errors.New("provided data must be a struct or a pointer to struct")

+ var ErrIdxNotFound = errors.New("index not found")

+ var ErrIncompatibleValue = errors.New("incompatible value")

+ var ErrNilParam = errors.New("param must not be nil")

+ var ErrNoID = errors.New("missing struct tag id or ID field")

+ var ErrNoName = errors.New("provided target must have a name")

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

+ var ErrNotInTransaction = errors.New("not in transaction")

+ var ErrPtrNeeded = errors.New("provided target must be a pointer to a valid variable")

+ var ErrSlicePtrNeeded = errors.New("provided target must be a pointer to slice")

+ var ErrStructPtrNeeded = errors.New("provided target must be a pointer to struct")

+ var ErrUnAddressable = errors.New("unaddressable value")

+ var ErrUnknownTag = errors.New("unknown tag")

+ var ErrZeroID = errors.New("id field must not be a zero value")

+ func AutoIncrement() func(*DB) error

+ func BoltOptions(mode os.FileMode, options *bolt.Options) func(*DB) error

+ func Codec(c codec.EncodeDecoder) func(*DB) error

+ func Limit(limit int) func(*index.Options)

+ func Reverse() func(*index.Options)

+ func Root(root ...string) func(*DB) error

+ func Skip(offset int) func(*index.Options)

+ func UseDB(b *bolt.DB) func(*DB) error

+ type BucketScanner interface

+ PrefixScan func(prefix string) []Node

+ RangeScan func(min, max string) []Node

+ type DB struct

+ Bolt *bolt.DB

+ Path string

+ func Open(path string, stormOptions ...func(*DB) error) (*DB, error)

+ func (s *DB) All(to interface{}, options ...func(*index.Options)) error

+ func (s *DB) AllByIndex(fieldName string, to interface{}, options ...func(*index.Options)) error

+ func (s *DB) Begin(writable bool) (Node, error)

+ func (s *DB) Bucket() []string

+ func (s *DB) Close() error

+ func (s *DB) Codec() codec.EncodeDecoder

+ func (s *DB) Commit() error

+ func (s *DB) Count(data interface{}) (int, error)

+ func (s *DB) CreateBucketIfNotExists(tx *bolt.Tx, bucket string) (*bolt.Bucket, error)

+ func (s *DB) Delete(bucketName string, key interface{}) error

+ func (s *DB) DeleteStruct(data interface{}) error

+ func (s *DB) Drop(data interface{}) error

+ func (s *DB) Find(fieldName string, value interface{}, to interface{}, ...) error

+ func (s *DB) From(root ...string) Node

+ func (s *DB) Get(bucketName string, key interface{}, to interface{}) error

+ func (s *DB) GetBucket(tx *bolt.Tx, children ...string) *bolt.Bucket

+ func (s *DB) Init(data interface{}) error

+ func (s *DB) One(fieldName string, value interface{}, to interface{}) error

+ func (s *DB) PrefixScan(prefix string) []Node

+ func (s *DB) Range(fieldName string, min, max, to interface{}, options ...func(*index.Options)) error

+ func (s *DB) RangeScan(min, max string) []Node

+ func (s *DB) Remove(data interface{}) error

+ func (s *DB) Rollback() error

+ func (s *DB) Save(data interface{}) error

+ func (s *DB) Select(matchers ...q.Matcher) Query

+ func (s *DB) Set(bucketName string, key interface{}, value interface{}) error

+ func (s *DB) Update(data interface{}) error

+ func (s *DB) UpdateField(data interface{}, fieldName string, value interface{}) error

+ func (s *DB) WithCodec(codec codec.EncodeDecoder) Node

+ func (s *DB) WithTransaction(tx *bolt.Tx) Node

+ type Finder interface

+ All func(to interface{}, options ...func(*index.Options)) error

+ AllByIndex func(fieldName string, to interface{}, options ...func(*index.Options)) error

+ Count func(data interface{}) (int, error)

+ Find func(fieldName string, value interface{}, to interface{}, ...) error

+ One func(fieldName string, value interface{}, to interface{}) error

+ Range func(fieldName string, min, max, to interface{}, options ...func(*index.Options)) error

+ Select func(matchers ...q.Matcher) Query

+ type KeyValueStore interface

+ Delete func(bucketName string, key interface{}) error

+ Get func(bucketName string, key interface{}, to interface{}) error

+ Set func(bucketName string, key interface{}, value interface{}) error

+ type Node interface

+ Begin func(writable bool) (Node, error)

+ Bucket func() []string

+ Codec func() codec.EncodeDecoder

+ CreateBucketIfNotExists func(tx *bolt.Tx, bucket string) (*bolt.Bucket, error)

+ From func(addend ...string) Node

+ GetBucket func(tx *bolt.Tx, children ...string) *bolt.Bucket

+ WithCodec func(codec codec.EncodeDecoder) Node

+ WithTransaction func(tx *bolt.Tx) Node

+ type Query interface

+ Bucket func(string) Query

+ Count func(interface{}) (int, error)

+ Delete func(interface{}) error

+ Find func(interface{}) error

+ First func(interface{}) error

+ Limit func(int) Query

+ Raw func() ([][]byte, error)

+ RawEach func(func([]byte, []byte) error) error

+ Reverse func() Query

+ Skip func(int) Query

+ type Tx interface

+ Commit func() error

+ Rollback func() error

+ type TypeStore interface

+ DeleteStruct func(data interface{}) error

+ Drop func(data interface{}) error

+ Init func(data interface{}) error

+ Remove func(data interface{}) error

+ Save func(data interface{}) error

+ Update func(data interface{}) error

+ UpdateField func(data interface{}, fieldName string, value interface{}) error

Incompatible versions in this module

v2.1.2+incompatible

Aug 29, 2018

v2.1.1+incompatible

Apr 30, 2018

v2.1.0+incompatible

Mar 11, 2018

v2.0.2+incompatible

Jan 6, 2018

v2.0.1+incompatible

Jan 6, 2018

v2.0.0+incompatible

Dec 3, 2017

v2.0.0-rc.1+incompatible

Nov 18, 2017

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