memory

Documentation

Index

• type ChangeSet
  • func NewChangeSet(prefix *record.Key, get GetFunc, commit CommitFunc) *ChangeSet
  • func (c *ChangeSet) Begin(prefix *record.Key, writable bool) keyvalue.ChangeSet
  • func (c *ChangeSet) Commit() error
  • func (c *ChangeSet) Delete(key *record.Key) error
  • func (c *ChangeSet) Discard()
  • func (c *ChangeSet) Get(key *record.Key) ([]byte, error)
  • func (c *ChangeSet) Put(key *record.Key, value []byte) error
• type CommitFunc
• type Database
  • func New(prefix *record.Key) *Database
  • func (d *Database) Begin(prefix *record.Key, writable bool) keyvalue.ChangeSet
  • func (d *Database) Export() ([]Entry, error)
  • func (d *Database) Import(entries []Entry) error
• type Entry
• type GetFunc

Types

type ChangeSet

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

ChangeSet is a key-value change set.

func NewChangeSet

func NewChangeSet(prefix *record.Key, get GetFunc, commit CommitFunc) *ChangeSet

func (*ChangeSet) Begin

func (c *ChangeSet) Begin(prefix *record.Key, writable bool) keyvalue.ChangeSet

Begin begins a nested change set.

func (*ChangeSet) Commit

func (c *ChangeSet) Commit() error

Commit commits pending changes to the parent store.

func (*ChangeSet) Delete

func (c *ChangeSet) Delete(key *record.Key) error

Delete deletes a key-value pair.

func (*ChangeSet) Discard

func (c *ChangeSet) Discard()

Discard discards pending changes.

func (*ChangeSet) Get

func (c *ChangeSet) Get(key *record.Key) ([]byte, error)

Get loads a value.

func (*ChangeSet) Put

func (c *ChangeSet) Put(key *record.Key, value []byte) error

Put stores a value.

type CommitFunc

type CommitFunc = func(map[[32]byte]Entry) error

type Database

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

func New

func New(prefix *record.Key) *Database

func (*Database) Begin

func (d *Database) Begin(prefix *record.Key, writable bool) keyvalue.ChangeSet

Begin begins a change set.

func (*Database) Export

func (d *Database) Export() ([]Entry, error)

Export exports the database as a set of entries. Behavior is undefined if the database was created with a prefix. Export may return an error in the future. Export is not safe to use concurrently.

func (*Database) Import

func (d *Database) Import(entries []Entry) error

Import imports a set of entries into the database. Behavior is undefined if the database was created with a prefix. Import is not safe to use concurrently.

type Entry

type Entry struct {
	Key    *record.Key
	Value  []byte
	Delete bool
}

Entry is a ChangeSet entry.

type GetFunc

type GetFunc = func(*record.Key) ([]byte, error)