db

Documentation

Index

• Constants
• type EncryptedDB
  • func (encDB *EncryptedDB) AddMany(m map[utils.MyULID]string, txn *NTransaction) error
  • func (encDB *EncryptedDB) AddManySame(uids []utils.MyULID, v string, txn *NTransaction) (err error)
  • func (encDB *EncryptedDB) AddManyTrueMap(m map[utils.MyULID]string, txn *NTransaction) (err error)
  • func (encDB *EncryptedDB) Count(txn *NTransaction) int
  • func (encDB *EncryptedDB) Delete(key utils.MyULID, txn *NTransaction) error
  • func (encDB *EncryptedDB) DeleteMany(keys []utils.MyULID, txn *NTransaction) error
  • func (encDB *EncryptedDB) Exists(key utils.MyULID, txn *NTransaction) (bool, error)
  • func (encDB *EncryptedDB) Get(key utils.MyULID, dst []byte, txn *NTransaction) ([]byte, error)
  • func (encDB *EncryptedDB) KeyIterator(txn *NTransaction) *ULIDIterator
  • func (encDB *EncryptedDB) KeyValueIterator(txn *NTransaction) *ULIDIterator
  • func (encDB *EncryptedDB) ListKeys(txn *NTransaction) []utils.MyULID
  • func (encDB *EncryptedDB) ListKeysTo(txn *NTransaction, dest []utils.MyULID) []utils.MyULID
  • func (encDB *EncryptedDB) Prefix() string
  • func (encDB *EncryptedDB) Set(key utils.MyULID, value string, txn *NTransaction) error
• type NTransaction
  • func NewNTransaction(db *badger.DB, update bool) *NTransaction
  • func (txn *NTransaction) Commit(callback func(error)) error
  • func (txn *NTransaction) Delete(key string) (err error)
  • func (txn *NTransaction) Discard()
  • func (txn *NTransaction) Get(key string, dst []byte) ([]byte, error)
  • func (txn *NTransaction) HasUpdate() bool
  • func (txn *NTransaction) NewIterator(opt badger.IteratorOptions) *badger.Iterator
  • func (txn *NTransaction) Set(key, val string) error
• type PTransaction
  • func NewPTransaction(db *badger.DB, prefix string, update bool) *PTransaction
  • func PTransactionFrom(txn *NTransaction, prefix string) *PTransaction
  • func (txn *PTransaction) Commit(callback func(error)) (err error)
  • func (txn *PTransaction) Delete(key string) (err error)
  • func (txn *PTransaction) Discard()
  • func (txn *PTransaction) Get(key string, dst []byte) ([]byte, error)
  • func (txn *PTransaction) HasUpdate() bool
  • func (txn *PTransaction) Set(key, val string) (err error)
• type Partition
  • func NewEncryptedPartition(p Partition, secret *memguard.LockedBuffer) (Partition, error)
  • func NewPartition(parent *badger.DB, prefix string) Partition
• type ULIDIterator
  • func (i *ULIDIterator) Close()
  • func (i *ULIDIterator) IsDeleted() bool
  • func (i *ULIDIterator) Key() (uid utils.MyULID)
  • func (i *ULIDIterator) KeyInto(uid *utils.MyULID)
  • func (i *ULIDIterator) Next()
  • func (i *ULIDIterator) Rewind()
  • func (i *ULIDIterator) Valid() bool
  • func (i *ULIDIterator) Value(dst []byte) ([]byte, error)

Constants

const MaxInt = int(MaxUint >> 1)

const MaxUint = ^uint(0)

Types

type EncryptedDB

type EncryptedDB struct {
	// contains filtered or unexported fields
}

func (*EncryptedDB) AddMany

func (encDB *EncryptedDB) AddMany(m map[utils.MyULID]string, txn *NTransaction) error

func (*EncryptedDB) AddManySame

func (encDB *EncryptedDB) AddManySame(uids []utils.MyULID, v string, txn *NTransaction) (err error)

func (*EncryptedDB) AddManyTrueMap

func (encDB *EncryptedDB) AddManyTrueMap(m map[utils.MyULID]string, txn *NTransaction) (err error)

func (*EncryptedDB) Count

func (encDB *EncryptedDB) Count(txn *NTransaction) int

func (*EncryptedDB) Delete

func (encDB *EncryptedDB) Delete(key utils.MyULID, txn *NTransaction) error

func (*EncryptedDB) DeleteMany

func (encDB *EncryptedDB) DeleteMany(keys []utils.MyULID, txn *NTransaction) error

func (*EncryptedDB) Exists

func (encDB *EncryptedDB) Exists(key utils.MyULID, txn *NTransaction) (bool, error)

func (*EncryptedDB) Get

func (encDB *EncryptedDB) Get(key utils.MyULID, dst []byte, txn *NTransaction) ([]byte, error)

func (*EncryptedDB) KeyIterator

func (encDB *EncryptedDB) KeyIterator(txn *NTransaction) *ULIDIterator

func (*EncryptedDB) KeyValueIterator

func (encDB *EncryptedDB) KeyValueIterator(txn *NTransaction) *ULIDIterator

func (*EncryptedDB) ListKeys

func (encDB *EncryptedDB) ListKeys(txn *NTransaction) []utils.MyULID

func (*EncryptedDB) ListKeysTo

func (encDB *EncryptedDB) ListKeysTo(txn *NTransaction, dest []utils.MyULID) []utils.MyULID

func (*EncryptedDB) Prefix

func (encDB *EncryptedDB) Prefix() string

func (*EncryptedDB) Set

func (encDB *EncryptedDB) Set(key utils.MyULID, value string, txn *NTransaction) error

type NTransaction

type NTransaction struct {
	// contains filtered or unexported fields
}

func NewNTransaction

func NewNTransaction(db *badger.DB, update bool) *NTransaction

func (*NTransaction) Commit

func (txn *NTransaction) Commit(callback func(error)) error

func (*NTransaction) Delete

func (txn *NTransaction) Delete(key string) (err error)

func (*NTransaction) Discard

func (txn *NTransaction) Discard()

func (*NTransaction) Get

func (txn *NTransaction) Get(key string, dst []byte) ([]byte, error)

func (*NTransaction) HasUpdate

func (txn *NTransaction) HasUpdate() bool

func (*NTransaction) NewIterator

func (txn *NTransaction) NewIterator(opt badger.IteratorOptions) *badger.Iterator

func (*NTransaction) Set

func (txn *NTransaction) Set(key, val string) error

type PTransaction

type PTransaction struct {
	// contains filtered or unexported fields
}

func NewPTransaction

func NewPTransaction(db *badger.DB, prefix string, update bool) *PTransaction

func PTransactionFrom

func PTransactionFrom(txn *NTransaction, prefix string) *PTransaction

func (*PTransaction) Commit

func (txn *PTransaction) Commit(callback func(error)) (err error)

func (*PTransaction) Delete

func (txn *PTransaction) Delete(key string) (err error)

func (*PTransaction) Discard

func (txn *PTransaction) Discard()

func (*PTransaction) Get

func (txn *PTransaction) Get(key string, dst []byte) ([]byte, error)

func (*PTransaction) HasUpdate

func (txn *PTransaction) HasUpdate() bool

func (*PTransaction) Set

func (txn *PTransaction) Set(key, val string) (err error)

type Partition

type Partition interface {
	Prefix() string
	ListKeys(txn *NTransaction) []utils.MyULID
	ListKeysTo(txn *NTransaction, dest []utils.MyULID) []utils.MyULID
	Count(txn *NTransaction) int
	Delete(key utils.MyULID, txn *NTransaction) error
	DeleteMany(keys []utils.MyULID, txn *NTransaction) error
	Set(key utils.MyULID, value string, txn *NTransaction) error
	AddMany(m map[utils.MyULID]string, txn *NTransaction) error
	AddManySame(uids []utils.MyULID, v string, txn *NTransaction) error
	AddManyTrueMap(m map[utils.MyULID]string, txn *NTransaction) error
	Get(key utils.MyULID, dst []byte, txn *NTransaction) ([]byte, error)
	Exists(key utils.MyULID, txn *NTransaction) (bool, error)
	KeyIterator(txn *NTransaction) *ULIDIterator
	KeyValueIterator(txn *NTransaction) *ULIDIterator
}

func NewEncryptedPartition

func NewEncryptedPartition(p Partition, secret *memguard.LockedBuffer) (Partition, error)

func NewPartition

func NewPartition(parent *badger.DB, prefix string) Partition

type ULIDIterator

type ULIDIterator struct {
	// contains filtered or unexported fields
}

func (*ULIDIterator) Close

func (i *ULIDIterator) Close()

func (*ULIDIterator) IsDeleted

func (i *ULIDIterator) IsDeleted() bool

func (*ULIDIterator) Key

func (i *ULIDIterator) Key() (uid utils.MyULID)

func (*ULIDIterator) KeyInto

func (i *ULIDIterator) KeyInto(uid *utils.MyULID)

func (*ULIDIterator) Next

func (i *ULIDIterator) Next()

func (*ULIDIterator) Rewind

func (i *ULIDIterator) Rewind()

func (*ULIDIterator) Valid

func (i *ULIDIterator) Valid() bool

func (*ULIDIterator) Value

func (i *ULIDIterator) Value(dst []byte) ([]byte, error)