memory

Documentation

Index

• func NewBatch(get GetFunc, commit CommitFunc) storage.KeyValueTxn
• type Batch
  • func (b *Batch) Commit() error
  • func (b *Batch) Copy() *Batch
  • func (b *Batch) Discard()
  • func (b *Batch) Get(key storage.Key) (v []byte, err error)
  • func (b *Batch) Put(key storage.Key, value []byte) error
  • func (b *Batch) PutAll(values map[storage.Key][]byte) error
• type CommitFunc
• type DB
  • func New(logger storage.Logger) *DB
  • func NewDB() *DB
  • func (db *DB) Begin(writable bool) storage.KeyValueTxn
  • func (m *DB) Close() error
  • func (m *DB) Copy() *DB
  • func (m *DB) Export() map[storage.Key][]byte
  • func (m *DB) MarshalJSON() ([]byte, error)
  • func (m *DB) Ready() bool
  • func (m *DB) UnmarshalJSON(b []byte) error
• type GetFunc

Functions

func NewBatch

func NewBatch(get GetFunc, commit CommitFunc) storage.KeyValueTxn

Types

type Batch

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

func (*Batch) Commit

func (b *Batch) Commit() error

func (*Batch) Copy

func (b *Batch) Copy() *Batch

func (*Batch) Discard

func (b *Batch) Discard()

func (*Batch) Get

func (b *Batch) Get(key storage.Key) (v []byte, err error)

func (*Batch) Put

func (b *Batch) Put(key storage.Key, value []byte) error

func (*Batch) PutAll

func (b *Batch) PutAll(values map[storage.Key][]byte) error

type CommitFunc

type CommitFunc func(map[storage.Key][]byte) error

type DB

type DB struct {
	DBOpen atomicBool
	// contains filtered or unexported fields
}

DB Implements a key value store in memory. Very basic, assumes no initial state for the database That must be handled by the caller, but see the notes on InitDB for future improvements.

func New

func New(logger storage.Logger) *DB

func NewDB

func NewDB() *DB

func (*DB) Begin

func (db *DB) Begin(writable bool) storage.KeyValueTxn

func (*DB) Close

func (m *DB) Close() error

Close Nothing really to do but to clear the Entries map

func (*DB) Copy

func (m *DB) Copy() *DB

Copy Make a copy of the database; a useful function for testing

func (*DB) Export

func (m *DB) Export() map[storage.Key][]byte

Export writes the database to a map

func (*DB) MarshalJSON

func (m *DB) MarshalJSON() ([]byte, error)

func (*DB) Ready

func (m *DB) Ready() bool

Ready Returns true if the database is open and ready to accept reads/writes

func (*DB) UnmarshalJSON

func (m *DB) UnmarshalJSON(b []byte) error

type GetFunc

type GetFunc func(storage.Key) ([]byte, error)