db

package
v0.0.0-...-2fecb0d Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 19, 2017 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var OpenFileLimit = 64

Functions

This section is empty.

Types

type Batch

type Batch interface {
	Put(key, value []byte) error
	Write() error
}

type Database

type Database interface {
	Put(key []byte, value []byte) error
	Get(key []byte) ([]byte, error)
	Delete(key []byte) error
	Close()
	NewBatch() Batch
}

type LevelDB

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

func NewLevelDB

func NewLevelDB(file string, cache int, handles int) (*LevelDB, error)

NewLevelDB returns a LevelDB wrapped object.

func (*LevelDB) Close

func (self *LevelDB) Close()

func (*LevelDB) Delete

func (self *LevelDB) Delete(key []byte) error

Delete deletes the key from the queue and database

func (*LevelDB) Get

func (self *LevelDB) Get(key []byte) ([]byte, error)

Get returns the given key if it's present.

func (*LevelDB) LDB

func (self *LevelDB) LDB() *leveldb.DB

func (*LevelDB) NewBatch

func (db *LevelDB) NewBatch() Batch

func (*LevelDB) NewIterator

func (self *LevelDB) NewIterator() iterator.Iterator

func (*LevelDB) Put

func (self *LevelDB) Put(key []byte, value []byte) error

Put puts the given key / value to the queue

type MemDatabase

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

* This is a test memory database. Do not use for any production it does not get persisted

func NewMemDatabase

func NewMemDatabase() (*MemDatabase, error)

func (*MemDatabase) Close

func (db *MemDatabase) Close()

func (*MemDatabase) Delete

func (db *MemDatabase) Delete(key []byte) error

func (*MemDatabase) Get

func (db *MemDatabase) Get(key []byte) ([]byte, error)

func (*MemDatabase) Keys

func (db *MemDatabase) Keys() [][]byte

func (*MemDatabase) NewBatch

func (db *MemDatabase) NewBatch() Batch

func (*MemDatabase) Put

func (db *MemDatabase) Put(key []byte, value []byte) error

func (*MemDatabase) Set

func (db *MemDatabase) Set(key []byte, value []byte)

Jump to

Keyboard shortcuts

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