db

Documentation

Index

• Variables
• func IPFSexport() error
• type KV
• type LevelDbStorage
  • func NewLevelDbStorage(path string, errorIfMissing bool) (*LevelDbStorage, error)
  • func (l *LevelDbStorage) Close()
  • func (l *LevelDbStorage) Get(key []byte) ([]byte, error)
  • func (l *LevelDbStorage) Info() string
  • func (l *LevelDbStorage) Iterate(f func([]byte, []byte)) error
  • func (l *LevelDbStorage) LevelDB() *leveldb.DB
  • func (l *LevelDbStorage) List(limit int) ([]KV, error)
  • func (l *LevelDbStorage) NewTx() (Tx, error)
  • func (l *LevelDbStorage) RawDump() error
  • func (l *LevelDbStorage) WithPrefix(prefix []byte) Storage
• type LevelDbStorageTx
  • func (tx *LevelDbStorageTx) Add(atx Tx)
  • func (l *LevelDbStorageTx) Close()
  • func (l *LevelDbStorageTx) Commit() error
  • func (l *LevelDbStorageTx) Get(key []byte) ([]byte, error)
  • func (tx *LevelDbStorageTx) Put(k, v []byte)
• type MemoryStorage
  • func NewMemoryStorage() *MemoryStorage
  • func (m *MemoryStorage) Close()
  • func (l *MemoryStorage) Get(key []byte) ([]byte, error)
  • func (l *MemoryStorage) Info() string
  • func (l *MemoryStorage) Iterate(f func([]byte, []byte)) error
  • func (l *MemoryStorage) List(limit int) ([]KV, error)
  • func (m *MemoryStorage) NewTx() (Tx, error)
  • func (m *MemoryStorage) WithPrefix(prefix []byte) Storage
• type MemoryStorageTx
  • func (tx *MemoryStorageTx) Add(atx Tx)
  • func (tx *MemoryStorageTx) Close()
  • func (tx *MemoryStorageTx) Commit() error
  • func (tx *MemoryStorageTx) Get(key []byte) ([]byte, error)
  • func (tx *MemoryStorageTx) Put(k, v []byte)
• type Storage
• type Tx

Variables

var ErrNotFound = errors.New("key not found")

Functions

func IPFSexport

func IPFSexport() error

Types

type KV

type KV struct {
	K []byte
	V []byte
}

type LevelDbStorage

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

func NewLevelDbStorage

func NewLevelDbStorage(path string, errorIfMissing bool) (*LevelDbStorage, error)

func (*LevelDbStorage) Close

func (l *LevelDbStorage) Close()

func (*LevelDbStorage) Get

func (l *LevelDbStorage) Get(key []byte) ([]byte, error)

Get retreives a value from a key in the mt.Lvl

func (*LevelDbStorage) Info

func (l *LevelDbStorage) Info() string

func (*LevelDbStorage) Iterate

func (l *LevelDbStorage) Iterate(f func([]byte, []byte)) error

func (*LevelDbStorage) LevelDB

func (l *LevelDbStorage) LevelDB() *leveldb.DB

func (*LevelDbStorage) List

func (l *LevelDbStorage) List(limit int) ([]KV, error)

func (*LevelDbStorage) NewTx

func (l *LevelDbStorage) NewTx() (Tx, error)

func (*LevelDbStorage) RawDump

func (l *LevelDbStorage) RawDump() error

func (*LevelDbStorage) WithPrefix

func (l *LevelDbStorage) WithPrefix(prefix []byte) Storage

type LevelDbStorageTx

type LevelDbStorageTx struct {
	*LevelDbStorage
	// contains filtered or unexported fields
}

func (*LevelDbStorageTx) Add

func (tx *LevelDbStorageTx) Add(atx Tx)

func (*LevelDbStorageTx) Close

func (l *LevelDbStorageTx) Close()

func (*LevelDbStorageTx) Commit

func (l *LevelDbStorageTx) Commit() error

func (*LevelDbStorageTx) Get

func (l *LevelDbStorageTx) Get(key []byte) ([]byte, error)

Get retreives a value from a key in the mt.Lvl

func (*LevelDbStorageTx) Put

func (tx *LevelDbStorageTx) Put(k, v []byte)

Insert saves a key:value into the mt.Lvl

type MemoryStorage

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

func NewMemoryStorage

func NewMemoryStorage() *MemoryStorage

func (*MemoryStorage) Close

func (m *MemoryStorage) Close()

func (*MemoryStorage) Get

func (l *MemoryStorage) Get(key []byte) ([]byte, error)

Get retreives a value from a key in the mt.Lvl

func (*MemoryStorage) Info

func (l *MemoryStorage) Info() string

func (*MemoryStorage) Iterate

func (l *MemoryStorage) Iterate(f func([]byte, []byte)) error

func (*MemoryStorage) List

func (l *MemoryStorage) List(limit int) ([]KV, error)

func (*MemoryStorage) NewTx

func (m *MemoryStorage) NewTx() (Tx, error)

func (*MemoryStorage) WithPrefix

func (m *MemoryStorage) WithPrefix(prefix []byte) Storage

type MemoryStorageTx

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

func (*MemoryStorageTx) Add

func (tx *MemoryStorageTx) Add(atx Tx)

func (*MemoryStorageTx) Close

func (tx *MemoryStorageTx) Close()

func (*MemoryStorageTx) Commit

func (tx *MemoryStorageTx) Commit() error

func (*MemoryStorageTx) Get

func (tx *MemoryStorageTx) Get(key []byte) ([]byte, error)

func (*MemoryStorageTx) Put

func (tx *MemoryStorageTx) Put(k, v []byte)

type Storage

type Storage interface {
	NewTx() (Tx, error)
	WithPrefix(prefix []byte) Storage
	Get([]byte) ([]byte, error)
	List(int) ([]KV, error)
	Close()
	Info() string
	Iterate(func([]byte, []byte)) error
}

type Tx

type Tx interface {
	Get([]byte) ([]byte, error)
	Put(k, v []byte)
	Add(Tx)
	Commit() error
	Close()
}