mdb

Aug 3, 2022

Changes in this version

type Database

+ func (db *Database) LogInfo() LogInfo

+ type LogInfo = kvstore.LogInfo

Jul 31, 2022

Changes in this version

type Database

+ func (db *Database) CleanBefore(seconds int64)

Jul 31, 2022

Changes in this version

type Database

+ func (db *Database) StoreDirect(collection string, id uint64, data []byte)

Jul 30, 2022

Changes in this version

+ var ErrAbortUpdate = errors.New("AbortUpdate")

+ var ErrDuplicate = errors.New("Duplicate")

+ var ErrMismatchedIDs = errors.New("MismatchedIDs")

+ var ErrNotFound = errors.New("NotFound")

+ var ErrReadOnly = errors.New("ReadOnly")

+ type BTreeIndex struct

+ func NewBTreeIndex(c *Collection[T], name string, less func(*T, *T) bool, include func(*T) bool) *BTreeIndex[T]

+ func (t *BTreeIndex[T]) Ascend() *BTreeIterator[T]

+ func (t *BTreeIndex[T]) AscendAfter(pivot T) *BTreeIterator[T]

+ func (t *BTreeIndex[T]) Descend() *BTreeIterator[T]

+ func (t *BTreeIndex[T]) DescendAfter(pivot T) *BTreeIterator[T]

+ func (t *BTreeIndex[T]) Get(item T) (T, bool)

+ func (t *BTreeIndex[T]) Len() int

+ func (t *BTreeIndex[T]) Max() (item T, ok bool)

+ func (t *BTreeIndex[T]) Min() (item T, ok bool)

+ type BTreeIterator struct

+ func (iter *BTreeIterator[T]) Close()

+ func (iter *BTreeIterator[T]) Next() bool

+ func (iter *BTreeIterator[T]) Value() T

+ type Collection struct

+ func NewCollection(db *Database, name string, getID func(*T) uint64) *Collection[T]

+ func (c *Collection[T]) Insert(item T) (T, error)

+ func (c *Collection[T]) NextID() uint64

+ func (c *Collection[T]) SetSanitize(sanitize func(*T))

+ func (c *Collection[T]) SetValidate(validate func(*T) error)

+ func (c *Collection[T]) Update(id uint64, update func(T) (T, error)) error

+ func (c Collection[T]) Delete(id uint64)

+ func (c Collection[T]) Get(id uint64) (t T, ok bool)

+ type Database struct

+ func NewPrimary(root string) *Database

+ func NewSecondary(root string) *Database

+ func (db *Database) Close()

+ func (db *Database) MaxSeqNum() uint64

+ func (db *Database) Start()

+ func (db *Database) SyncRecv(conn net.Conn)

+ func (db *Database) SyncSend(conn net.Conn)

+ type MapIndex struct

+ func NewMapIndex(c *Collection[T], name string, getKey func(*T) K, include func(*T) bool) *MapIndex[K, T]

+ func (m *MapIndex[K, T]) Delete(k K)

+ func (m *MapIndex[K, T]) Get(k K) (t T, ok bool)

+ func (m *MapIndex[K, T]) Update(k K, update func(T) (T, error)) error

+ type WALStatus struct

+ MaxSeqNumKV uint64

+ MaxSeqNumWAL uint64