db

package

v0.0.6 Latest Latest Go to latest Published: Jul 9, 2019 License: GPL-3.0 Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/iden3/go-iden3

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func IPFSexport() error
type KV
type LevelDbStorage
- func NewLevelDbStorage(path string, errorIfMissing bool) (*LevelDbStorage, error)
type LevelDbStorageTx
type MemoryStorage
- func NewMemoryStorage() *MemoryStorage
type MemoryStorageTx
type Storage
type Tx

Constants ¶

This section is empty.

Variables ¶

View Source

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()
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL