memdb

package module

Go to main page

Versions in this module

v1

v1.3.4

Oct 20, 2022

v1.3.3

Mar 14, 2022

Changes in this version

type MemDB

+ func (db *MemDB) DBSchema() *DBSchema

v1.3.2

Mar 12, 2021

v1.3.1

Jan 28, 2021

v1.3.0

Oct 6, 2020

Changes in this version

type Txn

+ func (txn *Txn) GetReverse(table, index string, args ...interface{}) (ResultIterator, error)

+ func (txn *Txn) Last(table, index string, args ...interface{}) (interface{}, error)

+ func (txn *Txn) LastWatch(table, index string, args ...interface{}) (<-chan struct{}, interface{}, error)

+ func (txn *Txn) ReverseLowerBound(table, index string, args ...interface{}) (ResultIterator, error)

v1.2.1

Apr 22, 2020

Changes in this version

type WatchSet

+ func (w WatchSet) WatchCh(ctx context.Context) <-chan error

v1.2.0

Apr 6, 2020

Changes in this version

type Txn

+ func (txn *Txn) Snapshot() *Txn

v1.1.2

Mar 30, 2020

v1.1.1

Mar 17, 2020

Changes in this version

+ type BoolFieldIndex struct

+ Field string

+ func (i *BoolFieldIndex) FromArgs(args ...interface{}) ([]byte, error)

+ func (i *BoolFieldIndex) FromObject(obj interface{}) (bool, []byte, error)

v1.1.0

Feb 19, 2020

Changes in this version

+ type Change struct

+ After interface{}

+ Before interface{}

+ Table string

+ func (m *Change) Created() bool

+ func (m *Change) Deleted() bool

+ func (m *Change) Updated() bool

+ type Changes []Change

type Txn

+ func (txn *Txn) Changes() Changes

+ func (txn *Txn) TrackChanges()

v1.0.4

Oct 17, 2019

v1.0.3

May 22, 2019

Changes in this version

type Txn

+ func (txn *Txn) LowerBound(table, index string, args ...interface{}) (ResultIterator, error)

v1.0.2

May 10, 2019

Changes in this version

+ type CompoundMultiIndex struct

+ AllowMissing bool

+ Indexes []Indexer

+ func (c *CompoundMultiIndex) FromArgs(args ...interface{}) ([]byte, error)

+ func (c *CompoundMultiIndex) FromObject(raw interface{}) (bool, [][]byte, error)

v1.0.1

Apr 18, 2019

Changes in this version

+ func IsIntType(k reflect.Kind) (size int, okay bool)

+ type IntFieldIndex struct

+ Field string

+ func (i *IntFieldIndex) FromArgs(args ...interface{}) ([]byte, error)

+ func (i *IntFieldIndex) FromObject(obj interface{}) (bool, []byte, error)

v1.0.0

Mar 22, 2019

Changes in this version

+ var ErrNotFound = fmt.Errorf("not found")

+ var MapType = reflect.MapOf(reflect.TypeOf(""), reflect.TypeOf("")).Kind()

+ func IsUintType(k reflect.Kind) (size int, okay bool)

+ type CompoundIndex struct

+ AllowMissing bool

+ Indexes []Indexer

+ func (c *CompoundIndex) FromArgs(args ...interface{}) ([]byte, error)

+ func (c *CompoundIndex) FromObject(raw interface{}) (bool, []byte, error)

+ func (c *CompoundIndex) PrefixFromArgs(args ...interface{}) ([]byte, error)

+ type ConditionalIndex struct

+ Conditional ConditionalIndexFunc

+ func (c *ConditionalIndex) FromArgs(args ...interface{}) ([]byte, error)

+ func (c *ConditionalIndex) FromObject(obj interface{}) (bool, []byte, error)

+ type ConditionalIndexFunc func(obj interface{}) (bool, error)

+ type DBSchema struct

+ Tables map[string]*TableSchema

+ func (s *DBSchema) Validate() error

+ type FieldSetIndex struct

+ Field string

+ func (f *FieldSetIndex) FromArgs(args ...interface{}) ([]byte, error)

+ func (f *FieldSetIndex) FromObject(obj interface{}) (bool, []byte, error)

+ type FilterFunc func(interface{}) bool

+ type FilterIterator struct

+ func NewFilterIterator(wrap ResultIterator, filter FilterFunc) *FilterIterator

+ func (f *FilterIterator) Next() interface{}

+ func (f *FilterIterator) WatchCh() <-chan struct{}

+ type IndexSchema struct

+ AllowMissing bool

+ Indexer Indexer

+ Name string

+ Unique bool

+ func (s *IndexSchema) Validate() error

+ type Indexer interface

+ FromArgs func(args ...interface{}) ([]byte, error)

+ type MemDB struct

+ func NewMemDB(schema *DBSchema) (*MemDB, error)

+ func (db *MemDB) Snapshot() *MemDB

+ func (db *MemDB) Txn(write bool) *Txn

+ type MultiIndexer interface

+ FromObject func(raw interface{}) (bool, [][]byte, error)

+ type PrefixIndexer interface

+ PrefixFromArgs func(args ...interface{}) ([]byte, error)

+ type ResultIterator interface

+ Next func() interface{}

+ WatchCh func() <-chan struct{}

+ type SingleIndexer interface

+ FromObject func(raw interface{}) (bool, []byte, error)

+ type StringFieldIndex struct

+ Field string

+ Lowercase bool

+ func (s *StringFieldIndex) FromArgs(args ...interface{}) ([]byte, error)

+ func (s *StringFieldIndex) FromObject(obj interface{}) (bool, []byte, error)

+ func (s *StringFieldIndex) PrefixFromArgs(args ...interface{}) ([]byte, error)

+ type StringMapFieldIndex struct

+ Field string

+ Lowercase bool

+ func (s *StringMapFieldIndex) FromArgs(args ...interface{}) ([]byte, error)

+ func (s *StringMapFieldIndex) FromObject(obj interface{}) (bool, [][]byte, error)

+ type StringSliceFieldIndex struct

+ Field string

+ Lowercase bool

+ func (s *StringSliceFieldIndex) FromArgs(args ...interface{}) ([]byte, error)

+ func (s *StringSliceFieldIndex) FromObject(obj interface{}) (bool, [][]byte, error)

+ func (s *StringSliceFieldIndex) PrefixFromArgs(args ...interface{}) ([]byte, error)

+ type TableSchema struct

+ Indexes map[string]*IndexSchema

+ Name string

+ func (s *TableSchema) Validate() error

+ type Txn struct

+ func (txn *Txn) Abort()

+ func (txn *Txn) Commit()

+ func (txn *Txn) Defer(fn func())

+ func (txn *Txn) Delete(table string, obj interface{}) error

+ func (txn *Txn) DeleteAll(table, index string, args ...interface{}) (int, error)

+ func (txn *Txn) DeletePrefix(table string, prefix_index string, prefix string) (bool, error)

+ func (txn *Txn) First(table, index string, args ...interface{}) (interface{}, error)

+ func (txn *Txn) FirstWatch(table, index string, args ...interface{}) (<-chan struct{}, interface{}, error)

+ func (txn *Txn) Get(table, index string, args ...interface{}) (ResultIterator, error)

+ func (txn *Txn) Insert(table string, obj interface{}) error

+ func (txn *Txn) LongestPrefix(table, index string, args ...interface{}) (interface{}, error)

+ type UUIDFieldIndex struct

+ Field string

+ func (u *UUIDFieldIndex) FromArgs(args ...interface{}) ([]byte, error)

+ func (u *UUIDFieldIndex) FromObject(obj interface{}) (bool, []byte, error)

+ func (u *UUIDFieldIndex) PrefixFromArgs(args ...interface{}) ([]byte, error)

+ type UintFieldIndex struct

+ Field string

+ func (u *UintFieldIndex) FromArgs(args ...interface{}) ([]byte, error)

+ func (u *UintFieldIndex) FromObject(obj interface{}) (bool, []byte, error)

+ type WatchSet map[<-chan struct{}]struct

+ func NewWatchSet() WatchSet

+ func (w WatchSet) Add(watchCh <-chan struct{})

+ func (w WatchSet) AddWithLimit(softLimit int, watchCh <-chan struct{}, altCh <-chan struct{})

+ func (w WatchSet) Watch(timeoutCh <-chan time.Time) bool

+ func (w WatchSet) WatchCtx(ctx context.Context) error

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