storm

package module

Go to main page

Versions in this module

v1

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

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