leveldb

Documentation

Index

• Variables
• func NewLevelDB(path string) (database.Database, error)
• func NewTestDatabase() (db database.Database, dispose func())
• func StartMetrics(db database.Database, dbname string, log *log.ScdoLog)
• type Batch
  • func (b *Batch) Commit() error
  • func (b *Batch) Delete(key []byte)
  • func (b *Batch) Put(key []byte, value []byte)
  • func (b *Batch) Rollback()
• type DBMetrics
• type LevelDB
  • func (db *LevelDB) Close()
  • func (db *LevelDB) Delete(key []byte) error
  • func (db *LevelDB) DeleteSring(key string) error
  • func (db *LevelDB) Get(key []byte) ([]byte, error)
  • func (db *LevelDB) GetString(key string) (string, error)
  • func (db *LevelDB) Has(key []byte) (ret bool, err error)
  • func (db *LevelDB) HasString(key string) (ret bool, err error)
  • func (db *LevelDB) NewBatch() database.Batch
  • func (db *LevelDB) Put(key []byte, value []byte) error
  • func (db *LevelDB) PutString(key string, value string) error

Variables

var (
	// ErrEmptyKey key is empty
	ErrEmptyKey = errors.New("key could not be empty")
)

Functions

func NewLevelDB

func NewLevelDB(path string) (database.Database, error)

NewLevelDB constructs and returns a LevelDB instance

func NewTestDatabase

func NewTestDatabase() (db database.Database, dispose func())

NewTestDatabase creates a database instance under temp folder.

func StartMetrics

func StartMetrics(db database.Database, dbname string, log *log.ScdoLog)

StartMetrics create metrics and run a goroutine to collect

Types

type Batch

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

Batch implements batch for leveldb

func (*Batch) Commit

func (b *Batch) Commit() error

Commit commits batch operation.

func (*Batch) Delete

func (b *Batch) Delete(key []byte)

Delete deletes the value for the given key.

func (*Batch) Put

func (b *Batch) Put(key []byte, value []byte)

Put sets the value for the given key

func (*Batch) Rollback

func (b *Batch) Rollback()

Rollback rollbacks batch operation.

type DBMetrics

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

DBMetrics defines the metrics used by leveldb

type LevelDB

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

LevelDB wraps the leveldb

func (*LevelDB) Close

func (db *LevelDB) Close()

Close is used to close the db when not used

func (*LevelDB) Delete

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

Delete deletes the value for the given key.

func (*LevelDB) DeleteSring

func (db *LevelDB) DeleteSring(key string) error

DeleteSring deletes the value for the given key.

func (*LevelDB) Get

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

Get gets the value for the given key

func (*LevelDB) GetString

func (db *LevelDB) GetString(key string) (string, error)

GetString gets the value for the given key

func (*LevelDB) Has

func (db *LevelDB) Has(key []byte) (ret bool, err error)

Has returns true if the DB does contain the given key.

func (*LevelDB) HasString

func (db *LevelDB) HasString(key string) (ret bool, err error)

HasString returns true if the DB does contain the given key.

func (*LevelDB) NewBatch

func (db *LevelDB) NewBatch() database.Batch

NewBatch constructs and returns a batch object

func (*LevelDB) Put

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

Put sets the value for the given key

func (*LevelDB) PutString

func (db *LevelDB) PutString(key string, value string) error

PutString sets the value for the given key